WMSPrjInstance/HH-0167_WuHuAoKeSi.git

			@@ -1,4 +1,5 @@
			ï»¿using Newtonsoft.Json;
			#region [èªå®ä¹ç±»-VS][20250623083459471][AutoThread]
			using Newtonsoft.Json;
			using System;
			using System.Collections.Generic;
			using System.Collections.Concurrent;
			@@ -14,6 +15,7 @@
			using static System.Windows.Forms.VisualStyles.VisualStyleElement;
			using System.Windows.Interop;
			using static System.Windows.Forms.VisualStyles.VisualStyleElement.TextBox;
			using System.Security.Cryptography;

			namespace GZ.Projects.AuxAllWCS
			{
			@@ -102,6 +104,12 @@
			else if (Settings.deviceInfos.Count == 0)
			{
			tag.Global.SettingsOver = 0;
			}
			else tag.Global.SettingsOver++;
			if (tag.Global.SettingsOver > 999)
			{
			tag.Global.SettingsOver = 1;
			Console.Clear();
			}
			}

			@@ -236,7 +244,8 @@
			LogHelper.Info($"{VERX.location[0]}ç³è¯·mesä»»å¡ç»æ{str}");
			if (str.Contains("true"))
			{
			tag.wxr1.R44_LAST = true;
			//tag.wxr1.R44_LAST = true;
			RedisHelper.Add($"ç»´å¸å°æè1.R44_LAST", "true", out string msg);
			}
			}
			else
			@@ -251,7 +260,8 @@
			{
			if (tag.wxr1.R10)
			{
			tag.wxr1.R10_LAST = false;
			//tag.wxr1.R10_LAST = false;
			RedisHelper.Add($"ç»´å¸å°æè1.R10_LAST", "false", out string msg);
			}
			else
			if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[0], out string traycode))
			@@ -267,7 +277,8 @@
			{
			//Conn.é»è®¤Redis.SetValue("ç»´å¸å°æè1.R10", "true", "ç»´å¸å°æè1Queue");
			tag.wxr1.R10 = true;
			tag.wxr1.R44_LAST = false;
			//tag.wxr1.R44_LAST = false;
			RedisHelper.Add($"ç»´å¸å°æè1.R44_LAST", "false", out string msg);
			}
			else
			{
			@@ -305,7 +316,8 @@
			LogHelper.Info($"{VERX.location[1]}ç³è¯·mesä»»å¡ç»æ{str}");
			if (str.Contains("true"))
			{
			tag.wxr1.R46_LAST = true;
			//tag.wxr1.R46_LAST = true;
			RedisHelper.Add($"ç»´å¸å°æè1.R46_LAST", "true", out string msg);
			}
			}
			else
			@@ -319,7 +331,8 @@
			{
			if (tag.wxr1.R11)
			{
			tag.wxr1.R11_LAST = false;
			//tag.wxr1.R11_LAST = false;
			RedisHelper.Add($"ç»´å¸å°æè1.R11_LAST", "false", out string msg);
			}
			else
			if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode))
			@@ -335,7 +348,8 @@
			{
			//Conn.é»è®¤Redis.SetValue("ç»´å¸å°æè1.R10", "true", "ç»´å¸å°æè1Queue");
			tag.wxr1.R11 = true;
			tag.wxr1.R46_LAST = false;
			//tag.wxr1.R46_LAST = false;
			RedisHelper.Add($"ç»´å¸å°æè1.R46_LAST", "false", out string msg);
			}
			else
			{
			@@ -373,7 +387,8 @@
			LogHelper.Info($"{VERX.location[0]}ç³è¯·mesä»»å¡ç»æ{str}");
			if (str.Contains("true"))
			{
			tag.wxr2.R44_LAST = true;
			//tag.wxr2.R44_LAST = true;
			RedisHelper.Add($"ç»´å¸å°æè2.R44_LAST", "true", out string msg);
			}
			}
			else
			@@ -387,7 +402,8 @@
			{
			if (tag.wxr2.R10)
			{
			tag.wxr2.R10_LAST = false;
			//tag.wxr2.R10_LAST = false;
			RedisHelper.Add($"ç»´å¸å°æè2.R10_LAST", "false", out string msg);
			}
			else
			if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[0], out string traycode))
			@@ -403,7 +419,8 @@
			{
			//Conn.é»è®¤Redis.SetValue("ç»´å¸å°æè1.R10", "true", "ç»´å¸å°æè1Queue");
			tag.wxr2.R10 = true;
			tag.wxr2.R44_LAST = false;
			//tag.wxr2.R44_LAST = false;
			RedisHelper.Add($"ç»´å¸å°æè2.R44_LAST", "false", out string msg);
			}
			else
			{
			@@ -442,7 +459,8 @@
			LogHelper.Info($"{VERX.location[1]}ç³è¯·mesä»»å¡ç»æ{str}");
			if (str.Contains("true"))
			{
			tag.wxr2.R46_LAST = true;
			//tag.wxr2.R46_LAST = true;
			RedisHelper.Add($"ç»´å¸å°æè2.R46_LAST", "true", out string msg);
			}
			}
			else
			@@ -456,7 +474,8 @@
			{
			if (tag.wxr2.R11)
			{
			tag.wxr2.R11_LAST = false;
			//tag.wxr2.R11_LAST = false;
			RedisHelper.Add($"ç»´å¸å°æè2.R11_LAST", "false", out string msg);
			}
			else
			if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode))
			@@ -472,7 +491,8 @@
			{
			//Conn.é»è®¤Redis.SetValue("ç»´å¸å°æè1.R10", "true", "ç»´å¸å°æè1Queue");
			tag.wxr2.R11 = true;
			tag.wxr2.R46_LAST = false;
			//tag.wxr2.R46_LAST = false;
			RedisHelper.Add($"ç»´å¸å°æè2.R46_LAST", "false", out string msg);
			}
			else
			{
			@@ -535,21 +555,44 @@
			}
			try
			{
			LogHelper.Info("ä»»å¡ä¸å Rgv ä»»å¡ è¿å¥");
			#region Rgv

			LogHelper.Info($"æ¥çRGV çµéï¼ã{tag.RGV.Rå½åçµé}ã åçµç¶æï¼ã{tag.RGV.Råçµç¶æ}ã æéä»£ç ï¼ã{tag.RGV.RgvrunError}ã");
			LogHelper.Info($"æ¥çRGV çµéï¼ã{tag.RGV.Rå½åçµé}ã åçµç¶æï¼ã{tag.RGV.Råçµç¶æ}ã æéä»£ç ï¼ã{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 æ125å½ä»¤æªæ§è¡ã");
			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 +604,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 +616,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 +625,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);
			@@ -624,11 +667,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 +692,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 æè´§ å°±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();
			@@ -688,11 +733,13 @@

			// 2å· ä¼åç» 1020 1008 1016
			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)
			if (t2 != null)
			{
			LogHelper.Info($"æ¥çRGV1 æä»»å¡{task1.S_TASK_NO},å·¥ä½2 æ²¡ä»»å¡ã æ¾1020 1008 1016åè´§ä»»å¡{t2.S_TASK_NO}ã");
			tag.RGV.workMod = 2;
			LogHelper.Info($"{task1.S_TASK_NO}> workMod 2 ã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 = "å·²æ¨é";
			@@ -753,7 +800,9 @@
			{
			LogHelper.Info($"æ¥çRGV1 æä»»å¡{task1.S_TASK_NO},å·¥ä½2 æ²¡ä»»å¡ã æ²¡æåä¾§åè´§ä»»å¡ 1å·¥ä½å¸è´§ã");
			tag.RGV.workMod = 1;
			LogHelper.Info($"{task1.S_TASK_NO}> workMod 1 ã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 +820,9 @@
			LogHelper.Info($"æ¥çRGV 1å·¥ä½æ²¡ä»»å¡,å·¥ä½2 æä»»å¡{task2.S_TASK_NO}ãå·¥ä½2å¸è´§ãã");
			//2 å¸è´§ã
			tag.RGV.workMod = 2;
			LogHelper.Info($"{task2.S_TASK_NO}> workMod 2 ã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,9 +844,11 @@
			//}
			if (e1017first != null)
			{
			LogHelper.Info($"æ¥çRGV1 ä»»å¡å·¥ä½2 æ²¡ä»»å¡ã 1002 1010 1023åè´§ä»»å¡{e1017first.S_TASK_NO}ã");
			LogHelper.Info($"æ¥çRGVæ²¡ä»»å¡ï¼ ç»å·¥ä½1çéä»»å¡ã 1002 1010 1023åè´§ä»»å¡{e1017first.S_TASK_NO}ã");
			tag.RGV.workMod = 1;
			LogHelper.Info($"{e1017first.S_TASK_NO}> workMod 1 ã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;
			@@ -810,17 +863,19 @@
			LogHelper.Info($"{e1017first.S_TASK_NO}> taskend å125");
			//tag.RGV.taskend=125
			Conn.é»è®¤Redis.SetValue("RGV.taskend", "125", "RGVQueue", false);

			}
			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 æ²¡ä»»å¡å·¥ä½2 æ²¡ä»»å¡ã æ¾1020 1008 1016åè´§ä»»å¡{t2.S_TASK_NO}ã");
			LogHelper.Info($"æ¥çRGVæ²¡ä»»å¡ ç»å·¥ä½2çéä»»å¡ã æ¾1020 1008 1016åè´§ä»»å¡{t2.S_TASK_NO}ã");
			tag.RGV.workMod = 2;
			LogHelper.Info($"{t2.S_TASK_NO}> workMod 2 ã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);
			@@ -845,13 +900,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)
			{
			@@ -859,7 +916,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)
			{
			@@ -875,21 +938,24 @@
			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 ? "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);
			@@ -899,7 +965,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 ? "å³é" : "å¼å¯")} ç³è¯·ã å·²ç»å³éï¼");
			@@ -908,15 +976,18 @@
			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;
			@@ -926,6 +997,7 @@
			LogHelper.Info($"{dev.deviceName}{(V ? "å·¦" : "å³")} åæ {(goin ? "å³é" : "å¼å¯")} ç³è¯·ã" + string.Format("{0}{1}{2}", dev.deviceName + "." + (V ? "D1220" : "D1221"), dev.deviceName + "Queue"));
			Conn.é»è®¤Redis.SetValue(dev.deviceName + "." + (V ? "D1220" : "D1221"), "1", dev.deviceName + "Queue");
			}
			LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤æ¯{dev.deviceName} å³éåæ å¤çå®æ =================> ");
			}

			}
			@@ -944,6 +1016,7 @@
			}
			}
			System.Threading.Thread.Sleep(3000);
			LogHelper.Info($"ThreadGrats deviceType2åæ åå¥ä½éç½® =================> ");
			//éç½®ä¿¡å·
			foreach (var dev in Settings.deviceInfos.FindAll(x => x.deviceType == 2))
			{
			@@ -951,16 +1024,16 @@
			int numm = int.Parse(string.IsNullOrEmpty(tf) ? "0" : tf);
			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)
			{
			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);
			}
			}

			LogHelper.Info($"ThreadGrats deviceType2åæ åå¥ä½éç½®å®æã =================> ");
			}
			/// <summary>
			/// 1020 1023ç©ºæ¡ä¸çº¿
			@@ -1155,7 +1228,7 @@
			var R5ç©ºé²_LAST = (System.UInt16)System.Convert.ChangeType(Conn.é»è®¤Redis.GetValue($"S{item}Read.R5ç©ºé²_LAST"), typeof(System.UInt16));
			if (R5 == 5 && R5ç©ºé²_LAST == 0)
			{
			task = taskRepository.FindEntity(x => x.S_END_LOC == Bssx && x.S_B_STATE != "å®æ" && x.S_B_STATE != "åæ¶");
			task = taskRepository.FindEntity(x => x.S_END_LOC == item && x.S_B_STATE != "å®æ" && x.S_B_STATE != "åæ¶");
			msg = "";
			if (task != null)
			{
			@@ -1354,3 +1427,5 @@

			}
			}

			#endregion [èªå®ä¹ç±»-VS][20250623083459471][AutoThread]