From e52744716da77be232ac6ecc7573a2ef2294e65c Mon Sep 17 00:00:00 2001 From: czw <selecti@yeah.net> Date: 星期五, 27 六月 2025 16:18:20 +0800 Subject: [PATCH] 1 --- 2025年6月12日/AuxAllWCS/Build/Project/代码/VS自定义类/AutoThread.cs | 315 ++++++++++++++++++++++++++++++++++++++------------- 1 files changed, 232 insertions(+), 83 deletions(-) diff --git "a/2025\345\271\2646\346\234\21012\346\227\245/AuxAllWCS/Build/Project/\344\273\243\347\240\201/VS\350\207\252\345\256\232\344\271\211\347\261\273/AutoThread.cs" "b/2025\345\271\2646\346\234\21012\346\227\245/AuxAllWCS/Build/Project/\344\273\243\347\240\201/VS\350\207\252\345\256\232\344\271\211\347\261\273/AutoThread.cs" index e452ea6..8e30962 100644 --- "a/2025\345\271\2646\346\234\21012\346\227\245/AuxAllWCS/Build/Project/\344\273\243\347\240\201/VS\350\207\252\345\256\232\344\271\211\347\261\273/AutoThread.cs" +++ "b/2025\345\271\2646\346\234\21012\346\227\245/AuxAllWCS/Build/Project/\344\273\243\347\240\201/VS\350\207\252\345\256\232\344\271\211\347\261\273/AutoThread.cs" @@ -1,4 +1,5 @@ -锘縰sing Newtonsoft.Json; +#region [鑷畾涔夌被-VS][20250623083459471][AutoThread] +using Newtonsoft.Json; using System; using System.Collections.Generic; using System.Collections.Concurrent; @@ -14,6 +15,8 @@ using static System.Windows.Forms.VisualStyles.VisualStyleElement; using System.Windows.Interop; using static System.Windows.Forms.VisualStyles.VisualStyleElement.TextBox; +using System.Security.Cryptography; +using System.Windows.Markup; namespace GZ.Projects.AuxAllWCS { @@ -103,6 +106,12 @@ { tag.Global.SettingsOver = 0; } + else tag.Global.SettingsOver++; + if (tag.Global.SettingsOver > 999) + { + tag.Global.SettingsOver = 1; + Console.Clear(); + } } /// <summary> @@ -124,16 +133,17 @@ endBit = VERX.location[0] })); LogHelper.Info($"{VERX.location[0]}鐢宠mes浠诲姟缁撴灉{str}"); - if (str.Contains("true")) + var strr = JsonConvert.DeserializeObject<Messss>(str); + if (strr != null && strr.success && strr.data?.state == 0) { //tag.Js1.D1212_LAST = 1; - RedisHelper.Add($"Js鎹烽『1.D1212_LAST", "1", out string msg); + RedisHelper.Add($"Js鎹烽『1.D1202_LAST", "1", out string msg); } } if (tag.Js1.D1212_LAST == 1 && TcpServer.GetBitdata(tag.Js1.D1212, 2) == 0) { //tag.Js1.D1212_LAST = 0; - RedisHelper.Add($"Js鎹烽『1.D1212_LAST", "0", out string msg); + RedisHelper.Add($"Js鎹烽『1.D1202_LAST", "0", out string msg); } if (tag.Js1.D1213_LAST == 0 && TcpServer.GetBitdata(tag.Js1.D1212, 3) == 1) { @@ -143,16 +153,17 @@ endBit = VERX.location[1] })); LogHelper.Info($"{VERX.location[1]}鐢宠mes浠诲姟缁撴灉{str}"); - if (str.Contains("true")) + var strr = JsonConvert.DeserializeObject<Messss>(str); + if (strr != null && strr.success && strr.data?.state == 0) { //tag.Js1.D1213_LAST = 1; - RedisHelper.Add($"Js鎹烽『1.D1213_LAST", "1", out string msg); + RedisHelper.Add($"Js鎹烽『1.D1203_LAST", "1", out string msg); } } if (tag.Js1.D1213_LAST == 1 && TcpServer.GetBitdata(tag.Js1.D1212, 3) == 0) { //tag.Js1.D1213_LAST = 0; - RedisHelper.Add($"Js鎹烽『1.D1213_LAST", "0", out string msg); + RedisHelper.Add($"Js鎹烽『1.D1203_LAST", "0", out string msg); } } } @@ -175,18 +186,17 @@ endBit = VERX.location[0] })); LogHelper.Info($"{VERX.location[0]}鐢宠mes浠诲姟缁撴灉{str}"); - if (str.Contains("true")) + var strr = JsonConvert.DeserializeObject<Messss>(str); + if (strr != null && strr.success && strr.data?.state == 0) { - //tag.Js2.D1212_LAST = 1; - - RedisHelper.Add($"Js鎹烽『1.D1212_LAST", "1", out string msg); + RedisHelper.Add($"Js鎹烽『2.D1202_LAST", "1", out string msg); } } if (tag.Js2.D1212_LAST == 1 && TcpServer.GetBitdata(tag.Js2.D1212, 2) == 0) { //tag.Js2.D1212_LAST = 0; - RedisHelper.Add($"Js鎹烽『1.D1212_LAST", "0", out string msg); + RedisHelper.Add($"Js鎹烽『2.D1202_LAST", "0", out string msg); } if (tag.Js2.D1213_LAST == 0 && TcpServer.GetBitdata(tag.Js2.D1212, 3) == 1) { @@ -196,18 +206,18 @@ endBit = VERX.location[1] })); LogHelper.Info($"{VERX.location[1]}鐢宠mes浠诲姟缁撴灉{str}"); - if (str.Contains("true")) - { - //tag.Js2.D1213_LAST = 1; - RedisHelper.Add($"Js鎹烽『1.D1213_LAST", "1", out string msg); + var strr = JsonConvert.DeserializeObject<Messss>(str); + if (strr != null && strr.success && strr.data?.state == 0) + { + RedisHelper.Add($"Js鎹烽『2.D1203_LAST", "1", out string msg); } } if (tag.Js2.D1213_LAST == 1 && TcpServer.GetBitdata(tag.Js2.D1213, 2) == 0) { //tag.Js2.D1213_LAST = 0; - RedisHelper.Add($"Js鎹烽『1.D1213_LAST", "0", out string msg); + RedisHelper.Add($"Js鎹烽『2.D1203_LAST", "0", out string msg); } } } @@ -234,9 +244,11 @@ endBit = "" })); LogHelper.Info($"{VERX.location[0]}鐢宠mes浠诲姟缁撴灉{str}"); - if (str.Contains("true")) + var strr = JsonConvert.DeserializeObject<Messss>(str); + if (strr != null && strr.success && strr.data?.state == 0) { - tag.wxr1.R44_LAST = true; + //tag.wxr1.R44_LAST = true; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R44_LAST", "true", out string msg); } } else @@ -251,7 +263,8 @@ { if (tag.wxr1.R10) { - tag.wxr1.R10_LAST = false; + //tag.wxr1.R10_LAST = false; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R10_LAST", "false", out string msg); } else if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[0], out string traycode)) @@ -267,7 +280,8 @@ { //Conn.榛樿Redis.SetValue("缁村笇灏旀姄鑷�.R10", "true", "缁村笇灏旀姄鑷�Queue"); tag.wxr1.R10 = true; - tag.wxr1.R44_LAST = false; + //tag.wxr1.R44_LAST = false; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R44_LAST", "false", out string msg); } else { @@ -303,9 +317,11 @@ endBit = "" })); LogHelper.Info($"{VERX.location[1]}鐢宠mes浠诲姟缁撴灉{str}"); - if (str.Contains("true")) + var strr = JsonConvert.DeserializeObject<Messss>(str); + if (strr != null && strr.success && strr.data?.state == 0) { - tag.wxr1.R46_LAST = true; + //tag.wxr1.R46_LAST = true; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R46_LAST", "true", out string msg); } } else @@ -319,7 +335,8 @@ { if (tag.wxr1.R11) { - tag.wxr1.R11_LAST = false; + //tag.wxr1.R11_LAST = false; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R11_LAST", "false", out string msg); } else if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode)) @@ -335,7 +352,8 @@ { //Conn.榛樿Redis.SetValue("缁村笇灏旀姄鑷�.R10", "true", "缁村笇灏旀姄鑷�Queue"); tag.wxr1.R11 = true; - tag.wxr1.R46_LAST = false; + //tag.wxr1.R46_LAST = false; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R46_LAST", "false", out string msg); } else { @@ -371,9 +389,11 @@ endBit = "" })); LogHelper.Info($"{VERX.location[0]}鐢宠mes浠诲姟缁撴灉{str}"); - if (str.Contains("true")) + var strr = JsonConvert.DeserializeObject<Messss>(str); + if (strr != null && strr.success && strr.data?.state == 0) { - tag.wxr2.R44_LAST = true; + //tag.wxr2.R44_LAST = true; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R44_LAST", "true", out string msg); } } else @@ -387,7 +407,8 @@ { if (tag.wxr2.R10) { - tag.wxr2.R10_LAST = false; + //tag.wxr2.R10_LAST = false; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R10_LAST", "false", out string msg); } else if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[0], out string traycode)) @@ -403,7 +424,8 @@ { //Conn.榛樿Redis.SetValue("缁村笇灏旀姄鑷�.R10", "true", "缁村笇灏旀姄鑷�Queue"); tag.wxr2.R10 = true; - tag.wxr2.R44_LAST = false; + //tag.wxr2.R44_LAST = false; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R44_LAST", "false", out string msg); } else { @@ -440,9 +462,11 @@ endBit = "" })); LogHelper.Info($"{VERX.location[1]}鐢宠mes浠诲姟缁撴灉{str}"); - if (str.Contains("true")) + var strr = JsonConvert.DeserializeObject<Messss>(str); + if (strr != null && strr.success && strr.data?.state == 0) { - tag.wxr2.R46_LAST = true; + //tag.wxr2.R46_LAST = true; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R46_LAST", "true", out string msg); } } else @@ -456,7 +480,8 @@ { if (tag.wxr2.R11) { - tag.wxr2.R11_LAST = false; + //tag.wxr2.R11_LAST = false; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R11_LAST", "false", out string msg); } else if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode)) @@ -472,7 +497,8 @@ { //Conn.榛樿Redis.SetValue("缁村笇灏旀姄鑷�.R10", "true", "缁村笇灏旀姄鑷�Queue"); tag.wxr2.R11 = true; - tag.wxr2.R46_LAST = false; + //tag.wxr2.R46_LAST = false; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R46_LAST", "false", out string msg); } else { @@ -494,7 +520,7 @@ ITaskRepository taskservice = new TaskRepository(); try { - LogHelper.Info("浠诲姟涓嬪彂 ARG 浠诲姟 杩涘叆"); + LogHelper.Info("浠诲姟涓嬪彂 AGV 浠诲姟 杩涘叆"); #region AGV浠诲姟涓嬪彂銆� var tklist = taskservice.FindList(x => x.S_B_STATE == "鏈墽琛� && x.S_WORK_MODE == "AGV"); @@ -535,21 +561,44 @@ } try { - LogHelper.Info("浠诲姟涓嬪彂 Rgv 浠诲姟 杩涘叆"); #region Rgv - LogHelper.Info($"鏌ョ湅RGV 鐢甸噺锛氥�{tag.RGV.R褰撳墠鐢甸噺}銆�鍏呯數鐘舵�锛氥�{tag.RGV.R鍏呯數鐘舵�}銆�鏁呴殰浠g爜锛氥�{tag.RGV.RgvrunError}銆�); + LogHelper.Info($"鏌ョ湅RGV 鐢甸噺锛氥�{tag.RGV.R褰撳墠鐢甸噺}銆�鍏呯數鐘舵�锛氥�{tag.RGV.R鍏呯數鐘舵�}銆�鏁呴殰浠g爜锛氥�{tag.RGV.RgvrunError}銆�鎵嬪姩1鑷姩2銆恵tag.RGV.R鎵嬪姩1鑷姩2}銆�); + + if (tag.RGV.R鎵嬪姩1鑷姩2 == 1) + { + LogHelper.Info($"RGV 鎵嬪姩妯″紡锛屼笉鐢ㄧ銆�); + return; + } + if (tag.RGV.taskend == 125) + { + LogHelper.Info($"RGV 鏈�25鍛戒护鏈墽琛屻�"); + System.Threading.Thread.Sleep(3000); + return; + } + LogHelper.Info("浠诲姟涓嬪彂 Rgv 浠诲姟 杩涘叆"); + + TaskEntity task1 = null; + TaskEntity task2 = null; var task1Isrun = false; if (tag.RGV.ReadTask1No > 0 && tag.RGV.bit1taskOver != 1) { - task1Isrun = true; + var taskno = tag.RGV.ReadTask1No; + string tno = "TN" + (DateTime.Now.ToString("yy")) + ((taskno.ToString()).PadLeft(8, '0')); + task1 = taskservice.FindEntity(x => x.S_TASK_NO == tno); + if (task1 != null && task1.S_B_STATE != "瀹屾垚") + task1Isrun = true; //if (tag.RGV.bit1taskOver_LAST == 1) // RedisHelper.Add($"RGV.bit1taskOver_LAST", "0", out string msg); } var task2Isrun = false; if (tag.RGV.ReadTask2No > 0 && tag.RGV.bit2taskOver != 1) { - task2Isrun = true; + var taskno = tag.RGV.ReadTask2No; + string tno = "TN" + (DateTime.Now.ToString("yy")) + ((taskno.ToString()).PadLeft(8, '0')); + task2 = taskservice.FindEntity(x => x.S_TASK_NO == tno); + if (task2 != null && task2.S_B_STATE != "瀹屾垚") + task2Isrun = true; //if (tag.RGV.bit2taskOver_LAST == 1) // RedisHelper.Add($"RGV.bit2taskOver_LAST", "0", out string msg); } @@ -561,12 +610,10 @@ if (task2Isrun) mes += tag.RGV.ReadTask2No + "鎵ц涓�.."; LogHelper.Info($"{mes} 涓嶈兘涓嬪彂鏂颁换鍔°�"); - throw new Exception($"{mes} 涓嶈兘涓嬪彂鏂颁换鍔°�"); + System.Threading.Thread.Sleep(3000); + return; } var thisOver = 0; - TaskEntity task1 = null; - TaskEntity task2 = null; - LogHelper.Info($"鏌ョ湅RGV 1宸ヤ綅浠诲姟銆�); if (tag.RGV.ReadTask1No > 0 && tag.RGV.bit1taskOver == 1) { @@ -575,7 +622,7 @@ string tno = "TN" + (DateTime.Now.ToString("yy")) + ((taskno.ToString()).PadLeft(8, '0')); task1 = taskservice.FindEntity(x => x.S_TASK_NO == tno); - LogHelper.Info($"RGV 1宸ヤ綅浠诲姟{JsonConvert.SerializeObject(task1)}.bit1taskOver_LAST锛歿tag.RGV.bit1taskOver_LAST}"); + LogHelper.Info($"RGV 1宸ヤ綅浠诲姟{task1?.S_TASK_NO}.bit1taskOver_LAST锛歿tag.RGV.bit1taskOver_LAST}"); if (tag.RGV.bit1taskOver_LAST == 0 && task1 != null) { if (task1.S_B_STATE != "瀹屾垚") @@ -584,11 +631,13 @@ if (task1.S_B_STATE == "鍙栬揣瀹屾垚") { task1.S_B_STATE = "瀹屾垚"; + //tag.RGV.ReadTask1No = 0; } else { task1.S_B_STATE = "鍙栬揣瀹屾垚"; } + //tag.RGV.bit1taskOver = 0; LogHelper.Info($"RGV 1宸ヤ綅浠诲姟{task1.S_TASK_NO} 鐘舵�鍒囨崲涓簕task1.S_B_STATE}"); //tag.RGV.bit1taskOver_LAST = 1; RedisHelper.Add($"RGV.bit1taskOver_LAST", "1", out string msg); @@ -615,7 +664,7 @@ string tno = "TN" + (DateTime.Now.ToString("yy")) + ((taskno.ToString()).PadLeft(8, '0')); task2 = taskservice.FindEntity(x => x.S_TASK_NO == tno); - LogHelper.Info($"RGV2宸ヤ綅浠诲姟{JsonConvert.SerializeObject(task2)}.bit2taskOver_LAST锛歿tag.RGV.bit2taskOver_LAST}"); + LogHelper.Info($"RGV2宸ヤ綅浠诲姟{task2?.S_TASK_NO}.bit2taskOver_LAST锛歿tag.RGV.bit2taskOver_LAST}"); if (tag.RGV.bit2taskOver_LAST == 0 && task2 != null) { if (task2.S_B_STATE != "瀹屾垚") @@ -624,11 +673,13 @@ if (task2.S_B_STATE == "鍙栬揣瀹屾垚") { task2.S_B_STATE = "瀹屾垚"; + //tag.RGV.ReadTask2No = 0; } else { task2.S_B_STATE = "鍙栬揣瀹屾垚"; } + //tag.RGV.bit2taskOver = 0; LogHelper.Info($"RGV 2宸ヤ綅浠诲姟{task2.S_TASK_NO} 鐘舵�鍒囨崲涓簕task2.S_B_STATE}"); RedisHelper.Add($"RGV.bit2taskOver_LAST", "1", out string msg); LogHelper.Info($"RGV 2宸ヤ綅浠诲姟鍐欏鐞�); @@ -647,14 +698,14 @@ } //if (thisOver > 0) - { - var v2 = RedisHelper.Get<WriteGroupEntity>("RGVQueue", out string rev); - if (v2 != null) - { - LogHelper.Info($"RGVQueue 璇诲埌缁撴灉-{JsonConvert.SerializeObject(v2)} \n 涓嬪彂鍓嶈繘琛屾竻闄ゃ�"); - var b = RedisHelper.Remove("RGVQueue", out rev); - } - } + //{ + // var v2 = RedisHelper.Get<WriteGroupEntity>("RGVQueue", out string rev); + // if (v2 != null) + // { + // LogHelper.Info($"RGVQueue 璇诲埌缁撴灉-{JsonConvert.SerializeObject(v2)} \n 涓嬪彂鍓嶈繘琛屾竻闄ゃ�"); + // var b = RedisHelper.Remove("RGVQueue", out rev); + // } + //} ///1 鏈夎揣 灏� 鍙栥� 1 娌¤揣 灏� 鍗歌揣锛�閮芥湁璐� 灏�鍗歌揣銆�閮芥病璐�灏�鍗� var tklist = taskservice.FindList(x => x.S_B_STATE == "鏈墽琛� && x.S_WORK_MODE == "RGV").OrderBy(x => x.T_CREATE).ToList(); @@ -692,17 +743,18 @@ { LogHelper.Info($"鏌ョ湅RGV1 鏈変换鍔task1.S_TASK_NO},宸ヤ綅2 娌′换鍔°� 鎵�020 1008 1016鍙栬揣浠诲姟{t2.S_TASK_NO}銆�); tag.RGV.workMod = 2; + LogHelper.Info($"{task1.S_TASK_NO}> workMod 2 銆�宸ヤ綅銆�); tag.RGV.taskmod = 1; + LogHelper.Info($"{task1.S_TASK_NO}> taskmod 1 銆婂彇璐с�"); tag.RGV.taskno2 = Convert.ToUInt32(t2.S_TASK_NO.Substring(4)); tag.RGV.task2do = Convert.ToUInt16(t2.S_START_LOC); - t2.S_B_STATE = "宸叉帹閫�; - taskservice.Update(t2); creT2 = true; - System.Threading.Thread.Sleep(750); LogHelper.Info($"{t2.S_TASK_NO}> bit2taskOver_LAST 鍐�0"); RedisHelper.Add($"RGV.bit2taskOver_LAST", "0", out string msg); LogHelper.Info($"{t2.S_TASK_NO}> end 鍐�125"); Conn.榛樿Redis.SetValue("RGV.taskend", "125", "RGVQueue", false); + t2.S_B_STATE = "宸叉帹閫�; + taskservice.Update(t2); } ////2 濡傛灉鏈夊悓渚у彇璐т换鍔°�灏卞彇銆傛病鏈� //else if (leftSide.Contains(task1.S_START_LOC)) @@ -753,7 +805,9 @@ { LogHelper.Info($"鏌ョ湅RGV1 鏈変换鍔task1.S_TASK_NO},宸ヤ綅2 娌′换鍔°� 娌℃湁鍚屼晶鍙栬揣浠诲姟 1宸ヤ綅鍗歌揣銆�); tag.RGV.workMod = 1; + LogHelper.Info($"{task1.S_TASK_NO}> workMod 1 銆�宸ヤ綅銆�); tag.RGV.taskmod = 2; + LogHelper.Info($"{task1.S_TASK_NO}> taskmod 2 銆婂嵏璐с�"); tag.RGV.taskno1 = Convert.ToUInt32(task1.S_TASK_NO.Substring(4)); tag.RGV.task1do = Convert.ToUInt16(task1.S_END_LOC); System.Threading.Thread.Sleep(750); @@ -771,7 +825,9 @@ LogHelper.Info($"鏌ョ湅RGV 1宸ヤ綅娌′换鍔�宸ヤ綅2 鏈変换鍔task2.S_TASK_NO}銆傚伐浣�鍗歌揣銆傘�"); //2 鍗歌揣銆� tag.RGV.workMod = 2; + LogHelper.Info($"{task2.S_TASK_NO}> workMod 2 銆�宸ヤ綅銆�); tag.RGV.taskmod = 2; + LogHelper.Info($"{task2.S_TASK_NO}> taskmod 2 銆婂嵏璐с�"); tag.RGV.taskno2 = Convert.ToUInt32(task2.S_TASK_NO.Substring(4)); tag.RGV.task2do = Convert.ToUInt16(task2.S_END_LOC); System.Threading.Thread.Sleep(750); @@ -793,41 +849,44 @@ //} if (e1017first != null) { - LogHelper.Info($"鏌ョ湅RGV1 浠诲姟宸ヤ綅2 娌′换鍔°� 1002 1010 1023鍙栬揣浠诲姟{e1017first.S_TASK_NO}銆�); + LogHelper.Info($"鏌ョ湅RGV娌′换鍔★紝 缁欏伐浣�绛涢�浠诲姟銆�1002 1010 1023鍙栬揣浠诲姟{e1017first.S_TASK_NO}銆�); tag.RGV.workMod = 1; + LogHelper.Info($"{e1017first.S_TASK_NO}> workMod 1 銆�宸ヤ綅銆�); tag.RGV.taskmod = 1; + LogHelper.Info($"{e1017first.S_TASK_NO}> taskmod 1 銆婂彇璐с�"); uint tno = Convert.ToUInt32(e1017first.S_TASK_NO.Substring(4)); LogHelper.Info($"{e1017first.S_TASK_NO}> 杞崲鍚庝换鍔″彿{tno} 寮�鍐欏叆銆�); tag.RGV.taskno1 = tno; LogHelper.Info($"{e1017first.S_TASK_NO}>寮�鍐欏叆 task1do>>{e1017first.S_START_LOC}銆�); tag.RGV.task1do = Convert.ToUInt16(e1017first.S_START_LOC); LogHelper.Info($"{e1017first.S_TASK_NO}> 鏇存柊浠诲姟銆�); - e1017first.S_B_STATE = "宸叉帹閫�; - taskservice.Update(e1017first); - System.Threading.Thread.Sleep(750); LogHelper.Info($"{e1017first.S_TASK_NO}> bit1taskOver_LAST 鍐�"); RedisHelper.Add($"RGV.bit1taskOver_LAST", "0", out string msg); LogHelper.Info($"{e1017first.S_TASK_NO}> taskend 鍐�25"); //tag.RGV.taskend=125 Conn.榛樿Redis.SetValue("RGV.taskend", "125", "RGVQueue", false); + e1017first.S_B_STATE = "宸叉帹閫�; + taskservice.Update(e1017first); } else { var t2 = tklist.OrderBy(x => x.T_CREATE).ToList().Find(x => x.S_START_LOC == "1020" || x.S_START_LOC == "1008" || x.S_START_LOC == "1016"); if (tklist != null) { - LogHelper.Info($"鏌ョ湅RGV1 娌′换鍔″伐浣� 娌′换鍔°� 鎵�020 1008 1016鍙栬揣浠诲姟{t2.S_TASK_NO}銆�); + LogHelper.Info($"鏌ョ湅RGV娌′换鍔�缁欏伐浣�绛涢�浠诲姟銆�鎵�020 1008 1016鍙栬揣浠诲姟{t2.S_TASK_NO}銆�); tag.RGV.workMod = 2; + LogHelper.Info($"{t2.S_TASK_NO}> workMod 2 銆�宸ヤ綅銆�); tag.RGV.taskmod = 1; + LogHelper.Info($"{t2.S_TASK_NO}> taskmod 1 銆婂彇璐с�"); tag.RGV.taskno2 = Convert.ToUInt32(t2.S_TASK_NO.Substring(4)); + LogHelper.Info($"{t2.S_TASK_NO}> taskno2 {Convert.ToUInt32(t2.S_TASK_NO.Substring(4))}銆婁换鍔″彿銆�); tag.RGV.task2do = Convert.ToUInt16(t2.S_START_LOC); - t2.S_B_STATE = "宸叉帹閫�; - taskservice.Update(t2); - System.Threading.Thread.Sleep(750); LogHelper.Info($"{t2.S_TASK_NO}> bit2taskOver_LAST 鍐�0"); RedisHelper.Add($"RGV.bit2taskOver_LAST", "0", out string msg); LogHelper.Info($"{t2.S_TASK_NO}> end 鍐�125"); Conn.榛樿Redis.SetValue("RGV.taskend", "125", "RGVQueue", false); + t2.S_B_STATE = "宸叉帹閫�; + taskservice.Update(t2); } } } @@ -844,13 +903,15 @@ public void ThreadGrats(Tag tag, Action<HaiKangOrderInfo> continueTask) { - Console.WriteLine($"ThreadGrats 鍏夋爡澶勭悊 =================> "); + LogHelper.Info($"ThreadGrats 鍏夋爡澶勭悊 =================> "); + var taskCOdes = new List<string> { "Sarrive", "Srelease", "Earrive", "Erelease" }; TaskActRepository taskActRepository = new TaskActRepository(); TaskRepository taskRepository = new TaskRepository(); - var requires = taskActRepository.FindList(x => taskCOdes.Contains(x.S_ACTION_CODE) && x.N_CREATEMETHOD == 0); + var requires = taskActRepository.FindList(x => taskCOdes.Contains(x.S_ACTION_CODE) && x.N_CREATEMETHOD == 0).OrderBy(x => x.T_CREATE); foreach (var item in requires) { + LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE}鍏夋爡澶勭悊 =================> "); var tin = taskCOdes.IndexOf(item.S_ACTION_CODE); if (tin == -1) { @@ -858,7 +919,13 @@ taskActRepository.Update(item); continue; } - //var task = taskRepository.FindEntity(x => x.S_TASK_NO == item.S_TASK_NO); + var task = taskRepository.FindEntity(x => x.S_TASK_NO == item.S_TASK_NO); + if (task == null) + { + item.N_CREATEMETHOD = -1; + taskActRepository.Update(item); + continue; + } string loc = ""; if (tin < 2) { @@ -874,21 +941,26 @@ var dev = Settings.deviceInfos.Find(x => x.location.Contains(loc)); if (dev != null) { + LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} 璁惧鏄瘂dev.deviceName} 鍏夋爡澶勭悊 =================> "); var V = dev.location.ToList().FindIndex(x => x == loc) == 0; //杞﹁蛋浜� 寮�厜鏍� if (!goin) { if (dev.deviceType == 1) { + LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} 璁惧鏄瘂dev.deviceName} 寮�惎鍏夋爡澶勭悊 =================> "); LogHelper.Info($"{dev.deviceName}{(V ? "宸� : "鍙�)} 鍏夋爡{(goin ? "鍏抽棴" : "寮�惎")} 鐢宠銆� + string.Format("{0}{1}{2}", dev.deviceName + "." + (V ? "R02" : "R04"), "true", dev.deviceName + "Queue")); - Conn.榛樿Redis.SetValue(dev.deviceName + "." + (V ? "R02" : "R04"), "true", dev.deviceName + "Queue"); - + Conn.榛樿Redis.SetValue(dev.deviceName + "." + (V ? "R02" : "R04"), "true", dev.deviceName + "Queue", false); } else if (dev.deviceType == 2) { + LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} 璁惧鏄瘂dev.deviceName} 寮�惎鍏夋爡澶勭悊 =================> "); LogHelper.Info($"{dev.deviceName}{(V ? "宸� : "鍙�)} 鍏夋爡{(goin ? "鍏抽棴" : "寮�惎")} 鐢宠銆� + string.Format("{0}{1}{2}", dev.deviceName + "." + (V ? "D1222" : "D1223"), "1", dev.deviceName + "Queue")); + + Conn.榛樿Redis.SetValue(dev.deviceName + "." + (V ? "D1220" : "D1221"), "0", dev.deviceName + "Queue"); Conn.榛樿Redis.SetValue(dev.deviceName + "." + (V ? "D1222" : "D1223"), "1", dev.deviceName + "Queue"); } + LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} 璁惧鏄瘂dev.deviceName} 寮�惎鍏夋爡澶勭悊瀹屾垚 =================> "); item.N_CREATEMETHOD = 1; taskActRepository.Update(item); @@ -898,7 +970,9 @@ { if (dev.deviceType == 1) { + LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} 璁惧鏄瘂dev.deviceName} 鍏抽棴鍏夋爡澶勭悊 =================> "); var tf = Conn.榛樿Redis.GetValue(dev.deviceName + "." + (V ? "R50" : "R52"));//璇诲叧闂姸鎬�+ LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} 璁惧鏄瘂dev.deviceName} 鍏夋爡鍏抽棴淇″彿{tf}"); if (tf?.ToLower() == "true") { LogHelper.Info($"{dev.deviceName}{(V ? "宸� : "鍙�)} 鍏夋爡{(goin ? "鍏抽棴" : "寮�惎")} 鐢宠銆�宸茬粡鍏抽棴锛�); @@ -907,26 +981,33 @@ else { LogHelper.Info($"{dev.deviceName}{(V ? "宸� : "鍙�)} 鍏夋爡{(goin ? "鍏抽棴" : "寮�惎")} 鐢宠銆� + string.Format("{0}{1}{2}", dev.deviceName + "." + (V ? "R01" : "R03"), "true", dev.deviceName + "Queue")); - Conn.榛樿Redis.SetValue(dev.deviceName + "." + (V ? "R01" : "R03"), "true", dev.deviceName + "Queue"); + Conn.榛樿Redis.SetValue(dev.deviceName + "." + (V ? "R01" : "R03"), "true", dev.deviceName + "Queue", false); } - + LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} 璁惧鏄瘂dev.deviceName} 鍏抽棴鍏夋爡澶勭悊瀹屾垚 =================> "); } else if (dev.deviceType == 2) { + LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} 璁惧鏄瘂dev.deviceName} 鍏抽棴鍏夋爡澶勭悊 =================> "); var tf = Conn.榛樿Redis.GetValue(dev.deviceName + ".D1202"); int numm = int.Parse(string.IsNullOrEmpty(tf) ? "0" : tf); - if (TcpServer.GetBitdata(numm, (V ? 0 : 1)) == 1) + int close = TcpServer.GetBitdata(numm, (V ? 0 : 1)); + LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} 璁惧鏄瘂dev.deviceName} 鍏夋爡鍏抽棴淇″彿{close}"); + if (close == 1) { LogHelper.Info($"{dev.deviceName}{(V ? "宸� : "鍙�)} 鍏夋爡{(goin ? "鍏抽棴" : "寮�惎")} 鐢宠銆�宸茬粡鍏抽棴锛�); continuuuuu = true; } else { - LogHelper.Info($"{dev.deviceName}{(V ? "宸� : "鍙�)} 鍏夋爡{(goin ? "鍏抽棴" : "寮�惎")} 鐢宠銆� + string.Format("{0}{1}{2}", dev.deviceName + "." + (V ? "D1220" : "D1221"), dev.deviceName + "Queue")); + LogHelper.Info($"{dev.deviceName}{(V ? "宸� : "鍙�)} 鍏夋爡{(goin ? "鍏抽棴" : "寮�惎")} 鐢宠銆� + string.Format("{0}{1}{2}", dev.deviceName + "." + (V ? "D1220" : "D1221"), "1", dev.deviceName + "Queue")); + Conn.榛樿Redis.SetValue(dev.deviceName + "." + (V ? "D1222" : "D1223"), "0", dev.deviceName + "Queue"); Conn.榛樿Redis.SetValue(dev.deviceName + "." + (V ? "D1220" : "D1221"), "1", dev.deviceName + "Queue"); - } - } + string d12201 = RedisHelper.Get<string>(dev.deviceName + "." + (V ? "D1220" : "D1221"), out string msg); + LogHelper.Info($"ThreadGrats 鍐檣(dev.deviceName + "." + (V ? "D1220" : "D1221"))}涓�1 锛�鍚庤{d12201}"); + } + LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} 璁惧鏄瘂dev.deviceName} 鍏抽棴鍏夋爡澶勭悊瀹屾垚 =================> "); + } } } @@ -943,23 +1024,35 @@ } } System.Threading.Thread.Sleep(3000); + LogHelper.Info($"ThreadGrats deviceType2鍏夋爡鍐欏叆浣嶉噸缃�=================> "); //閲嶇疆淇″彿 foreach (var dev in Settings.deviceInfos.FindAll(x => x.deviceType == 2)) { var tf = Conn.榛樿Redis.GetValue(dev.deviceName + ".D1202"); int numm = int.Parse(string.IsNullOrEmpty(tf) ? "0" : tf); + //int int0 = TcpServer.GetBitdata(numm, 0); + //int int1 = TcpServer.GetBitdata(numm, 1); + if (TcpServer.GetBitdata(numm, 0) == 0) { - Conn.榛樿Redis.SetValue(dev.deviceName + ".D1220", "0", dev.deviceName + "Queue"); - Conn.榛樿Redis.SetValue(dev.deviceName + ".D1222", "0", dev.deviceName + "Queue"); + Conn.榛樿Redis.SetValue(dev.deviceName + ".D1220", "0", dev.deviceName + "Queue", false); + Conn.榛樿Redis.SetValue(dev.deviceName + ".D1222", "0", dev.deviceName + "Queue", false); } - else if (TcpServer.GetBitdata(numm, 1) == 0) + if (TcpServer.GetBitdata(numm, 1) == 0) { - Conn.榛樿Redis.SetValue(dev.deviceName + ".D1221", "0", dev.deviceName + "Queue"); - Conn.榛樿Redis.SetValue(dev.deviceName + ".D1223", "0", dev.deviceName + "Queue"); + Conn.榛樿Redis.SetValue(dev.deviceName + ".D1221", "0", dev.deviceName + "Queue", false); + Conn.榛樿Redis.SetValue(dev.deviceName + ".D1223", "0", dev.deviceName + "Queue", false); + } + if (TcpServer.GetBitdata(numm, 2) == 0) + { + Conn.榛樿Redis.SetValue(dev.deviceName + ".D1224", "0", dev.deviceName + "Queue", false); + } + if (TcpServer.GetBitdata(numm, 3) == 0) + { + Conn.榛樿Redis.SetValue(dev.deviceName + ".D1225", "0", dev.deviceName + "Queue", false); } } - + LogHelper.Info($"ThreadGrats deviceType2鍏夋爡鍐欏叆浣嶉噸缃畬鎴愩� =================> "); } /// <summary> /// 1020 1023绌烘涓嬬嚎 @@ -1193,10 +1286,12 @@ { var RArrive = (System.UInt16)System.Convert.ChangeType(Conn.榛樿Redis.GetValue($"FNK1003051113.RArrive{ssx}"), typeof(System.UInt16)); var RArriveLast = (System.UInt16)System.Convert.ChangeType(Conn.榛樿Redis.GetValue($"FNK1003051113.RArrive{ssx}_LAST"), typeof(System.UInt16)); + LogHelper.Info($" FNK1003051113.RArrive{ssx}>{RArrive} && FNK1003051113.RArrive{ssx}_LAST >{RArriveLast}"); if (RArrive == 1 && RArriveLast == 0) { if (ssx == "1005" && tag.SF涓嬫枡浣�WRelease1005 == 0) { + LogHelper.Info($"ssx == 1005 && tag.SF涓嬫枡浣�WRelease1005:{tag.SF涓嬫枡浣�WRelease1005} 鍐檉1 2215=1锛孯Arrive1005_LAST=1"); tag.FNK1.D2215 = 1; //tag.SF涓嬫枡浣�RArrive1005_LAST = 1; RedisHelper.Add($"FNK1003051113.RArrive1005_LAST", "1", out string msg); @@ -1206,6 +1301,7 @@ } else if (ssx == "1003" && tag.SF涓嬫枡浣�WRelease1003 == 0) { + LogHelper.Info($"ssx == 1003 && tag.SF涓嬫枡浣�WRelease1003:{tag.SF涓嬫枡浣�WRelease1003} 鍐檉1 2210=1锛孯Arrive1003_LAST=1"); tag.FNK1.D2210 = 1; //tag.SF涓嬫枡浣�RArrive1003_LAST = 1; @@ -1216,6 +1312,7 @@ } else if (ssx == "1013" && tag.SF涓嬫枡浣�WRelease1013 == 0) { + LogHelper.Info($"ssx == 1013 && tag.SF涓嬫枡浣�WRelease1013:{tag.SF涓嬫枡浣�WRelease1013} 鍐檉2 2215=1锛孯Arrive1013_LAST=1"); tag.FNK2.D2215 = 1; //tag.SF涓嬫枡浣�RArrive1013_LAST = 1; RedisHelper.Add($"FNK1003051113.RArrive1013_LAST", "1", out string msg); @@ -1225,6 +1322,7 @@ } else if (ssx == "1011" && tag.SF涓嬫枡浣�WRelease1011 == 0) { + LogHelper.Info($"ssx == 1011 && tag.SF涓嬫枡浣�WRelease1011:{tag.SF涓嬫枡浣�WRelease1011} 鍐檉2 2210=1锛孯Arrive1011_LAST=1"); tag.FNK2.D2210 = 1; //tag.SF涓嬫枡浣�RArrive1011_LAST = 1; RedisHelper.Add($"FNK1003051113.RArrive1011_LAST", "1", out string msg); @@ -1235,6 +1333,7 @@ } else if (RArrive == 0 && RArriveLast == 1) { + LogHelper.Info($"閲嶇疆 FNK1003051113.RArrive{ssx}_LAST=0"); RedisHelper.Add($"FNK1003051113.RArrive{ssx}_LAST", "0", out string msg); //Conn.榛樿Redis.SetValue($"FNK1003051113.RArrive{ssx}_LAST", "0", $"FNK1003051113Queue"); } @@ -1244,6 +1343,8 @@ public void ThreadFNK1Over(Tag tag) { Console.WriteLine($"ThreadFNK1Over =====>"); + LogHelper.Info($" FN1 D2217>{tag.FNK1.D2217} D2217LAST>{tag.FNK1.D2217_LAST} D2215>{tag.FNK1.D2215} D2216>{tag.FNK1.D2216} D2215>{tag.FNK1.D2215}"); + //LogHelper.Info($" FN1 .D2217=1,2217_LAST=0 鍐�2215=0锛孌2217_LAST=1锛學Release1005=1 RArrive1005_LAST=0"); if (tag.FNK1.D2217 == 1 && tag.FNK1.D2217_LAST == 0) { tag.FNK1.D2215 = 0; @@ -1254,13 +1355,22 @@ tag.SF涓嬫枡浣�WSafe0305 = 1; System.Threading.Thread.Sleep(1000); RedisHelper.Add($"FNK1003051113.RArrive1005_LAST", "0", out msg); + LogHelper.Info($" FN1 .D2217=1,2217_LAST=0 鍐�2215=0锛孌2217_LAST=1锛學Release1005=1 RArrive1005_LAST=0"); } - if (tag.FNK1.D2216 == 1) - tag.FNK1.D2215 = 0; else if (tag.FNK1.D2217 == 0 && tag.FNK1.D2217_LAST == 1) + { //tag.FNK1.D2217_LAST = 0; RedisHelper.Add($"p鍙戦偅绉�涓嬬嚎.D2217_LAST", "0", out string msg); + LogHelper.Info($" p鍙戦偅绉�涓嬬嚎.D2217_LAST=0"); + } + if (tag.FNK1.D2216 == 1) + { + tag.FNK1.D2215 = 0; + LogHelper.Info($" p鍙戦偅绉�涓嬬嚎 璇籇2216=1 鍐橠2215 =0"); + } + + LogHelper.Info($" FN1 D2212>{tag.FNK1.D2212} D2212LAST>{tag.FNK1.D2212_LAST} D2210>{tag.FNK1.D2210} D2211>{tag.FNK1.D2211} D2210>{tag.FNK1.D2210}"); if (tag.FNK1.D2212 == 1 && tag.FNK1.D2212_LAST == 0) { tag.FNK1.D2210 = 0; @@ -1270,6 +1380,7 @@ tag.SF涓嬫枡浣�WSafe0305 = 1; System.Threading.Thread.Sleep(1000); RedisHelper.Add($"FNK1003051113.RArrive1003_LAST", "0", out msg); + LogHelper.Info($" FN1 .D2212=1,2212_LAST=0 鍐�2210=0锛孌2212_LAST=1锛學Release1003=1 RArrive1003_LAST=0"); } //else if (tag.FNK1.D2211 == 1) // tag.FNK1.D2210 = 0; @@ -1277,14 +1388,21 @@ { //tag.FNK1.D2212_LAST = 0; RedisHelper.Add($"p鍙戦偅绉�涓嬬嚎.D2212_LAST", "0", out string msg); + LogHelper.Info($" p鍙戦偅绉�涓嬬嚎.D2212_LAST=0"); } + if (tag.FNK1.D2211 == 1) + { tag.FNK1.D2210 = 0; + LogHelper.Info($" p鍙戦偅绉�涓嬬嚎 璇籇2211=1 鍐橠2210 =0"); + } } + public void ThreadFNK2Over(Tag tag) { Console.WriteLine($"ThreadFNK2Over =====>"); + LogHelper.Info($" FN2 D2217>{tag.FNK2.D2217} D2217LAST>{tag.FNK2.D2217_LAST} D2215>{tag.FNK2.D2215} D2216>{tag.FNK2.D2216} D2215>{tag.FNK2.D2215}"); if (tag.FNK2.D2217 == 1 && tag.FNK2.D2217_LAST == 0) { tag.FNK2.D2215 = 0; @@ -1295,14 +1413,23 @@ tag.SF涓嬫枡浣�WSafe1113 = 1; System.Threading.Thread.Sleep(1000); RedisHelper.Add($"FNK1003051113.RArrive1013_LAST", "0", out msg); + LogHelper.Info($" FN2 .D2217=1,2217_LAST=0 鍐�2215=0锛孌2217_LAST=1锛學Release1013=1 RArrive1013_LAST=0"); } else if (tag.FNK2.D2217 == 0 && tag.FNK2.D2217_LAST == 1) + { //tag.FNK2.D2217_LAST = 0; RedisHelper.Add($"p鍙戦偅绉�涓嬬嚎.D2217_LAST", "0", out string msg); + LogHelper.Info($" p鍙戦偅绉�涓嬬嚎.D2217_LAST=0"); + } if (tag.FNK2.D2216 == 1) + { tag.FNK2.D2215 = 0; + LogHelper.Info($" p鍙戦偅绉�涓嬬嚎 璇籇2216=1 鍐橠2215 =0"); + } + + LogHelper.Info($" FN2 D2212>{tag.FNK2.D2212} D2212LAST>{tag.FNK2.D2212_LAST} D2210>{tag.FNK2.D2210} D2211>{tag.FNK2.D2211} D2210>{tag.FNK2.D2210}"); if (tag.FNK2.D2212 == 1 && tag.FNK2.D2212_LAST == 0) { tag.FNK2.D2210 = 0; @@ -1313,16 +1440,22 @@ tag.SF涓嬫枡浣�WSafe1113 = 1; System.Threading.Thread.Sleep(1000); RedisHelper.Add($"FNK1003051113.RArrive1011_LAST", "0", out msg); + LogHelper.Info($" FN2 .D2212=1,2212_LAST=0 鍐�2210=0锛孌2212_LAST=1锛學Release1011=1 RArrive1011_LAST=0"); } else if (tag.FNK2.D2212 == 0 && tag.FNK2.D2212_LAST == 1) { //tag.FNK2.D2212_LAST = 0; RedisHelper.Add($"p鍙戦偅绉�涓嬬嚎.D2212_LAST", "0", out string msg); + LogHelper.Info($" p鍙戦偅绉�涓嬬嚎.D2212_LAST=0"); } if (tag.FNK2.D2211 == 1) + { tag.FNK2.D2210 = 0; - + LogHelper.Info($" p鍙戦偅绉�涓嬬嚎 璇籇2211=1 鍐橠2210 =0"); + } } + + public void Thread1019Down(Tag tag) { @@ -1352,4 +1485,20 @@ } + + class Messss + { + public bool success { get; set; } + public Ddata data { get; set; } + public object extra { get; set; } + } + + public class Ddata + { + public string reqCode { get; set; } + public int state { get; set; } + public string error { get; set; } + } } + +#endregion [鑷畾涔夌被-VS][20250623083459471][AutoThread] \ No newline at end of file -- Gitblit v1.9.1