137 lines
5.2 KiB
Java
137 lines
5.2 KiB
Java
package com.engine.salary.action;
|
||
|
||
import com.engine.common.util.ServiceUtil;
|
||
import com.engine.salary.biz.SalarySendInfoBiz;
|
||
import com.engine.salary.entity.salaryBill.param.SalarySendGrantParam;
|
||
import com.engine.salary.entity.salaryBill.po.SalarySendPO;
|
||
import com.engine.salary.entity.salaryacct.po.SalaryAcctRecordPO;
|
||
import com.engine.salary.service.SalaryAcctRecordService;
|
||
import com.engine.salary.service.SalaryBillService;
|
||
import com.engine.salary.service.SalarySendService;
|
||
import com.engine.salary.service.SalaryTemplateService;
|
||
import com.engine.salary.service.impl.SalaryAcctRecordServiceImpl;
|
||
import com.engine.salary.service.impl.SalaryBillServiceImpl;
|
||
import com.engine.salary.service.impl.SalarySendServiceImpl;
|
||
import com.engine.salary.service.impl.SalaryTemplateServiceImpl;
|
||
import lombok.extern.slf4j.Slf4j;
|
||
import org.apache.commons.lang3.StringUtils;
|
||
import weaver.general.Util;
|
||
import weaver.hrm.User;
|
||
import weaver.interfaces.workflow.action.Action;
|
||
import weaver.soa.workflow.request.Property;
|
||
import weaver.soa.workflow.request.RequestInfo;
|
||
|
||
import java.util.Arrays;
|
||
import java.util.List;
|
||
import java.util.Map;
|
||
import java.util.stream.Collectors;
|
||
|
||
/**
|
||
* @author Harryxzy
|
||
* @ClassName FileSalaryAcctRecordAction
|
||
* @date 2023/12/13 9:17
|
||
* @description 工资单发放action
|
||
*/
|
||
@Slf4j
|
||
public class SendSalaryAction implements Action {
|
||
|
||
|
||
private SalaryAcctRecordService getSalaryAcctRecordService(User user) {
|
||
return ServiceUtil.getService(SalaryAcctRecordServiceImpl.class, user);
|
||
}
|
||
|
||
private SalarySendService getSalarySendService(User user) {
|
||
return ServiceUtil.getService(SalarySendServiceImpl.class, user);
|
||
}
|
||
|
||
private SalaryTemplateService getSalaryTemplateService(User user) {
|
||
return ServiceUtil.getService(SalaryTemplateServiceImpl.class, user);
|
||
}
|
||
|
||
private SalarySendInfoBiz salarySendInfoMapper = new SalarySendInfoBiz();
|
||
|
||
private SalaryBillService getSalaryBillService(User user) {
|
||
return ServiceUtil.getService(SalaryBillServiceImpl.class, user);
|
||
}
|
||
|
||
|
||
/**
|
||
* 发放id（核算记录id，工资单id）流程字段名
|
||
*/
|
||
private String idFieldName;
|
||
|
||
/**
|
||
* 根据什么id（核算记录id，工资单id）发工资单
|
||
*/
|
||
private String sendBy;
|
||
|
||
// 是否执行action的字段, 0代表不执行，其余代表执行
|
||
private String enableField;
|
||
|
||
public String getEnableField() {
|
||
return enableField;
|
||
}
|
||
|
||
public void setEnableField(String enableField) {
|
||
this.enableField = enableField;
|
||
}
|
||
|
||
|
||
@Override
|
||
public String execute(RequestInfo requestInfo) {
|
||
Property[] properties = requestInfo.getMainTableInfo().getProperty();
|
||
Map<String, String> fieldMap = Arrays.stream(properties).collect(Collectors.toMap(Property::getName,
|
||
property -> Util.null2String(property.getValue())));
|
||
|
||
String enable = fieldMap.get(enableField);
|
||
if (StringUtils.isNotBlank(enable) && enable.equals("0")) {
|
||
// 不执行action
|
||
return SUCCESS;
|
||
}
|
||
|
||
String idStr = fieldMap.get(idFieldName);
|
||
if (StringUtils.isBlank(idStr)) {
|
||
requestInfo.getRequestManager().setMessage("核算记录id或工资单id不能为空");
|
||
return FAILURE_AND_CONTINUE;
|
||
}
|
||
User user = new User();
|
||
user.setUid(1);
|
||
Long id = Long.valueOf(idStr);
|
||
SalarySendPO salarySendPO;
|
||
if(!org.h2.util.StringUtils.isNullOrEmpty(sendBy) && sendBy.equals("salaryAcctRecordId")) {
|
||
// 根据核算记录id发
|
||
SalaryAcctRecordPO salaryAcctRecordPO = getSalaryAcctRecordService(user).getById(id);
|
||
if (salaryAcctRecordPO == null) {
|
||
requestInfo.getRequestManager().setMessage("薪资核算记录不存在,或已被删除");
|
||
return FAILURE_AND_CONTINUE;
|
||
}
|
||
if (salaryAcctRecordPO.getStatus() == 1) {
|
||
requestInfo.getRequestManager().setMessage("核算记录还未归档,请先归档");
|
||
return FAILURE_AND_CONTINUE;
|
||
}
|
||
// 获取工资单id
|
||
List<SalarySendPO> salarySendPOList = getSalarySendService(user).listSome(SalarySendPO.builder().salaryAccountingId(id).sendStatus(0).build());
|
||
salarySendPO = salarySendPOList.get(0);
|
||
} else if (!org.h2.util.StringUtils.isNullOrEmpty(sendBy) && sendBy.equals("salarySendId")) {
|
||
// 根据工资单发
|
||
salarySendPO = getSalarySendService(user).getById(id);
|
||
} else {
|
||
requestInfo.getRequestManager().setMessage("请先维护根据什么id发放工资单的sendBy参数");
|
||
return FAILURE_AND_CONTINUE;
|
||
}
|
||
|
||
if (salarySendPO == null || salarySendPO.getId() == null) {
|
||
requestInfo.getRequestManager().setMessage("工资单不存在或已被删除！");
|
||
return FAILURE_AND_CONTINUE;
|
||
}
|
||
try {
|
||
// 全部发放
|
||
getSalaryBillService(user).grant(SalarySendGrantParam.builder().salarySendId(salarySendPO.getId()).build());
|
||
} catch (Exception e) {
|
||
requestInfo.getRequestManager().setMessage(e.getMessage());
|
||
return FAILURE_AND_CONTINUE;
|
||
}
|
||
return SUCCESS;
|
||
}
|
||
}
|