2024-08-09 10:21:40 +08:00
|
|
|
|
package com.engine.salary.service.impl;
|
|
|
|
|
|
|
|
|
|
|
|
import com.cloudstore.eccom.pc.table.WeaTableColumn;
|
|
|
|
|
|
import com.engine.common.util.ServiceUtil;
|
|
|
|
|
|
import com.engine.core.impl.Service;
|
|
|
|
|
|
import com.engine.salary.constant.SalaryDefaultTenantConstant;
|
|
|
|
|
|
import com.engine.salary.constant.SalaryItemConstant;
|
|
|
|
|
|
import com.engine.salary.entity.datacollection.bo.VariableArchiveBO;
|
|
|
|
|
|
import com.engine.salary.entity.datacollection.bo.VariableArchiveExcelBO;
|
|
|
|
|
|
import com.engine.salary.entity.datacollection.dto.VariableArchiveListDTO;
|
|
|
|
|
|
import com.engine.salary.entity.datacollection.dto.VariableItemListDTO;
|
|
|
|
|
|
import com.engine.salary.entity.datacollection.param.VariableArchiveImportHandleParam;
|
|
|
|
|
|
import com.engine.salary.entity.datacollection.param.VariableArchiveQueryParam;
|
|
|
|
|
|
import com.engine.salary.entity.datacollection.param.VariableArchiveSaveParam;
|
|
|
|
|
|
import com.engine.salary.entity.datacollection.po.VariableArchiveItemPO;
|
|
|
|
|
|
import com.engine.salary.entity.datacollection.po.VariableArchivePO;
|
|
|
|
|
|
import com.engine.salary.entity.datacollection.po.VariableItemPO;
|
|
|
|
|
|
import com.engine.salary.entity.salaryarchive.dto.SalaryArchiveInitImportDTO;
|
2024-08-12 16:36:27 +08:00
|
|
|
|
import com.engine.salary.entity.taxagent.dto.TaxAgentManageRangeEmployeeDTO;
|
2024-08-09 10:21:40 +08:00
|
|
|
|
import com.engine.salary.entity.taxagent.po.TaxAgentPO;
|
|
|
|
|
|
import com.engine.salary.enums.datacollection.UseEmployeeTypeEnum;
|
|
|
|
|
|
import com.engine.salary.exception.SalaryRunTimeException;
|
|
|
|
|
|
import com.engine.salary.mapper.datacollection.VariableArchiveMapper;
|
|
|
|
|
|
import com.engine.salary.service.*;
|
|
|
|
|
|
import com.engine.salary.sys.entity.vo.OrderRuleVO;
|
|
|
|
|
|
import com.engine.salary.sys.service.SalarySysConfService;
|
|
|
|
|
|
import com.engine.salary.sys.service.impl.SalarySysConfServiceImpl;
|
|
|
|
|
|
import com.engine.salary.util.SalaryDateUtil;
|
|
|
|
|
|
import com.engine.salary.util.SalaryEntityUtil;
|
|
|
|
|
|
import com.engine.salary.util.SalaryI18nUtil;
|
|
|
|
|
|
import com.engine.salary.util.db.IdGenerator;
|
|
|
|
|
|
import com.engine.salary.util.db.MapperProxyFactory;
|
|
|
|
|
|
import com.engine.salary.util.excel.ExcelComment;
|
|
|
|
|
|
import com.engine.salary.util.excel.ExcelParseHelper;
|
|
|
|
|
|
import com.engine.salary.util.excel.ExcelSupport;
|
|
|
|
|
|
import com.engine.salary.util.excel.ExcelUtilPlus;
|
|
|
|
|
|
import com.engine.salary.util.page.PageInfo;
|
|
|
|
|
|
import com.engine.salary.util.page.SalaryPageUtil;
|
|
|
|
|
|
import com.engine.salary.util.valid.ValidUtil;
|
|
|
|
|
|
import com.google.common.collect.Lists;
|
|
|
|
|
|
import com.google.common.collect.Maps;
|
|
|
|
|
|
import org.apache.commons.collections4.CollectionUtils;
|
|
|
|
|
|
import org.apache.commons.lang3.BooleanUtils;
|
|
|
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
|
|
|
import org.apache.commons.lang3.math.NumberUtils;
|
|
|
|
|
|
import org.apache.poi.ss.usermodel.Sheet;
|
|
|
|
|
|
import org.apache.poi.util.IOUtils;
|
|
|
|
|
|
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
|
|
|
|
|
|
import weaver.file.ImageFileManager;
|
|
|
|
|
|
import weaver.general.Util;
|
|
|
|
|
|
import weaver.hrm.User;
|
|
|
|
|
|
|
|
|
|
|
|
import java.io.InputStream;
|
|
|
|
|
|
import java.time.YearMonth;
|
|
|
|
|
|
import java.util.*;
|
|
|
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
|
|
|
|
|
|
import static com.engine.salary.util.excel.ExcelSupport.EXCEL_TYPE_XLSX;
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
* @author Harryxzy
|
|
|
|
|
|
* @ClassName VariableArchiveServiceImpl
|
|
|
|
|
|
* @date 2024/08/06 17:40
|
|
|
|
|
|
* @description 浮动薪酬档案
|
|
|
|
|
|
*/
|
|
|
|
|
|
public class VariableArchiveServiceImpl extends Service implements VariableArchiveService {
|
|
|
|
|
|
|
|
|
|
|
|
private VariableArchiveMapper getVariableArchiveMapper(){
|
|
|
|
|
|
return MapperProxyFactory.getProxy(VariableArchiveMapper.class);
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private TaxAgentService getTaxAgentService(User user) {
|
|
|
|
|
|
return ServiceUtil.getService(TaxAgentServiceImpl.class, user);
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public SalarySysConfService getSalarySysConfService(User user) {
|
|
|
|
|
|
return ServiceUtil.getService(SalarySysConfServiceImpl.class, user);
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private VariableArchiveItemService getVariableArchiveItemService(User user) {
|
|
|
|
|
|
return ServiceUtil.getService(VariableArchiveItemServiceImpl.class, user);
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private VariableItemService getVariableItemService(User user) {
|
|
|
|
|
|
return ServiceUtil.getService(VariableItemServiceImpl.class, user);
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private SalaryEmployeeService getSalaryEmployeeService(User user) {
|
|
|
|
|
|
return (SalaryEmployeeService) ServiceUtil.getService(SalaryEmployeeServiceImpl.class, user);
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private int deleteByIds(List<Long> deleteIds) {
|
|
|
|
|
|
if (CollectionUtils.isEmpty(deleteIds)) {
|
|
|
|
|
|
return 0;
|
|
|
|
|
|
}
|
|
|
|
|
|
return getVariableArchiveMapper().deleteByIds(deleteIds);
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
* 浮动薪酬档案列表
|
|
|
|
|
|
* @param queryParam
|
|
|
|
|
|
* @return
|
|
|
|
|
|
*/
|
|
|
|
|
|
@Override
|
|
|
|
|
|
public PageInfo<VariableArchiveListDTO> listPage(VariableArchiveQueryParam queryParam) {
|
|
|
|
|
|
List<VariableArchiveListDTO> variableArchiveList = list(queryParam);
|
|
|
|
|
|
return SalaryPageUtil.buildPage(queryParam.getCurrent(), queryParam.getPageSize(), variableArchiveList, VariableArchiveListDTO.class);
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
|
public List<VariableArchiveListDTO> list(VariableArchiveQueryParam queryParam) {
|
|
|
|
|
|
ValidUtil.doValidator(queryParam);
|
|
|
|
|
|
Long employeeId = Long.valueOf(user.getUID());
|
|
|
|
|
|
// 判断是否是“总管理员”
|
|
|
|
|
|
Boolean isChief = getTaxAgentService(user).isChief(employeeId);
|
|
|
|
|
|
// 是否开启分权
|
|
|
|
|
|
Boolean openDevolution = getTaxAgentService(user).isOpenDevolution();
|
2024-08-12 16:36:27 +08:00
|
|
|
|
if (BooleanUtils.isTrue(openDevolution) && !isChief) {
|
|
|
|
|
|
Collection<TaxAgentPO> taxAgentPOS = getTaxAgentService(user).listAllTaxAgentsAsAdmin(employeeId);
|
|
|
|
|
|
List<Long> taxAgentIds = taxAgentPOS.stream().map(TaxAgentPO::getId).collect(Collectors.toList());
|
|
|
|
|
|
if (CollectionUtils.isNotEmpty(queryParam.getTaxAgentIds())) {
|
|
|
|
|
|
taxAgentIds = taxAgentIds.stream().filter(queryParam.getTaxAgentIds()::contains).collect(Collectors.toList());
|
|
|
|
|
|
}
|
|
|
|
|
|
queryParam.setTaxAgentIds(taxAgentIds);
|
2024-08-09 10:21:40 +08:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 浮动薪酬档案列表
|
|
|
|
|
|
if (Objects.nonNull(queryParam.getSalaryMonth())) {
|
|
|
|
|
|
queryParam.setSalaryMonthDate(SalaryDateUtil.dateStrToLocalYearMonth(queryParam.getSalaryMonth()));
|
|
|
|
|
|
}
|
|
|
|
|
|
//排序配置
|
|
|
|
|
|
OrderRuleVO orderRule = getSalarySysConfService(user).orderRule();
|
|
|
|
|
|
queryParam.setOrderRule(orderRule);
|
|
|
|
|
|
return getVariableArchiveMapper().list(queryParam);
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
* 构建浮动薪资档案数据
|
|
|
|
|
|
*
|
|
|
|
|
|
* @param variableArchives
|
|
|
|
|
|
* @return
|
|
|
|
|
|
*/
|
|
|
|
|
|
@Override
|
|
|
|
|
|
public List<Map<String, Object>> buildVariableArchiveData(Collection<VariableArchiveListDTO> variableArchives) {
|
|
|
|
|
|
if (CollectionUtils.isEmpty(variableArchives)) {
|
|
|
|
|
|
// 无数据
|
|
|
|
|
|
}
|
|
|
|
|
|
List<Long> variableArchiveIds = variableArchives.stream().map(VariableArchiveListDTO::getId).collect(Collectors.toList());
|
|
|
|
|
|
// 获取浮动薪资档案所对应的浮动薪资项目数据
|
|
|
|
|
|
List<VariableArchiveItemPO> variableArchiveItemList= getVariableArchiveItemService(user).listByVariableArchiveIds(variableArchiveIds);
|
|
|
|
|
|
Map<Long, List<VariableArchiveItemPO>> variableArchiveItemMap = SalaryEntityUtil.group2Map(variableArchiveItemList, VariableArchiveItemPO::getVariableArchiveId);
|
|
|
|
|
|
List<Map<String, Object>> variableArchiveItemData = variableArchives.stream().map(m -> {
|
|
|
|
|
|
Map<String, Object> map = Maps.newHashMap();
|
|
|
|
|
|
map.put("variableArchiveId", m.getId());
|
|
|
|
|
|
List<VariableArchiveItemPO> variableArchiveItemValuelList = variableArchiveItemMap.getOrDefault(m.getId(), Collections.emptyList());
|
|
|
|
|
|
variableArchiveItemValuelList.forEach(i -> {
|
|
|
|
|
|
map.put(i.getVariableItemId() + SalaryItemConstant.VARIABLE_ITEM_DYNAMIC_SUFFIX, i.getItemValue());
|
|
|
|
|
|
});
|
|
|
|
|
|
return map;
|
|
|
|
|
|
}).collect(Collectors.toList());
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 组装数据
|
|
|
|
|
|
List<Map<String, Object>> listMaps = new ArrayList<>();
|
|
|
|
|
|
variableArchives.forEach(e -> {
|
|
|
|
|
|
Map<String, Object> map = new LinkedHashMap<>();
|
|
|
|
|
|
map.put("id", e.getId());
|
2024-08-12 16:36:27 +08:00
|
|
|
|
map.put("taxAgentName", e.getTaxAgentName());
|
|
|
|
|
|
map.put("taxAgentIds", e.getTaxAgentId());
|
2024-08-09 10:21:40 +08:00
|
|
|
|
map.put("username", e.getUsername());
|
|
|
|
|
|
map.put("salaryMonth", SalaryDateUtil.getFormatYearMonth(e.getSalaryMonth()));
|
|
|
|
|
|
map.put("employeeId", e.getEmployeeId());
|
|
|
|
|
|
map.put("subcompanyName", e.getSubcompanyName());
|
|
|
|
|
|
map.put("departmentName", e.getDepartmentName());
|
|
|
|
|
|
map.put("mobile", e.getMobile());
|
|
|
|
|
|
map.put("workcode", e.getWorkcode());
|
|
|
|
|
|
map.put("idNo", e.getIdNo());
|
|
|
|
|
|
map.put("companystartdate", e.getCompanystartdate());
|
|
|
|
|
|
map.put("dismissdate", e.getDismissdate());
|
|
|
|
|
|
|
|
|
|
|
|
// 浮动薪资项目动态
|
|
|
|
|
|
Optional<Map<String, Object>> optionalItem = variableArchiveItemData.stream().filter(f -> f.get("variableArchiveId").toString().equals(e.getId().toString())).findFirst();
|
|
|
|
|
|
optionalItem.ifPresent(map::putAll);
|
|
|
|
|
|
|
|
|
|
|
|
listMaps.add(map);
|
|
|
|
|
|
});
|
|
|
|
|
|
return listMaps;
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
* 创建浮动薪酬档案
|
|
|
|
|
|
*
|
|
|
|
|
|
* @param saveParam
|
|
|
|
|
|
*/
|
|
|
|
|
|
@Override
|
|
|
|
|
|
public void createData(VariableArchiveSaveParam saveParam) {
|
|
|
|
|
|
ValidUtil.doValidator(saveParam);
|
|
|
|
|
|
saveParam.setSalaryMonthDate(SalaryDateUtil.dateStrToLocalYearMonth(saveParam.getSalaryMonth()));
|
2024-08-12 16:36:27 +08:00
|
|
|
|
|
|
|
|
|
|
List<VariableArchivePO> variableArchivePOList = getVariableArchiveMapper().listSome(VariableArchivePO.builder().salaryMonth(saveParam.getSalaryMonthDate()).taxAgentId(saveParam.getTaxAgentIds()).employeeId(saveParam.getEmployeeId()).build());
|
2024-08-09 10:21:40 +08:00
|
|
|
|
if (CollectionUtils.isNotEmpty(variableArchivePOList)) {
|
|
|
|
|
|
// 先删除原有档案
|
|
|
|
|
|
List<Long> variableArchiveIds = variableArchivePOList.stream().map(VariableArchivePO::getId).collect(Collectors.toList());
|
|
|
|
|
|
getVariableArchiveMapper().deleteByIds(variableArchiveIds);
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 保存浮动薪资档案信息
|
|
|
|
|
|
Date now = new Date();
|
|
|
|
|
|
VariableArchivePO variableArchivePO = VariableArchivePO.builder()
|
|
|
|
|
|
.id(IdGenerator.generate())
|
|
|
|
|
|
.employeeId(saveParam.getEmployeeId())
|
2024-08-12 16:36:27 +08:00
|
|
|
|
.taxAgentId(saveParam.getTaxAgentIds())
|
2024-08-09 10:21:40 +08:00
|
|
|
|
.salaryMonth(saveParam.getSalaryMonthDate())
|
|
|
|
|
|
.creator(Long.valueOf(user.getUID()))
|
|
|
|
|
|
.createTime(now)
|
|
|
|
|
|
.updateTime(now)
|
|
|
|
|
|
.deleteType(NumberUtils.INTEGER_ZERO)
|
|
|
|
|
|
.tenantKey(SalaryDefaultTenantConstant.DEFAULT_TENANT_KEY)
|
|
|
|
|
|
.build();
|
|
|
|
|
|
getVariableArchiveMapper().insertIgnoreNull(variableArchivePO);
|
|
|
|
|
|
|
|
|
|
|
|
// 保存浮动薪资档案详细信息
|
|
|
|
|
|
List<VariableArchiveItemPO> variableArchiveItemList = new ArrayList<>();
|
|
|
|
|
|
saveParam.getItemValueList().forEach(e -> {
|
|
|
|
|
|
variableArchiveItemList.add(VariableArchiveItemPO.builder()
|
|
|
|
|
|
.id(IdGenerator.generate())
|
|
|
|
|
|
.employeeId(saveParam.getEmployeeId())
|
|
|
|
|
|
.variableArchiveId(variableArchivePO.getId())
|
|
|
|
|
|
.variableItemId(e.getVariableItemId())
|
|
|
|
|
|
.itemValue(e.getItemValue())
|
|
|
|
|
|
.creator(Long.valueOf(user.getUID()))
|
|
|
|
|
|
.createTime(now)
|
|
|
|
|
|
.updateTime(now)
|
|
|
|
|
|
.deleteType(NumberUtils.INTEGER_ZERO)
|
|
|
|
|
|
.tenantKey(SalaryDefaultTenantConstant.DEFAULT_TENANT_KEY)
|
|
|
|
|
|
.build());
|
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
|
|
if (CollectionUtils.isNotEmpty(variableArchiveItemList)) {
|
|
|
|
|
|
getVariableArchiveItemService(user).batchInsert(variableArchiveItemList);
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
* 浮动薪资档案明细
|
|
|
|
|
|
*
|
|
|
|
|
|
* @param queryParam
|
|
|
|
|
|
* @return
|
|
|
|
|
|
*/
|
|
|
|
|
|
@Override
|
|
|
|
|
|
public Map<String, Object> getDetail(VariableArchiveQueryParam queryParam) {
|
|
|
|
|
|
if (queryParam.getId() == null) {
|
|
|
|
|
|
return Collections.emptyMap();
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
List<VariableArchiveListDTO> variableArchiveList = getVariableArchiveMapper().list(queryParam);
|
|
|
|
|
|
|
|
|
|
|
|
// 获取所有浮动薪酬项目
|
|
|
|
|
|
List<VariableItemPO> variableItems = getVariableItemService(user).listAll();
|
|
|
|
|
|
|
|
|
|
|
|
//整合所有的显示列（固定列+薪资项目动态列）
|
|
|
|
|
|
List<Map<String, Object>> listMaps = buildVariableArchiveData(variableArchiveList);
|
|
|
|
|
|
Map<String, Object> resultMap = listMaps.get(0);
|
|
|
|
|
|
|
|
|
|
|
|
//动态列组装
|
|
|
|
|
|
List<WeaTableColumn> columns = VariableArchiveBO.buildVariableArchiveTable(variableItems);
|
|
|
|
|
|
|
|
|
|
|
|
columns.add(0,new WeaTableColumn("100px", SalaryI18nUtil.getI18nLabel(85429, "薪资所属月"), "salaryMonth"));
|
|
|
|
|
|
|
|
|
|
|
|
Map<String, Object> datas = new HashMap<>();
|
|
|
|
|
|
datas.put("data", resultMap);
|
|
|
|
|
|
datas.put("column", columns);
|
|
|
|
|
|
return datas;
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
|
public List<VariableItemListDTO> getCreateForm() {
|
|
|
|
|
|
List<VariableItemPO> variableItemPOS = getVariableItemService(user).listAll();
|
|
|
|
|
|
List<VariableItemListDTO> variableItemDTOList = variableItemPOS.stream()
|
|
|
|
|
|
.map(po -> VariableItemListDTO.builder()
|
|
|
|
|
|
.id(po.getId())
|
|
|
|
|
|
.name(po.getName())
|
|
|
|
|
|
.build())
|
|
|
|
|
|
.collect(Collectors.toList());
|
|
|
|
|
|
return variableItemDTOList;
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
|
public XSSFWorkbook downloadTemplate(VariableArchiveQueryParam param) {
|
|
|
|
|
|
// 名称
|
|
|
|
|
|
String nameI18n = SalaryI18nUtil.getI18nLabel(0, "浮动薪酬导入模板");
|
|
|
|
|
|
|
|
|
|
|
|
// 获取所有可被引用的薪资项目
|
|
|
|
|
|
List<VariableItemPO> variableItems = getVariableItemService(user).listAll();
|
|
|
|
|
|
List<Object> header = Lists.newArrayList();
|
2024-08-12 16:36:27 +08:00
|
|
|
|
header.add(SalaryI18nUtil.getI18nLabel(0, "个税扣缴义务人"));
|
2024-08-09 10:21:40 +08:00
|
|
|
|
header.add(SalaryI18nUtil.getI18nLabel(85429, "姓名"));
|
|
|
|
|
|
header.add(SalaryI18nUtil.getI18nLabel(86185, "部门"));
|
|
|
|
|
|
header.add(SalaryI18nUtil.getI18nLabel(86186, "手机号"));
|
|
|
|
|
|
header.add(SalaryI18nUtil.getI18nLabel(1933, "工号"));
|
|
|
|
|
|
header.add(SalaryI18nUtil.getI18nLabel(86186, "证件号码"));
|
|
|
|
|
|
header.add(SalaryI18nUtil.getI18nLabel(86187, "入职日期"));
|
|
|
|
|
|
for (VariableItemPO variableItem : variableItems) {
|
|
|
|
|
|
header.add(variableItem.getName());
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 2.表头
|
|
|
|
|
|
List<List<Object>> rows = new ArrayList<>();
|
|
|
|
|
|
rows.add(header);
|
|
|
|
|
|
// 获取档案信息
|
|
|
|
|
|
List<VariableArchiveListDTO> variableArchiveList = list(param);
|
|
|
|
|
|
|
|
|
|
|
|
if (param.isHasData()) {
|
|
|
|
|
|
List<Map<String, Object>> listMaps = buildVariableArchiveData(variableArchiveList);
|
|
|
|
|
|
// 组装数据
|
|
|
|
|
|
listMaps.forEach(e -> {
|
|
|
|
|
|
List<Object> row = new ArrayList<>();
|
2024-08-12 16:36:27 +08:00
|
|
|
|
row.add(e.get("taxAgentName").toString());
|
2024-08-09 10:21:40 +08:00
|
|
|
|
row.add(e.get("username").toString());
|
|
|
|
|
|
row.add(Optional.ofNullable(e.get("departmentName")).orElse("").toString());
|
|
|
|
|
|
row.add(e.get("mobile") == null ? "" : e.get("mobile").toString());
|
|
|
|
|
|
row.add(Optional.ofNullable(e.get("workcode")).orElse("").toString());
|
|
|
|
|
|
row.add(Util.null2String(e.get("idNo")));
|
|
|
|
|
|
row.add(Util.null2String(e.get("companystartdate")));
|
|
|
|
|
|
|
|
|
|
|
|
// 薪资项目数据
|
|
|
|
|
|
for (VariableItemPO variableItem : variableItems) {
|
|
|
|
|
|
row.add(e.containsKey(variableItem.getId() + SalaryItemConstant.VARIABLE_ITEM_DYNAMIC_SUFFIX) ? (e.get(variableItem.getId() + SalaryItemConstant.VARIABLE_ITEM_DYNAMIC_SUFFIX) == null ? ""
|
|
|
|
|
|
: e.get(variableItem.getId() + SalaryItemConstant.VARIABLE_ITEM_DYNAMIC_SUFFIX).toString()) : "");
|
|
|
|
|
|
}
|
|
|
|
|
|
rows.add(row);
|
|
|
|
|
|
});
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 4.注释
|
|
|
|
|
|
List<ExcelComment> excelComments = Lists.newArrayList();
|
|
|
|
|
|
|
|
|
|
|
|
return ExcelUtilPlus.genWorkbookV2(rows, nameI18n, excelComments);
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
|
public Map<String, Object> preview(VariableArchiveImportHandleParam importParam) {
|
|
|
|
|
|
Map<String, Object> apidatas = new HashMap<String, Object>();
|
|
|
|
|
|
|
|
|
|
|
|
//excel文件id
|
|
|
|
|
|
String imageId = Util.null2String(importParam.getImageId());
|
|
|
|
|
|
|
|
|
|
|
|
InputStream fileInputStream = null;
|
|
|
|
|
|
try {
|
|
|
|
|
|
fileInputStream = ImageFileManager.getInputStreamById(Integer.parseInt(imageId));
|
|
|
|
|
|
Sheet sheet = ExcelSupport.parseFile(fileInputStream, 0, EXCEL_TYPE_XLSX);
|
|
|
|
|
|
apidatas.put("headers", ExcelSupport.getSheetHeader(sheet, 0));
|
|
|
|
|
|
apidatas.put("list", ExcelParseHelper.parse2List(sheet, 1, 0));
|
|
|
|
|
|
return apidatas;
|
|
|
|
|
|
} finally {
|
|
|
|
|
|
IOUtils.closeQuietly(fileInputStream);
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
|
public Map<String, Object> importData(VariableArchiveImportHandleParam importParam) {
|
|
|
|
|
|
// 初始化国际化标签
|
|
|
|
|
|
VariableArchiveExcelBO.initI18n();
|
|
|
|
|
|
// 校验参数
|
|
|
|
|
|
checkImportParam(importParam);
|
|
|
|
|
|
String imageId = importParam.getImageId();
|
|
|
|
|
|
// 构建导入处理参数
|
|
|
|
|
|
importParam = buildImportHandleParam(importParam);
|
|
|
|
|
|
// 导入有重复
|
|
|
|
|
|
List<String> allTodoVariableArchives = Lists.newArrayList();
|
|
|
|
|
|
|
|
|
|
|
|
InputStream fileInputStream = null;
|
|
|
|
|
|
try {
|
|
|
|
|
|
fileInputStream = ImageFileManager.getInputStreamById(Integer.parseInt(imageId));
|
|
|
|
|
|
Sheet sheet = ExcelSupport.parseFile(fileInputStream, 0, EXCEL_TYPE_XLSX);
|
|
|
|
|
|
int total = 0;
|
|
|
|
|
|
//excel数据
|
|
|
|
|
|
List<Map<String, Object>> data = ExcelParseHelper.parse2Map(sheet, 1);
|
|
|
|
|
|
if (data != null) {
|
|
|
|
|
|
total += data.size();
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
int index = 0;
|
|
|
|
|
|
int successCount = 0;
|
|
|
|
|
|
int errorCount = 0;
|
|
|
|
|
|
// 用于（初始化导入）的相同employeeId时的处理
|
|
|
|
|
|
List<SalaryArchiveInitImportDTO> initImportData = Lists.newArrayList();
|
|
|
|
|
|
|
|
|
|
|
|
List<String> headers = ExcelSupport.getSheetHeader(sheet, 0);
|
|
|
|
|
|
|
|
|
|
|
|
// 错误提示
|
|
|
|
|
|
List<Map<String, String>> excelComments = new ArrayList<>();
|
|
|
|
|
|
// 错误sheet数据
|
|
|
|
|
|
List<Map<String, Object>> errorData = new ArrayList<>();
|
|
|
|
|
|
|
|
|
|
|
|
Map<String, Object> map;
|
|
|
|
|
|
for (int i = 0; i < data.size(); i++) {
|
|
|
|
|
|
index += 1;
|
|
|
|
|
|
map = data.get(i);
|
|
|
|
|
|
map.put("index", i + 2);
|
|
|
|
|
|
// 3.校验行内容
|
|
|
|
|
|
boolean isError = VariableArchiveExcelBO.singleRowCheck(allTodoVariableArchives, map, headers, excelComments, errorCount, importParam, user);
|
|
|
|
|
|
if (isError) {
|
|
|
|
|
|
errorCount += 1;
|
|
|
|
|
|
// 添加错误数据
|
|
|
|
|
|
errorData.add(map);
|
|
|
|
|
|
} else {
|
|
|
|
|
|
successCount += 1;
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 4.数据入库处理
|
|
|
|
|
|
handleImportData(importParam);
|
|
|
|
|
|
|
|
|
|
|
|
Map<String, Object> apidatas = new HashMap<>();
|
|
|
|
|
|
|
|
|
|
|
|
apidatas.put("successCount", successCount);
|
|
|
|
|
|
apidatas.put("errorCount", errorCount);
|
|
|
|
|
|
apidatas.put("errorNotice", excelComments);
|
|
|
|
|
|
return apidatas;
|
|
|
|
|
|
} finally {
|
|
|
|
|
|
IOUtils.closeQuietly(fileInputStream);
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private void checkImportParam(VariableArchiveImportHandleParam importParam) {
|
|
|
|
|
|
//excel文件id
|
|
|
|
|
|
String imageId = Util.null2String(importParam.getImageId());
|
|
|
|
|
|
//税款所属期
|
|
|
|
|
|
String salaryMonthStr = Util.null2String(importParam.getSalaryMonth());
|
|
|
|
|
|
if (StringUtils.isBlank(imageId)) {
|
|
|
|
|
|
throw new SalaryRunTimeException("文件不存在");
|
|
|
|
|
|
}
|
|
|
|
|
|
if (StringUtils.isBlank(salaryMonthStr)) {
|
|
|
|
|
|
throw new SalaryRunTimeException("薪资所属月为空");
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
* 构建导入处理参数
|
|
|
|
|
|
*
|
|
|
|
|
|
* @param param
|
|
|
|
|
|
* @return
|
|
|
|
|
|
*/
|
|
|
|
|
|
private VariableArchiveImportHandleParam buildImportHandleParam(VariableArchiveImportHandleParam param) {
|
|
|
|
|
|
// 获取所有可被引用的浮动薪资项目
|
|
|
|
|
|
List<VariableItemPO> variableItems = getVariableItemService(user).listAll();
|
|
|
|
|
|
Collection<Long> variableItemIds = variableItems.stream().map(VariableItemPO::getId).collect(Collectors.toList());
|
|
|
|
|
|
List<VariableArchivePO> variableArchiveList = getVariableArchiveMapper().listSome(VariableArchivePO.builder().salaryMonth(SalaryDateUtil.dateStrToLocalYearMonth(param.getSalaryMonth())).build());
|
|
|
|
|
|
|
|
|
|
|
|
List<Long> variableArchiveIds = variableArchiveList.stream().map(VariableArchivePO::getId).collect(Collectors.toList());
|
2024-08-12 16:36:27 +08:00
|
|
|
|
Map<String, VariableArchivePO> variableArchivesMap = SalaryEntityUtil.convert2Map(variableArchiveList, k -> k.getTaxAgentId() + "-" + k.getEmployeeId());
|
2024-08-09 10:21:40 +08:00
|
|
|
|
|
|
|
|
|
|
// 获取浮动薪资档案明细数据
|
|
|
|
|
|
List<VariableArchiveItemPO> variableArchiveItemPOS = getVariableArchiveItemService(user).listByVariableArchiveIds(variableArchiveIds);
|
|
|
|
|
|
Map<String, List<VariableArchiveItemPO>> variableArchiveItemMap = SalaryEntityUtil.group2Map(variableArchiveItemPOS, k -> k.getVariableArchiveId() + "-" + k.getVariableItemId());
|
|
|
|
|
|
|
2024-08-12 16:36:27 +08:00
|
|
|
|
Collection<TaxAgentManageRangeEmployeeDTO> taxAgentList;
|
|
|
|
|
|
taxAgentList = getTaxAgentService(user).listTaxAgentAndEmployeeTree((long) user.getUID());
|
|
|
|
|
|
|
|
|
|
|
|
|
2024-08-09 10:21:40 +08:00
|
|
|
|
return VariableArchiveImportHandleParam.builder()
|
|
|
|
|
|
.imageId(param.getImageId())
|
|
|
|
|
|
.salaryMonth(param.getSalaryMonth())
|
|
|
|
|
|
.salaryMonthDate(SalaryDateUtil.dateStrToLocalYearMonth(param.getSalaryMonth()))
|
|
|
|
|
|
.currentEmployeeId((long) user.getUID())
|
|
|
|
|
|
.tenantKey(SalaryDefaultTenantConstant.DEFAULT_TENANT_KEY)
|
|
|
|
|
|
//人员定位方式
|
|
|
|
|
|
.empValidType(getSalaryEmployeeService(user).empValidType())
|
|
|
|
|
|
// 获取租户下所有的人员
|
|
|
|
|
|
.employees(getSalaryEmployeeService(user).listAll(UseEmployeeTypeEnum.ORG))
|
|
|
|
|
|
// 浮动薪资项目
|
|
|
|
|
|
.variableItems(variableItems)
|
|
|
|
|
|
// 查询已有的浮动薪资档案基本数据
|
|
|
|
|
|
.variableArchivesMap(variableArchivesMap)
|
|
|
|
|
|
// 浮动薪资项目id
|
|
|
|
|
|
.variableItemIds(variableItemIds)
|
|
|
|
|
|
// 查询已生效的浮动薪资项目数据
|
|
|
|
|
|
.effectiveItemListMap(variableArchiveItemMap)
|
2024-08-12 16:36:27 +08:00
|
|
|
|
// 可以管理的义务人
|
|
|
|
|
|
.taxAgentList(taxAgentList)
|
2024-08-09 10:21:40 +08:00
|
|
|
|
// 当前时间
|
|
|
|
|
|
.nowTime(new Date())
|
|
|
|
|
|
// 当天
|
|
|
|
|
|
.today(new Date())
|
|
|
|
|
|
// 待保存浮动薪资档案
|
|
|
|
|
|
.variableArchiveSaves(Lists.newArrayList())
|
|
|
|
|
|
// 待保存浮动薪资档案-浮动薪资项目
|
|
|
|
|
|
.variableArchiveItemSaves(Lists.newArrayList())
|
|
|
|
|
|
// 待删除浮动薪资档案-浮动薪资项目
|
|
|
|
|
|
.variableArchiveItemDelSalaryItemIds(Lists.newArrayList())
|
|
|
|
|
|
.build();
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private void handleImportData(VariableArchiveImportHandleParam importHandleParam) {
|
|
|
|
|
|
List<VariableArchivePO> variableArchiveSaves = importHandleParam.getVariableArchiveSaves();
|
|
|
|
|
|
List<VariableArchiveItemPO> variableArchiveItemSaves = importHandleParam.getVariableArchiveItemSaves();
|
|
|
|
|
|
List<Long> variableArchiveItemDelSalaryItemIds = importHandleParam.getVariableArchiveItemDelSalaryItemIds();
|
|
|
|
|
|
|
|
|
|
|
|
// 新增档案
|
|
|
|
|
|
if (CollectionUtils.isNotEmpty(variableArchiveSaves)) {
|
|
|
|
|
|
variableArchiveSaves.stream().forEach(getVariableArchiveMapper()::insertIgnoreNull);
|
|
|
|
|
|
}
|
|
|
|
|
|
// 薪资档案-薪资项目
|
|
|
|
|
|
if (CollectionUtils.isNotEmpty(variableArchiveItemDelSalaryItemIds)) {
|
|
|
|
|
|
getVariableArchiveItemService(user).deleteByIds(variableArchiveItemDelSalaryItemIds);
|
|
|
|
|
|
}
|
|
|
|
|
|
// 薪资档案-薪资项目
|
|
|
|
|
|
if (CollectionUtils.isNotEmpty(variableArchiveItemSaves)) {
|
|
|
|
|
|
getVariableArchiveItemService(user).batchInsert(variableArchiveItemSaves);
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
|
public XSSFWorkbook export(VariableArchiveQueryParam param) {
|
|
|
|
|
|
// 名称
|
|
|
|
|
|
String nameI18n = SalaryI18nUtil.getI18nLabel(0, "浮动薪酬");
|
|
|
|
|
|
|
|
|
|
|
|
// 获取所有可被引用的薪资项目
|
|
|
|
|
|
List<VariableItemPO> variableItems = getVariableItemService(user).listAll();
|
|
|
|
|
|
List<Object> header = Lists.newArrayList();
|
2024-08-12 16:36:27 +08:00
|
|
|
|
header.add(SalaryI18nUtil.getI18nLabel(0, "个税扣缴义务人"));
|
2024-08-09 10:21:40 +08:00
|
|
|
|
header.add(SalaryI18nUtil.getI18nLabel(85429, "姓名"));
|
|
|
|
|
|
header.add(SalaryI18nUtil.getI18nLabel(86185, "部门"));
|
|
|
|
|
|
header.add(SalaryI18nUtil.getI18nLabel(86186, "手机号"));
|
|
|
|
|
|
header.add(SalaryI18nUtil.getI18nLabel(1933, "工号"));
|
|
|
|
|
|
header.add(SalaryI18nUtil.getI18nLabel(86186, "证件号码"));
|
|
|
|
|
|
header.add(SalaryI18nUtil.getI18nLabel(86187, "入职日期"));
|
|
|
|
|
|
for (VariableItemPO variableItem : variableItems) {
|
|
|
|
|
|
header.add(variableItem.getName());
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 2.表头
|
|
|
|
|
|
List<List<Object>> rows = new ArrayList<>();
|
|
|
|
|
|
rows.add(header);
|
|
|
|
|
|
// 获取档案信息
|
|
|
|
|
|
List<VariableArchiveListDTO> variableArchiveList = list(param);
|
|
|
|
|
|
List<Map<String, Object>> listMaps = buildVariableArchiveData(variableArchiveList);
|
|
|
|
|
|
// 组装数据
|
|
|
|
|
|
listMaps.forEach(e -> {
|
|
|
|
|
|
List<Object> row = new ArrayList<>();
|
2024-08-12 16:36:27 +08:00
|
|
|
|
row.add(e.get("taxAgentName").toString());
|
2024-08-09 10:21:40 +08:00
|
|
|
|
row.add(e.get("username").toString());
|
|
|
|
|
|
row.add(Optional.ofNullable(e.get("departmentName")).orElse("").toString());
|
|
|
|
|
|
row.add(e.get("mobile") == null ? "" : e.get("mobile").toString());
|
|
|
|
|
|
row.add(Optional.ofNullable(e.get("workcode")).orElse("").toString());
|
|
|
|
|
|
row.add(Util.null2String(e.get("idNo")));
|
|
|
|
|
|
row.add(Util.null2String(e.get("companystartdate")));
|
|
|
|
|
|
|
|
|
|
|
|
// 薪资项目数据
|
|
|
|
|
|
for (VariableItemPO variableItem : variableItems) {
|
|
|
|
|
|
row.add(e.containsKey(variableItem.getId() + SalaryItemConstant.VARIABLE_ITEM_DYNAMIC_SUFFIX) ? (e.get(variableItem.getId() + SalaryItemConstant.VARIABLE_ITEM_DYNAMIC_SUFFIX) == null ? ""
|
|
|
|
|
|
: e.get(variableItem.getId() + SalaryItemConstant.VARIABLE_ITEM_DYNAMIC_SUFFIX).toString()) : "");
|
|
|
|
|
|
}
|
|
|
|
|
|
rows.add(row);
|
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
|
|
// 4.注释
|
|
|
|
|
|
List<ExcelComment> excelComments = Lists.newArrayList();
|
|
|
|
|
|
|
|
|
|
|
|
return ExcelUtilPlus.genWorkbookV2(rows, nameI18n, excelComments);
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
|
public void deleteSelectVariableArchive(Collection<Long> deleteIds) {
|
|
|
|
|
|
if (CollectionUtils.isEmpty(deleteIds)) {
|
|
|
|
|
|
return;
|
|
|
|
|
|
}
|
|
|
|
|
|
List<VariableArchivePO> variableArchivePOList = getVariableArchiveMapper().listSome(VariableArchivePO.builder().ids(deleteIds).build());
|
|
|
|
|
|
List<Long> archiveIds = variableArchivePOList.stream().map(VariableArchivePO::getId).collect(Collectors.toList());
|
|
|
|
|
|
deleteByIds(archiveIds);
|
|
|
|
|
|
// 删除明细
|
|
|
|
|
|
getVariableArchiveItemService(user).deleteByArchiveIds(archiveIds);
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
2024-08-12 16:36:27 +08:00
|
|
|
|
public List<Map<String, Object>> listBySalaryMonthAndEmployeeIds(YearMonth salaryMonth, List<Long> employeeIds, Long taxAgentId) {
|
|
|
|
|
|
VariableArchiveQueryParam queryParam = VariableArchiveQueryParam.builder()
|
|
|
|
|
|
.employeeIds(employeeIds)
|
|
|
|
|
|
.salaryMonth(SalaryDateUtil.getFormatYearMonth(salaryMonth))
|
|
|
|
|
|
.salaryMonthDate(SalaryDateUtil.toDate(salaryMonth,1))
|
|
|
|
|
|
.taxAgentIds(Collections.singletonList(taxAgentId))
|
|
|
|
|
|
.build();
|
2024-08-09 10:21:40 +08:00
|
|
|
|
List<VariableArchiveListDTO> variableArchiveListDTO = list(queryParam);
|
|
|
|
|
|
return buildVariableArchiveData(variableArchiveListDTO);
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
