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

using DBHelper;
using System;
using System.Collections.Generic;
using System.Linq;
using WCS.Core;
using WCS.Entity;
using WCS.Entity.Protocol;
using WCS.Entity.Protocol.SRM;
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.逻辑异常, GetType()));

            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";
        private readonly string Conv_1030 = "1030";
        private readonly string RGV8 = "RGV8";

        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()) return;

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

            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);
                if (string.IsNullOrEmpty(res.TunnelNum)) throw new Exception(LogHelper.SpliceLogMessage($"WMS未返回巷道", obj.Entity.CODE, WCS_EXCEPTIONTYPE.逻辑异常, GetType()));
                var tunnelNo = res.TunnelNum.Split(',').Select(v => "TY" + v).ToList();

                var tunnels = Device.Where(v => tunnelNo.Contains(v.CODE)).ToList();
                List<TunnelInfo> tunnelInfos = new List<TunnelInfo>();
                foreach (var item in tunnels)
                {
                    //找到空闲的取货点 先找到下一个路径点是当前巷道的设备
                    var q = Device.Where(p => p.PATHPOINTS.Any(d => d.NEXT == item))
                                    .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();//去一次重
                    if (q == null) continue;
                    var dev = Device.Where(p => p.CODE.StartsWith("G") && p.DEVICEGROUP.Any(d => d.MEMBER == q.Entity)).OrderBy(p => p.CODE).FirstOrDefault();

                    tunnelInfos.Add(new TunnelInfo
                    {
                        Tunnel = item,
                        taskIN = dev, //找到放货点设备所在组
                        SRM = Device.Where(p => p.IsSC()).FirstOrDefault(p => item.ROUTES.Any(d => d.NEXT.CODE == p.CODE)).Create<SRMDevice>()
                    });
                }
                //筛选出优先级最高的可用巷道
                var tunnelInfo = tunnelInfos.Where(v => { try { return v.SRM.Data3.SCAlarm == 0 && v.SRM.Data2.SRMMode == SCMode.远程; } catch { return false; } })
                                            .OrderBy(v => tunnelNo.IndexOf(v.Tunnel.CODE)).FirstOrDefault();
                if (tunnelInfo == null) throw new Exception(LogHelper.SpliceLogMessage("无可用巷道", obj.Entity.CODE, WCS_EXCEPTIONTYPE.逻辑异常, GetType()));

                //开始向设备中写入任务信息
                foreach (var dev in devs)
                {
                    var task = tasks.FirstOrDefault(p => p.ID == dev.Data2.Tasknum);
                    if ((task.TaskGroupKey.Contains($"{task.WMSTASK}_") || task.TaskGroupKey.Contains($"_{task.WMSTASK}"))) continue;
                    if (dev.Data2.Goodsend != task.ADDRNEXT.ToShort()) continue;
                    dev.Data.Tasknum = task.ID;
                    dev.Data.Goodsstart = Conv_1030.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 = $"下达从{Conv_1030}移动至{dev.Data.Goodsend}的PLC指令。同时将任务分配至[{ task.TUNNEL }]-[{task.DEVICE}]";
                    msg += $"[{dev.Data.Tasknum}][{Conv_1030}][{dev.Data.Goodsend}][{tunnelInfo.SRM.Entity.CODE}][{dev.Data.VoucherNo}[{dev.Data2.VoucherNo}]";

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

    [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);
                switch (task.ADDRFROM)
                {
                    case "1028":
                        break;

                    case "1029":
                        break;

                    default:
                        break;
                }
                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++;

                task.ADDRNEXT = next.FirstOrDefault().CODE;
                db.Default.SaveChanges();

                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 devCodes.Contains(dev.CODE);
        }

        private List<string> devCodes = new List<string>() {
            "1035",
            "1036",
            "1044",
            "1045",
            "1053",
            "1054",
            "1062",
            "1063",
        };
    }
}