WMSPrjInstance/HH-0167_WuHuAoKeSi.git

			@@ -15,6 +15,19 @@
			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;
			using static GZ.Projects.AuxAllWCS.EasyPLC;
			using static System.Runtime.CompilerServices.RuntimeHelpers;
			using ServiceStack.Configuration;
			using ServiceStack;
			using Spectre.Console;
			using System.Net.WebSockets;
			using System.Net;
			using System.Threading;
			using System.IO;
			using GZ.Device.Agv;
			using System.Net.NetworkInformation;

			namespace GZ.Projects.AuxAllWCS
			{
			@@ -66,6 +79,8 @@
			}

			// æ§è¡å§æ
			//if (methodName != "TaskEverythingRun")
			// return null;
			return methodDelegate.DynamicInvoke(args);
			}

			@@ -104,6 +119,78 @@
			{
			tag.Global.SettingsOver = 0;
			}
			else tag.Global.SettingsOver++;
			if (tag.Global.SettingsOver > 999)
			{
			tag.Global.SettingsOver = 1;
			Console.Clear();
			}
			}


			public void ThreaTotal(Tag tag)
			{
			List<Task> tasks = new List<Task>();
			tasks.Add(GetTask(ThreadMXC3, tag, 3000));
			tasks.Add(GetTask(ThreadMXC4, tag, 3000));
			tasks.Add(GetTask(ResetGats, tag, 3000));





			Task.WaitAll(tasks.ToArray());
			}
			public static bool IsMachineOnline(string hostNameOrIp, int timeout = 1000)
			{
			try
			{
			using (var ping = new Ping())
			{
			var reply = ping.Send(hostNameOrIp, timeout);
			return reply.Status == IPStatus.Success;
			}
			}
			catch (PingException)
			{
			return false;
			}
			catch (Exception)
			{
			// å¶ä»å¼å¸¸å¤ç
			return false;
			}
			}

			private Task GetTask(Action<Tag> action, Tag tag, int i = 2500)
			{
			var task = Task.Run(() =>
			{
			while (true)
			{
			try
			{
			action(tag);
			}
			catch (Exception ex)
			{
			LogHelper.Error(ex.Message, ex);
			}
			Thread.Sleep(i);
			}
			});
			return task;
			}

			public string WriteLine(string value = "")
			{




			// å¨è¿éæ¦æªå¤çè¾åº
			string intercepted = $"[æ¦æªå°çè¾åº] {value}";
			return intercepted;
			}

			/// <summary>
			@@ -125,17 +212,20 @@
			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);
			//Conn.é»è®¤Redis.SetValue(VERX.deviceName + ".D1224", "0", VERX.deviceName + "Queue");
			}

			if (tag.Js1.D1213_LAST == 0 && TcpServer.GetBitdata(tag.Js1.D1212, 3) == 1)
			{
			var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new
			@@ -144,16 +234,18 @@
			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);
			//Conn.é»è®¤Redis.SetValue(VERX.deviceName + ".D1225", "0", VERX.deviceName + "Queue");
			}
			}
			}
			@@ -176,18 +268,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)
			{
			@@ -197,18 +288,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);
			}
			}
			}
			@@ -223,9 +314,11 @@

			if (VERX != null)
			{
			if (tag.wxr1.R44)
			LogHelper.Info($"{VERX.deviceName} R44>{tag.wxr1.R44} R44LAST>{tag.wxr1.R44_LAST} R10>{tag.wxr1.R10}");
			if (tag.wxr1.R44 && !tag.wxr1.R44_LAST && tag.wxr1.R10)
			{
			if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[0], out string traycode))
			if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[0], out string traycode) && !string.IsNullOrEmpty(traycode.Trim()))
			{
			var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new
			{
			@@ -235,9 +328,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($"ç»´å¸å°æè1.R44_LAST", "true", out string msg);
			}
			}
			else
			@@ -252,23 +347,30 @@
			{
			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))
			if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[0], out string traycode) && !string.IsNullOrEmpty(traycode.Trim()))
			{
			//ä¸æ¥æ ¡éªã
			LogHelper.Info($"{VERX.deviceNo[0]} ä¸æ¥æ ¡éª>{traycode}");

			///var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/202", requestJson);
			var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/202", JsonConvert.SerializeObject(new
			{
			sceneType = 1,
			cntrCode = traycode,
			}));
			if (str.Contains("true"))
			var strr = JsonConvert.DeserializeObject<Mesrespone>(str);
			if (strr != null && strr.success)
			//if (str.Contains("true"))
			{
			//Conn.é»è®¤Redis.SetValue("ç»´å¸å°æè1.R10", "true", "ç»´å¸å°æè1Queue");
			tag.wxr1.R10 = true;
			tag.wxr1.R44_LAST = false;
			//tag.wxr1.R10 = true;
			Conn.é»è®¤Redis.SetValue(VERX.deviceName + ".R10", "true", VERX.deviceName + "Queue");
			//tag.wxr1.R44_LAST = false;
			RedisHelper.Add($"ç»´å¸å°æè1.R44_LAST", "false", out string msg);
			}
			else
			{
			@@ -276,6 +378,10 @@
			}
			}
			else { TcpServer.TcpServerSend(VERX.deviceNo[0], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E")); }
			}
			else if (!tag.wxr1.R10)
			{
			TcpServer.TrayIps.Remove(VERX.deviceNo[0]);
			}
			}
			}
			@@ -292,9 +398,11 @@

			if (VERX != null)
			{
			if (tag.wxr1.R46)
			LogHelper.Info($"{VERX.deviceName} R44>{tag.wxr1.R46} R44LAST>{tag.wxr1.R46_LAST} R10>{tag.wxr1.R11}");
			if (tag.wxr1.R46 && !tag.wxr1.R46_LAST && tag.wxr1.R11)
			{
			if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode))
			if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode) && !string.IsNullOrEmpty(traycode.Trim()))
			{
			var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new
			{
			@@ -304,9 +412,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($"ç»´å¸å°æè1.R46_LAST", "true", out string msg);
			}
			}
			else
			@@ -320,23 +430,29 @@
			{
			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))
			if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode) && !string.IsNullOrEmpty(traycode.Trim()))
			{
			//ä¸æ¥æ ¡éªã
			LogHelper.Info($"{VERX.deviceNo[1]} ä¸æ¥æ ¡éª>{traycode}");
			///var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/202", requestJson);
			var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/202", JsonConvert.SerializeObject(new
			{
			sceneType = 1,
			cntrCode = traycode,
			}));
			if (str.Contains("true"))
			var strr = JsonConvert.DeserializeObject<Mesrespone>(str);
			if (strr != null && strr.success)
			//if (str.Contains("true"))
			{
			//Conn.é»è®¤Redis.SetValue("ç»´å¸å°æè1.R10", "true", "ç»´å¸å°æè1Queue");
			tag.wxr1.R11 = true;
			tag.wxr1.R46_LAST = false;
			//tag.wxr1.R11 = true;
			Conn.é»è®¤Redis.SetValue(VERX.deviceName + ".R11", "true", VERX.deviceName + "Queue");
			//tag.wxr1.R46_LAST = false;
			RedisHelper.Add($"ç»´å¸å°æè1.R46_LAST", "false", out string msg);
			}
			else
			{
			@@ -344,6 +460,10 @@
			}
			}
			else { TcpServer.TcpServerSend(VERX.deviceNo[1], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E")); }
			}
			else if (!tag.wxr1.R11)
			{
			TcpServer.TrayIps.Remove(VERX.deviceNo[1]);
			}
			}
			}
			@@ -360,9 +480,11 @@

			if (VERX != null)
			{
			if (tag.wxr2.R44)
			LogHelper.Info($"{VERX.deviceName} R44>{tag.wxr2.R44} R44LAST>{tag.wxr2.R44_LAST} R10>{tag.wxr2.R10}");
			if (tag.wxr2.R44 && !tag.wxr2.R44_LAST && tag.wxr2.R10)
			{
			if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[0], out string traycode))
			if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[0], out string traycode) && !string.IsNullOrEmpty(traycode.Trim()))
			{
			var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new
			{
			@@ -372,9 +494,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($"ç»´å¸å°æè2.R44_LAST", "true", out string msg);
			}
			}
			else
			@@ -388,23 +512,29 @@
			{
			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))
			if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[0], out string traycode) && !string.IsNullOrEmpty(traycode.Trim()))
			{
			//ä¸æ¥æ ¡éªã
			LogHelper.Info($"{VERX.deviceNo[0]} ä¸æ¥æ ¡éª>{traycode}");
			///var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/202", requestJson);
			var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/202", JsonConvert.SerializeObject(new
			{
			sceneType = 1,
			cntrCode = traycode,
			}));
			if (str.Contains("true"))
			var strr = JsonConvert.DeserializeObject<Mesrespone>(str);
			if (strr != null && strr.success)
			//if (str.Contains("true"))
			{
			//Conn.é»è®¤Redis.SetValue("ç»´å¸å°æè1.R10", "true", "ç»´å¸å°æè1Queue");
			tag.wxr2.R10 = true;
			tag.wxr2.R44_LAST = false;
			//tag.wxr2.R10 = true;
			Conn.é»è®¤Redis.SetValue(VERX.deviceName + ".R10", "true", VERX.deviceName + "Queue");
			//tag.wxr2.R44_LAST = false;
			RedisHelper.Add($"ç»´å¸å°æè2.R44_LAST", "false", out string msg);
			}
			else
			{
			@@ -412,6 +542,10 @@
			}
			}
			else { TcpServer.TcpServerSend(VERX.deviceNo[0], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E")); }
			}
			else if (!tag.wxr2.R10)
			{
			TcpServer.TrayIps.Remove(VERX.deviceNo[0]);
			}
			}
			}
			@@ -429,9 +563,11 @@

			if (VERX != null)
			{
			if (tag.wxr2.R46)
			LogHelper.Info($"{VERX.deviceName} R44>{tag.wxr2.R46} R44LAST>{tag.wxr2.R46_LAST} R10>{tag.wxr2.R11}");
			if (tag.wxr2.R46 && !tag.wxr2.R46_LAST && tag.wxr2.R11)
			{
			if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode))
			if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode) && !string.IsNullOrEmpty(traycode.Trim()))
			{
			var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new
			{
			@@ -441,9 +577,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($"ç»´å¸å°æè2.R46_LAST", "true", out string msg);
			}
			}
			else
			@@ -453,15 +591,19 @@
			}
			else
			{
			//LogHelper.Info($"Threadwxr2R æçæ¾ç½®ä¿¡å·1ãã -{tag.wxr2.R11_LAST}");
			if (tag.wxr2.R11_LAST) //æçæ¾ç½®ä¿¡å·ãã
			{
			//LogHelper.Info($"Threadwxr2R æçæ¾ç½®ä¿¡å·1ãã -{tag.wxr2.R11}");
			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))
			if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode) && !string.IsNullOrEmpty(traycode.Trim()))
			{
			LogHelper.Info($"{VERX.deviceNo[1]} ä¸æ¥æ ¡éª>{traycode}");
			//ä¸æ¥æ ¡éªã
			///var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/202", requestJson);
			var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/202", JsonConvert.SerializeObject(new
			@@ -469,23 +611,40 @@
			sceneType = 1,
			cntrCode = traycode,
			}));
			if (str.Contains("true"))
			var strr = JsonConvert.DeserializeObject<Mesrespone>(str);
			if (strr != null && strr.success)
			{
			//Conn.é»è®¤Redis.SetValue("ç»´å¸å°æè1.R10", "true", "ç»´å¸å°æè1Queue");
			tag.wxr2.R11 = true;
			tag.wxr2.R46_LAST = false;
			//Conn.é»è®¤Redis.SetValue("ç»´å¸å°æè1.R11", "true", "ç»´å¸å°æè1Queue");
			//tag.wxr2.R11 = true;

			LogHelper.Info($"Threadwxr2Rãã -åR11 true");
			Conn.é»è®¤Redis.SetValue(VERX.deviceName + ".R11", "true", VERX.deviceName + "Queue");
			//tag.wxr2.R46_LAST = false;
			RedisHelper.Add($"ç»´å¸å°æè2.R46_LAST", "false", out string msg);
			LogHelper.Info($"Threadwxr2Rãã æ ¡éªä¸æå®æã");
			}
			else
			{
			//æ¥è¦ã
			}
			}
			else { TcpServer.TcpServerSend(VERX.deviceNo[1], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E")); }
			else
			{
			LogHelper.Info($"Threadwxr2Rãã -åéæ«ç ");
			TcpServer.TcpServerSend(VERX.deviceNo[1], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E"));
			}
			}
			else if (!tag.wxr2.R11)
			{
			TcpServer.TrayIps.Remove(VERX.deviceNo[1]);
			}
			}
			}
			else
			{
			Console.WriteLine($"Threadwxr2R ç»´å¸å°2 å³ è®¾å¤æªæ¾å°ã =================> ");
			}
			}


			public void ThreadTaskRun(Tag tag, Func<TaskEntity, bool> action)
			{
			@@ -495,7 +654,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");
			@@ -538,26 +697,48 @@
			{
			#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å½ä»¤æªæ§è¡ã ");
			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)
			{
			LogHelper.Info($"RGV125å½ä»¤æªæ§è¡ tag.RGV.workMod == 0 && tag.RGV.taskmod == 0 && tag.RGV.taskno1 == tag.RGV.ReadTask1No && tag.RGV.taskno2 == tag.RGV.ReadTask2No èªå¨æ¸é¤125");
			Conn.é»è®¤Redis.SetValue("RGV.taskend", "0", "RGVQueue", false);
			}
			System.Threading.Thread.Sleep(3000);
			return;
			}
			LogHelper.Info("ä»»å¡ä¸å Rgv ä»»å¡ è¿å¥");

			LogHelper.Info($"ä»»å¡ä¸å Rgv ä»»å¡ è¿å¥ Rgvä¿¡æ¯ W1ç¶æ{tag.RGV.w1status} ReadTask1No>{tag.RGV.ReadTask1No} 1å·¥ä½æ¡ç :{tag.RGV.bit1Code} bit1taskOver>{tag.RGV.bit1taskOver} W2ç¶æ{tag.RGV.w2status} ReadTask2No>{tag.RGV.ReadTask2No} 2å·¥ä½æ¡ç :{tag.RGV.bit2Code} bit2taskOver>{tag.RGV.bit2taskOver}");
			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);
			}
			@@ -572,10 +753,8 @@
			System.Threading.Thread.Sleep(3000);
			return;
			}
			var thisOver = 0;
			TaskEntity task1 = null;
			TaskEntity task2 = null;

			var thisOver = 0;
			LogHelper.Info($"æ¥çRGV 1å·¥ä½ä»»å¡ã");
			if (tag.RGV.ReadTask1No > 0 && tag.RGV.bit1taskOver == 1)
			{
			@@ -584,7 +763,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 != "å®æ")
			@@ -599,8 +778,8 @@
			{
			task1.S_B_STATE = "åè´§å®æ";
			}
			tag.RGV.bit1taskOver = 0;
			LogHelper.Info($"RGV 1å·¥ä½ä»»å¡{task1.S_TASK_NO} ç¶æåæ¢ä¸º{task1.S_B_STATE}");
			//tag.RGV.bit1taskOver = 0;
			LogHelper.Info($"RGV 1å·¥ä½ä»»å¡{task1.S_TASK_NO} æ¡ç ï¼{tag.RGV.bit1Code} ç¶æåæ¢ä¸º{task1.S_B_STATE}");
			//tag.RGV.bit1taskOver_LAST = 1;
			RedisHelper.Add($"RGV.bit1taskOver_LAST", "1", out string msg);
			LogHelper.Info($"RGV 1å·¥ä½ä»»å¡åå¤ç");
			@@ -626,7 +805,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 != "å®æ")
			@@ -641,8 +820,8 @@
			{
			task2.S_B_STATE = "åè´§å®æ";
			}
			tag.RGV.bit2taskOver = 0;
			LogHelper.Info($"RGV 2å·¥ä½ä»»å¡{task2.S_TASK_NO} ç¶æåæ¢ä¸º{task2.S_B_STATE}");
			//tag.RGV.bit2taskOver = 0;
			LogHelper.Info($"RGV 2å·¥ä½ä»»å¡{task2.S_TASK_NO} æ¡ç ï¼{tag.RGV.bit2Code} ç¶æåæ¢ä¸º{task2.S_B_STATE}");
			RedisHelper.Add($"RGV.bit2taskOver_LAST", "1", out string msg);
			LogHelper.Info($"RGV 2å·¥ä½ä»»å¡åå¤ç");
			taskservice.Update(task2);
			@@ -658,8 +837,6 @@
			{
			LogHelper.Info($"RGV 2å·¥ä½æ²¡æä»»å¡ã");
			}



			//if (thisOver > 0)
			//{
			@@ -682,15 +859,17 @@
			tag.RGV.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);
			//RedisHelper.Add($"RGV.bit1taskOver_LAST", "0", out string msg);
			//tag.RGV.taskend = 125;
			//Conn.é»è®¤Redis.SetValue("RGV.taskend", "125", "RGVQueue");

			LogHelper.Info($"{task1.S_TASK_NO}> bit1taskOver_LAST å 0");
			RedisHelper.Add($"RGV.bit1taskOver_LAST", "0", out string msg);
			if (tag.RGV.bit1taskOver == 1)
			tag.RGV.bit1taskOver = 0;
			LogHelper.Info($"{task1.S_TASK_NO}> end å 125");
			Conn.é»è®¤Redis.SetValue("RGV.taskend", "125", "RGVQueue", false);

			LogHelper.Info($"{task1.S_TASK_NO}> bit1taskOver_LAST å 0");
			RedisHelper.Add($"RGV.bit1taskOver_LAST", "0", out string msg);
			}
			else //1æä»»å¡ 2 æ²¡ä»»å¡ã
			{
			@@ -707,17 +886,21 @@
			{
			LogHelper.Info($"æ¥çRGV1 æä»»å¡{task1.S_TASK_NO},å·¥ä½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));
			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);

			if (tag.RGV.bit2taskOver == 1)
			tag.RGV.bit2taskOver = 0;
			LogHelper.Info($"{t2.S_TASK_NO}> end å 125");
			Conn.é»è®¤Redis.SetValue("RGV.taskend", "125", "RGVQueue", false);

			LogHelper.Info($"{t2.S_TASK_NO}> bit2taskOver_LAST å 0");
			RedisHelper.Add($"RGV.bit2taskOver_LAST", "0", out string msg);
			t2.S_B_STATE = "å·²æ¨é";
			taskservice.Update(t2);
			}
			////2 å¦ææåä¾§åè´§ä»»å¡ãå°±åãæ²¡æ
			//else if (leftSide.Contains(task1.S_START_LOC))
			@@ -768,14 +951,18 @@
			{
			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);

			if (tag.RGV.bit1taskOver == 1)
			tag.RGV.bit1taskOver = 0;
			LogHelper.Info($"{task1.S_TASK_NO}> taskend å 125");
			Conn.é»è®¤Redis.SetValue("RGV.taskend", "125", "RGVQueue", false);
			LogHelper.Info($"{task1.S_TASK_NO}> bit1taskOver_LAST å 0");
			RedisHelper.Add($"RGV.bit1taskOver_LAST", "0", out string msg);
			LogHelper.Info($"{task1.S_TASK_NO}> taskend å 0");
			Conn.é»è®¤Redis.SetValue("RGV.taskend", "125", "RGVQueue", false);
			}
			}
			}
			@@ -786,15 +973,19 @@
			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);
			LogHelper.Info($"{task2.S_TASK_NO}> bit2taskOver_LAST å 0");
			RedisHelper.Add($"RGV.bit2taskOver_LAST", "0", out string msg);

			if (tag.RGV.bit2taskOver == 1)
			tag.RGV.bit2taskOver = 0;
			//tag.RGV.taskend = 125;
			LogHelper.Info($"{task2.S_TASK_NO}> taskend å125");
			Conn.é»è®¤Redis.SetValue("RGV.taskend", "125", "RGVQueue", false);
			LogHelper.Info($"{task2.S_TASK_NO}> bit2taskOver_LAST å 0");
			RedisHelper.Add($"RGV.bit2taskOver_LAST", "0", out string msg);
			}
			else if (tklist.Any()) //1mei ä»»å¡ 2 æ²¡ä»»å¡ã
			{
			@@ -808,41 +999,48 @@
			//}
			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;
			LogHelper.Info($"{e1017first.S_TASK_NO}>å¼å§åå¥ task1do>>{e1017first.S_START_LOC}ã");
			tag.RGV.task1do = Convert.ToUInt16(e1017first.S_START_LOC);
			//tag.RGV.taskend=125
			if (tag.RGV.bit1taskOver == 1)
			tag.RGV.bit1taskOver = 0;
			LogHelper.Info($"{e1017first.S_TASK_NO}> taskend å125");
			Conn.é»è®¤Redis.SetValue("RGV.taskend", "125", "RGVQueue", false);
			LogHelper.Info($"{e1017first.S_TASK_NO}> bit1taskOver_LAST å0");
			RedisHelper.Add($"RGV.bit1taskOver_LAST", "0", out string msg);
			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 å0");
			RedisHelper.Add($"RGV.bit1taskOver_LAST", "0", out string msg);
			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);
			System.Threading.Thread.Sleep(750);
			LogHelper.Info($"{t2.S_TASK_NO}> bit2taskOver_LAST å 0");
			RedisHelper.Add($"RGV.bit2taskOver_LAST", "0", out string msg);
			if (tag.RGV.bit2taskOver == 1)
			tag.RGV.bit2taskOver = 0;
			LogHelper.Info($"{t2.S_TASK_NO}> end å 125");
			Conn.é»è®¤Redis.SetValue("RGV.taskend", "125", "RGVQueue", false);
			LogHelper.Info($"{t2.S_TASK_NO}> bit2taskOver_LAST å 0");
			RedisHelper.Add($"RGV.bit2taskOver_LAST", "0", out string msg);
			t2.S_B_STATE = "å·²æ¨é";
			taskservice.Update(t2);
			}
			}
			}
			@@ -859,21 +1057,42 @@

			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).ToList();
			var timeMorhours = requires.FindAll(x => DateTime.Now.Subtract(x.T_CREATE).TotalHours > 1);
			if (timeMorhours.Any())
			{
			foreach (var mor in timeMorhours)
			{
			mor.N_CREATEMETHOD = 2;
			mor.S_REVIEW_COMMENT = "è¶æ¶ä¸å¤ç";
			taskActRepository.Update(mor);
			}
			requires = requires.Except(timeMorhours).ToList();
			}
			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)
			{
			item.N_CREATEMETHOD = -1;
			item.S_REVIEW_COMMENT = $"ä¿¡å·æªç¥{item.S_ACTION_CODE}ä¸å¤ç";
			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;
			item.S_REVIEW_COMMENT = $"ä»»å¡ä¸¢å¤±ä¸å¤ç";
			taskActRepository.Update(item);
			continue;
			}
			string loc = "";
			if (tin < 2)
			{
			@@ -889,62 +1108,104 @@
			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");
			}
			else if (dev.deviceType == 5)
			{
			LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤æ¯{dev.deviceName} å¼å¯åæ å¤ç =================> ");
			Conn.é»è®¤Redis.SetValue(dev.deviceName + "." + (V ? "D2211" : "D2216"), "1", dev.deviceName + "Queue");
			Conn.é»è®¤Redis.SetValue(dev.deviceName + "." + (V ? "D2212" : "D2217"), "0", dev.deviceName + "Queue");
			}
			LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤æ¯{dev.deviceName} å¼å¯åæ å¤çå®æ =================> ");

			item.N_CREATEMETHOD = 1;
			item.S_REVIEW_COMMENT = $"åæ å¼å¯å®æ";
			taskActRepository.Update(item);
			}
			//è½¦è¦è¿å¥äº¤äºã
			else
			{
			if (dev.deviceType == 1)
			if (dev.deviceType == 4)
			{
			var tf = Conn.é»è®¤Redis.GetValue(dev.deviceName + "." + (V ? "R50" : "R52"));//è¯»å³éç¶æ
			if (tf?.ToLower() == "true")
			{
			LogHelper.Info($"{dev.deviceName}{(V ? "å·¦" : "å³")} åæ {(goin ? "å³é" : "å¼å¯")} ç³è¯·ã å·²ç»å³éï¼");
			continuuuuu = true;
			}
			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");
			}

			LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤æ¯{dev.deviceName} SSX AGV äº¤äºããã");
			//tag.SA1019.Sagverr
			}
			else if (dev.deviceType == 2)
			else
			{
			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)
			LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤æ¯{dev.deviceName} å³éåæ å¤ç =================> ");
			if (dev.deviceType == 1)
			{
			LogHelper.Info($"{dev.deviceName}{(V ? "å·¦" : "å³")} åæ {(goin ? "å³é" : "å¼å¯")} ç³è¯·ã å·²ç»å³éï¼");
			continuuuuu = true;
			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 ? "å³é" : "å¼å¯")} ç³è¯·ã å·²ç»å³éï¼");
			continuuuuu = true;
			}
			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", false);
			}
			}
			else
			else if (dev.deviceType == 2)
			{
			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");
			}
			}
			var tf = Conn.é»è®¤Redis.GetValue(dev.deviceName + ".D1202");
			int numm = int.Parse(string.IsNullOrEmpty(tf) ? "0" : tf);
			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"), "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}");
			}
			}
			else if (dev.deviceType == 3)
			{

			var close = (System.UInt16)System.Convert.ChangeType(Conn.é»è®¤Redis.GetValue(dev.deviceName + "." + (V ? "D2220" : "D2225")), typeof(System.UInt16));
			if (close == 1)
			{
			LogHelper.Info($"{dev.deviceName}{(V ? "å·¦" : "å³")} åæ {(goin ? "å³é" : "å¼å¯")} ç³è¯·ã å·²ç»å³éï¼");
			continuuuuu = true;
			}
			else
			{
			Conn.é»è®¤Redis.SetValue(dev.deviceName + "." + (V ? "D2212" : "D2217"), "1", dev.deviceName + "Queue");
			Conn.é»è®¤Redis.SetValue(dev.deviceName + "." + (V ? "D2211" : "D2216"), "0", dev.deviceName + "Queue");
			}
			}
			LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤æ¯{dev.deviceName} å³éåæ å¤çå®æ =================> ");
			}
			}

			}

			if (continuuuuu)
			{
			LogHelper.Info($"{item.S_TASK_NO}{item.S_ACTION_CODE} è½¦è¾åéç»§ç»ä»»å¡ï¼");
			@@ -954,27 +1215,57 @@
			taskCode = item.S_TASK_NO
			});
			item.N_CREATEMETHOD = 1;
			item.S_REVIEW_COMMENT = $"è½¦åç»§ç»ä»»å¡OK";
			taskActRepository.Update(item);
			}
			}
			System.Threading.Thread.Sleep(3000);
			}
			public void ResetGats(Tag tag)
			{
			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åæ åå¥ä½éç½®å®æã =================> ");
			LogHelper.Info($"ThreadGrats deviceType5åæ åå¥ä½éç½® =================> ");
			//éç½®ä¿¡å·
			//foreach (var dev in Settings.deviceInfos.FindAll(x => x.deviceType == 5))
			{
			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.DZ2.D2211 == 1 && tag.DZ2.D2220 == 1)
			tag.DZ2.D2211 = 0;
			if (tag.DZ2.D2216 == 1 && tag.DZ2.D2225 == 1)
			tag.DZ2.D2216 = 0;
			}
			LogHelper.Info($"ThreadGrats deviceType5åæ åå¥ä½éç½®å®æã =================> ");
			}
			/// <summary>
			/// 1020 1023ç©ºæ¡ä¸çº¿
			@@ -1005,7 +1296,7 @@
			var listtep = new List<string>();
			if (Bssx == "1020")
			{
			if (tag.SFä¸æä½.RArrive1003 == 1)
			if (!string.IsNullOrEmpty(tag.SFTä¸æå£æç.R1003Barcode) && string.IsNullOrEmpty(tag.SFTä¸æå£æç.R1011Barcode))
			{
			listtep = new List<string> { "1012", "1004" };
			}
			@@ -1016,7 +1307,8 @@
			}
			else
			{
			if (tag.SFä¸æä½.RArrive1005 == 1)
			//if (tag.SFä¸æä½.RArrive1005 == 1)
			if (!string.IsNullOrEmpty(tag.SFTä¸æå£æç.R1005Barcode) && string.IsNullOrEmpty(tag.SFTä¸æå£æç.R1013Barcode))
			{
			listtep = new List<string> { "1014", "1006" };
			}
			@@ -1207,84 +1499,141 @@
			foreach (var ssx in new string[] { "1003", "1005", "1011", "1013" })
			{
			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));
			if (RArrive == 1 && RArriveLast == 0)
			//var RArriveLast = (System.UInt16)System.Convert.ChangeType(Conn.é»è®¤Redis.GetValue($"FNK1003051113.RArrive{ssx}_LAST"), typeof(System.UInt16));
			var wArriveOver = (System.UInt16)System.Convert.ChangeType(Conn.é»è®¤Redis.GetValue($"FNK1003051113.wArrive{ssx}Over"), typeof(System.UInt16));
			var rReleaseOver = (System.UInt16)System.Convert.ChangeType(Conn.é»è®¤Redis.GetValue($"FNK1003051113.rRelease{ssx}Over"), typeof(System.UInt16));
			var WRelease = (System.UInt16)System.Convert.ChangeType(Conn.é»è®¤Redis.GetValue($"FNK1003051113.WRelease{ssx}"), typeof(System.UInt16));
			var RtrayCode = (System.String)System.Convert.ChangeType(Conn.é»è®¤Redis.GetValue($"SSX1003051113.R{ssx}Barcode"), typeof(System.String));
			var rdisTcode = RedisHelper.Get<string>($"Arrive{ssx}BarcodeLast", out string msg);
			// åäºç©ºæ¡å°ä½çæçå·è®°å½ï¼ å¦æä¸æ¬¡ä¿¡å·æ¥äºï¼æçå·ä¸ä¸è´å°±åï¼ä¸è´å°±ä¸åï¼é²æ¢å ç¹æ®åå è¢«æ¸é¤éæ°è§¦åï¼å¯¼è´åééå¤çé®é¢ã
			LogHelper.Info($@" æçå·ï¼{RtrayCode} redisæçå·ï¼{rdisTcode} ç©ºå°ä½ RArrive{ssx}>{RArrive} æºæ¢°ææ¶å°æ§å°ä½.wArrive{ssx}Over>{wArriveOver} éåºå®æ.rRelease{ssx}Over>{rReleaseOver} æ¾è´§å®æ.WRelease{ssx}>{WRelease}");
			if (RArrive == 1 && WRelease == 0 /&& RArriveLast == 0/ && !string.IsNullOrEmpty(RtrayCode) && RtrayCode != rdisTcode)
			{
			if (ssx == "1005" && tag.SFä¸æä½.WRelease1005 == 0)
			switch (ssx)
			{
			tag.FNK1.D2215 = 1;
			//tag.SFä¸æä½.RArrive1005_LAST = 1;
			RedisHelper.Add($"FNK1003051113.RArrive1005_LAST", "1", out string msg);

			//tag.SFä¸æä½.WRelease1005 = 0;
			//tag.SFä¸æä½.WSafe0305 = 0;
			case "1003":
			{
			LogHelper.Info($"ssx == 1003 && tag.SFä¸æä½.WRelease1003:{tag.SFä¸æä½.WRelease1003} åf1 2210=1ï¼Arrive{ssx}BarcodeLast={RtrayCode}");
			tag.FNK1.D2210 = 1;
			}
			break;
			case "1005":
			{
			LogHelper.Info($"ssx == 1005 && tag.SFä¸æä½.WRelease1005:{tag.SFä¸æä½.WRelease1005} åf1 2215=1ï¼Arrive{ssx}BarcodeLast={RtrayCode}");
			tag.FNK1.D2215 = 1;
			}
			break;
			case "1011":
			{
			LogHelper.Info($"ssx == 1011 && tag.SFä¸æä½.WRelease1011:{tag.SFä¸æä½.WRelease1011} åf2 2210=1ï¼Arrive{ssx}BarcodeLast={RtrayCode}");
			tag.FNK2.D2210 = 1;
			}
			break;
			case "1013":
			{
			LogHelper.Info($"ssx == 1013 && tag.SFä¸æä½.WRelease1013:{tag.SFä¸æä½.WRelease1013} åf2 2215=1ï¼Arrive{ssx}BarcodeLast={RtrayCode}");
			tag.FNK2.D2215 = 1;
			}
			break;
			}
			else if (ssx == "1003" && tag.SFä¸æä½.WRelease1003 == 0)
			{
			tag.FNK1.D2210 = 1;
			//tag.SFä¸æä½.RArrive1003_LAST = 1;

			RedisHelper.Add($"FNK1003051113.RArrive1003_LAST", "1", out string msg);

			//tag.SFä¸æä½.WRelease1003 = 0;
			//tag.SFä¸æä½.WSafe0305 = 0;
			}
			else if (ssx == "1013" && tag.SFä¸æä½.WRelease1013 == 0)
			{
			tag.FNK2.D2215 = 1;
			//tag.SFä¸æä½.RArrive1013_LAST = 1;
			RedisHelper.Add($"FNK1003051113.RArrive1013_LAST", "1", out string msg);

			//tag.SFä¸æä½.WRelease1013 = 0;
			//tag.SFä¸æä½.WSafe1113 = 0;
			}
			else if (ssx == "1011" && tag.SFä¸æä½.WRelease1011 == 0)
			{
			tag.FNK2.D2210 = 1;
			//tag.SFä¸æä½.RArrive1011_LAST = 1;
			RedisHelper.Add($"FNK1003051113.RArrive1011_LAST", "1", out string msg);

			//tag.SFä¸æä½.WRelease1011 = 0;
			//tag.SFä¸æä½.WSafe1113 = 0;
			}
			RedisHelper.Add($"Arrive{ssx}BarcodeLast", RtrayCode, out msg);
			}
			else if (RArrive == 0 && RArriveLast == 1)
			else if (RArrive == 0)
			{
			RedisHelper.Add($"FNK1003051113.RArrive{ssx}_LAST", "0", out string msg);
			//if (RArriveLast == 1)
			//{
			// LogHelper.Info($"éç½® FNK1003051113.RArrive{ssx}_LAST=0");
			// RedisHelper.Add($"FNK1003051113.RArrive{ssx}_LAST", "0", out string msg);
			//}
			if (wArriveOver == 1)
			{
			LogHelper.Info($"éç½® FNK1003051113.wArrive{ssx}Over=0");
			Conn.é»è®¤Redis.SetValue($"FNK1003051113.wArrive{ssx}Over", "0", $"FNK1003051113Queue");
			}
			//Conn.é»è®¤Redis.SetValue($"FNK1003051113.RArrive{ssx}_LAST", "0", $"FNK1003051113Queue");
			}

			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;
			}
			LogHelper.Info($"è¯»{ssx} WRelease=1&& rReleaseOver=1 WRelease å0");
			Conn.é»è®¤Redis.SetValue($"FNK1003051113.WRelease{ssx}", "0", $"FNK1003051113Queue");
			}

			}
			}

			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} D2218>{tag.FNK1.D2218}");
			//LogHelper.Info($" FN1 .D2217=1,2217_LAST=0 å 2215=0ï¼D2217_LAST=1ï¼WRelease1005=1 RArrive1005_LAST=0");
			if (tag.FNK1.D2217 == 1 && tag.FNK1.D2217_LAST == 0)
			{
			tag.FNK1.D2215 = 0;
			//tag.FNK1.D2215 = 0;
			tag.FNK1.D2218 = 1;
			//tag.FNK1.D2212_LAST = 1;
			RedisHelper.Add($"påé£ç§1ä¸çº¿.D2217_LAST", "1", out string msg);

			tag.SFä¸æä½.WRelease1005 = 1;
			tag.SFä¸æä½.WSafe0305 = 1;
			System.Threading.Thread.Sleep(1000);
			RedisHelper.Add($"FNK1003051113.RArrive1005_LAST", "0", out msg);
			//RedisHelper.Add($"FNK1003051113.RArrive1005_LAST", "0", out msg);
			RedisHelper.Add($"Arrive1005BarcodeLast", "0", out msg);
			LogHelper.Info($" FN1 .D2217=1,2217_LAST=0 å 2218=1ï¼D2217_LAST=1ï¼WRelease1005=1 Arrive1005BarcodeLast=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åé£ç§1ä¸çº¿.D2217_LAST", "0", out string msg);
			LogHelper.Info($" påé£ç§1ä¸çº¿.D2217_LAST=0");
			}
			if (tag.FNK1.D2216 == 1)
			{
			tag.FNK1.D2215 = 0;
			tag.SFä¸æä½.wArrive1005Over = 1;
			LogHelper.Info($" påé£ç§1ä¸çº¿ è¯»D2216=1 åD2215 =0ï¼ åæºæ¢°ææ¶å°1005 =1");
			}

			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.D2210 = 0;
			tag.FNK1.D2213 = 1;
			//tag.FNK1.D2210 = 0;
			//tag.FNK1.D2217_LAST = 1;
			RedisHelper.Add($"påé£ç§1ä¸çº¿.D2212_LAST", "1", out string msg);
			tag.SFä¸æä½.WRelease1003 = 1;
			tag.SFä¸æä½.WSafe0305 = 1;
			System.Threading.Thread.Sleep(1000);
			RedisHelper.Add($"FNK1003051113.RArrive1003_LAST", "0", out msg);
			//RedisHelper.Add($"FNK1003051113.RArrive1003_LAST", "0", out msg);
			RedisHelper.Add($"Arrive1003BarcodeLast", "0", out msg);
			LogHelper.Info($" FN1 .D2212=1,2212_LAST=0 å D2213=1ï¼D2212_LAST=1ï¼WRelease1003=1 Arrive1003BarcodeLast=0");
			}
			//else if (tag.FNK1.D2211 == 1)
			// tag.FNK1.D2210 = 0;
			@@ -1292,52 +1641,78 @@
			{
			//tag.FNK1.D2212_LAST = 0;
			RedisHelper.Add($"påé£ç§1ä¸çº¿.D2212_LAST", "0", out string msg);
			LogHelper.Info($" påé£ç§1ä¸çº¿.D2212_LAST=0");
			}
			if (tag.FNK1.D2211 == 1)
			tag.FNK1.D2210 = 0;

			if (tag.FNK1.D2211 == 1)
			{
			tag.FNK1.D2210 = 0;
			tag.SFä¸æä½.wArrive1003Over = 1;
			LogHelper.Info($" påé£ç§1ä¸çº¿ è¯»D2211=1 åD2210 =0 åæºæ¢°ææ¶å°ç©ºå°1003=1");
			}
			}

			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} D2218>{tag.FNK2.D2218}");
			if (tag.FNK2.D2217 == 1 && tag.FNK2.D2217_LAST == 0)
			{
			tag.FNK2.D2215 = 0;
			//tag.FNK2.D2215 = 0;
			tag.FNK2.D2218 = 1;
			//tag.FNK2.D2212_LAST = 1;
			RedisHelper.Add($"påé£ç§2ä¸çº¿.D2217_LAST", "1", out string msg);

			tag.SFä¸æä½.WRelease1013 = 1;
			tag.SFä¸æä½.WSafe1113 = 1;
			System.Threading.Thread.Sleep(1000);
			RedisHelper.Add($"FNK1003051113.RArrive1013_LAST", "0", out msg);
			//RedisHelper.Add($"FNK1003051113.RArrive1013_LAST", "0", out msg);
			RedisHelper.Add($"Arrive1013BarcodeLast", "0", out msg);
			LogHelper.Info($" FN2 .D2217=1,2217_LAST=0 å 2218=1ï¼D2217_LAST=1ï¼WRelease1013=1 Arrive1013BarcodeLast=0");
			}
			else if (tag.FNK2.D2217 == 0 && tag.FNK2.D2217_LAST == 1)
			{
			//tag.FNK2.D2217_LAST = 0;
			RedisHelper.Add($"påé£ç§2ä¸çº¿.D2217_LAST", "0", out string msg);

			LogHelper.Info($" påé£ç§2ä¸çº¿.D2217_LAST=0");
			}
			if (tag.FNK2.D2216 == 1)
			{
			tag.FNK2.D2215 = 0;
			tag.SFä¸æä½.wArrive1013Over = 1;
			LogHelper.Info($" påé£ç§2ä¸çº¿ è¯»D2216=1 åD2215 =0 åæºæ¢°ææ¶å°ç©ºå°1013=1");
			}

			LogHelper.Info($" FN2 D2212>{tag.FNK2.D2212} D2212LAST>{tag.FNK2.D2212_LAST} D2210>{tag.FNK2.D2210} D2211>{tag.FNK2.D2211} D2213>{tag.FNK2.D2213}");
			if (tag.FNK2.D2212 == 1 && tag.FNK2.D2212_LAST == 0)
			{
			tag.FNK2.D2210 = 0;
			//tag.FNK2.D2210 = 0;
			tag.FNK2.D2213 = 1;
			//tag.FNK2.D2217_LAST = 1;
			RedisHelper.Add($"påé£ç§2ä¸çº¿.D2212_LAST", "1", out string msg);

			tag.SFä¸æä½.WRelease1011 = 1;
			tag.SFä¸æä½.WSafe1113 = 1;
			System.Threading.Thread.Sleep(1000);
			RedisHelper.Add($"FNK1003051113.RArrive1011_LAST", "0", out msg);
			//RedisHelper.Add($"FNK1003051113.RArrive1011_LAST", "0", out msg);
			RedisHelper.Add($"Arrive1011BarcodeLast", "0", out msg);
			LogHelper.Info($" FN2 .D2212=1,2212_LAST=0 å 2213=1ï¼D2212_LAST=1ï¼WRelease1011=1 Arrive1011BarcodeLast=0");
			}
			else if (tag.FNK2.D2212 == 0 && tag.FNK2.D2212_LAST == 1)
			{
			//tag.FNK2.D2212_LAST = 0;
			RedisHelper.Add($"påé£ç§2ä¸çº¿.D2212_LAST", "0", out string msg);
			LogHelper.Info($" påé£ç§2ä¸çº¿.D2212_LAST=0");
			}
			if (tag.FNK2.D2211 == 1)
			{
			tag.FNK2.D2210 = 0;

			tag.SFä¸æä½.wArrive1011Over = 1;
			LogHelper.Info($" påé£ç§2ä¸çº¿ è¯»D2211=1 åD2210 =0 åæºæ¢°ææ¶å°ç©ºå°1011 wArrive1011Over=1");
			}
			}


			public void Thread1019Down(Tag tag)
			{
			@@ -1361,11 +1736,1076 @@
			}
			public void Thread2030Down(Tag tag)
			{

			Console.WriteLine($"SA2030 ä»»å¡ç¶æï¼ =====>");
			Console.WriteLine($"SA2030 ä»»å¡ç¶æï¼{tag.SA2030.RtaskState}- ç©ºé²{tag.SA2030.R5ç©ºé²} - barcode:{tag.SA2030.Ræçç }");



			}

			public void ResolveMesTask(Tag tag)
			{
			TaskRepository taskservice = new TaskRepository();
			var tasks = taskservice.FindList(x => (x.S_B_STATE == "MES" \|\| x.S_B_STATE == "People") && x.N_PRIORITY == -88);
			var VERXs = Settings.deviceInfos?.FindAll(x => x.deviceType == 2);
			//if (VERXs.Any())
			foreach (var task in tasks)
			{
			LogHelper.Info($"è§£éMESä»»å¡ ->{task.S_TASK_NO} ");
			if (task.S_TYPE?.Trim() == "100")
			{
			LogHelper.Info($"MESä»»å¡ S_TYPE 100->{task.S_TYPE} ");
			}
			var sx = VERXs?.Find(x => x.location.Contains(task.S_END_LOC));
			LogHelper.Info($"è§£éMESä»»å¡ ->{task.S_TASK_NO} {(sx == null ? "é" : "æ¯")}æ»è£æºå¨äººä»»å¡");
			if (sx == null)
			{
			if (string.IsNullOrEmpty(task.S_CNTRS) && !string.IsNullOrEmpty(task.S_INDEX))
			{
			// å«æä»»å¡ã æå®ç©æä¸æå®æçï¼éè¦åºåº
			switch (task.S_START_LOC)
			{
			case "2030":
			if (!string.IsNullOrEmpty(tag.SA2030.Ræçç ))
			{
			var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/224", JsonConvert.SerializeObject(new
			{
			cntrCode = tag.SA2030.Ræçç ,
			type = 1
			}));
			var strr = JsonConvert.DeserializeObject<MES2234>(str);
			if (strr.success && strr.data.materialCode == task.S_INDEX)
			{
			task.S_CNTRS = tag.SA2030.Ræçç ;
			taskservice.Update(task);
			}
			else
			{
			LogHelper.Info($"è§£éMESä»»å¡ ->{task.S_TASK_NO} 2030 åºå£çæçç©æä¸ç¬¦å");
			}
			}
			else
			{
			//TODO------------------2027 2220 2013.. è¯å«ä¸ä¸ï¼å¼å§åº
			}
			break;
			case "1019":
			if (!string.IsNullOrEmpty(tag.SA1019.Ræçç ))
			{
			var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/224", JsonConvert.SerializeObject(new
			{
			cntrCode = tag.SA1019.Ræçç ,
			type = 2
			}));
			var strr = JsonConvert.DeserializeObject<MES2234>(str);
			if (strr.success && strr.data.materialCode == task.S_INDEX)
			{
			task.S_CNTRS = tag.SA2030.Ræçç ;
			taskservice.Update(task);
			}
			else
			{
			LogHelper.Info($"è§£éMESä»»å¡ ->{task.S_TASK_NO} 1019 åºå£çæçç©æä¸ç¬¦å");
			}
			}
			break;
			}
			}
			else
			{
			if (new List<string> { "2001", "1022", "1025", "3001", "3006" }.Contains(task.S_END_LOC))
			{
			//------------------
			}
			else if (new List<string> { "1019"/, "1030"/, "2030", "3005", "3010" }.Contains(task.S_START_LOC)) //1030 æ¯ä¸»å¨ç³è¯·ï¼ ä¸ç¨å¤æã
			{

			}

			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>());

			LogHelper.Info($"è§£éMESä»»å¡ ->{task.S_TASK_NO} ç´æ¥çæå¯¹åºä»»å¡ ç»æï¼{res}");
			if (res)
			{
			LogHelper.Info($"è§£éMESä»»å¡ ->{task.S_TASK_NO} ä¿®æ¹æ è¯");
			//task.N_PRIORITY = 0;
			taskservice.dbcontext.Set<TaskEntity>().Attach(task);
			taskservice.dbcontext.Entry(task).Property(x => x.N_PRIORITY).CurrentValue = 0;
			taskservice.dbcontext.Entry(task).Property(x => x.N_PRIORITY).IsModified = true;
			taskservice.dbcontext.SaveChanges();
			}
			}
			}
			else
			{
			var sindex = sx.location.ToList().IndexOf(task.S_END_LOC);
			LocRepository locRepository = new LocRepository();
			//çæè·³è·ä»»å¡ã -- æçè´§ä½è¡¨ã
			var t1s = taskservice.FindList(x => x.S_SRC_NO == task.S_TASK_NO);

			LogHelper.Info($"è§£éMESä»»å¡ ->{task.S_TASK_NO} æ¥æ¾æ¯å¦æå·²çæä»»å¡ï¼{t1s != null}");
			if (t1s.Any())
			{
			var t1 = t1s.OrderBy(x => x.T_CREATE).LastOrDefault();
			if (t1.S_END_LOC == task.S_END_LOC)
			{
			task.N_PRIORITY = 0;
			task.S_B_STATE = "MES_å®æ";
			taskservice.Update(task);
			continue;
			}
			if (t1.S_B_STATE == "å®æ")
			{
			//1.ç»ç¹æ¯å¦ææçã ä¾æ®æ¯ç»ç¹çä»»å¡æ¯ ä½ä¸ºç»ç¹ï¼è¿æ¯èµ·ç¹ã
			//var ec = taskservice.FindList(x => (x.S_START_LOC == task.S_START_LOC \|\| x.S_END_LOC == task.S_END_LOC) /&& DateTime.Now.Subtract(x.T_CREATE).TotalHours < 5/).OrderByDescending(x => x.T_CREATE).FirstOrDefault();//($"select top 1 * from TN_TASK WHERE S_START_LOC='{task.S_END_LOC}' OR S_END_LOC='{task.S_END_LOC}' ORDER BY T_CREATE DESC");
			//var ec = taskservice.FindList(x => x.S_START_LOC == task.S_START_LOC && x.S_END_LOC == task.S_START_LOC, new Common.Data.Pagination
			// {
			// page = 1,
			// sidx = "T_CREATE",
			// sord = "desc",
			// rows = 1
			// }).FirstOrDefault();
			//TaskEntity ec = null;
			//var dev = Conn.é»è®¤Redis.GetValue(sx.deviceName + "." + (sindex == 0 ? "D1224" : "D1225"));
			//if (dev?.Trim() == "1")
			// ec = taskservice.FindList(x => x.S_END_LOC == task.S_END_LOC && x.S_B_STATE == "å®æ", new Common.Data.Pagination
			// {
			// page = 1,
			// sidx = "T_CREATE",
			// sord = "desc",
			// rows = 1
			// }).FirstOrDefault();
			bool canReq = true;
			var tf = Conn.é»è®¤Redis.GetValue(sx.deviceName + ".D1202");
			var V = sx.location.ToList().FindIndex(x => x == task.S_END_LOC) == 0;
			var tf2 = int.Parse(string.IsNullOrEmpty(tf) ? "0" : tf);
			canReq = TcpServer.GetBitdata(tf2, (V ? 2 : 3)) == 1;
			//if (canReq)
			// ec = taskservice.FindList(x => x.S_END_LOC == task.S_END_LOC && x.S_B_STATE == "å®æ", new Common.Data.Pagination
			// {
			// page = 1,
			// sidx = "T_CREATE",
			// sord = "desc",
			// rows = 1
			// }).FirstOrDefault();
			if (t1.S_START_LOC == task.S_START_LOC && canReq)//!= task.S_END_LOC)
			{
			//ç¬¬äºæ®µã
			LocEntity endLoc = null;
			var di = sx;
			if (di != null)
			{
			//foreach (var ssloc in di.deviceNo)
			{
			var ssloc = di.deviceNo[1];
			var endloc = locRepository.FindEntity(x => x.S_LOC_CODE == ssloc);
			if (endloc != null && endloc.N_CURRENT_NUM == 0 && endloc.S_LOCK_STATE.Trim() == "æ ")
			{
			endLoc = endloc;
			//break;
			}
			}
			if (endLoc != null)
			{
			var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_END_LOC, endLoc.S_LOC_CODE, task.S_TYPE + "ä¸ç©º", 7, "NONE".Split(',').ToList());
			if (res)
			{
			task.N_PRIORITY = 0; taskservice.Update(task);
			}
			}
			}
			}
			else
			{
			if (t1.S_START_LOC != task.S_START_LOC)
			{
			t1 = taskservice.FindEntity(x => x.S_SRC_NO == task.S_TASK_NO && x.S_START_LOC == task.S_START_LOC && x.S_B_STATE == "å®æ");
			}
			var res = TaskProcess.CreateTask(task.S_TASK_NO, t1.S_END_LOC, task.S_END_LOC, task.S_TYPE + "è¡¥æ»¡", 6, task.S_CNTRS.Split(',').ToList());
			if (res)
			{
			task.N_PRIORITY = 0; taskservice.Update(task);
			}
			}
			}
			}
			else
			{
			LogHelper.Info($"è§£éMESä»»å¡ ->{task.S_TASK_NO} çéçæç¬¬ä¸æ®µ ä»»å¡ã");
			//çæç¬¬ä¸æ®µã
			LocEntity endLoc = null;
			var di = sx;
			if (di != null)
			{
			//foreach (var ssloc in di.deviceNo)
			{
			var ssloc = di.deviceNo[0];
			var endloc = locRepository.FindEntity(x => x.S_LOC_CODE == ssloc);
			if (endloc != null && endloc.N_CURRENT_NUM == 0 && endloc.S_LOCK_STATE.Trim() == "æ ")
			{
			endLoc = endloc;
			//break;
			}
			}
			if (endLoc != null)
			{
			LogHelper.Info($"è§£éMESä»»å¡ ->{task.S_TASK_NO} åå»ºç¬¬ä¸æ®µ ä»»å¡ã");
			var res = TaskProcess.CreateTask(task.S_TASK_NO, task.S_START_LOC, endLoc.S_LOC_CODE, task.S_TYPE + "æ»¡è½¬", 8, task.S_CNTRS.Split(',').ToList());

			LogHelper.Info($"è§£éMESä»»å¡ ->{task.S_TASK_NO} åå»ºç¬¬ä¸æ®µ ä»»å¡ãç»æï¼{res}");
			if (res)
			{
			task.N_PRIORITY = 0; taskservice.Update(task);
			}
			}
			}
			}

			}
			}
			}


			public HkReturnResult OperateHKTaskStatus(HaiKangOrderInfo model)
			{
			// æ¥è¯¢ä»»å¡ï¼æ ¹æ®ä»»å¡å·
			//var wcsTask = WCSHelper.GetTask(model.taskCode);
			ITaskRepository MainMissionService = new TaskRepository();
			var wcsTask = MainMissionService.FindEntity(x => model.taskCode == x.S_TASK_NO);
			if (wcsTask != null)
			{
			if (!string.IsNullOrWhiteSpace(model.method))
			{
			ILocRepository locrep = new LocRepository();
			var startloc = locrep.FindEntity(x => x.S_LOC_CODE == wcsTask.S_START_LOC);
			var endLoc = locrep.FindEntity(x => x.S_LOC_CODE == wcsTask.S_END_LOC);

			List<string> cntrs = wcsTask.S_CNTRS.Split(',').ToList();
			bool bobe = false;
			//model.method = model.method?.ToLower();
			switch (model.method)
			{
			case "start":
			LogHelper.Info($"æµ·åº·è½¦ä»»å¡ç¶æåæ´ä¸ºæ§è¡ï¼ä»»å¡å·ä¸ºï¼{model.taskCode}", "agvæåäº¤äºæ¥å¿");
			if (wcsTask.S_B_STATE.Trim() == "å·²æ¨é")
			{
			wcsTask.S_B_STATE = "æ§è¡ä¸";
			wcsTask.T_START_TIME = DateTime.Now;
			MainMissionService.Update(wcsTask);
			bobe = true;
			}
			break;
			case "outBin":
			case "outbin":
			model.method = model.method?.ToLower();
			LogHelper.Info($"æµ·åº·è½¦ä»»å¡ç¶æåæ´ä¸ºåè´§å®æï¼ä»»å¡å·ä¸ºï¼{model.taskCode}", "agvæåäº¤äºæ¥å¿");
			wcsTask.S_B_STATE = "åè´§å®æ";

			startloc.N_CURRENT_NUM = 0;
			startloc.S_LOCK_STATE = "æ ";
			startloc.T_MODIFY = DateTime.Now;
			//ILocContainerRepository locContainerRepository = new LocContainerRepository();
			////var cnr = locContainerRepository.FindList(x => cntrs.Contains(x.S_CNTR_CODE.Trim()) && x.S_LOC_CODE == wcsTask.S_START_LOC);
			//locContainerRepository.Delete(x => cntrs.Contains(x.S_CNTR_CODE.Trim()) && x.S_LOC_CODE == wcsTask.S_START_LOC);
			MainMissionService.Update(wcsTask);
			locrep.Update(startloc);

			bobe = true;
			var device = Settings.deviceInfos.Find(x => x.location.Contains(wcsTask.S_START_LOC));
			if (device != null)
			{
			if (device.deviceType == 1)
			{
			if (device.deviceName.Contains("ç»´å¸å°æè"))
			{ //å¸è´§è¿è¡æ¸ç©ºï¼è§¦åæ«ç
			var inde = device.location.ToList().FindIndex(x => x == wcsTask.S_START_LOC) == 0;
			string V = inde ? "R05" : "R06";
			Conn.é»è®¤Redis.SetValue(device.deviceName + "." + V, "true", device.deviceName + "Queue", false);

			TcpServer.TrayIps.Remove(device.deviceNo[inde ? 0 : 1]);
			}
			}
			else if (device.deviceType == 2)
			{
			//Task.Run(() =>
			//{
			// var inde = device.location.ToList().FindIndex(x => x == wcsTask.S_START_LOC) == 0;
			// string V = inde ? "D1224" : "D1225";
			// Conn.é»è®¤Redis.SetValue(device.deviceName + "." + V, "0", device.deviceName + "Queue");
			//});
			}
			}
			//LocationHelper.UnLockLoc(wcsTask.S_START_LOC);
			break;
			case "end":
			LogHelper.Info($"æµ·åº·è½¦ä»»å¡ç¶æåæ´ä¸ºå®æï¼ä»»å¡å·ä¸ºï¼{model.taskCode}", "agvæåäº¤äºæ¥å¿");
			wcsTask.S_B_STATE = "å®æ";
			wcsTask.T_END_TIME = DateTime.Now;

			bobe = true;
			//ILocContainerRepository locContainerRepository2 = new LocContainerRepository();
			//List<LocContainerEntity> llls = new List<LocContainerEntity>();
			//foreach (var c in cntrs)
			//{
			// var action = new LocContainerEntity()
			// {
			// S_ID = Guid.NewGuid().ToString(),
			// S_STATE = "ç¼è¾",
			// T_CREATE = DateTime.Now,
			// T_MODIFY = DateTime.Now,

			// S_LOC_CODE = endLoc.S_LOC_CODE,
			// S_CNTR_CODE = c,
			// S_TYPE = "",
			// };
			// llls.Add(action);
			//}

			endLoc.S_LOCK_STATE = "æ ";
			endLoc.N_CURRENT_NUM = 1;
			endLoc.T_MODIFY = DateTime.Now;
			MainMissionService.Update(wcsTask);
			if (Settings.deviceInfos.Find(x => x.deviceType == 2 && (/x.location.Contains(wcsTask.S_END_LOC)\|\|/x.deviceNo.Contains(wcsTask.S_END_LOC))) != null)
			locrep.Update(endLoc);
			//locContainerRepository2.Insert(llls);

			var device2 = Settings.deviceInfos.Find(x => x.location.Contains(wcsTask.S_END_LOC));
			if (device2 != null)
			{
			if (device2.deviceType == 1)
			{
			if (device2.deviceName.Contains("ç»´å¸å°æè"))
			{
			//string V = device2.location.ToList().FindIndex(x => x == wcsTask.S_START_LOC) == 0 ? "R10" : "R11";
			//Conn.é»è®¤Redis.SetValue(device2.deviceName + "." + V, "true", device2.deviceName + "Queue");
			//å¸è´§ååæçåèµ°ã ç¶åè§¦åæ«ç è¿è¡æ ¡éªã
			var inde = device2.location.ToList().FindIndex(x => x == wcsTask.S_END_LOC) == 0;
			//string V = inde ? "R05" : "R06";
			//Conn.é»è®¤Redis.SetValue(device2.deviceName + "." + V, "true", device2.deviceName + "Queue");
			string V2 = inde ? "R10_LAST" : "R11_LAST";
			//Conn.é»è®¤Redis.SetValue(device2.deviceName + "." + V2, "true", device2.deviceName + "Queue");

			GZ.Modular.Redis.RedisHelper.Add(device2.deviceName + "." + V2, "true", out string msg1);
			TcpServer.TrayIps.Remove(device2.deviceNo[inde ? 0 : 1]);
			}
			}
			else if (device2.deviceType == 2)
			{
			if (device2.deviceName.Contains("Jsæ·é¡º"))
			{
			//Task.Run(() =>
			//{
			var inde = device2.location.ToList().FindIndex(x => x == wcsTask.S_END_LOC) == 0;
			string V = inde ? "D1224" : "D1225";
			Conn.é»è®¤Redis.SetValue(device2.deviceName + "." + V, "1", device2.deviceName + "Queue");
			//});

			var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/202", JsonConvert.SerializeObject(new
			{
			sceneType = 3,
			cntrCode = cntrs.FirstOrDefault()
			}));
			//if (device2.deviceName.Contains("1"))
			//{
			// if (inde) tag.Js1.D1224 = 1;
			// else tag.Js1.D1225 = 1;
			//}else
			//{
			// if (inde) tag.Js2.D1224 = 1;
			// else tag.Js2.D1225 = 1;
			//}
			}
			var ssloc = device2.deviceNo[1];
			var endloc = locrep.FindEntity(x => x.S_LOC_CODE == ssloc);
			LogHelper.Info($"æ·é¡ºå¸è´§åï¼ æ¥çç¼åä½ {ssloc}-{endloc?.N_CURRENT_NUM}>0? åç³è¯·mesæ¬èµ°ã");
			if (endloc != null && endloc.N_CURRENT_NUM == 1)
			{
			var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new
			{
			requestType = 3,
			startBit = ssloc
			}));
			LogHelper.Info($"{ssloc}ç³è¯·mesä»»å¡ç»æ{str}");
			}
			}
			switch (device2.deviceType)
			{
			case 4:
			{
			if (wcsTask.S_END_LOC == "2001")
			{

			}
			}
			break;
			case 5:
			{
			var inde = device2.location.ToList().FindIndex(x => x == wcsTask.S_END_LOC) == 0;
			string V = inde ? "D2210" : "D2215";
			Conn.é»è®¤Redis.SetValue(device2.deviceName + "." + V, "1", device2.deviceName + "Queue");
			}
			break;
			case 6:
			{
			//var inde = device2.location.ToList().FindIndex(x => x == wcsTask.S_END_LOC) == 0;
			//string V = inde ? "D2210" : "D2215";
			//Conn.é»è®¤Redis.SetValue(device2.deviceName + "." + V, "1", device2.deviceName + "Queue");
			}
			break;
			}
			}

			//LocationMethod.JudgeLocation(wcsTask);
			break;
			case "cancel":
			LogHelper.Info($"æµ·åº·è½¦ä»»å¡ç¶æåæ´ä¸ºåæ¶ï¼ä»»å¡å·ä¸ºï¼{model.taskCode}", "agvæåäº¤äºæ¥å¿");
			wcsTask.S_B_STATE = "åæ¶";
			//startloc.S_LOCK_STATE = "æ ";
			//endLoc.S_LOCK_STATE = "æ ";
			MainMissionService.Update(wcsTask);
			TaskActRepository taskActRepository = new TaskActRepository();
			var tare = taskActRepository.FindList(x => x.S_TASK_NO == wcsTask.S_TASK_NO);
			if (tare.Any())
			{
			if (tare.Find(x => x.S_ACTION_CODE == "outbin") == null)
			{
			startloc.S_LOCK_STATE = "æ ";
			endLoc.S_LOCK_STATE = "æ ";
			locrep.Update(startloc);
			locrep.Update(endLoc);
			}
			else if (tare.Find(x => x.S_ACTION_CODE == "end") == null)
			{
			endLoc.S_LOCK_STATE = "æ ";
			locrep.Update(endLoc);
			}
			}

			//locrep.Update(startloc);
			//locrep.Update(endLoc);
			//TaskProcess.OperateStatus(wcsTask, 7);
			//WCSHelper.Fail(wcsTask);
			break;
			case "apply":
			// å¤æè¯¥ä»»å¡çæ¥é©³ä½æ¯å¦æå¶ä»å¥åºæåºåºä»»å¡ï¼å¦ææï¼åå¨çä½çå¾ï¼å¦ææ²¡æï¼åå¥
			//TaskisOk(wcsTask);
			break;
			}

			if (!string.IsNullOrEmpty(wcsTask.S_SRC_NO))
			{
			var mestask = MainMissionService.FindEntity(x => x.S_TASK_NO == wcsTask.S_SRC_NO);
			if (mestask != null && bobe)
			{
			if (model.method != "end")
			{
			if (mestask.S_START_LOC == wcsTask.S_START_LOC && mestask.S_B_STATE == "MES")
			Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/201", JsonConvert.SerializeObject(new
			{
			reqCode = wcsTask.S_SRC_NO,
			model.method
			}));
			}
			else
			{
			if (mestask.S_END_LOC != wcsTask.S_END_LOC)
			{
			LogHelper.Info($"{wcsTask.S_SRC_NO}-{wcsTask.S_TASK_NO} ä¸é¶æ®µå®æï¼éç½®è¿è¡äºé¶æ®µã");
			mestask.N_PRIORITY = -88;
			MainMissionService.Update(mestask);
			}
			else if (mestask.S_B_STATE == "MES")
			{
			var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/201", JsonConvert.SerializeObject(new
			{
			reqCode = wcsTask.S_SRC_NO,
			model.method
			}));
			}
			}

			}
			else if (mestask != null && model.method == "cancel")
			{
			if (mestask.S_B_STATE == "MES")
			Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/201", JsonConvert.SerializeObject(new
			{
			reqCode = wcsTask.S_SRC_NO,
			model.method
			}));
			LogHelper.Info($"{wcsTask.S_SRC_NO}-{wcsTask.S_TASK_NO} ä¸é¶æ®µåæ¶ï¼éç½®ç¹ï¼çº¿ç¨å¤çã");
			mestask.N_PRIORITY = -1;
			mestask.S_B_STATE = "MES_åæ¶";
			MainMissionService.Update(mestask);
			}
			}
			TaskProcess.AddActionRecord(model.taskCode, model.method, model.eqpCode, model.data, wcsTask.S_START_LOC, wcsTask.S_END_LOC);
			//è°ç¨ç¬¬ä¸æ¹æ¥å£ï¼å¦ææï¼TaskProcess.ReportStatus
			}
			else
			{
			// ææ¶è®¾å®ä¸º0
			wcsTask.S_B_STATE = "ä¸æ¥ç¶æç©º";
			//å®å¨è¯·æ±ç
			//TaskProcess.OperateReq(model.taskCode, wcsTask.N_B_STATE, model.eqpCode, model.data);
			}
			}
			else
			{
			LogHelper.Info($"å½åä»»å¡å·ä»»å¡ä¸åå¨{model.taskCode} agvæåäº¤äºæ¥å¿");
			return new HkReturnResult { reqCode = model.reqCode, code = 1, message = "è¿ä¸æ¯æä»¬çä»»å¡ã" };
			}
			return new HkReturnResult { reqCode = model.reqCode, code = 0 };
			}

			public void TaskEverythingRun()
			{
			var host = System.Net.Dns.GetHostEntry(System.Net.Dns.GetHostName());
			foreach (var ip in host.AddressList)
			{
			if (ip.AddressFamily == System.Net.Sockets.AddressFamily.InterNetwork)
			{
			Console.WriteLine($"ip= {ip.ToString()}");
			new HttpServer(ip.ToString()).HttpServerRun();
			new TcpServer(ip.ToString());
			var server = new EnhancedWebSocketServer($"http://{ip.ToString()}:8809/").StartAsync();
			//var client = new WebSocketClient($"http://{ip.ToString()}:8809/").ConnectAsync();
			break;
			}
			}
			}

			/// <summary>
			/// å®å1å·çº¿ã
			/// 1.å¢å ä¸çº¿é»è¾ã 2. æåçä¿¡å·å°±åï¼æ²¡ä¿¡å·å«å
			/// </summary>
			/// <param name="tag"></param>
			public void ThreadMXC3(Tag tag)
			{
			var VERX = Settings.deviceInfos.Find(x => x.deviceType == 5 && x.deviceName.Contains("1å·"));
			if (VERX == null)
			{
			LogHelper.Info("å®å1å·çº¿ 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}");
			if (tag.DZ1.D2221 == 1 && tag.DZ1.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],
			unLockStartBitOutbin = true
			}));
			LogHelper.Info($"{VERX.location[0]}ç³è¯·mesä»»å¡ç»æ{str}");
			var strr = JsonConvert.DeserializeObject<Messss>(str);
			if (strr != null && strr.success && strr.data?.state == 0)
			RedisHelper.Add($"Då®å1å·æºæ¢°æ.D2221_LAST", "1", out string msg);
			}
			else if (tag.DZ1.D2221 == 0 && tag.DZ1.D2221_LAST == 1)
			{
			LogHelper.Info($"éç½® Då®å1å·æºæ¢°æ.D2221_LAST > 0");
			RedisHelper.Add($"Då®å1å·æºæ¢°æ.D2221_LAST", "0", out string msg);

			string V = 0 == 0 ? "D2210" : "D2215";
			Conn.é»è®¤Redis.SetValue(VERX.deviceName + "." + V, "0", VERX.deviceName + "Queue");
			}


			if (tag.DZ1.D2226 == 1 && tag.DZ1.D2226_LAST == 0)
			{
			var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new
			{
			requestType = 7,
			startBit = VERX.location[1],
			unLockStartBitOutbin = true
			}));
			LogHelper.Info($"{VERX.location[0]}ç³è¯·mesä»»å¡ç»æ{str}");
			var strr = JsonConvert.DeserializeObject<Messss>(str);
			if (strr != null && strr.success && strr.data?.state == 0)
			RedisHelper.Add($"Då®å1å·æºæ¢°æ.D2226_LAST", "1", out string msg);
			}
			else if (tag.DZ1.D2226 == 0 && tag.DZ1.D2226_LAST == 1)
			{
			LogHelper.Info($"éç½® Då®å1å·æºæ¢°æ.D2226_LAST > 0");
			RedisHelper.Add($"Då®å1å·æºæ¢°æ.D2226_LAST", "0", out string msg);
			string V = 1 == 0 ? "D2210" : "D2215";
			Conn.é»è®¤Redis.SetValue(VERX.deviceName + "." + V, "0", VERX.deviceName + "Queue");
			}


			}
			/// <summary>
			/// å®å2å·çº¿ã
			/// </summary>
			/// <param name="tag"></param>
			public void ThreadMXC4(Tag tag)
			{
			var VERX = Settings.deviceInfos.Find(x => x.deviceType == 5 && x.deviceName.Contains("2å·"));
			if (VERX == null)
			{
			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}");
			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],
			unLockStartBitOutbin = true
			}));
			LogHelper.Info($"{VERX.location[0]}ç³è¯·mesä»»å¡ç»æ{str}");
			var strr = JsonConvert.DeserializeObject<Messss>(str);
			if (strr != null && strr.success && strr.data?.state == 0)
			RedisHelper.Add($"Då®å2å·æºæ¢°æ.D2221_LAST", "1", out string msg);
			}
			else if (tag.DZ2.D2221 == 0 && tag.DZ2.D2221_LAST == 1)
			{
			LogHelper.Info($"éç½® Då®å2å·æºæ¢°æ.D2221_LAST > 0");
			RedisHelper.Add($"Då®å2å·æºæ¢°æ.D2221_LAST", "0", out string msg);
			string V = 0 == 0 ? "D2210" : "D2215";
			Conn.é»è®¤Redis.SetValue(VERX.deviceName + "." + V, "0", VERX.deviceName + "Queue");
			}


			if (tag.DZ2.D2226 == 1 && tag.DZ2.D2226_LAST == 0)
			{
			var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new
			{
			requestType = 7,
			startBit = VERX.location[1],
			unLockStartBitOutbin = true
			}));
			LogHelper.Info($"{VERX.location[0]}ç³è¯·mesä»»å¡ç»æ{str}");
			var strr = JsonConvert.DeserializeObject<Messss>(str);
			if (strr != null && strr.success && strr.data?.state == 0)
			RedisHelper.Add($"Då®å2å·æºæ¢°æ.D2226_LAST", "1", out string msg);
			}
			else if (tag.DZ2.D2226 == 0 && tag.DZ2.D2226_LAST == 1)
			{
			LogHelper.Info($"éç½® Då®å2å·æºæ¢°æ.D2226_LAST > 0");
			RedisHelper.Add($"Då®å2å·æºæ¢°æ.D2226_LAST", "0", out string msg);
			string V = 1 == 0 ? "D2210" : "D2215";
			Conn.é»è®¤Redis.SetValue(VERX.deviceName + "." + V, "0", VERX.deviceName + "Queue");
			}

			}

			}




			public class HttpServer
			{
			System.Net.HttpListener HttpSvcHost = null;

			public static string _listenerPrefix = "";
			public HttpServer(string ip)
			{
			_listenerPrefix = $"http://{ip}:8808/";
			}
			public void HttpServerRun()
			{
			HttpSvcHost = new System.Net.HttpListener();
			HttpSvcHost.AuthenticationSchemes = System.Net.AuthenticationSchemes.Anonymous;
			HttpSvcHost.Prefixes.Add(_listenerPrefix);
			HttpSvcHost.Start();
			HttpSvcHost.BeginGetContext(HttpSvcListenerCallback, null);
			}


			private async void HttpSvcListenerCallback(IAsyncResult ar)
			{
			System.Net.HttpListenerContext context = null;
			var data = DateTime.Now;
			string apth = "";
			try
			{
			HttpSvcHost.BeginGetContext(HttpSvcListenerCallback, null);
			context = HttpSvcHost.EndGetContext(ar);
			System.Net.HttpListenerRequest request = context.Request;
			System.Net.HttpListenerResponse response = context.Response;

			using (var reader = new System.IO.StreamReader(request.InputStream, System.Text.Encoding.UTF8))
			{
			string requestJson = reader.ReadToEnd();
			System.Net.HttpStatusCode statusCode = 0;
			apth = request.Url.AbsolutePath;
			string respstr = HttpSvcListenerCallback_he(request.HttpMethod, request.Url.AbsolutePath, requestJson, out statusCode);
			string logContent = "";
			logContent += $"\r\n[{request.HttpMethod}]{request.Url.AbsolutePath}";
			logContent += $"\r\n[request]{requestJson}";
			logContent += $"\r\n[response]{respstr}";
			_ = Task.Run(() =>
			{
			Conn.é»è®¤æ¥å¿?.Info(logContent);
			});
			byte[] bytstr = Encoding.UTF8.GetBytes(respstr);
			response.StatusCode = (int)statusCode;
			response.SendChunked = false;
			response.ContentLength64 = bytstr.Length;
			//response.OutputStream.Write(bytstr, 0, bytstr.Length);
			if (request.Url.AbsolutePath.ToLower().Contains(".js"))
			response.ContentType = "application/javascript";
			else if (request.Url.AbsolutePath.ToLower().Contains(".svg"))
			response.ContentType = "image/svg+xml";
			// å¼æ¥åå¥ååº
			await response.OutputStream.WriteAsync(bytstr, 0, bytstr.Length);
			}
			}
			catch (Exception ex)
			{
			_ = Task.Run(() =>
			{
			Conn.é»è®¤æ¥å¿.Error(ex.ToString());
			});
			}
			finally
			{
			context?.Response.Close();
			Console.WriteLine(apth + "<<>>" + DateTime.Now.Subtract(data).TotalMilliseconds);
			}
			}
			private System.String HttpSvcListenerCallback_he(System.String method, System.String path, System.String requestJson, out System.Net.HttpStatusCode statusCode)
			{
			try
			{
			switch (method)
			{
			case "POST":
			{
			switch (path)
			{
			case "/agv/agvCallbackService/agvCallback":
			{
			statusCode = System.Net.HttpStatusCode.OK;

			LogHelper.Info("ExecuteState Request-haikangï¼" + requestJson);
			var model = JsonConvert.DeserializeObject<HaiKangOrderInfo>(requestJson);
			AutoThread.Instance.OperateHKTaskStatus(model);
			return JsonConvert.SerializeObject(new HkReturnResult { reqCode = model.reqCode });
			}
			case "/api/Wcs/CreateTask":
			{
			statusCode = System.Net.HttpStatusCode.OK;

			LogHelper.Info("/api/Wcs/CreateTaskï¼" + requestJson);
			var model = JsonConvert.DeserializeObject<ToWMSMES.CreateTask>(requestJson);
			var res = ToWMSMES.CreateTask.CreatemesTask(model);
			return JsonConvert.SerializeObject(res);
			}
			case "/api/Wcs/TestRequestTask":
			{
			statusCode = System.Net.HttpStatusCode.OK;
			LogHelper.Info("/api/Wcs/TestRequestTaskï¼" + requestJson);
			var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", requestJson);
			return str;
			}
			case "/api/Wcs/updateStatus":
			{
			statusCode = System.Net.HttpStatusCode.OK;
			LogHelper.Info("/api/Wcs/updateStatusï¼" + requestJson);
			var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/201", requestJson);
			return str;
			}
			case "/api/Wcs/toMes":
			{
			statusCode = System.Net.HttpStatusCode.OK;

			LogHelper.Info("/api/Wcs/toMesï¼" + requestJson);
			var str = Settings.apiHelper.Post(Settings.MESbaseUrl + "mom-basic/dataTransmission/json/service/202", requestJson);
			return str;
			}
			case "/api/Wcs/CreatePointTask":
			{
			statusCode = System.Net.HttpStatusCode.OK;

			LogHelper.Info("/api/Wcs/CreatepointTaskï¼" + requestJson);
			var model = JsonConvert.DeserializeObject<ToWMSMES.CreateTask>(requestJson);
			var res = ToWMSMES.CreateTask.CreatePointTask(model);
			return JsonConvert.SerializeObject(res);
			}
			}
			break;
			}
			case "GET":
			{
			switch (path)
			{
			case var _ when System.Text.RegularExpressions.Regex.IsMatch(path, @"\.(html\|ico\|js\|css)(\?.*)?$", System.Text.RegularExpressions.RegexOptions.IgnoreCase):
			{
			statusCode = System.Net.HttpStatusCode.OK;
			// å¤å¶å°case ä¸
			//var _ when System.Text.RegularExpressions.Regex.IsMatch(path, @"\.(html\|ico\|js\|css)(\?.*)?$", System.Text.RegularExpressions.RegexOptions.IgnoreCase)
			var filePath = /Directory.GetCurrentDirectory() + "\\Static" + "\\" + path.Substring(1);/System.IO.Path.Combine(Directory.GetCurrentDirectory() + "\\Static", path.Substring(1));
			return File.ReadAllText(filePath);
			}
			}
			break;
			}
			}
			statusCode = System.Net.HttpStatusCode.NotFound;
			return "";
			}
			catch (Exception ex)
			{
			Conn.é»è®¤æ¥å¿.Error(ex.ToString());
			statusCode = System.Net.HttpStatusCode.InternalServerError;
			return "";
			}
			}
			}

			class EnhancedWebSocketServer
			{
			private HttpListener _listener;
			private readonly string _listenerPrefix;
			private readonly ConcurrentDictionary<Guid, WebSocket> _connections = new ConcurrentDictionary<Guid, WebSocket>();
			private CancellationTokenSource _cts = new CancellationTokenSource();

			public EnhancedWebSocketServer(string url)
			{
			_listenerPrefix = url;
			}

			public async Task StartAsync()
			{
			try
			{
			_listener = new HttpListener();
			_listener.Prefixes.Add(_listenerPrefix);
			_listener.Start();
			Console.WriteLine($"WebSocketæå¡å¨å·²å¯å¨ï¼çå¬ {_listenerPrefix}");
			while (!_cts.IsCancellationRequested)
			{
			HttpListenerContext context = await _listener.GetContextAsync();
			if (context.Request.IsWebSocketRequest)
			{
			var wsContext = await context.AcceptWebSocketAsync(null);
			var connectionId = Guid.NewGuid();
			_connections[connectionId] = wsContext.WebSocket;
			_ = HandleConnectionAsync(connectionId, wsContext.WebSocket, _cts.Token);
			}
			else
			{
			context.Response.StatusCode = 400;
			context.Response.Close();
			}
			}
			}
			catch (Exception ex) when (ex is HttpListenerException \|\| ex is ObjectDisposedException)
			{
			// æå¡å¨åæ¢æ¶çæ£å¸¸å¼å¸¸
			Console.WriteLine("æå¡å¨æ£å¨åæ¢...");
			}
			}

			private async Task HandleConnectionAsync(Guid connectionId, WebSocket webSocket, CancellationToken ct)
			{
			var buffer = new byte[1024 * 4];
			try
			{
			while (webSocket.State == WebSocketState.Open && !ct.IsCancellationRequested)
			{
			var result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), ct);

			if (result.MessageType == WebSocketMessageType.Close)
			{
			await webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, "å®¢æ·ç«¯å³éè¿æ¥", ct);
			break;
			}

			string message = System.Text.Encoding.UTF8.GetString(buffer, 0, result.Count);
			Console.WriteLine($"è¿æ¥ {connectionId} æ¶å°æ¶æ¯: {message}");

			// å¹¿ææ¶æ¯ç»ææå®¢æ·ç«¯
			await BroadcastMessageAsync($"å®¢æ·ç«¯ {connectionId} è¯´: {message}");
			}
			}
			catch (WebSocketException ex)
			{
			Console.WriteLine($"è¿æ¥ {connectionId} éè¯¯: {ex.WebSocketErrorCode} - {ex.Message}");
			}
			catch (Exception ex)
			{
			Console.WriteLine($"å¤çè¿æ¥ {connectionId} æ¶åºé: {ex.Message}");
			}
			finally
			{
			_connections.TryRemove(connectionId, out _);
			webSocket?.Dispose();
			Console.WriteLine($"{DateTime.Now.ToString("HH:mm:ss.fff")} è¿æ¥ {connectionId} å·²å³é");
			}
			}

			public async Task BroadcastMessageAsync(string message)
			{
			var buffer = System.Text.Encoding.UTF8.GetBytes(message);
			foreach (var connection in _connections)
			{
			if (connection.Value.State == WebSocketState.Open)
			{
			try
			{
			await connection.Value.SendAsync(
			new ArraySegment<byte>(buffer),
			WebSocketMessageType.Text,
			true,
			CancellationToken.None);
			}
			catch (Exception ex)
			{
			Console.WriteLine($"å¹¿ææ¶æ¯å°è¿æ¥ {connection.Key} å¤±è´¥: {ex.Message}");
			}
			}
			}
			}

			public async Task StopAsync()
			{
			_cts.Cancel();

			// å³éææè¿æ¥
			foreach (var connection in _connections)
			{
			try
			{
			if (connection.Value.State == WebSocketState.Open)
			{
			await connection.Value.CloseAsync(
			WebSocketCloseStatus.NormalClosure,
			"æå¡å¨å³é",
			CancellationToken.None);
			}
			connection.Value.Dispose();
			}
			catch (Exception ex)
			{
			Console.WriteLine($"å³éè¿æ¥ {connection.Key} æ¶åºé: {ex.Message}");
			}
			}

			_listener?.Stop();
			_listener?.Close();
			Console.WriteLine("WebSocketæå¡å¨å·²åæ¢");
			}

			}

			internal class WebSocketClient
			{
			private ClientWebSocket _webSocket = new ClientWebSocket();
			private readonly Uri _serverUri;

			public WebSocketClient(string serverUrl)
			{
			_serverUri = new Uri(serverUrl);
			}

			public async Task ConnectAsync()
			{
			try
			{
			await _webSocket.ConnectAsync(_serverUri, CancellationToken.None);
			Console.WriteLine("å·²è¿æ¥å°WebSocketæå¡å¨");

			// å¯å¨æ¥æ¶æ¶æ¯ä»»å¡
			_ = ReceiveMessagesAsync();

			// åéæµè¯æ¶æ¯
			await SendMessageAsync("Hello, Server!");
			}
			catch (Exception ex)
			{
			Console.WriteLine($"è¿æ¥å¤±è´¥: {ex.Message}");
			}
			}

			private async Task ReceiveMessagesAsync()
			{
			var buffer = new byte[1024];
			try
			{
			while (_webSocket.State == WebSocketState.Open)
			{
			var result = await _webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
			if (result.MessageType == WebSocketMessageType.Close)
			{
			await _webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, string.Empty, CancellationToken.None);
			Console.WriteLine("æå¡å¨å³éäºè¿æ¥");
			break;
			}

			string message = Encoding.UTF8.GetString(buffer, 0, result.Count);
			Console.WriteLine($"æ¶å°æå¡å¨æ¶æ¯: {message}");
			}
			}
			catch (Exception ex)
			{
			Console.WriteLine($"æ¥æ¶æ¶æ¯æ¶åºé: {ex.Message}");
			}
			}

			public async Task SendMessageAsync(string message)
			{
			if (_webSocket.State != WebSocketState.Open)
			{
			Console.WriteLine("WebSocketæªè¿æ¥ï¼æ æ³åéæ¶æ¯");
			return;
			}

			byte[] buffer = Encoding.UTF8.GetBytes(message);
			await _webSocket.SendAsync(new ArraySegment<byte>(buffer), WebSocketMessageType.Text, true, CancellationToken.None);
			}

			public async Task DisconnectAsync()
			{
			if (_webSocket.State == WebSocketState.Open)
			{
			await _webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, "å®¢æ·ç«¯å³éè¿æ¥", CancellationToken.None);
			}
			_webSocket.Dispose();
			Console.WriteLine("å·²æå¼WebSocketè¿æ¥");
			}
			}


			class Messss
			{
			public bool success { get; set; }
			public Ddata data { get; set; }
			public object extra { get; set; }
			}
			class Mesrespone
			{
			public bool success { get; set; }
			public string msg { get; set; }
			public object extra { get; set; }
			}

			class MES2234
			{
			public bool success { get; set; }
			public ML data { get; set; }
			}

			public class ML
			{
			public string materialCode { get; set; }
			public int lineNum { get; set; }
			}

			public class Ddata
			{
			public string reqCode { get; set; }
			public int state { get; set; }
			public string error { get; set; }
			}
			}