🚀 集成SSE

kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/MapLogisticSseServiceImpl.java

@@ -48,6 +48,7 @@ public class MapLogisticSseServiceImpl implements IMapLogisticSseService {
     @SneakyThrows
     public SseEmitter SseSubscribe(String clientId) {
         KiccUser kiccUser = getUser();
+        Optional.ofNullable(clientId).orElseThrow(() -> new CommonException("当前客户端Id为空,请检查后重试!"));
         // 设置超时时间为1小时
         SseEmitter sseEmitter = new SseEmitter(3600_000L);
         doMaintenance();
@@ -111,6 +112,7 @@ public class MapLogisticSseServiceImpl implements IMapLogisticSseService {
     @Override
     public void disconnect(String clientId) {
         KiccUser kiccUser = getUser();
+        Optional.ofNullable(clientId).orElseThrow(() -> new CommonException("当前客户端Id为空,请检查后重试!"));
         Set<SseSignalContainer> sendSseSignalContainers = sseSignalContainers.stream()
                 .filter(item -> StrUtil.equals(item.getClientId(), clientId) && StrUtil.equals(item.getTenantId(), kiccUser.getTenantId()))
                 .collect(Collectors.toSet());