Просмотр исходного кода

[功能修复]添加休眠时间防止登录不上

liuf 1 год назад
Родитель
Сommit
f06047dd45

+ 6 - 1
src/main/java/com/tmzn/devicelinkykc/message/DeviceMsgHandle.java

@@ -249,7 +249,12 @@ public class DeviceMsgHandle {
             return false;
         }
         socketHandle.addDeviceConnection(device.getIp(), device.getPort(), device.getPileCode(), device.getDeviceImei(), device.getDeviceSn(), device.getCommProtocolVer());
-        loginFrame.loginMsgSend(socketHandle.getDeviceConnection(device.getPileCode()), device);
+
+        try{
+            Thread.sleep(300);
+            loginFrame.loginMsgSend(socketHandle.getDeviceConnection(device.getPileCode()), device);
+        }catch (Exception e){
+        }
         return false;
 
     }

+ 6 - 2
src/main/java/com/tmzn/devicelinkykc/taskQueue/runner/DeviceOnlineRunner.java

@@ -121,8 +121,12 @@ public class DeviceOnlineRunner {
                     }
                     logger.info("桩检测需要自动上线{}",device.getPileCode());
                     socketHandle.addDeviceConnection(device.getIp(),device.getPort(),device.getPileCode(), device.getDeviceImei(), device.getDeviceSn(),device.getCommProtocolVer());
-                    loginFrame.loginMsgSend(socketHandle.getDeviceConnection(device.getPileCode()), device);
+                    try{
+                        Thread.sleep(300);
+                        loginFrame.loginMsgSend(socketHandle.getDeviceConnection(device.getPileCode()), device);
+                    }catch (Exception e){
 
+                    }
 //                    deviceControlerService.sendImeiDetail(device.getDeviceImei());
                     try103(deviceStatus);
                 }catch (Exception e){
@@ -145,7 +149,7 @@ public class DeviceOnlineRunner {
             return;
         }
 
-        log.info("{}-{}2分钟内无状态下发一次103", deviceStatus.getPileCode(), deviceStatus.getGunPort());
+        log.info("{}-{}-2分钟内无状态下发一次103", deviceStatus.getPileCode(), deviceStatus.getGunPort());
         deviceControlerService.sendImeiDetail(deviceStatus.getDeviceImei());
         redisCache.setCacheObject(key, System.currentTimeMillis(),120, TimeUnit.SECONDS);
     }