YG-OPP-WCS/Projects/永冠OPP/WCS.Service/Works/Station/一楼入库.cs

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

namespace WCS.Service.Works.Station
{
    [WorkTitle(typeof(ProductHandler), "一楼入库扫码")]
    internal class 一楼入库 : DeviceWork<StationDevice>
    {
        private readonly string Conv_1028 = "1028";
        private readonly string Conv_1029 = "1029";

        protected override bool SelectDevice(WCS_DEVICE dev)
        {
            return dev.CODE == Conv_1028 || dev.CODE == Conv_1029;
        }

        protected override void Do(StationDevice dev)
        {
            var code = dev.Entity.CODE;
            if (dev.WhetherToExecute(IstationRequest.扫码入库)) return;

            var bcr = dev.Entity.BCR();
            var barcode = bcr.Content.Trim('\r');
            if (barcode == "") throw new Exception(LogHelper.SpliceLogMessage("扫码失败", dev.Entity.CODE, WCS_EXCEPTIONTYPE.逻辑异常));

            var info = WMS.I_WCS_GetInTask(barcode, dev.Entity.CODE);
            var next = dev.Entity.CODE == Conv_1028 ? "1030" : "1031";
            var station = dev.Entity.CODE;
            DB.Do(db =>
            {
                var task = new WCS_TASK();
                task.BARCODE = info.ContainerCode;
                task.TYPE = TaskType.入库;
                task.STATUS = TaskStatus.执行中;
                task.ADDRFROM = dev.Entity.CODE;
                task.ADDRTO = info.EndPostion;
                task.STARTTIME = DateTime.Now;
                task.UPDATEUSER = "WCS";
                task.UPDATETIME = DateTime.Now;
                task.WMSTASK = int.Parse(info.WMSTaskNum);
                task.TaskGroupKey = info.TaskGroupKey;
                task.ADDRNEXT = next;

                db.Default.Set<WCS_TASK>().Add(task);
                db.Default.SaveChanges();

                dev.Data.Tasknum = task.ID;
                dev.Data.Goodsstart = task.ADDRFROM.ToShort();
                dev.Data.Goodsend = task.ADDRNEXT.ToShort();
                dev.Data.CmdType = IstationCmdType.扫码入库;
                dev.Data.VoucherNo++;

                var msg = $"下达从{dev.Entity.CODE}移动至{next}的PLC指令。";
                msg += $"[{dev.Data.Tasknum}][{dev.Data.Goodsstart}][{dev.Data.Goodsend}][{dev.Data.VoucherNo}[{dev.Data2.VoucherNo}]";

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

    [WorkTitle(typeof(ProductHandler), "一楼分配巷道")]
    internal class 巷道分配 : Work<StationDeviceGroup>
    {
        private readonly string ConvGroup_1030 = "G1030";

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

        protected override void Do(StationDeviceGroup obj)
        {
            var code = obj.Entity.CODE;
            //当前组有一个运行的设备就停止执行
            if (obj.WhetherToExecute(IstationRequest.请求分配目标地址)) return;

            //获取需要进行巷道分配的设备
            var devs = obj.TaskedDeviceGetNextAddress() ?? throw new Exception(LogHelper.SpliceLogMessage("无可用任务", obj.Entity.CODE, WCS_EXCEPTIONTYPE.逻辑异常));

            DB.Do(db =>
            {
                var taskIds = devs.Select(p => p.Data2.Tasknum);
                var tasks = db.Default.Set<WCS_TASK>().Where(p => taskIds.Any(v => v == p.ID)).ToList();
                var res = WMS.GetTunnelList(tasks.Select(v => v.WMSTASK.ToString()).ToList(), code);
                var tunnels = res.TunnelNum.Split(',').Select(v => "TY" + v).ToList();
                //var tunnels = "5,6".Split(',').Select(v => "TY" + v).ToList();

                //筛选出优先级最高的可用巷道
                var tunnelInfo = Device.Where(v => tunnels.Contains(v.CODE)).Select(v =>
                                        {
                                            var a = Device.Where(p => p.PATHPOINTS.Any(d => d.NEXT == v))
                                                            .SelectMany(p => p.PATHPOINTS) //将所有取货点的路线信息提取到一个集合中
                                                            .Select(p => p.PREV.Create<StationDevice>())//取出所有取货点的前一个路径点
                                                            .Where(p => !p.Data3.Status.HasFlag(StationStatus.运行状态位) && !p.Data2.Status.HasFlag(IstationStatus.光电状态) && p.Data2.Tasknum < 10000);

                                            //找到空闲的取货点 先找到下一个路径点是当前巷道的设备
                                            var dev = Device.Where(p => p.PATHPOINTS.Any(d => d.NEXT == v))
                                                            .SelectMany(p => p.PATHPOINTS) //将所有取货点的路线信息提取到一个集合中
                                                            .Select(p => p.PREV.Create<StationDevice>())//取出所有取货点的前一个路径点
                                                            .Where(p => !p.Data3.Status.HasFlag(StationStatus.运行状态位) && !p.Data2.Status.HasFlag(IstationStatus.光电状态) && p.Data2.Tasknum < 10000)//筛选出空闲的路径点，此处因输送机都是一个动力，因此可以先找路径点再找设备组
                                                            .Where(p => Device.Where(d => d.CODE.StartsWith("G")).Any(d => d.DEVICEGROUP.Any(c => c.MEMBER == p.Entity)))//找到有效路径点对应的设备组
                                                            .Distinct().FirstOrDefault().Entity;//去一次重
                                            dev = Device.Where(p => p.CODE.StartsWith("G") && p.DEVICEGROUP.Any(d => d.MEMBER == dev)).OrderBy(p => p.CODE).FirstOrDefault();
                                            return new TunnelInfo
                                            {
                                                Tunnel = v,
                                                taskIN = dev, //找到放货点设备所在组
                                                SRM = Device.Where(p => p.IsSC()).FirstOrDefault(p => v.ROUTES.Any(d => d.NEXT.CODE == p.CODE)).Create<SRMDevice>()
                                            };
                                        })
                                        //TODO:正式使用时必须启用这下一行的堆垛机状态判断
                                        //.Where(v => v.SRM.Data2.Alarm_1 == false && v.SRM.Data2.Alarm_2 && v.SRM.Data2.Mode_1 == SCMode.远程 && v.SRM.Data2.Mode_2 == SCMode.远程)
                                        .OrderBy(v => tunnels.IndexOf(v.Tunnel.CODE)).FirstOrDefault();
                //开始向设备中写入任务信息
                foreach (var dev in devs)
                {
                    var task = tasks.FirstOrDefault(p => p.ID == dev.Data2.Tasknum);
                    dev.Data.Tasknum = task.ID;
                    dev.Data.Goodsstart = dev.Entity.CODE.ToShort();
                    dev.Data.Goodsend = tunnelInfo.taskIN.CODE.Replace("G", "").ToShort();
                    dev.Data.CmdType = IstationCmdType.分配目标地址;
                    dev.Data.VoucherNo++;

                    task.DEVICE = tunnelInfo.SRM.Entity.CODE;
                    task.TUNNEL = tunnelInfo.Tunnel.CODE;
                    task.ADDRNEXT = dev.Data.Goodsend.ToString();
                    task.TaskGroupKey = res.WMSTaskGroupKey;
                    task.ADDRTO = task.DEVICE;
                    db.Default.SaveChanges();

                    var msg = $"下达从{dev.Data.Goodsstart}移动至{dev.Data.Goodsend}的PLC指令。同时将任务分配至[{ task.TUNNEL }]-[{task.DEVICE}]";
                    msg += $"[{dev.Data.Tasknum}][{dev.Data.Goodsstart}][{dev.Data.Goodsend}][{dev.Data.VoucherNo}[{dev.Data2.VoucherNo}]";

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

        private class TunnelInfo
        {
            public WCS_DEVICE Tunnel;
            public WCS_DEVICE taskIN;
            public Device<ISRM520, ISRM521, ISRM537> SRM;
        }
    }

    [WorkTitle(typeof(ProductHandler), "一楼RGV放货结束分配目标地址")]
    internal class 一楼RGV放货结束分配目标地址 : DeviceWork<StationDevice>
    {
        protected override void Do(StationDevice obj)
        {
            var code = obj.Entity.CODE;
            if (obj.WhetherToExecute(IstationRequest.请求分配目标地址)) return;

            DB.Do(db =>
            {
                var task = db.Default.Set<WCS_TASK>().FirstOrDefault(v => v.ID == obj.Data2.Tasknum);
                var next = obj.Entity.GetPath(task.ADDRTO);

                obj.Data.Tasknum = task.ID;
                obj.Data.Goodsstart = obj.Entity.CODE.ToShort();
                obj.Data.Goodsend = next.FirstOrDefault().CODE.ToShort();
                obj.Data.CmdType = IstationCmdType.分配目标地址;
                obj.Data.VoucherNo++;

                var msg = $"下达从{obj.Data.Goodsstart}移动至{obj.Data.Goodsend}的PLC指令";
                msg += $"[{obj.Data.Tasknum}][{obj.Data.Goodsstart}][{obj.Data.Goodsend}][{obj.Data.VoucherNo}[{obj.Data2.VoucherNo}]";

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

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