工资单发送action

src/com/engine/salary/action/FileSalaryAcctRecordAction.java

@@ -1,12 +1,14 @@
 package com.engine.salary.action;
 
 import com.engine.common.util.ServiceUtil;
+import com.engine.salary.entity.salaryacct.po.SalaryAcctRecordPO;
 import com.engine.salary.mapper.taxagent.TaxAgentMapper;
 import com.engine.salary.service.SalaryAcctRecordService;
 import com.engine.salary.service.impl.SalaryAcctRecordServiceImpl;
 import com.engine.salary.util.db.MapperProxyFactory;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
+import weaver.general.BaseBean;
 import weaver.general.Util;
 import weaver.hrm.User;
 import weaver.interfaces.workflow.action.Action;
@@ -59,8 +61,19 @@ public class FileSalaryAcctRecordAction implements Action {
         }
         User user = new User();
         user.setUid(1);
+        Long acctRecordId = Long.valueOf(salaryAcctRecordId);
+        SalaryAcctRecordPO salaryAcctRecordPO = getSalaryAcctRecordService(user).getById(acctRecordId);
+        if (salaryAcctRecordPO == null) {
+            requestInfo.getRequestManager().setMessage("薪资核算记录不存在,或已被删除");
+            return FAILURE_AND_CONTINUE;
+        }
+        if (salaryAcctRecordPO.getStatus() > 1) {
+            BaseBean baseBean = new BaseBean();
+            baseBean.writeLog("核算记录归档action， 该核算记录已经归档：" + salaryAcctRecordPO.getId());
+            return SUCCESS;
+        }
         try {
-            getSalaryAcctRecordService(user).file(Long.valueOf(salaryAcctRecordId));
+            getSalaryAcctRecordService(user).file(acctRecordId);
         } catch (Exception e) {
             requestInfo.getRequestManager().setMessage(e.getMessage());
             return FAILURE_AND_CONTINUE;

src/com/engine/salary/action/SendSalaryAction.java

@@ -0,0 +1,118 @@
+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;
+
+
+    @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 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;
+    }
+}

src/com/engine/salary/service/SalarySendService.java

@@ -216,4 +216,6 @@ public interface SalarySendService {
     void autoConfirmSalaryBill(List<Long> needAutoIds);
 
     List<SalarySendPO> getByIds(List<Long> salarySendId);
+
+    List<SalarySendPO> listSome(SalarySendPO param);
 }

src/com/engine/salary/service/impl/SalarySendServiceImpl.java

@@ -1725,4 +1725,9 @@ public class SalarySendServiceImpl extends Service implements SalarySendService
         }
         return getSalarySendMapper().getByIds(salarySendId);
     }
+
+    @Override
+    public List<SalarySendPO> listSome(SalarySendPO param) {
+        return getSalarySendMapper().listSome(param);
+    }
 }