"feature-zhaJi:优化退回EKP交互逻辑"

yifu-insurances/yifu-insurances-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/insurances/service/impl/TInsuranceDetailServiceImpl.java

@@ -1142,28 +1142,28 @@ public class TInsuranceDetailServiceImpl extends ServiceImpl<TInsuranceDetailMap
 			}
 		}
 		if (CollectionUtils.isNotEmpty(successList)){
+			threadPool.execute(() -> {
 			for (TInsuranceDetail tInsuranceDetail : successList) {
 				Integer settleType = tInsuranceDetail.getSettleType();
 				//如果是合并计算则推送至EKP
 				if(CommonConstants.ZERO_INT == settleType){
 					//存储成功后发送给EKP
-					threadPool.execute(() -> {
-						String s = pushEstimate(tInsuranceDetail,CommonConstants.ONE_INT);
-						if(StringUtils.isNotBlank(s)){
-							LambdaUpdateWrapper<TInsuranceSettle> settleWrapper = new LambdaUpdateWrapper<>();
-							settleWrapper.eq(TInsuranceSettle :: getId,tInsuranceDetail.getDefaultSettleId())
-									.set(TInsuranceSettle :: getIsEstimatePush,CommonConstants.ONE_INT)
-									.set(TInsuranceSettle :: getEstimatePushTime,LocalDateTime.now());
-							//更新结算信息表
-							tInsuranceSettleService.update(settleWrapper);
-							//更新保单信息表
-							updateById(tInsuranceDetail);
-						}
-					});
+					String s = pushEstimate(tInsuranceDetail,CommonConstants.ONE_INT);
+					if(StringUtils.isNotBlank(s)){
+						LambdaUpdateWrapper<TInsuranceSettle> settleWrapper = new LambdaUpdateWrapper<>();
+						settleWrapper.eq(TInsuranceSettle :: getId,tInsuranceDetail.getDefaultSettleId())
+								.set(TInsuranceSettle :: getIsEstimatePush,CommonConstants.ONE_INT)
+								.set(TInsuranceSettle :: getEstimatePushTime,LocalDateTime.now());
+						//更新结算信息表
+						tInsuranceSettleService.update(settleWrapper);
+						//更新保单信息表
+						updateById(tInsuranceDetail);
+					}
 				}else{
 					updateById(tInsuranceDetail);
 				}
 			}
+			});
 			//todo 根据结算类型是合并结算，推送预估保费到ekp(上面已经算好，这里直接判断有预估保费的就推送)
 			//结算状态是待结算，结算中、已结算是ekp反馈的，如果结算失败，反馈到我们这边的状态是待结算
 		}
@@ -3158,8 +3158,8 @@ public class TInsuranceDetailServiceImpl extends ServiceImpl<TInsuranceDetailMap
 		List<DeptChangeCheckParam> successList = stringListMap.get("successList");
 		List<TInsuranceOperate> operateList = new ArrayList<>(16);
 		if(CollectionUtils.isNotEmpty(successList)){
+			threadPool.execute(() -> {
 			for (DeptChangeCheckParam success : successList) {
-				threadPool.execute(() -> {
 					EKPInteractiveParam interactiveParam = new EKPInteractiveParam();
 					TInsuranceDetail one = getOne(lambdaQuery().getWrapper().eq(TInsuranceDetail::getId, success.getId()));
 					BeanCopyUtils.copyProperties(one,interactiveParam);
@@ -3531,7 +3531,6 @@ public class TInsuranceDetailServiceImpl extends ServiceImpl<TInsuranceDetailMap
 
 						}
 					}
-				});
 				//新增操作信息
 				TInsuranceOperate insuranceOperate = new TInsuranceOperate();
 				insuranceOperate.setInsuranceDetailId(success.getId());
@@ -3541,6 +3540,7 @@ public class TInsuranceDetailServiceImpl extends ServiceImpl<TInsuranceDetailMap
 				insuranceOperate.setOperateDesc(InsurancesConstants.DEPT_CHANGE);
 				operateList.add(insuranceOperate);
 			}
+			});
 		}
 		tInsuranceOperateService.saveBatch(operateList);
 		List<DeptChangeCheckParam> errorList = stringListMap.get("errorList");