fix批量发放工资单

This commit is contained in:
钱涛 2022-08-03 11:08:23 +08:00
parent 03f7efa2c9
commit 7c5d7bba35
1 changed files with 10 additions and 1 deletions

View File

@ -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();