push

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

@@ -10,7 +10,13 @@ import com.yd.csf.feign.request.premiumreconciliation.ApiPremiumReconciliationRe
 import com.yd.csf.feign.response.premiumreconciliation.ApiCalculateRemainingUnpaidAmountResponse;
 import com.yd.csf.feign.response.premiumreconciliation.ApiPremiumReconciliationDetailResponse;
 import com.yd.csf.feign.response.premiumreconciliation.ApiPremiumReconciliationPageResponse;
+import com.yd.csf.service.dto.ChangePolicyFollowStatusRequest;
+import com.yd.csf.service.dto.QueryPolicyAndBrokerDto;
+import com.yd.csf.service.model.CommissionRuleBinding;
 import com.yd.csf.service.model.PremiumReconciliation;
+import org.springframework.scheduling.annotation.Async;
+
+import java.util.List;
 
 public interface ApiPremiumReconciliationService {
     Result<IPage<ApiPremiumReconciliationPageResponse>> page(ApiPremiumReconciliationPageRequest request);
@@ -25,6 +31,9 @@ public interface ApiPremiumReconciliationService {
 
     Result editResult(ApiPremiumReconciliationResultEditRequest request);
 
+    @Async("commonAsyncExecutor")
+    void execute(ChangePolicyFollowStatusRequest changePolicyFollowStatusRequest);
+
     Result<Boolean> checkReconciliationComplete(String policyNo);
 
     Result<PremiumReconciliation> checkPremiumReconciliationIsExist(String expectedCommissionRatioBizId);

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

@@ -31,8 +31,10 @@ import com.yd.csf.feign.response.premiumreconciliation.ApiPremiumReconciliationP
 import com.yd.csf.feign.response.team.ApiTeamPageResponse;
 import com.yd.csf.service.dto.ChangePolicyFollowStatusRequest;
 import com.yd.csf.service.dto.PremiumReconciliationDto;
+import com.yd.csf.service.dto.QueryPolicyAndBrokerDto;
 import com.yd.csf.service.dto.QueryPolicyDto;
 import com.yd.csf.service.enums.PolicyFollowStatusEnum;
+import com.yd.csf.service.model.CommissionRuleBinding;
 import com.yd.csf.service.model.Policy;
 import com.yd.csf.service.model.PolicyFollow;
 import com.yd.csf.service.model.PremiumReconciliation;
@@ -52,6 +54,8 @@ import org.apache.commons.lang3.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationContext;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
@@ -98,6 +102,13 @@ public class ApiPremiumReconciliationServiceImpl implements ApiPremiumReconcilia
     @Resource
     private ApiExpectedFortuneService apiExpectedFortuneService;
 
+    @Autowired
+    private ApplicationContext applicationContext;
+
+    private ApiPremiumReconciliationService getSelf() {
+        return applicationContext.getBean(ApiPremiumReconciliationService.class);
+    }
+
     /**
      * 分页列表查询-保费对账记录信息
      * @param request
@@ -1102,6 +1113,9 @@ public class ApiPremiumReconciliationServiceImpl implements ApiPremiumReconcilia
                 statusRequest.setUnderwritingDate(request.getUnderwritingDate());
                 statusRequest.setPolicyBizId(policyFollow.getPolicyBizId());
                 statusRequest.setStatus("TAKE_EFFECT");
+                //遍历保单转介人列表信息 -> 调用基本法算出预计发佣列表
+                // 通过代理对象调用
+                getSelf().execute(statusRequest);
                 Result<Boolean> result1 = changePolicyFollowStatus(statusRequest);
                 if (result1.getCode() != 200) {
                     throw new BusinessException(result1.getMsg());
@@ -1119,6 +1133,12 @@ public class ApiPremiumReconciliationServiceImpl implements ApiPremiumReconcilia
         return Result.success();
     }
 
+    @Override
+    @Async("commonAsyncExecutor")
+    public void execute(ChangePolicyFollowStatusRequest changePolicyFollowStatusRequest) {
+        changePolicyFollowStatus(changePolicyFollowStatusRequest);
+    }
+
     /**
      * 修改跟进状态
      *