|
|
@ -1,10 +1,8 @@ |
|
|
|
package com.cloud.kicc.commonbiz.service.impl; |
|
|
|
package com.cloud.kicc.commonbiz.service.impl; |
|
|
|
|
|
|
|
|
|
|
|
import cn.hutool.core.collection.CollectionUtil; |
|
|
|
|
|
|
|
import cn.hutool.core.collection.ConcurrentHashSet; |
|
|
|
import cn.hutool.core.collection.ConcurrentHashSet; |
|
|
|
import cn.hutool.core.util.StrUtil; |
|
|
|
import cn.hutool.core.util.StrUtil; |
|
|
|
import com.cloud.kicc.common.core.exception.CommonException; |
|
|
|
import com.cloud.kicc.common.core.exception.CommonException; |
|
|
|
import com.cloud.kicc.common.core.util.BaseUtil; |
|
|
|
|
|
|
|
import com.cloud.kicc.common.data.entity.KiccUser; |
|
|
|
import com.cloud.kicc.common.data.entity.KiccUser; |
|
|
|
import com.cloud.kicc.common.security.util.SecurityUtils; |
|
|
|
import com.cloud.kicc.common.security.util.SecurityUtils; |
|
|
|
import com.cloud.kicc.commonbiz.api.entity.SseSignalContainer; |
|
|
|
import com.cloud.kicc.commonbiz.api.entity.SseSignalContainer; |
|
|
@ -16,7 +14,6 @@ import lombok.extern.slf4j.Slf4j; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter; |
|
|
|
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter; |
|
|
|
|
|
|
|
|
|
|
|
import java.io.IOException; |
|
|
|
|
|
|
|
import java.time.LocalDateTime; |
|
|
|
import java.time.LocalDateTime; |
|
|
|
import java.util.Iterator; |
|
|
|
import java.util.Iterator; |
|
|
|
import java.util.Optional; |
|
|
|
import java.util.Optional; |
|
|
@ -53,6 +50,7 @@ public class MapLogisticSseServiceImpl implements IMapLogisticSseService { |
|
|
|
KiccUser kiccUser = getUser(); |
|
|
|
KiccUser kiccUser = getUser(); |
|
|
|
// 设置超时时间为1小时
|
|
|
|
// 设置超时时间为1小时
|
|
|
|
SseEmitter sseEmitter = new SseEmitter(3600_000L); |
|
|
|
SseEmitter sseEmitter = new SseEmitter(3600_000L); |
|
|
|
|
|
|
|
doMaintenance(); |
|
|
|
if(sseSignalContainers.stream() |
|
|
|
if(sseSignalContainers.stream() |
|
|
|
.filter(item -> StrUtil.equals(item.getClientId(),clientId) && StrUtil.equals(item.getTenantId(), kiccUser.getTenantId())) |
|
|
|
.filter(item -> StrUtil.equals(item.getClientId(),clientId) && StrUtil.equals(item.getTenantId(), kiccUser.getTenantId())) |
|
|
|
.collect(Collectors.toSet()).isEmpty()) { |
|
|
|
.collect(Collectors.toSet()).isEmpty()) { |
|
|
|