新单跟进65

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

@@ -536,19 +536,30 @@ public class ApiPolicyFollowController {
             ApiGenerateExpectedFortuneRequest apiGenerateExpectedFortuneRequest = new ApiGenerateExpectedFortuneRequest();
             ApiGenerateExpectedFortuneRequest apiGenerateExpectedFortuneRequest = new ApiGenerateExpectedFortuneRequest();
             apiGenerateExpectedFortuneRequest.setPolicyNo(policyFollow.getPolicyNo());
             apiGenerateExpectedFortuneRequest.setPolicyNo(policyFollow.getPolicyNo());
 
 
-            CompletableFuture.runAsync(() -> {
+//            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);
+//                }
+//            });
+
             long startTime = System.currentTimeMillis();
             long startTime = System.currentTimeMillis();
             String taskName = "新单跟进生成预计发佣: " + policyBizId;
             String taskName = "新单跟进生成预计发佣: " + policyBizId;
+            log.info("任务: {}", taskName);
             try {
             try {
-                    log.info("异步任务: {}", taskName);
                 apiExpectedFortuneService.generate(apiGenerateExpectedFortuneRequest);
                 apiExpectedFortuneService.generate(apiGenerateExpectedFortuneRequest);
                 long costTime = System.currentTimeMillis() - startTime;
                 long costTime = System.currentTimeMillis() - startTime;
-                    log.info("异步任务完成: {}, 耗时: {}ms", taskName, costTime);
-
+                log.info("任务完成: {}, 耗时: {}ms", taskName, costTime);
             } catch (Exception e) {
             } catch (Exception e) {
-                    log.error("异步任务失败: {}, 错误: {}", taskName, e.getMessage(), e);
+                log.error("任务失败: {}, 错误: {}", taskName, e.getMessage(), e);
             }
             }
-            });
         }
         }
         return Result.success(result);
         return Result.success(result);
     }
     }