push

yd-csf-api/src/main/java/com/yd/csf/api/async/ApiExpectedFortuneAsyncService.java

 package com.yd.csf.api.async;
 package com.yd.csf.api.async;
 
 
+import com.alibaba.fastjson.JSON;
 import com.yd.common.enums.CommonEnum;
 import com.yd.common.enums.CommonEnum;
 import com.yd.common.result.Result;
 import com.yd.common.result.Result;
 import com.yd.common.utils.RandomStringGenerator;
 import com.yd.common.utils.RandomStringGenerator;
@@ -118,6 +119,7 @@ public class ApiExpectedFortuneAsyncService {
                 .filter(Objects::nonNull)
                 .filter(Objects::nonNull)
                 .collect(Collectors.toList());
                 .collect(Collectors.toList());
 
 
+        log.info("过滤掉 calculatedValue 为 0 的项，并收集所有有效的 AlgorithmResDto，返回新的List<AlgorithmCollectResDto>=>返回数据：{}", JSON.toJSONString(filteredCollectResDtos));
         if (CollectionUtils.isEmpty(filteredCollectResDtos)) {
         if (CollectionUtils.isEmpty(filteredCollectResDtos)) {
             log.info("过滤后无有效发佣数据，policyNo: {}", policyNo);
             log.info("过滤后无有效发佣数据，policyNo: {}", policyNo);
             return;
             return;
@@ -134,6 +136,7 @@ public class ApiExpectedFortuneAsyncService {
         if (CollectionUtils.isNotEmpty(clientUserBizIdList)) {
         if (CollectionUtils.isNotEmpty(clientUserBizIdList)) {
             accumulatedFycList = iAgentAccumulatedFycService.queryList(clientUserBizIdList);
             accumulatedFycList = iAgentAccumulatedFycService.queryList(clientUserBizIdList);
         }
         }
+        log.info("查询转介人对应累计积分=>返回数据：{}",JSON.toJSONString(accumulatedFycList));
 
 
         //循环，构建同保单号多个转介人多个期数多个佣金项目的冷静期定时任务记录和积分明细记录
         //循环，构建同保单号多个转介人多个期数多个佣金项目的冷静期定时任务记录和积分明细记录
         for (AlgorithmCollectResDto resDto : filteredCollectResDtos) {
         for (AlgorithmCollectResDto resDto : filteredCollectResDtos) {

yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiExpectedFortuneServiceImpl.java

@@ -601,6 +601,7 @@ public class ApiExpectedFortuneServiceImpl implements ApiExpectedFortuneService
                         .build());
                         .build());
 
 
                 //异步处理-构建冷静期定时任务
                 //异步处理-构建冷静期定时任务
+                log.info("异步处理-构建冷静期定时任务=>请求前入参：{}",JSON.toJSONString(collectResDtos));
                 apiExpectedFortuneAsyncService.buildCalmDateTask(collectResDtos,policyNo);
                 apiExpectedFortuneAsyncService.buildCalmDateTask(collectResDtos,policyNo);
 
 
                 return Result.success();
                 return Result.success();