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());
+        });
     }
 }