| | |
| | | using GZ.DB.Entity.OIDATABASE; |
| | | namespace GZ.Projects.AuxAllWCS |
| | | { |
| | | /// <summary> |
| | | /// äºä»¶ |
| | | /// </summary> |
| | | public partial class ViewModel : System.ComponentModel.INotifyPropertyChanged |
| | | { |
| | | /// <summary> |
| | | /// äºä»¶ |
| | | /// </summary> |
| | | public partial class ViewModel : System.ComponentModel.INotifyPropertyChanged |
| | | { |
| | | bool IsExitApp = false; |
| | | ConcurrentStack<int> ExitJudgeStack = new ConcurrentStack<int>(); |
| | | System.Net.HttpListener HttpSvcHost = null; |
| | | |
| | | #region View1äºä»¶ |
| | | /// <summary> |
| | | System.Net.HttpListener HttpSvcHost = null; |
| | | |
| | | #region View1äºä»¶ |
| | | /// <summary> |
| | | /// View1æå¼äºä»¶ |
| | | /// </summary> |
| | | /// <param name="sender"></param> |
| | | /// <param name="e"></param> |
| | | public void View1_LoadEvent(object sender, RoutedEventArgs e) |
| | | { |
| | | |
| | | try |
| | | { |
| | | HttpSvcHost = new System.Net.HttpListener(); |
| | | HttpSvcHost.AuthenticationSchemes = System.Net.AuthenticationSchemes.Anonymous; |
| | | HttpSvcHost.Prefixes.Add("http://10.221.55.116:8808/"); |
| | | HttpSvcHost.Start(); |
| | | HttpSvcHost.BeginGetContext(HttpSvcListenerCallback, null); |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | View1_Init(sender, e); |
| | | |
| | | /// <summary> |
| | | /// ç¨åºç段:åå§åé
ç½® |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250323111613779][ä¸å¡é»è¾.åå§åé
ç½®] |
| | | if (Tag.Global.SettingsOver == 0) |
| | | { |
| | | SettingInit(); |
| | | Tag.Global.SettingsOver = 1; |
| | | } |
| | | else if(Settings.deviceInfos.Count == 0) |
| | | { |
| | | Tag.Global.SettingsOver = 0; |
| | | } |
| | | public void View1_LoadEvent(object sender, RoutedEventArgs e) |
| | | { |
| | | |
| | | #endregion [èæ¬][20250323111613779][ä¸å¡é»è¾.åå§åé
ç½®] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(10000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | //æ§è¡å¤æ¬¡ |
| | | for(int iii=0;iii<1;iii++) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250323151832119][ä¸å¡é»è¾.Program4] |
| | | //Conn.é»è®¤Redis.SetValue("西é¨å2.Param3","300","西é¨å2Queue"); |
| | | //return; |
| | | if(false){ |
| | | List<string> locs = new List<string>() { "vxr1l", "vx1r", "vxr1c1", "vxr1c2", "vxr2l", "vxr2r", "vxr2c1", "vxr2c2" }; |
| | | List<string> sites = new List<string>() { "196365BB283162", "193841BB283149", "198756BB287300", "198767BB286133", "206987BB282931", "204460BB282975", "209405BB287057", "209377BB285899" }; |
| | | try |
| | | { |
| | | //HttpSvcHost = new System.Net.HttpListener(); |
| | | //HttpSvcHost.AuthenticationSchemes = System.Net.AuthenticationSchemes.Anonymous; |
| | | //HttpSvcHost.Prefixes.Add("http://10.221.55.117:8808/"); |
| | | //HttpSvcHost.Start(); |
| | | //HttpSvcHost.BeginGetContext(HttpSvcListenerCallback, null); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | View1_Init(sender, e); |
| | | |
| | | LocRepository locservice = new LocRepository(); |
| | | for (int i = 0; i < locs.Count; i++) |
| | | /// <summary> |
| | | /// ç¨åºç段:åå§åé
ç½® |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | string loccode = locs[i]; |
| | | string sitesss = sites[i]; |
| | | var loc = locservice.FindEntity(x => x.S_LOC_CODE == loccode); |
| | | if (loc == null) |
| | | { |
| | | locservice.Insert(new LocEntity |
| | | { |
| | | S_ID = Guid.NewGuid().ToString(), |
| | | S_STATE = "ç¼è¾", |
| | | T_CREATE = DateTime.Now, |
| | | T_MODIFY = DateTime.Now, |
| | | S_DEEP = "vxr", |
| | | #region [èæ¬][20250323111613779][ä¸å¡é»è¾.åå§åé
ç½®] |
| | | |
| | | S_LOC_CODE = loccode, |
| | | S_AGV_SITE = sitesss, |
| | | |
| | | S_LOCK_STATE = "æ ", |
| | | N_ROW = 1, |
| | | N_COL = 1, |
| | | N_AGV_CODE = 0, |
| | | N_AGV_SITE_LAYER = 0, |
| | | N_CAPACITY = 1, |
| | | N_CURRENT_NUM = 0, |
| | | S_TYPE = "", |
| | | |
| | | }); |
| | | } |
| | | Action myDelegate = () => SettingInit(); |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "ThreadSettingInit", new object[] { tag, myDelegate }); |
| | | #endregion [èæ¬][20250323111613779][ä¸å¡é»è¾.åå§åé
ç½®] |
| | | } |
| | | // TaskProcess.CreateTask("", locs[6], locs[7], "test", 9, new List<string> { "test" }, 1, 1, 1); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(10000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:æ·ç¬æè1 |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250325083325390][ä¸å¡é»è¾.ç¬¬ä¸æ 段.æ·ç¬æè1] |
| | | |
| | | #endregion [èæ¬][20250323151832119][ä¸å¡é»è¾.Program4] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | /// <summary> |
| | | /// ç¨åºç段:æ·ç¬æè1 |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250325083325390][ä¸å¡é»è¾.ç¬¬ä¸æ 段.æ·ç¬æè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}"); |
| | | if (str.Contains("true")) |
| | | { |
| | | tag.Js1.D1212_LAST = 1; |
| | | } |
| | | } |
| | | if(tag.Js1.D1212_LAST == 1 &&TcpServer.GetBitdata(tag.Js1.D1212, 2) == 0){ |
| | | tag.Js1.D1212_LAST = 0; |
| | | } |
| | | 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}"); |
| | | if (str.Contains("true")) |
| | | { |
| | | tag.Js1.D1213_LAST = 1; |
| | | } |
| | | }if(tag.Js1.D1213_LAST == 1 &&TcpServer.GetBitdata(tag.Js1.D1212, 3) == 0){ |
| | | tag.Js1.D1213_LAST = 0; |
| | | } |
| | | } |
| | | #endregion [èæ¬][20250325083325390][ä¸å¡é»è¾.ç¬¬ä¸æ 段.æ·ç¬æè1] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:æ·ç¬æè2 |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250325083326611][ä¸å¡é»è¾.ç¬¬ä¸æ 段.æ·ç¬æè2] |
| | | //jsz2æ·ç¬æè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}"); |
| | | if (str.Contains("true")) |
| | | { |
| | | tag.Js2.D1212_LAST = 1; |
| | | } |
| | | } if(tag.Js2.D1212_LAST == 1 &&TcpServer.GetBitdata(tag.Js2.D1212, 2) == 0){ |
| | | tag.Js2.D1212_LAST = 0; |
| | | } |
| | | 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}"); |
| | | if (str.Contains("true")) |
| | | { |
| | | tag.Js2.D1213_LAST = 1; |
| | | } |
| | | }if(tag.Js2.D1213_LAST == 1 &&TcpServer.GetBitdata(tag.Js2.D1213, 2) == 0){ |
| | | tag.Js2.D1213_LAST = 0; |
| | | } |
| | | } |
| | | #endregion [èæ¬][20250325083326611][ä¸å¡é»è¾.ç¬¬ä¸æ 段.æ·ç¬æè2] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:èªæµè½¬æµç¨ |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250325085810885][ä¸å¡é»è¾.ç¬¬ä¸æ 段.èªæµè½¬æµç¨] |
| | | //foreach(var di in Settings.deviceInfos) |
| | | // if (di.deviceType == 2 || di.deviceType == 1) |
| | | // RunafterMac(di,true); |
| | | /// TODO mes ä¸åã æ¹ææºæ¢°èçæ§ - çæ§ç©ºçè¿æ¯æ»¡ç - èå¨mes ä»»å¡ã |
| | | #endregion [èæ¬][20250325085810885][ä¸å¡é»è¾.ç¬¬ä¸æ 段.èªæµè½¬æµç¨] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:ç»´å¸å°æè1L |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250325083149366][ä¸å¡é»è¾.ç¬¬ä¸æ 段.ç»´ç³»å°1å·.ç»´å¸å°æè1L] |
| | | |
| | | 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)) |
| | | { |
| | | 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}"); |
| | | if (str.Contains("true")) |
| | | { |
| | | tag.wxr1.R44_LAST = true; |
| | | } |
| | | } |
| | | 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; |
| | | } else |
| | | if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[0],out string 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("ç»´å¸å°æè1.R10", "true", "ç»´å¸å°æè1Queue"); |
| | | tag.wxr1.R10 = true; |
| | | tag.wxr1.R44_LAST = false; |
| | | } |
| | | else |
| | | { |
| | | //æ¥è¦ã |
| | | } |
| | | } |
| | | else { TcpServer.TcpServerSend(VERX.deviceNo[0], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E")); } |
| | | } |
| | | } |
| | | } |
| | | #endregion [èæ¬][20250325083149366][ä¸å¡é»è¾.ç¬¬ä¸æ 段.ç»´ç³»å°1å·.ç»´å¸å°æè1L] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:ç»´å¸å°æè1R |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250610002047005][ä¸å¡é»è¾.ç¬¬ä¸æ 段.ç»´ç³»å°1å·.ç»´å¸å°æè1R] |
| | | 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)) |
| | | { |
| | | 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}"); |
| | | if (str.Contains("true")) |
| | | { |
| | | tag.wxr1.R46_LAST = true; |
| | | } |
| | | } |
| | | 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; |
| | | } else |
| | | if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1],out string 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("ç»´å¸å°æè1.R10", "true", "ç»´å¸å°æè1Queue"); |
| | | tag.wxr1.R11 = true; |
| | | tag.wxr1.R46_LAST = false; |
| | | } |
| | | else |
| | | { |
| | | //æ¥è¦ã |
| | | } |
| | | } |
| | | else { TcpServer.TcpServerSend(VERX.deviceNo[1], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E")); } |
| | | } |
| | | } |
| | | } |
| | | #endregion [èæ¬][20250610002047005][ä¸å¡é»è¾.ç¬¬ä¸æ 段.ç»´ç³»å°1å·.ç»´å¸å°æè1R] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:ç»´å¸å°æè2L |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250325083315503][ä¸å¡é»è¾.ç¬¬ä¸æ 段.ç»´ç³»å°2å·.ç»´å¸å°æè2L] |
| | | |
| | | 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)) |
| | | { |
| | | 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}"); |
| | | if (str.Contains("true")) |
| | | { |
| | | tag.wxr2.R44_LAST = true; |
| | | } |
| | | } |
| | | 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; |
| | | } else |
| | | if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[0],out string 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("ç»´å¸å°æè1.R10", "true", "ç»´å¸å°æè1Queue"); |
| | | tag.wxr2.R10 = true; |
| | | tag.wxr2.R44_LAST = false; |
| | | } |
| | | else |
| | | { |
| | | //æ¥è¦ã |
| | | } |
| | | } |
| | | else { TcpServer.TcpServerSend(VERX.deviceNo[0], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E")); } |
| | | } |
| | | } |
| | | } |
| | | #endregion [èæ¬][20250325083315503][ä¸å¡é»è¾.ç¬¬ä¸æ 段.ç»´ç³»å°2å·.ç»´å¸å°æè2L] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:ç»´å¸å°æè2R |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250610002647095][ä¸å¡é»è¾.ç¬¬ä¸æ 段.ç»´ç³»å°2å·.ç»´å¸å°æè2R] |
| | | 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)) |
| | | { |
| | | 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}"); |
| | | if (str.Contains("true")) |
| | | { |
| | | tag.wxr2.R46_LAST = true; |
| | | } |
| | | } |
| | | else |
| | | { |
| | | TcpServer.TcpServerSend(VERX.deviceNo[2], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E")); |
| | | } |
| | | } |
| | | else |
| | | { |
| | | if (tag.wxr2.R11_LAST) //æçæ¾ç½®ä¿¡å·ãã |
| | | { |
| | | if (tag.wxr2.R11) |
| | | { |
| | | tag.wxr2.R11_LAST=false; |
| | | } else |
| | | if (TcpServer.TrayIps.TryGetValue(VERX.deviceNo[1],out string 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("ç»´å¸å°æè1.R10", "true", "ç»´å¸å°æè1Queue"); |
| | | tag.wxr2.R11 = true; |
| | | tag.wxr2.R46_LAST = false; |
| | | } |
| | | else |
| | | { |
| | | //æ¥è¦ã |
| | | } |
| | | } |
| | | else { TcpServer.TcpServerSend(VERX.deviceNo[1], GZ.Device.PLC.PlcHelper.Hex2Bin("544F4E")); } |
| | | } |
| | | } |
| | | } |
| | | #endregion [èæ¬][20250610002647095][ä¸å¡é»è¾.ç¬¬ä¸æ 段.ç»´ç³»å°2å·.ç»´å¸å°æè2R] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:ä»»å¡ä¸å |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250325085542733][ä¸å¡é»è¾.ä»»å¡ä¸å] |
| | | |
| | | #endregion [èæ¬][20250325085542733][ä¸å¡é»è¾.ä»»å¡ä¸å] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:ResolveMesTask |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250531163716255][ä¸å¡é»è¾.å¤çMESä»»å¡çº¿ç¨.ResolveMesTask] |
| | | //mes 任塿åã䏿®µä»»å¡å 夿®µä»»å¡ã |
| | | ToWMSMES.ResMesTask(); |
| | | #endregion [èæ¬][20250531163716255][ä¸å¡é»è¾.å¤çMESä»»å¡çº¿ç¨.ResolveMesTask] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | try |
| | | { |
| | | #region [èæ¬][20250605212104026][ä¸å¡é»è¾.SocketServer] |
| | | 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 TcpServer(ip.ToString()); |
| | | } |
| | | } |
| | | #endregion [èæ¬][20250605212104026][ä¸å¡é»è¾.SocketServer] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | } |
| | | /// <summary> |
| | | /// ç¨åºç段:å
æ
å¤ç |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250611223832523][ä¸å¡é»è¾.å
æ
å¤ç] |
| | | // - å
æ
交äºå¤çãã |
| | | 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); |
| | | foreach (var item in requires) |
| | | { |
| | | 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); |
| | | 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) |
| | | { |
| | | var V = dev.location.ToList().FindIndex(x => x == loc) == 0; |
| | | //è½¦èµ°äº å¼å
æ
|
| | | if (!goin) |
| | | { |
| | | if (dev.deviceType == 1) |
| | | { |
| | | 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"); |
| | | |
| | | } |
| | | else if (dev.deviceType == 2) |
| | | { |
| | | 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"); |
| | | } |
| | | |
| | | item.N_CREATEMETHOD = 1; |
| | | taskActRepository.Update(item); |
| | | } |
| | | //车è¦è¿å
¥äº¤äºã |
| | | else |
| | | { |
| | | if (dev.deviceType == 1) |
| | | { |
| | | var tf = Conn.é»è®¤Redis.GetValue(dev.deviceName + "." + (V ? "R50" : "R52"));//读å
³éç¶æ |
| | | if (tf?.ToLower() == "true") |
| | | { |
| | | LogHelper.Info($"{dev.deviceName}{(V ? "å·¦" : "å³")} å
æ
{(goin?"å
³é":"å¼å¯")} ç³è¯·ã å·²ç»å
³éï¼"); |
| | | continuuuuu = true; |
| | | } |
| | | else |
| | | { |
| | | LogHelper.Info($"{dev.deviceName}{(V ? "å·¦" : "å³")} å
æ
{(goin?"å
³é":"å¼å¯")} ç³è¯·ã"+string.Format("{0}{1}{2}", dev.deviceName + "." + (V ? "R01" : "R03"), "true", dev.deviceName + "Queue")); |
| | | Conn.é»è®¤Redis.SetValue(dev.deviceName + "." + (V ? "R01" : "R03"), "true", dev.deviceName + "Queue"); |
| | | } |
| | | |
| | | } |
| | | else if (dev.deviceType == 2) |
| | | { |
| | | var tf = Conn.é»è®¤Redis.GetValue(dev.deviceName + ".D1202"); |
| | | int numm = int.Parse(string.IsNullOrEmpty(tf) ? "0" : tf); |
| | | if (TcpServer.GetBitdata(numm,(V?0:1))==1) |
| | | { |
| | | LogHelper.Info($"{dev.deviceName}{(V ? "å·¦" : "å³")} å
æ
{(goin?"å
³é":"å¼å¯")} ç³è¯·ã å·²ç»å
³éï¼"); |
| | | continuuuuu = true; |
| | | } |
| | | else |
| | | { |
| | | 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"); |
| | | } |
| | | } |
| | | |
| | | } |
| | | |
| | | } |
| | | if (continuuuuu) |
| | | { |
| | | LogHelper.Info($"{item.S_TASK_NO}{item.S_ACTION_CODE} 车è¾åéç»§ç»ä»»å¡ï¼"); |
| | | continueTask(new HaiKangOrderInfo |
| | | { |
| | | reqCode = item.S_ID.Replace("-", ""), |
| | | taskCode = item.S_TASK_NO |
| | | }); |
| | | item.N_CREATEMETHOD = 1; |
| | | taskActRepository.Update(item); |
| | | } |
| | | } |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "ThreadJS1", new object[] { tag }); |
| | | #endregion [èæ¬][20250325083325390][ä¸å¡é»è¾.ç¬¬ä¸æ 段.æ·ç¬æè1] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | //éç½®ä¿¡å· |
| | | 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); |
| | | 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"); |
| | | } |
| | | 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"); |
| | | } |
| | | } |
| | | |
| | | // åé£ç§ä¸æå
æ
ã |
| | | #endregion [èæ¬][20250611223832523][ä¸å¡é»è¾.å
æ
å¤ç] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:1020空æ¡ä¸çº¿ |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250616094224396][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1020空æ¡ä¸çº¿] |
| | | 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) |
| | | { |
| | | try |
| | | { |
| | | foreach (var item in new string[] { "1004", "1006", "1012", "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) |
| | | { |
| | | var b = TaskProcess.CreateTask("", Bssx, item, "空ä¸RGV", 5, new List<string> { Ræçç }, "RGV"); |
| | | if (b) |
| | | { |
| | | LogHelper.Debug($"è¾é线RGV空æä»»å¡ from:{Bssx}>to {item}å¼å§å建æå"); |
| | | Modular.Redis.RedisHelper.Add($"S{Bssx}Read.RtaskState_LAST", "1", out string msg); |
| | | //Conn.é»è®¤Redis.SetValue($"S{Bssx}Read.RtaskState_LAST", "1", $"S{Bssx}ReadQueue"); |
| | | Modular.Redis.RedisHelper.Add($"S{item}Read.R5空é²_LAST", "1", out string msg1); |
| | | //Conn.é»è®¤Redis.SetValue($"S{item}Read.R5空é²_LAST", "1", $"S{item}ReadQueue"); |
| | | break; |
| | | } |
| | | } |
| | | else if (R5 != 5 && R5空é²_LAST == 1) |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:æ·ç¬æè2 |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | Modular.Redis.RedisHelper.Add($"S{item}Read.R5空é²_LAST", "0", out string msg); |
| | | //Conn.é»è®¤Redis.SetValue($"S{item}Read.R5空é²_LAST", "0", $"S{item}ReadQueue"); |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250325083326611][ä¸å¡é»è¾.ç¬¬ä¸æ 段.æ·ç¬æè2] |
| | | |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "ThreadJS2", new object[] { tag }); |
| | | #endregion [èæ¬][20250325083326611][ä¸å¡é»è¾.ç¬¬ä¸æ 段.æ·ç¬æè2] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:èªæµè½¬æµç¨ |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250325085810885][ä¸å¡é»è¾.ç¬¬ä¸æ 段.èªæµè½¬æµç¨] |
| | | //foreach(var di in Settings.deviceInfos) |
| | | // if (di.deviceType == 2 || di.deviceType == 1) |
| | | // RunafterMac(di,true); |
| | | /// TODO mes ä¸åã æ¹ææºæ¢°èçæ§ - çæ§ç©ºçè¿æ¯æ»¡ç - èå¨mes ä»»å¡ã |
| | | |
| | | //LogHelper.Info($"设å¤ç¶æï¼ç»´å¸å°1ï¼ç»´å¸å°æè1.State:{Device.ç»´å¸å°æè1.State} "); |
| | | //Device.ç»´å¸å°æè1.ReadPLC("ç»´å¸å°æè1.R50", out object value); |
| | | //LogHelper.Info($"设å¤ç¶æï¼ç»´å¸å°1ï¼ç»´å¸å°æè1.R50:{value?.ToString()} "); |
| | | |
| | | //LogHelper.Info($"设å¤ç¶æï¼ç»´å¸å°2ï¼ç»´å¸å°æè2.State:{Device.ç»´å¸å°æè2.State} "); |
| | | //Device.ç»´å¸å°æè2.ReadPLC("ç»´å¸å°æè2.R50", out value); |
| | | //LogHelper.Info($"设å¤ç¶æï¼ç»´å¸å°2ï¼ç»´å¸å°æè2.R50:{value?.ToString()} "); |
| | | |
| | | //LogHelper.Info($"设å¤ç¶æï¼æ·ç¬1ï¼Jsæ·é¡º1.State:{Device.Jsæ·é¡º1.State} "); |
| | | //Device.Jsæ·é¡º1.ReadPLC("Jsæ·é¡º1.D1202", out value); |
| | | //LogHelper.Info($"设å¤ç¶æï¼æ·ç¬1 Jsæ·é¡º1.D1202:{value?.ToString()} "); |
| | | |
| | | //LogHelper.Info($"设å¤ç¶æï¼æ·ç¬2ï¼Jsæ·é¡º2.State:{Device.Jsæ·é¡º2.State} "); |
| | | //Device.Jsæ·é¡º2.ReadPLC("Jsæ·é¡º2.D1202", out value); |
| | | //LogHelper.Info($"设å¤ç¶æï¼æ·ç¬2 Jsæ·é¡º2.D1202:{value?.ToString()} "); |
| | | |
| | | |
| | | #endregion [èæ¬][20250325085810885][ä¸å¡é»è¾.ç¬¬ä¸æ 段.èªæµè½¬æµç¨] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:ç»´å¸å°æè1L |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250325083149366][ä¸å¡é»è¾.ç¬¬ä¸æ 段.ç»´ç³»å°1å·.ç»´å¸å°æè1L] |
| | | |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "Threadwxr1L", new object[] { tag }); |
| | | #endregion [èæ¬][20250325083149366][ä¸å¡é»è¾.ç¬¬ä¸æ 段.ç»´ç³»å°1å·.ç»´å¸å°æè1L] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:ç»´å¸å°æè1R |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250610002047005][ä¸å¡é»è¾.ç¬¬ä¸æ 段.ç»´ç³»å°1å·.ç»´å¸å°æè1R] |
| | | |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "Threadwxr1R", new object[] { tag }); |
| | | #endregion [èæ¬][20250610002047005][ä¸å¡é»è¾.ç¬¬ä¸æ 段.ç»´ç³»å°1å·.ç»´å¸å°æè1R] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:ç»´å¸å°æè2L |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250325083315503][ä¸å¡é»è¾.ç¬¬ä¸æ 段.ç»´ç³»å°2å·.ç»´å¸å°æè2L] |
| | | |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "Threadwxr2L", new object[] { tag }); |
| | | #endregion [èæ¬][20250325083315503][ä¸å¡é»è¾.ç¬¬ä¸æ 段.ç»´ç³»å°2å·.ç»´å¸å°æè2L] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:ç»´å¸å°æè2R |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250610002647095][ä¸å¡é»è¾.ç¬¬ä¸æ 段.ç»´ç³»å°2å·.ç»´å¸å°æè2R] |
| | | |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "Threadwxr2R", new object[] { tag }); |
| | | #endregion [èæ¬][20250610002647095][ä¸å¡é»è¾.ç¬¬ä¸æ 段.ç»´ç³»å°2å·.ç»´å¸å°æè2R] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:ä»»å¡ä¸å |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250325085542733][ä¸å¡é»è¾.ä»»å¡ä¸å] |
| | | |
| | | Func<TaskEntity, bool> myDelegate = (t) => RunTask(t); |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "ThreadTaskRun", new object[] { tag, myDelegate }); |
| | | #endregion [èæ¬][20250325085542733][ä¸å¡é»è¾.ä»»å¡ä¸å] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:ResolveMesTask |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250531163716255][ä¸å¡é»è¾.å¤çMESä»»å¡çº¿ç¨.ResolveMesTask] |
| | | //mes 任塿åã䏿®µä»»å¡å 夿®µä»»å¡ã |
| | | ToWMSMES.ResMesTask(); |
| | | #endregion [èæ¬][20250531163716255][ä¸å¡é»è¾.å¤çMESä»»å¡çº¿ç¨.ResolveMesTask] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | try |
| | | { |
| | | #region [èæ¬][20250605212104026][ä¸å¡é»è¾.SocketServer] |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "TaskEverythingRun"); |
| | | #endregion [èæ¬][20250605212104026][ä¸å¡é»è¾.SocketServer] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | } |
| | | /// <summary> |
| | | /// ç¨åºç段:å
æ
å¤ç |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250611223832523][ä¸å¡é»è¾.å
æ
å¤ç] |
| | | // - å
æ
交äºå¤çãã |
| | | Action<HaiKangOrderInfo> myDelegate = (t) => continueTask(t); |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "ThreadGrats", new object[] { tag, myDelegate }); |
| | | |
| | | // åé£ç§ä¸æå
æ
ã |
| | | #endregion [èæ¬][20250611223832523][ä¸å¡é»è¾.å
æ
å¤ç] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:1020空æ¡ä¸çº¿ |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250616094224396][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1020空æ¡ä¸çº¿] |
| | | |
| | | //1020 1023 空æ¡ä¸çº¿ |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "ThreadEdown", new object[] { tag }); |
| | | #endregion [èæ¬][20250616094224396][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1020空æ¡ä¸çº¿] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:1023空æ¡ä¸çº¿ |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250616094226654][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1023空æ¡ä¸çº¿] |
| | | //1023 空æ¡ä¸çº¿ |
| | | #endregion [èæ¬][20250616094226654][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1023空æ¡ä¸çº¿] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:å®å满ä¸çº¿ |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250616094632985][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.å®å满ä¸çº¿] |
| | | |
| | | //å®å满ä¸çº¿ 1008 1016 -> 1026 |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "ThreadDdown", new object[] { tag }); |
| | | #endregion [èæ¬][20250616094632985][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.å®å满ä¸çº¿] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:è½¬åæ»¡ä¸çº¿ |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250616094511322][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.è½¬åæ»¡ä¸çº¿] |
| | | |
| | | //è½¬åæ»¡ä¸çº¿ 1002 1010 - RGV2å·¥ä½ä¸å¯å° 1017 ä¸å¯ä¸å2å·¥ä½ä»»å¡ã |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "Thread0210Down", new object[] { tag }); |
| | | #endregion [èæ¬][20250616094511322][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.è½¬åæ»¡ä¸çº¿] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:䏿使£æµ |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250616095605911][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.䏿使£æµ] |
| | | |
| | | //䏿使£æµã 1003 å°ä½æ¶ å æ è¯ä¿¡å· å¹¶ ç»æºæ¢°æä¿¡å·ã |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "Thread䏿使£æµ", new object[] { tag }); |
| | | #endregion [èæ¬][20250616095605911][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.䏿使£æµ] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:1å·FNKæºæ¢°æå®æ |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250616095709155][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1å·FNKæºæ¢°æå®æ] |
| | | |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "ThreadFNK1Over", new object[] { tag }); |
| | | #endregion [èæ¬][20250616095709155][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1å·FNKæºæ¢°æå®æ] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:2å·FNKæºæ¢°æå®æ |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250616095733680][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.2å·FNKæºæ¢°æå®æ] |
| | | |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "ThreadFNK2Over", new object[] { tag }); |
| | | #endregion [èæ¬][20250616095733680][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.2å·FNKæºæ¢°æå®æ] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:Program1 |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250617085708084][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1019转满åºè¾é线.Program1] |
| | | |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "Thread1019Down", new object[] { tag }); |
| | | #endregion [èæ¬][20250617085708084][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1019转满åºè¾é线.Program1] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:Program1 |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250617085712101][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1025agvä¸ç©º.Program1] |
| | | |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "Thread1025Up", new object[] { tag }); |
| | | #endregion [èæ¬][20250617085712101][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1025agvä¸ç©º.Program1] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:Program1 |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250617085750712][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1022agvä¸ç©º.Program1] |
| | | |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "Thread1022Up", new object[] { tag }); |
| | | #endregion [èæ¬][20250617085750712][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1022agvä¸ç©º.Program1] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:Program1 |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250617085800942][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1030䏿¯æ.Program1] |
| | | |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "Thread1030Down", new object[] { tag }); |
| | | #endregion [èæ¬][20250617085800942][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1030䏿¯æ.Program1] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | |
| | | /// <summary> |
| | | /// ç¨åºç段:Program1 |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while (true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250617085809982][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.2030è¾é线ä¸å®å.Program1] |
| | | |
| | | AutoThread.InvokeMethod(AutoThread.Instance, "Thread2030Down", new object[] { tag }); |
| | | #endregion [èæ¬][20250617085809982][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.2030è¾é线ä¸å®å.Program1] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | //æ§è¡å¤æ¬¡ |
| | | for (int iii = 0; iii < 1; iii++) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250323151832119][ä¸å¡é»è¾.Program4] |
| | | |
| | | //LogHelper.Info($"<<<<<<<<<<<<<<<<<<<<<<>>>>>>>>>>>>>>>>>>"); |
| | | //LogHelper.Info($"<<<<<<<<<<<<<<<<<ç¨åºÂ·å¯å¨>>>>>>>>>>>>>>"); |
| | | |
| | | //// ä½¿ç¨æ¦æªå¨ |
| | | //var interceptor = new ConsoleInterceptor(); |
| | | //Console.SetOut(interceptor); |
| | | |
| | | //LogHelper.Info($"<<<<<<<<<<<<<<<<<<<<<<>>>>>>>>>>>>>>>>>>"); |
| | | //AnsiConsole.Markup("[underline red]Hello[/] World!"); |
| | | // AnsiConsole.Markup("[underline red]Hello[/] World!"); |
| | | #endregion [èæ¬][20250323151832119][ä¸å¡é»è¾.Program4] |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | 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) |
| | | { |
| | | Modular.Redis.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); |
| | | } |
| | | #endregion [èæ¬][20250616094224396][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1020空æ¡ä¸çº¿] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:1023空æ¡ä¸çº¿ |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250616094226654][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1023空æ¡ä¸çº¿] |
| | | //1023 空æ¡ä¸çº¿ |
| | | #endregion [èæ¬][20250616094226654][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1023空æ¡ä¸çº¿] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:å®å满ä¸çº¿ |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250616094632985][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.å®å满ä¸çº¿] |
| | | 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 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) |
| | | { |
| | | var b = TaskProcess.CreateTask("", Bssx, item, "满转1026", 5, new List<string> { Ræçç }, "RGV"); |
| | | if (b) |
| | | { |
| | | Modular.Redis.RedisHelper.Add($"S{Bssx}Read.RtaskState_LAST", "1", out string msg); |
| | | Modular.Redis.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) |
| | | { |
| | | Modular.Redis.RedisHelper.Add($"S{item}Read.R5空é²_LAST", "0", out string msg2); |
| | | } |
| | | } |
| | | else if (RtaskState != 3 && RtaskState_LAST == 1) |
| | | { |
| | | Modular.Redis.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); |
| | | } |
| | | #endregion [èæ¬][20250616094632985][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.å®å满ä¸çº¿] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:è½¬åæ»¡ä¸çº¿ |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250616094511322][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.è½¬åæ»¡ä¸çº¿] |
| | | //è½¬åæ»¡ä¸çº¿ 1002 1010 - RGV2å·¥ä½ä¸å¯å° 1017 ä¸å¯ä¸å2å·¥ä½ä»»å¡ã |
| | | 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 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) |
| | | { |
| | | var b = TaskProcess.CreateTask("", Bssx, item, "满转1017", 5, new List<string> { Ræçç }, "RGV"); |
| | | if (b) |
| | | { |
| | | Modular.Redis.RedisHelper.Add($"S{Bssx}Read.RtaskState_LAST", "1", out string msg); |
| | | Modular.Redis.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) |
| | | { |
| | | Modular.Redis.RedisHelper.Add($"S{item}Read.R5空é²_LAST", "0", out string msg1); |
| | | } |
| | | } |
| | | else if (RtaskState != 3 && RtaskState_LAST == 1) |
| | | { |
| | | Modular.Redis.RedisHelper.Add($"S{Bssx}Read.RtaskState_LAST", "0", out string msg); |
| | | } |
| | | System.Threading.Thread.Sleep(2000); |
| | | } |
| | | #endregion [èæ¬][20250616094511322][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.è½¬åæ»¡ä¸çº¿] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:䏿使£æµ |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250616095605911][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.䏿使£æµ] |
| | | //䏿使£æµã 1003 å°ä½æ¶ å æ è¯ä¿¡å· å¹¶ ç»æºæ¢°æä¿¡å·ã |
| | | foreach (var ssx in new string[] { "1003", "1005", "1011", "1013" }) |
| | | { |
| | | var RArrive = (System.UInt16)System.Convert.ChangeType(Conn.é»è®¤Redis.GetValue($"FNK1003051113.RArrive{ssx}"), typeof(System.UInt16)); |
| | | var RArriveLast = (System.UInt16)System.Convert.ChangeType(Conn.é»è®¤Redis.GetValue($"FNK1003051113.RArrive{ssx}_LAST"), typeof(System.UInt16)); |
| | | if (RArrive == 1 && RArriveLast == 0) |
| | | { |
| | | if (ssx == "1005") |
| | | { |
| | | tag.FNK1.D2210 = 1; |
| | | tag.SF䏿ä½.RArrive1005_LAST = 1; |
| | | |
| | | tag.SF䏿ä½.WRelease1005 = 0; |
| | | tag.SF䏿ä½.WSafe0305 = 0; |
| | | } |
| | | else if (ssx == "1003") |
| | | { |
| | | tag.FNK2.D2215 = 1; |
| | | tag.SF䏿ä½.RArrive1003_LAST = 1; |
| | | |
| | | tag.SF䏿ä½.WRelease1003 = 0; |
| | | tag.SF䏿ä½.WSafe0305 = 0; |
| | | } |
| | | else if (ssx == "1013") |
| | | { |
| | | tag.FNK2.D2210 = 1; |
| | | tag.SF䏿ä½.RArrive1013_LAST = 1; |
| | | |
| | | tag.SF䏿ä½.WRelease1013 = 0; |
| | | tag.SF䏿ä½.WSafe1113 = 0; |
| | | } |
| | | else if (ssx == "1011") |
| | | { |
| | | tag.FNK2.D2215 = 1; |
| | | tag.SF䏿ä½.RArrive1011_LAST = 1; |
| | | |
| | | tag.SF䏿ä½.WRelease1011 = 0; |
| | | tag.SF䏿ä½.WSafe1113 = 0; |
| | | } |
| | | } |
| | | else if (RArrive == 0 && RArriveLast == 1) |
| | | { |
| | | Modular.Redis.RedisHelper.Add($"FNK1003051113.RArrive{ssx}_LAST", "0", out string msg); |
| | | } |
| | | } |
| | | #endregion [èæ¬][20250616095605911][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.䏿使£æµ] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:1å·FNKæºæ¢°æå®æ |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250616095709155][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1å·FNKæºæ¢°æå®æ] |
| | | if (tag.FNK1.D2212 == 1 && tag.FNK1.D2212_LAST == 0) |
| | | { |
| | | tag.FNK1.D2210 = 0; |
| | | tag.FNK1.D2212_LAST = 1; |
| | | |
| | | tag.SF䏿ä½.WRelease1005 = 1; |
| | | tag.SF䏿ä½.WSafe0305 = 1; |
| | | } |
| | | else if (tag.FNK1.D2212 == 0 && tag.FNK1.D2212_LAST == 1) |
| | | { |
| | | tag.FNK1.D2212_LAST = 0; |
| | | } |
| | | if (tag.FNK1.D2217 == 1 && tag.FNK1.D2217_LAST == 0) |
| | | { |
| | | tag.FNK1.D2215 = 0; |
| | | tag.FNK1.D2217_LAST = 1; |
| | | |
| | | tag.SF䏿ä½.WRelease1003 = 1; |
| | | tag.SF䏿ä½.WSafe0305 = 1; |
| | | } |
| | | else if (tag.FNK1.D2217 == 0 && tag.FNK1.D2217_LAST == 1) |
| | | tag.FNK1.D2217_LAST = 0; |
| | | |
| | | #endregion [èæ¬][20250616095709155][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1å·FNKæºæ¢°æå®æ] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:2å·FNKæºæ¢°æå®æ |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250616095733680][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.2å·FNKæºæ¢°æå®æ] |
| | | if (tag.FNK2.D2212 == 1 && tag.FNK2.D2212_LAST == 0) |
| | | { |
| | | tag.FNK2.D2210 = 0; |
| | | tag.FNK2.D2212_LAST = 1; |
| | | |
| | | tag.SF䏿ä½.WRelease1013 = 1; |
| | | tag.SF䏿ä½.WSafe1113 = 1; |
| | | } |
| | | else if (tag.FNK2.D2212 == 0 && tag.FNK2.D2212_LAST == 1) |
| | | { |
| | | tag.FNK2.D2212_LAST = 0; |
| | | } |
| | | if (tag.FNK2.D2217 == 1 && tag.FNK2.D2217_LAST == 0) |
| | | { |
| | | tag.FNK2.D2215 = 0; |
| | | tag.FNK2.D2217_LAST = 1; |
| | | |
| | | tag.SF䏿ä½.WRelease1011 = 1; |
| | | tag.SF䏿ä½.WSafe1113 = 1; |
| | | } |
| | | else if (tag.FNK2.D2217 == 0 && tag.FNK2.D2217_LAST == 1) |
| | | tag.FNK2.D2217_LAST = 0; |
| | | #endregion [èæ¬][20250616095733680][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.2å·FNKæºæ¢°æå®æ] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:Program1 |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250617085708084][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1019转满åºè¾é线.Program1] |
| | | |
| | | Console.WriteLine($"1019ä»»å¡ç¶æï¼{tag.SA1019.RtaskState}- barcode:{tag.SA1019.Ræçç }- 空é²{tag.SA1019.R5空é²}"); |
| | | #endregion [èæ¬][20250617085708084][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1019转满åºè¾é线.Program1] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:Program1 |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250617085712101][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1025agvä¸ç©º.Program1] |
| | | |
| | | Console.WriteLine($"SA1025 ä»»å¡ç¶æï¼{tag.SA1025.RtaskState}- 空é²{tag.SA1025.R5空é²}"); |
| | | #endregion [èæ¬][20250617085712101][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1025agvä¸ç©º.Program1] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:Program1 |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250617085750712][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1022agvä¸ç©º.Program1] |
| | | |
| | | Console.WriteLine($"SA1022 ä»»å¡ç¶æï¼{tag.SA1022.RtaskState}- 空é²{tag.SA1022.R5空é²}"); |
| | | #endregion [èæ¬][20250617085750712][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1022agvä¸ç©º.Program1] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:Program1 |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250617085800942][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1030䏿¯æ.Program1] |
| | | |
| | | Console.WriteLine($"SA1030 ä»»å¡ç¶æï¼{tag.SA1030.RtaskState}- 空é²{tag.SA1030.R5空é²}-->对åºç»ç¹2001>空é²5ï¼{tag.SA2001.R5空é²}"); |
| | | #endregion [èæ¬][20250617085800942][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.1030䏿¯æ.Program1] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | /// <summary> |
| | | /// ç¨åºç段:Program1 |
| | | /// æè¿°: |
| | | /// </summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | System.Threading.Thread.CurrentThread.IsBackground = true; |
| | | ExitJudgeStack.Push(0); |
| | | //ä¸ç´æ§è¡ï¼ç´å°æ»¡è¶³ç»ææ¡ä»¶ |
| | | while(true) |
| | | { |
| | | if (IsExitApp) { break; } |
| | | try |
| | | { |
| | | #region [èæ¬][20250617085809982][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.2030è¾é线ä¸å®å.Program1] |
| | | |
| | | Console.WriteLine($"SA2030 ä»»å¡ç¶æï¼{tag.SA2030.RtaskState}- 空é²{tag.SA2030.R5空é²} - barcode:{tag.SA2030.Ræçç }"); |
| | | #endregion [èæ¬][20250617085809982][ä¸å¡é»è¾.æµç¨2çå¤ççè¿åº.2030è¾é线ä¸å®å.Program1] |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | } |
| | | } |
| | | ExitJudgeStack.TryPop(out int exitJudgeVal); |
| | | }); |
| | | |
| | | } |
| | | /// <summary> |
| | | /// <summary> |
| | | /// View1å
³éäºä»¶ |
| | | /// </summary> |
| | | /// <param name="sender"></param> |
| | | /// <param name="e"></param> |
| | | public void View1_CloseEvent(object sender, System.ComponentModel.CancelEventArgs e) |
| | | { |
| | | |
| | | try |
| | | { |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => { MessageBox.Show("ç¨åºæ£å¨å
³éï¼è¯·çå¾
..."); }); |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | try |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Debug("[å
³éå¤ç][Start]å
³éHttpæå¡"); |
| | | if(HttpSvcHost!=null) |
| | | { |
| | | HttpSvcHost.Stop(); |
| | | } |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Debug("[å
³éå¤ç][End]å
³éHttpæå¡"); |
| | | } |
| | | public void View1_CloseEvent(object sender, System.ComponentModel.CancelEventArgs e) |
| | | { |
| | | |
| | | try |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Debug("[å
³éå¤ç][Start]夿ä¸å¡å¤çç¶æ"); |
| | | IsExitApp = true; |
| | | //int exitCnt = 0; |
| | | while |
| | | ( |
| | | ExitJudgeStack.Count > 0 |
| | | ) |
| | | { |
| | | System.Threading.Thread.Sleep(100); |
| | | //++exitCnt; |
| | | //10ç§æªç»æå强å¶å
³é |
| | | //if (exitCnt >= 100) |
| | | //{ |
| | | // break; |
| | | //} |
| | | } |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Debug("[å
³éå¤ç][End]夿ä¸å¡å¤çç¶æ"); |
| | | } |
| | | |
| | | try |
| | | { |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => { MessageBox.Show("ç¨åºæ£å¨å
³éï¼è¯·çå¾
..."); }); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | try |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Debug("[å
³éå¤ç][Start]å
³éHttpæå¡"); |
| | | if (HttpSvcHost != null) |
| | | { |
| | | HttpSvcHost.Stop(); |
| | | } |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Debug("[å
³éå¤ç][End]å
³éHttpæå¡"); |
| | | } |
| | | |
| | | try |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Debug("[å
³éå¤ç][Start]夿ä¸å¡å¤çç¶æ"); |
| | | IsExitApp = true; |
| | | //int exitCnt = 0; |
| | | while |
| | | ( |
| | | ExitJudgeStack.Count > 0 |
| | | ) |
| | | { |
| | | System.Threading.Thread.Sleep(100); |
| | | //++exitCnt; |
| | | //10ç§æªç»æå强å¶å
³é |
| | | //if (exitCnt >= 100) |
| | | //{ |
| | | // break; |
| | | //} |
| | | } |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Debug("[å
³éå¤ç][End]夿ä¸å¡å¤çç¶æ"); |
| | | } |
| | | |
| | | e.Cancel = true; |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | try |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Debug("[å
³éå¤ç][Start]å
³éPLC"); |
| | | Device.ç»´å¸å°æè1?.Stop(); |
| | | Device.ç»´å¸å°æè2?.Stop(); |
| | | Device.Jsæ·é¡º1?.Stop(); |
| | | Device.Jsæ·é¡º2?.Stop(); |
| | | Device.påé£ç§1ä¸çº¿?.Stop(); |
| | | Device.A1025æ¾è´§äº¤äº?.Stop(); |
| | | Device.A1022æ¾è´§äº¤äº?.Stop(); |
| | | Device.A1019å货交äº?.Stop(); |
| | | Device.A1030å货交äº?.Stop(); |
| | | Device.SSXReadTemp?.Stop(); |
| | | Device.S1019Read?.Stop(); |
| | | Device.S1022Read?.Stop(); |
| | | Device.S1025Read?.Stop(); |
| | | Device.S1017Read?.Stop(); |
| | | Device.S1023Read?.Stop(); |
| | | Device.S1020Read?.Stop(); |
| | | Device.S1002Read?.Stop(); |
| | | Device.S1004Read?.Stop(); |
| | | Device.S1006Read?.Stop(); |
| | | Device.S1008Read?.Stop(); |
| | | Device.S1010Read?.Stop(); |
| | | Device.S1012Read?.Stop(); |
| | | Device.S1014Read?.Stop(); |
| | | Device.S1016Read?.Stop(); |
| | | Device.FNK1003051113?.Stop(); |
| | | Device.SSX1003051113?.Stop(); |
| | | Device.S1026Read?.Stop(); |
| | | Device.S1030Read?.Stop(); |
| | | Device.S2001Read?.Stop(); |
| | | Device.S2030Read?.Stop(); |
| | | Device.A2001æ¾è´§äº¤äº?.Stop(); |
| | | Device.A2030å货交äº?.Stop(); |
| | | Device.RGV?.Stop(); |
| | | Device.påé£ç§2ä¸çº¿?.Stop(); |
| | | Device.påé£ç§3ä¸çº¿?.Stop(); |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Debug("[å
³éå¤ç][End]å
³éPLC"); |
| | | } |
| | | try |
| | | { |
| | | |
| | | Conn.é»è®¤æ¥å¿.Debug("[å
³éå¤ç][Start]夿PLCç¶æ"); |
| | | //int exitCnt = 0; |
| | | while |
| | | ( |
| | | false |
| | | || (Device.ç»´å¸å°æè1 == null ? false : Device.ç»´å¸å°æè1.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.ç»´å¸å°æè2 == null ? false : Device.ç»´å¸å°æè2.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.Jsæ·é¡º1 == null ? false : Device.Jsæ·é¡º1.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.Jsæ·é¡º2 == null ? false : Device.Jsæ·é¡º2.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.påé£ç§1ä¸çº¿ == null ? false : Device.påé£ç§1ä¸çº¿.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.A1025æ¾è´§äº¤äº == null ? false : Device.A1025æ¾è´§äº¤äº.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.A1022æ¾è´§äº¤äº == null ? false : Device.A1022æ¾è´§äº¤äº.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.A1019åè´§äº¤äº == null ? false : Device.A1019å货交äº.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.A1030åè´§äº¤äº == null ? false : Device.A1030å货交äº.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.SSXReadTemp == null ? false : Device.SSXReadTemp.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1019Read == null ? false : Device.S1019Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1022Read == null ? false : Device.S1022Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1025Read == null ? false : Device.S1025Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1017Read == null ? false : Device.S1017Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1023Read == null ? false : Device.S1023Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1020Read == null ? false : Device.S1020Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1002Read == null ? false : Device.S1002Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1004Read == null ? false : Device.S1004Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1006Read == null ? false : Device.S1006Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1008Read == null ? false : Device.S1008Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1010Read == null ? false : Device.S1010Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1012Read == null ? false : Device.S1012Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1014Read == null ? false : Device.S1014Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1016Read == null ? false : Device.S1016Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.FNK1003051113 == null ? false : Device.FNK1003051113.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.SSX1003051113 == null ? false : Device.SSX1003051113.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1026Read == null ? false : Device.S1026Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1030Read == null ? false : Device.S1030Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S2001Read == null ? false : Device.S2001Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S2030Read == null ? false : Device.S2030Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.A2001æ¾è´§äº¤äº == null ? false : Device.A2001æ¾è´§äº¤äº.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.A2030åè´§äº¤äº == null ? false : Device.A2030å货交äº.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.RGV == null ? false : Device.RGV.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.påé£ç§2ä¸çº¿ == null ? false : Device.påé£ç§2ä¸çº¿.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.påé£ç§3ä¸çº¿ == null ? false : Device.påé£ç§3ä¸çº¿.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | ) |
| | | { |
| | | System.Threading.Thread.Sleep(1000); |
| | | //++exitCnt; |
| | | //10ç§æªç»æå强å¶å
³é |
| | | //if (exitCnt >= 100) |
| | | //{ |
| | | // break; |
| | | //} |
| | | } |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Debug("[å
³éå¤ç][End]夿PLCç¶æ"); |
| | | } |
| | | Application.Current.Dispatcher.Invoke(() => { Environment.Exit(0); }); |
| | | }); |
| | | |
| | | //System.Windows.Application.Current.Shutdown(); |
| | | } |
| | | /// <summary> |
| | | System.Threading.Tasks.Task.Factory.StartNew(() => |
| | | { |
| | | try |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Debug("[å
³éå¤ç][Start]å
³éPLC"); |
| | | Device.ç»´å¸å°æè1?.Stop(); |
| | | Device.ç»´å¸å°æè2?.Stop(); |
| | | Device.Jsæ·é¡º1?.Stop(); |
| | | Device.Jsæ·é¡º2?.Stop(); |
| | | Device.påé£ç§1ä¸çº¿?.Stop(); |
| | | Device.A1025æ¾è´§äº¤äº?.Stop(); |
| | | Device.A1022æ¾è´§äº¤äº?.Stop(); |
| | | Device.A1019å货交äº?.Stop(); |
| | | Device.A1030å货交äº?.Stop(); |
| | | Device.SSXReadTemp?.Stop(); |
| | | Device.S1019Read?.Stop(); |
| | | Device.S1022Read?.Stop(); |
| | | Device.S1025Read?.Stop(); |
| | | Device.S1017Read?.Stop(); |
| | | Device.S1023Read?.Stop(); |
| | | Device.S1020Read?.Stop(); |
| | | Device.S1002Read?.Stop(); |
| | | Device.S1004Read?.Stop(); |
| | | Device.S1006Read?.Stop(); |
| | | Device.S1008Read?.Stop(); |
| | | Device.S1010Read?.Stop(); |
| | | Device.S1012Read?.Stop(); |
| | | Device.S1014Read?.Stop(); |
| | | Device.S1016Read?.Stop(); |
| | | Device.FNK1003051113?.Stop(); |
| | | Device.SSX1003051113?.Stop(); |
| | | Device.S1026Read?.Stop(); |
| | | Device.S1030Read?.Stop(); |
| | | Device.S2001Read?.Stop(); |
| | | Device.S2030Read?.Stop(); |
| | | Device.A2001æ¾è´§äº¤äº?.Stop(); |
| | | Device.A2030å货交äº?.Stop(); |
| | | Device.RGV?.Stop(); |
| | | Device.påé£ç§2ä¸çº¿?.Stop(); |
| | | Device.påé£ç§3ä¸çº¿?.Stop(); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Debug("[å
³éå¤ç][End]å
³éPLC"); |
| | | } |
| | | try |
| | | { |
| | | |
| | | Conn.é»è®¤æ¥å¿.Debug("[å
³éå¤ç][Start]夿PLCç¶æ"); |
| | | //int exitCnt = 0; |
| | | while |
| | | ( |
| | | false |
| | | || (Device.ç»´å¸å°æè1 == null ? false : Device.ç»´å¸å°æè1.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.ç»´å¸å°æè2 == null ? false : Device.ç»´å¸å°æè2.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.Jsæ·é¡º1 == null ? false : Device.Jsæ·é¡º1.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.Jsæ·é¡º2 == null ? false : Device.Jsæ·é¡º2.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.påé£ç§1ä¸çº¿ == null ? false : Device.påé£ç§1ä¸çº¿.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.A1025æ¾è´§äº¤äº == null ? false : Device.A1025æ¾è´§äº¤äº.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.A1022æ¾è´§äº¤äº == null ? false : Device.A1022æ¾è´§äº¤äº.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.A1019åè´§äº¤äº == null ? false : Device.A1019å货交äº.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.A1030åè´§äº¤äº == null ? false : Device.A1030å货交äº.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.SSXReadTemp == null ? false : Device.SSXReadTemp.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1019Read == null ? false : Device.S1019Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1022Read == null ? false : Device.S1022Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1025Read == null ? false : Device.S1025Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1017Read == null ? false : Device.S1017Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1023Read == null ? false : Device.S1023Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1020Read == null ? false : Device.S1020Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1002Read == null ? false : Device.S1002Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1004Read == null ? false : Device.S1004Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1006Read == null ? false : Device.S1006Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1008Read == null ? false : Device.S1008Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1010Read == null ? false : Device.S1010Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1012Read == null ? false : Device.S1012Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1014Read == null ? false : Device.S1014Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1016Read == null ? false : Device.S1016Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.FNK1003051113 == null ? false : Device.FNK1003051113.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.SSX1003051113 == null ? false : Device.SSX1003051113.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1026Read == null ? false : Device.S1026Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S1030Read == null ? false : Device.S1030Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S2001Read == null ? false : Device.S2001Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.S2030Read == null ? false : Device.S2030Read.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.A2001æ¾è´§äº¤äº == null ? false : Device.A2001æ¾è´§äº¤äº.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.A2030åè´§äº¤äº == null ? false : Device.A2030å货交äº.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.RGV == null ? false : Device.RGV.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.påé£ç§2ä¸çº¿ == null ? false : Device.påé£ç§2ä¸çº¿.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | || (Device.påé£ç§3ä¸çº¿ == null ? false : Device.påé£ç§3ä¸çº¿.State != GZ.Device.PLC.PlcRunState.Stoped) |
| | | ) |
| | | { |
| | | System.Threading.Thread.Sleep(1000); |
| | | //++exitCnt; |
| | | //10ç§æªç»æå强å¶å
³é |
| | | //if (exitCnt >= 100) |
| | | //{ |
| | | // break; |
| | | //} |
| | | } |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Debug("[å
³éå¤ç][End]夿PLCç¶æ"); |
| | | } |
| | | Application.Current.Dispatcher.Invoke(() => { Environment.Exit(0); }); |
| | | }); |
| | | |
| | | //System.Windows.Application.Current.Shutdown(); |
| | | } |
| | | /// <summary> |
| | | /// View1åå§å |
| | | /// </summary> |
| | | /// <param name="sender"></param> |
| | | /// <param name="e"></param> |
| | | public void View1_Init(object sender, RoutedEventArgs e) |
| | | { |
| | | } |
| | | #endregion |
| | | |
| | | #region 忢tab页 |
| | | public void tab_SelectionChanged(object sender, EventArgs e) |
| | | { |
| | | //TabItem ti = (sender as TabControl).SelectedItem as TabItem; |
| | | //MessageBox.Show(ti.Name); |
| | | } |
| | | #endregion |
| | | |
| | | #region Httpæå¡çå¬ |
| | | private void HttpSvcListenerCallback(IAsyncResult ar) |
| | | { |
| | | try |
| | | { |
| | | HttpSvcHost.BeginGetContext(HttpSvcListenerCallback, null); |
| | | System.Net.HttpListenerContext context = HttpSvcHost.EndGetContext(ar); |
| | | System.Net.HttpListenerRequest request = context.Request; |
| | | System.Net.HttpListenerResponse response = context.Response; |
| | | switch(request.LocalEndPoint.ToString()) |
| | | { |
| | | case "10.221.55.116:8808": |
| | | { |
| | | using (var reader = new System.IO.StreamReader(request.InputStream, System.Text.Encoding.UTF8)) |
| | | { |
| | | string requestJson = reader.ReadToEnd(); |
| | | public void View1_Init(object sender, RoutedEventArgs e) |
| | | { |
| | | } |
| | | #endregion |
| | | |
| | | string respstr = HttpSvcListenerCallback_he(request.HttpMethod,request.Url.AbsolutePath,requestJson,out System.Net.HttpStatusCode statusCode); |
| | | #region View2äºä»¶ |
| | | /// <summary> |
| | | /// View2æå¼äºä»¶ |
| | | /// </summary> |
| | | /// <param name="sender"></param> |
| | | /// <param name="e"></param> |
| | | public void View2_LoadEvent(object sender, RoutedEventArgs e) |
| | | { |
| | | |
| | | string logContent=""; |
| | | logContent += $"\r\n[{request.HttpMethod}]{request.Url.AbsolutePath}"; |
| | | logContent += $"\r\n[request]{requestJson}"; |
| | | logContent += $"\r\n[response]{respstr}"; |
| | | 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); |
| | | response.Close(); |
| | | } |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | catch(Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | } |
| | | 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; |
| | | |
| | | |
| | | |
| | | } |
| | | /// <summary> |
| | | /// View2å
³éäºä»¶ |
| | | /// </summary> |
| | | /// <param name="sender"></param> |
| | | /// <param name="e"></param> |
| | | public void View2_CloseEvent(object sender, System.ComponentModel.CancelEventArgs e) |
| | | { |
| | | |
| | | |
| | | } |
| | | /// <summary> |
| | | /// View2åå§å |
| | | /// </summary> |
| | | /// <param name="sender"></param> |
| | | /// <param name="e"></param> |
| | | public void View2_Init(object sender, RoutedEventArgs e) |
| | | { |
| | | } |
| | | #endregion |
| | | |
| | | #region 忢tab页 |
| | | public void tab_SelectionChanged(object sender, EventArgs e) |
| | | { |
| | | //TabItem ti = (sender as TabControl).SelectedItem as TabItem; |
| | | //MessageBox.Show(ti.Name); |
| | | } |
| | | #endregion |
| | | |
| | | #region Httpæå¡çå¬ |
| | | private async void HttpSvcListenerCallback(IAsyncResult ar) |
| | | { |
| | | System.Net.HttpListenerContext context = null; |
| | | try |
| | | { |
| | | HttpSvcHost.BeginGetContext(HttpSvcListenerCallback, null); |
| | | context = HttpSvcHost.EndGetContext(ar); |
| | | System.Net.HttpListenerRequest request = context.Request; |
| | | System.Net.HttpListenerResponse response = context.Response; |
| | | switch (request.LocalEndPoint.ToString()) |
| | | { |
| | | case "10.221.55.117:8808": |
| | | { |
| | | using (var reader = new System.IO.StreamReader(request.InputStream, System.Text.Encoding.UTF8)) |
| | | { |
| | | string requestJson = reader.ReadToEnd(); |
| | | System.Net.HttpStatusCode statusCode = 0; |
| | | string respstr = await Task.Run(() => |
| | | { |
| | | return 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); |
| | | // 弿¥åå
¥ååº |
| | | await response.OutputStream.WriteAsync(bytstr, 0, bytstr.Length); |
| | | |
| | | } |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | } |
| | | finally |
| | | { |
| | | context?.Response.Close(); |
| | | } |
| | | } |
| | | 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); |
| | | OperateHKTaskStatus(model); |
| | | return JsonConvert.SerializeObject(new HkReturnResult { reqCode = model.reqCode }); |
| | | } |
| | | case "/api/Wcs/CreateTask": |
| | | { |
| | | statusCode = System.Net.HttpStatusCode.OK; |
| | | |
| | | } |
| | | 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; |
| | | |
| | | } |
| | | 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; |
| | | |
| | | } |
| | | 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 "/inddddddddddddddddd": |
| | | { |
| | | statusCode = System.Net.HttpStatusCode.OK; |
| | | // å¤å¶å°case ä¸ |
| | | //var _ when System.Text.RegularExpressions.Regex.IsMatch(path, @"\.(html|ico|js|css)(\?.*)?$", System.Text.RegularExpressions.RegexOptions.IgnoreCase) |
| | | var filePath = System.IO.Path.Combine("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 ""; |
| | | } |
| | | } |
| | | #endregion |
| | | } |
| | | } |
| | | } |
| | | break; |
| | | } |
| | | case "GET": |
| | | { |
| | | switch (path) |
| | | { |
| | | case var _ when System.Text.RegularExpressions.Regex.IsMatch(path, @"\.(html|ico|js|css)(\?.*)?$", System.Text.RegularExpressions.RegexOptions.IgnoreCase): |
| | | { |
| | | statusCode = System.Net.HttpStatusCode.OK; |
| | | // å¤å¶å°case ä¸ |
| | | //var _ when System.Text.RegularExpressions.Regex.IsMatch(path, @"\.(html|ico|js|css)(\?.*)?$", System.Text.RegularExpressions.RegexOptions.IgnoreCase) |
| | | var filePath = /*Directory.GetCurrentDirectory() + "\\Static" + "\\" + path.Substring(1);*/System.IO.Path.Combine(Directory.GetCurrentDirectory() + "\\Static", path.Substring(1)); |
| | | return File.ReadAllText(filePath); |
| | | } |
| | | } |
| | | break; |
| | | } |
| | | } |
| | | statusCode = System.Net.HttpStatusCode.NotFound; |
| | | return ""; |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | Conn.é»è®¤æ¥å¿.Error(ex.ToString()); |
| | | statusCode = System.Net.HttpStatusCode.InternalServerError; |
| | | return ""; |
| | | } |
| | | } |
| | | #endregion |
| | | } |
| | | } |
| | | |