BOPP输送线 init

Projects/永冠OPP/WCS.Service/Handlers/BOPPHandler.cs

@@ -0,0 +1,19 @@
+using System.ComponentModel;
+using WCS.Core;
+
+namespace WCS.Service.Handlers
+{
+    /// <summary>
+    /// BOPP处理中心
+    /// </summary>
+    [Description("BOPP处理中心")]
+    internal class BOPPHandler : WorkHandler
+    {
+        public override bool ParallelRun => false;
+
+        protected override void DoWork(WorkInfo work)
+        {
+            base.DoWork(work);
+        }
+    }
+}

Projects/永冠OPP/WCS.Service/Works/RGV/RGVWorks.cs

@@ -206,4 +206,135 @@ namespace WCS.Service.Works.RGV
             return dev.Is(DF.涂布RGV);
         }
     }
+
+    [WorkTitle(typeof(RGVHandler), "BOPP环穿")]
+    public class BOPP环穿 : DeviceWork<RGVDevice>
+    {
+        protected override void Do(RGVDevice obj)
+        {
+            obj.EX(obj =>
+            {
+                if (obj.Data2.Trigger_1 != obj.Data.Trigger_1) throw new WarnException($"等待执行任务{obj.Data2.TaskID_1}--{obj.Data2.TaskID_2}");
+                if (obj.Data2.WorkMode != RGVMode.自动) throw new DoException(obj.Data2.WorkMode.ToString());
+                if (obj.Data2.SystemStatus != RGVRunStatus.空闲) throw new DoException(obj.Data2.SystemStatus.ToString());
+                //RGV当前是否刚刚完成取货任务，等待放货
+                if (obj.IsPut())
+                {
+                    if (!obj.Data2.Status_1.HasFlag(WCS.Entity.Protocol.RGVStatus.光电)) throw new WarnException("RGV无光电，无法放货，请检查实际情况");
+                    //取小车上的任务
+                    DB.Do(db =>
+                    {
+                        List<int> taskids = new List<int>() { obj.Data2.TaskID_1, obj.Data2.TaskID_2 };
+                        var tasks = db.Default.Set<WCS_TASK>().Where(p => taskids.Contains(p.ID));
+                        if (tasks.GroupBy(p => p.TaskGroupKey).Count() > 1)
+                            throw new WarnException("任务组ID不一致");
+                        if (!tasks.GroupBy(p => p.TaskGroupKey).Any())
+                            throw new WarnException("无任务组ID");
+                        var destStation = Device.Find(tasks.FirstOrDefault().ADDRNEXT).Create<StationDeviceGroup>();
+                        obj.Put(destStation, obj.Data2.TaskID_1, obj.Data2.TaskID_2);
+                    });
+
+                    return;
+                }
+
+                var pickStation = obj.CurrentStation();
+                //RGV是否在任何一个站台
+                if (pickStation != null)
+                {
+                    //是否是取货站台
+                    if (pickStation.Entity.Is(DF.涂布RGV取货设备组))
+                    {
+                        // 筛选出有任务号和起始及目标地址的设备
+                        var devs = pickStation.RGVGetTaskedDevice();
+                        //是否需要取货
+                        if (devs != null && devs.Count() > 0)
+                        {
+                            //开始下达取货任务
+                            DB.Do(db =>
+                            {
+                                if (obj.Data2.TaskType_1 != RGVTaskType.移动) throw new WarnException($"RGV正在执行{obj.Data2.TaskType_1}");
+                                if (obj.Data2.Status_1.HasFlag(WCS.Entity.Protocol.RGVStatus.光电)) throw new WarnException("RGV有光电，无法取货，请检查实际情况");
+                                if (!obj.Data2.Status_1.HasFlag(WCS.Entity.Protocol.RGVStatus.RGV到站)) throw new WarnException("RGV无到站状态，请检查RGV实际状态");
+
+                                var taskids = devs.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 WarnException("任务组ID不一致");
+                                if (!tasks.GroupBy(p => p.TaskGroupKey).Any())
+                                    throw new WarnException("无任务组ID");
+                                var gw1 = pickStation.Items.ToArray()[0];
+                                var gw2 = pickStation.Items.ToArray()[1];
+                                if (gw1.Data2.Tasknum != 0 && gw2.Data2.Tasknum != 0)
+                                {
+                                    if (gw1.Data2.Goodsend != gw2.Data2.Goodsend) throw new WarnException($"{obj.Entity.CODE}目标地址不一致");
+                                }
+                                obj.Data.TaskID_1 = gw1.Data2.Tasknum;
+                                obj.Data.TaskID_2 = gw2.Data2.Tasknum;
+                                obj.Data.TaskType_1 = RGVTaskType.取货;
+                                obj.Data.DestPosition_1 = pickStation.Entity.CODE.Replace("G", "").ToShort();
+
+                                obj.Data.Trigger_1++;
+
+                                foreach (var task in tasks)
+                                {
+                                    var msg = $"下达从{obj.Data.StartPosition_1}移动至{ obj.Data.DestPosition_1}的RGV PLC指令。";
+                                    msg += $"[{ task.ID}][{obj.Data.StartPosition_1}][{obj.Data.DestPosition_1}[{ obj.Data.Trigger_1}]";
+
+                                    task.CreateStatusLog(db, msg, this.GetType());
+                                }
+                            });
+                            return;
+                        }
+
+                        //找到自己的后一个小车
+                        var afterStation = obj.After();
+                        //后面的小车是否在执行任务
+                        if (afterStation.Data2.WorkMode == RGVMode.自动 && afterStation.Data2.SystemStatus == RGVRunStatus.空闲) return;
+                        //自己是否阻挡了该小车
+                        if (obj.StopedByMe(afterStation))
+                        {
+                            //找到当前所在站台的下一个取货点
+                            var beforeStation = Device.Where(v => v.Is(DF.涂布RGV取货设备组) && v.CODE != pickStation.Entity.CODE)
+                                          .Select(v => v.Create<StationDeviceGroup>())
+                                          .OrderBy(v => pickStation.Distance(v))
+                                          .FirstOrDefault();
+
+                            //if (beforeStation.Entity.CODE == pickStation.Entity.CODE)
+                            //{
+                            //    //取被挡住小车的目标位置的下一个取货点
+                            //    beforeStation = Device.Where(v => v.Is(DF.涂布RGV取货设备组) && v.CODE != beforeStation.Entity.CODE)
+                            //                 .Select(v => v.Create<StationDeviceGroup>())
+                            //                 .OrderBy(v => beforeStation.Distance(v))
+                            //                 .FirstOrDefault();
+                            //}
+
+                            //写入移动任务
+                            obj.Move(beforeStation);
+                            return;
+                        }
+                    }
+
+                    //是否在一个放货站台
+                    if (pickStation.Entity.Is(DF.涂布RGV放货设备组))
+                    {
+                        pickStation = obj.BeforeStation();
+                        obj.Move(pickStation);
+                    }
+                    return;
+                }
+
+                //此时RGV即没有等待执行的放货任务，也不在任何一个取货点,因此需要调往最近的一个取货点
+                //找到距离这个RGV最近的一个取货点
+                //必须所有RGV都是空闲状态时才可以进行初始化
+                if (obj.RGVList.Any(v => v.Data2.SystemStatus != RGVRunStatus.空闲 || v.Data2.WorkMode != RGVMode.自动)) return;
+                pickStation = obj.BeforeStation();
+                obj.Move(pickStation);
+            });
+        }
+
+        protected override bool SelectDevice(WCS_DEVICE dev)
+        {
+            return dev.Is(DF.涂布RGV);
+        }
+    }
 }

Projects/永冠OPP/WCS.Service/Works/Station/BOPP入库.cs

@@ -0,0 +1,356 @@
+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 TaskStatus = WCS.Entity.TaskStatus;
+
+namespace WCS.Service.Works.Station
+{
+    /// <summary>
+    ///BOPP扫码入库
+    /// </summary>
+    [WorkTitle(typeof(BOPPHandler), "BOPP扫码入库")]
+    public class BOPP扫码入库 : Work<StationDeviceGroup>
+    {
+        protected override void Do(StationDeviceGroup obj)
+        {
+            obj.EX(obj =>
+            {
+                //设备组无论单卷还是双卷都必须满足的条件
+                if (obj.Items.Any(v => v.Data.VoucherNo != v.Data2.VoucherNo)) throw new WarnException($"等待任务执行--凭证号不一致");
+                if (obj.Items.Any(v => v.Data3.Status.HasFlag(StationStatus.运行状态位))) throw new WarnException($"设备运行中");
+                if (obj.Items.Any(v => !v.Data3.Status.HasFlag(StationStatus.低位))) throw new DoException("不在低位");
+
+                //成功创建的任务
+                var finishTaskList = new List<Tuple<int, StationDevice>>();
+
+                //创建对应的任务
+                DB.Do(db =>
+                {
+                    var devs = new List<Tuple<StationDevice, string>>();
+
+                    //获取需要执行的设备信息
+                    foreach (var dev in obj.Items)
+                    {
+                        if (dev.Data2.Request != IstationRequest.扫码入库) continue; //没有请求
+                        if (dev.Data2.Tasknum > 10000) continue; //没有任务号
+                        if (!dev.Data2.Status.HasFlag(IstationStatus.光电状态)) continue; //没有光电
+
+                        var bcr = dev.Entity.BCR();
+                        var barcode = bcr.Content.Trim('\r');
+                        if (barcode == "") continue; //扫码失败
+                        devs.Add(new Tuple<StationDevice, string>(dev.Entity.Create<StationDevice>(), barcode));
+                    }
+
+                    if (!devs.Any()) return;
+                    var items = devs.ToArray();
+                    List<I_WCS_GetInTaskResponseItem> Infos = items.Length switch
+                    {
+                        1 => WMS.I_WCS_GetInTask(items[0].Item2, items[0].Item1.Entity.CODE),
+                        2 => WMS.I_WCS_GetInTask(items[0].Item2, items[0].Item1.Entity.CODE, items[1].Item2, items[1].Item1.Entity.CODE),
+                        _ => throw new WarnException($"一组任务数量最大为2,当前{items.Length}"),
+                    };
+                    var agvTask = db.Default.Set<WCS_AGVTask>().Where(v => v.ID == items[0].Item1.Data.Goodscode).FirstOrDefault() ?? throw new WarnException("无完成AGV任务");
+
+                    if (agvTask.Status != AGVTaskStatus.完成扫码)
+                    {
+                        agvTask.Status = AGVTaskStatus.完成扫码;
+                        agvTask.UpdateTime = DateTime.Now;
+                    }
+
+                    foreach (var item in devs)
+                    {
+                        var dev = item.Item1;
+                        var next = dev.Entity.GetPath("SRM");
+                        var info = Infos.FirstOrDefault(v => item.Item2.Contains(v.ContainerCode));
+                        if (db.Default.Set<WCS_TASK>().AsNoTracking().Any(v => v.BARCODE == info.ContainerCode && v.STATUS < TaskStatus.已完成 && v.TYPE == TaskType.入库)) continue;
+
+                        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;
+                        task.AgvTask = agvTask.ID;
+
+                        db.Default.Set<WCS_TASK>().Add(task);
+                        finishTaskList.Add(new Tuple<int, StationDevice>(task.WMSTASK, dev.Entity.Create<StationDevice>()));
+
+                        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());
+                    }
+                    //两个任务一起创建
+                    db.Default.SaveChanges();
+                });
+
+                //检查对应的任务是否已创建成功
+                DB.Do(db =>
+                {
+                    foreach (var finishTask in finishTaskList)
+                    {
+                        var task = db.Default.Set<WCS_TASK>().FirstOrDefault(v => v.WMSTASK == finishTask.Item1);
+                        if (task == null) continue;
+
+                        finishTask.Item2.Data.Tasknum = task.ID;
+                        finishTask.Item2.Data.Goodsstart = task.ADDRFROM.ToShort();
+                        finishTask.Item2.Data.Goodsend = task.ADDRNEXT.ToShort();
+                        finishTask.Item2.Data.Goodsnum = (short)finishTaskList.Count;
+                        finishTask.Item2.Data.CmdType = IstationCmdType.扫码入库;
+                        finishTask.Item2.Data.VoucherNo++;
+                    }
+                });
+            });
+        }
+
+        protected override bool SelectDevice(WCS_DEVICE dev)
+        {
+            return false;
+        }
+    }
+
+    /// <summary>
+    /// BOPP巷道分配
+    /// </summary>
+    [WorkTitle(typeof(BOPPHandler), "BOPP巷道分配")]
+    public class BOPP巷道分配 : Work<StationDeviceGroup>
+    {
+        protected override void Do(StationDeviceGroup obj)
+        {
+            obj.EX(obj =>
+            {
+                var code = obj.Entity.CODE;
+                //两个设备都必须满足的条件
+                if (obj.Items.Any(v => v.Data.VoucherNo != v.Data2.VoucherNo)) return;
+                if (obj.Items.Any(v => v.Data3.Status.HasFlag(StationStatus.运行状态位))) return;
+
+                //成功分配巷道的任务的任务
+                var finishTaskList = new List<Tuple<int, StationDevice>>();
+
+                //变更数据库信息
+                DB.Do(db =>
+                {
+                    var devs = obj.Items.Where(v => v.Data2.Status.HasFlag(IstationStatus.光电状态) && v.Data2.Request == IstationRequest.请求分配目标地址)
+                                           .Where(v => v.Data2.Tasknum > 10000 && v.Data2.Goodsend != 0);
+                    if (!devs.Any()) return; //无可执行任务
+                    var taskIds = devs.Select(dev => dev.Data2.Tasknum).ToList();
+                    var taskList = db.Default.Set<WCS_TASK>().Where(v => taskIds.Contains(v.ID)).ToList();
+
+                    taskList.ValidTaskCheck(devs.Count(), db);
+
+                    var res = WMS.GetTunnelList(taskList.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 putStation = Device.Where(v => v.IsConv() && v.ROUTES.Any(p => p.NEXT != null && allIn.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 (putStation == null) continue;
+                        var taskInStation = Device.Where(p => p.CODE.StartsWith("G") && p.DEVICEGROUP.Any(d => d.MEMBER == putStation.Entity)).OrderBy(p => p.CODE).FirstOrDefault();
+                        //RGV是否有正在前往这个地址的任务
+                        var rgvList = Device.Where(v => v.Is(DF.涂布RGV)).Select(v => v.Create<RGVDevice>());
+                        if (rgvList.Any(v => !v.Data2.SystemStatus.HasFlag(WCS.Entity.Protocol.RGV.RGVRunStatus.空闲)
+                                          && !v.Data2.WorkMode.HasFlag(WCS.Entity.Protocol.RGV.RGVMode.自动)
+                                          && v.Data2.TaskType_1 == WCS.Entity.Protocol.RGV.RGVTaskType.放货
+                                          && v.Data2.DestPosition_1 == taskInStation.CODE.Replace("G", "").ToShort())) continue;
+                        tunnelInfos.Add(new TunnelInfo
+                        {
+                            Tunnel = item,
+                            taskIN = taskInStation, //找到放货点设备所在组
+                            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 = taskList.FirstOrDefault(p => p.ID == dev.Data2.Tasknum);
+                        if (task == null) throw new WarnException($"WCS无该任务{dev.Data2.Tasknum}--{dev.Entity.CODE}");
+
+                        task.DEVICE = tunnelInfo.SRM.Entity.CODE;
+                        task.TUNNEL = tunnelInfo.Tunnel.CODE;
+                        task.ADDRNEXT = tunnelInfo.taskIN.CODE;
+                        task.TaskGroupKey = res.WMSTaskGroupKey;
+                        task.ADDRTO = task.DEVICE;
+                        var msg = $"下达从G1030移动至{dev.Data.Goodsend}的PLC指令。同时将任务分配至[{ task.TUNNEL }]-[{task.DEVICE}]";
+                        msg += $"[{dev.Data.Tasknum}][G1030][{dev.Data.Goodsend}][{tunnelInfo.SRM.Entity.CODE}][{dev.Data.VoucherNo}[{dev.Data2.VoucherNo}]";
+                        task.CreateStatusLog(db, msg, this.GetType());
+                        finishTaskList.Add(new Tuple<int, StationDevice>(task.ID, item.Entity.Create<StationDevice>()));
+                    }
+                    db.Default.SaveChanges();
+                });
+
+                // 开始将任务信息写入到设备
+                DB.Do(db =>
+                {
+                    foreach (var finishTask in finishTaskList)
+                    {
+                        var task = db.Default.Set<WCS_TASK>().Find(finishTask.Item1);
+                        if (task == null) continue;
+
+                        finishTask.Item2.Data.Tasknum = task.ID;
+                        finishTask.Item2.Data.Goodsstart = obj.Entity.CODE.Replace("G", "").ToShort();
+                        finishTask.Item2.Data.Goodsend = task.ADDRNEXT.Replace("G", "").ToShort();
+                        finishTask.Item2.Data.Goodsnum = (short)finishTaskList.Count;
+                        finishTask.Item2.Data.CmdType = IstationCmdType.分配目标地址;
+                        finishTask.Item2.Data.VoucherNo++;
+                    }
+                });
+            });
+        }
+
+        protected override bool SelectDevice(WCS_DEVICE dev)
+        {
+            return false;
+        }
+    }
+
+    /// <summary>
+    /// 涂布入库旋转台二次分配巷道
+    /// </summary>
+    [WorkTitle(typeof(BOPPHandler), "BOPP入库旋转台二次分配巷道")]
+    public class BOPP入库旋转台二次分配巷道 : Work<StationDeviceGroup>
+    {
+        protected override void Do(StationDeviceGroup obj)
+        {
+            obj.EX(obj =>
+            {
+                var code = obj.Entity.CODE;
+
+                //两个设备都必须满足的条件
+                if (obj.Items.Any(v => v.Data.VoucherNo != v.Data2.VoucherNo)) return;
+                if (obj.Items.Any(v => v.Data3.Status.HasFlag(StationStatus.运行状态位))) return;
+                //成功分配巷道的任务的任务
+                var finishTaskList = new List<Tuple<int, StationDevice>>();
+
+                //变更数据库信息
+                DB.Do(db =>
+                {
+                    var devs = obj.Items.Where(v => v.Data2.Status.HasFlag(IstationStatus.光电状态) && v.Data2.Request == IstationRequest.请求分配目标地址)
+                                           .Where(v => v.Data2.Tasknum > 10000 && v.Data2.Goodsend != 0);
+                    if (!devs.Any()) return; //无可执行任务
+                    var taskIds = devs.Select(dev => dev.Data2.Tasknum).ToList();
+                    var taskList = db.Default.Set<WCS_TASK>().Where(v => taskIds.Contains(v.ID)).ToList();
+
+                    taskList.ValidTaskCheck(devs.Count(), db);
+
+                    var res = WMS.GetTunnelList(taskList.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 = taskList.FirstOrDefault(p => p.ID == dev.Data2.Tasknum);
+                        if (task == null) throw new WarnException($"WCS无该任务{dev.Data2.Tasknum}--{dev.Entity.CODE}");
+
+                        task.DEVICE = tunnelInfo.SRM.Entity.CODE;
+                        task.TUNNEL = tunnelInfo.Tunnel.CODE;
+                        task.ADDRNEXT = tunnelInfo.taskIN.CODE;
+                        task.TaskGroupKey = res.WMSTaskGroupKey;
+                        task.ADDRTO = task.DEVICE;
+                        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());
+                        finishTaskList.Add(new Tuple<int, StationDevice>(task.ID, item.Entity.Create<StationDevice>()));
+                    }
+                    db.Default.SaveChanges();
+                });
+
+                // 开始将任务信息写入到设备
+                DB.Do(db =>
+                {
+                    foreach (var finishTask in finishTaskList)
+                    {
+                        var task = db.Default.Set<WCS_TASK>().Find(finishTask.Item1);
+                        if (task == null) continue;
+
+                        finishTask.Item2.Data.Tasknum = task.ID;
+                        finishTask.Item2.Data.Goodsstart = obj.Entity.CODE.Replace("G", "").ToShort();
+                        finishTask.Item2.Data.Goodsend = task.ADDRNEXT.Replace("G", "").ToShort();
+                        finishTask.Item2.Data.Goodsnum = (short)finishTaskList.Count;
+                        finishTask.Item2.Data.CmdType = IstationCmdType.分配目标地址;
+                        finishTask.Item2.Data.VoucherNo++;
+                    }
+                });
+            });
+        }
+
+        protected override bool SelectDevice(WCS_DEVICE dev)
+        {
+            return false;
+        }
+
+        private List<string> devCodes = new List<string>() {
+            "G1404",
+            "G1413",
+            "G1420",
+            "G1429",
+        };
+    }
+}

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

@@ -63,7 +63,8 @@ namespace WCS.Service.Works.Station
                         var dev = item.Item1;
                         var next = dev.Entity.CODE == "1028" ? "1030" : "1031";
                         var info = Infos.FirstOrDefault(v => item.Item2.Contains(v.ContainerCode));
-                        if (db.Default.Set<WCS_TASK>().AsNoTracking().Any(v => v.BARCODE == info.ContainerCode && v.STATUS < TaskStatus.已完成 && v.TYPE == TaskType.入库)) continue;
+                        if (db.Default.Set<WCS_TASK>().AsNoTracking().Any(v => v.BARCODE == info.ContainerCode && v.STATUS < TaskStatus.已完成 && v.TYPE == TaskType.入库))
+                            throw new WarnException($"生产条码{info.ContainerCode}存在未完成任务,请检查是否为标签卡重复使用");
 
                         var task = new WCS_TASK();
                         task.BARCODE = info.ContainerCode;

Projects/永冠OPP/WCS.Service/Works/Station/涂布入库.cs

@@ -197,7 +197,8 @@ namespace WCS.Service.Works.Station
                         var dev = item.Item1;
                         var next = dev.Entity.GetPath("SRM");
                         var info = Infos.FirstOrDefault(v => item.Item2.Contains(v.ContainerCode));
-                        if (db.Default.Set<WCS_TASK>().AsNoTracking().Any(v => v.BARCODE == info.ContainerCode && v.STATUS < TaskStatus.已完成 && v.TYPE == TaskType.入库)) continue;
+                        if (db.Default.Set<WCS_TASK>().AsNoTracking().Any(v => v.BARCODE == info.ContainerCode && v.STATUS < TaskStatus.已完成 && v.TYPE == TaskType.入库))
+                            throw new WarnException($"生产条码{info.ContainerCode}存在未完成任务,请检查是否为标签卡重复使用");
 
                         var task = new WCS_TASK();
                         task.BARCODE = info.ContainerCode;
@@ -262,26 +263,25 @@ namespace WCS.Service.Works.Station
             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("无可用任务");
+                //两个设备都必须满足的条件
+                if (obj.Items.Any(v => v.Data.VoucherNo != v.Data2.VoucherNo)) return;
+                if (obj.Items.Any(v => v.Data3.Status.HasFlag(StationStatus.运行状态位))) return;
+
+                //成功分配巷道的任务的任务
+                var finishTaskList = new List<Tuple<int, StationDevice>>();
 
+                //变更数据库信息
                 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 devs = obj.Items.Where(v => v.Data2.Status.HasFlag(IstationStatus.光电状态) && v.Data2.Request == IstationRequest.请求分配目标地址)
+                                           .Where(v => v.Data2.Tasknum > 10000 && v.Data2.Goodsend != 0);
+                    if (!devs.Any()) return; //无可执行任务
+                    var taskIds = devs.Select(dev => dev.Data2.Tasknum).ToList();
+                    var taskList = db.Default.Set<WCS_TASK>().Where(v => taskIds.Contains(v.ID)).ToList();
+
+                    taskList.ValidTaskCheck(devs.Count(), db);
+
+                    var res = WMS.GetTunnelList(taskList.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();
 
@@ -291,27 +291,23 @@ namespace WCS.Service.Works.Station
                     foreach (var item in tunnels)
                     {
                         //当前巷道的取货点
-                        var allIn = Device.Where(v => v.Is(DF.SRM涂布取货)) //一楼所有取货点
+                        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)))
+                        var putStation = Device.Where(v => v.IsConv() && v.ROUTES.Any(p => p.NEXT != null && allIn.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 taskInStation = Device.Where(p => p.CODE.StartsWith("G") && p.DEVICEGROUP.Any(d => d.MEMBER == rgvDeliveryPoint.Entity)).OrderBy(p => p.CODE).FirstOrDefault();
-
+                        if (putStation == null) continue;
+                        var taskInStation = Device.Where(p => p.CODE.StartsWith("G") && p.DEVICEGROUP.Any(d => d.MEMBER == putStation.Entity)).OrderBy(p => p.CODE).FirstOrDefault();
+                        //RGV是否有正在前往这个地址的任务
                         var rgvList = Device.Where(v => v.Is(DF.涂布RGV)).Select(v => v.Create<RGVDevice>());
                         if (rgvList.Any(v => !v.Data2.SystemStatus.HasFlag(WCS.Entity.Protocol.RGV.RGVRunStatus.空闲)
                                           && !v.Data2.WorkMode.HasFlag(WCS.Entity.Protocol.RGV.RGVMode.自动)
                                           && v.Data2.TaskType_1 == WCS.Entity.Protocol.RGV.RGVTaskType.放货
                                           && v.Data2.DestPosition_1 == taskInStation.CODE.Replace("G", "").ToShort())) continue;
-
                         tunnelInfos.Add(new TunnelInfo
                         {
                             Tunnel = item,
@@ -325,30 +321,40 @@ namespace WCS.Service.Works.Station
                                                 .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);
+                        var task = taskList.FirstOrDefault(p => p.ID == dev.Data2.Tasknum);
+                        if (task == null) throw new WarnException($"WCS无该任务{dev.Data2.Tasknum}--{dev.Entity.CODE}");
 
                         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());
+                        finishTaskList.Add(new Tuple<int, StationDevice>(task.ID, item.Entity.Create<StationDevice>()));
+                    }
+                    db.Default.SaveChanges();
+                });
+
+                // 开始将任务信息写入到设备
+                DB.Do(db =>
+                {
+                    foreach (var finishTask in finishTaskList)
+                    {
+                        var task = db.Default.Set<WCS_TASK>().Find(finishTask.Item1);
+                        if (task == null) continue;
 
-                        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++;
+                        finishTask.Item2.Data.Tasknum = task.ID;
+                        finishTask.Item2.Data.Goodsstart = obj.Entity.CODE.Replace("G", "").ToShort();
+                        finishTask.Item2.Data.Goodsend = task.ADDRNEXT.Replace("G", "").ToShort();
+                        finishTask.Item2.Data.Goodsnum = (short)finishTaskList.Count;
+                        finishTask.Item2.Data.CmdType = IstationCmdType.分配目标地址;
+                        finishTask.Item2.Data.VoucherNo++;
                     }
                 });
             });
@@ -371,27 +377,25 @@ namespace WCS.Service.Works.Station
             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("无可用任务");
 
+                //两个设备都必须满足的条件
+                if (obj.Items.Any(v => v.Data.VoucherNo != v.Data2.VoucherNo)) return;
+                if (obj.Items.Any(v => v.Data3.Status.HasFlag(StationStatus.运行状态位))) return;
+                //成功分配巷道的任务的任务
+                var finishTaskList = new List<Tuple<int, StationDevice>>();
+
+                //变更数据库信息
                 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 devs = obj.Items.Where(v => v.Data2.Status.HasFlag(IstationStatus.光电状态) && v.Data2.Request == IstationRequest.请求分配目标地址)
+                                           .Where(v => v.Data2.Tasknum > 10000 && v.Data2.Goodsend != 0);
+                    if (!devs.Any()) return; //无可执行任务
+                    var taskIds = devs.Select(dev => dev.Data2.Tasknum).ToList();
+                    var taskList = db.Default.Set<WCS_TASK>().Where(v => taskIds.Contains(v.ID)).ToList();
+
+                    taskList.ValidTaskCheck(devs.Count(), db);
+
+                    var res = WMS.GetTunnelList(taskList.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();
 
@@ -426,30 +430,40 @@ namespace WCS.Service.Works.Station
                                                 .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);
+                        var task = taskList.FirstOrDefault(p => p.ID == dev.Data2.Tasknum);
+                        if (task == null) throw new WarnException($"WCS无该任务{dev.Data2.Tasknum}--{dev.Entity.CODE}");
 
                         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());
+                        finishTaskList.Add(new Tuple<int, StationDevice>(task.ID, item.Entity.Create<StationDevice>()));
+                    }
+                    db.Default.SaveChanges();
+                });
+
+                // 开始将任务信息写入到设备
+                DB.Do(db =>
+                {
+                    foreach (var finishTask in finishTaskList)
+                    {
+                        var task = db.Default.Set<WCS_TASK>().Find(finishTask.Item1);
+                        if (task == null) continue;
 
-                        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++;
+                        finishTask.Item2.Data.Tasknum = task.ID;
+                        finishTask.Item2.Data.Goodsstart = obj.Entity.CODE.Replace("G", "").ToShort();
+                        finishTask.Item2.Data.Goodsend = task.ADDRNEXT.Replace("G", "").ToShort();
+                        finishTask.Item2.Data.Goodsnum = (short)finishTaskList.Count;
+                        finishTask.Item2.Data.CmdType = IstationCmdType.分配目标地址;
+                        finishTask.Item2.Data.VoucherNo++;
                     }
                 });
             });