Przeglądaj źródła

[功能修复]优化链接

liuf 1 rok temu
rodzic
commit
5ba70c6fc6

+ 10 - 1
src/main/java/com/tmzn/devicelinkykc/taskQueue/runner/MsgHeartRunner.java

@@ -75,8 +75,17 @@ public class MsgHeartRunner {
             if ((System.currentTimeMillis() - deviceConnectionMsg.getLoginTime()) < 8 * 1000) {
                 return;
             }
-        }
 
+            if(!deviceConnectionMsg.getLoginMsgSend()){
+                QueryWrapper<Device> deviceQueryWrapper = new QueryWrapper<>();
+                deviceQueryWrapper.eq("pile_code", devicePileCode).eq("disabled", DeviceOnlineStatus.NORMAL);
+                Device device = deviceService.getOne(deviceQueryWrapper);
+                if(device!=null){
+                    loginFrame.loginMsgSend(deviceConnectionMsg,device);
+                }
+            }
+
+        }
 
         DeviceStatus oneDs = redisCache.getCacheMapValue(portStatusCacheKey, devicePileCode);
         if(oneDs==null){