YG-OPP-WCS/Projects/永冠OPP/WCS.Service/Works/RGV/RGVWorks.cs

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

namespace WCS.Service.Works.RGV
{
    [WorkTitle(typeof(RGVHandler), "直穿RGV")]
    public class 直穿RGV : DeviceWork<RGVDevice>
    {
        private readonly string ConvGroup_1030 = "G1030";
        private readonly string RGV8 = "RGV8";

        protected override void Do(RGVDevice rgv)
        {
            rgv.EX(rgv =>
            {
                //RGV是自动且空闲的
                if (rgv.Data2.WorkMode != WCS.Entity.Protocol.RGV.RGVMode.自动) return;
                if (rgv.Data2.SystemStatus != WCS.Entity.Protocol.RGV.RGVRunStatus.空闲) return;

                var obj = Device.Find(ConvGroup_1030).Create<StationDeviceGroup>();

                obj.WhetherToExecute();

                //筛选出有任务号和起始及目标地址的设备
                var dev = obj.RGVGetTaskedDevice() ?? throw new WarnException("无可用任务");

                DB.Do(db =>
                {
                    var taskids = dev.Select(v => v.Data2.Tasknum);
                    var tasks = db.Default.Set<WCS_TASK>().Where(p => taskids.Contains(p.ID));
                    if (tasks.GroupBy(p => p.TaskGroupKey).Count() > 1)
                        throw new WarnException("任务组ID不一致");
                    if (tasks.GroupBy(p => p.TaskGroupKey).Count() == 0)
                        throw new WarnException("无任务组ID");
                    var gw1 = obj.Items.ToArray()[0];
                    var gw2 = obj.Items.ToArray()[1];
                    if (gw1.Data2.Tasknum != 0 && gw2.Data2.Tasknum != 0)
                    {
                        if (gw1.Data2.Goodsend != gw2.Data2.Goodsend) throw new WarnException($"{obj.Entity.Code}目标地址不一致");
                    }
                    rgv.Data.TaskID_1 = gw1.Data2.Tasknum;
                    rgv.Data.TaskID_2 = gw2.Data2.Tasknum;
                    if (gw1.Data2.Tasknum != 0)
                    {
                        rgv.Data.StartPosition_1 = gw1.Entity.CODE.ToShort();
                        rgv.Data.DestPosition_1 = gw1.Data2.Goodsend;
                    }
                    else
                    {
                        rgv.Data.StartPosition_1 = gw1.Entity.CODE.ToShort();
                        rgv.Data.DestPosition_1 = gw2.Data2.Goodsend;
                    }
                    rgv.Data.Trigger_1++;

                    foreach (var task in tasks)
                    {
                        var msg = $"下达从{rgv.Data.StartPosition_1}移动至{ rgv.Data.DestPosition_1}的RGV PLC指令。";
                        msg += $"[{ task.ID}][{rgv.Data.StartPosition_1}][{rgv.Data.DestPosition_1}[{ rgv.Data.Trigger_1}]";

                        task.CreateStatusLog(db, msg, this.GetType());
                    }
                });
            });
        }

        protected override bool SelectDevice(WCS_DEVICE dev)
        {
            return dev.CODE == RGV8;
        }
    }

    //[WorkTitle(typeof(RGVHandler), "直穿RGV")]
    //public class 直穿RGV : DeviceWork<RGVDevice>
    //{
    //    private readonly string ConvGroup_1030 = "G1030";
    //    private readonly string RGV8 = "RGV8";

    //    protected override void Do(RGVDevice rgv)
    //    {
    //        //RGV是自动且空闲的
    //        if (rgv.Data2.WorkMode != WCS.Entity.Protocol.RGV.RGVMode.自动) return;
    //        if (rgv.Data2.SystemStatus != WCS.Entity.Protocol.RGV.RGVRunStatus.空闲) return;

    //        var obj = Device.Find(ConvGroup_1030).Create<StationDeviceGroup>();

    //        if (obj.WhetherToExecute()) return;

    //        //筛选出有任务号和起始及目标地址的设备
    //        var dev = obj.RGVGetTaskedDevice() ?? throw new Exception(LogHelper.SpliceLogMessage("无可用任务", rgv.Entity.CODE, WCS_EXCEPTIONTYPE.逻辑异常, GetType()));

    //        DB.Do(db =>
    //        {
    //            var taskids = dev.Select(v => v.Data2.Tasknum);
    //            var tasks = db.Default.Set<WCS_TASK>().Where(p => taskids.Contains(p.ID));
    //            if (tasks.GroupBy(p => p.TaskGroupKey).Count() > 1)
    //                throw new Exception(LogHelper.SpliceLogMessage("任务组ID不一致", obj.Entity.CODE, WCS_EXCEPTIONTYPE.逻辑异常, GetType()));
    //            if (tasks.GroupBy(p => p.TaskGroupKey).Count() == 0)
    //                throw new Exception(LogHelper.SpliceLogMessage("无任务组ID", obj.Entity.CODE, WCS_EXCEPTIONTYPE.逻辑异常, GetType()));
    //            var gw1 = obj.Items.ToArray()[0];
    //            var gw2 = obj.Items.ToArray()[1];
    //            if (gw1.Data2.Tasknum != 0 && gw2.Data2.Tasknum != 0)
    //            {
    //                if (gw1.Data2.Goodsend != gw2.Data2.Goodsend) throw new Exception(LogHelper.SpliceLogMessage($"{obj.Entity.Code}目标地址不一致", obj.Entity.CODE, WCS_EXCEPTIONTYPE.逻辑异常, GetType()));
    //            }
    //            rgv.Data.TaskID_1 = gw1.Data2.Tasknum;
    //            rgv.Data.TaskID_2 = gw2.Data2.Tasknum;
    //            if (gw1.Data2.Tasknum != 0)
    //            {
    //                rgv.Data.StartPosition_1 = gw1.Entity.CODE.ToShort();
    //                rgv.Data.DestPosition_1 = gw1.Data2.Goodsend;
    //            }
    //            else
    //            {
    //                rgv.Data.StartPosition_1 = gw1.Entity.CODE.ToShort();
    //                rgv.Data.DestPosition_1 = gw2.Data2.Goodsend;
    //            }
    //            rgv.Data.Trigger_1++;

    //            foreach (var task in tasks)
    //            {
    //                var msg = $"下达从{rgv.Data.StartPosition_1}移动至{ rgv.Data.DestPosition_1}的RGV PLC指令。";
    //                msg += $"[{ task.ID}][{rgv.Data.StartPosition_1}][{rgv.Data.DestPosition_1}[{ rgv.Data.Trigger_1}]";

    //                task.CreateStatusLog(db, msg, this.GetType());
    //            }
    //        });
    //    }

    //    protected override bool SelectDevice(WCS_DEVICE dev)
    //    {
    //        return dev.CODE == RGV8;
    //    }
    //}
}