实缴费用导入接口修改

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/service/impl/TPaymentInfoServiceImpl.java

@@ -796,13 +796,14 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 								if (i % partSize == 0) {
 									lastIdx = i;
 									List<TPaymentInfoVo> finalTempList = tempList;
-									CompletableFuture.supplyAsync(() ->
+									CompletableFuture<List<ErrorMessage>> oneCompletableFuture = CompletableFuture.supplyAsync(() ->
 											executeImportSocialList(user, finalTempList, areaMap, areaMap2,
 													paymentInfoPensionMap, paymentInfoBigMap, paymentInfoBirMap,
 													paymentInfoMedicalMap, paymentInfoUnEmpMap, paymentInfoInjuryMap,
 													errorMessageList,pensionMoneyMap, bigMoneyMap, unEmpMoneyMap, birMoneyMap,
 													injuryMoneyMap, medicalMoneyMap, accrualMoneyMap, paymentInfoaccrualMap
 											), yfSocialImportThreadPoolExecutor);
+									completableFutureList.add(oneCompletableFuture);
 									tempList = new ArrayList<>();
 								}
 							}
@@ -819,6 +820,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 								for (int i = lastIdx + 1; i < list.size(); i++) {
 									tempList.add(list.get(i));
 								}
+								lastIdx += 1;
 							}
 
 							List<TPaymentInfoVo> finalTempList = tempList;
@@ -1942,6 +1944,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 							for (int i = lastIdx + 1; i < list.size(); i++) {
 								tempList.add(list.get(i));
 							}
+							lastIdx += 1;
 						}
 
 						List<TPaymentHeFeiVo> finalTempList = tempList;