From 366c1a83670513f8fe7c827e24ff3e751fc4a2b9 Mon Sep 17 00:00:00 2001
From: sy <sy666666>
Date: Fri, 25 Nov 2022 14:43:45 +0800
Subject: [PATCH] =?UTF-8?q?=E8=96=AA=E9=85=AC=E7=B3=BB=E7=BB=9F-=E7=A6=8F?=
 =?UTF-8?q?=E5=88=A9=E5=8F=B0=E8=B4=A6=EF=BC=8C=E9=80=80=E5=B7=AE=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E4=BF=9D=E5=AD=98=E4=BC=98=E5=8C=96=EF=BC=8C=E5=88=86?=
 =?UTF-8?q?=E6=89=B9=E6=9F=A5=E8=AF=A2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/SIRecessionServiceImpl.java  | 19 +++++++++++++------
 1 file changed, 13 insertions(+), 6 deletions(-)

diff --git a/src/com/engine/salary/service/impl/SIRecessionServiceImpl.java b/src/com/engine/salary/service/impl/SIRecessionServiceImpl.java
index 847fa177d..acd6c5e85 100644
--- a/src/com/engine/salary/service/impl/SIRecessionServiceImpl.java
+++ b/src/com/engine/salary/service/impl/SIRecessionServiceImpl.java
@@ -79,12 +79,19 @@ public class SIRecessionServiceImpl extends Service implements SIRecessionServic
         SalaryAssert.notEmpty(employeeIds, SalaryI18nUtil.getI18nLabel(133967, "无退差人员"));
 
         //查询退差员工对应的退差月份的正常缴纳的福利台账数据
-        List<InsuranceAccountDetailPO> detailPOS= getInsuranceAccountDetailMapper().list(InsuranceAccountDetailParam.builder()
-                .paymentStatus(PaymentStatusEnum.COMMON.getValue())
-                .recessionMonthList(param.getRecessionMonthList())
-                .employeeIds(employeeIds)
-                .paymentOrganization(param.getPaymentOrganization())
-                .build());
+        List<InsuranceAccountDetailPO> detailPOS = new ArrayList<>();
+        List<List<Long>> partitionEmpIds = Lists.partition((List<Long>) employeeIds, 1000);
+        partitionEmpIds.forEach(p -> {
+            detailPOS.addAll(
+                    getInsuranceAccountDetailMapper().list(InsuranceAccountDetailParam.builder()
+                    .paymentStatus(PaymentStatusEnum.COMMON.getValue())
+                    .recessionMonthList(param.getRecessionMonthList())
+                    .employeeIds(p)
+                    .paymentOrganization(param.getPaymentOrganization())
+                    .build())
+            );
+        });
+
         InsuranceAccountDetailPOEncrypt.decryptInsuranceAccountDetailPOList(detailPOS);
         //处理数据
         List<InsuranceAccountDetailPO> finalDetailPOS = detailPOS;