| | |
| | | } |
| | | try |
| | | { |
| | | LogHelper.Info("ä»»å¡ä¸å Rgv ä»»å¡ è¿å
¥"); |
| | | #region Rgv |
| | | |
| | | LogHelper.Info($"æ¥çRGV çµéï¼ã{tag.RGV.Rå½åçµé}ã å
çµç¶æï¼ã{tag.RGV.Rå
çµç¶æ}ã æ
é代ç ï¼ã{tag.RGV.RgvrunError}ã"); |
| | | |
| | | if (tag.RGV.taskend == 125) |
| | | { |
| | | System.Threading.Thread.Sleep(3000); |
| | | return; |
| | | } |
| | | LogHelper.Info("ä»»å¡ä¸å Rgv ä»»å¡ è¿å
¥"); |
| | | |
| | | var task1Isrun = false; |
| | | if (tag.RGV.ReadTask1No > 0 && tag.RGV.bit1taskOver != 1) |
| | | { |
| | |
| | | if (task2Isrun) |
| | | mes += tag.RGV.ReadTask2No + "æ§è¡ä¸..."; |
| | | LogHelper.Info($"{mes} ä¸è½ä¸åæ°ä»»å¡ã"); |
| | | throw new Exception($"{mes} ä¸è½ä¸åæ°ä»»å¡ã"); |
| | | System.Threading.Thread.Sleep(3000); |
| | | return; |
| | | } |
| | | var thisOver = 0; |
| | | TaskEntity task1 = null; |
| | |
| | | if (task1.S_B_STATE == "åè´§å®æ") |
| | | { |
| | | task1.S_B_STATE = "宿"; |
| | | tag.RGV.ReadTask1No = 0; |
| | | } |
| | | else |
| | | { |
| | | task1.S_B_STATE = "åè´§å®æ"; |
| | | } |
| | | tag.RGV.bit1taskOver = 0; |
| | | LogHelper.Info($"RGV 1å·¥ä½ä»»å¡{task1.S_TASK_NO} ç¶æåæ¢ä¸º{task1.S_B_STATE}"); |
| | | //tag.RGV.bit1taskOver_LAST = 1; |
| | | RedisHelper.Add($"RGV.bit1taskOver_LAST", "1", out string msg); |
| | |
| | | if (task2.S_B_STATE == "åè´§å®æ") |
| | | { |
| | | task2.S_B_STATE = "宿"; |
| | | tag.RGV.ReadTask2No = 0; |
| | | } |
| | | else |
| | | { |
| | | task2.S_B_STATE = "åè´§å®æ"; |
| | | } |
| | | tag.RGV.bit2taskOver = 0; |
| | | LogHelper.Info($"RGV 2å·¥ä½ä»»å¡{task2.S_TASK_NO} ç¶æåæ¢ä¸º{task2.S_B_STATE}"); |
| | | RedisHelper.Add($"RGV.bit2taskOver_LAST", "1", out string msg); |
| | | LogHelper.Info($"RGV 2å·¥ä½ä»»å¡åå¤ç"); |
| | |
| | | LogHelper.Info($"RGV 2工使²¡æä»»å¡ã"); |
| | | } |
| | | |
| | | |
| | | |
| | | //if (thisOver > 0) |
| | | { |
| | | var v2 = RedisHelper.Get<WriteGroupEntity>("RGVQueue", out string rev); |
| | | if (v2 != null) |
| | | { |
| | | LogHelper.Info($"RGVQueue 读å°ç»æ-{JsonConvert.SerializeObject(v2)} \n ä¸ååè¿è¡æ¸
é¤ã"); |
| | | var b = RedisHelper.Remove("RGVQueue", out rev); |
| | | } |
| | | } |
| | | //{ |
| | | // var v2 = RedisHelper.Get<WriteGroupEntity>("RGVQueue", out string rev); |
| | | // if (v2 != null) |
| | | // { |
| | | // LogHelper.Info($"RGVQueue 读å°ç»æ-{JsonConvert.SerializeObject(v2)} \n ä¸ååè¿è¡æ¸
é¤ã"); |
| | | // var b = RedisHelper.Remove("RGVQueue", out rev); |
| | | // } |
| | | //} |
| | | |
| | | ///1 æè´§ å°±2 åã 1 没货 å°±2 å¸è´§ï¼ é½æè´§ å°±1å¸è´§ã 齿²¡è´§ å°±1å¸ |
| | | var tklist = taskservice.FindList(x => x.S_B_STATE == "æªæ§è¡" && x.S_WORK_MODE == "RGV").OrderBy(x => x.T_CREATE).ToList(); |