| | |
| | | using static System.Windows.Forms.VisualStyles.VisualStyleElement; |
| | | using System.Windows.Interop; |
| | | using static System.Windows.Forms.VisualStyles.VisualStyleElement.TextBox; |
| | | using System.Security.Cryptography; |
| | | |
| | | namespace GZ.Projects.AuxAllWCS |
| | | { |
| | |
| | | else if (Settings.deviceInfos.Count == 0) |
| | | { |
| | | tag.Global.SettingsOver = 0; |
| | | } |
| | | else tag.Global.SettingsOver++; |
| | | if (tag.Global.SettingsOver > 999) |
| | | { |
| | | tag.Global.SettingsOver = 1; |
| | | Console.Clear(); |
| | | } |
| | | } |
| | | |
| | |
| | | LogHelper.Info($"{VERX.location[0]}ç³è¯·mesä»»å¡ç»æ{str}"); |
| | | if (str.Contains("true")) |
| | | { |
| | | tag.wxr1.R44_LAST = true; |
| | | //tag.wxr1.R44_LAST = true; |
| | | RedisHelper.Add($"ç»´å¸å°æè1.R44_LAST", "true", out string msg); |
| | | } |
| | | } |
| | | else |
| | |
| | | { |
| | | if (tag.wxr1.R10) |
| | | { |
| | | tag.wxr1.R10_LAST = false; |
| | | //tag.wxr1.R10_LAST = false; |
| | | RedisHelper.Add($"ç»´å¸å°æè1.R10_LAST", "false", out string msg); |
| | | } |
| | | else |
| | | if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[0], out string traycode)) |
| | |
| | | { |
| | | //Conn.é»è®¤Redis.SetValue("ç»´å¸å°æè1.R10", "true", "ç»´å¸å°æè1Queue"); |
| | | tag.wxr1.R10 = true; |
| | | tag.wxr1.R44_LAST = false; |
| | | //tag.wxr1.R44_LAST = false; |
| | | RedisHelper.Add($"ç»´å¸å°æè1.R44_LAST", "false", out string msg); |
| | | } |
| | | else |
| | | { |
| | |
| | | LogHelper.Info($"{VERX.location[1]}ç³è¯·mesä»»å¡ç»æ{str}"); |
| | | if (str.Contains("true")) |
| | | { |
| | | tag.wxr1.R46_LAST = true; |
| | | //tag.wxr1.R46_LAST = true; |
| | | RedisHelper.Add($"ç»´å¸å°æè1.R46_LAST", "true", out string msg); |
| | | } |
| | | } |
| | | else |
| | |
| | | { |
| | | if (tag.wxr1.R11) |
| | | { |
| | | tag.wxr1.R11_LAST = false; |
| | | //tag.wxr1.R11_LAST = false; |
| | | RedisHelper.Add($"ç»´å¸å°æè1.R11_LAST", "false", out string msg); |
| | | } |
| | | else |
| | | if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode)) |
| | |
| | | { |
| | | //Conn.é»è®¤Redis.SetValue("ç»´å¸å°æè1.R10", "true", "ç»´å¸å°æè1Queue"); |
| | | tag.wxr1.R11 = true; |
| | | tag.wxr1.R46_LAST = false; |
| | | //tag.wxr1.R46_LAST = false; |
| | | RedisHelper.Add($"ç»´å¸å°æè1.R46_LAST", "false", out string msg); |
| | | } |
| | | else |
| | | { |
| | |
| | | LogHelper.Info($"{VERX.location[0]}ç³è¯·mesä»»å¡ç»æ{str}"); |
| | | if (str.Contains("true")) |
| | | { |
| | | tag.wxr2.R44_LAST = true; |
| | | //tag.wxr2.R44_LAST = true; |
| | | RedisHelper.Add($"ç»´å¸å°æè2.R44_LAST", "true", out string msg); |
| | | } |
| | | } |
| | | else |
| | |
| | | { |
| | | if (tag.wxr2.R10) |
| | | { |
| | | tag.wxr2.R10_LAST = false; |
| | | //tag.wxr2.R10_LAST = false; |
| | | RedisHelper.Add($"ç»´å¸å°æè2.R10_LAST", "false", out string msg); |
| | | } |
| | | else |
| | | if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[0], out string traycode)) |
| | |
| | | { |
| | | //Conn.é»è®¤Redis.SetValue("ç»´å¸å°æè1.R10", "true", "ç»´å¸å°æè1Queue"); |
| | | tag.wxr2.R10 = true; |
| | | tag.wxr2.R44_LAST = false; |
| | | //tag.wxr2.R44_LAST = false; |
| | | RedisHelper.Add($"ç»´å¸å°æè2.R44_LAST", "false", out string msg); |
| | | } |
| | | else |
| | | { |
| | |
| | | LogHelper.Info($"{VERX.location[1]}ç³è¯·mesä»»å¡ç»æ{str}"); |
| | | if (str.Contains("true")) |
| | | { |
| | | tag.wxr2.R46_LAST = true; |
| | | //tag.wxr2.R46_LAST = true; |
| | | RedisHelper.Add($"ç»´å¸å°æè2.R46_LAST", "true", out string msg); |
| | | } |
| | | } |
| | | else |
| | |
| | | { |
| | | if (tag.wxr2.R11) |
| | | { |
| | | tag.wxr2.R11_LAST = false; |
| | | //tag.wxr2.R11_LAST = false; |
| | | RedisHelper.Add($"ç»´å¸å°æè2.R11_LAST", "false", out string msg); |
| | | } |
| | | else |
| | | if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1], out string traycode)) |
| | |
| | | { |
| | | //Conn.é»è®¤Redis.SetValue("ç»´å¸å°æè1.R10", "true", "ç»´å¸å°æè1Queue"); |
| | | tag.wxr2.R11 = true; |
| | | tag.wxr2.R46_LAST = false; |
| | | //tag.wxr2.R46_LAST = false; |
| | | RedisHelper.Add($"ç»´å¸å°æè2.R46_LAST", "false", out string msg); |
| | | } |
| | | else |
| | | { |
| | |
| | | string tno = "TN" + (DateTime.Now.ToString("yy")) + ((taskno.ToString()).PadLeft(8, '0')); |
| | | task1 = taskservice.FindEntity(x => x.S_TASK_NO == tno); |
| | | |
| | | LogHelper.Info($"RGV 1å·¥ä½ä»»å¡{JsonConvert.SerializeObject(task1)}.bit1taskOver_LASTï¼{tag.RGV.bit1taskOver_LAST}"); |
| | | LogHelper.Info($"RGV 1å·¥ä½ä»»å¡{task1?.S_TASK_NO}.bit1taskOver_LASTï¼{tag.RGV.bit1taskOver_LAST}"); |
| | | if (tag.RGV.bit1taskOver_LAST == 0 && task1 != null) |
| | | { |
| | | if (task1.S_B_STATE != "宿") |
| | |
| | | |
| | | public void ThreadGrats(Tag tag, Action<HaiKangOrderInfo> continueTask) |
| | | { |
| | | Console.WriteLine($"ThreadGrats å
æ
å¤ç =================> "); |
| | | LogHelper.Info($"ThreadGrats å
æ
å¤ç =================> "); |
| | | |
| | | var taskCOdes = new List<string> { "Sarrive", "Srelease", "Earrive", "Erelease" }; |
| | | TaskActRepository taskActRepository = new TaskActRepository(); |
| | | TaskRepository taskRepository = new TaskRepository(); |
| | | var requires = taskActRepository.FindList(x => taskCOdes.Contains(x.S_ACTION_CODE) && x.N_CREATEMETHOD == 0); |
| | | var requires = taskActRepository.FindList(x => taskCOdes.Contains(x.S_ACTION_CODE) && x.N_CREATEMETHOD == 0).OrderBy(x => x.T_CREATE); |
| | | foreach (var item in requires) |
| | | { |
| | | LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE}å
æ
å¤ç =================> "); |
| | | var tin = taskCOdes.IndexOf(item.S_ACTION_CODE); |
| | | if (tin == -1) |
| | | { |
| | |
| | | taskActRepository.Update(item); |
| | | continue; |
| | | } |
| | | //var task = taskRepository.FindEntity(x => x.S_TASK_NO == item.S_TASK_NO); |
| | | var task = taskRepository.FindEntity(x => x.S_TASK_NO == item.S_TASK_NO); |
| | | if (task == null) |
| | | { |
| | | item.N_CREATEMETHOD = -1; |
| | | taskActRepository.Update(item); |
| | | continue; |
| | | } |
| | | string loc = ""; |
| | | if (tin < 2) |
| | | { |
| | |
| | | var dev = Settings.deviceInfos.Find(x => x.location.Contains(loc)); |
| | | if (dev != null) |
| | | { |
| | | LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤æ¯{dev.deviceName} å
æ
å¤ç =================> "); |
| | | var V = dev.location.ToList().FindIndex(x => x == loc) == 0; |
| | | //è½¦èµ°äº å¼å
æ
|
| | | if (!goin) |
| | | { |
| | | if (dev.deviceType == 1) |
| | | { |
| | | LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤æ¯{dev.deviceName} å¼å¯å
æ
å¤ç =================> "); |
| | | LogHelper.Info($"{dev.deviceName}{(V ? "å·¦" : "å³")} å
æ
{(goin ? "å
³é" : "å¼å¯")} ç³è¯·ã" + string.Format("{0}{1}{2}", dev.deviceName + "." + (V ? "R02" : "R04"), "true", dev.deviceName + "Queue")); |
| | | Conn.é»è®¤Redis.SetValue(dev.deviceName + "." + (V ? "R02" : "R04"), "true", dev.deviceName + "Queue"); |
| | | |
| | | Conn.é»è®¤Redis.SetValue(dev.deviceName + "." + (V ? "R02" : "R04"), "true", dev.deviceName + "Queue", false); |
| | | } |
| | | else if (dev.deviceType == 2) |
| | | { |
| | | LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤æ¯{dev.deviceName} å¼å¯å
æ
å¤ç =================> "); |
| | | LogHelper.Info($"{dev.deviceName}{(V ? "å·¦" : "å³")} å
æ
{(goin ? "å
³é" : "å¼å¯")} ç³è¯·ã" + string.Format("{0}{1}{2}", dev.deviceName + "." + (V ? "D1222" : "D1223"), "1", dev.deviceName + "Queue")); |
| | | Conn.é»è®¤Redis.SetValue(dev.deviceName + "." + (V ? "D1222" : "D1223"), "1", dev.deviceName + "Queue"); |
| | | } |
| | | LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤æ¯{dev.deviceName} å¼å¯å
æ
å¤ç宿 =================> "); |
| | | |
| | | item.N_CREATEMETHOD = 1; |
| | | taskActRepository.Update(item); |
| | |
| | | { |
| | | 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 ? "å
³é" : "å¼å¯")} ç³è¯·ã å·²ç»å
³éï¼"); |
| | |
| | | else |
| | | { |
| | | LogHelper.Info($"{dev.deviceName}{(V ? "å·¦" : "å³")} å
æ
{(goin ? "å
³é" : "å¼å¯")} ç³è¯·ã" + string.Format("{0}{1}{2}", dev.deviceName + "." + (V ? "R01" : "R03"), "true", dev.deviceName + "Queue")); |
| | | Conn.é»è®¤Redis.SetValue(dev.deviceName + "." + (V ? "R01" : "R03"), "true", dev.deviceName + "Queue"); |
| | | Conn.é»è®¤Redis.SetValue(dev.deviceName + "." + (V ? "R01" : "R03"), "true", dev.deviceName + "Queue", false); |
| | | } |
| | | |
| | | LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤æ¯{dev.deviceName} å
³éå
æ
å¤ç宿 =================> "); |
| | | } |
| | | else if (dev.deviceType == 2) |
| | | { |
| | | LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤æ¯{dev.deviceName} å
³éå
æ
å¤ç =================> "); |
| | | var tf = Conn.é»è®¤Redis.GetValue(dev.deviceName + ".D1202"); |
| | | int numm = int.Parse(string.IsNullOrEmpty(tf) ? "0" : tf); |
| | | if (TcpServer.GetBitdata(numm, (V ? 0 : 1)) == 1) |
| | | int close = TcpServer.GetBitdata(numm, (V ? 0 : 1)); |
| | | LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤æ¯{dev.deviceName} å
æ
å
³éä¿¡å·{close}"); |
| | | if (close == 1) |
| | | { |
| | | LogHelper.Info($"{dev.deviceName}{(V ? "å·¦" : "å³")} å
æ
{(goin ? "å
³é" : "å¼å¯")} ç³è¯·ã å·²ç»å
³éï¼"); |
| | | continuuuuu = true; |
| | |
| | | LogHelper.Info($"{dev.deviceName}{(V ? "å·¦" : "å³")} å
æ
{(goin ? "å
³é" : "å¼å¯")} ç³è¯·ã" + string.Format("{0}{1}{2}", dev.deviceName + "." + (V ? "D1220" : "D1221"), dev.deviceName + "Queue")); |
| | | Conn.é»è®¤Redis.SetValue(dev.deviceName + "." + (V ? "D1220" : "D1221"), "1", dev.deviceName + "Queue"); |
| | | } |
| | | LogHelper.Info($"ThreadGrats {item.S_TASK_NO} >{item.S_ACTION_CODE} è®¾å¤æ¯{dev.deviceName} å
³éå
æ
å¤ç宿 =================> "); |
| | | } |
| | | |
| | | } |
| | |
| | | } |
| | | } |
| | | System.Threading.Thread.Sleep(3000); |
| | | LogHelper.Info($"ThreadGrats deviceType2å
æ
åå
¥ä½éç½® =================> "); |
| | | //éç½®ä¿¡å· |
| | | foreach (var dev in Settings.deviceInfos.FindAll(x => x.deviceType == 2)) |
| | | { |
| | |
| | | int numm = int.Parse(string.IsNullOrEmpty(tf) ? "0" : tf); |
| | | if (TcpServer.GetBitdata(numm, 0) == 0) |
| | | { |
| | | Conn.é»è®¤Redis.SetValue(dev.deviceName + ".D1220", "0", dev.deviceName + "Queue"); |
| | | Conn.é»è®¤Redis.SetValue(dev.deviceName + ".D1222", "0", dev.deviceName + "Queue"); |
| | | Conn.é»è®¤Redis.SetValue(dev.deviceName + ".D1220", "0", dev.deviceName + "Queue", false); |
| | | Conn.é»è®¤Redis.SetValue(dev.deviceName + ".D1222", "0", dev.deviceName + "Queue", false); |
| | | } |
| | | else if (TcpServer.GetBitdata(numm, 1) == 0) |
| | | { |
| | | Conn.é»è®¤Redis.SetValue(dev.deviceName + ".D1221", "0", dev.deviceName + "Queue"); |
| | | Conn.é»è®¤Redis.SetValue(dev.deviceName + ".D1223", "0", dev.deviceName + "Queue"); |
| | | Conn.é»è®¤Redis.SetValue(dev.deviceName + ".D1221", "0", dev.deviceName + "Queue", false); |
| | | Conn.é»è®¤Redis.SetValue(dev.deviceName + ".D1223", "0", dev.deviceName + "Queue", false); |
| | | } |
| | | } |
| | | |
| | | LogHelper.Info($"ThreadGrats deviceType2å
æ
åå
¥ä½éç½®å®æã =================> "); |
| | | } |
| | | /// <summary> |
| | | /// 1020 1023空æ¡ä¸çº¿ |