1

czw

5 天以前 3fac3fde950fac3057e5766fa350f20d454b53a0

 2025Äê6ÔÂ12ÈÕ/AuxAllWCS/Build/Project/´úÂë/VS×Ô¶¨ÒåÀà/AutoThread.cs

@@ -137,24 +137,35 @@
            {
                try
                {
                    foreach (var ip in new List<string> {
                    device1.p发那科1下线.Config.IP,
                    device1.p发那科2下线.Config.IP,
                    device1.D定子1号机械手.Config.IP,
                    device1.D定子2号机械手.Config.IP,
                    device1.Js捷顺1.Config.IP,
                    device1.Js捷顺2.Config.IP,
                    device1.维希尔抓臂1.Config.IP,
                    device1.维希尔抓臂2.Config.IP,
                    device1.RGV.Config.IP
                })
                    {
                        string pattern = @"\b(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\b";
                    //    foreach (var ip in new List<string> {
                    //    device1.p发那科1下线.Config.IP,
                    //    device1.p发那科2下线.Config.IP,
                    //    device1.D定子1号机械手.Config.IP,
                    //    device1.D定子2号机械手.Config.IP,
                    //    device1.Js捷顺1.Config.IP,
                    //    device1.Js捷顺2.Config.IP,
                    //    device1.维希尔抓臂1.Config.IP,
                    //    device1.维希尔抓臂2.Config.IP,
                    //    device1.RGV.Config.IP,
                    //    device1.S1002Read.Config.IP,
                    //    device1.S2001Read.Config.IP,
                    //    device1.S3001Read.Config.IP
                    //})
                    //    {
                    //        string pattern = @"\b(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\b";

                        var matches = Regex.Match(ip, pattern);
                        if (matches.Success)
                            IsMachineOnline(matches.Value);
                    }
                    //        var matches = Regex.Match(ip, pattern);
                    //        if (matches.Success)
                    //        {
                    //            var b = IsMachineOnline(matches.Value);
                    //            if (!Iponlines.ContainsKey(ip))
                    //            {
                    //                Iponlines.TryAdd(ip, b);
                    //            }
                    //            else
                    //                Iponlines[ip] = b;
                    //        }
                    //    }
                }
                catch (Exception ex)
                {
@@ -177,12 +188,10 @@
            tasks.Add(GetTask(sa3006, tag, 3000));
            tasks.Add(GetTask(sa3010, tag, 3000));




            Task.WaitAll(tasks.ToArray());
        }

        public static ConcurrentDictionary<string, bool> Iponlines = new ConcurrentDictionary<string, bool>();
        public bool IsMachineOnline(string hostNameOrIp, int timeout = 1000)
        {
            //device.p发那科1下线.Config.IP
@@ -468,7 +477,7 @@
            if (VERX != null)
            {
                if (tag.wxr1.R46)
                    LogHelper.Info($"{VERX.deviceName} R44>{tag.wxr1.R46} R44LAST>{tag.wxr1.R46_LAST} R10>{tag.wxr1.R11}");
                    LogHelper.Info($"{VERX.deviceName} R46>{tag.wxr1.R46} R46LAST>{tag.wxr1.R46_LAST} R11>{tag.wxr1.R11}");
                if (tag.wxr1.R46 && !tag.wxr1.R46_LAST && tag.wxr1.R11)
                {
                    if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode) && !string.IsNullOrEmpty(traycode.Trim()))
@@ -633,7 +642,7 @@
            if (VERX != null)
            {
                if (tag.wxr2.R46)
                    LogHelper.Info($"{VERX.deviceName} R44>{tag.wxr2.R46} R44LAST>{tag.wxr2.R46_LAST} R10>{tag.wxr2.R11}");
                    LogHelper.Info($"{VERX.deviceName} R46>{tag.wxr2.R46} R46LAST>{tag.wxr2.R46_LAST} R11>{tag.wxr2.R11}");
                if (tag.wxr2.R46 && !tag.wxr2.R46_LAST && tag.wxr2.R11)
                {
                    if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode) && !string.IsNullOrEmpty(traycode.Trim()))
@@ -655,7 +664,7 @@
                    }
                    else
                    {
                        TcpServer.TcpServerSend(VERX.deviceNo[2], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E"));
                        TcpServer.TcpServerSend(VERX.deviceNo[1], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E"));
                    }
                }
                else
@@ -768,15 +777,25 @@

                LogHelper.Info($"查看RGV ç”µé‡ï¼šã€{tag.RGV.R当前电量}】 å……电状态：【{tag.RGV.R充电状态}】 æ•…障代码：【{tag.RGV.RgvrunError}】 æ‰‹åŠ¨1自动2【{tag.RGV.R手动1自动2}】");

                if (tag.RGV.R充电状态 == 1)
                {
                    LogHelper.Info($"RGV å……电模式，不用管。");
                    return;
                }
                if (tag.RGV.R手动1自动2 == 1)
                {
                    LogHelper.Info($"RGV æ‰‹åŠ¨æ¨¡å¼ï¼Œä¸ç”¨ç®¡ã€‚");
                    return;
                }
                if (tag.RGV.RgvrunError > 0)
                {
                    LogHelper.Info($"RGV æ•…障，不用管。");
                    return;
                }
                LogHelper.Info($"RGV125命令查看 ä»»åŠ¡æ•°æ® workmode:{tag.RGV.workMod}\n taskmod{tag.RGV.taskmod} \n t1No:{tag.RGV.taskno1}\n t1do:{tag.RGV.task1do} \n t2No:{tag.RGV.taskno2}\n t2do:{tag.RGV.task2do}\n taskend:{tag.RGV.taskend} ");
                if (tag.RGV.taskend == 125)
                {
                    LogHelper.Info($"RGV æœ‰125命令未执行。 ");
                    LogHelper.Info($"RGV125命令未执行 ä»»åŠ¡æ•°æ® workmode:{tag.RGV.workMod}\n taskmod{tag.RGV.taskmod} \n t1No:{tag.RGV.taskno1}\n t1do:{tag.RGV.task1do} \n t2No:{tag.RGV.taskno2}\n t2do:{tag.RGV.task2do}\n taskend:{tag.RGV.taskend} ");

                    if (tag.RGV.workMod == 0 && tag.RGV.taskmod == 0 && tag.RGV.taskno1 == tag.RGV.ReadTask1No && tag.RGV.taskno2 == tag.RGV.ReadTask2No)
                    {
@@ -916,9 +935,22 @@
                //        var b = RedisHelper.Remove("RGVQueue", out rev);
                //    }
                //}
                var tklistall = taskservice.FindList(x => x.S_B_STATE != "完成" && x.S_B_STATE != "取消" && x.S_WORK_MODE == "RGV").OrderBy(x => x.T_CREATE).ToList();
                var tklist = tklistall.FindAll(x => x.S_B_STATE == "未执行");
                var tkunNormal = tklistall.Except(tklist);
                if (tkunNormal.Any())
                    foreach (var tk in tkunNormal)
                    {
                        if (tk.S_TASK_NO != task1?.S_TASK_NO && tk.S_TASK_NO != task2?.S_TASK_NO)
                        {
                            tk.S_B_STATE = "取消";
                            tk.S_NOTE = "不在执行队列中,取消";
                            taskservice.Update(tk);
                        }
                    }

                ///1 æœ‰è´§  å°±2 å–。  1 æ²¡è´§ å°±2 å¸è´§ï¼Œ éƒ½æœ‰è´§  å°±1卸货。 éƒ½æ²¡è´§ å°±1卸
                var tklist = taskservice.FindList(x => x.S_B_STATE == "未执行" && x.S_WORK_MODE == "RGV").OrderBy(x => x.T_CREATE).ToList();
                // taskservice.FindList(x => x.S_B_STATE == "未执行" && x.S_WORK_MODE == "RGV").OrderBy(x => x.T_CREATE).ToList();
                if (task1 != null && task1.S_B_STATE != "完成") //1有任务
                {
                    if (task2 != null && task2.S_B_STATE != "完成")// 1 æœ‰ä»»åŠ¡  2 æœ‰ä»»åŠ¡ã€‚ 
@@ -1290,7 +1322,10 @@
                                            continuuuuu = true;
                                        }
                                        else
                                        {
                                            SetRedistoPlc("A1019取货交互.Ssetreq", "true", "A1019取货交互Queue", "写AGV申请");
                                            tag.SA1019.StaskMode = 1;
                                        }
                                    }
                                    break;
                                case "1030":
@@ -1301,7 +1336,10 @@
                                            continuuuuu = true;
                                        }
                                        else
                                        {
                                            SetRedistoPlc("A1030取货交互.Ssetreq", "true", "A1030取货交互Queue", "写AGV申请");
                                            tag.SA1030.StaskMode = 1;
                                        }
                                    }
                                    break;
                                case "2030":
@@ -1312,7 +1350,10 @@
                                            continuuuuu = true;
                                        }
                                        else
                                        {
                                            SetRedistoPlc("A2030取货交互.Ssetreq", "true", "A2030取货交互Queue", "写AGV申请");
                                            tag.SA2030.StaskMode = 1;
                                        }
                                    }
                                    break;
                                case "3005":
@@ -1323,7 +1364,10 @@
                                            continuuuuu = true;
                                        }
                                        else
                                        {
                                            SetRedistoPlc("A3005取货交互.Ssetreq", "true", "A3005取货交互Queue", "写AGV申请");
                                            tag.ssx输送线.s3005.StaskMode = 1;
                                        }
                                    }
                                    break;
                                case "3010":
@@ -1334,7 +1378,10 @@
                                            continuuuuu = true;
                                        }
                                        else
                                        {
                                            SetRedistoPlc("A3010取货交互.Ssetreq", "true", "A3010取货交互Queue", "写AGV申请");
                                            tag.ssx输送线.s3010.StaskMode = 1;
                                        }
                                    }
                                    break;
                                //}
@@ -1348,7 +1395,10 @@
                                            continuuuuu = true;
                                        }
                                        else
                                        {
                                            SetRedistoPlc("A1022放货交互.Ssetreq", "true", "A1022放货交互Queue", "写AGV申请");
                                            tag.SA1022.StaskMode = 2;
                                        }
                                    }
                                    break;
                                case "1025":
@@ -1359,7 +1409,10 @@
                                            continuuuuu = true;
                                        }
                                        else
                                        {
                                            SetRedistoPlc("A1025放货交互.Ssetreq", "true", "A1025放货交互Queue", "写AGV申请");
                                            tag.SA1025.StaskMode = 2;
                                        }
                                    }
                                    break;
                                case "2001":
@@ -1370,7 +1423,10 @@
                                            continuuuuu = true;
                                        }
                                        else
                                        {
                                            SetRedistoPlc("A2001放货交互.Ssetreq", "true", "A2001放货交互Queue", "写AGV申请");
                                            tag.SA2001.StaskMode = 2;
                                        }
                                    }
                                    break;
                                case "3001":
@@ -1381,7 +1437,10 @@
                                            continuuuuu = true;
                                        }
                                        else
                                        {
                                            SetRedistoPlc("A3001放货交互.Ssetreq", "true", "A3001放货交互Queue", "写AGV申请");
                                            tag.ssx输送线.s3001.StaskMode = 2;
                                        }
                                    }
                                    break;
                                case "3006":
@@ -1392,7 +1451,10 @@
                                            continuuuuu = true;
                                        }
                                        else
                                        {
                                            SetRedistoPlc("A3006放货交互.Ssetreq", "true", "A3006放货交互Queue", "写AGV申请");
                                            tag.ssx输送线.s3006.StaskMode = 2;
                                        }
                                    }
                                    break;
                            }
@@ -1440,7 +1502,7 @@
                            {

                                var close = (System.UInt16)System.Convert.ChangeType(Conn.默认Redis.GetValue(dev.deviceName + "." + (V ? "D2220" : "D2225")), typeof(System.UInt16));
                                if (close == 1)
                                if (close == 0)
                                {
                                    LogHelper.Info($"{dev.deviceName}{(V ? "å·¦" : "右")} å…‰æ …{(goin ? "关闭" : "开启")} ç”³è¯·ã€‚ å·²ç»å…³é—­ï¼");
                                    continuuuuu = true;
@@ -1510,18 +1572,22 @@
                //一线地址：10.221.55.181     ç«¯å£ï¼š6000
                //if (IsMachineOnline("10.221.55.181"))
                {
                    //if (tag.DZ1.D2211 == 1 && tag.DZ1.D2220 == 1)
                    //    tag.DZ1.D2211 = 0;
                    //if (tag.DZ1.D2216 == 1 && tag.DZ1.D2225 == 1)
                    //    tag.DZ1.D2216 = 0;
                    if (tag.DZ1.D2211 == 1 && tag.DZ1.D2220 == 1)
                        //tag.DZ1.D2211 = 0;
                        Conn.默认Redis.SetValue("D定子1号机械手.D2211", "0", "D定子1号机械手Queue", false);
                    if (tag.DZ1.D2216 == 1 && tag.DZ1.D2225 == 1)
                        //tag.DZ1.D2216 = 0;
                        Conn.默认Redis.SetValue("D定子1号机械手.D2216", "0", "D定子1号机械手Queue", false);
                }
                //二线地址：10.221.55.179     ç«¯å£ï¼š6000
                //if (IsMachineOnline("10.221.55.179"))
                {
                    //if (tag.DZ2.D2211 == 1 && tag.DZ2.D2220 == 1)
                    //    tag.DZ2.D2211 = 0;
                    //if (tag.DZ2.D2216 == 1 && tag.DZ2.D2225 == 1)
                    //    tag.DZ2.D2216 = 0;
                    if (tag.DZ2.D2211 == 1 && tag.DZ2.D2220 == 1)
                        //tag.DZ2.D2211 = 0;
                        Conn.默认Redis.SetValue("D定子2号机械手.D2211", "0", "D定子2号机械手Queue", false);
                    if (tag.DZ2.D2216 == 1 && tag.DZ2.D2225 == 1)
                        //tag.DZ2.D2216 = 0;
                        Conn.默认Redis.SetValue("D定子2号机械手.D2216", "0", "D定子2号机械手Queue", false);
                }
            }
            LogHelper.Info($"ThreadGrats deviceType5光栅写入位重置完成。 =================> ");
@@ -1533,6 +1599,11 @@
        public void ThreadEdown(Tag tag)
        {
            Console.WriteLine($"ThreadEdown 20 23 = ç©ºä¸‹æ£€æµ‹ =================> ");
            if (tag.RGV.R充电状态 == 1 || tag.RGV.R手动1自动2 == 1 || tag.RGV.RgvrunError > 0)
            {
                LogHelper.Info($"RGV æ‰‹åŠ¨||故障||充电，空下检测终止。");
                return;
            }
            TaskRepository taskRepository = new TaskRepository();
            foreach (var Bssx in new string[] { "1020", "1023" })
            {
@@ -1639,7 +1710,12 @@

        public void ThreadDdown(Tag tag)
        {
            Console.WriteLine($"ThreadDdown 08 10 ==================> 1026");
            Console.WriteLine($"ThreadDdown 08 16==================> 1026");
            if (tag.RGV.R充电状态 == 1 || tag.RGV.R手动1自动2 == 1 || tag.RGV.RgvrunError > 0)
            {
                LogHelper.Info($"RGV æ‰‹åŠ¨||故障||充电，08 16 > 1026终止。");
                return;
            }
            TaskRepository taskRepository = new TaskRepository();
            foreach (var Bssx in new string[] { "1008", "1016" })
            {
@@ -1676,6 +1752,19 @@
                        {
                            RedisHelper.Add($"S{Bssx}Read.RtaskState_LAST", "1", out msg);
                            RedisHelper.Add($"S{item}Read.R5空闲_LAST", "1", out string msg2);

                            LogHelper.Info($"{R托盘码} å®šå­ç”Ÿäº§å®Œæˆè¿›è¡Œé²å·¥ï¼ï¼");
                            var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/223", JsonConvert.SerializeObject(new
                            {
                                cntrCode = R托盘码,
                                type = 1,
                                lineCode = "1002,1008".Contains(Bssx) ? "T01" : "T02"
                            }));
                            //var strr = JsonConvert.DeserializeObject<MES2234>(str);
                            //if (strr.success && strr.data != null)
                            //{

                            //}
                            //Conn.默认Redis.SetValue($"S{Bssx}Read.RtaskState_LAST", "1", $"S{Bssx}ReadQueue");
                            //Conn.默认Redis.SetValue($"S{item}Read.R5空闲_LAST", "1", $"S{item}ReadQueue");
                            break;
@@ -1698,6 +1787,11 @@
        public void Thread0210Down(Tag tag)
        {
            Console.WriteLine($"Thread0210Down ==================>");
            if (tag.RGV.R充电状态 == 1 || tag.RGV.R手动1自动2 == 1 || tag.RGV.RgvrunError > 0)
            {
                LogHelper.Info($"RGV æ‰‹åŠ¨||故障||充电，02 10 > 1017终止。");
                return;
            }
            TaskRepository taskRepository = new TaskRepository();
            foreach (var Bssx in new string[] { "1002", "1010" })
            {
@@ -1733,6 +1827,13 @@
                        {
                            RedisHelper.Add($"S{Bssx}Read.RtaskState_LAST", "1", out msg);
                            RedisHelper.Add($"S{item}Read.R5空闲_LAST", "1", out string msg1);
                            LogHelper.Info($"{R托盘码} è½¬å­ç”Ÿäº§å®Œæˆè¿›è¡Œé²å·¥ï¼ï¼");
                            var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/223", JsonConvert.SerializeObject(new
                            {
                                cntrCode = R托盘码,
                                type = 2,
                                lineCode = "1002,1008".Contains(Bssx) ? "T01" : "T02"
                            }));
                            //Conn.默认Redis.SetValue($"S{Bssx}Read.RtaskState_LAST", "1", $"S{Bssx}ReadQueue");
                            //Conn.默认Redis.SetValue($"S{item}Read.R5空闲_LAST", "1", $"S{item}ReadQueue");
                            break;
@@ -1775,6 +1876,7 @@
                            {
                                LogHelper.Info($"ssx == 1003 && tag.SF下料位.WRelease1003:{tag.SF下料位.WRelease1003}  å†™f1 2210=1，Arrive{ssx}BarcodeLast={RtrayCode}");
                                tag.FNK1.D2210 = 1;
                                //Conn.默认Redis.SetValue($"p发那科1下线.D2210", "1", $"p发那科1下线Queue",false);
                            }
                            break;
                        case "1005":
@@ -1815,33 +1917,33 @@

                if (WRelease == 1 && rReleaseOver == 1)
                {
                    switch (ssx)
                    {
                        case "1003":
                            {
                                LogHelper.Info($"读{ssx} WRelease=1&& rReleaseOver=1  è¯»FNK1.D2213{tag.FNK1.D2213}=1? å¹¶å†™0");
                                tag.FNK1.D2213 = 0;
                            }
                            break;
                        case "1005":
                            {
                                LogHelper.Info($"读{ssx} WRelease=1&& rReleaseOver=1  è¯»FNK1.D2218{tag.FNK1.D2218}=1? å¹¶å†™0");
                                tag.FNK1.D2218 = 0;
                            }
                            break;
                        case "1011":
                            {
                                LogHelper.Info($"读{ssx} WRelease=1&& rReleaseOver=1  è¯»FNK2.D2213{tag.FNK1.D2213}=1? å¹¶å†™0");
                                tag.FNK2.D2213 = 0;
                            }
                            break;
                        case "1013":
                            {
                                LogHelper.Info($"读{ssx} WRelease=1&& rReleaseOver=1  è¯»FNK2.D2218{tag.FNK2.D2218}=1?  å¹¶å†™0");
                                tag.FNK2.D2218 = 0;
                            }
                            break;
                    }
                    //switch (ssx)
                    //{
                    //    case "1003":
                    //        {
                    //            LogHelper.Info($"读{ssx} WRelease=1&& rReleaseOver=1  è¯»FNK1.D2213{tag.FNK1.D2213}=1? å¹¶å†™0");
                    //            tag.FNK1.D2213 = 0;
                    //        }
                    //        break;
                    //    case "1005":
                    //        {
                    //            LogHelper.Info($"读{ssx} WRelease=1&& rReleaseOver=1  è¯»FNK1.D2218{tag.FNK1.D2218}=1? å¹¶å†™0");
                    //            tag.FNK1.D2218 = 0;
                    //        }
                    //        break;
                    //    case "1011":
                    //        {
                    //            LogHelper.Info($"读{ssx} WRelease=1&& rReleaseOver=1  è¯»FNK2.D2213{tag.FNK1.D2213}=1? å¹¶å†™0");
                    //            tag.FNK2.D2213 = 0;
                    //        }
                    //        break;
                    //    case "1013":
                    //        {
                    //            LogHelper.Info($"读{ssx} WRelease=1&& rReleaseOver=1  è¯»FNK2.D2218{tag.FNK2.D2218}=1?  å¹¶å†™0");
                    //            tag.FNK2.D2218 = 0;
                    //        }
                    //        break;
                    //}
                    LogHelper.Info($"读{ssx} WRelease=1&& rReleaseOver=1  WRelease å†™0");
                    Conn.默认Redis.SetValue($"FNK1003051113.WRelease{ssx}", "0", $"FNK1003051113Queue");
                }
@@ -1857,7 +1959,7 @@
            if (tag.FNK1.D2217 == 1 && tag.FNK1.D2217_LAST == 0)
            {
                //tag.FNK1.D2215 = 0;
                tag.FNK1.D2218 = 1;
                //tag.FNK1.D2218 = 1;
                //tag.FNK1.D2212_LAST = 1;
                RedisHelper.Add($"p发那科1下线.D2217_LAST", "1", out string msg);

@@ -1884,7 +1986,7 @@
            LogHelper.Info($" FN1 D2212>{tag.FNK1.D2212} D2212LAST>{tag.FNK1.D2212_LAST} D2210>{tag.FNK1.D2210} D2211>{tag.FNK1.D2211} D2213>{tag.FNK1.D2213}");
            if (tag.FNK1.D2212 == 1 && tag.FNK1.D2212_LAST == 0)
            {
                tag.FNK1.D2213 = 1;
                //tag.FNK1.D2213 = 1;
                //tag.FNK1.D2210 = 0;
                //tag.FNK1.D2217_LAST = 1;
                RedisHelper.Add($"p发那科1下线.D2212_LAST", "1", out string msg);
@@ -1919,7 +2021,7 @@
            if (tag.FNK2.D2217 == 1 && tag.FNK2.D2217_LAST == 0)
            {
                //tag.FNK2.D2215 = 0;
                tag.FNK2.D2218 = 1;
                //tag.FNK2.D2218 = 1;
                //tag.FNK2.D2212_LAST = 1;
                RedisHelper.Add($"p发那科2下线.D2217_LAST", "1", out string msg);

@@ -1948,7 +2050,7 @@
            if (tag.FNK2.D2212 == 1 && tag.FNK2.D2212_LAST == 0)
            {
                //tag.FNK2.D2210 = 0;
                tag.FNK2.D2213 = 1;
                //tag.FNK2.D2213 = 1;
                //tag.FNK2.D2217_LAST = 1;
                RedisHelper.Add($"p发那科2下线.D2212_LAST", "1", out string msg);

@@ -1978,8 +2080,8 @@
        {
            var taggg = tag.SA1019;
            string vqu = "A1019取货交互";
            Console.WriteLine($"1019任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            LogHelper.Info($"1019任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (taggg.SOver && taggg.SreadAgvover)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
@@ -1991,18 +2093,38 @@
        private void sa2008(Tag tag)
        {
            var rdisTcode = RedisHelper.Get<string>($"Arrive{2008}BarcodeLast", out string msg);
            //if(tag.ssx输送线.s2008)
            LogHelper.Info($"2008 æ‰˜ç›˜å·{tag.SA2030.R托盘码}  redis Arrive{2008}BarcodeLast托盘号：{rdisTcode} åŒ¹é…æ ¡éªŒã€‚");
            if (!string.IsNullOrEmpty(tag.ssx输送线.s2008.R托盘码) && rdisTcode != tag.ssx输送线.s2008.R托盘码)
            {
                var ntr = tag.ssx输送线.s2008.R托盘码;
                var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/224", JsonConvert.SerializeObject(new
                {
                    cntrCode = ntr,
                    type = 1
                }));
                var strr = JsonConvert.DeserializeObject<MES2234>(str);
                if (strr.success && strr.data != null)
                {
                    var end = (strr.data.lineNum == 1 ? 2027
                                : strr.data.lineNum == 2 ? 2020 : 2013);
                    tag.ssx输送线.s2008.wTaskNo = (uint)(20080000 + end);
                    tag.ssx输送线.s2008.wEbit = 2027;
                    tag.ssx输送线.s2008.R托盘码 = ntr;
                    RedisHelper.Add<string>($"Arrive{2008}BarcodeLast", ntr, out msg);
                }
            }
        }

        private void sa2030(Tag tag)
        {
            var taggg = tag.SA2030;
            string vqu = "A2030取货交互";
            Console.WriteLine($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            LogHelper.Info($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (taggg.SOver && taggg.SreadAgvover)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "清AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "清AGV申请");
                SetRedistoPlc(vqu + ".StaskMode", "0", vqu + "Queue", "清AGV申请");
            }
        }

@@ -2010,11 +2132,12 @@
        {
            var taggg = tag.SA2001;
            string vqu = "A2001放货交互";
            Console.WriteLine($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            LogHelper.Info($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (taggg.SOver && taggg.SreadAgvover)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "清AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "清AGV申请");
                SetRedistoPlc(vqu + ".StaskMode", "0", vqu + "Queue", "清AGV申请");
            }
        }

@@ -2022,11 +2145,12 @@
        {
            var taggg = tag.SA1030;
            string vqu = "A1030取货交互";
            Console.WriteLine($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            LogHelper.Info($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (taggg.SOver && taggg.SreadAgvover)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".StaskMode", "0", vqu + "Queue", "写AGV申请");
            }
        }

@@ -2034,11 +2158,12 @@
        {
            var taggg = tag.SA1025;
            string vqu = "A1025放货交互";
            Console.WriteLine($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            LogHelper.Info($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (taggg.SOver && taggg.SreadAgvover)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "清AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "清AGV申请");
                SetRedistoPlc(vqu + ".StaskMode", "0", vqu + "Queue", "清AGV申请");
            }
        }

@@ -2046,11 +2171,12 @@
        {
            var taggg = tag.SA1022;
            string vqu = "A1022放货交互";
            Console.WriteLine($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            LogHelper.Info($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (taggg.SOver && taggg.SreadAgvover)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "清AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "清AGV申请");
                SetRedistoPlc(vqu + ".StaskMode", "0", vqu + "Queue", "清AGV申请");
            }
        }

@@ -2058,11 +2184,12 @@
        {
            var taggg = tag.ssx输送线.s3010;
            string vqu = "A3010取货交互";
            Console.WriteLine($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            LogHelper.Info($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (taggg.SOver && taggg.SreadAgvover)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "清AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "清AGV申请");
                SetRedistoPlc(vqu + ".StaskMode", "0", vqu + "Queue", "清AGV申请");
            }
        }

@@ -2070,11 +2197,12 @@
        {
            var taggg = tag.ssx输送线.s3006;
            string vqu = "A3006放货交互";
            Console.WriteLine($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            LogHelper.Info($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (taggg.SOver && taggg.SreadAgvover)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "清AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "清AGV申请");
                SetRedistoPlc(vqu + ".StaskMode", "0", vqu + "Queue", "清AGV申请");
            }
        }

@@ -2082,11 +2210,12 @@
        {
            var taggg = tag.ssx输送线.s3005;
            string vqu = "A3005取货交互";
            Console.WriteLine($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            LogHelper.Info($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (taggg.SOver && taggg.SreadAgvover)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "清AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "清AGV申请");
                SetRedistoPlc(vqu + ".StaskMode", "0", vqu + "Queue", "清AGV申请");
            }
        }

@@ -2094,11 +2223,12 @@
        {
            var taggg = tag.ssx输送线.s3010;
            string vqu = "A3001放货交互";
            Console.WriteLine($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            LogHelper.Info($"{vqu}任务状态：   =====>任务申请：{taggg.Ssetreq},输送线允许：{taggg.SreadCan} ä»»åŠ¡å®Œæˆï¼š{taggg.SOver} è¾“送线收到完成：{taggg.SreadAgvover}");
            if (taggg.SOver && taggg.SreadAgvover)
            {
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "写AGV申请");
                SetRedistoPlc(vqu + ".Ssetreq", "false", vqu + "Queue", "清AGV申请");
                SetRedistoPlc(vqu + ".SOver", "false", vqu + "Queue", "清AGV申请");
                SetRedistoPlc(vqu + ".StaskMode", "0", vqu + "Queue", "清AGV申请");
            }
        }

@@ -2124,7 +2254,19 @@
        }
        public void Thread1030Down(Tag tag)
        {
            //Console.WriteLine($"SA1030 ä»»åŠ¡çŠ¶æ€ï¼š   =====>agv完成SOver{tag.SA1030.SOver}");
            Console.WriteLine($"SA1030 ä»»åŠ¡çŠ¶æ€ï¼š   =====>");
            if (tag.SA1030.RtaskState == 4 && tag.SA1030.RtaskState_LAST == 0 && tag.SA2001.R5空闲 == 5)
            {
                var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new
                {
                    requestType = 10,
                    startBit = "1030",
                    endBit = "2001",
                }));
                RedisHelper.Add($"S1030Read.RtaskState_LAST", "1", out string msg);
            }
            else if (tag.SA1030.RtaskState != 4 && tag.SA1030.RtaskState_LAST == 1)
                RedisHelper.Add($"S1030Read.RtaskState_LAST", "0", out string msg);
            //if (tag.SA1019.SOver && tag.SA1019.SreadSsxOver)
            //{
            //    SetRedistoPlc("A1022放货交互.Ssetreq", "false", "A1022放货交互Queue", "清理");
@@ -2459,9 +2601,9 @@
                                case "1022":
                                    {
                                        type = "A008";
                                        if (tag.SA1022.R5空闲 != 1)
                                        if (tag.SA1022.R5空闲 != 5)
                                        {
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹1022 éžç©ºé—²ï¼Œä¸æŽ¨é€");
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹1022 >{tag.SA1022.R5空闲} éžç©ºé—²ï¼Œä¸æŽ¨é€");
                                            continue;
                                        }
                                    }
@@ -2469,9 +2611,9 @@
                                case "1025":
                                    {
                                        type = "A007";
                                        if (tag.SA1025.R5空闲 != 1)
                                        if (tag.SA1025.R5空闲 != 5)
                                        {
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹ 1025 éžç©ºé—²ï¼Œä¸æŽ¨é€");
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹ 1025 >{tag.SA1025.R5空闲} éžç©ºé—²ï¼Œä¸æŽ¨é€");
                                            continue;
                                        }
                                    }
@@ -2479,9 +2621,9 @@
                                case "2001":
                                    {
                                        type = "A007";
                                        if (tag.SA2001.R5空闲 != 1)
                                        if (tag.SA2001.R5空闲 != 5)
                                        {
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹ 2001 éžç©ºé—²ï¼Œä¸æŽ¨é€");
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹ 2001>{tag.SA2001.R5空闲} éžç©ºé—²ï¼Œä¸æŽ¨é€");
                                            continue;
                                        }
                                    }
@@ -2489,9 +2631,9 @@
                                case "3001":
                                    {
                                        type = "A010";
                                        if (tag.ssx输送线.s3001.R5空闲 != 1)
                                        if (tag.ssx输送线.s3001.R5空闲 != 5)
                                        {
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹ 3001 éžç©ºé—²ï¼Œä¸æŽ¨é€");
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹ 3001>{tag.ssx输送线.s3001.R5空闲} éžç©ºé—²ï¼Œä¸æŽ¨é€");
                                            continue;
                                        }
                                    }
@@ -2499,9 +2641,9 @@
                                case "3006":
                                    {
                                        type = "A010";
                                        if (tag.ssx输送线.s3006.R5空闲 != 1)
                                        if (tag.ssx输送线.s3006.R5空闲 != 5)
                                        {
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹ 3006 éžç©ºé—²ï¼Œä¸æŽ¨é€");
                                            LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç»ˆç‚¹ 3006>{tag.ssx输送线.s3001.R5空闲} éžç©ºé—²ï¼Œä¸æŽ¨é€");
                                            continue;
                                        }
                                    }
@@ -2510,7 +2652,7 @@

                        LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç›´æŽ¥ç”Ÿæˆå¯¹åº”任务");
                        //直接生成对应任务。
                        var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_START_LOC, task.S_END_LOC, task.S_TYPE, 6, task.S_CNTRS?.Split(',').ToList() ?? new List<string>(), type);
                        var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_START_LOC, task.S_END_LOC, task.S_TYPE, 6, task.S_CNTRS?.Split(',').ToList() ?? new List<string>(), "AGV", type);

                        LogHelper.Info($"解释MES任务 ->{task.S_TASK_NO} ç›´æŽ¥ç”Ÿæˆå¯¹åº”任务 ç»“果：{res}");
                        if (res)
@@ -2655,7 +2797,7 @@

        public string procNo()
        {
            return TaskProcess.GenerateTaskNo("日志流水号");
            return TaskProcess.GenerateTaskNo("日志流水号", "LOG");
        }
        public bool SetRedistoPlc(string key, string value, string queue, string desc)
        {
@@ -3002,6 +3144,7 @@
                {
                    requestType = 7,
                    startBit = VERX.location[0],
                    endBit = "1025",
                    unLockStartBitOutbin = true
                }));
                LogHelper.Info($"{VERX.location[0]}申请mes任务结果{str}");
@@ -3025,6 +3168,7 @@
                {
                    requestType = 7,
                    startBit = VERX.location[1],
                    endBit = "1025",
                    unLockStartBitOutbin = true
                }));
                LogHelper.Info($"{VERX.location[0]}申请mes任务结果{str}");
@@ -3054,13 +3198,14 @@
                LogHelper.Info("定子2号线 deviceType 5 æ²¡æœ‰é…ç½®ã€‚");
                return;
            }
            LogHelper.Info($" {VERX.deviceName} D2221>{tag.DZ1.D2221} D2221_LAST>{tag.DZ1.D2221_LAST}  D2226>{tag.DZ1.D2226}  D2226_LAST>{tag.DZ1.D2226_LAST}");
            LogHelper.Info($" {VERX.deviceName} D2221>{tag.DZ2.D2221} D2221_LAST>{tag.DZ2.D2221_LAST}  D2226>{tag.DZ2.D2226}  D2226_LAST>{tag.DZ2.D2226_LAST}");
            if (tag.DZ2.D2221 == 1 && tag.DZ2.D2221_LAST == 0)
            {
                var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new
                {
                    requestType = 7,
                    startBit = VERX.location[0],
                    endBit = "1025",
                    unLockStartBitOutbin = true
                }));
                LogHelper.Info($"{VERX.location[0]}申请mes任务结果{str}");
@@ -3083,6 +3228,7 @@
                {
                    requestType = 7,
                    startBit = VERX.location[1],
                    endBit = "1025",
                    unLockStartBitOutbin = true
                }));
                LogHelper.Info($"{VERX.location[0]}申请mes任务结果{str}");