YG-OPP-WCS/Projects/永冠OPP/WCS.Service/Works/SRM/SRMWork.cs

using DBHelper;
using Microsoft.EntityFrameworkCore;
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.Entity;
using WCS.Service.Extensions;
using WCS.Service.Handlers;
using WCS.Service.Helpers;
using WCS.Service.Log;

namespace WCS.Service.Works.SRM
{
    [WorkTitle(typeof(SRMHandler), "堆垛机")]
    internal class SRMWork : DeviceWork<SRMDevice>
    {
        //月台发货需要的设备
        private StationDevice[] DockDevs;

        public SRMWork()
        {
            //只取设备组 设备过多，先写程序后填写
            DockDevs = new string[]
            {
            }.Select(v => Device.Find(v)).SelectMany(v => v.DEVICEGROUP).Select(v => v.MEMBER.Create<StationDevice>()).ToArray();
        }

        protected override void Do(SRMDevice obj)
        {
            obj.EX(obj =>
            {
                var deviceCode = obj.Entity.CODE;
                //先检查堆垛机是否报警
                if (obj.Data3.SCAlarm != 0)
                {
                    if (obj.Entity.WakeupOn(5000)) WMS.DevInfo(obj.Entity.CODE, obj.Data3.SCAlarm.ToString());
                    InfoLog.INFO_SRMALARM($"{obj.Entity.CODE}-{obj.Data3.SCAlarm}");
                    return;
                }
                if (obj.Data.FinishedACK_1 == 1 || obj.Data.FinishedACK_2 == 1) throw new WarnException($"堆垛机完成任务WCS反馈信号未清除");
                if (obj.Data2.VoucherNo_1 != obj.Data.VoucherNo_1 || obj.Data2.VoucherNo_2 != obj.Data.VoucherNo_2) throw new WarnException($"等待执行{obj.Data.TaskID_1}-{obj.Data.TaskID_2}");
                //处理堆垛机已完成的任务
                if (obj.Data2.FinishedTask_1 != 0 || obj.Data2.FinishedTask_2 != 0)
                {
                    InfoLog.INFO_SRMINFO($"开始完成任务：[{obj.Entity.CODE}]-{obj.Data2.FinishedTask_1}-{obj.Data2.FinishedTask_2}");
                    obj.FinishedTaskHandle();
                    InfoLog.INFO_SRMINFO($"完成任务处理结束：[{obj.Entity.CODE}]-{obj.Data2.FinishedTask_1}-{obj.Data2.FinishedTask_2}");
                    return;
                }

                if (obj.Data2.SRMMode != SCMode.远程) return;
                if (obj.Data2.SRMStatus != SCRunStatus.空闲) return;

                var isTransfer = new List<WCS_TASK>(); //是否有移库任务
                WCS_TASK enterPriority = new WCS_TASK(), outPriority = new WCS_TASK(); //出入库优先级任务
                //再检查是否有等待执行的货物
                DB.Do(db =>
                {
                    var task = db.Default.Set<WCS_TASK>().Where(v => v.DEVICE == obj.Entity.CODE).Where(v => v.STATUS == TaskStatus.堆垛机执行).FirstOrDefault();
                    if (task != null) throw new WarnException($"[{deviceCode}]有正在执行的任务:[{task.ID}]");
                    //属于当前堆垛机未执行的移库任务
                    isTransfer = db.Default.Set<WCS_TASK>().AsNoTracking().Where(v => v.DEVICE == obj.Entity.CODE && v.TYPE == TaskType.移库 && v.STATUS < TaskStatus.堆垛机执行).ToList();
                    //判断是否存在调整优先级任务,存在初始化isTransfer值 让本次执行优先任务
                    if (db.Default.Set<WCS_TASK>().AsNoTracking().Any(v => v.DEVICE == obj.Entity.CODE && v.TYPE != TaskType.移库 && v.STATUS < TaskStatus.堆垛机执行 && v.Priority > 0))
                        isTransfer = new List<WCS_TASK>();
                    enterPriority = db.Default.Set<WCS_TASK>().Where(v => v.DEVICE == obj.Entity.CODE && v.TYPE == TaskType.入库 && v.STATUS < TaskStatus.堆垛机执行)
                                                                 .OrderByDescending(v => v.Priority).FirstOrDefault();
                    outPriority = db.Default.Set<WCS_TASK>().Where(v => v.DEVICE == obj.Entity.CODE && v.TYPE == TaskType.出库 && v.STATUS < TaskStatus.堆垛机执行)
                                                                  .OrderByDescending(v => v.Priority).FirstOrDefault();
                });

                //最后一个是否是出库任务
                var LastIsOut = obj.Entity.Get<bool>("LastIsOut");
                obj.Entity.Set("LastIsOut", !LastIsOut);
                if (isTransfer.Count > 0) //防止因为无当前堆垛机移库任务导致无法执行其他类型任务
                {
                    #region 移库

                    DB.Do(db =>
                    {
                        //获取当前堆垛机未执行的任务的组ID
                        var taskGroupKey = db.Default.Set<WCS_TASK>().Where(v => v.DEVICE == obj.Entity.CODE && v.TYPE == TaskType.移库 && v.STATUS < TaskStatus.堆垛机执行).OrderBy(p => p.CREATETIME).FirstOrDefault().TaskGroupKey;
                        //通过任务的组ID找到本组的所有任务
                        var tasks = db.Default.Set<WCS_TASK>().Where(v => v.TaskGroupKey == taskGroupKey);

                        var taskList = tasks.Select(v => v.Create<Task>());
                        foreach (var item in taskList)
                        {
                        }

                        //双工位  货架列单数为一工位取放点  货架列双数为二工位取放点
                        foreach (var task in tasks)
                        {
                            var addrFrom = task.ADDRFROM.Split("-");
                            var addrTo = task.ADDRTO.Split("-");

                            var oldTaskSTATUS = task.STATUS;
                            task.STARTTIME = DateTime.Now;
                            task.UPDATETIME = DateTime.Now;
                            task.STATUS = WCS.Entity.TaskStatus.堆垛机执行;
                            task.DEVICE = obj.Entity.CODE;
                            db.Default.SaveChanges();
                            Uploader.Upload(db);
                            task.CreateStatusLog(db, $"状态由[{oldTaskSTATUS}]变更为[{task.STATUS}]", this.GetType());

                            if (addrFrom[2].ToShort().OddNumberOrEven())
                            {
                                obj.Data.TaskID_1 = task.ID;
                                obj.Data.SLine_1 = addrFrom[0].ToShort();
                                obj.Data.SCol_1 = addrFrom[1].ToShort();
                                obj.Data.SLayer_1 = addrFrom[2].ToShort();
                                obj.Data.ELine_1 = addrTo[0].ToShort();
                                obj.Data.ECol_1 = addrTo[1].ToShort();
                                obj.Data.ELayer_1 = addrTo[2].ToShort();
                                obj.Data.VoucherNo_1++;
                            }
                            else
                            {
                                obj.Data.TaskID_2 = task.ID;
                                obj.Data.SLine_2 = addrFrom[0].ToShort();
                                obj.Data.SCol_2 = addrFrom[1].ToShort();
                                obj.Data.SLayer_2 = addrFrom[2].ToShort();
                                obj.Data.ELine_2 = addrTo[0].ToShort();
                                obj.Data.ECol_2 = addrTo[1].ToShort();
                                obj.Data.ELayer_2 = addrTo[2].ToShort();
                                obj.Data.VoucherNo_2++;
                            }
                        }
                    });

                    #endregion 移库
                }
                else if (LastIsOut)
                {
                    #region 入库

                    if (enterPriority != null && outPriority != null && outPriority.Priority > enterPriority.Priority) return;

                    var arrIn = obj.GetPickPoint()
                                   .Where(v => Device.Where(d => d.IsConv()).Select(d => d.Device<IStation521>()).Where(d => d.Data.Goodsend == v.Entity.Code()).Any()) //有正在前往取货点的任务
                                   .ToList();

                    if (!arrIn.Any()) return; //当前堆垛机无入库任务

                    //入库口设备信息 找一个有任务有光电且不在运行状态位的取货点 如果找不到代表任务还在输送途中
                    var station = arrIn.OrderBy(v => v.Data2.Tasknum > 0 && v.Data2.Status.HasFlag(IstationStatus.光电状态) && !v.Data3.Status.HasFlag(StationStatus.运行状态位) ? 0 : 1)
                                  .ThenBy(v => v.UpdateTime)
                                  .FirstOrDefault() ?? throw new WarnException($"[{deviceCode}]等待入库任务输送到位");

                    //根据上述筛选条件筛选出来的入库任务 找到对应的设备组
                    var item = Device.Where(v => v.DEVICEGROUP.Any(p => p.MEMBER.CODE == station.Entity.CODE)).Single();
                    //对数据进行排序，根据CAD图纸规划，取货点两个设备中设备号较大的一个一定对应到堆垛机的一工位货叉
                    //因此按照降序进行排序，可以保证数组中第一个一定是放到堆垛机一工位的数据
                    var devs = item.DEVICEGROUP.Select(v => v.MEMBER)
                                               .Select(v => v.Create<StationDevice>())
                                               .OrderByDescending(v => v.Entity.CODE)
                                               .ToArray();
                    var finishTaskList = new List<FinishTaskList<int>>(); //成功分配货位的任务
                    //取巷道
                    DB.Do(db =>
                    {
                        //检测有效任务数与实际任务是是否相等
                        var validDev = devs.Where(v => v.Data2.Tasknum > 10000 && v.Data2.Status.HasFlag(IstationStatus.光电状态) && !v.Data3.Status.HasFlag(StationStatus.运行状态位));
                        if (!validDev.Any()) throw new DoException("无有效入库任务");
                        var tasknum = db.Default.Set<WCS_TASK>().FirstOrDefault(v => v.ID == validDev.First().Data2.Tasknum);
                        var taskList = db.Default.Set<WCS_TASK>().Count(v => v.TaskGroupKey == tasknum.TaskGroupKey);
                        if (validDev.Count() != taskList) throw new WarnException($"任务数量不匹配,设备-{validDev.Count()},WCS-{taskList}");

                        foreach (var dev in validDev)
                        {
                            var task = db.Default.Set<WCS_TASK>().FirstOrDefault(v => v.STATUS < TaskStatus.堆垛机执行 && v.ID == dev.Data2.Tasknum) ?? throw new WarnException($"设备有光电有任务且不在运行状态，但WCS找不到任务{dev.Data2.Tasknum}");
                            var oldTask = task.STATUS;
                            var tunnel = dev.Entity.ROUTES.First().NEXT.CODE;
                            I_WCS_GetWareCellResponse loc;
                            //判定当前设备对应的堆垛机工位
                            if (dev.Entity.CODE == devs[0].Entity.CODE) loc = WMS.GetLocalIn(task.WMSTASK, tunnel, dev.Entity.CODE, Entity.WareCellForkNum.货叉1); //一工位
                            else if (dev.Entity.CODE == devs[1].Entity.CODE) loc = WMS.GetLocalIn(task.WMSTASK, tunnel, dev.Entity.CODE, Entity.WareCellForkNum.货叉2); //2工位
                            else throw new WarnException($"设备{dev.Entity.CODE}无法对应至堆垛机的任一一个工位");

                            task.UPDATETIME = DateTime.Now;
                            task.STATUS = TaskStatus.堆垛机执行;
                            task.ADDRTO = string.Format("{0}-{1}-{2}", loc.Row, loc.Colomn, loc.Layer);
                            task.DEVICE = obj.Entity.CODE;
                            task.TUNNEL = tunnel;
                            task.CreateStatusLog(db, $"状态由{oldTask}变更至{task.STATUS}", this.GetType());
                            finishTaskList.Add(new FinishTaskList<int>(task.ID, dev));
                        }
                        db.Default.SaveChanges();
                    });
                    DB.Do(db =>
                    {
                        foreach (var finish in finishTaskList)
                        {
                            var task = db.Default.Set<WCS_TASK>().Find(finish.FinishCode);
                            var addTo = task.ADDRTO.Split("-");
                            if (finish.Station.Entity.CODE == devs[0].Entity.CODE)  //一工位
                            {
                                InfoLog.INFO_SRMINFO($"入库--写入堆垛机[{obj.Entity.CODE}]1工位-开始:[{obj.Data.TaskID_1}][{obj.Data.SLine_1}][{obj.Data.SCol_1}][{obj.Data.SLayer_1}][{obj.Data.ELine_1}][{obj.Data.VoucherNo_1}]");
                                obj.Data.TaskID_1 = task.ID;
                                obj.Data.SLine_1 = finish.Station.Entity.CODE.ToShort();
                                obj.Data.SCol_1 = 0;
                                obj.Data.SLayer_1 = 0;
                                obj.Data.ELine_1 = addTo[0].ToShort();
                                obj.Data.ECol_1 = addTo[1].ToShort();
                                obj.Data.ELayer_1 = addTo[2].ToShort();
                                obj.Data.RES1_1 = finishTaskList.Count.ToShort();
                                obj.Data.VoucherNo_1++;
                                InfoLog.INFO_SRMINFO($"入库--写入堆垛机[{obj.Entity.CODE}]1工位-结束:[{obj.Data.TaskID_1}][{obj.Data.SLine_1}][{obj.Data.SCol_1}][{obj.Data.SLayer_1}][{obj.Data.ELine_1}][{obj.Data.VoucherNo_1}]");
                            }
                            else if (finish.Station.Entity.CODE == devs[1].Entity.CODE)
                            {
                                InfoLog.INFO_SRMINFO($"入库--写入堆垛机[{obj.Entity.CODE}]2工位-开始:[{obj.Data.TaskID_2}][{obj.Data.SLine_2}][{obj.Data.SCol_2}][{obj.Data.SLayer_2}][{obj.Data.ELine_2}][{obj.Data.VoucherNo_2}]");
                                obj.Data.TaskID_2 = task.ID;
                                obj.Data.SLine_2 = finish.Station.Entity.CODE.ToShort();
                                obj.Data.SCol_2 = 0;
                                obj.Data.SLayer_2 = 0;
                                obj.Data.ELine_2 = addTo[0].ToShort();
                                obj.Data.ECol_2 = addTo[1].ToShort();
                                obj.Data.ELayer_2 = addTo[2].ToShort();
                                obj.Data.RES1_2 = finishTaskList.Count.ToShort();
                                obj.Data.VoucherNo_2++;
                                InfoLog.INFO_SRMINFO($"入库--写入堆垛机[{obj.Entity.CODE}]2工位-结束:[{obj.Data.TaskID_2}][{obj.Data.SLine_2}][{obj.Data.SCol_2}][{obj.Data.SLayer_2}][{obj.Data.ELine_2}][{obj.Data.VoucherNo_2}]");
                            }
                        }
                    });

                    #endregion 入库
                }
                else
                {
                    #region 出库

                    var floor = obj.Entity.Get<int>("LastFloor");
                    floor = floor % 2 + 1;
                    obj.Entity.Set("LastFloor", floor);
                    if (enterPriority != null && outPriority != null && enterPriority.Priority > outPriority.Priority) return;

                    //获取当前堆垛机所有的放货点
                    var list = obj.GetDeliveryPoint();

                    list = list.Where(v =>
                    {
                        //true:满足条件  false：不满足条件
                        //返回结果为无货的设备  默认无货
                        var res = true;
                        //放货点是否有货
                        if (v.Data.VoucherNo != v.Data2.VoucherNo) res = false;
                        else if (v.Data3.Status.HasFlag(StationStatus.运行状态位)) res = false;
                        else if (v.Data2.Status.HasFlag(IstationStatus.光电状态)) res = false;
                        else if (v.Data2.Request == IstationRequest.堆垛机放货完成请求目标地址) res = false;
                        else if (v.Data2.Tasknum > 10000) res = false;
                        return res;
                    }).ToList();

                    //没有可用货位
                    if (list.Count == 0) return;

                    //月台所有设备当前有的任务号
                    var taskidList = DockDevs.Select(v => v.Data2.Tasknum).Where(v => v > 10000).ToList();
                    //堆垛机设备
                    var srm = obj.Entity.CODE;
                    DB.Do(db =>
                    {
                        //堆垛机当前是否有正在执行的任务
                        if (db.Default.Set<WCS_TASK>().Any(d => d.DEVICE == srm && d.STATUS == TaskStatus.堆垛机执行)) throw new WarnException($"[{deviceCode}]有正在执行的出库任务");

                        //找出等待执行的出库任务
                        var waitTask = db.Default.Set<WCS_TASK>().Where(v => v.STATUS == TaskStatus.新建)
                                                      .Where(v => v.DEVICE == srm)
                                                      .Where(v => v.TYPE == TaskType.出库)
                                                      .Where(v => !db.Default.Set<WCS_TASK>().Any(d => d.DEVICE == srm && d.STATUS == TaskStatus.堆垛机执行)).ToList();
                        //同一个目标地址同时只能有两组正在执行的任务
                        //同时对结果进行排序，分组后取第一组任务
                        var maxnum = ProtocolProxy.YGWMS150Redis.Get("SaleTaskGroupCount").ToInt();
                        var outDepot = waitTask.Where(v =>
                                            {
                                                var max = v.ADDRTO == "G1340" ? 4 : maxnum;
                                                return db.Default.Set<WCS_TASK>()
                                                   .AsNoTracking()
                                                   .Where(d => d.TYPE == TaskType.出库)
                                                   .Where(d => d.STATUS > TaskStatus.新建)
                                                   .Where(d => d.STATUS < TaskStatus.已完成 || taskidList.Contains(d.ID))
                                                   .Where(d => d.ADDRTO == v.ADDRTO && d.FLOOR == v.FLOOR)
                                                   .GroupBy(d => d.TaskGroupKey).Count() < max;
                                            })
                                .OrderByDescending(v => v.Priority)
                                .ThenBy(v => v.FLOOR == floor ? 0 : 1)
                                .ThenBy(v =>
                                {
                                    return db.Default.Set<WCS_TASK>()
                                                     .AsNoTracking()
                                                     .Where(d => d.TYPE == TaskType.出库)
                                                     .Where(d => d.STATUS > TaskStatus.新建)
                                                     .Where(d => d.STATUS < TaskStatus.已完成 || taskidList.Contains(d.ID))
                                                     .Where(d => d.ADDRTO == v.ADDRTO && d.FLOOR == v.FLOOR)
                                                     .GroupBy(d => d.TaskGroupKey).Count();
                                })
                                .ThenBy(v => v.CREATETIME)
                                .GroupBy(v => v.ADDRTO)
                                .FirstOrDefault() ?? throw new WarnException("无可执行出库任务");

                        //获取两个个可执行任务，此时这两个任务的目标地址是一致的
                        var tasks = outDepot.Select(v => v).ToList().GetOutTask();

                        #region 校验两个产品是否为同规格

                        if (tasks.Length == 2)
                        {
                            var length = tasks.OrderByDescending(v => v.Length).ToArray();
                            //较大的长度减去较小的长度，差大于两百表示为不同规格产品
                            if (length[0].Length - length[1].Length > 200)
                            {
                                tasks = tasks.Take(1).ToArray();
                            }
                        }

                        #endregion 校验两个产品是否为同规格

                        for (int i = 0; i < tasks.Length; i++)
                        {
                            var item = tasks[i];
                            var task = db.Default.Set<WCS_TASK>().Find(item.ID);
                            var oldTaskSTATUS = task.STATUS;
                            task.STARTTIME = DateTime.Now;
                            task.UPDATETIME = DateTime.Now;
                            task.STATUS = WCS.Entity.TaskStatus.堆垛机执行;
                            task.DEVICE = obj.Entity.CODE;
                            task.TaskGroupKey = tasks.Length switch
                            {
                                1 => $"{tasks[0].ID}_0",
                                2 => $"{tasks[0].ID}_{tasks[1].ID}",
                                _ => throw new WarnException($"可用任务数异常{tasks.Length}"),
                            };
                            var fork = obj.GetFork(item, i);
                            //获取站台及下一个地址
                            task.GetSrmStationAndaddNext(fork);
                            var msg = "";
                            if (fork == SrmFork.货叉1)
                                msg = $"状态由[{oldTaskSTATUS}]变更为[{task.STATUS}][{obj.Data.SLine_1}-{obj.Data.SCol_1}-{obj.Data.SLayer_1}][{obj.Data.ELine_1}][{obj.Data.VoucherNo_1}]";
                            else
                                msg = $"状态由[{oldTaskSTATUS}]变更为[{task.STATUS}][{obj.Data.SLine_2}-{obj.Data.SCol_2}-{obj.Data.SLayer_2}][{obj.Data.ELine_2}][{obj.Data.VoucherNo_2}]";
                            task.CreateStatusLog(db, msg, this.GetType());
                            item.SRMSTATION = task.SRMSTATION;
                            if (fork == SrmFork.货叉1) // 列数较小的放一工位
                            {
                                obj.WriteTask1(item, (short)tasks.Length);
                            }
                            else if (fork == SrmFork.货叉2) //列数较大的放二工位
                            {
                                obj.WriteTask2(item, (short)tasks.Length);
                            }
                            db.Default.SaveChanges();
                        }
                    });

                    #endregion 出库
                }
            });
        }

        protected override bool SelectDevice(WCS_DEVICE dev)
        {
            return dev.Is(DF.SRM);
        }
    }
}