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

修复 修改测报灯离线检测逻辑,避免大量离线消息涌入导致阻塞的问题

zhaiyifei 1 год назад
Родитель
Сommit
4325614c84

+ 9 - 18
src/main/java/com/yunfeiyun/agmp/iots/device/serviceImp/YfQxzDeviceImpl.java

@@ -394,25 +394,16 @@ public class YfQxzDeviceImpl extends DeviceAbstractImpl implements IYfQxzDevice
 
         iIotDeviceService.updateIotDevice(newIotDevice);
         // 主动进行查询,以确保不是误判离线
+
         if("offline".equalsIgnoreCase(cmd)){
-            new Thread(new Runnable() {
-                @Override
-                public void run() {
-                    try {
-                        Thread.sleep(2*1000);
-                    }catch (InterruptedException e){
-                        e.printStackTrace();
-                    }
-                    //主动进行查询,以确保不是误判离线
-                    log.info("【YFQXZ】主动进行查询,以确保不是误判离线" + iotDeviceOld);
-                    YfQxzReqMsg reqMsg = new YfQxzReqMsg();
-                    JSONObject jobjParams = new JSONObject();
-                    jobjParams.put("type","data");
-                    reqMsg.setExt(jobjParams);
-
-                    publishMsg(iotDeviceOld, reqMsg);
-                }
-            }).start();
+            //主动进行查询,以确保不是误判离线
+            log.info("【YFQXZ】主动进行查询,以确保不是误判离线" + iotDeviceOld);
+            YfQxzReqMsg reqMsg = new YfQxzReqMsg();
+            JSONObject jobjParams = new JSONObject();
+            jobjParams.put("type","data");
+            reqMsg.setExt(jobjParams);
+
+            publishMsg(iotDeviceOld, reqMsg);
         }
     }