涂布入库巷道分配点，新增互锁机制

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

@@ -254,106 +254,117 @@ namespace WCS.Service.Works.Station
         {
             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 key = $"WCS:Lock:CoatingAllocationTunnel";
+                try
                 {
-                    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();
+                    if (ProtocolProxy.YG150Redis.Get(key) != null) throw new WarnException($"[CoatingAllocationTunnel]--触发并发管控");
+                    ProtocolProxy.YG150Redis.Set(key, key);
+                    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);
+                        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 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();
+                        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 taskInStation = Device.Where(p => p.CODE.StartsWith("G") && p.DEVICEGROUP.Any(d => d.MEMBER == rgvDeliveryPoint.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
+                        List<TunnelInfo> tunnelInfos = new List<TunnelInfo>();
+                        foreach (var item in tunnels)
                         {
-                            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("无可用巷道");
+                            //当前巷道的取货点
+                            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 taskInStation = Device.Where(p => p.CODE.StartsWith("G") && p.DEVICEGROUP.Any(d => d.MEMBER == rgvDeliveryPoint.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 = $"下达从{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();
+                    });
 
-                    //开始变更任务信息
-                    foreach (var item in devs)
+                    // 开始将任务信息写入到设备
+                    DB.Do(db =>
                     {
-                        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++;
+                        }
+                    });
+                }
+                finally
                 {
-                    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++;
-                    }
-                });
+                    ProtocolProxy.YG150Redis.Del(key);
+                }
             });
         }