修改校验

device-manager/src/main/java/com/mortals/xhx/thread/DeviceDownMsgThread.java

@@ -60,7 +60,7 @@ public class DeviceDownMsgThread extends AbstractThread {
 
     @Override
     protected void process() {
-        //log.info("DeviceDownMsgThread process");
+        log.info("DeviceDownMsgThread process");
         List<DeviceMsgReq> deviceMsgReqs = new ArrayList<>();
         while (true) {
             DeviceMsgReq deviceMsgReq = cacheService.lpop(KEY_DEVICE_DOWN_MSG_QUEUE, DeviceMsgReq.class);
@@ -124,9 +124,6 @@ public class DeviceDownMsgThread extends AbstractThread {
 
     @Override
     protected void threadClosed() {
-        // TODO Auto-generated method stub
         super.close();
     }
-
-
 }

device-manager/src/main/java/com/mortals/xhx/thread/SendThirdPartyThread.java

@@ -60,23 +60,12 @@ public class SendThirdPartyThread extends AbstractThread {
             deviceMsgReqs.add(deviceReq);
         }
         if (!ObjectUtils.isEmpty(deviceMsgReqs)) {
-            // DeviceReq deviceReq = cacheService.lpop(KEY_DEVICE_THIRDPARTY_QUEUE, DeviceReq.class);
-            if (!ObjectUtils.isEmpty(deviceMsgReqs)) {
-
-                for (DeviceReq deviceMsgReq : deviceMsgReqs) {
-                    //设备上下线信息 不更新通知
-   /*                 if (DeviceMethodEnum.ONLINE.getValue() == deviceMsgReq.getDeviceStatus() || DeviceMethodEnum.OFFLINE.getValue() == deviceMsgReq.getDeviceStatus()) {
-                        return;
-                    }*/
-                    //deviceReq.getReceiveMethod()
-                    String phpInUrl = GlobalSysInfo.getParamValue(PARAM_SERVER_PHP_IN_HTTP_URL, "http://127.0.0.1:11078/zwfw_api");
-                    ApiResp<String> resp = messageService.sendThirdParty(UrlBuilder.of(phpInUrl).addPath(thirdPartyPath).build(), deviceMsgReq);
-                    log.info("sendThirty req==>deviceCode:{} TYPE:{} \n resp ==>{}",deviceMsgReq.getDeviceCode(),DeviceMethodEnum.getByValue(deviceMsgReq.getDeviceStatus()).getDesc(), JSON.toJSONString(resp));
-                }
+            for (DeviceReq deviceMsgReq : deviceMsgReqs) {
+                String phpInUrl = GlobalSysInfo.getParamValue(PARAM_SERVER_PHP_IN_HTTP_URL, "http://127.0.0.1:11078/zwfw_api");
+                ApiResp<String> resp = messageService.sendThirdParty(UrlBuilder.of(phpInUrl).addPath(thirdPartyPath).build(), deviceMsgReq);
+                log.info("sendThirty req==>deviceCode:{} TYPE:{} \n resp ==>{}", deviceMsgReq.getDeviceCode(), DeviceMethodEnum.getByValue(deviceMsgReq.getDeviceStatus()).getDesc(), JSON.toJSONString(resp));
             }
-
         }
-
     }