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;
using WCS.Service.Helpers;

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是自动且空闲的
            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;
        }
    }
}