完善待处理消息数量

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

@@ -2052,8 +2052,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

@@ -624,7 +624,13 @@ public class DcWarningServiceImpl implements IDcWarningService
         if (dcWarnings.size()==0){
             return 1;
         }
-        return dcWarningMapper.updateEndSection(dcWarnings);
+        Integer i = dcWarningMapper.updateEndSection(dcWarnings);
+
+        //推送待处理消息数量
+        Long num = dcEventService.getCountNum();
+        WebSocketService.broadcast(WebSocketEvent.EVENT_COUNT, num);
+
+        return i;
     }
 
     @Override