From f9163340e5cd7d933a6de1591d1da5a34a6e1fa7 Mon Sep 17 00:00:00 2001
From: Harryxzy <xuzhuoyan_xzy@163.com>
Date: Wed, 28 Feb 2024 09:17:28 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=86=E7=89=87?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mapper/salaryacct/SalaryAcctResultLogMapper.java      | 2 +-
 .../engine/salary/service/SalaryAcctResultLogService.java | 2 +-
 .../service/impl/SalaryAcctResultLogServiceImpl.java      | 8 ++++++--
 3 files changed, 8 insertions(+), 4 deletions(-)

diff --git a/src/com/engine/salary/mapper/salaryacct/SalaryAcctResultLogMapper.java b/src/com/engine/salary/mapper/salaryacct/SalaryAcctResultLogMapper.java
index 13229c4f1..c69a4ce49 100644
--- a/src/com/engine/salary/mapper/salaryacct/SalaryAcctResultLogMapper.java
+++ b/src/com/engine/salary/mapper/salaryacct/SalaryAcctResultLogMapper.java
@@ -76,6 +76,6 @@ public interface SalaryAcctResultLogMapper {
      * @param salaryAcctEmployeeIds
      * @param lockSalaryItemIds
      */
-    void deleteBySalaryAcctEmpIdExceptItemIds(@Param("salaryAcctEmployeeIds") Collection<Long> salaryAcctEmployeeIds,
+    void deleteBySalaryAcctEmpIdExceptItemIds(@Param("salaryAcctEmployeeIds") List<Long> salaryAcctEmployeeIds,
                                               @Param("exceptItems") Collection<Long> lockSalaryItemIds, @Param("updateTime") Date updateTime);
 }
diff --git a/src/com/engine/salary/service/SalaryAcctResultLogService.java b/src/com/engine/salary/service/SalaryAcctResultLogService.java
index 8edcf222d..81fb3f350 100644
--- a/src/com/engine/salary/service/SalaryAcctResultLogService.java
+++ b/src/com/engine/salary/service/SalaryAcctResultLogService.java
@@ -68,5 +68,5 @@ public interface SalaryAcctResultLogService {
      * @param salaryAcctEmployeeIds
      * @param lockSalaryItemIds
      */
-    void deleteBySalaryAcctEmpIdExceptItemIds(Collection<Long> salaryAcctEmployeeIds, Collection<Long> lockSalaryItemIds);
+    void deleteBySalaryAcctEmpIdExceptItemIds(List<Long> salaryAcctEmployeeIds, Collection<Long> lockSalaryItemIds);
 }
diff --git a/src/com/engine/salary/service/impl/SalaryAcctResultLogServiceImpl.java b/src/com/engine/salary/service/impl/SalaryAcctResultLogServiceImpl.java
index 72a128c1e..378920dbd 100644
--- a/src/com/engine/salary/service/impl/SalaryAcctResultLogServiceImpl.java
+++ b/src/com/engine/salary/service/impl/SalaryAcctResultLogServiceImpl.java
@@ -60,7 +60,11 @@ public class SalaryAcctResultLogServiceImpl extends Service implements SalaryAcc
     }
 
     @Override
-    public void deleteBySalaryAcctEmpIdExceptItemIds(Collection<Long> salaryAcctEmployeeIds, Collection<Long> lockSalaryItemIds) {
-        getSalaryAcctResultLogMapper().deleteBySalaryAcctEmpIdExceptItemIds(salaryAcctEmployeeIds,lockSalaryItemIds, new Date());
+    public void deleteBySalaryAcctEmpIdExceptItemIds(List<Long> salaryAcctEmployeeIds, Collection<Long> lockSalaryItemIds) {
+        // 分片
+        List<List<Long>> partition = Lists.partition(salaryAcctEmployeeIds, 50);
+        partition.forEach(part -> {
+            getSalaryAcctResultLogMapper().deleteBySalaryAcctEmpIdExceptItemIds(part,lockSalaryItemIds, new Date());
+        });
     }
 }