增加扣除名单

This commit is contained in:
钱涛 2025-03-11 11:15:08 +08:00
parent 894b9cd1fc
commit 12bbfeceae
2 changed files with 31 additions and 27 deletions

View File

@ -53,7 +53,7 @@ public class DeductionAmountPO {
* 人员类型
*/
@ElogTransform(name = "人员类型")
private Byte employeeType;
private Integer employeeType;
/**
* 工号
@ -71,24 +71,24 @@ public class DeductionAmountPO {
* 证件类型
*/
@ElogTransform(name = "证件类型")
private Byte cardType;
private Integer cardType;
/**
* 报送状态
*/
@ElogTransform(name = "报送状态")
private Byte declareStatus;
private Integer declareStatus;
/**
* 是否扣除
*/
@ElogTransform(name = "是否扣除")
private Byte deductFlag;
private Integer deductFlag;
/**
* 是否成功报送过
*/
@ElogTransform(name = "是否成功报送过")
private Byte successfullyDeclared;
private Integer successfullyDeclared;
/**

View File

@ -3,6 +3,7 @@ package com.engine.salary.service.impl;
import com.engine.common.util.ServiceUtil;
import com.engine.core.impl.Service;
import com.engine.salary.constant.SalaryDefaultTenantConstant;
import com.engine.salary.entity.deductionamount.param.DeductionAmountAddParam;
import com.engine.salary.entity.deductionamount.param.DeductionAmountOnlineQueryParam;
import com.engine.salary.entity.deductionamount.po.DeductionAmountPO;
@ -15,8 +16,10 @@ import com.engine.salary.util.SalaryEntityUtil;
import com.engine.salary.util.db.MapperProxyFactory;
import com.engine.salary.util.valid.ValidUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.math.NumberUtils;
import weaver.hrm.User;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;
@ -86,27 +89,28 @@ public class DeductionAmountServiceImpl extends Service implements DeductionAmou
List<Long> employeeDeclareIds = param.getEmployeeDeclareIds();
List<EmployeeDeclarePO> employeeDeclarePOS = getEmployeeDeclareMapper().listSome(EmployeeDeclarePO.builder().ids(employeeDeclareIds).build());
// employeeDeclarePOS.stream()
// .filter(employeeDeclarePO -> !oldIds.contains(employeeDeclarePO.getEmployeeId()))
// .map(employeeDeclarePO -> {
// DeductionAmountPO.builder()
// .id(employeeDeclarePO.getEmployeeId())
// .taxAgentId(employeeDeclarePO.getEmployeeId())
// .year(param.getYear())
// .employeeId(employeeDeclarePO.getEmployeeId())
// .employeeName(employeeDeclarePO.getEmployeeName())
// .employeeType(employeeDeclarePO.getEmployeeId())
// .jobNum(employeeDeclarePO.getEmployeeId())
// .cardNum(employeeDeclarePO.getEmployeeId())
// .cardType(employeeDeclarePO.getEmployeeId())
// .declareStatus(employeeDeclarePO.getEmployeeId())
// .deductFlag(employeeDeclarePO.getEmployeeId())
// .successfullyDeclared(employeeDeclarePO.getEmployeeId())
// .creator(employeeId)
// .createTime(now)
// .updateTime(now)
// .tenantKey(SalaryDefaultTenantConstant.DEFAULT_TENANT_KEY)
// .deleteType(NumberUtils.INTEGER_ZERO)
// });
Date now = new Date();
employeeDeclarePOS.stream()
.filter(employeeDeclarePO -> !oldIds.contains(employeeDeclarePO.getEmployeeId()))
.map(employeeDeclarePO -> {
DeductionAmountPO.builder()
.id(employeeDeclarePO.getEmployeeId())
.taxAgentId(employeeDeclarePO.getEmployeeId())
.year(param.getYear())
.employeeId(employeeDeclarePO.getEmployeeId())
.employeeName(employeeDeclarePO.getEmployeeName())
.employeeType(employeeDeclarePO.getEmployeeType())
.jobNum(employeeDeclarePO.getJobNum())
.cardNum(employeeDeclarePO.getCardNum())
.cardType(employeeDeclarePO.getCardType())
.declareStatus(0)
.deductFlag(1)
.successfullyDeclared(0)
.creator((long)user.getUID())
.createTime(now)
.updateTime(now)
.tenantKey(SalaryDefaultTenantConstant.DEFAULT_TENANT_KEY)
.deleteType(NumberUtils.INTEGER_ZERO);
});
}
}