package cn.iocoder.yudao.module.hrm.service.salary;
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.util.StrUtil;
|
import cn.iocoder.yudao.framework.common.exception.ServiceException;
|
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
|
import cn.iocoder.yudao.module.hrm.controller.admin.salary.vo.HrmTaxRateConfigImportExcelVO;
|
import cn.iocoder.yudao.module.hrm.controller.admin.salary.vo.HrmTaxRateConfigImportReqVO;
|
import cn.iocoder.yudao.module.hrm.controller.admin.salary.vo.HrmTaxRateConfigImportRespVO;
|
import cn.iocoder.yudao.module.hrm.dal.dataobject.salary.HrmTaxRateConfigDO;
|
import cn.iocoder.yudao.module.hrm.dal.mysql.salary.HrmTaxRateConfigMapper;
|
import jakarta.annotation.Resource;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.validation.annotation.Validated;
|
|
import java.time.LocalDate;
|
import java.util.ArrayList;
|
import java.util.LinkedHashMap;
|
import java.util.List;
|
|
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
|
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.filterList;
|
import static cn.iocoder.yudao.module.hrm.enums.ErrorCodeConstants.*;
|
|
/**
|
* 个税税率配置 Service 实现类
|
*
|
* @author 超级管理员
|
*/
|
@Service
|
@Validated
|
public class HrmTaxRateConfigServiceImpl implements HrmTaxRateConfigService {
|
|
@Resource
|
private HrmTaxRateConfigMapper taxRateConfigMapper;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void createTaxRateConfigList(List<HrmTaxRateConfigDO> configList) {
|
for (HrmTaxRateConfigDO config : configList) {
|
taxRateConfigMapper.insert(config);
|
}
|
}
|
|
@Override
|
public void updateTaxRateConfig(HrmTaxRateConfigDO config) {
|
validateTaxRateConfigExists(config.getId());
|
taxRateConfigMapper.updateById(config);
|
}
|
|
@Override
|
public void deleteTaxRateConfig(Long id) {
|
validateTaxRateConfigExists(id);
|
taxRateConfigMapper.deleteById(id);
|
}
|
|
@Override
|
public HrmTaxRateConfigDO getTaxRateConfig(Long id) {
|
return taxRateConfigMapper.selectById(id);
|
}
|
|
@Override
|
public List<HrmTaxRateConfigDO> getTaxRateConfigList() {
|
return taxRateConfigMapper.selectListByStatus(null);
|
}
|
|
@Override
|
public List<HrmTaxRateConfigDO> getEffectiveTaxRateConfigList(LocalDate effectiveDate) {
|
return taxRateConfigMapper.selectListByEffectiveDate(effectiveDate);
|
}
|
|
private void validateTaxRateConfigExists(Long id) {
|
if (taxRateConfigMapper.selectById(id) == null) {
|
throw exception(TAX_RATE_CONFIG_NOT_EXISTS);
|
}
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public HrmTaxRateConfigImportRespVO importTaxRateConfigList(
|
List<HrmTaxRateConfigImportExcelVO> importList, HrmTaxRateConfigImportReqVO importReqVO) {
|
// 1. 校验非空
|
importList = filterList(importList, item -> item.getLevel() != null);
|
if (CollUtil.isEmpty(importList)) {
|
throw exception(TAX_RATE_CONFIG_IMPORT_LIST_IS_EMPTY);
|
}
|
// 2. 逐条处理
|
HrmTaxRateConfigImportRespVO respVO = HrmTaxRateConfigImportRespVO.builder()
|
.createNames(new ArrayList<>())
|
.updateNames(new ArrayList<>())
|
.failureNames(new LinkedHashMap<>())
|
.build();
|
importList.forEach(importConfig -> {
|
String configKey = StrUtil.isNotBlank(importConfig.getName()) ? importConfig.getName()
|
: (importConfig.getEffectiveDate() + "-" + importConfig.getLevel());
|
try {
|
// 2.1 生效日期与级数必填
|
if (importConfig.getEffectiveDate() == null) {
|
respVO.getFailureNames().put(configKey, "生效日期不能为空");
|
return;
|
}
|
// 2.2 判断是否存在（按生效日期+级数唯一）
|
HrmTaxRateConfigDO existConfig = taxRateConfigMapper.selectByEffectiveDateAndLevel(
|
importConfig.getEffectiveDate(), importConfig.getLevel());
|
if (existConfig == null) {
|
// 2.2.1 新增
|
HrmTaxRateConfigDO config = BeanUtils.toBean(importConfig, HrmTaxRateConfigDO.class);
|
if (config.getStatus() == null) {
|
config.setStatus(0);
|
}
|
taxRateConfigMapper.insert(config);
|
respVO.getCreateNames().add(configKey);
|
return;
|
}
|
// 2.2.2 已存在，判断是否允许更新
|
if (!importReqVO.getUpdateSupport()) {
|
respVO.getFailureNames().put(configKey,
|
StrUtil.format(TAX_RATE_CONFIG_EXISTS.getMsg(), configKey));
|
return;
|
}
|
HrmTaxRateConfigDO updateConfig = BeanUtils.toBean(importConfig, HrmTaxRateConfigDO.class)
|
.setId(existConfig.getId());
|
if (updateConfig.getStatus() == null) {
|
updateConfig.setStatus(0);
|
}
|
taxRateConfigMapper.updateById(updateConfig);
|
respVO.getUpdateNames().add(configKey);
|
} catch (ServiceException ex) {
|
respVO.getFailureNames().put(configKey, ex.getMessage());
|
}
|
});
|
return respVO;
|
}
|
|
}
|
