功能优化

rk

2026-06-09 c467370d8741bc05ca7c22d4253c58ac0a979ef5

 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPushServiceImpl.java

@@ -39,6 +39,7 @@
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
@@ -47,6 +48,7 @@
import java.io.IOException;
import java.util.*;
import java.util.Date;
import java.util.concurrent.Executor;
import java.util.stream.Collectors;

/**
@@ -58,6 +60,9 @@
@Slf4j
public class HkSyncPushServiceImpl extends HkSyncBaseServiceImpl {

    @Autowired
    @Qualifier("asyncExecutor")
    private Executor asyncExecutor;
    @Autowired
    private InoutDayCountMapper inoutDayCountMapper;
    @Autowired
@@ -598,9 +603,7 @@
    private void dealNoticeTelecomEvent(EventBaseRequest param,EventBaseInfoRequest request ,List<WarningEvent> list) {
        try {
            log.error("========通知其他三方地址离岗事件开始:"+list.size());
            Thread t1=new Thread(new Runnable() {
                @Override
                public void run() {
            asyncExecutor.execute(() -> {
//                  EventBaseRequest submitParam = new EventBaseRequest();
//                  submitParam.setMethod(param.getMethod());
//                  submitParam.setParams(new EventBaseParamRequest());
@@ -664,11 +667,9 @@
                            log.error("========通知其他三方地址离岗事件已推送，结果:"+s+"\n"+response);
                        }
                    }
                }
            });
            t1.start();
        }catch (Exception e){
            e.printStackTrace();
            log.error("dealNoticeTelecomEvent异常", e);
        }
    }