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.Handlers;

namespace WCS.Service.Works.Station
{
    /// <summary>
    /// 涂布入库AGV交互
    /// </summary>
    [WorkTitle(typeof(CoatingHandler), "涂布入库AGV交互")]
    public class 涂布入库AGV交互 : Work<StationDeviceGroup>
    {
        protected override void Do(StationDeviceGroup obj)
        {
            obj.EX(obj =>
            {
                var station = obj.Entity.CODE;

                #region 处理新增AGV任务

                DB.Do(db =>
                {
                    //找到所有的AGV任务
                    var agvTasks = db.Default.Set<WCS_AGVTask>().Where(v => v.TaskType == AGVTaskType.入库)
                    .Where(v => v.Status < AGVTaskStatus.完成).ToArray();

                    foreach (var agvtask in agvTasks)
                    {
                        var position = agvtask.Position;
                        if (!ProtocolProxy.AllDatas.ContainsKey(position))
                            ProtocolProxy.AllDatas[position] = new ProdLineData();
                        var pld = ProtocolProxy.AllDatas[position] as ProdLineData;
                        pld.Frame = LogicHandler.Frame;
                        pld.Code = position;
                        pld.TaskList.Add(agvtask);

                        if (agvtask.Status == AGVTaskStatus.新建)
                        {
                            var qty = db.Default.Set<WCS_AGVTask>().Where(v => v.TaskType == AGVTaskType.入库 && v.Status > AGVTaskStatus.新建 && v.Status < AGVTaskStatus.完成)
                           .Where(v => v.Position == agvtask.Position).Count();

                            if (qty >= 2)
                            {
                                throw new Exception($"{agvtask.Position}正在执行的入库任务数量已达{qty},暂停入库");
                            }
                            //暂时管控同一时间被确认的任务数为1
                            if (db.Default.Set<WCS_AGVTask>().Any(v => v.Status == AGVTaskStatus.确认 && v.Station == obj.Entity.CODE)) continue;
                            agvtask.Station = obj.Entity.CODE;
                            agvtask.Status = AGVTaskStatus.确认;
                            agvtask.UpdateTime = DateTime.Now;
                            db.Default.SaveChanges();
                        }
                        else if (agvtask.Status == AGVTaskStatus.确认)
                        {
                            if (agvtask.Station != obj.Entity.CODE) continue;
                            if (obj.Items.Any(v => !v.Data3.Status.HasFlag(StationStatus.高位))) continue;
                            if (obj.Items.Any(v => !v.Data3.Status.HasFlag(StationStatus.自动))) continue;
                            if (obj.Items.Any(v => v.Data2.Status.HasFlag(IstationStatus.光电状态))) continue;
                            if (obj.Items.Any(v => v.Data3.Status.HasFlag(StationStatus.运行状态位))) continue;
                            if (obj.Items.Any(v => v.Data2.Tasknum > 10000)) continue;

                            //暂时管控同一时间被执行的任务数为1
                            if (db.Default.Set<WCS_AGVTask>().Any(v => v.Status == AGVTaskStatus.执行 && v.Station == obj.Entity.CODE)) continue;
                            agvtask.Status = AGVTaskStatus.执行;
                            agvtask.UpdateTime = DateTime.Now;
                            db.Default.SaveChanges();
                        }
                        else if (agvtask.Status < agvtask.AGVStatus)
                        {
                            if (agvtask.AGVStatus == AGVTaskStatus.请求_允许)
                            {
                                if (obj.Items.Any(v => !v.Data3.Status.HasFlag(StationStatus.高位))) continue;
                                if (obj.Items.Any(v => !v.Data3.Status.HasFlag(StationStatus.自动))) continue;
                                if (obj.Items.Any(v => v.Data2.Status.HasFlag(IstationStatus.光电状态))) continue;
                                if (obj.Items.Any(v => v.Data3.Status.HasFlag(StationStatus.运行状态位))) continue;
                                if (obj.Items.Any(v => v.Data2.Tasknum > 10000)) continue;

                                agvtask.Status = agvtask.AGVStatus;
                                agvtask.UpdateTime = DateTime.Now;
                                db.Default.SaveChanges();
                            }
                            else if (agvtask.AGVStatus == AGVTaskStatus.取放完成)
                            {
                                if (obj.Items.Any(v => v.Data2.Status.HasFlag(IstationStatus.AGV放货完成信号))) throw new WarnException("顶升下降信号未清除");
                                if (obj.Items.Any(v => !v.Data2.Status.HasFlag(IstationStatus.光电状态))) throw new WarnException("AGV放货完成后输送线无光电信号");

                                agvtask.Status = agvtask.AGVStatus;
                                agvtask.UpdateTime = DateTime.Now;
                                db.Default.SaveChanges();
                                foreach (var dev in obj.Items)
                                {
                                    dev.Data.Istation521Status = IstationStatus.AGV放货完成信号;
                                }
                            }
                            else if (Ltc.Do(agvtask, v => v.AGVStatus == AGVTaskStatus.完成))
                            {
                                agvtask.Status = agvtask.AGVStatus;
                                agvtask.UpdateTime = DateTime.Now;
                                db.Default.SaveChanges();
                            }
                            else if (Ltc.Do(agvtask, v => v.AGVStatus == AGVTaskStatus.取消))
                            {
                                agvtask.Status = agvtask.AGVStatus;
                                agvtask.UpdateTime = DateTime.Now;
                                db.Default.SaveChanges();
                            }
                        }
                    }
                });

                #endregion 处理新增AGV任务
            });
        }

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

    /// <summary>
    /// 涂布扫码入库
    /// </summary>
    [WorkTitle(typeof(CoatingHandler), "涂布入库")]
    public class 涂布扫码入库 : DeviceWork<StationDevice>
    {
        protected override void Do(StationDevice obj)
        {
            obj.EX(dev =>
            {
                var code = dev.Entity.CODE;
                if (dev.Data.VoucherNo != dev.Data2.VoucherNo)
                    throw new WarnException($"等待任务[{dev.Data2.Tasknum}]执行--凭证号不一致[{dev.Data.VoucherNo}][{dev.Data2.VoucherNo}]");
                if (!dev.Data2.Status.HasFlag(IstationStatus.光电状态)) throw new DoException("无光电");
                if (dev.Data3.Status.HasFlag(StationStatus.运行状态位)) throw new DoException("设备运行中");
                if (!dev.Data3.Status.HasFlag(StationStatus.低位)) throw new DoException("不在低位");
                if (dev.Data2.Request != IstationRequest.扫码入库) throw new WarnException("有光电无请求");
                if (dev.Data2.Tasknum > 10000) throw new WarnException("有光电有请求,但已生产任务");

                var bcr = dev.Entity.BCR();
                var barcode = bcr.Content.Trim('\r');
                if (barcode == "") throw new WarnException("扫码失败");

                var info = WMS.I_WCS_GetInTask(barcode, dev.Entity.CODE);
                var next = dev.Entity.GetPath("SRM");
                var station = dev.Entity.CODE;
                DB.Do(db =>
                {
                    var arr = db.Default.Set<WCS_AGVTask>().Where(v => v.TaskType == AGVTaskType.入库 && v.Status == AGVTaskStatus.完成).Where(v => v.Station == station).ToArray();

                    foreach (var t in arr)
                    {
                        t.Status = AGVTaskStatus.完成扫码;
                        t.UpdateTime = DateTime.Now;
                    }
                    db.Default.SaveChanges();

                    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.CODE;
                    task.HEIGHT = dev.Data2.GoodsSize;

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

        protected override bool SelectDevice(WCS_DEVICE dev)
        {
            return dev.CODE == "1386" || dev.CODE == "1387" || dev.CODE == "1394" || dev.CODE == "1395";
        }
    }

    /// <summary>
    /// 涂布入库分配巷道
    /// </summary>
    [WorkTitle(typeof(CoatingHandler), "涂布入库分配巷道")]
    public class 涂布入库分配巷道 : Work<StationDeviceGroup>
    {
        protected override void Do(StationDeviceGroup obj)
        {
            obj.EX(obj =>
            {
                var code = obj.Entity.CODE;
                //当前组有一个运行的设备就停止执行
                foreach (var item in obj.Items)
                {
                    var dev = Device.Find(item.Entity.CODE).Create<StationDevice>();
                    if (!dev.Data2.Status.HasFlag(IstationStatus.光电状态)) throw new DoException("无光电");
                    if (dev.Data.VoucherNo != dev.Data2.VoucherNo)
                        throw new WarnException($"等待任务[{dev.Data2.Tasknum}]执行--凭证号不一致[{dev.Data.VoucherNo}][{dev.Data2.VoucherNo}]");
                    if (dev.Data3.Status.HasFlag(StationStatus.运行状态位)) throw new WarnException("设备运行中");
                    if (dev.Data2.Tasknum > 10000 && dev.Data2.Request != IstationRequest.请求分配目标地址)
                        throw new WarnException("有任务无请求");
                }

                //获取需要进行巷道分配的设备
                var devs = obj.TaskedDeviceGetNextAddress() ?? throw new WarnException("无可用任务");

                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 WarnException($"WMS未返回巷道");
                    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 allIn = Device.Where(v => v.Is(DF.SRM涂布取货)) //一楼所有取货点
                                          .Where(v => v.ROUTES.Any(p => p.NEXT == item)) //下一个点为当前巷道的取货点
                                          .Select(v => v.CODE)
                                          .ToList();
                        //下一个目标地址包含取货点的设备,此时获得的数据是旋转台
                        var turntable = Device.Where(v => v.IsConv() && v.ROUTES.Any(p => p.NEXT != null && allIn.Contains(p.NEXT.CODE))).Select(v => v.CODE);
                        //获得RGV的交货点
                        var rgvDeliveryPoint = Device.Where(v => v.IsConv() && v.ROUTES.Any(p => p.NEXT != null && turntable.Contains(p.NEXT.CODE)))
                                      .Select(v => v.Create<StationDevice>()) //取所有可以到达取货点设备的信息
                                      .Where(v => !v.Data3.Status.HasFlag(StationStatus.运行状态位) && !v.Data2.Status.HasFlag(IstationStatus.光电状态) && v.Data2.Tasknum < 10000)//筛选出空闲的路径点，此处因输送机都是一个动力，因此可以先找路径点再找设备组
                                      .Distinct()
                                      .FirstOrDefault();//去一次重
                        if (rgvDeliveryPoint == null) continue;
                        var dev = Device.Where(p => p.CODE.StartsWith("G") && p.DEVICEGROUP.Any(d => d.MEMBER == rgvDeliveryPoint.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.远程 && v.SRM.Data2.SRMStatus == SCRunStatus.空闲; } catch { return false; } })
                                                .Where(v => !db.Default.Set<WCS_TASK>().Any(p => p.Priority > 0 && p.DEVICE == v.SRM.Entity.CODE && p.STATUS < TaskStatus.堆垛机完成))
                                                .OrderBy(v => tunnelNo.IndexOf(v.Tunnel.CODE)).FirstOrDefault();
                    if (tunnelInfo == null) throw new WarnException("无可用巷道");

                    //开始向设备中写入任务信息
                    foreach (var item in devs)
                    {
                        var dev = Device.Find(item.Entity.CODE).Create<StationDevice>();
                        var task = tasks.FirstOrDefault(p => p.ID == dev.Data2.Tasknum);

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

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

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

                        dev.Data.Tasknum = task.ID;
                        dev.Data.Goodsstart = obj.Entity.CODE.Replace("G", "").ToShort();
                        dev.Data.Goodsend = tunnelInfo.taskIN.CODE.Replace("G", "").ToShort();
                        dev.Data.Goodsnum = (short)devs.Count();
                        dev.Data.CmdType = IstationCmdType.分配目标地址;
                        dev.Data.VoucherNo++;
                    }
                });
            });
        }

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

    /// <summary>
    /// 涂布入库旋转台二次分配巷道
    /// </summary>
    [WorkTitle(typeof(CoatingHandler), "涂布入库旋转台二次分配巷道")]
    public class 涂布入库旋转台二次分配巷道 : Work<StationDeviceGroup>
    {
        protected override void Do(StationDeviceGroup obj)
        {
            obj.EX(obj =>
            {
                var code = obj.Entity.CODE;
                //当前组有一个运行的设备就停止执行
                foreach (var item in obj.Items)
                {
                    var dev = Device.Find(item.Entity.CODE).Create<StationDevice>();
                    if (!dev.Data2.Status.HasFlag(IstationStatus.光电状态)) throw new DoException("无光电");
                    if (dev.Data.VoucherNo != dev.Data2.VoucherNo)
                        throw new WarnException($"等待任务[{dev.Data2.Tasknum}]执行--凭证号不一致[{dev.Data.VoucherNo}][{dev.Data2.VoucherNo}]");
                    if (dev.Data3.Status.HasFlag(StationStatus.运行状态位)) throw new WarnException("设备运行中");
                    if (dev.Data2.Tasknum > 10000 && dev.Data2.Request != IstationRequest.请求分配目标地址)
                        throw new WarnException("有任务无请求");
                }

                //获取需要进行巷道分配的设备
                var devs = obj.Items.Where(v => v.Data2.Status.HasFlag(IstationStatus.光电状态) && v.Data2.Tasknum > 10000).ToList();
                if (devs.Count == 0) throw new WarnException("无可用任务");

                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 WarnException($"WMS未返回巷道");
                    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 allIn = Device.Where(v => v.Is(DF.SRM涂布取货)) //一楼所有取货点
                                          .Where(v => v.ROUTES.Any(p => p.NEXT == item)) //下一个点为当前巷道的取货点
                                          .Select(v => v.CODE)
                                          .ToList();
                        //下一个目标地址包含取货点的设备,此时获得的数据是旋转台
                        var turntable = Device.Where(v => v.IsConv() && v.ROUTES.Any(p => p.NEXT != null && allIn.Contains(p.NEXT.CODE)))
                                              .Where(v => obj.Items.Any(p => p.Entity == v))// 筛选出包含在当前设备组的设备
                                              .Distinct()
                                              .FirstOrDefault();//去一次重
                        if (turntable == null) continue;
                        var dev = Device.Where(p => p.CODE.StartsWith("G") && p.DEVICEGROUP.Any(d => d.MEMBER == turntable)).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.远程 && v.SRM.Data2.SRMStatus == SCRunStatus.空闲; } catch { return false; } })
                                                .Where(v => !db.Default.Set<WCS_TASK>().Any(p => p.Priority > 0 && p.DEVICE == v.SRM.Entity.CODE && p.STATUS < TaskStatus.堆垛机完成))
                                                .OrderBy(v => tunnelNo.IndexOf(v.Tunnel.CODE)).FirstOrDefault();
                    if (tunnelInfo == null) throw new WarnException("无可用巷道");

                    //开始向设备中写入任务信息
                    foreach (var item in devs)
                    {
                        var dev = Device.Find(item.Entity.CODE).Create<StationDevice>();
                        var task = tasks.FirstOrDefault(p => p.ID == dev.Data2.Tasknum);

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

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

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

                        dev.Data.Tasknum = task.ID;
                        dev.Data.Goodsstart = dev.Entity.CODE.ToShort();
                        dev.Data.Goodsend = dev.Entity.GetPath(task.DEVICE).CODE.ToShort();
                        dev.Data.Goodsnum = (short)devs.Count();
                        dev.Data.CmdType = IstationCmdType.分配目标地址;
                        dev.Data.VoucherNo++;
                    }
                });
            });
        }

        protected override bool SelectDevice(WCS_DEVICE dev)
        {
            return devCodes.Contains(dev.CODE);
        }

        private List<string> devCodes = new List<string>() {
            "G1404",
            "G1413",
            "G1420",
            "G1429",
        };
    }
}