添加告警统计信息

device-manager/src/main/java/com/mortals/xhx/base/framework/listener/DirectDynamicListener.java

@@ -60,14 +60,14 @@ public class DirectDynamicListener implements MessageListener {
         String queue = message.getMessageProperties().getConsumerQueue();
         byte[] body = message.getBody();
         String data = new String(body);
-       // log.info("接收到：{} ，\n消息内容为：{}", queue, data);
+        // log.info("接收到：{} ，\n消息内容为：{}", queue, data);
         DefaultQueueMsg queueMsg = JSON.parseObject(data, DefaultQueueMsg.class);
         //做相应业务,做日志操作
         String deviceCode = queueMsg.getHeaders().getData().get(DEVICECODE);
         String messageType = queueMsg.getHeaders().getData().get(MESSAGETYPE);
         try {
-            if(ObjectUtils.isEmpty(deviceCode)){
-                log.info("onMessage deviceCode is null,receive data:{}",data);
+            if (ObjectUtils.isEmpty(deviceCode)) {
+                log.info("onMessage deviceCode is null,receive data:{}", data);
                 return;
             }
 
@@ -77,7 +77,15 @@ public class DirectDynamicListener implements MessageListener {
                 if (deviceEntity.getDeviceStatus() == DeviceStatusEnum.离线.getValue()) {
                     deviceEntity.setOnlineTime(new Date());
                     deviceEntity.setDeviceStatus(DeviceStatusEnum.在线.getValue());
-                   // deviceService.update(deviceEntity);
+                    DeviceEntity entity = new DeviceEntity();
+                    entity.setOnlineTime(new Date());
+                    entity.setDeviceStatus(DeviceStatusEnum.在线.getValue());
+                    DeviceEntity condition = new DeviceEntity();
+                    condition.setId(deviceEntity.getId());
+
+                    deviceService.getDeviceDao().update(entity, condition);
+
+                    // deviceService.update(deviceEntity);
 
                     PlatformEntity platformEntity = platformService.get(deviceEntity.getPlatformId());
                     ProductEntity productEntity = productService.get(deviceEntity.getProductId());
@@ -104,7 +112,7 @@ public class DirectDynamicListener implements MessageListener {
                 //获取exchange,
                 PlatformEntity platformEntity = platformService.get(deviceEntity.getPlatformId());
 
-                String phpInUrl=GlobalSysInfo.getParamValue(PARAM_SERVER_PHP_IN_HTTP_URL, "http://172.15.28.116:8090");
+                String phpInUrl = GlobalSysInfo.getParamValue(PARAM_SERVER_PHP_IN_HTTP_URL, "http://172.15.28.116:8090");
                 if (!Constant.MESSAGETYPE_HEARTBEAT.equalsIgnoreCase(messageType)
                         && !ObjectUtils.isEmpty(platformEntity)
                         && platformEntity.getSendSwitch() == YesNoEnum.YES.getValue()) {