新单跟进v2

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

@@ -719,28 +719,20 @@ public class ApiPolicyFollowController {
      * @param policyNo 保单号
      * @param policyNo 保单号
      */
      */
     private void generateExpectedFortuneSync(String token, String policyNo) {
     private void generateExpectedFortuneSync(String token, String policyNo) {
-        try {
-            // 设置ThreadLocal Token
-            FeignTokenInterceptor.setThreadLocalToken(token);
-
-            // 调用 ApiExpectedFortuneService 的 generateSyncWithLogAndRedis（同步版本，包含日志和Redis处理）
-            ApiGenerateExpectedFortuneRequest generateExpectedFortuneRequest = new ApiGenerateExpectedFortuneRequest();
-            generateExpectedFortuneRequest.setPolicyNo(policyNo);
-            log.info("生成预计发佣generateSyncWithLogAndRedis——>PolicyNo：{}", policyNo);
-            Result<ApiGenerateExpectedFortuneResponse> result = apiExpectedFortuneService.generateSyncWithLogAndRedis(generateExpectedFortuneRequest);
-            if (result == null || result.getCode() != 200) {
-                log.error("新单跟进-同步生成预计出账记录失败:保单号={}, 响应结果={}",
-                        policyNo, result);
-                throw new BusinessException("生成预计出账记录失败:保单号=" + policyNo + ", 错误信息=" + result.getMsg());
-            } else {
-                log.info("新单跟进-同步生成预计出账记录成功:保单号={}", policyNo);
-            }
-        } catch (BusinessException e) {
-            throw e;
-        } catch (Exception e) {
-            log.error("新单跟进-同步生成预计出账记录失败:保单号={}, 错误信息={}",
-                    policyNo, e.getMessage(), e);
-            throw new BusinessException("生成预计出账记录异常:保单号=" + policyNo + ", 错误信息=" + e.getMessage());
+        // 设置ThreadLocal Token
+        FeignTokenInterceptor.setThreadLocalToken(token);
+
+        // 调用 ApiExpectedFortuneService 的 generateSyncWithLogAndRedis（同步版本，包含日志和Redis处理）
+        ApiGenerateExpectedFortuneRequest generateExpectedFortuneRequest = new ApiGenerateExpectedFortuneRequest();
+        generateExpectedFortuneRequest.setPolicyNo(policyNo);
+        log.info("生成预计发佣generateSyncWithLogAndRedis——>PolicyNo：{}", policyNo);
+        Result<ApiGenerateExpectedFortuneResponse> result = apiExpectedFortuneService.generateSyncWithLogAndRedis(generateExpectedFortuneRequest);
+        if (result == null || result.getCode() != 200) {
+            log.error("新单跟进-同步生成预计出账记录失败:保单号={}, 响应结果={}",
+                    policyNo, result);
+            throw new BusinessException("生成预计出账记录失败:保单号=" + policyNo + ", 错误信息=" + result.getMsg());
+        } else {
+            log.info("新单跟进-同步生成预计出账记录成功:保单号={}", policyNo);
         }
         }
     }
     }
 }
 }
\ No newline at end of file