From 0d746f4f5032d7bd7e86649e22a3227bd6087cc6 Mon Sep 17 00:00:00 2001 From: czw <selecti@yeah.net> Date: 星期四, 03 七月 2025 16:23:20 +0800 Subject: [PATCH] 11 --- 2025年6月12日/AuxAllWCS/Build/Project/代码/VS自定义类/AutoThread.cs | 2334 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 2,329 insertions(+), 5 deletions(-) diff --git "a/2025\345\271\2646\346\234\21012\346\227\245/AuxAllWCS/Build/Project/\344\273\243\347\240\201/VS\350\207\252\345\256\232\344\271\211\347\261\273/AutoThread.cs" "b/2025\345\271\2646\346\234\21012\346\227\245/AuxAllWCS/Build/Project/\344\273\243\347\240\201/VS\350\207\252\345\256\232\344\271\211\347\261\273/AutoThread.cs" index c8078c6..6cf597f 100644 --- "a/2025\345\271\2646\346\234\21012\346\227\245/AuxAllWCS/Build/Project/\344\273\243\347\240\201/VS\350\207\252\345\256\232\344\271\211\347\261\273/AutoThread.cs" +++ "b/2025\345\271\2646\346\234\21012\346\227\245/AuxAllWCS/Build/Project/\344\273\243\347\240\201/VS\350\207\252\345\256\232\344\271\211\347\261\273/AutoThread.cs" @@ -1,4 +1,5 @@ -锘縰sing Newtonsoft.Json; +#region [鑷畾涔夌被-VS][20250623083459471][AutoThread] +using Newtonsoft.Json; using System; using System.Collections.Generic; using System.Collections.Concurrent; @@ -7,6 +8,24 @@ using System.Reflection; using System.Text; using System.Threading.Tasks; +using GZ.Modular.Redis; +using GZ.DB.Entity.OIDATABASE; +using GZ.DB.IRepository.OIDATABASE; +using GZ.DB.Repository.OIDATABASE; +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; namespace GZ.Projects.AuxAllWCS { @@ -58,6 +77,8 @@ } // 鎵ц濮旀墭 + if (methodName != "TaskEverythingRun") + return null; return methodDelegate.DynamicInvoke(args); } @@ -79,10 +100,11 @@ } } - - - - + /// <summary> + /// 閰嶇疆鍒濆鍖栥� + /// </summary> + /// <param name="tag"></param> + /// <param name="action"></param> public void ThreadSettingInit(Tag tag, Action action) { Console.WriteLine("鍒濆鍖栭厤缃�绾跨▼ run " + tag.Global.SettingsOver); @@ -95,8 +117,2310 @@ { tag.Global.SettingsOver = 0; } + else tag.Global.SettingsOver++; + if (tag.Global.SettingsOver > 999) + { + tag.Global.SettingsOver = 1; + Console.Clear(); + } + } + + public string WriteLine(string value = "") + { + + + + + // 鍦ㄨ繖閲屾嫤鎴鐞嗚緭鍑�+ string intercepted = $"[鎷︽埅鍒扮殑杈撳嚭] {value}"; + return intercepted; + } + + /// <summary> + /// 鎹烽『1 淇″彿澶勭悊 + /// </summary> + /// <param name="tag"></param> + public void ThreadJS1(Tag tag) + { + Console.WriteLine($"ThreadJS1 鎹烽『1 淇″彿澶勭悊 =================> "); + var VERX = Settings.deviceInfos?.Find(x => x.deviceType == 2 && x.deviceName == "Js鎹烽『1"); + + if (VERX != null) + { + if (tag.Js1.D1212_LAST == 0 && TcpServer.GetBitdata(tag.Js1.D1212, 2) == 1) + { + var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new + { + requestType = 4, + endBit = VERX.location[0] + })); + LogHelper.Info($"{VERX.location[0]}鐢宠mes浠诲姟缁撴灉{str}"); + var strr = JsonConvert.DeserializeObject<Messss>(str); + if (strr != null && strr.success && strr.data?.state == 0) + { + //tag.Js1.D1212_LAST = 1; + 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.D1202_LAST", "0", out string msg); + } + + 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 + { + requestType = 4, + endBit = VERX.location[1] + })); + LogHelper.Info($"{VERX.location[1]}鐢宠mes浠诲姟缁撴灉{str}"); + var strr = JsonConvert.DeserializeObject<Messss>(str); + if (strr != null && strr.success && strr.data?.state == 0) + { + //tag.Js1.D1213_LAST = 1; + 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.D1203_LAST", "0", out string msg); + } + } + } + /// <summary> + /// 鎹烽『2 淇″彿澶勭悊 + /// </summary> + /// <param name="tag"></param> + public void ThreadJS2(Tag tag) + { + Console.WriteLine($"ThreadJS2 鎹烽『2 淇″彿澶勭悊 =================> "); + var VERX = Settings.deviceInfos?.Find(x => x.deviceType == 2 && x.deviceName == "Js鎹烽『2"); + + if (VERX != null) + { + if (tag.Js2.D1212_LAST == 0 && TcpServer.GetBitdata(tag.Js2.D1212, 2) == 1) + { + var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new + { + requestType = 4, + endBit = VERX.location[0] + })); + LogHelper.Info($"{VERX.location[0]}鐢宠mes浠诲姟缁撴灉{str}"); + var strr = JsonConvert.DeserializeObject<Messss>(str); + if (strr != null && strr.success && strr.data?.state == 0) + { + 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鎹烽『2.D1202_LAST", "0", out string msg); + } + if (tag.Js2.D1213_LAST == 0 && TcpServer.GetBitdata(tag.Js2.D1212, 3) == 1) + { + var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new + { + requestType = 4, + endBit = VERX.location[1] + })); + LogHelper.Info($"{VERX.location[1]}鐢宠mes浠诲姟缁撴灉{str}"); + + 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鎹烽『2.D1203_LAST", "0", out string msg); + } + } + } + /// <summary> + /// 缁村笇灏� 宸�+ /// </summary> + /// <param name="tag"></param> + public void Threadwxr1L(Tag tag) + { + Console.WriteLine($"Threadwxr1L 缁村笇灏� 宸�=================> "); + var VERX = Settings.deviceInfos?.Find(x => x.deviceType == 1 && x.deviceName.Contains("1")); + + if (VERX != null) + { + if (tag.wxr1.R44 && !tag.wxr1.R44_LAST && tag.wxr1.R10) + { + 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 + { + requestType = 1, + cntrCode = traycode, + startBit = VERX.location[0], + endBit = "" + })); + LogHelper.Info($"{VERX.location[0]}鐢宠mes浠诲姟缁撴灉{str}"); + var strr = JsonConvert.DeserializeObject<Messss>(str); + if (strr != null && strr.success && strr.data?.state == 0) + { + //tag.wxr1.R44_LAST = true; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R44_LAST", "true", out string msg); + } + } + else + { + TcpServer.TcpServerSend(VERX.deviceNo[0], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E")); + } + } + else + { + //TaskRepository ts = new TaskRepository(); + if (tag.wxr1.R10_LAST) //鎵樼洏鏀剧疆淇″彿銆傘� + { + if (tag.wxr1.R10) + { + //tag.wxr1.R10_LAST = false; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R10_LAST", "false", out string msg); + } + else + if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[0], out string traycode) && !string.IsNullOrEmpty(traycode.Trim())) + { + //涓婃姤鏍¢獙銆�+ ///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")) + { + //Conn.榛樿Redis.SetValue("缁村笇灏旀姄鑷�.R10", "true", "缁村笇灏旀姄鑷�Queue"); + tag.wxr1.R10 = true; + //tag.wxr1.R44_LAST = false; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R44_LAST", "false", out string msg); + } + else + { + //鎶ヨ銆�+ } + } + else { TcpServer.TcpServerSend(VERX.deviceNo[0], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E")); } + } + } + } + } + + /// <summary> + /// 缁村笇灏� 鍙�+ /// </summary> + /// <param name="tag"></param> + public void Threadwxr1R(Tag tag) + { + Console.WriteLine($"Threadwxr1R 缁村笇灏� 鍙�=================> "); + var VERX = Settings.deviceInfos?.Find(x => x.deviceType == 1 && x.deviceName.Contains("1")); + + if (VERX != null) + { + if (tag.wxr1.R46 && !tag.wxr1.R46_LAST && tag.wxr1.R11) + { + if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode) && !string.IsNullOrEmpty(traycode.Trim())) + { + var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new + { + requestType = 1, + cntrCode = traycode, + startBit = VERX.location[1], + endBit = "" + })); + LogHelper.Info($"{VERX.location[1]}鐢宠mes浠诲姟缁撴灉{str}"); + var strr = JsonConvert.DeserializeObject<Messss>(str); + if (strr != null && strr.success && strr.data?.state == 0) + { + //tag.wxr1.R46_LAST = true; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R46_LAST", "true", out string msg); + } + } + else + { + TcpServer.TcpServerSend(VERX.deviceNo[1], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E")); + } + } + else + { + if (tag.wxr1.R11_LAST) //鎵樼洏鏀剧疆淇″彿銆傘� + { + if (tag.wxr1.R11) + { + //tag.wxr1.R11_LAST = false; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R11_LAST", "false", out string msg); + } + else + if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode) && !string.IsNullOrEmpty(traycode.Trim())) + { + //涓婃姤鏍¢獙銆�+ ///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")) + { + //Conn.榛樿Redis.SetValue("缁村笇灏旀姄鑷�.R10", "true", "缁村笇灏旀姄鑷�Queue"); + tag.wxr1.R11 = true; + //tag.wxr1.R46_LAST = false; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R46_LAST", "false", out string msg); + } + else + { + //鎶ヨ銆�+ } + } + else { TcpServer.TcpServerSend(VERX.deviceNo[1], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E")); } + } + } + } + } + + /// <summary> + /// 缁村笇灏� 宸�+ /// </summary> + /// <param name="tag"></param> + public void Threadwxr2L(Tag tag) + { + Console.WriteLine($"Threadwxr2L 缁村笇灏� 宸�=================> "); + var VERX = Settings.deviceInfos?.Find(x => x.deviceType == 1 && x.deviceName.Contains("2")); + + if (VERX != null) + { + if (tag.wxr2.R44 && !tag.wxr2.R44_LAST && tag.wxr2.R10) + { + 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 + { + requestType = 1, + cntrCode = traycode, + startBit = VERX.location[0], + endBit = "" + })); + LogHelper.Info($"{VERX.location[0]}鐢宠mes浠诲姟缁撴灉{str}"); + var strr = JsonConvert.DeserializeObject<Messss>(str); + if (strr != null && strr.success && strr.data?.state == 0) + { + //tag.wxr2.R44_LAST = true; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R44_LAST", "true", out string msg); + } + } + else + { + TcpServer.TcpServerSend(VERX.deviceNo[0], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E")); + } + } + else + { + if (tag.wxr2.R10_LAST) //鎵樼洏鏀剧疆淇″彿銆傘� + { + if (tag.wxr2.R10) + { + //tag.wxr2.R10_LAST = false; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R10_LAST", "false", out string msg); + } + else + if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[0], out string traycode) && !string.IsNullOrEmpty(traycode.Trim())) + { + //涓婃姤鏍¢獙銆�+ ///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")) + { + //Conn.榛樿Redis.SetValue("缁村笇灏旀姄鑷�.R10", "true", "缁村笇灏旀姄鑷�Queue"); + tag.wxr2.R10 = true; + //tag.wxr2.R44_LAST = false; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R44_LAST", "false", out string msg); + } + else + { + //鎶ヨ銆�+ } + } + else { TcpServer.TcpServerSend(VERX.deviceNo[0], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E")); } + } + } + } + } + + /// <summary> + /// 缁村笇灏� 鍙�+ /// </summary> + /// <param name="tag"></param> + public void Threadwxr2R(Tag tag) + { + Console.WriteLine($"Threadwxr2R 缁村笇灏� 鍙�=================> "); + + var VERX = Settings.deviceInfos?.Find(x => x.deviceType == 1 && x.deviceName.Contains("2")); + + if (VERX != null) + { + if (tag.wxr2.R46 && !tag.wxr2.R46_LAST && tag.wxr2.R11) + { + if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode) && !string.IsNullOrEmpty(traycode.Trim())) + { + var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new + { + requestType = 1, + cntrCode = traycode, + startBit = VERX.location[1], + endBit = "" + })); + LogHelper.Info($"{VERX.location[1]}鐢宠mes浠诲姟缁撴灉{str}"); + var strr = JsonConvert.DeserializeObject<Messss>(str); + if (strr != null && strr.success && strr.data?.state == 0) + { + //tag.wxr2.R46_LAST = true; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R46_LAST", "true", out string msg); + } + } + else + { + TcpServer.TcpServerSend(VERX.deviceNo[2], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E")); + } + } + 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; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R11_LAST", "false", out string msg); + } + else + if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode) && !string.IsNullOrEmpty(traycode.Trim())) + { + LogHelper.Info($"Threadwxr2R 涓婃姤鏍¢獙>{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")) + { + //Conn.榛樿Redis.SetValue("缁村笇灏旀姄鑷�.R10", "true", "缁村笇灏旀姄鑷�Queue"); + tag.wxr2.R11 = true; + //tag.wxr2.R46_LAST = false; + RedisHelper.Add($"缁村笇灏旀姄鑷�.R46_LAST", "false", out string msg); + } + else + { + //鎶ヨ銆�+ } + } + else + { + LogHelper.Info($"Threadwxr2R銆傘� -鍙戦�鎵爜"); + TcpServer.TcpServerSend(VERX.deviceNo[1], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E")); + } + } + } + } + else + { + Console.WriteLine($"Threadwxr2R 缁村笇灏� 鍙� 璁惧鏈壘鍒般� =================> "); + } + } + + public void ThreadTaskRun(Tag tag, Func<TaskEntity, bool> action) + { + Console.WriteLine($"ThreadTaskRun 浠诲姟涓嬪彂 =================> "); + LogHelper.Info("ThreadTaskRun 浠诲姟涓嬪彂"); + + ITaskRepository taskservice = new TaskRepository(); + try + { + LogHelper.Info("浠诲姟涓嬪彂 AGV 浠诲姟 杩涘叆"); + #region AGV浠诲姟涓嬪彂銆�+ + var tklist = taskservice.FindList(x => x.S_B_STATE == "鏈墽琛� && x.S_WORK_MODE == "AGV"); + if (tklist.Any()) + foreach (var tk in tklist.GroupBy(item => + { + var ticks = item.T_CREATE.Ticks; + return new DateTime(ticks - ticks % (10 * TimeSpan.TicksPerMinute)); + }).OrderBy(x => x.Key)) + { + var ts = tk.OrderByDescending(x => x.N_PRIORITY).ToList(); + foreach (var t in ts) + { + var b = false; + b = action?.Invoke(t) ?? false; //new ViewModel().RunTask(t); + + if (b) + { + t.S_B_STATE = "宸叉帹閫�; + taskservice.Update(t); + } + } + break; + } + //foreach (var tk in tklist.GroupBy(item => + //{ + // var ticks = item.T_CREATE.Ticks; + // return new DateTime(ticks - ticks % (10 * TimeSpan.TicksPerMinute)); + //}).OrderBy(x => x.Key)) + //if (tklist.Any()) + //{ + + #endregion + } + catch (Exception ex) + { + LogHelper.Info(ex.Message + ex.StackTrace); + } + try + { + #region Rgv + + LogHelper.Info($"鏌ョ湅RGV 鐢甸噺锛氥�{tag.RGV.R褰撳墠鐢甸噺}銆�鍏呯數鐘舵�锛氥�{tag.RGV.R鍏呯數鐘舵�}銆�鏁呴殰浠g爜锛氥�{tag.RGV.RgvrunError}銆�鎵嬪姩1鑷姩2銆恵tag.RGV.R鎵嬪姩1鑷姩2}銆�); + + if (tag.RGV.R鎵嬪姩1鑷姩2 == 1) + { + LogHelper.Info($"RGV 鎵嬪姩妯″紡锛屼笉鐢ㄧ銆�); + return; + } + if (tag.RGV.taskend == 125) + { + LogHelper.Info($"RGV 鏈�25鍛戒护鏈墽琛屻�"); + System.Threading.Thread.Sleep(3000); + return; + } + LogHelper.Info($"浠诲姟涓嬪彂 Rgv 浠诲姟 杩涘叆 Rgv淇℃伅 W1鐘舵�{tag.RGV.w1status} ReadTask1No>{tag.RGV.ReadTask1No} bit1taskOver>{tag.RGV.bit1taskOver} W2鐘舵�{tag.RGV.w2status} ReadTask2No>{tag.RGV.ReadTask2No} bit2taskOver>{tag.RGV.bit2taskOver}"); + TaskEntity task1 = null; + TaskEntity task2 = null; + var task1Isrun = false; + if (tag.RGV.ReadTask1No > 0 && tag.RGV.bit1taskOver != 1) + { + 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) + { + 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); + } + if (task1Isrun || task2Isrun) + { + string mes = ""; + if (task1Isrun) + mes += tag.RGV.ReadTask1No + "鎵ц涓�.."; + if (task2Isrun) + mes += tag.RGV.ReadTask2No + "鎵ц涓�.."; + LogHelper.Info($"{mes} 涓嶈兘涓嬪彂鏂颁换鍔°�"); + System.Threading.Thread.Sleep(3000); + return; + } + + var thisOver = 0; + LogHelper.Info($"鏌ョ湅RGV 1宸ヤ綅浠诲姟銆�); + if (tag.RGV.ReadTask1No > 0 && tag.RGV.bit1taskOver == 1) + { + var taskno = tag.RGV.ReadTask1No; + LogHelper.Info($"RGV 1宸ヤ綅浠诲姟{tag.RGV.ReadTask1No}"); + 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宸ヤ綅浠诲姟{task1?.S_TASK_NO}.bit1taskOver_LAST锛歿tag.RGV.bit1taskOver_LAST}"); + if (tag.RGV.bit1taskOver_LAST == 0 && task1 != null) + { + if (task1.S_B_STATE != "瀹屾垚") + { + thisOver = 1; + 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); + LogHelper.Info($"RGV 1宸ヤ綅浠诲姟鍐欏鐞�); + taskservice.Update(task1); + LogHelper.Info($"RGV 1宸ヤ綅浠诲姟鏇存柊銆�); + } + else + { + LogHelper.Info("RGV1宸ヤ綅浠诲姟宸茬粡瀹屾垚銆�); + } + } + } + else if (tag.RGV.ReadTask1No == 0) + { + LogHelper.Info($"RGV 1宸ヤ綅娌℃湁浠诲姟銆�); + } + + LogHelper.Info($"鏌ョ湅RGV 2宸ヤ綅浠诲姟銆�); + if (tag.RGV.ReadTask2No > 0 && tag.RGV.bit2taskOver == 1) + { + var taskno = tag.RGV.ReadTask2No; + LogHelper.Info($"RGV 2宸ヤ綅浠诲姟{tag.RGV.ReadTask2No}"); + string tno = "TN" + (DateTime.Now.ToString("yy")) + ((taskno.ToString()).PadLeft(8, '0')); + task2 = taskservice.FindEntity(x => x.S_TASK_NO == tno); + + 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 != "瀹屾垚") + { + thisOver = 2; + 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宸ヤ綅浠诲姟鍐欏鐞�); + taskservice.Update(task2); + LogHelper.Info($"RGV 2宸ヤ綅浠诲姟鏇存柊銆�); + } + else + { + LogHelper.Info("RGV2宸ヤ綅浠诲姟宸茬粡瀹屾垚銆�); + } + } + } + else if (tag.RGV.ReadTask2No == 0) + { + LogHelper.Info($"RGV 2宸ヤ綅娌℃湁浠诲姟銆�); + } + + //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); + // } + //} + + ///1 鏈夎揣 灏� 鍙栥� 1 娌¤揣 灏� 鍗歌揣锛�閮芥湁璐� 灏�鍗歌揣銆�閮芥病璐�灏�鍗�+ var tklist = taskservice.FindList(x => x.S_B_STATE == "鏈墽琛� && x.S_WORK_MODE == "RGV").OrderBy(x => x.T_CREATE).ToList(); + if (task1 != null && task1.S_B_STATE != "瀹屾垚") //1鏈変换鍔�+ { + if (task2 != null && task2.S_B_STATE != "瀹屾垚")// 1 鏈変换鍔� 2 鏈変换鍔°� + { + LogHelper.Info($"鏌ョ湅RGV1 鏈変换鍔task1.S_TASK_NO},宸ヤ綅2 涔熸湁浠诲姟{task2.S_TASK_NO}銆�寮�宸ヤ綅1 鍗歌揣銆�); + tag.RGV.workMod = 1; + tag.RGV.taskmod = 2; + tag.RGV.taskno1 = Convert.ToUInt32(task1.S_TASK_NO.Substring(4)); + tag.RGV.task1do = Convert.ToUInt16(task1.S_END_LOC); + //RedisHelper.Add($"RGV.bit1taskOver_LAST", "0", out string msg); + //tag.RGV.taskend = 125; + //Conn.榛樿Redis.SetValue("RGV.taskend", "125", "RGVQueue"); + + 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 娌′换鍔°� + { + + LogHelper.Info($"鏌ョ湅RGV1 鏈変换鍔task1.S_TASK_NO},宸ヤ綅2 娌′换鍔°� 鎵惧悓渚у彇璐т换鍔°�"); + + var leftSide = new List<string> { "1023", "1020" }; + var RightSide = new List<string> { "1002", "1008", "1010", "1016" }; + bool creT2 = false; + + // 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 (t2 != null) + { + LogHelper.Info($"鏌ョ湅RGV1 鏈変换鍔task1.S_TASK_NO},宸ヤ綅2 娌′换鍔°� 鎵�020 1008 1016鍙栬揣浠诲姟{t2.S_TASK_NO}銆�); + tag.RGV.workMod = 2; + LogHelper.Info($"{t2.S_TASK_NO}> workMod 2 銆�宸ヤ綅銆�); + tag.RGV.taskmod = 1; + LogHelper.Info($"{t2.S_TASK_NO}> taskmod 1 銆婂彇璐с�"); + tag.RGV.taskno2 = Convert.ToUInt32(t2.S_TASK_NO.Substring(4)); + tag.RGV.task2do = Convert.ToUInt16(t2.S_START_LOC); + + 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)) + //{ + // leftSide.Remove(task1.S_START_LOC); + // var lsde = leftSide.FirstOrDefault(); + // t2 = tklist.Find(x => x.S_START_LOC == lsde && x.S_END_LOC != "1017"); + // if (t2 != null) //鍚屼晶鍙栬揣浠诲姟銆�+ // { + // LogHelper.Info($"鏌ョ湅RGV1 鏈変换鍔task1.S_TASK_NO},宸ヤ綅2 娌′换鍔°� 鎵惧悓渚у彇璐т换鍔t2.S_TASK_NO}銆�); + // tag.RGV.workMod = 2; + // tag.RGV.taskmod = 1; + // tag.RGV.taskno2 = Convert.ToUInt32(t2.S_TASK_NO.Substring(4)); + // tag.RGV.task2do = Convert.ToUInt16(t2.S_START_LOC); + // t2.S_B_STATE = "宸叉帹閫�; + // taskservice.Update(t2); + // creT2 = true; + // System.Threading.Thread.Sleep(750); + // LogHelper.Info($"{t2.S_TASK_NO}> bit2taskOver_LAST 鍐�0"); + // RedisHelper.Add($"RGV.bit2taskOver_LAST", "0", out string msg); + // LogHelper.Info($"{t2.S_TASK_NO}> end 鍐�125"); + // Conn.榛樿Redis.SetValue("RGV.taskend", "125", "RGVQueue", false); + // } + //} + //else if (RightSide.Contains(task1.S_START_LOC)) + //{ + // RightSide.Remove(task1.S_START_LOC); + // t2 = tklist.Find(x => RightSide.Contains(x.S_START_LOC) && x.S_END_LOC != "1017"); + // if (t2 != null) //鍚屼晶鍙栬揣浠诲姟銆�+ // { + // LogHelper.Info($"鏌ョ湅RGV1 鏈変换鍔task1.S_TASK_NO},宸ヤ綅2 娌′换鍔°� 鎵惧悓渚�1002,1010 鍙栬揣浠诲姟{t2.S_TASK_NO}銆�); + // tag.RGV.workMod = 2; + // tag.RGV.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 鍐�125"); + // RedisHelper.Add($"RGV.bit2taskOver_LAST", "0", out string msg); + // LogHelper.Info($"{t2.S_TASK_NO}> end 鍐�125"); + // Conn.榛樿Redis.SetValue("RGV.taskend", "125", "RGVQueue", false); + // } + //} + else //1 鐩存帴鍗歌揣銆� + //if (!creT2) + { + LogHelper.Info($"鏌ョ湅RGV1 鏈変换鍔task1.S_TASK_NO},宸ヤ綅2 娌′换鍔°� 娌℃湁鍚屼晶鍙栬揣浠诲姟 1宸ヤ綅鍗歌揣銆�); + tag.RGV.workMod = 1; + LogHelper.Info($"{task1.S_TASK_NO}> workMod 1 銆�宸ヤ綅銆�); + tag.RGV.taskmod = 2; + LogHelper.Info($"{task1.S_TASK_NO}> taskmod 2 銆婂嵏璐с�"); + tag.RGV.taskno1 = Convert.ToUInt32(task1.S_TASK_NO.Substring(4)); + tag.RGV.task1do = Convert.ToUInt16(task1.S_END_LOC); + + if (tag.RGV.bit1taskOver == 1) + tag.RGV.bit1taskOver = 0; + LogHelper.Info($"{task1.S_TASK_NO}> taskend 鍐�0"); + 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 + { + if (task2 != null && task2.S_B_STATE != "瀹屾垚")// 1 娌′换鍔� 2 鏈変换鍔°� + { + LogHelper.Info($"鏌ョ湅RGV 1宸ヤ綅娌′换鍔�宸ヤ綅2 鏈変换鍔task2.S_TASK_NO}銆傚伐浣�鍗歌揣銆傘�"); + //2 鍗歌揣銆�+ tag.RGV.workMod = 2; + LogHelper.Info($"{task2.S_TASK_NO}> workMod 2 銆�宸ヤ綅銆�); + tag.RGV.taskmod = 2; + LogHelper.Info($"{task2.S_TASK_NO}> taskmod 2 銆婂嵏璐с�"); + tag.RGV.taskno2 = Convert.ToUInt32(task2.S_TASK_NO.Substring(4)); + tag.RGV.task2do = Convert.ToUInt16(task2.S_END_LOC); + + if (tag.RGV.bit2taskOver == 1) + tag.RGV.bit2taskOver = 0; + //tag.RGV.taskend = 125; + LogHelper.Info($"{task2.S_TASK_NO}> taskend 鍐�25"); + 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 娌′换鍔°� + { + LogHelper.Info($"鏌ョ湅RGV 1宸ヤ綅娌′换鍔�宸ヤ綅2 涔熸病浠诲姟銆備紭鍏�宸ヤ綅缁堢偣1017浠诲姟銆傘�"); + //銆佷笅 1017浠诲姟 缁�鍙峰伐浣嶃� + //var lss = tklist.Take(2).ToList(); + var e1017first = tklist.Find(x => x.S_START_LOC == "1002" || x.S_START_LOC == "1010" || x.S_START_LOC == "1023"); + //if (e1017first != null) + //{ + // e1017first = tklist.FirstOrDefault(); + //} + if (e1017first != null) + { + LogHelper.Info($"鏌ョ湅RGV娌′换鍔★紝 缁欏伐浣�绛涢�浠诲姟銆�1002 1010 1023鍙栬揣浠诲姟{e1017first.S_TASK_NO}銆�); + tag.RGV.workMod = 1; + LogHelper.Info($"{e1017first.S_TASK_NO}> workMod 1 銆�宸ヤ綅銆�); + tag.RGV.taskmod = 1; + LogHelper.Info($"{e1017first.S_TASK_NO}> taskmod 1 銆婂彇璐с�"); + uint tno = Convert.ToUInt32(e1017first.S_TASK_NO.Substring(4)); + LogHelper.Info($"{e1017first.S_TASK_NO}> 杞崲鍚庝换鍔″彿{tno} 寮�鍐欏叆銆�); + tag.RGV.taskno1 = tno; + LogHelper.Info($"{e1017first.S_TASK_NO}>寮�鍐欏叆 task1do>>{e1017first.S_START_LOC}銆�); + tag.RGV.task1do = Convert.ToUInt16(e1017first.S_START_LOC); + //tag.RGV.taskend=125 + if (tag.RGV.bit1taskOver == 1) + tag.RGV.bit1taskOver = 0; + LogHelper.Info($"{e1017first.S_TASK_NO}> taskend 鍐�25"); + Conn.榛樿Redis.SetValue("RGV.taskend", "125", "RGVQueue", false); + LogHelper.Info($"{e1017first.S_TASK_NO}> bit1taskOver_LAST 鍐�"); + RedisHelper.Add($"RGV.bit1taskOver_LAST", "0", out string msg); + LogHelper.Info($"{e1017first.S_TASK_NO}> 鏇存柊浠诲姟銆�); + e1017first.S_B_STATE = "宸叉帹閫�; + taskservice.Update(e1017first); + } + else + { + var t2 = tklist.OrderBy(x => x.T_CREATE).ToList().Find(x => x.S_START_LOC == "1020" || x.S_START_LOC == "1008" || x.S_START_LOC == "1016"); + if (tklist != null) + { + LogHelper.Info($"鏌ョ湅RGV娌′换鍔�缁欏伐浣�绛涢�浠诲姟銆�鎵�020 1008 1016鍙栬揣浠诲姟{t2.S_TASK_NO}銆�); + tag.RGV.workMod = 2; + LogHelper.Info($"{t2.S_TASK_NO}> workMod 2 銆�宸ヤ綅銆�); + tag.RGV.taskmod = 1; + LogHelper.Info($"{t2.S_TASK_NO}> taskmod 1 銆婂彇璐с�"); + tag.RGV.taskno2 = Convert.ToUInt32(t2.S_TASK_NO.Substring(4)); + LogHelper.Info($"{t2.S_TASK_NO}> taskno2 {Convert.ToUInt32(t2.S_TASK_NO.Substring(4))}銆婁换鍔″彿銆�); + tag.RGV.task2do = Convert.ToUInt16(t2.S_START_LOC); + 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); + } + } + } + } + LogHelper.Info($"rgv 澶勭悊瀹屾垚銆倀askend 125"); + #endregion + } + catch (Exception ex) + { + LogHelper.Info(ex.Message + ex.StackTrace); + } } + public void ThreadGrats(Tag tag, Action<HaiKangOrderInfo> continueTask) + { + 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).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) + { + item.N_CREATEMETHOD = -1; + taskActRepository.Update(item); + continue; + } + 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) + { + loc = item.S_START_LOC; + } + else + { + loc = item.S_END_LOC; + } + if (loc == null) continue; else loc = loc.Trim(); + bool goin = tin % 2 == 0; + bool continuuuuu = false; + 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", false); + } + else if (dev.deviceType == 2) + { + LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} 璁惧鏄瘂dev.deviceName} 寮�惎鍏夋爡澶勭悊 =================> "); + LogHelper.Info($"{dev.deviceName}{(V ? "宸� : "鍙�)} 鍏夋爡{(goin ? "鍏抽棴" : "寮�惎")} 鐢宠銆� + string.Format("{0}{1}{2}", dev.deviceName + "." + (V ? "D1222" : "D1223"), "1", dev.deviceName + "Queue")); + + Conn.榛樿Redis.SetValue(dev.deviceName + "." + (V ? "D1220" : "D1221"), "0", dev.deviceName + "Queue"); + Conn.榛樿Redis.SetValue(dev.deviceName + "." + (V ? "D1222" : "D1223"), "1", dev.deviceName + "Queue"); + } + LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} 璁惧鏄瘂dev.deviceName} 寮�惎鍏夋爡澶勭悊瀹屾垚 =================> "); + + item.N_CREATEMETHOD = 1; + taskActRepository.Update(item); + } + //杞﹁杩涘叆浜や簰銆�+ else + { + 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 ? "鍏抽棴" : "寮�惎")} 鐢宠銆�宸茬粡鍏抽棴锛�); + 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); + } + 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); + 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}"); + } + 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} 杞﹁締鍙戦�缁х画浠诲姟锛�); + continueTask?.Invoke(new HaiKangOrderInfo + { + reqCode = item.S_ID.Replace("-", ""), + taskCode = item.S_TASK_NO + }); + item.N_CREATEMETHOD = 1; + taskActRepository.Update(item); + } + } + System.Threading.Thread.Sleep(3000); + LogHelper.Info($"ThreadGrats deviceType2鍏夋爡鍐欏叆浣嶉噸缃�=================> "); + //閲嶇疆淇″彿 + foreach (var dev in Settings.deviceInfos.FindAll(x => x.deviceType == 2)) + { + var tf = Conn.榛樿Redis.GetValue(dev.deviceName + ".D1202"); + int numm = int.Parse(string.IsNullOrEmpty(tf) ? "0" : tf); + //int int0 = TcpServer.GetBitdata(numm, 0); + //int int1 = TcpServer.GetBitdata(numm, 1); + + if (TcpServer.GetBitdata(numm, 0) == 0) + { + Conn.榛樿Redis.SetValue(dev.deviceName + ".D1220", "0", dev.deviceName + "Queue", false); + Conn.榛樿Redis.SetValue(dev.deviceName + ".D1222", "0", dev.deviceName + "Queue", false); + } + if (TcpServer.GetBitdata(numm, 1) == 0) + { + Conn.榛樿Redis.SetValue(dev.deviceName + ".D1221", "0", dev.deviceName + "Queue", false); + Conn.榛樿Redis.SetValue(dev.deviceName + ".D1223", "0", dev.deviceName + "Queue", false); + } + if (TcpServer.GetBitdata(numm, 2) == 0) + { + Conn.榛樿Redis.SetValue(dev.deviceName + ".D1224", "0", dev.deviceName + "Queue", false); + } + if (TcpServer.GetBitdata(numm, 3) == 0) + { + Conn.榛樿Redis.SetValue(dev.deviceName + ".D1225", "0", dev.deviceName + "Queue", false); + } + } + LogHelper.Info($"ThreadGrats deviceType2鍏夋爡鍐欏叆浣嶉噸缃畬鎴愩� =================> "); + } + /// <summary> + /// 1020 1023绌烘涓嬬嚎 + /// </summary> + /// <param name="tag"></param> + public void ThreadEdown(Tag tag) + { + Console.WriteLine($"ThreadEdown 20 23 = 绌轰笅妫�祴 =================> "); + TaskRepository taskRepository = new TaskRepository(); + foreach (var Bssx in new string[] { "1020", "1023" }) + { + var RtaskState = (System.UInt16)System.Convert.ChangeType(Conn.榛樿Redis.GetValue($"S{Bssx}Read.RtaskState"), typeof(System.UInt16)); + var RtaskState_LAST = (System.UInt16)System.Convert.ChangeType(Conn.榛樿Redis.GetValue($"S{Bssx}Read.RtaskState_LAST"), typeof(System.UInt16)); + var R鎵樼洏鐮�= (System.String)System.Convert.ChangeType(Conn.榛樿Redis.GetValue($"S{Bssx}Read.R鎵樼洏鐮�), typeof(System.String)); + Console.WriteLine($"{Bssx} 绌轰笅妫�祴锛氫换鍔$敵璇凤細{RtaskState}- 鏄惁宸插鐞嗭細{RtaskState_LAST}- 鎵樼洏鐮侊細{R鎵樼洏鐮亇 "); + if (RtaskState == 3 && RtaskState_LAST == 0) + { + var task = taskRepository.FindEntity(x => x.S_START_LOC == Bssx && x.S_B_STATE != "瀹屾垚" && x.S_B_STATE != "鍙栨秷"); + string msg = ""; + if (task != null) + { + Console.WriteLine($"{Bssx} 鏈夋鍦�[{task.S_B_STATE}] 涓殑{task.S_TASK_NO}浠诲姟"); + LogHelper.Info($"{Bssx} 鏈夋鍦�[{task.S_B_STATE}] 涓殑{task.S_TASK_NO}浠诲姟"); + continue; + } + try + { + var listtep = new List<string>(); + if (Bssx == "1020") + { + if (tag.SF涓嬫枡浣�RArrive1003 == 1) + { + listtep = new List<string> { "1012", "1004" }; + } + else + { + listtep = new List<string> { "1004", "1012" }; + } + } + else + { + if (tag.SF涓嬫枡浣�RArrive1005 == 1) + { + listtep = new List<string> { "1014", "1006" }; + } + else + { + listtep = new List<string> { "1006", "1014" }; + } + } + + foreach (var item in listtep)//(Bssx == "1020" ? new string[] { "1004", "1012" } : new string[] { "1006", "1014" })) + { + var R5 = (System.UInt16)System.Convert.ChangeType(Conn.榛樿Redis.GetValue($"S{item}Read.R5绌洪棽"), typeof(System.UInt16)); + 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 == null) + { + task = taskRepository.FindEntity(x => x.S_END_LOC == item && x.S_B_STATE != "瀹屾垚" && x.S_B_STATE != "鍙栨秷"); + msg = ""; + if (task != null) + { + Console.WriteLine($" {item}鏈夋鍦�[{task.S_B_STATE}] 涓殑{task.S_TASK_NO}浠诲姟"); + LogHelper.Info($" {item}鏈夋鍦�[{task.S_B_STATE}] 涓殑{task.S_TASK_NO}浠诲姟"); + continue; + } + + var b = TaskProcess.CreateTask("", Bssx, item, "绌轰笂RGV", 5, new List<string> { R鎵樼洏鐮�}, "RGV"); + if (b) + { + LogHelper.Debug($"杈撻�绾縍GV绌烘墭浠诲姟 from:{Bssx}>to {item}寮�鍒涘缓鎴愬姛"); + RedisHelper.Add($"S{Bssx}Read.RtaskState_LAST", "1", out msg); + //Conn.榛樿Redis.SetValue($"S{Bssx}Read.RtaskState_LAST", "1", $"S{Bssx}ReadQueue"); + RedisHelper.Add($"S{item}Read.R5绌洪棽_LAST", "1", out msg); + //Conn.榛樿Redis.SetValue($"S{item}Read.R5绌洪棽_LAST", "1", $"S{item}ReadQueue"); + break; + } + } + else if (R5 != 5 && R5绌洪棽_LAST == 1) + { + RedisHelper.Add($"S{item}Read.R5绌洪棽_LAST", "0", out msg); + //Conn.榛樿Redis.SetValue($"S{item}Read.R5绌洪棽_LAST", "0", $"S{item}ReadQueue"); + } + } + System.Threading.Thread.Sleep(1000); + } + catch (Exception ex) + { + LogHelper.Error(ex.Message, ex); + Console.WriteLine(ex.Message + ex.StackTrace); + } + } + else if (RtaskState != 3 && RtaskState_LAST == 1) + { + RedisHelper.Add($"S{Bssx}Read.RtaskState_LAST", "0", out string msg); + //Conn.榛樿Redis.SetValue($"S{Bssx}Read.RtaskState_LAST", "0", $"S{Bssx}ReadQueue"); + } + System.Threading.Thread.Sleep(2000); + } + + foreach (var item in new string[] { "1004", "1012", "1006", "1014", "1026", "1017" }) + { + var R5 = (System.UInt16)System.Convert.ChangeType(Conn.榛樿Redis.GetValue($"S{item}Read.R5绌洪棽"), typeof(System.UInt16)); + var R5绌洪棽_LAST = (System.UInt16)System.Convert.ChangeType(Conn.榛樿Redis.GetValue($"S{item}Read.R5绌洪棽_LAST"), typeof(System.UInt16)); + if (R5 != 5 && R5绌洪棽_LAST == 1) + { + RedisHelper.Add($"S{item}Read.R5绌洪棽_LAST", "0", out string msg); + //Conn.榛樿Redis.SetValue($"S{item}Read.R5绌洪棽_LAST", "0", $"S{item}ReadQueue"); + } + } + } + + public void ThreadDdown(Tag tag) + { + Console.WriteLine($"ThreadDdown 08 10 ==================> 1026"); + TaskRepository taskRepository = new TaskRepository(); + foreach (var Bssx in new string[] { "1008", "1016" }) + { + var RtaskState = (System.UInt16)System.Convert.ChangeType(Conn.榛樿Redis.GetValue($"S{Bssx}Read.RtaskState"), typeof(System.UInt16)); + var RtaskState_LAST = (System.UInt16)System.Convert.ChangeType(Conn.榛樿Redis.GetValue($"S{Bssx}Read.RtaskState_LAST"), typeof(System.UInt16)); + var R鎵樼洏鐮�= (System.String)System.Convert.ChangeType(Conn.榛樿Redis.GetValue($"S{Bssx}Read.R鎵樼洏鐮�), typeof(System.String)); + Console.WriteLine($"{Bssx} 婊′笅妫�祴锛氫换鍔$敵璇凤細{RtaskState}- 鏄惁宸插鐞嗭細{RtaskState_LAST}- 鎵樼洏鐮侊細{R鎵樼洏鐮亇"); + if (RtaskState == 3 && RtaskState_LAST == 0) + { + var task = taskRepository.FindEntity(x => x.S_START_LOC == Bssx && x.S_B_STATE != "瀹屾垚" && x.S_B_STATE != "鍙栨秷"); + string msg = ""; + if (task != null) + { + Console.WriteLine($"{Bssx} 鏈夋鍦�[{task.S_B_STATE}] 涓殑{task.S_TASK_NO}浠诲姟"); + LogHelper.Info($"{Bssx} 鏈夋鍦�[{task.S_B_STATE}] 涓殑{task.S_TASK_NO}浠诲姟"); + continue; + } + + var item = "1026"; + var R5 = (System.UInt16)System.Convert.ChangeType(Conn.榛樿Redis.GetValue($"S{item}Read.R5绌洪棽"), typeof(System.UInt16)); + 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 == item && x.S_B_STATE != "瀹屾垚" && x.S_B_STATE != "鍙栨秷"); + msg = ""; + if (task != null) + { + Console.WriteLine($"{item} 鏈夋鍦�[{task.S_B_STATE}] 涓殑{task.S_TASK_NO}浠诲姟"); + LogHelper.Info($"{item} 鏈夋鍦�[{task.S_B_STATE}] 涓殑{task.S_TASK_NO}浠诲姟"); + continue; + } + var b = TaskProcess.CreateTask("", Bssx, item, "婊¤浆1026", 5, new List<string> { R鎵樼洏鐮�}, "RGV"); + if (b) + { + RedisHelper.Add($"S{Bssx}Read.RtaskState_LAST", "1", out msg); + RedisHelper.Add($"S{item}Read.R5绌洪棽_LAST", "1", out string msg2); + //Conn.榛樿Redis.SetValue($"S{Bssx}Read.RtaskState_LAST", "1", $"S{Bssx}ReadQueue"); + //Conn.榛樿Redis.SetValue($"S{item}Read.R5绌洪棽_LAST", "1", $"S{item}ReadQueue"); + break; + } + } + else if (R5 != 5 && R5绌洪棽_LAST == 1) + { + RedisHelper.Add($"S{item}Read.R5绌洪棽_LAST", "0", out string msg2); + } + } + else if (RtaskState != 3 && RtaskState_LAST == 1) + { + RedisHelper.Add($"S{Bssx}Read.RtaskState_LAST", "0", out string msg); + //Conn.榛樿Redis.SetValue($"S{Bssx}Read.RtaskState_LAST", "0", $"S{Bssx}ReadQueue"); + } + System.Threading.Thread.Sleep(2000); + } + } + + public void Thread0210Down(Tag tag) + { + Console.WriteLine($"Thread0210Down ==================>"); + TaskRepository taskRepository = new TaskRepository(); + foreach (var Bssx in new string[] { "1002", "1010" }) + { + var RtaskState = (System.UInt16)System.Convert.ChangeType(Conn.榛樿Redis.GetValue($"S{Bssx}Read.RtaskState"), typeof(System.UInt16)); + var RtaskState_LAST = (System.UInt16)System.Convert.ChangeType(Conn.榛樿Redis.GetValue($"S{Bssx}Read.RtaskState_LAST"), typeof(System.UInt16)); + var R鎵樼洏鐮�= (System.String)System.Convert.ChangeType(Conn.榛樿Redis.GetValue($"S{Bssx}Read.R鎵樼洏鐮�), typeof(System.String)); + Console.WriteLine($"{Bssx} 婊′笅妫�祴锛氫换鍔$敵璇凤細{RtaskState}- 鏄惁宸插鐞嗭細{RtaskState_LAST}- 鎵樼洏鐮侊細{R鎵樼洏鐮亇"); + if (RtaskState == 3 && RtaskState_LAST == 0) + { + var task = taskRepository.FindEntity(x => x.S_START_LOC == Bssx && x.S_B_STATE != "瀹屾垚" && x.S_B_STATE != "鍙栨秷"); + string msg = ""; + if (task != null) + { + Console.WriteLine($"{Bssx} 鏈夋鍦�[{task.S_B_STATE}] 涓殑{task.S_TASK_NO}浠诲姟"); + LogHelper.Info($"{Bssx} 鏈夋鍦�[{task.S_B_STATE}] 涓殑{task.S_TASK_NO}浠诲姟"); + continue; + } + var item = "1017"; + var R5 = (System.UInt16)System.Convert.ChangeType(Conn.榛樿Redis.GetValue($"S{item}Read.R5绌洪棽"), typeof(System.UInt16)); + 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 == item && x.S_B_STATE != "瀹屾垚" && x.S_B_STATE != "鍙栨秷"); + msg = ""; + if (task != null) + { + Console.WriteLine($"{item} 鏈夋鍦�[{task.S_B_STATE}] 涓殑{task.S_TASK_NO}浠诲姟"); + LogHelper.Info($"{item} 鏈夋鍦�[{task.S_B_STATE}] 涓殑{task.S_TASK_NO}浠诲姟"); + continue; + } + var b = TaskProcess.CreateTask("", Bssx, item, "婊¤浆1017", 5, new List<string> { R鎵樼洏鐮�}, "RGV"); + if (b) + { + RedisHelper.Add($"S{Bssx}Read.RtaskState_LAST", "1", out msg); + RedisHelper.Add($"S{item}Read.R5绌洪棽_LAST", "1", out string msg1); + //Conn.榛樿Redis.SetValue($"S{Bssx}Read.RtaskState_LAST", "1", $"S{Bssx}ReadQueue"); + //Conn.榛樿Redis.SetValue($"S{item}Read.R5绌洪棽_LAST", "1", $"S{item}ReadQueue"); + break; + } + } + else if (R5 != 5 && R5绌洪棽_LAST == 1) + { + RedisHelper.Add($"S{item}Read.R5绌洪棽_LAST", "0", out string msg1); + } + } + else if (RtaskState != 3 && RtaskState_LAST == 1) + { + RedisHelper.Add($"S{Bssx}Read.RtaskState_LAST", "0", out string msg); + } + System.Threading.Thread.Sleep(2000); + } + } + + + public void Thread涓嬫枡浣嶆娴�Tag tag) + { + Console.WriteLine($"Thread涓嬫枡浣嶆娴� =====>"); + 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)); + 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) + { + switch (ssx) + { + case "1003": + { + LogHelper.Info($"ssx == 1003 && tag.SF涓嬫枡浣�WRelease1003:{tag.SF涓嬫枡浣�WRelease1003} 鍐檉1 2210=1锛孉rrive{ssx}BarcodeLast={RtrayCode}"); + tag.FNK1.D2210 = 1; + } + break; + case "1005": + { + LogHelper.Info($"ssx == 1005 && tag.SF涓嬫枡浣�WRelease1005:{tag.SF涓嬫枡浣�WRelease1005} 鍐檉1 2215=1锛孉rrive{ssx}BarcodeLast={RtrayCode}"); + tag.FNK1.D2215 = 1; + } + break; + case "1011": + { + LogHelper.Info($"ssx == 1011 && tag.SF涓嬫枡浣�WRelease1011:{tag.SF涓嬫枡浣�WRelease1011} 鍐檉2 2210=1锛孉rrive{ssx}BarcodeLast={RtrayCode}"); + tag.FNK2.D2210 = 1; + } + break; + case "1013": + { + LogHelper.Info($"ssx == 1013 && tag.SF涓嬫枡浣�WRelease1013:{tag.SF涓嬫枡浣�WRelease1013} 鍐檉2 2215=1锛孉rrive{ssx}BarcodeLast={RtrayCode}"); + tag.FNK2.D2215 = 1; + } + break; + } + RedisHelper.Add($"Arrive{ssx}BarcodeLast", RtrayCode, out msg); + } + else if (RArrive == 0) + { + //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 璇籉NK1.D2213{tag.FNK1.D2213}=1? 骞跺啓0"); + tag.FNK1.D2213 = 0; + } + break; + case "1005": + { + LogHelper.Info($"璇粄ssx} WRelease=1&& rReleaseOver=1 璇籉NK1.D2218{tag.FNK1.D2218}=1? 骞跺啓0"); + tag.FNK1.D2218 = 0; + } + break; + case "1011": + { + LogHelper.Info($"璇粄ssx} WRelease=1&& rReleaseOver=1 璇籉NK2.D2213{tag.FNK1.D2213}=1? 骞跺啓0"); + tag.FNK2.D2213 = 0; + } + break; + case "1013": + { + LogHelper.Info($"璇粄ssx} WRelease=1&& rReleaseOver=1 璇籉NK2.D2218{tag.FNK2.D2218}=1? 骞跺啓0"); + tag.FNK2.D2218 = 0; + } + break; + } + LogHelper.Info($"璇粄ssx} WRelease=1&& rReleaseOver=1 WRelease 鍐�"); + 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锛孌2217_LAST=1锛學Release1005=1 RArrive1005_LAST=0"); + if (tag.FNK1.D2217 == 1 && tag.FNK1.D2217_LAST == 0) + { + //tag.FNK1.D2215 = 0; + tag.FNK1.D2218 = 1; + //tag.FNK1.D2212_LAST = 1; + RedisHelper.Add($"p鍙戦偅绉�涓嬬嚎.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($"Arrive1005BarcodeLast", "0", out msg); + LogHelper.Info($" FN1 .D2217=1,2217_LAST=0 鍐�2218=1锛孌2217_LAST=1锛學Release1005=1 Arrive1005BarcodeLast=0"); + } + else if (tag.FNK1.D2217 == 0 && tag.FNK1.D2217_LAST == 1) + { + //tag.FNK1.D2217_LAST = 0; + RedisHelper.Add($"p鍙戦偅绉�涓嬬嚎.D2217_LAST", "0", out string msg); + LogHelper.Info($" p鍙戦偅绉�涓嬬嚎.D2217_LAST=0"); + } + if (tag.FNK1.D2216 == 1) + { + tag.FNK1.D2215 = 0; + tag.SF涓嬫枡浣�wArrive1005Over = 1; + LogHelper.Info($" p鍙戦偅绉�涓嬬嚎 璇籇2216=1 鍐橠2215 =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.D2213 = 1; + //tag.FNK1.D2210 = 0; + //tag.FNK1.D2217_LAST = 1; + RedisHelper.Add($"p鍙戦偅绉�涓嬬嚎.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($"Arrive1003BarcodeLast", "0", out msg); + LogHelper.Info($" FN1 .D2212=1,2212_LAST=0 鍐�D2213=1锛孌2212_LAST=1锛學Release1003=1 Arrive1003BarcodeLast=0"); + } + //else if (tag.FNK1.D2211 == 1) + // tag.FNK1.D2210 = 0; + else if (tag.FNK1.D2212 == 0 && tag.FNK1.D2212_LAST == 1) + { + //tag.FNK1.D2212_LAST = 0; + RedisHelper.Add($"p鍙戦偅绉�涓嬬嚎.D2212_LAST", "0", out string msg); + LogHelper.Info($" p鍙戦偅绉�涓嬬嚎.D2212_LAST=0"); + } + + if (tag.FNK1.D2211 == 1) + { + tag.FNK1.D2210 = 0; + tag.SF涓嬫枡浣�wArrive1003Over = 1; + LogHelper.Info($" p鍙戦偅绉�涓嬬嚎 璇籇2211=1 鍐橠2210 =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.D2218 = 1; + //tag.FNK2.D2212_LAST = 1; + RedisHelper.Add($"p鍙戦偅绉�涓嬬嚎.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($"Arrive1013BarcodeLast", "0", out msg); + LogHelper.Info($" FN2 .D2217=1,2217_LAST=0 鍐�2218=1锛孌2217_LAST=1锛學Release1013=1 Arrive1013BarcodeLast=0"); + } + else if (tag.FNK2.D2217 == 0 && tag.FNK2.D2217_LAST == 1) + { + //tag.FNK2.D2217_LAST = 0; + RedisHelper.Add($"p鍙戦偅绉�涓嬬嚎.D2217_LAST", "0", out string msg); + + LogHelper.Info($" p鍙戦偅绉�涓嬬嚎.D2217_LAST=0"); + } + if (tag.FNK2.D2216 == 1) + { + tag.FNK2.D2215 = 0; + tag.SF涓嬫枡浣�wArrive1013Over = 1; + LogHelper.Info($" p鍙戦偅绉�涓嬬嚎 璇籇2216=1 鍐橠2215 =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.D2213 = 1; + //tag.FNK2.D2217_LAST = 1; + RedisHelper.Add($"p鍙戦偅绉�涓嬬嚎.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($"Arrive1011BarcodeLast", "0", out msg); + LogHelper.Info($" FN2 .D2212=1,2212_LAST=0 鍐�2213=1锛孌2212_LAST=1锛學Release1011=1 Arrive1011BarcodeLast=0"); + } + else if (tag.FNK2.D2212 == 0 && tag.FNK2.D2212_LAST == 1) + { + //tag.FNK2.D2212_LAST = 0; + RedisHelper.Add($"p鍙戦偅绉�涓嬬嚎.D2212_LAST", "0", out string msg); + LogHelper.Info($" p鍙戦偅绉�涓嬬嚎.D2212_LAST=0"); + } + if (tag.FNK2.D2211 == 1) + { + tag.FNK2.D2210 = 0; + tag.SF涓嬫枡浣�wArrive1011Over = 1; + LogHelper.Info($" p鍙戦偅绉�涓嬬嚎 璇籇2211=1 鍐橠2210 =0 鍐欐満姊版墜鏀跺埌绌哄埌1011 wArrive1011Over=1"); + } + } + + + public void Thread1019Down(Tag tag) + { + Console.WriteLine($"1019浠诲姟鐘舵�锛� =====>"); + Console.WriteLine($"1019浠诲姟鐘舵�锛歿tag.SA1019.RtaskState}- barcode:{tag.SA1019.R鎵樼洏鐮亇- 绌洪棽{tag.SA1019.R5绌洪棽}"); + } + public void Thread1025Up(Tag tag) + { + Console.WriteLine($"SA1025 浠诲姟鐘舵�锛� =====>"); + Console.WriteLine($"SA1025 浠诲姟鐘舵�锛歿tag.SA1025.RtaskState}- 绌洪棽{tag.SA1025.R5绌洪棽}"); + } + public void Thread1022Up(Tag tag) + { + Console.WriteLine($"SA1022 =====>"); + Console.WriteLine($"SA1022 浠诲姟鐘舵�锛歿tag.SA1022.RtaskState}- 绌洪棽{tag.SA1022.R5绌洪棽}"); + } + public void Thread1030Down(Tag tag) + { + Console.WriteLine($"SA1030 浠诲姟鐘舵�锛� =====>"); + Console.WriteLine($"SA1030 浠诲姟鐘舵�锛歿tag.SA1030.RtaskState}- 绌洪棽{tag.SA1030.R5绌洪棽}-->瀵瑰簲缁堢偣2001>绌洪棽5锛歿tag.SA2001.R5绌洪棽}"); + } + public void Thread2030Down(Tag tag) + { + + Console.WriteLine($"SA2030 浠诲姟鐘舵�锛� =====>"); + Console.WriteLine($"SA2030 浠诲姟鐘舵�锛歿tag.SA2030.RtaskState}- 绌洪棽{tag.SA2030.R5绌洪棽} - barcode:{tag.SA2030.R鎵樼洏鐮亇"); + + + + } + + public void ResolveMesTask() + { + 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($"瑙i噴MES浠诲姟 ->{task.S_TASK_NO} "); + var sx = VERXs?.Find(x => x.location.Contains(task.S_END_LOC)); + LogHelper.Info($"瑙i噴MES浠诲姟 ->{task.S_TASK_NO} {(sx == null ? "闈� : "鏄�)}鎬昏鏈哄櫒浜轰换鍔�); + if (sx == null) + { + LogHelper.Info($"瑙i噴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($"瑙i噴MES浠诲姟 ->{task.S_TASK_NO} 鐩存帴鐢熸垚瀵瑰簲浠诲姟 缁撴灉锛歿res}"); + if (res) + { + LogHelper.Info($"瑙i噴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($"瑙i噴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($"瑙i噴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($"瑙i噴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($"瑙i噴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? 鍒欑敵璇穖es鎼蛋銆�); + 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}"); + } + } + } + + //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); + //璋冪敤绗笁鏂规帴鍙o紙濡傛灉鏈夛級TaskProcess.ReportStatus + } + else + { + // 鏆傛椂璁惧畾涓� + 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; + } + } + } + + + + + + + + + + + + + } + + public class HttpServer + { + System.Net.HttpListener HttpSvcHost = null; + + private readonly string _listenerPrefix = ""; + public HttpServer(string ip) + { + _listenerPrefix = ip; + } + public void HttpServerRun() + { + HttpSvcHost = new System.Net.HttpListener(); + HttpSvcHost.AuthenticationSchemes = System.Net.AuthenticationSchemes.Anonymous; + HttpSvcHost.Prefixes.Add($"http://{_listenerPrefix}:8808/"); + 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; + // 澶嶅埗鍒癱ase 涓�+ //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("宸叉柇寮�ebSocket杩炴帴"); + } + } + + + class Messss + { + public bool success { get; set; } + public Ddata data { get; set; } + public object extra { get; set; } + } + + public class Ddata + { + public string reqCode { get; set; } + public int state { get; set; } + public string error { get; set; } } } + +#endregion [鑷畾涔夌被-VS][20250623083459471][AutoThread] \ No newline at end of file -- Gitblit v1.9.1