添加设备告警

device-manager/src/main/java/com/mortals/xhx/common/utils/UploadTask.java

@@ -47,15 +47,16 @@ public class UploadTask implements Runnable {
                 if (deviceEntity.getDeviceOnlineStatus() == DeviceOnlineStatusEnum.离线.getValue()) {
                     bool = true;
                 }
-                deviceEntity.setOnlineTime(new Date());
-                deviceEntity.setDeviceOnlineStatus(DeviceOnlineStatusEnum.在线.getValue());
-                deviceEntity.setIp(req.getIp());
-                deviceEntity.setPort(req.getPort());
-                deviceEntity.setSiteNum(req.getSitenum());
-                deviceEntity.setSiteName(req.getSitename());
-                deviceEntity.setCenternum(req.getCenternum());
-               // deviceService.update(deviceEntity);
-
+                if(bool){
+                    deviceEntity.setOnlineTime(new Date());
+                    deviceEntity.setDeviceOnlineStatus(DeviceOnlineStatusEnum.在线.getValue());
+                    deviceEntity.setIp(req.getIp());
+                    deviceEntity.setPort(req.getPort());
+                    deviceEntity.setSiteNum(req.getSitenum());
+                    deviceEntity.setSiteName(req.getSitename());
+                    deviceEntity.setCenternum(req.getCenternum());
+                    deviceService.update(deviceEntity);
+                }
                 DeviceLogEntity deviceLogEntity = new DeviceLogEntity();
                 deviceLogEntity.initAttrValue();
                 deviceLogEntity.setDeviceId(deviceEntity.getId());
@@ -66,7 +67,7 @@ public class UploadTask implements Runnable {
                 deviceLogService.save(deviceLogEntity);
 
                 if (bool) {
-                    WebSocketUtil.broadcast(SendToAllRequest.TYPE, new SendToAllRequest().setContent(JSON.toJSONString(deviceEntity)));
+                   // WebSocketUtil.broadcast(SendToAllRequest.TYPE, new SendToAllRequest().setContent(JSON.toJSONString(deviceEntity)));
                 }
 
             } else {
@@ -93,7 +94,7 @@ public class UploadTask implements Runnable {
                 deviceLogEntity.setContent(JSONObject.toJSONString(req));
                 deviceLogEntity.setCreateTime(new Date());
                 deviceLogService.save(deviceLogEntity);
-                WebSocketUtil.broadcast(SendToAllRequest.TYPE, new SendToAllRequest().setContent(JSON.toJSONString(deviceEntity)));
+               // WebSocketUtil.broadcast(SendToAllRequest.TYPE, new SendToAllRequest().setContent(JSON.toJSONString(deviceEntity)));
             }
         } catch (Exception e) {
             log.error("异常：" ,e);