push

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

@@ -401,9 +401,11 @@ public class ApiExpectedFortuneServiceImpl implements ApiExpectedFortuneService
                     }
                 }
 
+                log.info("异步调用-销售佣金-保存预计发佣数据,{}",JSON.toJSONString(billingResponses));
                 // 异步调用-销售佣金-保存预计发佣数据
                 CompletableFuture<Void> future1 = CompletableFuture.runAsync(
                         () -> self.generateExpectedFortuneBilling(billingResponses), asyncExecutor);
+                log.info("异步调用-奖励佣金-保存预计发佣数据,{}",JSON.toJSONString(rewardResponses));
                 //异步调用-奖励佣金-保存预计发佣数据
                 CompletableFuture<Void> future2 = CompletableFuture.runAsync(
                         () -> self.generateExpectedFortuneReward(rewardResponses), asyncExecutor);
@@ -446,6 +448,7 @@ public class ApiExpectedFortuneServiceImpl implements ApiExpectedFortuneService
      */
     @Transactional(propagation = Propagation.REQUIRES_NEW)
     public void generateExpectedFortuneBilling(List<ApiExecuteBillingResponse> billingResponses) {
+        log.info("异步调用-销售佣金-保存预计发佣数据执行,{}",JSON.toJSONString(billingResponses));
         for (ApiExecuteBillingResponse response : billingResponses) {
             ExecuteBillingDto dto = response.getDto();
             QueryPolicyAndBrokerDto brokerDto = dto.getPolicyAndBrokerDto();
@@ -489,6 +492,7 @@ public class ApiExpectedFortuneServiceImpl implements ApiExpectedFortuneService
      */
     @Transactional(propagation = Propagation.REQUIRES_NEW)
     public void generateExpectedFortuneReward(List<ApiExecuteRewardResponse> rewardResponses) {
+        log.info("异步-奖励佣金-保存预计发佣数据执行,{}",JSON.toJSONString(rewardResponses));
         for (ApiExecuteRewardResponse response : rewardResponses) {
             List<AlgorithmResDto> algorithmResDtoList = response.getAlgorithmResDtoList();
             ExecuteBillingDto dto = response.getDto();