1273 lines
75 KiB
Java
1273 lines
75 KiB
Java
|
//package com.engine.salary.service.impl;
|
|||
|
|
//
|
|||
|
|
//import com.alibaba.fastjson.JSONObject;
|
|||
|
|
//import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
|
|||
|
|
//import com.baomidou.mybatisplus.extension.conditions.update.LambdaUpdateChainWrapper;
|
|||
|
|
//import com.engine.salary.biz.SalaryArchiveBiz;
|
|||
|
|
//import com.engine.salary.biz.SalaryArchiveItemBiz;
|
|||
|
|
//import com.engine.salary.biz.SalaryArchiveTaxAgentBiz;
|
|||
|
|
//import com.engine.salary.entity.salaryarchive.param.SalaryArchiveItemQueryParam;
|
|||
|
|
//import com.engine.salary.entity.salaryarchive.param.SalaryArchiveTaxAgentQueryParam;
|
|||
|
|
//import com.engine.salary.entity.salaryarchive.po.SalaryArchiveItemPO;
|
|||
|
|
//import com.engine.salary.entity.salaryarchive.po.SalaryArchivePO;
|
|||
|
|
//import com.engine.salary.entity.salaryarchive.po.SalaryArchiveTaxAgentPO;
|
|||
|
|
//import com.engine.salary.service.SalaryArchiveService;
|
|||
|
|
//import com.google.common.base.Joiner;
|
|||
|
|
//import com.google.common.collect.Lists;
|
|||
|
|
//import com.google.common.collect.Maps;
|
|||
|
|
//import com.weaver.common.batch.context.BatchExportContext;
|
|||
|
|
//import com.weaver.common.batch.context.BatchImportContext;
|
|||
|
|
//import com.weaver.common.batch.entity.BatchCallbackMessage;
|
|||
|
|
//import com.weaver.common.batch.entity.BatchDocumentMessage;
|
|||
|
|
//import com.weaver.common.batch.entity.ExcelComment;
|
|||
|
|
//import com.weaver.common.batch.entity.ExcelSheet;
|
|||
|
|
//import com.weaver.common.batch.handler.BatchExportHandler;
|
|||
|
|
//import com.weaver.common.batch.handler.BatchImportHandler;
|
|||
|
|
//import com.weaver.common.distribution.genid.IdGenerator;
|
|||
|
|
//import com.weaver.datasecurity.interceptor.DSTenantKeyThreadVar;
|
|||
|
|
//import com.weaver.hrm.salary.common.LocalDateRange;
|
|||
|
|
//import com.weaver.hrm.salary.common.excel.ExcelSheetData;
|
|||
|
|
//import com.weaver.hrm.salary.common.excel.ExportExcelInfo;
|
|||
|
|
//import com.weaver.hrm.salary.constant.SalaryItemConstant;
|
|||
|
|
//import com.weaver.hrm.salary.dao.*;
|
|||
|
|
//import com.weaver.hrm.salary.entity.salaryarchive.bo.SalaryArchiveBO;
|
|||
|
|
//import com.weaver.hrm.salary.entity.salaryarchive.dto.*;
|
|||
|
|
//import com.weaver.hrm.salary.entity.salaryarchive.param.SalaryArchiveDimissionSaveParam;
|
|||
|
|
//import com.weaver.hrm.salary.entity.salaryarchive.param.SalaryArchiveImportHandleParam;
|
|||
|
|
//import com.weaver.hrm.salary.entity.salaryarchive.param.SalaryArchiveQueryParam;
|
|||
|
|
//import com.weaver.hrm.salary.entity.salaryarchive.po.*;
|
|||
|
|
//import com.weaver.hrm.salary.entity.salaryitem.po.SalaryItemPO;
|
|||
|
|
//import com.weaver.hrm.salary.enums.SalaryUserStatusEnum;
|
|||
|
|
//import com.weaver.hrm.salary.enums.salaryarchive.SalaryArchiveImportTypeEnum;
|
|||
|
|
//import com.weaver.hrm.salary.enums.salaryarchive.SalaryArchiveItemAdjustReasonEnum;
|
|||
|
|
//import com.weaver.hrm.salary.enums.salaryarchive.SalaryArchiveTaxAgentAdjustReasonEnum;
|
|||
|
|
//import com.weaver.hrm.salary.service.SalaryArchiveItemService;
|
|||
|
|
//import com.weaver.hrm.salary.service.SalaryBatchService;
|
|||
|
|
//import com.weaver.hrm.salary.service.TaxAgentService;
|
|||
|
|
//import com.weaver.hrm.salary.util.SalaryDateUtil;
|
|||
|
|
//import com.weaver.hrm.salary.util.SalaryI18nUtil;
|
|||
|
|
//import com.weaver.teams.util.StringUtils;
|
|||
|
|
//import org.apache.commons.collections4.CollectionUtils;
|
|||
|
|
//import org.springframework.transaction.annotation.Transactional;
|
|||
|
|
//
|
|||
|
|
//import java.time.LocalDate;
|
|||
|
|
//import java.time.LocalDateTime;
|
|||
|
|
//import java.util.*;
|
|||
|
|
//import java.util.concurrent.ExecutorService;
|
|||
|
|
//import java.util.concurrent.atomic.AtomicInteger;
|
|||
|
|
//import java.util.stream.Collectors;
|
|||
|
|
//
|
|||
|
|
///**
|
|||
|
|
// * 薪资档案
|
|||
|
|
// * <p>Copyright: Copyright (c) 2022</p>
|
|||
|
|
// * <p>Company: 泛微软件</p>
|
|||
|
|
// *
|
|||
|
|
// * @author qiantao
|
|||
|
|
// * @version 1.0
|
|||
|
|
// **/
|
|||
|
|
//public class SalaryArchiveServiceImpl implements SalaryArchiveService {
|
|||
|
|
//
|
|||
|
|
// private SalaryArchiveBiz mapper = new SalaryArchiveBiz();
|
|||
|
|
// private SalaryArchiveItemBiz salaryArchiveItemMapper;
|
|||
|
|
// private SalaryArchiveTaxAgentBiz salaryArchiveTaxAgentMapper;
|
|||
|
|
// private SalaryArchiveDimissionMapper salaryArchiveDimissionMapper;
|
|||
|
|
// private SalaryArchiveItemService salaryArchiveItemService;
|
|||
|
|
// private SalaryBatchService salaryBatchService;
|
|||
|
|
// private TaxAgentService taxAgentService;
|
|||
|
|
// private ExecutorService taskExecutor;
|
|||
|
|
//
|
|||
|
|
// @Override
|
|||
|
|
// public SalaryArchivePO getById(Long salaryArchiveId) {
|
|||
|
|
// return mapper.getById(salaryArchiveId);
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
//// @Override
|
|||
|
|
//// public Page<SalaryArchiveListDTO> listPage(Page<SalaryArchiveListDTO> page, SalaryArchiveQueryParam queryParam, String tenantKey) {
|
|||
|
|
//// mapper.list(page, queryParam, tenantKey);
|
|||
|
|
//// return page;
|
|||
|
|
//// }
|
|||
|
|
//
|
|||
|
|
// /**
|
|||
|
|
// * 获取薪资档案对应的当前生效的薪资项目
|
|||
|
|
// *
|
|||
|
|
// * @param salaryArchivesIds
|
|||
|
|
// * @return
|
|||
|
|
// */
|
|||
|
|
// @Override
|
|||
|
|
// public List<SalaryArchiveItemPO> getCurrentEffectiveItemList(Collection<Long> salaryArchivesIds, Collection<Long> salaryItemIds) {
|
|||
|
|
// // 没有薪资项目时，给个不存在的，否则加载所有不合理 fixme
|
|||
|
|
// salaryItemIds = CollectionUtils.isEmpty(salaryItemIds)?Collections.singletonList(0L):salaryItemIds;
|
|||
|
|
// List<SalaryArchiveItemPO> salaryArchiveItems = salaryArchiveItemMapper.getCurrentEffectiveItemList(SalaryArchiveItemQueryParam.builder().salaryArchivesIds(salaryArchivesIds).salaryItemIds(salaryItemIds).effectiveTime(new Date()).build());
|
|||
|
|
// return salaryArchiveItems.stream()
|
|||
|
|
// .collect(Collectors.collectingAndThen(Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(f -> f.getSalaryArchiveId()+"-"+f.getSalaryItemId()))), ArrayList::new));
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// /**
|
|||
|
|
// * 获取薪资档案对应的当前生效的个税扣缴义务人
|
|||
|
|
// *
|
|||
|
|
// * @param salaryArchivesIds
|
|||
|
|
// * @return
|
|||
|
|
// */
|
|||
|
|
// @Override
|
|||
|
|
// public List<SalaryArchiveTaxAgentPO> getCurrentEffectiveTaxAgentList(Collection<Long> salaryArchivesIds) {
|
|||
|
|
//
|
|||
|
|
// List<SalaryArchiveTaxAgentPO> salaryArchiveTaxAgents = salaryArchiveTaxAgentMapper.listByParam(SalaryArchiveTaxAgentQueryParam.builder().salaryArchivesIds(salaryArchivesIds).effectiveTime(new Date()).build());
|
|||
|
|
//
|
|||
|
|
// return salaryArchiveTaxAgents.stream()
|
|||
|
|
// .collect(Collectors.collectingAndThen(Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(SalaryArchiveTaxAgentPO::getSalaryArchiveId))), ArrayList::new));
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// /**
|
|||
|
|
// * 构建薪资档案数据
|
|||
|
|
// * @param salaryArchives
|
|||
|
|
// * @param taxAgentLists
|
|||
|
|
// * @param salaryItems
|
|||
|
|
// * @param tenantKey
|
|||
|
|
// * @param isPage
|
|||
|
|
// * @return
|
|||
|
|
// */
|
|||
|
|
// @Override
|
|||
|
|
// public List<Map<String, Object>> buildSalaryArchiveData(Collection<SalaryArchiveListDTO> salaryArchives,
|
|||
|
|
// Collection<TaxAgentListDTO> taxAgentLists,
|
|||
|
|
// List<SalaryItemPO> salaryItems,
|
|||
|
|
// Long currentEmployeeId,
|
|||
|
|
// String tenantKey,
|
|||
|
|
// Boolean isPage) {
|
|||
|
|
// // 分页用于表格展示，否则用于导出
|
|||
|
|
// Collection<Long> ids = isPage?salaryArchives.stream().map(SalaryArchiveListDTO::getId).collect(Collectors.toList()):CollectionUtils.emptyCollection();
|
|||
|
|
//
|
|||
|
|
// List<Long> salaryItemIds = salaryItems.stream().map(SalaryItemPO::getId).collect(Collectors.toList());
|
|||
|
|
// // 1.获取薪资档案所对应的当前生效的薪资项目数据
|
|||
|
|
// List<SalaryArchiveItemPO> salaryArchiveItemList = getCurrentEffectiveItemList(ids, salaryItemIds, tenantKey);
|
|||
|
|
// List<Map<String, Object>> salaryArchiveItemData = salaryArchives.stream().map(m->{
|
|||
|
|
// Map<String, Object> map = Maps.newHashMap();
|
|||
|
|
// map.put("salaryArchiveId", m.getId());
|
|||
|
|
// List<SalaryArchiveItemPO> salaryArchiveItemValuelList = salaryArchiveItemList.stream().filter(i->i.getSalaryArchiveId().equals(m.getId())).collect(Collectors.toList());
|
|||
|
|
// salaryArchiveItemValuelList.forEach(i->{
|
|||
|
|
// map.put(i.getSalaryItemId() + SalaryItemConstant.DYNAMIC_SUFFIX, i.getItemValue());
|
|||
|
|
// });
|
|||
|
|
// return map;
|
|||
|
|
// }).collect(Collectors.toList());
|
|||
|
|
// //2.获取薪资档案所对应的当前生效的个税扣缴义务人列表
|
|||
|
|
// List<SalaryArchiveTaxAgentPO> taxAgentList = getCurrentEffectiveTaxAgentList(ids, tenantKey);
|
|||
|
|
// List<Map<String, Object>> taxAgentData = taxAgentList.stream().map(m->{
|
|||
|
|
// Map<String, Object> map = Maps.newHashMap();
|
|||
|
|
// map.put("salaryArchiveId", m.getSalaryArchiveId());
|
|||
|
|
// map.put("taxAgentId", m.getTaxAgentId());
|
|||
|
|
// Optional<TaxAgentListDTO> optional = taxAgentLists.stream().filter(f->f.getId().equals(m.getTaxAgentId())).findFirst();
|
|||
|
|
// map.put("taxAgentName", optional.isPresent()?optional.get().getName():"");
|
|||
|
|
// map.put("taxAgentEffectiveTime", m.getEffectiveTime() + "");
|
|||
|
|
// return map;
|
|||
|
|
// }).collect(Collectors.toList());
|
|||
|
|
// // 3.组装数据
|
|||
|
|
// List<Map<String, Object>> listMaps = new ArrayList<>();
|
|||
|
|
// salaryArchives.forEach(e->{
|
|||
|
|
// e.setEmployeeStatus(SalaryUserStatusEnum.getDefaultLabelByValue(e.getEmployeeStatus(), currentEmployeeId, tenantKey));
|
|||
|
|
//
|
|||
|
|
// Map<String, Object> map = new LinkedHashMap<>();
|
|||
|
|
// map.put("id", e.getId());
|
|||
|
|
// map.put("username", e.getUsername());
|
|||
|
|
// map.put("employeeId", e.getEmployeeId());
|
|||
|
|
//
|
|||
|
|
// Optional<Map<String, Object>> optionalTaxAgent = taxAgentData.stream().filter(f->f.get("salaryArchiveId").toString().equals(e.getId().toString())).findFirst();
|
|||
|
|
// map.put("taxAgentName", optionalTaxAgent.isPresent()?optionalTaxAgent.get().get("taxAgentName").toString():"");
|
|||
|
|
// map.put("taxAgentId", optionalTaxAgent.isPresent()?optionalTaxAgent.get().get("taxAgentId").toString():"");
|
|||
|
|
// map.put("taxAgentEffectiveTime", optionalTaxAgent.isPresent()?optionalTaxAgent.get().get("taxAgentEffectiveTime").toString():"");
|
|||
|
|
//
|
|||
|
|
// map.put("departmentName", e.getDepartmentName());
|
|||
|
|
// map.put("mobile", e.getMobile());
|
|||
|
|
// map.put("employeeStatus", e.getEmployeeStatus());
|
|||
|
|
//
|
|||
|
|
// // 薪资项目动态
|
|||
|
|
// Optional<Map<String, Object>> optionalItem = salaryArchiveItemData.stream().filter(f->f.get("salaryArchiveId").toString().equals(e.getId().toString())).findFirst();
|
|||
|
|
// optionalItem.ifPresent(map::putAll);
|
|||
|
|
//
|
|||
|
|
// listMaps.add(map);
|
|||
|
|
// });
|
|||
|
|
// return listMaps;
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// @Override
|
|||
|
|
// public void exportList(Map<String, Object> map, String username, String eteamsId, SalaryArchiveQueryParam queryParam, Long employeeId, String tenantKey) {
|
|||
|
|
// String nameI18n = SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 85368, "薪资档案");
|
|||
|
|
// List<ExcelSheetData> sheetList = new ArrayList<>();
|
|||
|
|
//
|
|||
|
|
// ExcelSheetData excelSheetData = new ExcelSheetData();
|
|||
|
|
// // 1.工作簿名称
|
|||
|
|
// excelSheetData.setSheetName(nameI18n);
|
|||
|
|
// // 获取所有可被引用的薪资项目
|
|||
|
|
// List<SalaryItemPO> salaryItems = salaryArchiveItemService.getCanAdjustSalaryItems(tenantKey);
|
|||
|
|
// String[] header = {
|
|||
|
|
// SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 85429, "姓名"),
|
|||
|
|
// SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 86184, "个税扣缴义务人"),
|
|||
|
|
// SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 86185, "部门"),
|
|||
|
|
// SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 86186, "手机号"),
|
|||
|
|
// SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 91075, "状态")
|
|||
|
|
// };
|
|||
|
|
// List<String> headerList = new ArrayList<>(Arrays.asList(header));
|
|||
|
|
// for (SalaryItemPO salaryItem : salaryItems) {
|
|||
|
|
// headerList.add(salaryItem.getName());
|
|||
|
|
// }
|
|||
|
|
// // 2.表头
|
|||
|
|
// excelSheetData.setHeaders(Collections.singletonList(headerList.toArray(new String[]{})));
|
|||
|
|
// // 获取所有个税扣缴义务人
|
|||
|
|
// Collection<TaxAgentListDTO> taxAgentList = taxAgentService.findAll(tenantKey);
|
|||
|
|
// Collection<SalaryArchiveListDTO> salaryArchives = mapper.list(queryParam, tenantKey);
|
|||
|
|
// List<Map<String, Object>> listMaps = buildSalaryArchiveData(salaryArchives, taxAgentList, salaryItems, employeeId, tenantKey, Boolean.FALSE);
|
|||
|
|
// // 组装数据
|
|||
|
|
// List<List<Object>> rows = new ArrayList<>();
|
|||
|
|
// listMaps.forEach(e->{
|
|||
|
|
// List<Object> row = new ArrayList<>();
|
|||
|
|
// row.add(e.get("username").toString());
|
|||
|
|
// row.add(e.get("taxAgentName").toString());
|
|||
|
|
// row.add(e.get("departmentName").toString());
|
|||
|
|
// row.add(e.get("mobile")==null?"":e.get("mobile").toString());
|
|||
|
|
// row.add(e.get("employeeStatus").toString());
|
|||
|
|
// // 薪资项目数据
|
|||
|
|
// for (SalaryItemPO salaryItem : salaryItems) {
|
|||
|
|
// row.add(e.containsKey(salaryItem.getId()+SalaryItemConstant.DYNAMIC_SUFFIX)?(e.get(salaryItem.getId()+SalaryItemConstant.DYNAMIC_SUFFIX)==null?"":e.get(salaryItem.getId()+SalaryItemConstant.DYNAMIC_SUFFIX).toString()):"");
|
|||
|
|
// }
|
|||
|
|
// rows.add(row);
|
|||
|
|
// });
|
|||
|
|
// // 3.表数据
|
|||
|
|
// excelSheetData.setRows(rows);
|
|||
|
|
//
|
|||
|
|
// sheetList.add(excelSheetData);
|
|||
|
|
//
|
|||
|
|
// salaryBatchService.simpleExportExcel(ExportExcelInfo.builder()
|
|||
|
|
// .bizId(map.get("biz").toString())
|
|||
|
|
// .flag(true)
|
|||
|
|
// .userId(employeeId)
|
|||
|
|
// .eteamsId(eteamsId)
|
|||
|
|
// .tenantKey(tenantKey)
|
|||
|
|
// .operator(username)
|
|||
|
|
// .module(map.get("module").toString())
|
|||
|
|
// .fileName(nameI18n + SalaryDateUtil.getFormatLocalDateTime(LocalDateTime.now()))
|
|||
|
|
// .handlerName("exportSalaryArchive")
|
|||
|
|
// .dataType(nameI18n)
|
|||
|
|
// .function("exportSalaryArchive").build(), sheetList);
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// @Override
|
|||
|
|
// public void downloadTemplate(Map<String, Object> map, String username, String eteamsId, SalaryArchiveImportTypeEnum salaryArchiveImportTypeEnum, SalaryArchiveQueryParam queryParam, Long employeeId, String tenantKey) {
|
|||
|
|
// boolean isInit = salaryArchiveImportTypeEnum.getValue().equals(SalaryArchiveImportTypeEnum.INIT.getValue());
|
|||
|
|
// boolean isTaxAgentAdjust = salaryArchiveImportTypeEnum.getValue().equals(SalaryArchiveImportTypeEnum.TAXAGENTADJUST.getValue());
|
|||
|
|
// boolean isSalaryItemAdjust = salaryArchiveImportTypeEnum.getValue().equals(SalaryArchiveImportTypeEnum.SALARYITEMADJUST.getValue());
|
|||
|
|
//
|
|||
|
|
// String nameI18n = SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 101601, "薪资档案导入模板");
|
|||
|
|
// // 初始化
|
|||
|
|
// if (isInit) {
|
|||
|
|
// nameI18n+="-"+SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, SalaryArchiveImportTypeEnum.INIT.getLabelId(), SalaryArchiveImportTypeEnum.INIT.getDefaultLabel());
|
|||
|
|
// // 调整个税扣缴义务人
|
|||
|
|
// } else if (isTaxAgentAdjust) {
|
|||
|
|
// nameI18n+="-"+SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, SalaryArchiveImportTypeEnum.TAXAGENTADJUST.getLabelId(), SalaryArchiveImportTypeEnum.TAXAGENTADJUST.getDefaultLabel());
|
|||
|
|
// // 调薪
|
|||
|
|
// } else if (isSalaryItemAdjust) {
|
|||
|
|
// nameI18n+="-"+SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, SalaryArchiveImportTypeEnum.SALARYITEMADJUST.getLabelId(), SalaryArchiveImportTypeEnum.SALARYITEMADJUST.getDefaultLabel());
|
|||
|
|
// }
|
|||
|
|
// String finalNameI18n = nameI18n;
|
|||
|
|
//
|
|||
|
|
// List<ExcelSheetData> sheetList = new ArrayList<>();
|
|||
|
|
//
|
|||
|
|
// ExcelSheetData excelSheetData = new ExcelSheetData();
|
|||
|
|
// // 1.工作簿名称
|
|||
|
|
// excelSheetData.setSheetName(finalNameI18n);
|
|||
|
|
// // 获取所有可被引用的薪资项目
|
|||
|
|
// List<SalaryItemPO> salaryItems = salaryArchiveItemService.getCanAdjustSalaryItems(tenantKey);
|
|||
|
|
// List<String> header = Lists.newArrayList();
|
|||
|
|
// header.add(SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 85429, "姓名"));
|
|||
|
|
// header.add(SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 86184, "个税扣缴义务人"));
|
|||
|
|
// header.add(SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 85904, "生效日期"));
|
|||
|
|
// if (isTaxAgentAdjust || isSalaryItemAdjust) {
|
|||
|
|
// header.add(SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 85431, "调整原因"));
|
|||
|
|
// }
|
|||
|
|
// header.add(SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 86185, "部门"));
|
|||
|
|
// header.add(SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 86186, "手机号"));
|
|||
|
|
// header.add(SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 91075, "状态"));
|
|||
|
|
// if (isInit || isSalaryItemAdjust) {
|
|||
|
|
// for (SalaryItemPO salaryItem : salaryItems) {
|
|||
|
|
// header.add(salaryItem.getName());
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// // 2.表头
|
|||
|
|
// excelSheetData.setHeaders(Collections.singletonList(header.toArray(new String[]{})));
|
|||
|
|
// // 获取所有个税扣缴义务人
|
|||
|
|
// Collection<TaxAgentListDTO> taxAgentList = taxAgentService.findAll(tenantKey);
|
|||
|
|
// Collection<SalaryArchiveListDTO> salaryArchives = mapper.list(queryParam, tenantKey);
|
|||
|
|
// List<Map<String, Object>> listMaps = buildSalaryArchiveData(salaryArchives, taxAgentList, salaryItems, employeeId, tenantKey, Boolean.FALSE);
|
|||
|
|
// // 组装数据
|
|||
|
|
// List<List<Object>> rows = new ArrayList<>();
|
|||
|
|
// listMaps.forEach(e->{
|
|||
|
|
// List<Object> row = new ArrayList<>();
|
|||
|
|
// row.add(e.get("username").toString());
|
|||
|
|
// row.add(e.get("taxAgentName").toString());
|
|||
|
|
// if (isTaxAgentAdjust || isSalaryItemAdjust) {
|
|||
|
|
// row.add(isTaxAgentAdjust?e.get("taxAgentEffectiveTime").toString():"");
|
|||
|
|
// }
|
|||
|
|
// row.add("");
|
|||
|
|
// row.add(e.get("departmentName").toString());
|
|||
|
|
// row.add(e.get("mobile")==null?"":e.get("mobile").toString());
|
|||
|
|
// row.add(e.get("employeeStatus").toString());
|
|||
|
|
// // 调薪
|
|||
|
|
// if (isInit || isSalaryItemAdjust) {
|
|||
|
|
// // 薪资项目数据
|
|||
|
|
// for (SalaryItemPO salaryItem : salaryItems) {
|
|||
|
|
// row.add(e.containsKey(salaryItem.getId()+SalaryItemConstant.DYNAMIC_SUFFIX)?(e.get(salaryItem.getId()+SalaryItemConstant.DYNAMIC_SUFFIX)==null?"":e.get(salaryItem.getId()+SalaryItemConstant.DYNAMIC_SUFFIX).toString()):"");
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// rows.add(row);
|
|||
|
|
// });
|
|||
|
|
// // 3.表数据
|
|||
|
|
// excelSheetData.setRows(rows);
|
|||
|
|
// // 4.注释
|
|||
|
|
// List<ExcelComment> excelComments = Lists.newArrayList();
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 100344, "必填"), 0, 0, 0, 0);
|
|||
|
|
// if (isInit || isTaxAgentAdjust) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 100344, "必填"), 0, 0, 1, 1);
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 100458,"必填，格式样例为'2022-01-01'、'2022/1/1'"), 0, 0, 2, 2);
|
|||
|
|
//
|
|||
|
|
// // 调整个税扣缴义务人
|
|||
|
|
// if (isTaxAgentAdjust) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 100952, "必填,可填写如:调动,变更,入职,离职,其他,初始化"), 0, 0, 3, 3);
|
|||
|
|
// // 调薪
|
|||
|
|
// } else if (isSalaryItemAdjust) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, employeeId, 100953, "必填,可填写如:入职,转正,调薪,调岗调薪,离职,其他,初始化"), 0, 0, 3, 3);
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// excelSheetData.setExcelComment(excelComments);
|
|||
|
|
//
|
|||
|
|
// sheetList.add(excelSheetData);
|
|||
|
|
//
|
|||
|
|
// salaryBatchService.simpleExportExcel(ExportExcelInfo.builder()
|
|||
|
|
// .bizId(map.get("biz").toString())
|
|||
|
|
// .flag(true)
|
|||
|
|
// .userId(employeeId)
|
|||
|
|
// .eteamsId(eteamsId)
|
|||
|
|
// .tenantKey(tenantKey)
|
|||
|
|
// .operator(username)
|
|||
|
|
// .module(map.get("module").toString())
|
|||
|
|
// .fileName(finalNameI18n + "-" + SalaryDateUtil.getFormatLocalDateTime(LocalDateTime.now()))
|
|||
|
|
// .handlerName("exportSalaryArchive")
|
|||
|
|
// .dataType(finalNameI18n + "-")
|
|||
|
|
// .function("exportSalaryArchive").build(), sheetList);
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// @BatchExportHandler("exportSalaryArchive")
|
|||
|
|
// public void exportSalaryArchiveHandler() {
|
|||
|
|
// BatchCallbackMessage message = BatchExportContext.getBatchCallbackMessage();
|
|||
|
|
// log.info("接受到薪资档案导出的结果:{}", JSONObject.toJSONString(message));
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// @Override
|
|||
|
|
// public List<SalaryArchiveDimissionPO> dimissionSets(String tenantKey) {
|
|||
|
|
// return new LambdaQueryChainWrapper<>(salaryArchiveDimissionMapper)
|
|||
|
|
// .eq(SalaryArchiveDimissionPO::getDeleteType, 0)
|
|||
|
|
// .eq(SalaryArchiveDimissionPO::getTenantKey, tenantKey).list();
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// @Override
|
|||
|
|
// public String saveDimissionSet(SalaryArchiveDimissionSaveParam saveParam, Long employeeId, String tenantKey) {
|
|||
|
|
// List<SalaryArchiveDimissionPO> dimissionSets = new LambdaQueryChainWrapper<>(salaryArchiveDimissionMapper)
|
|||
|
|
// .eq(SalaryArchiveDimissionPO::getDeleteType, 0)
|
|||
|
|
// .eq(SalaryArchiveDimissionPO::getTenantKey, tenantKey).list();
|
|||
|
|
// if (CollectionUtils.isNotEmpty(dimissionSets)) {
|
|||
|
|
// SalaryArchiveDimissionPO po = dimissionSets.get(0);
|
|||
|
|
// po.setDimissionTimeInterval(saveParam.getDimissionTimeInterval().getValue());
|
|||
|
|
// po.setUpdateTime(LocalDateTime.now());
|
|||
|
|
// salaryArchiveDimissionMapper.updateById(po);
|
|||
|
|
// } else {
|
|||
|
|
// salaryArchiveDimissionMapper.insert(SalaryArchiveDimissionPO
|
|||
|
|
// .builder()
|
|||
|
|
// .id(IdGenerator.generate())
|
|||
|
|
// .dimissionTimeInterval(saveParam.getDimissionTimeInterval().getValue())
|
|||
|
|
// .createTime(LocalDateTime.now())
|
|||
|
|
// .updateTime(LocalDateTime.now())
|
|||
|
|
// .creator(employeeId)
|
|||
|
|
// .tenantKey(tenantKey)
|
|||
|
|
// .build()
|
|||
|
|
// );
|
|||
|
|
// }
|
|||
|
|
// return StringUtils.EMPTY;
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// @Override
|
|||
|
|
// public List<SalaryArchiveDataDTO> getSalaryArchiveData(LocalDateRange localDateRange, Collection<Long> employeeIds, String tenantKey) {
|
|||
|
|
// return getSalaryArchiveData(localDateRange, employeeIds, Boolean.FALSE, tenantKey);
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// @Override
|
|||
|
|
// public List<SalaryArchiveDataDTO> getSalaryArchiveTaxAgentData(LocalDateRange localDateRange, Collection<Long> employeeIds, String tenantKey) {
|
|||
|
|
// return getSalaryArchiveData(localDateRange, employeeIds, Boolean.TRUE, tenantKey);
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// /**
|
|||
|
|
// * 根据日期范围和人员获取薪资档案数据
|
|||
|
|
// * @param localDateRange
|
|||
|
|
// * @param employeeIds
|
|||
|
|
// * @param isOnlyTaxAgent
|
|||
|
|
// * @param tenantKey
|
|||
|
|
// * @return
|
|||
|
|
// */
|
|||
|
|
// private List<SalaryArchiveDataDTO> getSalaryArchiveData(LocalDateRange localDateRange, Collection<Long> employeeIds, boolean isOnlyTaxAgent, String tenantKey) {
|
|||
|
|
// // 获取个税扣缴义务人调整数据
|
|||
|
|
// List<SalaryArchiveTaxAgentPO> salaryArchiveTaxAgentList = new LambdaQueryChainWrapper<>(salaryArchiveTaxAgentMapper)
|
|||
|
|
// .eq(SalaryArchiveTaxAgentPO::getDeleteType, 0)
|
|||
|
|
// .eq(SalaryArchiveTaxAgentPO::getTenantKey, tenantKey)
|
|||
|
|
// .in(CollectionUtils.isNotEmpty(employeeIds), SalaryArchiveTaxAgentPO::getEmployeeId, employeeIds)
|
|||
|
|
// .le(SalaryArchiveTaxAgentPO::getEffectiveTime, localDateRange.getEndDate())
|
|||
|
|
// .orderByDesc(SalaryArchiveTaxAgentPO::getEffectiveTime)
|
|||
|
|
// .list();
|
|||
|
|
// List<Long> allEmployeeIds = salaryArchiveTaxAgentList.stream().map(SalaryArchiveTaxAgentPO::getEmployeeId).distinct().collect(Collectors.toList());
|
|||
|
|
// // 获取所有可被引用的薪资项目
|
|||
|
|
// List<SalaryItemPO> salaryItems = salaryArchiveItemService.getCanAdjustSalaryItems(tenantKey);
|
|||
|
|
// Collection<Long> salaryItemIds = salaryItems.stream().map(SalaryItemPO::getId).collect(Collectors.toList());
|
|||
|
|
// // 获取薪资项目调整数据,isOnlyTaxAgent为true时不需要薪资项目数据
|
|||
|
|
// List<SalaryArchiveItemPO> salaryArchiveItemDataList = isOnlyTaxAgent || CollectionUtils.isEmpty(salaryItemIds)?Lists.newArrayList():new LambdaQueryChainWrapper<>(salaryArchiveItemMapper)
|
|||
|
|
// .eq(SalaryArchiveItemPO::getDeleteType, 0)
|
|||
|
|
// .eq(SalaryArchiveItemPO::getTenantKey, tenantKey)
|
|||
|
|
// .in(CollectionUtils.isNotEmpty(employeeIds), SalaryArchiveItemPO::getEmployeeId, employeeIds)
|
|||
|
|
// .in(SalaryArchiveItemPO::getSalaryItemId, salaryItemIds)
|
|||
|
|
// .le(SalaryArchiveItemPO::getEffectiveTime, localDateRange.getEndDate())
|
|||
|
|
// .orderByDesc(SalaryArchiveItemPO::getEffectiveTime)
|
|||
|
|
// .list();
|
|||
|
|
// return SalaryArchiveBO.buildSalaryArchiveData(salaryArchiveTaxAgentList,
|
|||
|
|
// salaryArchiveItemDataList,
|
|||
|
|
// localDateRange,
|
|||
|
|
// allEmployeeIds,
|
|||
|
|
// isOnlyTaxAgent);
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// /**
|
|||
|
|
// * 导入薪资档案
|
|||
|
|
// */
|
|||
|
|
// @BatchImportHandler("importSalaryArchive")
|
|||
|
|
// public void importSalaryArchive() {
|
|||
|
|
// BatchDocumentMessage message = BatchImportContext.getBatchDocumentMessage();
|
|||
|
|
// log.info("【薪资档案】接收到上传的数据：{}", JSONObject.toJSONString(message));
|
|||
|
|
// // 租户key
|
|||
|
|
// String tenantKey = message.getTenantKey().toLowerCase();
|
|||
|
|
// try {
|
|||
|
|
// // 加密用
|
|||
|
|
// DSTenantKeyThreadVar.tenantKey.set(tenantKey);
|
|||
|
|
// // 接收到解析的数据
|
|||
|
|
// batchImportEbatch(message);
|
|||
|
|
// } catch (Exception e) {
|
|||
|
|
// e.printStackTrace();
|
|||
|
|
// log.error("【薪资档案】导入失败：{}", String.format("BatchTaskId=%s,错误信息=%s", message.getBatchTaskId(), e.getMessage()));
|
|||
|
|
// } finally {
|
|||
|
|
// // 加密用
|
|||
|
|
// DSTenantKeyThreadVar.tenantKey.remove();
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// /**
|
|||
|
|
// * 导入的数据插入到数据库中
|
|||
|
|
// * @param message
|
|||
|
|
// */
|
|||
|
|
// @Transactional(rollbackFor = Exception.class)
|
|||
|
|
// public void batchImportEbatch(BatchDocumentMessage message) {
|
|||
|
|
// List<ExcelSheet> excelSheets = message.getBatchFile().getExcelSheets();
|
|||
|
|
//
|
|||
|
|
// // 租户key
|
|||
|
|
// String tenantKey = message.getTenantKey().toLowerCase();
|
|||
|
|
// Long currentEmployeeId = message.getUserId();
|
|||
|
|
// String paramsData = message.getUploadSet().getCustomData();
|
|||
|
|
// Map<String, Object> params = JSONObject.parseObject(paramsData, Map.class);
|
|||
|
|
//
|
|||
|
|
// // 1.自定义参数校验
|
|||
|
|
// boolean isValid = checkParams(message, params);
|
|||
|
|
// if (!isValid) {
|
|||
|
|
// return;
|
|||
|
|
// }
|
|||
|
|
// // 导入类型
|
|||
|
|
// String importType = params.get("importType").toString();
|
|||
|
|
//
|
|||
|
|
// // 2.构建导入需要的数据
|
|||
|
|
// SalaryArchiveImportHandleParam importHandleParam = buildImportHandleParam(tenantKey);
|
|||
|
|
//
|
|||
|
|
// int total = 0;
|
|||
|
|
// for (ExcelSheet excelSheet : excelSheets) {
|
|||
|
|
// List<Map<String, Object>> data = excelSheet.getData();
|
|||
|
|
// if (data != null) {
|
|||
|
|
// total += data.size();
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// int index = 0;
|
|||
|
|
// int successCount = 0;
|
|||
|
|
// int errorCount = 0;
|
|||
|
|
// // 错误excel内容
|
|||
|
|
// List<ExcelSheet> errorExcelSheets = new ArrayList<>();
|
|||
|
|
// // 用于（初始化导入）的相同employeeId时的处理
|
|||
|
|
// boolean isInit = importType.equals(SalaryArchiveImportTypeEnum.INIT.getValue());
|
|||
|
|
// List<SalaryArchiveInitImportDTO> initImportData = Lists.newArrayList();
|
|||
|
|
// // 用于（调薪和调整个税扣缴义务人）的相同employeeId时取第一条记录,如果是初始化导入则有重复
|
|||
|
|
// List<Long> allEmployeeIds = Lists.newArrayList();
|
|||
|
|
// for (ExcelSheet excelSheet : excelSheets) {
|
|||
|
|
// if (excelSheet.getHeader().size() == 0) {
|
|||
|
|
// continue;
|
|||
|
|
// }
|
|||
|
|
// List<Map> headers = excelSheet.getHeader();
|
|||
|
|
// boolean isValidHeader = checkHeaders(importType, message, headers);
|
|||
|
|
// if (!isValidHeader) {
|
|||
|
|
// return;
|
|||
|
|
// }
|
|||
|
|
// int effectiveTimeIndex = 0;
|
|||
|
|
// for (int j = 0; j < headers.size(); j++) {
|
|||
|
|
// Map header = headers.get(j);
|
|||
|
|
// String key = Optional.ofNullable(header.get("key")).orElse("").toString();
|
|||
|
|
// if (key.equals(SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 85904, "生效日期"))) {
|
|||
|
|
// effectiveTimeIndex = j;
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// // 错误sheet数据
|
|||
|
|
// List<Map<String,Object>> errorData = new ArrayList<>();
|
|||
|
|
// // 错误提示
|
|||
|
|
// List<ExcelComment> excelComments = new ArrayList<>();
|
|||
|
|
//
|
|||
|
|
// List<Map<String, Object>> data = excelSheet.getData();
|
|||
|
|
// Map<String, Object> map;
|
|||
|
|
// if (data == null) {
|
|||
|
|
// continue;
|
|||
|
|
// }
|
|||
|
|
// for (int i = 0; i < data.size(); i++) {
|
|||
|
|
// index += 1;
|
|||
|
|
// map = data.get(i);
|
|||
|
|
// // 3.校验行内容
|
|||
|
|
// boolean isError = singleRowCheck(importType, allEmployeeIds, map, headers, effectiveTimeIndex, excelComments, errorCount, currentEmployeeId, tenantKey, importHandleParam);
|
|||
|
|
//
|
|||
|
|
// if (isError) {
|
|||
|
|
// errorCount += 1;
|
|||
|
|
// // 添加错误数据
|
|||
|
|
// errorData.add(map);
|
|||
|
|
// } else {
|
|||
|
|
// successCount += 1;
|
|||
|
|
// }
|
|||
|
|
// // 初始化导入对重复记录校验
|
|||
|
|
// if (isInit) {
|
|||
|
|
// Map<String, Object> validMap = validInitImportData(isError, i, map, excelComments, errorCount, successCount, errorData, initImportData, currentEmployeeId, tenantKey, importHandleParam);
|
|||
|
|
// errorCount = Integer.parseInt(validMap.getOrDefault("errorCount", errorCount).toString());
|
|||
|
|
// successCount = Integer.parseInt(validMap.getOrDefault("successCount", successCount).toString());
|
|||
|
|
// }
|
|||
|
|
// // 导入进度
|
|||
|
|
// salaryBatchService.sendImportRate(message.getBizId(), total, index);
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// // 如果sheet包含错误数据
|
|||
|
|
// if (CollectionUtils.isNotEmpty(errorData)) {
|
|||
|
|
// salaryBatchService.createErrorExcelSheet(headers, errorData, excelSheet.getName(), excelComments, errorExcelSheets);
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// // 4.数据入库处理
|
|||
|
|
// handleImportData(isInit, tenantKey, importHandleParam);
|
|||
|
|
//
|
|||
|
|
// // 发送导入回调信息
|
|||
|
|
// salaryBatchService.sendImportCallBackInfo(message, successCount, errorCount, errorExcelSheets);
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// /**
|
|||
|
|
// * 构建导入处理参数
|
|||
|
|
// * @param tenantKey
|
|||
|
|
// * @return
|
|||
|
|
// */
|
|||
|
|
// private SalaryArchiveImportHandleParam buildImportHandleParam(String tenantKey) {
|
|||
|
|
// // 获取所有可被引用的薪资项目
|
|||
|
|
// List<SalaryItemPO> salaryItems = salaryArchiveItemService.getCanAdjustSalaryItems(tenantKey);
|
|||
|
|
//
|
|||
|
|
// Collection<Long> salaryItemIds = salaryItems.stream().map(SalaryItemPO::getId).collect(Collectors.toList());
|
|||
|
|
//
|
|||
|
|
// return SalaryArchiveImportHandleParam.builder()
|
|||
|
|
// // 获取租户下所有的人员
|
|||
|
|
// .employees(mapper.listEmployee(tenantKey))
|
|||
|
|
// // 获取所有个税扣缴义务人
|
|||
|
|
// .taxAgentList(taxAgentService.findAll(tenantKey))
|
|||
|
|
// .salaryItems(salaryItems)
|
|||
|
|
// // 查询已有的薪资档案基本数据
|
|||
|
|
// .salaryArchives(mapper.list(SalaryArchiveQueryParam.builder().build(), tenantKey))
|
|||
|
|
// .salaryItemIds(salaryItemIds)
|
|||
|
|
// // 查询已生效的薪资项目数据
|
|||
|
|
// .effectiveItemList(getEffectiveItemList(salaryItemIds, tenantKey))
|
|||
|
|
// // 查询未生效的薪资项目数据
|
|||
|
|
// .ineffectiveItemList(getIneffectiveItemList(salaryItemIds, tenantKey))
|
|||
|
|
// // 查询已生效的个税扣缴义务人数据
|
|||
|
|
// .effectiveTaxAgentList(getEffectiveTaxAgentList(tenantKey))
|
|||
|
|
// // 查询未生效的个税扣缴义务人数据
|
|||
|
|
// .ineffectiveTaxAgentList(getIneffectiveTaxAgentList(tenantKey))
|
|||
|
|
// // 当前时间
|
|||
|
|
// .nowTime(LocalDateTime.now())
|
|||
|
|
// // 当天
|
|||
|
|
// .today(LocalDate.now())
|
|||
|
|
// // 待保存薪资档案
|
|||
|
|
// .salaryArchiveSaves(Lists.newArrayList())
|
|||
|
|
// // 待保存薪资档案-个税扣缴义务人
|
|||
|
|
// .salaryArchiveTaxAgentSaves(Lists.newArrayList())
|
|||
|
|
// // 待保存薪资档案-薪资项目
|
|||
|
|
// .salaryArchiveItemSaves(Lists.newArrayList())
|
|||
|
|
// // 待删除薪资档案-个税扣缴义务人
|
|||
|
|
// .salaryArchiveTaxAgentDelTaxAgentIds(Lists.newArrayList())
|
|||
|
|
// // 待删除薪资档案-薪资项目
|
|||
|
|
// .salaryArchiveItemDelSalaryItemIds(Lists.newArrayList())
|
|||
|
|
// .build();
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// /**
|
|||
|
|
// * 初始化导入数据校验
|
|||
|
|
// * 说明：如果一个人的多条记录中有一个错那么就全部弄到错误文档中
|
|||
|
|
// * @param isError
|
|||
|
|
// * @param rowNo
|
|||
|
|
// * @param map
|
|||
|
|
// * @param excelComments
|
|||
|
|
// * @param errorCount
|
|||
|
|
// * @param successCount
|
|||
|
|
// * @param errorData
|
|||
|
|
// * @param initImportData
|
|||
|
|
// * @param currentEmployeeId
|
|||
|
|
// * @param tenantKey
|
|||
|
|
// * @param importHandleParam
|
|||
|
|
// */
|
|||
|
|
// private Map<String, Object> validInitImportData(boolean isError, int rowNo, Map<String, Object> map, List<ExcelComment> excelComments, int errorCount, int successCount, List<Map<String,Object>> errorData, List<SalaryArchiveInitImportDTO> initImportData, Long currentEmployeeId, String tenantKey, SalaryArchiveImportHandleParam importHandleParam) {
|
|||
|
|
// Long employeeId = Long.valueOf(Optional.ofNullable(map.get("employeeId")).orElse("0").toString());
|
|||
|
|
// Optional<SalaryArchiveInitImportDTO> optionalInitImport = initImportData.stream().filter(f -> f.getEmployeeId().equals(employeeId)).findFirst();
|
|||
|
|
//
|
|||
|
|
// Map<String, Object> validMap = new HashMap<>();
|
|||
|
|
// validMap.put("errorCount", errorCount);
|
|||
|
|
// validMap.put("successCount", successCount);
|
|||
|
|
//
|
|||
|
|
// if (employeeId.equals(0L)) {
|
|||
|
|
// return validMap;
|
|||
|
|
// }
|
|||
|
|
// AtomicInteger finalErrorCount = new AtomicInteger(errorCount);
|
|||
|
|
// AtomicInteger finalSuccessCount = new AtomicInteger(successCount);
|
|||
|
|
// if (optionalInitImport.isPresent()) {
|
|||
|
|
// SalaryArchiveInitImportDTO initImport = optionalInitImport.get();
|
|||
|
|
// List<SalaryArchiveInitImportSameDTO> sames = initImport.getSames();
|
|||
|
|
// sames.add(SalaryArchiveInitImportSameDTO.builder()
|
|||
|
|
// .isError(isError)
|
|||
|
|
// .rowNo(rowNo)
|
|||
|
|
// .row(map)
|
|||
|
|
// .build());
|
|||
|
|
// Optional<SalaryArchiveInitImportSameDTO> optionalSame = sames.stream().filter(SalaryArchiveInitImportSameDTO::isError).findFirst();
|
|||
|
|
// // 只要是其中一行有错误
|
|||
|
|
// if (optionalSame.isPresent()) {
|
|||
|
|
// sames.forEach(e->{
|
|||
|
|
// if (!e.isError()) {
|
|||
|
|
// e.setError(Boolean.TRUE);
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 101723, "该员工的薪资档案记录有误，请检查"), finalErrorCount.get() +1, finalErrorCount.get() +1, 0, 0);
|
|||
|
|
// finalErrorCount.addAndGet(1);
|
|||
|
|
// errorData.add(e.getRow());
|
|||
|
|
// finalSuccessCount.addAndGet(-1);
|
|||
|
|
// }
|
|||
|
|
// });
|
|||
|
|
// // 如果到目前为止都没错的话，则相互之间检验调整记录
|
|||
|
|
// } else {
|
|||
|
|
// int nums = sames.size();
|
|||
|
|
// // 1.生效时间不可重复
|
|||
|
|
// List<String> effectiveTimeList = sames.stream().map(m->Optional.ofNullable(m.getRow().get("effectiveTime")).orElse("").toString()).distinct().collect(Collectors.toList());
|
|||
|
|
// // 2.个税扣缴义务人和薪资项目共同决定是否重复
|
|||
|
|
// List<String> rowSameList = sames.stream().map(m->{
|
|||
|
|
// Map<String, Object> row = m.getRow();
|
|||
|
|
// String taxAgent = Optional.ofNullable(row.get("taxAgent")).orElse("").toString();
|
|||
|
|
// String salaryItem = Optional.ofNullable(row.get("salaryItemVal")).orElse("").toString();
|
|||
|
|
// return taxAgent+salaryItem;
|
|||
|
|
// }).distinct().collect(Collectors.toList());
|
|||
|
|
// if (effectiveTimeList.size()!=nums || rowSameList.size()!=nums) {
|
|||
|
|
// sames.forEach(e->{
|
|||
|
|
// if (!e.isError()) {
|
|||
|
|
// e.setError(Boolean.TRUE);
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 101723, "该员工的薪资档案记录有误，请检查"), finalErrorCount.get() +1, finalErrorCount.get() +1, 0, 0);
|
|||
|
|
// finalErrorCount.addAndGet(1);
|
|||
|
|
// errorData.add(e.getRow());
|
|||
|
|
// finalSuccessCount.addAndGet(-1);
|
|||
|
|
// }
|
|||
|
|
// });
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// initImport.setSames(sames);
|
|||
|
|
// } else {
|
|||
|
|
// SalaryArchiveInitImportDTO initImport = new SalaryArchiveInitImportDTO();
|
|||
|
|
// initImport.setEmployeeId(employeeId);
|
|||
|
|
// List<SalaryArchiveInitImportSameDTO> sames = Lists.newArrayList();
|
|||
|
|
// sames.add(SalaryArchiveInitImportSameDTO.builder()
|
|||
|
|
// .isError(isError)
|
|||
|
|
// .rowNo(rowNo)
|
|||
|
|
// .row(map)
|
|||
|
|
// .build());
|
|||
|
|
// initImport.setSames(sames);
|
|||
|
|
// initImportData.add(initImport);
|
|||
|
|
// }
|
|||
|
|
// // 如果出现错误
|
|||
|
|
// if (isError || errorCount!=finalErrorCount.get() || successCount!=finalSuccessCount.get()) {
|
|||
|
|
// validMap.put("errorCount", finalErrorCount.get());
|
|||
|
|
// validMap.put("successCount", finalSuccessCount.get());
|
|||
|
|
// // 将前面添加好的数据给过滤掉
|
|||
|
|
// importHandleParam.setSalaryArchiveSaves(importHandleParam.getSalaryArchiveSaves().stream().filter(f->!f.getEmployeeId().equals(employeeId)).collect(Collectors.toList()));
|
|||
|
|
// importHandleParam.setSalaryArchiveTaxAgentSaves(importHandleParam.getSalaryArchiveTaxAgentSaves().stream().filter(f->!f.getEmployeeId().equals(employeeId)).collect(Collectors.toList()));
|
|||
|
|
// importHandleParam.setSalaryArchiveItemSaves(importHandleParam.getSalaryArchiveItemSaves().stream().filter(f->!f.getEmployeeId().equals(employeeId)).collect(Collectors.toList()));
|
|||
|
|
// }
|
|||
|
|
// return validMap;
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// /**
|
|||
|
|
// * 校验单行数据
|
|||
|
|
// * @param importType
|
|||
|
|
// * @param allEmployeeIds
|
|||
|
|
// * @param map
|
|||
|
|
// * @param headers
|
|||
|
|
// * @param excelComments
|
|||
|
|
// * @param errorCount
|
|||
|
|
// * @param currentEmployeeId
|
|||
|
|
// * @param tenantKey
|
|||
|
|
// * @param importHandleParam
|
|||
|
|
// * @return
|
|||
|
|
// */
|
|||
|
|
// private boolean singleRowCheck(String importType, List<Long> allEmployeeIds, Map<String, Object> map, List<Map> headers, int effectiveTimeIndex, List<ExcelComment> excelComments, int errorCount, Long currentEmployeeId, String tenantKey, SalaryArchiveImportHandleParam importHandleParam) {
|
|||
|
|
// boolean isError = false;
|
|||
|
|
//
|
|||
|
|
// boolean isInit = importType.equals(SalaryArchiveImportTypeEnum.INIT.getValue());
|
|||
|
|
// boolean isTaxAgentAdjust = importType.equals(SalaryArchiveImportTypeEnum.TAXAGENTADJUST.getValue());
|
|||
|
|
// boolean isSalaryItemAdjust = importType.equals(SalaryArchiveImportTypeEnum.SALARYITEMADJUST.getValue());
|
|||
|
|
//
|
|||
|
|
// String userNameI18n = SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 85429, "姓名");
|
|||
|
|
// String taxAgentI18n = SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 86184, "个税扣缴义务人");
|
|||
|
|
// String effectiveTimeI18n = SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 85904, "生效日期");
|
|||
|
|
// String adjustReasonI18n = SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 85431, "调整原因");
|
|||
|
|
// // 1.姓名
|
|||
|
|
// String userName = Optional.ofNullable(map.get(userNameI18n)).orElse("").toString();
|
|||
|
|
// String deparmentName = Optional.ofNullable(map.get(SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 86185, "部门"))).orElse("").toString();
|
|||
|
|
// List<Long> employeeSameIds = importHandleParam.getEmployees().stream().filter(e -> (StringUtils.isBlank(userName) || Objects.equals(e.getUsername(), userName))
|
|||
|
|
// && (StringUtils.isBlank(deparmentName) || Objects.equals(e.getDeparmentName(), deparmentName))).map(SalaryArchiveEmployeePO::getEmployeeId)
|
|||
|
|
// .collect(Collectors.toList());
|
|||
|
|
// Long employeeId = CollectionUtils.isNotEmpty(employeeSameIds) && employeeSameIds.size() == 1 && employeeSameIds.get(0)>0?employeeSameIds.get(0):null;
|
|||
|
|
// // 调薪和调整个税扣缴义务人的存在相同的取第一条
|
|||
|
|
// if (employeeId != null && allEmployeeIds.contains(employeeId) && (isTaxAgentAdjust || isSalaryItemAdjust)) {
|
|||
|
|
// return isError;
|
|||
|
|
// }
|
|||
|
|
// if (employeeId != null) {
|
|||
|
|
// allEmployeeIds.add(employeeId);
|
|||
|
|
// }
|
|||
|
|
// // 用于初始化导入数据校验
|
|||
|
|
// map.put("employeeId", employeeId);
|
|||
|
|
// map.put("rowId", employeeId);
|
|||
|
|
// // 2.生效日期
|
|||
|
|
// String effectiveTimeCellVal = Optional.ofNullable(map.get(effectiveTimeI18n)).orElse("").toString().replaceAll(" 00:00:00", "");
|
|||
|
|
// // 免得失败后，会追加 00:00:00
|
|||
|
|
// map.put(effectiveTimeI18n, effectiveTimeCellVal);
|
|||
|
|
// map.put("effectiveTime", effectiveTimeCellVal);
|
|||
|
|
// LocalDate effectiveTime = SalaryDateUtil.checkDay(effectiveTimeCellVal)?dateStrToLocalDate(effectiveTimeCellVal):null;
|
|||
|
|
// // 3.个税扣缴义务人
|
|||
|
|
// String taxAgentCellVal = Optional.ofNullable(map.get(taxAgentI18n)).orElse("").toString();
|
|||
|
|
// // 用于初始化导入的同一个人的记录校验
|
|||
|
|
// map.put("taxAgent", taxAgentCellVal);
|
|||
|
|
// Optional<TaxAgentListDTO> optionalTaxAgent = importHandleParam.getTaxAgentList().stream().filter(m -> m.getName().equals(taxAgentCellVal)).findFirst();
|
|||
|
|
// Long taxAgentId = optionalTaxAgent.map(TaxAgentListDTO::getId).orElse(null);
|
|||
|
|
// // 4.调整原因
|
|||
|
|
// String adjustReason = "";
|
|||
|
|
// if (isTaxAgentAdjust) {
|
|||
|
|
// // 4.调整原因[个税扣缴义务人]
|
|||
|
|
// adjustReason = SalaryArchiveTaxAgentAdjustReasonEnum.getValueByDefaultLabel(Optional.ofNullable(map.get(adjustReasonI18n)).orElse("").toString(), currentEmployeeId, tenantKey);
|
|||
|
|
// } else if (isSalaryItemAdjust) {
|
|||
|
|
// // 4.调整原因[薪资项目]
|
|||
|
|
// adjustReason = SalaryArchiveItemAdjustReasonEnum.getValueByDefaultLabel(Optional.ofNullable(map.get(adjustReasonI18n)).orElse("").toString(), currentEmployeeId, tenantKey);
|
|||
|
|
// }
|
|||
|
|
// // 构建薪资档案
|
|||
|
|
//
|
|||
|
|
// SalaryArchivePO finalSalaryArchive = buildSalaryArchive(isInit, currentEmployeeId, tenantKey, employeeId, importHandleParam);
|
|||
|
|
// for (int j = 0; j < headers.size(); j++) {
|
|||
|
|
// Map header = headers.get(j);
|
|||
|
|
// Object key = header.get("key");
|
|||
|
|
// if (key == null) {
|
|||
|
|
// continue;
|
|||
|
|
// }
|
|||
|
|
// String cellVal = Optional.ofNullable(map.get(key.toString())).orElse("").toString();
|
|||
|
|
//
|
|||
|
|
// boolean isEmpty = StringUtils.isEmpty(cellVal) &&
|
|||
|
|
// (userNameI18n.equals(key.toString())
|
|||
|
|
// // 个税扣缴义务人列判空(初始化导入或调整个税扣缴义务人)
|
|||
|
|
// || (taxAgentI18n.equals(key.toString()) && (isInit || isTaxAgentAdjust))
|
|||
|
|
// || effectiveTimeI18n.equals(key.toString())
|
|||
|
|
// // 调整原因列判空(调薪或调整个税扣缴义务人)
|
|||
|
|
// || (adjustReasonI18n.equals(key.toString()) && (isTaxAgentAdjust || isSalaryItemAdjust)));
|
|||
|
|
// // 判空
|
|||
|
|
// if (isEmpty) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100577, "不能为空"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// }
|
|||
|
|
// // 1.姓名列处理
|
|||
|
|
// if (!isEmpty && userNameI18n.equals(key.toString())) {
|
|||
|
|
// if (CollectionUtils.isEmpty(employeeSameIds) || employeeSameIds.size() > 1) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100578, "员工信息不能为空且不可重复(姓名与部门同时确认唯一)"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// } else if (employeeId == null) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100579, "姓名错误，系统内不存在该姓名"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// // (调薪或调整个税扣缴义务人)
|
|||
|
|
// } else if (finalSalaryArchive == null && (isTaxAgentAdjust || isSalaryItemAdjust)) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 101653, "该人员的薪资档案不存在，请先初始化"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// }
|
|||
|
|
// // 2.个税扣缴义务人列处理(初始化导入或调整个税扣缴义务人)
|
|||
|
|
// } else if (!isEmpty && taxAgentI18n.equals(key.toString()) && (isInit || isTaxAgentAdjust)) {
|
|||
|
|
// isError = handleTaxAgent(isError, isInit, effectiveTimeIndex, excelComments, errorCount, j, currentEmployeeId, tenantKey,
|
|||
|
|
// taxAgentId, effectiveTime, finalSalaryArchive, adjustReason, importHandleParam);
|
|||
|
|
// // 3.生效时间处理
|
|||
|
|
// } else if (!isEmpty && effectiveTimeI18n.equals(key.toString()) && effectiveTime == null) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 102497, "生效日期错误或格式不正确，正确格式示例为'2022-01-01'、'2022/1/1'"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// // 4.调整原因列处理(调薪或调整个税扣缴义务人)
|
|||
|
|
// } else if (!isEmpty && adjustReasonI18n.equals(key.toString()) && (isTaxAgentAdjust || isSalaryItemAdjust) && StringUtils.isEmpty(adjustReason)) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100591, "调整原因不存在"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// // 5.薪资项目列处理(初始化导入或调薪)
|
|||
|
|
// } else {
|
|||
|
|
// // 薪资项目数据
|
|||
|
|
// if (effectiveTime == null || finalSalaryArchive == null || !(isInit || isSalaryItemAdjust)) {
|
|||
|
|
// continue;
|
|||
|
|
// }
|
|||
|
|
// isError = handleSalaryItem(isError, isInit, effectiveTimeIndex, excelComments, errorCount, j, currentEmployeeId, tenantKey,
|
|||
|
|
// effectiveTime, finalSalaryArchive, adjustReason, importHandleParam, key.toString(), cellVal, map);
|
|||
|
|
//
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// return isError;
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// private SalaryArchivePO buildSalaryArchive(boolean isInit, Long currentEmployeeId, String tenantKey, Long employeeId, SalaryArchiveImportHandleParam importHandleParam) {
|
|||
|
|
// Optional<SalaryArchiveListDTO> optionalSA = importHandleParam.getSalaryArchives().stream().filter(p->p.getEmployeeId().toString().equals(employeeId!=null?employeeId.toString():"")).findFirst();
|
|||
|
|
// SalaryArchivePO salaryArchive = null;
|
|||
|
|
// if (optionalSA.isPresent()) {
|
|||
|
|
// // 修改档案
|
|||
|
|
// SalaryArchiveListDTO sa = optionalSA.get();
|
|||
|
|
// salaryArchive = new SalaryArchivePO();
|
|||
|
|
// salaryArchive.setId(sa.getId());
|
|||
|
|
// salaryArchive.setEmployeeId(sa.getEmployeeId());
|
|||
|
|
// } else if (employeeId!=null && isInit) {
|
|||
|
|
// // 新增档案
|
|||
|
|
// salaryArchive = SalaryArchivePO.builder()
|
|||
|
|
// .id(IdGenerator.generate())
|
|||
|
|
// .employeeId(employeeId)
|
|||
|
|
// .createTime(importHandleParam.getNowTime())
|
|||
|
|
// .updateTime(importHandleParam.getNowTime())
|
|||
|
|
// .creator(currentEmployeeId)
|
|||
|
|
// .tenantKey(tenantKey)
|
|||
|
|
// .build();
|
|||
|
|
// importHandleParam.getSalaryArchiveSaves().add(salaryArchive);
|
|||
|
|
// }
|
|||
|
|
// return salaryArchive;
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// /**
|
|||
|
|
// * 个税扣缴义务人处理
|
|||
|
|
// * @param isError
|
|||
|
|
// * @param excelComments
|
|||
|
|
// * @param errorCount
|
|||
|
|
// * @param j
|
|||
|
|
// * @param currentEmployeeId
|
|||
|
|
// * @param tenantKey
|
|||
|
|
// * @param taxAgentId
|
|||
|
|
// * @param effectiveTime
|
|||
|
|
// * @param finalSalaryArchive
|
|||
|
|
// * @param taxAgentAdjustReason
|
|||
|
|
// * @param importHandleParam
|
|||
|
|
// * @return
|
|||
|
|
// */
|
|||
|
|
// private boolean handleTaxAgent(boolean isError, boolean isInit , int effectiveTimeIndex,
|
|||
|
|
// List<ExcelComment> excelComments, int errorCount, int j, Long currentEmployeeId, String tenantKey,
|
|||
|
|
// Long taxAgentId, LocalDate effectiveTime,SalaryArchivePO finalSalaryArchive, String taxAgentAdjustReason, SalaryArchiveImportHandleParam importHandleParam) {
|
|||
|
|
// if (taxAgentId == null) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100545, "个税扣缴义务人不存在"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// } else if (effectiveTime != null && finalSalaryArchive != null) {
|
|||
|
|
// boolean isBeforeError = false;
|
|||
|
|
// if (!isInit) {
|
|||
|
|
// // 前后调整校验
|
|||
|
|
// // 已生效
|
|||
|
|
// List<SalaryArchiveTaxAgentPO> effectiveList = importHandleParam.getEffectiveTaxAgentList().stream().filter(i -> finalSalaryArchive.getId().equals(i.getSalaryArchiveId())).collect(Collectors.toList());
|
|||
|
|
// // 当前已生效
|
|||
|
|
// SalaryArchiveTaxAgentPO effectiveTaxAgent = CollectionUtils.isNotEmpty(effectiveList)&&effectiveList.size()>0?effectiveList.get(0):null;
|
|||
|
|
// // 当前已生效的前一次调整
|
|||
|
|
// SalaryArchiveTaxAgentPO effectiveBeforeTaxAgent = CollectionUtils.isNotEmpty(effectiveList)&&effectiveList.size()>1?effectiveList.get(1):null;
|
|||
|
|
// // 未生效
|
|||
|
|
// Optional<SalaryArchiveTaxAgentPO> optionalIneffective = importHandleParam.getIneffectiveTaxAgentList().stream().filter(i -> finalSalaryArchive.getId().equals(i.getSalaryArchiveId())).findFirst();
|
|||
|
|
// SalaryArchiveTaxAgentPO ineffectiveTaxAgent = optionalIneffective.orElse(null);
|
|||
|
|
// // 1.检验是否可以调整
|
|||
|
|
// if (effectiveTaxAgent != null) {
|
|||
|
|
// // 当前已经生效的时间
|
|||
|
|
// LocalDate currentEffectiveTime = effectiveTaxAgent.getEffectiveTime();
|
|||
|
|
// // 1.1 如果早于<当前已生效
|
|||
|
|
// if (effectiveTime.isBefore(currentEffectiveTime)) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100429, "生效日期不可早于当前已生效的调整日期"), errorCount+1, errorCount+1, effectiveTimeIndex, effectiveTimeIndex);
|
|||
|
|
// isError = true;
|
|||
|
|
// isBeforeError = true;
|
|||
|
|
// // 1.2 如果等于当前已生效
|
|||
|
|
// } else if (effectiveTime.isEqual(currentEffectiveTime)) {
|
|||
|
|
// if (effectiveBeforeTaxAgent != null && effectiveBeforeTaxAgent.getTaxAgentId().equals(taxAgentId)) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100432, "调整前后不可相同"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// }
|
|||
|
|
// if (ineffectiveTaxAgent != null && ineffectiveTaxAgent.getTaxAgentId().equals(taxAgentId)) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100434, "与未生效的调整后不可相同"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// }
|
|||
|
|
// // 1.3 如果>已经生效且<=今天
|
|||
|
|
// } else if (effectiveTime.isAfter(currentEffectiveTime) && !effectiveTime.isAfter(importHandleParam.getToday())) {
|
|||
|
|
// if (effectiveTaxAgent.getTaxAgentId().equals(taxAgentId)) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100432, "调整前后不可相同"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// }
|
|||
|
|
// if (ineffectiveTaxAgent != null && ineffectiveTaxAgent.getTaxAgentId().equals(taxAgentId)) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100434, "与未生效的调整后不可相同"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// }
|
|||
|
|
// // 1.4 如果>今天
|
|||
|
|
// } else if (effectiveTime.isAfter(importHandleParam.getToday()) && effectiveTaxAgent.getTaxAgentId().equals(taxAgentId)) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100432, "调整前后不可相同"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// }
|
|||
|
|
// } else if (ineffectiveTaxAgent != null && ineffectiveTaxAgent.getTaxAgentId().equals(taxAgentId)) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100434, "与未生效的调整后不可相同"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// }
|
|||
|
|
// // 2.数据处理,有的就先删后增
|
|||
|
|
// if (effectiveTaxAgent != null && effectiveTime.isEqual(effectiveTaxAgent.getEffectiveTime())) {
|
|||
|
|
// importHandleParam.getSalaryArchiveTaxAgentDelTaxAgentIds().add(effectiveTaxAgent.getId());
|
|||
|
|
// }
|
|||
|
|
// if (ineffectiveTaxAgent != null && effectiveTime.isAfter(importHandleParam.getToday())) {
|
|||
|
|
// importHandleParam.getSalaryArchiveTaxAgentDelTaxAgentIds().add(ineffectiveTaxAgent.getId());
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// if (!isBeforeError) {
|
|||
|
|
// importHandleParam.getSalaryArchiveTaxAgentSaves().add(SalaryArchiveTaxAgentPO.builder()
|
|||
|
|
// .id(IdGenerator.generate())
|
|||
|
|
// .salaryArchiveId(finalSalaryArchive.getId())
|
|||
|
|
// .employeeId(finalSalaryArchive.getEmployeeId())
|
|||
|
|
// .taxAgentId(taxAgentId)
|
|||
|
|
// .effectiveTime(effectiveTime)
|
|||
|
|
// .adjustReason(StringUtils.isEmpty(taxAgentAdjustReason)?SalaryArchiveTaxAgentAdjustReasonEnum.INIT.getValue():taxAgentAdjustReason)
|
|||
|
|
// .operator(currentEmployeeId)
|
|||
|
|
// .operateTime(importHandleParam.getNowTime())
|
|||
|
|
// .createTime(importHandleParam.getNowTime())
|
|||
|
|
// .updateTime(importHandleParam.getNowTime())
|
|||
|
|
// .creator(currentEmployeeId)
|
|||
|
|
// .tenantKey(tenantKey)
|
|||
|
|
// .build());
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// return isError;
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// /**
|
|||
|
|
// * 薪资项目处理
|
|||
|
|
// * @param isError
|
|||
|
|
// * @param excelComments
|
|||
|
|
// * @param errorCount
|
|||
|
|
// * @param j
|
|||
|
|
// * @param currentEmployeeId
|
|||
|
|
// * @param tenantKey
|
|||
|
|
// * @param effectiveTime
|
|||
|
|
// * @param finalSalaryArchive
|
|||
|
|
// * @param salaryItemAdjustReason
|
|||
|
|
// * @param importHandleParam
|
|||
|
|
// * @param cellVal
|
|||
|
|
// * @return
|
|||
|
|
// */
|
|||
|
|
// private boolean handleSalaryItem(boolean isError, boolean isInit, int effectiveTimeIndex,
|
|||
|
|
// List<ExcelComment> excelComments, int errorCount, int j, Long currentEmployeeId, String tenantKey,
|
|||
|
|
// LocalDate effectiveTime,SalaryArchivePO finalSalaryArchive, String salaryItemAdjustReason, SalaryArchiveImportHandleParam importHandleParam,
|
|||
|
|
// String key, String cellVal, Map<String, Object> map) {
|
|||
|
|
// Optional<SalaryItemPO> optionalSalaryItem = importHandleParam.getSalaryItems().stream().filter(e->e.getName().equals(key)).findFirst();
|
|||
|
|
// if (optionalSalaryItem.isPresent()) {
|
|||
|
|
// Long salaryItemId = optionalSalaryItem.get().getId();
|
|||
|
|
// boolean isBeforeError = false;
|
|||
|
|
// if (!isInit) {
|
|||
|
|
// // 已生效
|
|||
|
|
// List<SalaryArchiveItemPO> effectiveList = importHandleParam.getEffectiveItemList().stream().filter(i -> finalSalaryArchive.getId().equals(i.getSalaryArchiveId()) && i.getSalaryItemId().equals(salaryItemId)).collect(Collectors.toList());
|
|||
|
|
// // 当前已生效
|
|||
|
|
// SalaryArchiveItemPO effectiveSalaryItem = CollectionUtils.isNotEmpty(effectiveList)&&effectiveList.size()>0?effectiveList.get(0):null;
|
|||
|
|
// // 当前已生效的前一次调整
|
|||
|
|
// SalaryArchiveItemPO effectiveBeforeSalaryItem = CollectionUtils.isNotEmpty(effectiveList)&&effectiveList.size()>1?effectiveList.get(1):null;
|
|||
|
|
// // 未生效
|
|||
|
|
// Optional<SalaryArchiveItemPO> optionalIneffective = importHandleParam.getIneffectiveItemList().stream().filter(i -> finalSalaryArchive.getId().equals(i.getSalaryArchiveId()) && i.getSalaryItemId().equals(salaryItemId)).findFirst();
|
|||
|
|
// SalaryArchiveItemPO ineffectiveSalaryItem = optionalIneffective.orElse(null);
|
|||
|
|
//
|
|||
|
|
// // 1.检验是否可以调整
|
|||
|
|
// if (effectiveSalaryItem != null) {
|
|||
|
|
// // 当前已经生效的时间
|
|||
|
|
// LocalDate currentEffectiveTime = effectiveSalaryItem.getEffectiveTime();
|
|||
|
|
// // 1.1 如果早于<当前已生效
|
|||
|
|
// if (effectiveTime.isBefore(currentEffectiveTime)) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100429, "生效日期不可早于当前已生效的调整日期"), errorCount+1, errorCount+1, effectiveTimeIndex, effectiveTimeIndex);
|
|||
|
|
// isError = true;
|
|||
|
|
// isBeforeError = true;
|
|||
|
|
// // 1.2 如果等于当前已生效
|
|||
|
|
// } else if (effectiveTime.isEqual(currentEffectiveTime)) {
|
|||
|
|
// if (effectiveBeforeSalaryItem !=null && effectiveBeforeSalaryItem.getItemValue().equals(cellVal)) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100432, "调整前后不可相同"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// }
|
|||
|
|
// if (ineffectiveSalaryItem != null && ineffectiveSalaryItem.getItemValue().equals(cellVal)) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100434, "与未生效的调整后不可相同"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// }
|
|||
|
|
// // 1.3 如果>已经生效且<=今天
|
|||
|
|
// } else if (effectiveTime.isAfter(currentEffectiveTime) && !effectiveTime.isAfter(importHandleParam.getToday())) {
|
|||
|
|
// if (effectiveSalaryItem.getItemValue().equals(cellVal)) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100432, "调整前后不可相同"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// }
|
|||
|
|
// if (ineffectiveSalaryItem != null && ineffectiveSalaryItem.getItemValue().equals(cellVal)) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100434, "与未生效的调整后不可相同"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// }
|
|||
|
|
// // 1.4 如果>今天
|
|||
|
|
// } else if (effectiveTime.isAfter(importHandleParam.getToday()) && effectiveSalaryItem.getItemValue().equals(cellVal)) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100432, "调整前后不可相同"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// }
|
|||
|
|
// } else if (ineffectiveSalaryItem != null && ineffectiveSalaryItem.getItemValue().equals(cellVal)) {
|
|||
|
|
// salaryBatchService.createExcelComment(excelComments, SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 100434, "与未生效的调整后不可相同"), errorCount+1, errorCount+1, j, j);
|
|||
|
|
// isError = true;
|
|||
|
|
// }
|
|||
|
|
// // 2.数据处理
|
|||
|
|
// if (effectiveSalaryItem != null && effectiveTime.isEqual(effectiveSalaryItem.getEffectiveTime())) {
|
|||
|
|
// importHandleParam.getSalaryArchiveItemDelSalaryItemIds().add(effectiveSalaryItem.getId());
|
|||
|
|
// }
|
|||
|
|
// if (ineffectiveSalaryItem != null && effectiveTime.isAfter(importHandleParam.getToday())) {
|
|||
|
|
// importHandleParam.getSalaryArchiveItemDelSalaryItemIds().add(ineffectiveSalaryItem.getId());
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// if (!isBeforeError) {
|
|||
|
|
// importHandleParam.getSalaryArchiveItemSaves().add(SalaryArchiveItemPO.builder()
|
|||
|
|
// .id(IdGenerator.generate())
|
|||
|
|
// .salaryArchiveId(finalSalaryArchive.getId())
|
|||
|
|
// .employeeId(finalSalaryArchive.getEmployeeId())
|
|||
|
|
// .effectiveTime(effectiveTime)
|
|||
|
|
// .adjustReason(StringUtils.isEmpty(salaryItemAdjustReason) ? SalaryArchiveItemAdjustReasonEnum.INIT.getValue() : salaryItemAdjustReason)
|
|||
|
|
// .salaryItemId(salaryItemId)
|
|||
|
|
// .itemValue(cellVal)
|
|||
|
|
// .description("")
|
|||
|
|
// .operator(currentEmployeeId)
|
|||
|
|
// .operateTime(importHandleParam.getNowTime())
|
|||
|
|
// .createTime(importHandleParam.getNowTime())
|
|||
|
|
// .updateTime(importHandleParam.getNowTime())
|
|||
|
|
// .creator(currentEmployeeId)
|
|||
|
|
// .tenantKey(tenantKey)
|
|||
|
|
// .build());
|
|||
|
|
// }
|
|||
|
|
// // 用于初始化导入，同一个人的多行记录之间的薪资项目是否调整
|
|||
|
|
// map.put("salaryItemVal", Optional.ofNullable(map.get("salaryItemVal")).orElse("").toString()+salaryItemId+cellVal);
|
|||
|
|
// }
|
|||
|
|
// return isError;
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// /**
|
|||
|
|
// * 字符串转日期
|
|||
|
|
// * 兼容/和-
|
|||
|
|
// * @param effectiveTime
|
|||
|
|
// * @return
|
|||
|
|
// */
|
|||
|
|
// private LocalDate dateStrToLocalDate(String effectiveTime) {
|
|||
|
|
// LocalDate localDate = null;
|
|||
|
|
// try {
|
|||
|
|
// if (effectiveTime.contains("/")) {
|
|||
|
|
// String[] strs = effectiveTime.split("/");
|
|||
|
|
// localDate = LocalDate.of(Integer.parseInt(strs[0]), Integer.parseInt(strs[1]), Integer.parseInt(strs[2]));
|
|||
|
|
// } else if (effectiveTime.contains("-")) {
|
|||
|
|
// String[] strs = effectiveTime.replaceAll("-0", "-").split("-");
|
|||
|
|
// // localDate = LocalDate.parse(effectiveTime, DateTimeFormatter.ofPattern("yyyy-MM-dd")); // 月份日期超过最大会被改为最大
|
|||
|
|
// localDate = LocalDate.of(Integer.parseInt(strs[0]), Integer.parseInt(strs[1]), Integer.parseInt(strs[2]));
|
|||
|
|
// }
|
|||
|
|
// } catch (Exception e) {
|
|||
|
|
// localDate = null;
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// return localDate;
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// private List<SalaryArchiveItemPO> getEffectiveItemList(Collection<Long> salaryItemIds, String tenantKey) {
|
|||
|
|
// // 没有薪资项目时，给个不存在的，否则加载所有不合理
|
|||
|
|
// salaryItemIds = CollectionUtils.isEmpty(salaryItemIds)?Collections.singletonList(0L):salaryItemIds;
|
|||
|
|
// return new LambdaQueryChainWrapper<>(salaryArchiveItemMapper)
|
|||
|
|
// .eq(SalaryArchiveItemPO::getDeleteType, 0)
|
|||
|
|
// .eq(SalaryArchiveItemPO::getTenantKey, tenantKey)
|
|||
|
|
// .le(SalaryArchiveItemPO::getEffectiveTime, LocalDate.now())
|
|||
|
|
// .in(SalaryArchiveItemPO::getSalaryItemId, salaryItemIds)
|
|||
|
|
// .orderByDesc(SalaryArchiveItemPO::getEffectiveTime)
|
|||
|
|
// .list();
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// private List<SalaryArchiveItemPO> getIneffectiveItemList(Collection<Long> salaryItemIds, String tenantKey) {
|
|||
|
|
// // 没有薪资项目时，给个不存在的，否则加载所有不合理
|
|||
|
|
// salaryItemIds = CollectionUtils.isEmpty(salaryItemIds)?Collections.singletonList(0L):salaryItemIds;
|
|||
|
|
// return new LambdaQueryChainWrapper<>(salaryArchiveItemMapper)
|
|||
|
|
// .eq(SalaryArchiveItemPO::getDeleteType, 0)
|
|||
|
|
// .eq(SalaryArchiveItemPO::getTenantKey, tenantKey)
|
|||
|
|
// .in(SalaryArchiveItemPO::getSalaryItemId, salaryItemIds)
|
|||
|
|
// .gt(SalaryArchiveItemPO::getEffectiveTime, LocalDate.now())
|
|||
|
|
// .list();
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// private List<SalaryArchiveTaxAgentPO> getEffectiveTaxAgentList(String tenantKey) {
|
|||
|
|
// return new LambdaQueryChainWrapper<>(salaryArchiveTaxAgentMapper)
|
|||
|
|
// .eq(SalaryArchiveTaxAgentPO::getDeleteType, 0)
|
|||
|
|
// .eq(SalaryArchiveTaxAgentPO::getTenantKey, tenantKey)
|
|||
|
|
// .le(SalaryArchiveTaxAgentPO::getEffectiveTime, LocalDate.now())
|
|||
|
|
// .orderByDesc(SalaryArchiveTaxAgentPO::getEffectiveTime)
|
|||
|
|
// .list();
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// private List<SalaryArchiveTaxAgentPO> getIneffectiveTaxAgentList(String tenantKey) {
|
|||
|
|
// return new LambdaQueryChainWrapper<>(salaryArchiveTaxAgentMapper)
|
|||
|
|
// .eq(SalaryArchiveTaxAgentPO::getDeleteType, 0)
|
|||
|
|
// .eq(SalaryArchiveTaxAgentPO::getTenantKey, tenantKey)
|
|||
|
|
// .gt(SalaryArchiveTaxAgentPO::getEffectiveTime, LocalDate.now())
|
|||
|
|
// .list();
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// /**
|
|||
|
|
// * 检查参数
|
|||
|
|
// * @param message
|
|||
|
|
// * @param params
|
|||
|
|
// * @return
|
|||
|
|
// */
|
|||
|
|
// private boolean checkParams(BatchDocumentMessage message, Map<String, Object> params) {
|
|||
|
|
// boolean isValid = true;
|
|||
|
|
// String errorMsg = "";
|
|||
|
|
// if (params == null) {
|
|||
|
|
// errorMsg = SalaryI18nUtil.getI18nLabel(message.getTenantKey(), message.getUserId(), 100582, "参数必传");
|
|||
|
|
// } else {
|
|||
|
|
// if (!params.containsKey("importType")
|
|||
|
|
// || params.get("importType") == null) {
|
|||
|
|
// errorMsg = SalaryI18nUtil.getI18nLabel(message.getTenantKey(), message.getUserId(), 100592, "导入类型必传");
|
|||
|
|
// } else {
|
|||
|
|
// Optional<SalaryArchiveImportTypeEnum> optional = Arrays.stream(SalaryArchiveImportTypeEnum.values()).filter(e->e.getValue().equals(params.get("importType").toString())).findFirst();
|
|||
|
|
// if (!optional.isPresent()) {
|
|||
|
|
// errorMsg = SalaryI18nUtil.getI18nLabel(message.getTenantKey(), message.getUserId(), 100593, "导入类型不正确");
|
|||
|
|
// } else {
|
|||
|
|
// message.setDataType(message.getDataType()+"-"+SalaryI18nUtil.getI18nLabel(message.getTenantKey(), message.getUserId(), optional.get().getLabelId(), optional.get().getDefaultLabel()));
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// // 有错误信息发送
|
|||
|
|
// if (org.apache.commons.lang3.StringUtils.isNotEmpty(errorMsg)) {
|
|||
|
|
// // 发送导入回调信息
|
|||
|
|
// salaryBatchService.sendImportCallBackInfo(message, errorMsg);
|
|||
|
|
// isValid = false;
|
|||
|
|
// }
|
|||
|
|
// return isValid;
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// /**
|
|||
|
|
// * 检查列头
|
|||
|
|
// * @param importType
|
|||
|
|
// * @param message
|
|||
|
|
// * @param headers
|
|||
|
|
// * @return
|
|||
|
|
// */
|
|||
|
|
// private boolean checkHeaders(String importType, BatchDocumentMessage message, List<Map> headers) {
|
|||
|
|
// boolean isValid = true;
|
|||
|
|
// boolean isInit = importType.equals(SalaryArchiveImportTypeEnum.INIT.getValue());
|
|||
|
|
// boolean isTaxAgentAdjust = importType.equals(SalaryArchiveImportTypeEnum.TAXAGENTADJUST.getValue());
|
|||
|
|
// boolean isSalaryItemAdjust = importType.equals(SalaryArchiveImportTypeEnum.SALARYITEMADJUST.getValue());
|
|||
|
|
//
|
|||
|
|
// String tenantKey = message.getTenantKey();
|
|||
|
|
// Long currentEmployeeId = message.getUserId();
|
|||
|
|
// String userNameI18n = SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 85429, "姓名");
|
|||
|
|
// String taxAgentI18n = SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 86184, "个税扣缴义务人");
|
|||
|
|
// String effectiveTimeI18n = SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 85904, "生效日期");
|
|||
|
|
// String adjustReasonI18n = SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 85431, "调整原因");
|
|||
|
|
//
|
|||
|
|
// List<String> headerList = headers.stream().map(m->Optional.ofNullable(m.get("key")).orElse("").toString()).collect(Collectors.toList());
|
|||
|
|
//
|
|||
|
|
// List<String> mustHeaders = Lists.newArrayList();
|
|||
|
|
// if (isInit) {
|
|||
|
|
// mustHeaders.add(userNameI18n);
|
|||
|
|
// mustHeaders.add(taxAgentI18n);
|
|||
|
|
// mustHeaders.add(effectiveTimeI18n);
|
|||
|
|
// } else if (isTaxAgentAdjust) {
|
|||
|
|
// mustHeaders.add(userNameI18n);
|
|||
|
|
// mustHeaders.add(taxAgentI18n);
|
|||
|
|
// mustHeaders.add(effectiveTimeI18n);
|
|||
|
|
// mustHeaders.add(adjustReasonI18n);
|
|||
|
|
// } else if (isSalaryItemAdjust) {
|
|||
|
|
// mustHeaders.add(userNameI18n);
|
|||
|
|
// mustHeaders.add(effectiveTimeI18n);
|
|||
|
|
// mustHeaders.add(adjustReasonI18n);
|
|||
|
|
// }
|
|||
|
|
// // 缺少的必须列
|
|||
|
|
// List<String> lackHeaders = mustHeaders.stream().filter(item -> !headerList.contains(item)).collect(Collectors.toList());
|
|||
|
|
//
|
|||
|
|
// String errorMsg = "";
|
|||
|
|
// String checkHeaderI18n = SalaryI18nUtil.getI18nLabel(tenantKey, currentEmployeeId, 101850, "缺少如下列，请检查：");
|
|||
|
|
// if (CollectionUtils.isNotEmpty(lackHeaders)) {
|
|||
|
|
// errorMsg = checkHeaderI18n + Joiner.on(",").join(lackHeaders);
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// // 有错误信息发送
|
|||
|
|
// if (StringUtils.isNotEmpty(errorMsg)) {
|
|||
|
|
// // 发送导入回调信息
|
|||
|
|
// salaryBatchService.sendImportCallBackInfo(message, errorMsg);
|
|||
|
|
// isValid = false;
|
|||
|
|
// }
|
|||
|
|
// return isValid;
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// /**
|
|||
|
|
// * 数据落库处理
|
|||
|
|
// * @param importHandleParam
|
|||
|
|
// */
|
|||
|
|
// private void handleImportData(boolean isInit, String tenantKey, SalaryArchiveImportHandleParam importHandleParam) {
|
|||
|
|
//
|
|||
|
|
// List<SalaryArchivePO> salaryArchiveSaves = importHandleParam.getSalaryArchiveSaves();
|
|||
|
|
// List<SalaryArchiveTaxAgentPO> salaryArchiveTaxAgentSaves = importHandleParam.getSalaryArchiveTaxAgentSaves();
|
|||
|
|
// List<SalaryArchiveItemPO> salaryArchiveItemSaves = importHandleParam.getSalaryArchiveItemSaves();
|
|||
|
|
// List<Long> salaryArchiveTaxAgentDelTaxAgentIds = importHandleParam.getSalaryArchiveTaxAgentDelTaxAgentIds();
|
|||
|
|
// List<Long> salaryArchiveItemDelSalaryItemIds = importHandleParam.getSalaryArchiveItemDelSalaryItemIds();
|
|||
|
|
// // 初始化导入
|
|||
|
|
// if (isInit) {
|
|||
|
|
// List<Long> salaryArchiveTaxAgentIds = importHandleParam.getSalaryArchiveTaxAgentSaves().stream().map(SalaryArchiveTaxAgentPO::getSalaryArchiveId).distinct().collect(Collectors.toList());
|
|||
|
|
// List<Long> salaryArchiveItemIds = importHandleParam.getSalaryArchiveItemSaves().stream().map(SalaryArchiveItemPO::getSalaryArchiveId).distinct().collect(Collectors.toList());
|
|||
|
|
// List<Long> salaryArchiveIds = salaryArchiveTaxAgentIds.stream().filter(item -> salaryArchiveItemIds.contains(item)).collect(Collectors.toList());
|
|||
|
|
// if (CollectionUtils.isNotEmpty(salaryArchiveIds)) {
|
|||
|
|
// List<List<Long>> partition = Lists.partition(salaryArchiveIds, 1000);
|
|||
|
|
// for (List<Long> p : partition) {
|
|||
|
|
// new LambdaUpdateChainWrapper<>(salaryArchiveTaxAgentMapper)
|
|||
|
|
// .eq(SalaryArchiveTaxAgentPO::getDeleteType, 0)
|
|||
|
|
// .eq(SalaryArchiveTaxAgentPO::getTenantKey, tenantKey)
|
|||
|
|
// .in(SalaryArchiveTaxAgentPO::getSalaryArchiveId, p)
|
|||
|
|
// .set(SalaryArchiveTaxAgentPO::getDeleteType, 1)
|
|||
|
|
// .update();
|
|||
|
|
// new LambdaUpdateChainWrapper<>(salaryArchiveItemMapper)
|
|||
|
|
// .eq(SalaryArchiveItemPO::getDeleteType, 0)
|
|||
|
|
// .eq(SalaryArchiveItemPO::getTenantKey, tenantKey)
|
|||
|
|
// .in(SalaryArchiveItemPO::getSalaryArchiveId, p)
|
|||
|
|
// .set(SalaryArchiveItemPO::getDeleteType, 1)
|
|||
|
|
// .update();
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
// } else {
|
|||
|
|
// if (CollectionUtils.isNotEmpty(salaryArchiveTaxAgentDelTaxAgentIds)) {
|
|||
|
|
// salaryArchiveTaxAgentMapper.deleteBatchIds(salaryArchiveTaxAgentDelTaxAgentIds);
|
|||
|
|
// }
|
|||
|
|
// if (CollectionUtils.isNotEmpty(salaryArchiveItemDelSalaryItemIds)) {
|
|||
|
|
// salaryArchiveItemMapper.deleteBatchIds(salaryArchiveItemDelSalaryItemIds);
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
//
|
|||
|
|
// // 新增薪资档案
|
|||
|
|
// if (CollectionUtils.isNotEmpty(salaryArchiveSaves)) {
|
|||
|
|
// // 薪资档案
|
|||
|
|
// mapper.batchInsert(salaryArchiveSaves);
|
|||
|
|
// }
|
|||
|
|
// // 薪资档案-个税扣缴义务人
|
|||
|
|
// if (CollectionUtils.isNotEmpty(salaryArchiveTaxAgentSaves)) {
|
|||
|
|
// salaryArchiveTaxAgentMapper.batchInsert(salaryArchiveTaxAgentSaves);
|
|||
|
|
// }
|
|||
|
|
// // 薪资档案-薪资项目
|
|||
|
|
// if (CollectionUtils.isNotEmpty(salaryArchiveItemSaves)) {
|
|||
|
|
// salaryArchiveItemMapper.batchInsert(salaryArchiveItemSaves);
|
|||
|
|
// }
|
|||
|
|
// }
|
|||
|
|
//}
|