[update] 快速特勤，车辆位置推送WebSocket判空

signal-control-service/src/main/java/net/wanji/web/kafka/ConsumerHandler.java

 package net.wanji.web.kafka;
 
+import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSONObject;
 import lombok.NonNull;
@@ -136,6 +137,7 @@ public class ConsumerHandler implements KafkaListenerErrorHandler {
                                 // 给前端推送WebSocket
                                 Set<WebSocketServer> events =
                                         WebSocketServer.getWebSocketSet(Constant.WEBSOCKET_AUTO_UNLOCK);
+                                if (CollectionUtil.isNotEmpty(events)) {
                                     for (WebSocketServer socketServer : events) {
                                         socketServer.sendMessage(crossId);
                                     }
@@ -144,6 +146,7 @@ public class ConsumerHandler implements KafkaListenerErrorHandler {
                         }
                     }
                 }
+            }
         } catch (Exception e) {
             log.error("监听主题消息异常， 异常信息", e);
         }

signal-control-service/src/main/java/net/wanji/web/task/RealTimeCarTask.java

 package net.wanji.web.task;
 
+import cn.hutool.core.collection.CollectionUtil;
 import com.alibaba.fastjson.JSONObject;
 import lombok.AllArgsConstructor;
 import lombok.Data;
@@ -46,6 +47,9 @@ public class RealTimeCarTask {
     public void pushRealTimeCarInfo() {
         try {
             Set<WebSocketServer> events = WebSocketServer.getWebSocketSet(Constant.WEBSOCKET_TOPIC_CAR_TRAIL_INFO);
+            if (CollectionUtil.isEmpty(events)) {
+                return;
+            }
             for (WebSocketServer socketServer : events) {
                 String picLicense = socketServer.getUserId();
                 JNMatchResultMiniData jnMatchResultMiniData = consumerHandler.getTopicMessage("CSMatchResultMiniData_0");