Merge remote-tracking branch 'origin/develop' into develop

zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java

@@ -610,8 +610,7 @@ public class DeviceMessageHandler {
             dcWarningService.insertDcWarning(dcWarning);
 
             //待确认数量
-            Long count = dcEventService.getCountNum();
-            WebSocketService.broadcast(WebSocketEvent.EVENT_COUNT, count);
+            dcEventService.getCountNum();
         }
         if (!meteorologicalDetectorData.getVisibilityType().equals("4")) {//  能见度类型，4 表示能见度良好3表示阴霾 2表示雾 1表示浓雾；
             WebSocketService.broadcast(WebSocketEvent.WARNING, meteorologicalDetectorData);
@@ -627,8 +626,7 @@ public class DeviceMessageHandler {
             dcWarningService.insertDcWarning(dcWarning);
 
             //待确认数量
-            Long count = dcEventService.getCountNum();
-            WebSocketService.broadcast(WebSocketEvent.EVENT_COUNT, count);
+            dcEventService.getCountNum();
         }
 
 

zc-business/src/main/java/com/zc/business/service/impl/DcEventServiceImpl.java

@@ -575,8 +575,7 @@ public class DcEventServiceImpl extends ServiceImpl<DcEventMapper, DcEvent> impl
 
         WebSocketService.broadcast(WebSocketEvent.EVENT, contentMap); //推送事件消息 0不是感知事件
 
-        Long count = getCountNum();
-        WebSocketService.broadcast(WebSocketEvent.EVENT_COUNT, count);
+        getCountNum();
 
     }
 
@@ -1059,8 +1058,7 @@ public class DcEventServiceImpl extends ServiceImpl<DcEventMapper, DcEvent> impl
             }
         }
         //推送待处理数量
-        Long count = getCountNum();
-        WebSocketService.broadcast(WebSocketEvent.EVENT_COUNT,count);
+        getCountNum();
         return i7;
 
     }
@@ -1235,8 +1233,7 @@ public class DcEventServiceImpl extends ServiceImpl<DcEventMapper, DcEvent> impl
         if (i > 0) {
 
             //推送待处理数量
-            Long count = getCountNum();
-            WebSocketService.broadcast(WebSocketEvent.EVENT_COUNT,count);
+            getCountNum();
 
             DcEvent dcEvent = dcEventMapper.selectDcEventMainById(id);
 
@@ -2052,8 +2049,11 @@ public class DcEventServiceImpl extends ServiceImpl<DcEventMapper, DcEvent> impl
 
         Long eventCount = dcEventMapper.selectEventNumByStatus("0");
 
+        Long num = warningCount + eventCount;
 
-        return warningCount + eventCount;
+        WebSocketService.broadcast(WebSocketEvent.EVENT_COUNT, num);
+
+        return num;
     }
 
 

zc-business/src/main/java/com/zc/business/service/impl/DcWarningServiceImpl.java

@@ -236,8 +236,7 @@ public class DcWarningServiceImpl implements IDcWarningService
         contentMap.put("content",content);
         contentMap.put("event",dcWarning);
         WebSocketService.broadcast(WebSocketEvent.WARNING, contentMap); //推送事件消息 0不是感知事件
-        Long count = dcEventService.getCountNum();
-        WebSocketService.broadcast(WebSocketEvent.EVENT_COUNT, count); //推送待处理数量
+        dcEventService.getCountNum();
     }
 
     //优先级策略(还差优先级策略需要配置)
@@ -527,8 +526,7 @@ public class DcWarningServiceImpl implements IDcWarningService
             return AjaxResult.error("操作失败");
         }
         //推送待处理数量
-        Long count = dcEventService.getCountNum();
-        WebSocketService.broadcast(WebSocketEvent.EVENT_COUNT,count);
+        dcEventService.getCountNum();
         return AjaxResult.success("操作成功");
 
     }
@@ -624,7 +622,12 @@ public class DcWarningServiceImpl implements IDcWarningService
         if (dcWarnings.size()==0){
             return 1;
         }
-        return dcWarningMapper.updateEndSection(dcWarnings);
+        Integer i = dcWarningMapper.updateEndSection(dcWarnings);
+
+        //推送待处理消息数量
+        dcEventService.getCountNum();
+
+        return i;
     }
 
     @Override
@@ -947,8 +950,7 @@ public class DcWarningServiceImpl implements IDcWarningService
         dcWarning.setUpdateTime(DateUtils.getNowDate());
         Integer i = dcWarningMapper.falseAlarmResolution(dcWarning);
         //推送待处理数量
-        Long count = dcEventService.getCountNum();
-        WebSocketService.broadcast(WebSocketEvent.EVENT_COUNT,count);
+        dcEventService.getCountNum();
         return i;
     }