| | |
| | | { |
| | | try |
| | | { |
| | | foreach (var ip in new List<string> { |
| | | device1.påé£ç§1ä¸çº¿.Config.IP, |
| | | device1.påé£ç§2ä¸çº¿.Config.IP, |
| | | device1.Då®å1å·æºæ¢°æ.Config.IP, |
| | | device1.Då®å2å·æºæ¢°æ.Config.IP, |
| | | device1.Jsæ·é¡º1.Config.IP, |
| | | device1.Jsæ·é¡º2.Config.IP, |
| | | device1.ç»´å¸å°æè1.Config.IP, |
| | | device1.ç»´å¸å°æè2.Config.IP, |
| | | device1.RGV.Config.IP, |
| | | device1.S1002Read.Config.IP, |
| | | device1.S2001Read.Config.IP, |
| | | device1.S3001Read.Config.IP |
| | | }) |
| | | { |
| | | string pattern = @"\b(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\b"; |
| | | // foreach (var ip in new List<string> { |
| | | // device1.påé£ç§1ä¸çº¿.Config.IP, |
| | | // device1.påé£ç§2ä¸çº¿.Config.IP, |
| | | // device1.Då®å1å·æºæ¢°æ.Config.IP, |
| | | // device1.Då®å2å·æºæ¢°æ.Config.IP, |
| | | // device1.Jsæ·é¡º1.Config.IP, |
| | | // device1.Jsæ·é¡º2.Config.IP, |
| | | // device1.ç»´å¸å°æè1.Config.IP, |
| | | // device1.ç»´å¸å°æè2.Config.IP, |
| | | // device1.RGV.Config.IP, |
| | | // device1.S1002Read.Config.IP, |
| | | // device1.S2001Read.Config.IP, |
| | | // device1.S3001Read.Config.IP |
| | | //}) |
| | | // { |
| | | // string pattern = @"\b(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.(25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\b"; |
| | | |
| | | var matches = Regex.Match(ip, pattern); |
| | | if (matches.Success) |
| | | { |
| | | var b = IsMachineOnline(matches.Value); |
| | | if (!Iponlines.ContainsKey(ip)) |
| | | { |
| | | Iponlines.TryAdd(ip, b); |
| | | } |
| | | else |
| | | Iponlines[ip] = b; |
| | | } |
| | | } |
| | | // var matches = Regex.Match(ip, pattern); |
| | | // if (matches.Success) |
| | | // { |
| | | // var b = IsMachineOnline(matches.Value); |
| | | // if (!Iponlines.ContainsKey(ip)) |
| | | // { |
| | | // Iponlines.TryAdd(ip, b); |
| | | // } |
| | | // else |
| | | // Iponlines[ip] = b; |
| | | // } |
| | | // } |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | |
| | | }, tag, device, 3000)); |
| | | tasks.Add(GetTask(ThreadMXC3, tag, 3000)); |
| | | tasks.Add(GetTask(ThreadMXC4, tag, 3000)); |
| | | tasks.Add(GetTask(ResetGats, tag, 3000)); |
| | | //tasks.Add(GetTask(ResetGats, tag, 3000)); |
| | | |
| | | tasks.Add(GetTask(sa1022, tag, 3000)); |
| | | tasks.Add(GetTask(sa1025, tag, 3000)); |
| | |
| | | tasks.Add(GetTask(sa2001, tag, 3000)); |
| | | tasks.Add(GetTask(sa2030, tag, 3000)); |
| | | tasks.Add(GetTask(sa2008, tag, 3000)); |
| | | tasks.Add(GetTask(sa3001, tag, 3000)); |
| | | tasks.Add(GetTask(sa3005, tag, 3000)); |
| | | tasks.Add(GetTask(sa3006, tag, 3000)); |
| | | tasks.Add(GetTask(sa3010, tag, 3000)); |
| | | //tasks.Add(GetTask(sa3001, tag, 3000)); |
| | | //tasks.Add(GetTask(sa3005, tag, 3000)); |
| | | //tasks.Add(GetTask(sa3006, tag, 3000)); |
| | | //tasks.Add(GetTask(sa3010, tag, 3000)); |
| | | |
| | | Task.WaitAll(tasks.ToArray()); |
| | | } |
| | |
| | | |
| | | if (VERX != null) |
| | | { |
| | | LogHelper.Info($"{VERX.deviceName}æ¶é´æ³ {RedisHelper.Get<string>("Jsæ·é¡º1#Timestamp", out string mg)} D1212>{tag.Js1.D1212} 左满信å·:{TcpServer.GetBitdata(tag.Js1.D1212, 2)} D1212_LAST>{tag.Js1.D1212_LAST} 峿»¡ä¿¡å·>{TcpServer.GetBitdata(tag.Js1.D1212, 3)} D1213_LAST>{tag.Js1.D1213_LAST}"); |
| | | 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 |
| | |
| | | if (tag.Js1.D1212_LAST == 1 && TcpServer.GetBitdata(tag.Js1.D1212, 2) == 0) |
| | | { |
| | | //tag.Js1.D1212_LAST = 0; |
| | | tag.Js1.D1224 = 0; |
| | | RedisHelper.Add($"Jsæ·é¡º1.D1202_LAST", "0", out string msg); |
| | | //Conn.é»è®¤Redis.SetValue(VERX.deviceName + ".D1224", "0", VERX.deviceName + "Queue"); |
| | | //Conn.é»è®¤Redis.SetValue("Jsæ·é¡º1.D1224", "0", VERX.deviceName + "Queue"); |
| | | } |
| | | |
| | | if (tag.Js1.D1213_LAST == 0 && TcpServer.GetBitdata(tag.Js1.D1212, 3) == 1) |
| | |
| | | if (tag.Js1.D1213_LAST == 1 && TcpServer.GetBitdata(tag.Js1.D1212, 3) == 0) |
| | | { |
| | | //tag.Js1.D1213_LAST = 0; |
| | | tag.Js1.D1225 = 0; |
| | | RedisHelper.Add($"Jsæ·é¡º1.D1203_LAST", "0", out string msg); |
| | | //Conn.é»è®¤Redis.SetValue(VERX.deviceName + ".D1225", "0", VERX.deviceName + "Queue"); |
| | | } |
| | | } |
| | | } |
| | |
| | | |
| | | if (VERX != null) |
| | | { |
| | | LogHelper.Info($"{VERX.deviceName} æ¶é´æ³ {RedisHelper.Get<string>("Jsæ·é¡º2#Timestamp", out string mg)} D1212>{tag.Js2.D1212} 左满信å·:{TcpServer.GetBitdata(tag.Js2.D1212, 2)} D1212_LAST>{tag.Js2.D1212_LAST} 峿»¡ä¿¡å·>{TcpServer.GetBitdata(tag.Js2.D1212, 2)} D1213_LAST>{tag.Js2.D1213_LAST}"); |
| | | |
| | | 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 |
| | |
| | | if (tag.Js2.D1212_LAST == 1 && TcpServer.GetBitdata(tag.Js2.D1212, 2) == 0) |
| | | { |
| | | //tag.Js2.D1212_LAST = 0; |
| | | |
| | | tag.Js2.D1224 = 0; |
| | | RedisHelper.Add($"Jsæ·é¡º2.D1202_LAST", "0", out string msg); |
| | | } |
| | | if (tag.Js2.D1213_LAST == 0 && TcpServer.GetBitdata(tag.Js2.D1212, 3) == 1) |
| | |
| | | if (tag.Js2.D1213_LAST == 1 && TcpServer.GetBitdata(tag.Js2.D1213, 2) == 0) |
| | | { |
| | | //tag.Js2.D1213_LAST = 0; |
| | | |
| | | tag.Js2.D1225 = 0; |
| | | RedisHelper.Add($"Jsæ·é¡º2.D1203_LAST", "0", out string msg); |
| | | } |
| | | } |
| | |
| | | |
| | | LogHelper.Info($"æ¥çRGV çµéï¼ã{tag.RGV.Rå½åçµé}ã å
çµç¶æï¼ã{tag.RGV.Rå
çµç¶æ}ã æ
é代ç ï¼ã{tag.RGV.RgvrunError}ã æå¨1èªå¨2ã{tag.RGV.Ræå¨1èªå¨2}ã"); |
| | | |
| | | if (tag.RGV.Rå
çµç¶æ == 1) |
| | | { |
| | | LogHelper.Info($"RGV å
çµæ¨¡å¼ï¼ä¸ç¨ç®¡ã"); |
| | | return; |
| | | } |
| | | if (tag.RGV.Ræå¨1èªå¨2 == 1) |
| | | { |
| | | LogHelper.Info($"RGV æå¨æ¨¡å¼ï¼ä¸ç¨ç®¡ã"); |
| | | return; |
| | | } |
| | | if (tag.RGV.RgvrunError > 0) |
| | | { |
| | | LogHelper.Info($"RGV æ
éï¼ä¸ç¨ç®¡ã"); |
| | | return; |
| | | } |
| | | LogHelper.Info($"RGV125å½ä»¤æ¥ç Rgv任塿°æ® å workmode:{tag.RGV.workMod} taskmod{tag.RGV.taskmod} t1No:{tag.RGV.taskno1} t1do:{tag.RGV.task1do} t2No:{tag.RGV.taskno2} t2do:{tag.RGV.task2do} taskend:{tag.RGV.taskend} "); |
| | | if (tag.RGV.taskend == 125) |
| | | { |
| | | LogHelper.Info($"RGV æ125å½ä»¤æªæ§è¡ã "); |
| | | LogHelper.Info($"RGV125å½ä»¤æªæ§è¡ 任塿°æ® workmode:{tag.RGV.workMod}\n taskmod{tag.RGV.taskmod} \n t1No:{tag.RGV.taskno1}\n t1do:{tag.RGV.task1do} \n t2No:{tag.RGV.taskno2}\n t2do:{tag.RGV.task2do}\n taskend:{tag.RGV.taskend} "); |
| | | |
| | | if (tag.RGV.workMod == 0 && tag.RGV.taskmod == 0 && tag.RGV.taskno1 == tag.RGV.ReadTask1No && tag.RGV.taskno2 == tag.RGV.ReadTask2No) |
| | | { |
| | |
| | | System.Threading.Thread.Sleep(3000); |
| | | return; |
| | | } |
| | | 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}"); |
| | | LogHelper.Info($"ä»»å¡ä¸å 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) |
| | | { |
| | | 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; |
| | | //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; |
| | | //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); |
| | | } |
| | |
| | | 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).ToList(); |
| | | var timeMorhours = requires.FindAll(x => DateTime.Now.Subtract(x.T_CREATE).TotalHours > 1); |
| | | var requires1 = taskActRepository.FindList(x => taskCOdes.Contains(x.S_ACTION_CODE) && x.N_CREATEMETHOD == 0).OrderBy(x => x.T_CREATE).ToList(); |
| | | var timeMorhours = requires1.FindAll(x => DateTime.Now.Subtract(x.T_CREATE).TotalHours > 1); |
| | | if (timeMorhours.Any()) |
| | | { |
| | | foreach (var mor in timeMorhours) |
| | |
| | | mor.S_REVIEW_COMMENT = "è¶
æ¶ä¸å¤ç"; |
| | | taskActRepository.Update(mor); |
| | | } |
| | | requires = requires.Except(timeMorhours).ToList(); |
| | | requires1 = requires1.Except(timeMorhours).ToList(); |
| | | } |
| | | foreach (var item in requires) |
| | | foreach (var requires in requires1.GroupBy(x => x.S_TASK_NO)) |
| | | //foreach (var item in requires) |
| | | { |
| | | var rsss = requires.ToList(); |
| | | var item = rsss.OrderBy(x => x.S_ACTION_CODE.Contains("release") ? 0 : 1).LastOrDefault(); |
| | | if (rsss.Count > 1) |
| | | { |
| | | rsss.Remove(item); |
| | | foreach (var mor in rsss) |
| | | { |
| | | mor.N_CREATEMETHOD = 3; |
| | | mor.S_REVIEW_COMMENT = "å¤ä½ä¸å¤ç"; |
| | | taskActRepository.Update(mor); |
| | | } |
| | | } |
| | | LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE}å
æ
å¤ç =================> "); |
| | | var tin = taskCOdes.IndexOf(item.S_ACTION_CODE); |
| | | if (tin == -1) |
| | |
| | | } |
| | | } |
| | | System.Threading.Thread.Sleep(3000); |
| | | //ResetGats(tag); |
| | | } |
| | | public void ResetGats(Tag tag) |
| | | { |
| | |
| | | //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, 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.GetValue(dev.deviceName + ".D1224"); |
| | | Conn.é»è®¤Redis.SetValue(dev.deviceName + ".D1224", "0", dev.deviceName + "Queue", false); |
| | | } |
| | | if (TcpServer.GetBitdata(numm, 3) == 0) |
| | |
| | | public void ThreadEdown(Tag tag) |
| | | { |
| | | Console.WriteLine($"ThreadEdown 20 23 = ç©ºä¸æ£æµ =================> "); |
| | | if (tag.RGV.Rå
çµç¶æ == 1 || tag.RGV.Ræå¨1èªå¨2 == 1 || tag.RGV.RgvrunError > 0) |
| | | { |
| | | LogHelper.Info($"RGV æå¨||æ
é||å
çµï¼ç©ºä¸æ£æµç»æ¢ã"); |
| | | return; |
| | | } |
| | | TaskRepository taskRepository = new TaskRepository(); |
| | | foreach (var Bssx in new string[] { "1020", "1023" }) |
| | | { |
| | |
| | | |
| | | public void ThreadDdown(Tag tag) |
| | | { |
| | | Console.WriteLine($"ThreadDdown 08 10 ==================> 1026"); |
| | | Console.WriteLine($"ThreadDdown 08 16==================> 1026"); |
| | | if (tag.RGV.Rå
çµç¶æ == 1 || tag.RGV.Ræå¨1èªå¨2 == 1 || tag.RGV.RgvrunError > 0) |
| | | { |
| | | LogHelper.Info($"RGV æå¨||æ
é||å
çµï¼08 16 > 1026ç»æ¢ã"); |
| | | return; |
| | | } |
| | | TaskRepository taskRepository = new TaskRepository(); |
| | | foreach (var Bssx in new string[] { "1008", "1016" }) |
| | | { |
| | |
| | | public void Thread0210Down(Tag tag) |
| | | { |
| | | Console.WriteLine($"Thread0210Down ==================>"); |
| | | if (tag.RGV.Rå
çµç¶æ == 1 || tag.RGV.Ræå¨1èªå¨2 == 1 || tag.RGV.RgvrunError > 0) |
| | | { |
| | | LogHelper.Info($"RGV æå¨||æ
é||å
çµï¼02 10 > 1017ç»æ¢ã"); |
| | | return; |
| | | } |
| | | TaskRepository taskRepository = new TaskRepository(); |
| | | foreach (var Bssx in new string[] { "1002", "1010" }) |
| | | { |
| | |
| | | { |
| | | LogHelper.Info($"ssx == 1003 && tag.SF䏿ä½.WRelease1003:{tag.SF䏿ä½.WRelease1003} åf1 2210=1ï¼Arrive{ssx}BarcodeLast={RtrayCode}"); |
| | | tag.FNK1.D2210 = 1; |
| | | //Conn.é»è®¤Redis.SetValue($"påé£ç§1ä¸çº¿.D2210", "1", $"påé£ç§1ä¸çº¿Queue",false); |
| | | } |
| | | break; |
| | | case "1005": |
| | |
| | | |
| | | if (WRelease == 1 && rReleaseOver == 1) |
| | | { |
| | | switch (ssx) |
| | | { |
| | | case "1003": |
| | | { |
| | | LogHelper.Info($"读{ssx} WRelease=1&& rReleaseOver=1 读FNK1.D2213{tag.FNK1.D2213}=1? å¹¶å0"); |
| | | tag.FNK1.D2213 = 0; |
| | | } |
| | | break; |
| | | case "1005": |
| | | { |
| | | LogHelper.Info($"读{ssx} WRelease=1&& rReleaseOver=1 读FNK1.D2218{tag.FNK1.D2218}=1? å¹¶å0"); |
| | | tag.FNK1.D2218 = 0; |
| | | } |
| | | break; |
| | | case "1011": |
| | | { |
| | | LogHelper.Info($"读{ssx} WRelease=1&& rReleaseOver=1 读FNK2.D2213{tag.FNK1.D2213}=1? å¹¶å0"); |
| | | tag.FNK2.D2213 = 0; |
| | | } |
| | | break; |
| | | case "1013": |
| | | { |
| | | LogHelper.Info($"读{ssx} WRelease=1&& rReleaseOver=1 读FNK2.D2218{tag.FNK2.D2218}=1? å¹¶å0"); |
| | | tag.FNK2.D2218 = 0; |
| | | } |
| | | break; |
| | | } |
| | | //switch (ssx) |
| | | //{ |
| | | // case "1003": |
| | | // { |
| | | // LogHelper.Info($"读{ssx} WRelease=1&& rReleaseOver=1 读FNK1.D2213{tag.FNK1.D2213}=1? å¹¶å0"); |
| | | // tag.FNK1.D2213 = 0; |
| | | // } |
| | | // break; |
| | | // case "1005": |
| | | // { |
| | | // LogHelper.Info($"读{ssx} WRelease=1&& rReleaseOver=1 读FNK1.D2218{tag.FNK1.D2218}=1? å¹¶å0"); |
| | | // tag.FNK1.D2218 = 0; |
| | | // } |
| | | // break; |
| | | // case "1011": |
| | | // { |
| | | // LogHelper.Info($"读{ssx} WRelease=1&& rReleaseOver=1 读FNK2.D2213{tag.FNK1.D2213}=1? å¹¶å0"); |
| | | // tag.FNK2.D2213 = 0; |
| | | // } |
| | | // break; |
| | | // case "1013": |
| | | // { |
| | | // LogHelper.Info($"读{ssx} WRelease=1&& rReleaseOver=1 读FNK2.D2218{tag.FNK2.D2218}=1? å¹¶å0"); |
| | | // tag.FNK2.D2218 = 0; |
| | | // } |
| | | // break; |
| | | //} |
| | | LogHelper.Info($"读{ssx} WRelease=1&& rReleaseOver=1 WRelease å0"); |
| | | Conn.é»è®¤Redis.SetValue($"FNK1003051113.WRelease{ssx}", "0", $"FNK1003051113Queue"); |
| | | } |
| | |
| | | public void ThreadFNK1Over(Tag tag) |
| | | { |
| | | Console.WriteLine($"ThreadFNK1Over =====>"); |
| | | LogHelper.Info($" FN1 æ¶é´æ³ {RedisHelper.Get<string>("påé£ç§1ä¸çº¿#Timestamp", out string mg)}"); |
| | | 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) |
| | |
| | | public void ThreadFNK2Over(Tag tag) |
| | | { |
| | | Console.WriteLine($"ThreadFNK2Over =====>"); |
| | | LogHelper.Info($" FN2 æ¶é´æ³ {RedisHelper.Get<string>("påé£ç§2ä¸çº¿#Timestamp", out string mg)}"); |
| | | 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) |
| | | { |
| | |
| | | //} |
| | | //Console.WriteLine($"SA1030 ä»»å¡ç¶æï¼{tag.SA1030.RtaskState}- 空é²{tag.SA1030.R5空é²}-->对åºç»ç¹2001>空é²5ï¼{tag.SA2001.R5空é²}"); |
| | | } |
| | | static int i = 0; |
| | | public void Thread2030Down(Tag tag) |
| | | { |
| | | i++; |
| | | if (i > 2 * 3600 / 3) |
| | | { |
| | | Console.Clear(); |
| | | LogHelper.Info($"循ç¯{i}次>> æ¸
空æ§å¶å°ã"); |
| | | i = 0; |
| | | } |
| | | |
| | | //Console.WriteLine($"SA2030 ä»»å¡ç¶æï¼ =====>"); |
| | | //Console.WriteLine($"SA2030 ä»»å¡ç¶æï¼{tag.SA2030.RtaskState}- 空é²{tag.SA2030.R5空é²} - barcode:{tag.SA2030.Ræçç }"); |
| | |
| | | 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}"); |
| | | LogHelper.Info($" {VERX.deviceName} æ¶é´æ³ {RedisHelper.Get<string>("Då®å1å·æºæ¢°æ#Timestamp", out string mg)} 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 |
| | |
| | | LogHelper.Info("å®å2å·çº¿ deviceType 5 没æé
ç½®ã"); |
| | | return; |
| | | } |
| | | LogHelper.Info($" {VERX.deviceName} D2221>{tag.DZ2.D2221} D2221_LAST>{tag.DZ2.D2221_LAST} D2226>{tag.DZ2.D2226} D2226_LAST>{tag.DZ2.D2226_LAST}"); |
| | | LogHelper.Info($" {VERX.deviceName} æ¶é´æ³ {RedisHelper.Get<string>("Då®å2å·æºæ¢°æ#Timestamp", out string mg)} D2221>{tag.DZ2.D2221} D2221_LAST>{tag.DZ2.D2221_LAST} D2226>{tag.DZ2.D2226} D2226_LAST>{tag.DZ2.D2226_LAST}"); |
| | | if (tag.DZ2.D2221 == 1 && tag.DZ2.D2221_LAST == 0) |
| | | { |
| | | var str = Settings.apiHelper.Post(Settings.WMSbaseUrl + "mom-basic/dataTransmission/json/service/200", JsonConvert.SerializeObject(new |