diff --git a/zc-business/src/main/java/com/zc/business/service/impl/DcEventServiceImpl.java b/zc-business/src/main/java/com/zc/business/service/impl/DcEventServiceImpl.java
index cf330806..1c7d0c05 100644
--- a/zc-business/src/main/java/com/zc/business/service/impl/DcEventServiceImpl.java
+++ b/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;
     }
 
 
diff --git a/zc-business/src/main/java/com/zc/business/service/impl/DcWarningServiceImpl.java b/zc-business/src/main/java/com/zc/business/service/impl/DcWarningServiceImpl.java
index e85b6a36..87ff9f0d 100644
--- a/zc-business/src/main/java/com/zc/business/service/impl/DcWarningServiceImpl.java
+++ b/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