YG-OPP-WCS/Projects/永冠OPP/WCS.Service/Works/Station/涂布出入库.cs

using DBHelper;
using System.Linq;
using WCS.Core;
using WCS.Entity;
using WCS.Entity.Protocol;
using WCS.Service.Extensions;

namespace WCS.Service.Works.Station
{
    /// <summary>
    /// 涂布出库分配出库口
    /// </summary>
    //[WorkTitle(typeof(ProductHandler), "涂布出库分配出库口")]
    public class 涂布出库分配出库口 : DeviceWork<StationDevice>
    {
        protected override void Do(StationDevice obj)
        {
            obj.EX(obj =>
            {
                if (!obj.Data2.Status.HasFlag(IstationStatus.光电状态)) throw new DoException("无光电");
                if (obj.Data3.Status.HasFlag(StationStatus.运行状态位)) throw new DoException("设备运行中");
                if (obj.Data.VoucherNo != obj.Data2.VoucherNo)
                    throw new WarnException($"等待任务[{obj.Data2.Tasknum}]执行--凭证号不一致[{obj.Data.VoucherNo}][{obj.Data2.VoucherNo}]");
                if (obj.Data2.Tasknum < 10000) throw new DoException("无任务");
                if (obj.Data2.Request != IstationRequest.请求分配目标地址) throw new WarnException("有任务无请求");

                DB.Do(db =>
                {
                    var task = db.Default.Set<WCS_TASK>().FirstOrDefault(v => v.TYPE == TaskType.出库 && v.SRMSTATION == obj.Entity.CODE && v.STATUS == WCS.Entity.TaskStatus.堆垛机完成);
                    var tasks = db.Default.Set<WCS_TASK>().Where(v => v.TaskGroupKey == task.TaskGroupKey);
                    if (tasks.Any(v => v.STATUS != WCS.Entity.TaskStatus.堆垛机完成 && v.STATUS != WCS.Entity.TaskStatus.执行中))
                        throw new WarnException("任务异常，同组任务状态不为堆垛机完成或执行中");
                    if (task == null) throw new WarnException("WCS无该任务信息");
                    if (task.SRMSTATION != obj.Entity.CODE && task.STATUS != WCS.Entity.TaskStatus.堆垛机完成) throw new WarnException("任务状态不是堆垛机完成");
                    task.STATUS = WCS.Entity.TaskStatus.执行中;
                    db.Default.SaveChanges();
                    task.CreateStatusLog(db, $"状态由[{WCS.Entity.TaskStatus.堆垛机完成}]变更为[{task.STATUS}]-{obj.Entity.Code}", this.GetType());
                    //开始写入目标地址
                    obj.Data.Tasknum = task.ID;
                    obj.Data.Goodsstart = obj.Entity.CODE.ToShort();
                    obj.Data.Goodsend = task.ADDRNEXT.ToShort();
                    obj.Data.CmdType = IstationCmdType.堆垛机放货完成请求目标地址;
                    obj.Data.VoucherNo++;
                });
            });
        }

        protected override bool SelectDevice(WCS_DEVICE dev)
        {
            return dev.Is(DF.涂布出库取货站台);
        }
    }

    /// <summary>
    /// 涂布出库分配AGV取货点
    /// </summary>
    //[WorkTitle(typeof(ProductHandler), "涂布出库分配AGV取货点")]
    public class 涂布出库分配AGV取货点 : DeviceWork<StationDevice>
    {
        protected override void Do(StationDevice obj)
        {
            obj.EX(obj =>
            {
                if (!obj.Data2.Status.HasFlag(IstationStatus.光电状态)) throw new DoException("无光电");
                if (obj.Data3.Status.HasFlag(StationStatus.运行状态位)) throw new DoException("设备运行中");
                if (obj.Data.VoucherNo != obj.Data2.VoucherNo)
                    throw new WarnException($"等待任务[{obj.Data2.Tasknum}]执行--凭证号不一致[{obj.Data.VoucherNo}][{obj.Data2.VoucherNo}]");
                if (obj.Data2.Tasknum < 10000) throw new DoException("无任务");
                if (obj.Data2.Request != IstationRequest.请求分配目标地址) throw new WarnException("有任务无请求");

                DB.Do(db =>
                {
                    var task = db.Default.Set<WCS_TASK>().FirstOrDefault(v => v.TYPE == TaskType.出库 && v.SRMSTATION == obj.Entity.CODE && v.STATUS == WCS.Entity.TaskStatus.执行中);
                    if (task == null) throw new WarnException("WCS无该任务信息");

                    //全部统一分配目标地址至

                    db.Default.SaveChanges();
                    task.CreateStatusLog(db, $"状态由[{WCS.Entity.TaskStatus.堆垛机完成}]变更为[{task.STATUS}]-{obj.Entity.Code}", this.GetType());
                    //开始写入目标地址
                    obj.Data.Tasknum = task.ID;
                    obj.Data.Goodsstart = obj.Entity.CODE.ToShort();
                    obj.Data.Goodsend = task.ADDRNEXT.ToShort();
                    obj.Data.CmdType = IstationCmdType.堆垛机放货完成请求目标地址;
                    obj.Data.VoucherNo++;
                });
            });
        }

        protected override bool SelectDevice(WCS_DEVICE dev)
        {
            return dev.CODE == "1332" || dev.CODE == "1333";
        }
    }
}