YG-OPP-WCS/Projects/永冠OPP/WCS.Service/Works/Station/合流入库.cs

using DBHelper;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WCS.Core;
using WCS.Entity;
using WCS.Entity.Protocol;
using WCS.Service.Extensions;
using WCS.Service.Helpers;
using WCS.Service.Log;

namespace WCS.Service.Works.Station
{
    [WorkTitle(typeof(ProductHandler), "合流入库")]
    internal class 合流入库 : DeviceWork<Device<IStation520, IStation521, IStation523>>
    {
        protected override void Do(Device<IStation520, IStation521, IStation523> dev)
        {
            if (Ltc.Do(dev, v => v.Data2.VoucherNo != v.Data.VoucherNo)) throw new WarnException($"等待任务执行--凭证号不一致");
            if (Ltc.Do(dev, v => v.Data3.Status.HasFlag(StationStatus.运行状态位))) throw new WarnException($"设备运行中");
            if (Ltc.Do(dev, v => v.Data2.Status.HasFlag(IstationStatus.光电状态) == false)) return;
            if (Ltc.Do(dev, v => v.Data2.Tasknum < 10000)) return;
            if (Ltc.Do(dev, v => v.Data2.Request != IstationRequest.请求分配目标地址)) return;
            if (dev.Entity.CODE == "3163")
            {
                InfoLog.INFO_INFO($"已扫码等待分配目标地址，[{dev.Entity.CODE}写入信息:当前任务号[{dev.Data2.Tasknum}]-凭证号[{dev.Data2.VoucherNo}]");
            }


            var bcr = dev.Entity.BCR();
            var barcode = bcr.Content.Trim('\r');
            if (barcode == "")                 
            {
                InfoLog.INFO_WarnDb($"{dev.Entity.CODE}--扫码失败，内容为空", dev.Entity.CODE, WCS_EXCEPTIONTYPE.设备异常);
                return;
            };
            var res = WMS.GetSingleOrDouble(barcode,dev.Entity.CODE);
            if (res == null) throw new WarnException($"{dev.Entity.CODE}: WMS未返回结果");
            DB.Do(db =>
            {
                var task = db.Default.Set<WCS_TASK>().FirstOrDefault(v => v.ID == dev.Data2.Tasknum);
                if(task == null) throw new Exception($"任务号不存在");
                dev.Data.Tasknum = dev.Data2.Tasknum;
                dev.Data.Goodsnum = res.Root.ToShort();
                if (dev.Entity.CODE == "3163")
                {
                    dev.Data.Goodsend = Device.Find(task.ADDRNEXT).GetPath("SRM").CODE.ToShort();
                }
                dev.Data.VoucherNo++;
                if (dev.Entity.CODE == "3163")
                {
                    InfoLog.INFO_INFO($"[{dev.Entity.CODE}]写入信息:[{dev.Data2.Tasknum}]-[{dev.Data.VoucherNo}]");
                }
            });
        }
        protected override bool SelectDevice(WCS_DEVICE dev)
        {
            return new string[] { "3047","3163" }.Contains(dev.CODE);
        }
    }
}