push

yd-csf-api/src/main/java/com/yd/csf/api/service/ApiPremiumReconciliationService.java

@@ -32,7 +32,7 @@ public interface ApiPremiumReconciliationService {
     Result editResult(ApiPremiumReconciliationResultEditRequest request);
 
     @Async("commonAsyncExecutor")
-    void execute(ChangePolicyFollowStatusRequest changePolicyFollowStatusRequest,String token);
+    void execute(ChangePolicyFollowStatusRequest changePolicyFollowStatusRequest);
 
     Result<Boolean> checkReconciliationComplete(String policyNo);
 

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

@@ -1084,11 +1084,6 @@ public class ApiPremiumReconciliationServiceImpl implements ApiPremiumReconcilia
     @Override
     @Transactional(rollbackFor = Exception.class)
     public Result editResult(ApiPremiumReconciliationResultEditRequest request) {
-        // 通过 RequestContextHolder 获取 HttpServletRequest
-        HttpServletRequest httpServletRequest = ((ServletRequestAttributes)
-                RequestContextHolder.currentRequestAttributes()).getRequest();
-        // 获取Token
-        String token = httpServletRequest.getHeader("Authorization");
         //校验保费对账记录信息是否存在
         Result<PremiumReconciliation> result = checkPremiumReconciliationIsExist(request.getPremiumReconciliationBizId());
         PremiumReconciliation premiumReconciliation = result.getData();
@@ -1120,11 +1115,11 @@ public class ApiPremiumReconciliationServiceImpl implements ApiPremiumReconcilia
                 statusRequest.setStatus("TAKE_EFFECT");
                 //遍历保单转介人列表信息 -> 调用基本法算出预计发佣列表
                 // 通过代理对象调用
-                getSelf().execute(statusRequest,token);
-//                Result<Boolean> result1 = changePolicyFollowStatus(statusRequest);
-//                if (result1.getCode() != 200) {
-//                    throw new BusinessException(result1.getMsg());
-//                }
+//                getSelf().execute(statusRequest,token);
+                Result<Boolean> result1 = changePolicyFollowStatus(statusRequest);
+                if (result1.getCode() != 200) {
+                    throw new BusinessException(result1.getMsg());
+                }
             }else {
                 //大于0，只更新新单跟进：新单状态——>保费对账成功，核保中
                 PolicyFollow policyFollow = policyFollowService.queryOneByPolicyNo(premiumReconciliation.getPolicyNo());
@@ -1140,8 +1135,8 @@ public class ApiPremiumReconciliationServiceImpl implements ApiPremiumReconcilia
 
     @Override
     @Async("commonAsyncExecutor")
-    public void execute(ChangePolicyFollowStatusRequest changePolicyFollowStatusRequest,String token) {
-        changePolicyFollowStatus(changePolicyFollowStatusRequest,token);
+    public void execute(ChangePolicyFollowStatusRequest changePolicyFollowStatusRequest) {
+        changePolicyFollowStatus(changePolicyFollowStatusRequest);
     }
 
     /**
@@ -1151,8 +1146,10 @@ public class ApiPremiumReconciliationServiceImpl implements ApiPremiumReconcilia
      * @return
      */
     @Transactional(rollbackFor = Exception.class)
-    public Result<Boolean> changePolicyFollowStatus(ChangePolicyFollowStatusRequest changePolicyFollowStatusRequest,String token) {
-
+    public Result<Boolean> changePolicyFollowStatus(ChangePolicyFollowStatusRequest changePolicyFollowStatusRequest) {
+        // 通过 RequestContextHolder 获取 HttpServletRequest
+        HttpServletRequest httpServletRequest = ((ServletRequestAttributes)
+                RequestContextHolder.currentRequestAttributes()).getRequest();
         if (changePolicyFollowStatusRequest == null || StringUtils.isBlank(changePolicyFollowStatusRequest.getPolicyBizId())) {
             return Result.fail(ResultCode.PARAMS_ERROR.getCode(), "policyBizId不能为空");
         }
@@ -1193,7 +1190,8 @@ public class ApiPremiumReconciliationServiceImpl implements ApiPremiumReconcilia
 
         // 修改为生效时需要同步预计发佣
         if (PolicyFollowStatusEnum.EFFECTIVE.equals(currentStatusEnum)) {
-
+            // 获取Token
+            String token = httpServletRequest.getHeader("Authorization");
             log.info("修改跟进状态获取token：{}", token);
             // 同步：根据保单生成预计出账记录
             generateExpectedFortuneSync(token, policyFollow.getPolicyNo());