172 lines
9.0 KiB
Java
172 lines
9.0 KiB
Java
package com.engine.salary.entity.salaryacct.bo;
|
||
|
||
import com.engine.salary.constant.SalaryDefaultTenantConstant;
|
||
import com.engine.salary.entity.datacollection.DataCollectionEmployee;
|
||
import com.engine.salary.entity.salaryacct.dto.SalaryAccEmployeeListDTO;
|
||
import com.engine.salary.entity.salaryacct.po.SalaryAcctEmployeePO;
|
||
import com.engine.salary.entity.salaryacct.po.SalaryAcctRecordPO;
|
||
import com.engine.salary.entity.salaryarchive.dto.SalaryArchiveDataDTO;
|
||
import com.engine.salary.entity.salaryarchive.dto.SalaryArchiveTaxAgentDataDTO;
|
||
import com.engine.salary.entity.taxagent.po.TaxAgentPO;
|
||
import com.engine.salary.enums.AccountTypeEnum;
|
||
import com.engine.salary.enums.UserStatusEnum;
|
||
import com.engine.salary.util.SalaryEntityUtil;
|
||
import com.google.common.collect.Lists;
|
||
import com.google.common.collect.Sets;
|
||
import org.apache.commons.collections4.CollectionUtils;
|
||
import org.apache.commons.lang3.StringUtils;
|
||
import org.apache.commons.lang3.math.NumberUtils;
|
||
import weaver.general.Util;
|
||
|
||
import java.util.*;
|
||
import java.util.stream.Collectors;
|
||
|
||
/**
|
||
* 薪资核算人员
|
||
* <p>Copyright: Copyright (c) 2022</p>
|
||
* <p>Company: 泛微软件</p>
|
||
*
|
||
* @author qiantao
|
||
* @version 1.0
|
||
**/
|
||
public class SalaryAcctEmployeeBO {
|
||
|
||
/**
|
||
* 将薪资核算人员po转换成薪资核算人员列表dto
|
||
*
|
||
* @param salaryAccountingEmployees
|
||
* @param taxAgents
|
||
* @param simpleEmployees
|
||
* @return
|
||
*/
|
||
public static List<SalaryAccEmployeeListDTO> convert2EmployeeListDTO(List<SalaryAcctEmployeePO> salaryAccountingEmployees,
|
||
List<TaxAgentPO> taxAgents,
|
||
List<DataCollectionEmployee> simpleEmployees) {
|
||
if (CollectionUtils.isEmpty(salaryAccountingEmployees)) {
|
||
return Collections.emptyList();
|
||
}
|
||
Map<Long, String> taxAgentNameMap = SalaryEntityUtil.convert2Map(taxAgents, TaxAgentPO::getId, TaxAgentPO::getName);
|
||
Map<Long, DataCollectionEmployee> simpleEmployeeMap = SalaryEntityUtil.convert2Map(simpleEmployees, DataCollectionEmployee::getEmployeeId);
|
||
return salaryAccountingEmployees.stream()
|
||
.map(e -> {
|
||
DataCollectionEmployee simpleEmployee = simpleEmployeeMap.get(e.getEmployeeId());
|
||
if (simpleEmployee == null) {
|
||
return SalaryAccEmployeeListDTO.builder()
|
||
.id(e.getId())
|
||
.employeeId(e.getId())
|
||
.taxAgentId(e.getTaxAgentId())
|
||
.taxAgentName(taxAgentNameMap.getOrDefault(e.getTaxAgentId(), StringUtils.EMPTY))
|
||
.build();
|
||
}
|
||
return SalaryAccEmployeeListDTO.builder()
|
||
.id(e.getId())
|
||
.employeeId(simpleEmployee.getEmployeeId())
|
||
.employeeName(simpleEmployee.getUsername())
|
||
.taxAgentId(e.getTaxAgentId())
|
||
.taxAgentName(taxAgentNameMap.getOrDefault(e.getTaxAgentId(), StringUtils.EMPTY))
|
||
.departmentId(e.getDepartmentId())
|
||
.departmentName(e.getDepartmentName())
|
||
.status(UserStatusEnum.getDefaultLabelByValue(NumberUtils.toInt(e.getStatus())))
|
||
.accountType(AccountTypeEnum.getDefaultLabelByValue(e.getAccountType()))
|
||
.mobile(simpleEmployee.getMobile())
|
||
.jobNum(simpleEmployee.getWorkcode())
|
||
.hireDate(simpleEmployee.getCompanystartdate())
|
||
.dismissDate(simpleEmployee.getDismissdate())
|
||
.build();
|
||
}).collect(Collectors.toList());
|
||
}
|
||
|
||
public static List<SalaryAcctEmployeePO> convert2Employee(Collection<DataCollectionEmployee> employee,
|
||
SalaryAcctRecordPO salaryAcctRecord,
|
||
List<SalaryArchiveDataDTO> salaryArchiveTaxAgentData,
|
||
Long employeeId) {
|
||
if (CollectionUtils.isEmpty(employee)) {
|
||
return Collections.emptyList();
|
||
}
|
||
List<SalaryAcctEmployeePO> resultList = Lists.newArrayList();
|
||
Map<Long, Set<List<SalaryArchiveTaxAgentDataDTO>>> empIdKeyTaxAgentMap = SalaryEntityUtil.group2Map(salaryArchiveTaxAgentData, SalaryArchiveDataDTO::getEmployeeId, SalaryArchiveDataDTO::getTaxAgents);
|
||
Date now = new Date();
|
||
for (DataCollectionEmployee emp : employee) {
|
||
Set<Long> taxAgentIds = Sets.newHashSet();
|
||
Set<List<SalaryArchiveTaxAgentDataDTO>> taxAgentSet = empIdKeyTaxAgentMap.getOrDefault(emp.getEmployeeId(), Collections.emptySet());
|
||
for (List<SalaryArchiveTaxAgentDataDTO> taxAgents : taxAgentSet) {
|
||
taxAgentIds.addAll(SalaryEntityUtil.properties(taxAgents, SalaryArchiveTaxAgentDataDTO::getTaxAgentId));
|
||
}
|
||
if (CollectionUtils.isEmpty(taxAgentIds)) {
|
||
taxAgentIds.add(0L);
|
||
}
|
||
for (Long taxAgentId : taxAgentIds) {
|
||
SalaryAcctEmployeePO salaryAcctEmployee = SalaryAcctEmployeePO.builder()
|
||
.salaryAcctRecordId(salaryAcctRecord.getId())
|
||
.salarySobId(salaryAcctRecord.getSalarySobId())
|
||
.salaryMonth(salaryAcctRecord.getSalaryMonth())
|
||
.employeeId(emp.getEmployeeId())
|
||
.employeeType(emp.isExtEmp() ? 1 : 0)
|
||
.taxAgentId(taxAgentId)
|
||
.departmentId(emp.getDepartmentId())
|
||
.departmentName(emp.getDepartmentName())
|
||
.jobcall(emp.getJobcall())
|
||
.jobcallId(emp.getJobcallId())
|
||
.jobtitleId(emp.getJobtitleId())
|
||
.jobtitleName(emp.getJobtitleName())
|
||
.subcompanyId(emp.getSubcompanyid())
|
||
.subcompanyName(emp.getSubcompanyName())
|
||
.status(emp.getStatus())
|
||
.accountType(emp.getAccountType())
|
||
.creator(employeeId)
|
||
.createTime(now)
|
||
.updateTime(now)
|
||
.deleteType(0)
|
||
.tenantKey(SalaryDefaultTenantConstant.DEFAULT_TENANT_KEY)
|
||
.build();
|
||
resultList.add(salaryAcctEmployee);
|
||
}
|
||
}
|
||
return resultList;
|
||
}
|
||
|
||
/**
|
||
* 核算人员信息替换实时信息
|
||
* @param simpleEmployee
|
||
* @param acctEmployeePO
|
||
*/
|
||
public static void copyAcctEmp(DataCollectionEmployee simpleEmployee, SalaryAcctEmployeePO acctEmployeePO) {
|
||
simpleEmployee.setDepartmentId(acctEmployeePO.getDepartmentId());
|
||
simpleEmployee.setDepartmentName(acctEmployeePO.getDepartmentName());
|
||
simpleEmployee.setSubcompanyid(acctEmployeePO.getSubcompanyId());
|
||
simpleEmployee.setSubcompanyName(acctEmployeePO.getSubcompanyName());
|
||
simpleEmployee.setJobcallId(acctEmployeePO.getJobcallId());
|
||
simpleEmployee.setJobcall(acctEmployeePO.getJobcall());
|
||
simpleEmployee.setJobtitleId(acctEmployeePO.getJobtitleId());
|
||
simpleEmployee.setJobtitleName(acctEmployeePO.getJobtitleName());
|
||
simpleEmployee.setStatusName(UserStatusEnum.getDefaultLabelByValue(new Integer(Util.null2s(acctEmployeePO.getStatus(), "1"))));
|
||
simpleEmployee.setStatus(acctEmployeePO.getStatus());
|
||
simpleEmployee.setAccountType(acctEmployeePO.getAccountType());
|
||
simpleEmployee.setAccountTypeName(AccountTypeEnum.getDefaultLabelByValue(acctEmployeePO.getAccountType()));
|
||
}
|
||
|
||
|
||
public static List<List<SalaryAcctEmployeePO>> partitionByEmployeeId(List<SalaryAcctEmployeePO> salaryAcctEmployees) {
|
||
if (CollectionUtils.isEmpty(salaryAcctEmployees)) {
|
||
return Collections.emptyList();
|
||
}
|
||
List<Long> employeeIdList = salaryAcctEmployees.stream()
|
||
.map(SalaryAcctEmployeePO::getEmployeeId)
|
||
.distinct()
|
||
.collect(Collectors.toList());
|
||
// 每个线程处理多少个人员（一个线程最多处理10个人员）
|
||
int size = 100;
|
||
List<List<Long>> partition = Lists.partition(employeeIdList, size);
|
||
List<List<SalaryAcctEmployeePO>> resultList = new ArrayList<>();
|
||
Map<Long, List<SalaryAcctEmployeePO>> salaryAcctEmployeeMap = SalaryEntityUtil.group2Map(salaryAcctEmployees, SalaryAcctEmployeePO::getEmployeeId);
|
||
for (List<Long> employeeIds : partition) {
|
||
List<SalaryAcctEmployeePO> temp = new ArrayList<>();
|
||
for (Long employeeId : employeeIds) {
|
||
temp.addAll(salaryAcctEmployeeMap.getOrDefault(employeeId, Collections.emptyList()));
|
||
}
|
||
resultList.add(temp);
|
||
}
|
||
return resultList;
|
||
}
|
||
}
|