新单跟进64

yd-csf-api/src/main/java/com/yd/csf/api/controller/ApiPolicyFollowController.java

@@ -23,6 +23,7 @@ import com.yd.csf.service.dto.*;
 import com.yd.csf.service.enums.PolicyFollowStatusEnum;
 import com.yd.csf.service.model.*;
 import com.yd.csf.service.service.*;
+import com.yd.csf.service.utils.AsyncQueryUtil;
 import com.yd.csf.service.vo.PolicyFollowDetailVO;
 import com.yd.csf.service.vo.PolicyFollowRecordVO;
 import com.yd.csf.service.vo.PolicyFollowVO;
@@ -81,6 +82,8 @@ public class ApiPolicyFollowController {
     private PolicyFollowFileService policyFollowFileService;
     @Autowired
     private ApiExpectedFortuneService apiExpectedFortuneService;
+    @Resource
+    private AsyncQueryUtil asyncQueryUtil;
 
 
     @PostMapping("/upload/excel")
@@ -533,7 +536,19 @@ public class ApiPolicyFollowController {
             ApiGenerateExpectedFortuneRequest apiGenerateExpectedFortuneRequest = new ApiGenerateExpectedFortuneRequest();
             apiGenerateExpectedFortuneRequest.setPolicyNo(policyFollow.getPolicyNo());
 
-            CompletableFuture.runAsync(() -> apiExpectedFortuneService.generate(apiGenerateExpectedFortuneRequest));
+            CompletableFuture.runAsync(() -> {
+                long startTime = System.currentTimeMillis();
+                String taskName = "新单跟进生成预计发佣: " + policyBizId;
+                try {
+                    log.info("异步任务: {}", taskName);
+                    apiExpectedFortuneService.generate(apiGenerateExpectedFortuneRequest);
+                    long costTime = System.currentTimeMillis() - startTime;
+                    log.info("异步任务完成: {}, 耗时: {}ms", taskName, costTime);
+
+                } catch (Exception e) {
+                    log.error("异步任务失败: {}, 错误: {}", taskName, e.getMessage(), e);
+                }
+            });
         }
         return Result.success(result);
     }