qt
/
weaver-hrm-salary
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

薪酬系统-福利档案，增量数据处理中相关日志添加开关

This commit is contained in:
sy 2023-08-02 16:31:59 +08:00
parent 109028e645
commit 0749ab9d5b
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/com/engine/salary/service/impl/SIArchivesServiceImpl.java
View File

@ -43,6 +43,7 @@ import org.apache.commons.lang3.StringUtils;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StopWatch;
import weaver.general.BaseBean;
import weaver.general.Util;
import weaver.hrm.User;
@ -58,6 +59,9 @@ import java.util.stream.Collectors;
**/
@Slf4j
public class SIArchivesServiceImpl extends Service implements SIArchivesService {
private final BaseBean baseBean = new BaseBean();
private final Boolean isLog = "true".equals(baseBean.getPropValue("hrmSalary", "log"));
private SIArchivesBiz siArchivesBiz = new SIArchivesBiz();
@ -290,6 +294,9 @@ public class SIArchivesServiceImpl extends Service implements SIArchivesService
List<InsuranceArchivesBaseInfoPO> toStayDelList = changeData.getBaseInfoUpdateTodoList().stream()
.filter(f -> f.getRunStatus().equals(EmployeeStatusEnum.STAY_DEL.getValue()))
.collect(Collectors.toList());
if (isLog) {
log.info("福利档案-待减员明细:{}", toStayDelList);
}
if (toStayDelList.size() > 0) {
List<List<InsuranceArchivesBaseInfoPO>> partitionUpdateEndTime = Lists.partition(toStayDelList, 100);
partitionUpdateEndTime.forEach(part->{
@ -310,7 +317,9 @@ public class SIArchivesServiceImpl extends Service implements SIArchivesService
List<InsuranceArchivesBaseInfoPO> delList = changeData.getBaseInfoUpdateTodoList().stream()
.filter(f -> f.getDeleteType().equals(DeleteTypeEnum.DELETED.getValue()))
.collect(Collectors.toList());
log.info("福利档案-逻辑删除明细:{}", delList);
if (isLog) {
log.info("福利档案-逻辑删除明细:{}", delList);
}
if (delList.size() > 0) {
for (InsuranceArchivesBaseInfoPO po : delList) {
getSocialSchemeMapper().deleteByEmployeeIdAndPayOrg(InsuranceArchivesSocialSchemePO.builder()
@ -330,7 +339,9 @@ public class SIArchivesServiceImpl extends Service implements SIArchivesService
sw.stop();
//修改福利档案基础信息
sw.start("增量数据中待更新数据入库");
log.info("福利档案-增量数据中待更新数据入库:{}", changeData.getBaseInfoUpdateTodoList());
if (isLog) {
log.info("福利档案-增量数据中待更新数据入库明细:{}", changeData.getBaseInfoUpdateTodoList());
}
List<List<InsuranceArchivesBaseInfoPO>> partitionUpdateBase = Lists.partition(changeData.getBaseInfoUpdateTodoList(), 100);
partitionUpdateBase.forEach(part-> getInsuranceBaseInfoMapper().batchUpdate(part));
sw.stop();