From 7c5d7bba35be4cfa120b11bde600746689b314b3 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=92=B1=E6=B6=9B?= <15850646081@163.com>
Date: Wed, 3 Aug 2022 11:08:23 +0800
Subject: [PATCH] =?UTF-8?q?fix=E6=89=B9=E9=87=8F=E5=8F=91=E6=94=BE?=
 =?UTF-8?q?=E5=B7=A5=E8=B5=84=E5=8D=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/com/engine/salary/biz/SalarySendInfoBiz.java | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/src/com/engine/salary/biz/SalarySendInfoBiz.java b/src/com/engine/salary/biz/SalarySendInfoBiz.java
index 2b036c1db..bf6c9fd5b 100644
--- a/src/com/engine/salary/biz/SalarySendInfoBiz.java
+++ b/src/com/engine/salary/biz/SalarySendInfoBiz.java
@@ -8,6 +8,8 @@ import com.engine.salary.entity.salaryBill.param.SalarySendDetailQueryParam;
 import com.engine.salary.entity.salaryBill.param.SalarySendInfoQueryParam;
 import com.engine.salary.entity.salaryBill.po.SalarySendInfoPO;
 import com.engine.salary.mapper.salarybill.SalarySendInfoMapper;
+import com.google.common.collect.Lists;
+import org.apache.commons.collections4.CollectionUtils;
 import org.apache.ibatis.annotations.Param;
 import org.apache.ibatis.session.SqlSession;
 import weaver.conn.mybatis.MyBatisFactory;
@@ -31,6 +33,7 @@ public class SalarySendInfoBiz {
 
     /**
      * 工资单发放
+     *
      * @param po
      * @param salarySendId
      * @param statusList
@@ -50,6 +53,7 @@ public class SalarySendInfoBiz {
 
     /**
      * 根据现有字段查询
+     *
      * @param params
      * @return
      */
@@ -76,6 +80,7 @@ public class SalarySendInfoBiz {
 
     /**
      * 工资单发放详情列表
+     *
      * @param param
      * @return
      */
@@ -106,10 +111,14 @@ public class SalarySendInfoBiz {
     }
 
     public void batchInsert(List<SalarySendInfoPO> salarySendInfos) {
+        if (CollectionUtils.isEmpty(salarySendInfos)) {
+            return;
+        }
         SqlSession sqlSession = MyBatisFactory.sqlSessionFactory.openSession();
         try {
             SalarySendInfoMapper mapper = sqlSession.getMapper(SalarySendInfoMapper.class);
-            mapper.batchInsert(salarySendInfos);
+            List<List<SalarySendInfoPO>> partition = Lists.partition(salarySendInfos, 100);
+            partition.forEach(mapper::batchInsert);
             sqlSession.commit();
         } finally {
             sqlSession.close();