push

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

@@ -32,6 +32,7 @@ import com.yd.csf.service.service.*;
 import com.yd.csf.service.vo.PolicyFollowDetailVO;
 import com.yd.csf.service.vo.PolicyFollowRecordVO;
 import com.yd.csf.service.vo.PolicyFollowVO;
+import com.yd.feign.config.FeignTokenInterceptor;
 import com.yd.insurance.base.feign.client.insurancereconciliationcompany.ApiInsuranceReconciliationCompanyFeignClient;
 import com.yd.insurance.base.feign.request.insurancereconciliationcompany.ApiInsuranceReconciliationCompanyPageRequest;
 import io.swagger.v3.oas.annotations.Operation;
@@ -536,9 +537,14 @@ public class ApiPolicyFollowController {
 
         policyFollowService.changePolicyFollowStatus(changePolicyFollowStatusRequest, policyFollow);
 
+        // 获取Token
+        String token = request.getHeader("Authorization");
         // 异步：根据保单生成预计出账记录
         CompletableFuture.runAsync(() -> {
             try {
+                // 设置ThreadLocal Token
+                FeignTokenInterceptor.setThreadLocalToken(token);
+
                 // 调用 ApiExpectedFortuneService 的 generateWithLogAndRedis（包含日志和Redis处理）
                 ApiGenerateExpectedFortuneRequest generateExpectedFortuneRequest = new ApiGenerateExpectedFortuneRequest();
                 generateExpectedFortuneRequest.setPolicyNo(policyFollow.getPolicyNo());