优化待处理数量推送

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);
 

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("操作成功");
 
     }
@@ -627,8 +625,7 @@ public class DcWarningServiceImpl implements IDcWarningService
         Integer i = dcWarningMapper.updateEndSection(dcWarnings);
 
         //推送待处理消息数量
-        Long num = dcEventService.getCountNum();
-        WebSocketService.broadcast(WebSocketEvent.EVENT_COUNT, num);
+        dcEventService.getCountNum();
 
         return i;
     }
@@ -953,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;
     }