From 880794f63e27b64ae03c40afc55a34928d090d57 Mon Sep 17 00:00:00 2001
From: 野心家 <1051256694@qq.com>
Date: 星期三, 28 五月 2025 10:08:18 +0800
Subject: [PATCH] #ZH

---
 src/main/java/com/zy/core/thread/RgvThread.java |  101 +++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 79 insertions(+), 22 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/RgvThread.java b/src/main/java/com/zy/core/thread/RgvThread.java
index 879779c..b755b34 100644
--- a/src/main/java/com/zy/core/thread/RgvThread.java
+++ b/src/main/java/com/zy/core/thread/RgvThread.java
@@ -53,6 +53,7 @@
     private Long trackBenchmark = 1L;
     //  # 閬胯璺濈
     private Long avoidDistance = 5000L;
+    private String errorRgv = "-";
 
     /**
      * 宸ヤ綅1澶嶄綅淇″彿
@@ -117,7 +118,7 @@
                     DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                     deviceErrorService.addDeviceError("rgv", slave.getId(), "rgv杩炴帴澶辫触"+e.getMessage());
                 } catch (Exception e2){
-                    log.error("e2:"+e2.getMessage());
+//                    log.error("e2:"+e2.getMessage());
                 }
                 initRgv();
 //                e.printStackTrace();
@@ -139,7 +140,7 @@
                     DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                     deviceErrorService.addDeviceError("rgv", slave.getId(), "RGV鏁版嵁璇诲彇绾跨▼寮傚父"+e.getMessage());
                 } catch (Exception e2){
-                    log.error("e2:"+e2.getMessage());
+//                    log.error("e2:"+e2.getMessage());
                 }
                 initRgv();
 //                e.printStackTrace();
@@ -172,7 +173,7 @@
                     DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                     deviceErrorService.addDeviceError("rgv", slave.getId(), "RGV鏁版嵁浠诲姟涓嬪彂澶嶄綅绾跨▼寮傚父"+e.getMessage());
                 } catch (Exception e2){
-                    log.error("e2:"+e2.getMessage());
+//                    log.error("e2:"+e2.getMessage());
                 }
                 initRgv();
 //                e.printStackTrace();
@@ -298,7 +299,7 @@
 //                System.out.println(JSON.toJSON(rgvRun));
 
                 // 浼戠湢 1 绉�
-                if (System.currentTimeMillis() - rgvRun.currentTimeMilliOld > 500) {
+                if (System.currentTimeMillis() - rgvRun.currentTimeMilliOld > 1000) {
                     rgvRun.currentTimeMilliOld = System.currentTimeMillis()+50;
                 } else {
                     continue;
@@ -307,6 +308,7 @@
                     rgvRun.currentTimeMilliOld = System.currentTimeMillis()+50;
                     rgvRun.setRgvNo(slave.getOtherId());
                     RgvRunCache.updateRgvStatus(rgvRun);
+                    RgvErrCache.updateRgvErr(slave.getId(),errorRgv);
                     continue;
                 }
 
@@ -327,6 +329,7 @@
                     rgvRun.currentTimeMilliOld = System.currentTimeMillis()+50;
                     rgvRun.setRgvNo(slave.getOtherId());
                     RgvRunCache.updateRgvStatus(rgvRun);
+                    RgvErrCache.updateRgvErr(slave.getId(),"灏忚溅鎺㈢墿鐗╃姸鎬佸紓甯�");
                     continue;
                 }
                 if (rgvTaskProtocol.getAvoid() != 0) {
@@ -337,6 +340,7 @@
                         issued.setTaskStatus(1);
                         issued.setDirection(true);
                         write(issued);
+                        RgvErrCache.updateRgvErr(slave.getId());
                         rgvTaskProtocol.setAvoid(0);
 
 //                        try{Thread.sleep(50L);} catch (Exception e){}
@@ -358,21 +362,25 @@
                             if (rgvOtherStatusEnable()) {
                                 //鍙︿竴鍙拌溅鏄惁鍏佽姝ゅ彴杞︽墽琛�
                                 if (!otherRgvAvoid(taskProtocol.getTargetPosition())) {
+                                    RgvErrCache.updateRgvErr(slave.getId(),errorRgv);
                                     break;
                                 }
                             }
                             if (taskProtocol.getTargetPosition()<=rgvProtocol.getRgvPos()+50
                                     && taskProtocol.getTargetPosition()>=rgvProtocol.getRgvPos()-50){
                                 taskProtocolCache.removeTaskProtocol(taskProtocol.getTaskNoDirection());
+                                RgvErrCache.updateRgvErr(slave.getId());
                                 break;
                             } else {
                                 TaskProtocol issued = new TaskProtocol(taskProtocol,true);
                                 write(issued);
+                                RgvErrCache.updateRgvErr(slave.getId());
                                 taskProtocolCache.removeTaskProtocol(taskProtocol.getTaskNoDirection());
                                 break;
                             }
                         }
                     }
+                    RgvErrCache.updateRgvErr(slave.getId());
                 } else {
                     for (TaskProtocol taskProtocol : allTakeTaskProtocol) {
                         if (taskProtocol.getIsRunning() == 1) {//鍑嗗涓嬪彂
@@ -380,6 +388,7 @@
                             if (rgvOtherStatusEnable()) {
                                 //鍙︿竴鍙拌溅鏄惁鍏佽姝ゅ彴杞︽墽琛�
                                 if (!otherRgvAvoid(taskProtocol.getTargetPosition())) {
+                                    RgvErrCache.updateRgvErr(slave.getId(),errorRgv);
                                     break;
                                 }
                             }
@@ -389,32 +398,38 @@
                                     DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, taskProtocol.getTargetPositionStaNoPlcId());
                                     StaProtocol staProtocol = devpThread.getStation().get(taskProtocol.getTargetPositionStaNo());
                                     if (staProtocol == null ) {
+                                        RgvErrCache.updateRgvErr(slave.getId(),"鏈煡鍒板皬杞︿綔涓氱珯"+staProtocol.getStaNo()+"绔欑偣");
                                         break;
                                     }
                                     // 鍒ゆ柇鏄惁婊¤冻鍏ュ簱鏉′欢
                                     if (!staProtocol.isAutoing() || staProtocol.isLoading()
                                     ){
+                                        RgvErrCache.updateRgvErr(slave.getId(),"灏忚溅绛夊緟"+staProtocol.getStaNo()+"绔欑偣灏辩华");
                                         break;
                                     }
                                 } else if (taskProtocol.getTaskStatus()==2){
                                     DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, taskProtocol.getTargetPositionStaNoPlcId());
                                     StaProtocol staProtocol = devpThread.getStation().get(taskProtocol.getTargetPositionStaNo());
                                     if (staProtocol == null ) {
+                                        RgvErrCache.updateRgvErr(slave.getId(),"鏈煡鍒板皬杞︿綔涓氱珯"+staProtocol.getStaNo()+"绔欑偣");
                                         break;
                                     }
                                     // 鍒ゆ柇鏄惁婊¤冻鍏ュ簱鏉′欢
                                     if (!staProtocol.isAutoing() || !staProtocol.isLoading() || staProtocol.getWorkNo()==0
                                     ){
+                                        RgvErrCache.updateRgvErr(slave.getId(),"灏忚溅绛夊緟"+staProtocol.getStaNo()+"绔欑偣灏辩华");
                                         break;
                                     }
                                 }
                                 TaskProtocol issued = new TaskProtocol(taskProtocol);
                                 write(issued);
+                                RgvErrCache.updateRgvErr(slave.getId());
                                 taskProtocolCache.removeTaskProtocol(taskProtocol.getTaskNoDirection());
                                 break;
                             } else {
                                 TaskProtocol issued = new TaskProtocol(taskProtocol,true);
                                 write(issued);
+                                RgvErrCache.updateRgvErr(slave.getId());
                                 break;
                             }
                         }
@@ -429,7 +444,7 @@
                     DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                     deviceErrorService.addDeviceError("rgv", slave.getId(), "RGV浠诲姟涓嬪彂绾跨▼寮傚父"+e.getMessage());
                 } catch (Exception e2){
-                    log.error("e2:"+e2.getMessage());
+//                    log.error("e2:"+e2.getMessage());
                 }
                 rgvRun = RgvRunCache.getRgvRun();
                 rgvRun.currentTimeMilliOld = System.currentTimeMillis()+50;
@@ -465,10 +480,25 @@
         RgvTaskProtocol rgvTaskProtocol = RgvTaskCache.getRgvStatus(slave.getId());
 
         if (rgvProtocol == null || rgvTaskProtocol == null) {
+            errorRgv = slave.getId()+"鍙峰皬杞﹁繛鎺ュけ璐�";
             return false;
         }
-        if (!rgvProtocol.getModeType().equals(RgvModeType.AUTO) || rgvProtocol.getRgvPos().equals(0L) || rgvTaskProtocol.getAvoid() == -1 || rgvProtocol.getRgvPosDestination() == 0L
-                || ((!rgvProtocol.getStatusType().equals(RgvStatusType.IDLE) || (Math.abs(rgvProtocol.getRgvPos() - rgvProtocol.getRgvPosDestination())>100)) && !rgvProtocol.getStatusType().equals(RgvStatusType.ROAM))) {
+        if (!rgvProtocol.getModeType().equals(RgvModeType.AUTO)) {
+            errorRgv = slave.getId()+"鍙峰皬杞﹂潪鑷姩";
+            return false;
+        }
+        if (rgvProtocol.getRgvPos().equals(0L)
+                || rgvTaskProtocol.getAvoid() == -1
+                || rgvProtocol.getRgvPosDestination() == 0L) {
+            errorRgv = slave.getId()+"鍙峰皬杞︾姸鎬佸紓甯�";
+            return false;
+        }
+        if (!rgvProtocol.getStatusType().equals(RgvStatusType.IDLE) && !rgvProtocol.getStatusType().equals(RgvStatusType.ROAM)) {
+            errorRgv = slave.getId()+"鍙峰皬杞﹂潪绌洪棽";
+            return false;
+        }
+        if ( (Math.abs(rgvProtocol.getRgvPos() - rgvProtocol.getRgvPosDestination())>100) && !rgvProtocol.getStatusType().equals(RgvStatusType.ROAM)) {
+            errorRgv = slave.getId()+"鍙峰皬杞﹀瓨鍦ㄨ繍琛岀洰鏍囧�硷紝闇�瑕佸浣嶏紒锛侊紒";
             return false;
         }
         RgvProtocol rgvProtocolOther = RgvStatusCache.getRgvStatus(slave.getOtherId());
@@ -477,10 +507,12 @@
 //                "rgvTaskProtocolOther:"+slave.getOtherId()+"sign:"+rgvTaskProtocolOther.isSignRun()+"/n");
 
         if (rgvProtocolOther == null) {
+            errorRgv = slave.getOtherId()+"鍙峰皬杞﹁繛鎺ュけ璐�";
             return false;
         }
         if (rgvProtocolOther.statusEnable) {
             if (!rgvProtocolOther.getModeType().equals(RgvModeType.AUTO) || rgvProtocolOther.getRgvPos().equals(0L) || rgvTaskProtocolOther.getAvoid() == -1 || rgvProtocolOther.getRgvPosDestination() == 0L) {
+                errorRgv = slave.getOtherId()+"鍙峰皬杞︾姸鎬佸紓甯�";
                 return false;
             }
         }
@@ -536,11 +568,12 @@
                                             long avoid = rgvProtocolOther.getRgvPos() - rgvProtocolOther.getCarBodyJiaoMing() - avoidDistance - rgvProtocol.getCarBodyKunPeng();
                                             if (!new TrackRangeUtils().avoidRange(avoid, avoidRange[1])) {
                                                 log.error("RGV琛岃蛋瓒呭嚭鑼冨洿锛侊紒锛� ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
+                                                errorRgv = "RGV琛岃蛋鐩爣瓒呭嚭鑼冨洿";
                                                 try{
                                                     DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                                                     deviceErrorService.addDeviceError("rgv", slave.getId(), "RGV琛岃蛋瓒呭嚭鑼冨洿");
                                                 } catch (Exception e2){
-                                                    log.error("e2:"+e2.getMessage());
+//                                                    log.error("e2:"+e2.getMessage());
                                                 }
                                                 return false;
                                             }
@@ -559,17 +592,20 @@
                             }
                         }
                         if (signNowPosRun){
+                            errorRgv = slave.getOtherId()+"鍙稲GV绛夊緟浣滀笟...";
                             return false;
                         }
                     }
                     long avoid = targetPosition + rgvProtocol.getCarBodyKunPeng() + avoidDistance + rgvProtocolOther.getCarBodyJiaoMing();
                     if (!new TrackRangeUtils().avoidRange(avoid, avoidRange[0])) {
                         log.error("RGV琛岃蛋瓒呭嚭鑼冨洿锛侊紒锛� ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
+                        errorRgv = "RGV琛岃蛋鐩爣瓒呭嚭鑼冨洿";
+
                         try{
                             DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                             deviceErrorService.addDeviceError("rgv", slave.getId(), "RGV琛岃蛋瓒呭嚭鑼冨洿");
                         } catch (Exception e2){
-                            log.error("e2:"+e2.getMessage());
+//                            log.error("e2:"+e2.getMessage());
                         }
                         return false;
                     }
@@ -591,11 +627,13 @@
                     long avoid = targetPosition + rgvProtocol.getCarBodyKunPeng() + avoidDistance + rgvProtocolOther.getCarBodyJiaoMing();
                     if (!new TrackRangeUtils().avoidRange(avoid, avoidRange[0])) {
                         log.error("RGV琛岃蛋瓒呭嚭鑼冨洿锛侊紒锛� ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
+                        errorRgv = "RGV琛岃蛋鐩爣瓒呭嚭鑼冨洿";
+
                         try{
                             DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                             deviceErrorService.addDeviceError("rgv", slave.getId(), "RGV琛岃蛋瓒呭嚭鑼冨洿");
                         } catch (Exception e2){
-                            log.error("e2:"+e2.getMessage());
+//                            log.error("e2:"+e2.getMessage());
                         }
                         return false;
                     }
@@ -618,11 +656,13 @@
                         long avoid = rgvProtocolOther.getRgvPos() - rgvProtocolOther.getCarBodyJiaoMing() - avoidDistance - rgvProtocol.getCarBodyKunPeng();
                         if (!new TrackRangeUtils().avoidRange(avoid, avoidRange[1])) {
                             log.error("RGV琛岃蛋瓒呭嚭鑼冨洿锛侊紒锛� ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
+                            errorRgv = "RGV琛岃蛋鐩爣瓒呭嚭鑼冨洿";
+
                             try{
                                 DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                                 deviceErrorService.addDeviceError("rgv", slave.getId(), "RGV琛岃蛋瓒呭嚭鑼冨洿");
                             } catch (Exception e2){
-                                log.error("e2:"+e2.getMessage());
+//                                log.error("e2:"+e2.getMessage());
                             }
                             return false;
                         }
@@ -635,6 +675,8 @@
                         RgvTaskCache.updateRgvStatus(rgvTaskProtocol);
                         return false;
                     }
+                    errorRgv = slave.getOtherId()+"鍙稲GV褰卞搷锛岀瓑寰呬腑...";
+
                     return false;
                 }
             } else {
@@ -671,11 +713,13 @@
                                             long avoid = rgvProtocolOther.getRgvPos() + rgvProtocolOther.getCarBodyKunPeng() + avoidDistance + rgvProtocol.getCarBodyJiaoMing();
                                             if (!new TrackRangeUtils().avoidRange(avoid, avoidRange[0])) {
                                                 log.error("RGV琛岃蛋瓒呭嚭鑼冨洿锛侊紒锛� ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
+                                                errorRgv = "RGV琛岃蛋鐩爣瓒呭嚭鑼冨洿";
+
                                                 try{
                                                     DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                                                     deviceErrorService.addDeviceError("rgv", slave.getId(), "RGV琛岃蛋瓒呭嚭鑼冨洿");
                                                 } catch (Exception e2){
-                                                    log.error("e2:"+e2.getMessage());
+//                                                    log.error("e2:"+e2.getMessage());
                                                 }
                                                 return false;
                                             }
@@ -694,17 +738,20 @@
                             }
                         }
                         if (signNowPosRun){
+                            errorRgv = slave.getOtherId()+"鍙稲GV绛夊緟浣滀笟...";
                             return false;
                         }
                     }
                     long avoid = targetPosition - rgvProtocol.getCarBodyJiaoMing() - avoidDistance - rgvProtocolOther.getCarBodyKunPeng();
                     if (!new TrackRangeUtils().avoidRange(avoid, avoidRange[1])) {
                         log.error("RGV琛岃蛋瓒呭嚭鑼冨洿锛侊紒锛� ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
+                        errorRgv = "RGV琛岃蛋鐩爣瓒呭嚭鑼冨洿";
+
                         try{
                             DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                             deviceErrorService.addDeviceError("rgv", slave.getId(), "RGV琛岃蛋瓒呭嚭鑼冨洿");
                         } catch (Exception e2){
-                            log.error("e2:"+e2.getMessage());
+//                            log.error("e2:"+e2.getMessage());
                         }
                         return false;
                     }
@@ -726,11 +773,13 @@
                     long avoid = targetPosition - rgvProtocol.getCarBodyJiaoMing() - avoidDistance - rgvProtocolOther.getCarBodyKunPeng();
                     if (!new TrackRangeUtils().avoidRange(avoid, avoidRange[1])) {
                         log.error("RGV琛岃蛋瓒呭嚭鑼冨洿锛侊紒锛� ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
+                        errorRgv = "RGV琛岃蛋鐩爣瓒呭嚭鑼冨洿";
+
                         try{
                             DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                             deviceErrorService.addDeviceError("rgv", slave.getId(), "RGV琛岃蛋瓒呭嚭鑼冨洿");
                         } catch (Exception e2){
-                            log.error("e2:"+e2.getMessage());
+//                            log.error("e2:"+e2.getMessage());
                         }
                         return false;
                     }
@@ -754,11 +803,13 @@
                         long avoid = rgvProtocolOther.getRgvPos() + rgvProtocolOther.getCarBodyKunPeng() + avoidDistance + rgvProtocol.getCarBodyJiaoMing();
                         if (!new TrackRangeUtils().avoidRange(avoid, avoidRange[0])) {
                             log.error("RGV琛岃蛋瓒呭嚭鑼冨洿锛侊紒锛� ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
+                            errorRgv = "RGV琛岃蛋鐩爣瓒呭嚭鑼冨洿";
+
                             try{
                                 DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                                 deviceErrorService.addDeviceError("rgv", slave.getId(), "RGV琛岃蛋瓒呭嚭鑼冨洿");
                             } catch (Exception e2){
-                                log.error("e2:"+e2.getMessage());
+//                                log.error("e2:"+e2.getMessage());
                             }
                             return false;
                         }
@@ -771,6 +822,7 @@
                         RgvTaskCache.updateRgvStatus(rgvTaskProtocol);
                         return false;
                     }
+                    errorRgv = slave.getOtherId()+"鍙稲GV绛夊緟涓�...";
                     return false;
                 }
             } else {
@@ -781,6 +833,8 @@
                 }
             }
         }
+
+        errorRgv = slave.getOtherId()+"鍙稲GV褰卞搷锛岀瓑寰呬腑...";
         return false;
     }
 
@@ -817,7 +871,7 @@
                 DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                 deviceErrorService.addDeviceError("rgv", slave.getId(), "RGV寮傚父"+e.getMessage());
             } catch (Exception e2){
-                log.error("e2:"+e2.getMessage());
+//                log.error("e2:"+e2.getMessage());
             }
             rgvProtocol.setStatusEnable(true);
         }
@@ -855,7 +909,7 @@
                 DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                 deviceErrorService.addDeviceError("rgv", slave.getId(), "RGVplc杩炴帴澶辫触");
             } catch (Exception e2){
-                log.error("e2:"+e2.getMessage());
+//                log.error("e2:"+e2.getMessage());
             }
         }
         initRgv();
@@ -918,6 +972,9 @@
 //                        }
 //                    }
 //                }
+                if (rgvProtocol.getAlarm$()!=0){
+                    RgvErrCache.updateRgvErr(slave.getId(),rgvProtocol.getAlarmM());
+                }
 
                 try {
                     // 鏍规嵁瀹炴椂淇℃伅鏇存柊鏁版嵁搴�
@@ -938,7 +995,7 @@
                             DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                             deviceErrorService.addDeviceError("rgv", slave.getId(), "RGV plc鏁版嵁搴撴洿鏂板け璐�");
                         } catch (Exception e2){
-                            log.error("e2:"+e2.getMessage());
+//                            log.error("e2:"+e2.getMessage());
                         }
                     }
                 } catch (Exception ignore) {
@@ -959,7 +1016,7 @@
                     DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                     deviceErrorService.addDeviceError("rgv", slave.getId(), "璇诲彇RGV plc鐘舵�佷俊鎭け璐�");
                 } catch (Exception e2){
-                    log.error("e2:"+e2.getMessage());
+//                    log.error("e2:"+e2.getMessage());
                 }
             }
         } catch (Exception e) {
@@ -971,7 +1028,7 @@
                 DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                 deviceErrorService.addDeviceError("rgv", slave.getId(), "璇诲彇RGV plc鐘舵�佷俊鎭け璐�");
             } catch (Exception e2){
-                log.error("e2:"+e2.getMessage());
+//                log.error("e2:"+e2.getMessage());
             }
             initRgv();
         }
@@ -988,7 +1045,7 @@
                 DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                 deviceErrorService.addDeviceError("rgv", slave.getId(), "RGV鍐欏叆鍛戒护涓虹┖");
             } catch (Exception e2){
-                log.error("e2:"+e2.getMessage());
+//                log.error("e2:"+e2.getMessage());
             }
             return false;
         }
@@ -1047,7 +1104,7 @@
                 DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class);
                 deviceErrorService.addDeviceError("rgv", slave.getId(), "RGV 鍛戒护涓嬪彂"+JSON.toJSON(taskProtocol));
             } catch (Exception e2){
-                log.error("e2:"+e2.getMessage());
+//                log.error("e2:"+e2.getMessage());
             }
             OutputQueue.RGV.offer(MessageFormat.format("銆恵0}銆慬id:{1}] >>>>> 鍛戒护涓嬪彂锛� {2}", DateUtils.convert(new Date()), slave.getId(), JSON.toJSON(taskProtocol)));
             return true;

--
Gitblit v1.9.1