feat: 重新改版流程

admin/src/main/java/com/anplus/hr/constant/HrFlowEnum.java

@@ -30,7 +30,12 @@ public enum HrFlowEnum {
     /**
      * 已完成
      */
-    FINISH(2, "已完成");
+    FINISH(2, "已完成"),
+
+    /**
+     * 已撤销
+     */
+    CANCEL(3, "已撤销");
 
     /**
      * 状态
@@ -44,4 +49,8 @@ public enum HrFlowEnum {
 
     private static final Map<Integer, HrFlowEnum> STATUS_MAP = Arrays.stream(HrFlowEnum.values())
             .collect(Collectors.toConcurrentMap(HrFlowEnum::getStatus, Function.identity()));
+
+    public static boolean isNotAbleToApply(Integer status) {
+        return status != null && !CANCEL.status.equals(status);
+    }
 }

admin/src/main/java/com/anplus/hr/controller/EmployeeFlowCtrl.java

@@ -75,8 +75,8 @@ public class EmployeeFlowCtrl {
     @SaCheckPermission("employee:flow:add")
     @PinSysLog(value = "人事审批对象", businessType = BusinessType.INSERT)
     @PostMapping()
-    public Response add(@Validated(AddGroup.class) @RequestBody EmployeeFlowParam param) {
-        return ResponseUtils.ofResult(employeeFlowServ.insertByParam(param));
+    public SingleResponse<EmployeeFlowVo> add(@Validated(AddGroup.class) @RequestBody EmployeeFlowParam param) {
+        return SingleResponse.of(employeeFlowServ.insertByParam(param));
     }
 
     /**
@@ -85,8 +85,8 @@ public class EmployeeFlowCtrl {
     @SaCheckPermission("employee:flow:edit")
     @PinSysLog(value = "人事审批对象", businessType = BusinessType.UPDATE)
     @PutMapping()
-    public Response edit(@Validated(EditGroup.class) @RequestBody EmployeeFlowParam param) {
-        return ResponseUtils.ofResult(employeeFlowServ.updateByParam(param));
+    public SingleResponse<EmployeeFlowVo> edit(@Validated(EditGroup.class) @RequestBody EmployeeFlowParam param) {
+        return SingleResponse.of(employeeFlowServ.updateByParam(param));
     }
 
     /**

admin/src/main/java/com/anplus/hr/controller/EmployeeInfoCtrl.java

@@ -8,6 +8,7 @@ import com.alibaba.cola.dto.PageResponse;
 import com.alibaba.cola.dto.Response;
 import com.alibaba.cola.dto.SingleResponse;
 import com.anplus.hr.domain.params.*;
+import com.anplus.hr.domain.vo.EmployeeFlowVo;
 import com.anplus.hr.domain.vo.EmployeeInfoImportVo;
 import com.anplus.hr.domain.vo.EmployeeInfoVo;
 import com.anplus.hr.service.EmployeeInfoServ;
@@ -162,8 +163,8 @@ public class EmployeeInfoCtrl {
     @SaCheckPermission("employee:info:add")
     @PinSysLog(value = "员工信息-入职申请", businessType = BusinessType.UPDATE)
     @PostMapping("/applyEntry")
-    public Response applyEntry(@RequestBody EmployeeEntryApplyParam param) {
-        return ResponseUtils.ofResult(employeeInfoServ.applyEntry(param));
+    public SingleResponse<EmployeeFlowVo> applyEntry(@RequestBody EmployeeEntryApplyParam param) {
+        return SingleResponse.of(employeeInfoServ.applyEntry(param));
     }
 
     /**
@@ -173,8 +174,8 @@ public class EmployeeInfoCtrl {
     @SaCheckPermission("employee:info:edit")
     @PinSysLog(value = "员工信息-调职申请", businessType = BusinessType.UPDATE)
     @PostMapping("/applyTransfer")
-    public Response applyTransfer(@Validated @RequestBody EmployeeTransferApplyParam param) {
-        return ResponseUtils.ofResult(employeeInfoServ.applyTransfer(param));
+    public SingleResponse<EmployeeFlowVo> applyTransfer(@Validated @RequestBody EmployeeTransferApplyParam param) {
+        return SingleResponse.of(employeeInfoServ.applyTransfer(param));
     }
 
     /**
@@ -184,8 +185,8 @@ public class EmployeeInfoCtrl {
     @SaCheckPermission("employee:info:resign")
     @PinSysLog(value = "员工信息-离职申请", businessType = BusinessType.UPDATE)
     @PostMapping("/applyResign")
-    public Response applyResign(@Validated @RequestBody EmployeeResignApplyParam param) {
-        return ResponseUtils.ofResult(employeeInfoServ.applyResign(param));
+    public SingleResponse<EmployeeFlowVo> applyResign(@Validated @RequestBody EmployeeResignApplyParam param) {
+        return SingleResponse.of(employeeInfoServ.applyResign(param));
     }
 
     /**
@@ -195,8 +196,8 @@ public class EmployeeInfoCtrl {
     @SaCheckPermission("employee:info:regular")
     @PinSysLog(value = "员工信息-转正申请", businessType = BusinessType.UPDATE)
     @PostMapping("/applyRegular")
-    public Response applyRegular(@Validated @RequestBody EmployeeRegularApplyParam param) {
-        return ResponseUtils.ofResult(employeeInfoServ.applyRegular(param));
+    public SingleResponse<EmployeeFlowVo> applyRegular(@Validated @RequestBody EmployeeRegularApplyParam param) {
+        return SingleResponse.of(employeeInfoServ.applyRegular(param));
     }
 
     /**
@@ -206,8 +207,8 @@ public class EmployeeInfoCtrl {
     @SaCheckPermission("employee:info:contractRenewal")
     @PinSysLog(value = "员工信息-合同续约申请", businessType = BusinessType.UPDATE)
     @PostMapping("/applyRenewalContract")
-    public Response applyRenewalContract(@Validated @RequestBody EmployeeRenewalContractApplyParam param) {
-        return ResponseUtils.ofResult(employeeInfoServ.applyRenewalContract(param));
+    public SingleResponse<EmployeeFlowVo> applyRenewalContract(@Validated @RequestBody EmployeeRenewalContractApplyParam param) {
+        return SingleResponse.of(employeeInfoServ.applyRenewalContract(param));
     }
 
     /**

admin/src/main/java/com/anplus/hr/domain/params/EmployeeEntryApplyParam.java

 package com.anplus.hr.domain.params;
 
+import jakarta.validation.constraints.NotBlank;
 import jakarta.validation.constraints.NotNull;
 import lombok.Data;
 
@@ -14,6 +15,12 @@ public class EmployeeEntryApplyParam {
 
     private Long id;
 
+    /**
+     * 员工id
+     */
+    @NotBlank(message = "员工不能为空")
+    private Long employeeId;
+
     /**
      * 入职时间
      */

admin/src/main/java/com/anplus/hr/domain/params/EmployeeRegularApplyParam.java

 package com.anplus.hr.domain.params;
 
+import jakarta.validation.constraints.NotBlank;
 import jakarta.validation.constraints.NotNull;
 import lombok.Data;
 
@@ -22,6 +23,12 @@ public class EmployeeRegularApplyParam {
 
     private Long id;
 
+    /**
+     * 员工id
+     */
+    @NotBlank(message = "员工不能为空")
+    private Long employeeId;
+
     /**
      * 劳动合同开始时间
      */

admin/src/main/java/com/anplus/hr/domain/params/EmployeeRenewalContractApplyParam.java

@@ -20,6 +20,12 @@ public class EmployeeRenewalContractApplyParam {
 
     private Long id;
 
+    /**
+     * 员工id
+     */
+    @NotBlank(message = "员工不能为空")
+    private Long employeeId;
+
     /**
      * 合同形式
      */

admin/src/main/java/com/anplus/hr/domain/params/EmployeeResignApplyParam.java

@@ -18,6 +18,12 @@ public class EmployeeResignApplyParam {
 
     private Long id;
 
+    /**
+     * 员工id
+     */
+    @NotBlank(message = "员工不能为空")
+    private Long employeeId;
+
     /**
      * 离职类型
      */

admin/src/main/java/com/anplus/hr/domain/params/EmployeeTransferApplyParam.java

@@ -15,6 +15,12 @@ public class EmployeeTransferApplyParam {
 
     private Long id;
 
+    /**
+     * 员工id
+     */
+    @NotBlank(message = "员工不能为空")
+    private Long employeeId;
+
     /**
      * 板块
      */

admin/src/main/java/com/anplus/hr/domain/vo/EmployeeFlowVo.java

@@ -36,6 +36,11 @@ public class EmployeeFlowVo implements Serializable {
     @ExcelProperty(value = "申请编号")
     private String applyCode;
 
+    /**
+     * 流程code
+     */
+    private String flowCode;
+
     /**
      * 审批类型
      */
@@ -48,17 +53,17 @@ public class EmployeeFlowVo implements Serializable {
     @ExcelProperty(value = "员工信息ID")
     private Long employeeId;
 
-//    /**
-//     * 开始时间
-//     */
-//    @ExcelProperty(value = "开始时间")
-//    private LocalDateTime startDate;
-//
-//    /**
-//     * 结束时间
-//     */
-//    @ExcelProperty(value = "结束时间")
-//    private LocalDateTime endDate;
+    /**
+     * 员工姓名
+     */
+    @ExcelProperty(value = "员工姓名")
+    private String name;
+
+    /**
+     * 员工部门
+     */
+    @ExcelProperty(value = "员工部门")
+    private String deptName;
 
     /**
      * 审计内容

admin/src/main/java/com/anplus/hr/domain/vo/EmployeeInfoVo.java

@@ -538,6 +538,11 @@ public class EmployeeInfoVo implements TransPojo, Serializable {
     @ExcelProperty(value = "绩效比例")
     private String performanceRatio;
 
+    /**
+     * 员工状态
+     */
+    private Integer status;
+
 
     /**
      * 入职审批状态

admin/src/main/java/com/anplus/hr/service/EmployeeAuditLogServ.java

@@ -14,6 +14,8 @@ public interface EmployeeAuditLogServ {
 
     Boolean saveAuditLogs(List<SysAuditLog> auditLog);
 
+    Boolean removeAuditLogs(List<Long> logIds);
+
     default void initAuditLog(String auditName, String auditField, String auditFieldName, String afterVal, List<SysAuditLog> list) {
         SysAuditLog auditLog = new SysAuditLog();
         auditLog.setAuditName(auditName);

admin/src/main/java/com/anplus/hr/service/EmployeeFlowServ.java

@@ -48,7 +48,7 @@ public interface EmployeeFlowServ extends IService<EmployeeFlow> {
      * @param param 人事审批对象
      * @return 是否新增成功
      */
-    Boolean insertByParam(EmployeeFlowParam param);
+    EmployeeFlowVo insertByParam(EmployeeFlowParam param);
 
     /**
      * 修改人事审批对象
@@ -56,7 +56,15 @@ public interface EmployeeFlowServ extends IService<EmployeeFlow> {
      * @param param 人事审批对象
      * @return 是否修改成功
      */
-    Boolean updateByParam(EmployeeFlowParam param);
+    EmployeeFlowVo updateByParam(EmployeeFlowParam param);
+
+    /**
+     * 新增或修改人事审批对象
+     *
+     * @param param 人事审批对象
+     * @return 是否新增或修改成功
+     */
+    EmployeeFlowVo insertOrUpdateByParam(EmployeeFlowParam param);
 
     /**
      * 提交请假并发起流程

admin/src/main/java/com/anplus/hr/service/EmployeeInfoServ.java

@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.StrUtil;
 import com.alibaba.cola.dto.PageResponse;
 import com.alibaba.cola.dto.Response;
+import com.anplus.hr.domain.vo.EmployeeFlowVo;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.anplus.hr.domain.EmployeeInfo;
@@ -113,35 +114,35 @@ public interface EmployeeInfoServ extends IService<EmployeeInfo> {
      *
      * @param param 参数
      */
-    Boolean applyEntry(EmployeeEntryApplyParam param);
+    EmployeeFlowVo applyEntry(EmployeeEntryApplyParam param);
 
     /**
      * 员工调职申请
      *
      * @param param 参数
      */
-    Boolean applyTransfer(EmployeeTransferApplyParam param);
+    EmployeeFlowVo applyTransfer(EmployeeTransferApplyParam param);
 
     /**
      * 员工离职申请
      *
      * @param param 参数
      */
-    Boolean applyResign(EmployeeResignApplyParam param);
+    EmployeeFlowVo applyResign(EmployeeResignApplyParam param);
 
     /**
      * 员工转正申请
      *
      * @param param 参数
      */
-    Boolean applyRegular(EmployeeRegularApplyParam param);
+    EmployeeFlowVo applyRegular(EmployeeRegularApplyParam param);
 
     /**
      * 员工续签合同申请
      *
      * @param param 参数
      */
-    Boolean applyRenewalContract(EmployeeRenewalContractApplyParam param);
+    EmployeeFlowVo applyRenewalContract(EmployeeRenewalContractApplyParam param);
 
     /**
      * 校验并批量删除员工信息信息

admin/src/main/java/com/anplus/hr/service/impl/EmployeeAuditLogServImpl.java

@@ -43,4 +43,9 @@ public class EmployeeAuditLogServImpl implements EmployeeAuditLogServ {
     public Boolean saveAuditLogs(List<SysAuditLog> auditLog) {
         return SqlHelper.retBool(auditLogMapper.insert(auditLog));
     }
+
+    @Override
+    public Boolean removeAuditLogs(List<Long> logIds) {
+        return SqlHelper.retBool(auditLogMapper.deleteByIds(logIds));
+    }
 }
\ No newline at end of file

admin/src/main/java/com/anplus/hr/service/impl/EmployeeFlowServImpl.java

@@ -118,12 +118,20 @@ public class EmployeeFlowServImpl extends ServiceImpl<EmployeeFlowMapper, Employ
     @Override
     public EmployeeFlowVo queryById(Long id) {
         EmployeeFlow employeeFlow = employeeFlowMapper.selectById(id);
+        EmployeeFlowVo employeeFlowVo = MapstructUtils.convert(employeeFlow, EmployeeFlowVo.class);
+        if (employeeFlow.getEmployeeId() != null) {
+            EmployeeInfo employeeInfo = employeeInfoMapper.selectById(employeeFlow.getEmployeeId());
+            employeeFlowVo.setName(employeeInfo.getName());
+            employeeFlowVo.setDeptName(employeeInfo.getPlate() +
+                    " / " + employeeInfo.getFirstLevelDepartment() +
+                    " / " + Convert.toStr(employeeInfo.getSecondLevelDepartment()) +
+                    " / " + Convert.toStr(employeeInfo.getThirdLevelDepartment()));
+        }
         List<SysAuditLogVo> sysAuditLogVoList = null;
         if (StrUtil.isNotBlank(employeeFlow.getLogIds())) {
             List<SysAuditLog> auditLogs = employeeAuditLogServ.queryAuditLogs(employeeFlow.getLogIds());
             sysAuditLogVoList = MapstructUtils.convert(auditLogs, SysAuditLogVo.class);
         }
-        EmployeeFlowVo employeeFlowVo = MapstructUtils.convert(employeeFlow, EmployeeFlowVo.class);
         employeeFlowVo.setAuditLogList(sysAuditLogVoList);
         return employeeFlowVo;
     }
@@ -135,10 +143,13 @@ public class EmployeeFlowServImpl extends ServiceImpl<EmployeeFlowMapper, Employ
      * @return 是否新增成功
      */
     @Override
-    public Boolean insertByParam(EmployeeFlowParam param) {
+    public EmployeeFlowVo insertByParam(EmployeeFlowParam param) {
         EmployeeFlow employeeFlow = MapstructUtils.convert(param, EmployeeFlow.class);
         employeeFlow.setId(snGen.nextId());
-        return this.save(employeeFlow);
+        employeeFlow.setStatus(BusinessStatusEnum.DRAFT.getStatus());
+        employeeFlow.setApplyCode(System.currentTimeMillis() + StrUtil.EMPTY);
+        this.save(employeeFlow);
+        return MapstructUtils.convert(employeeFlow, EmployeeFlowVo.class);
     }
 
     /**
@@ -148,9 +159,28 @@ public class EmployeeFlowServImpl extends ServiceImpl<EmployeeFlowMapper, Employ
      * @return 是否修改成功
      */
     @Override
-    public Boolean updateByParam(EmployeeFlowParam param) {
+    public EmployeeFlowVo updateByParam(EmployeeFlowParam param) {
         EmployeeFlow employeeFlow = MapstructUtils.convert(param, EmployeeFlow.class);
-        return this.updateById(employeeFlow);
+        this.updateById(employeeFlow);
+        return MapstructUtils.convert(employeeFlow, EmployeeFlowVo.class);
+    }
+
+    /**
+     * 新增或修改人事审批对象
+     *
+     * @param param 人事审批对象
+     * @return 是否新增或修改成功
+     */
+    @Override
+    public EmployeeFlowVo insertOrUpdateByParam(EmployeeFlowParam param) {
+        EmployeeFlowVo employeeFlowVo;
+        if (Convert.toLong(param.getId(), 0L) > 0) {
+            employeeFlowVo = this.updateByParam(param);
+        } else {
+            employeeFlowVo = this.insertByParam(param);
+        }
+        employeeFlowVo.setFlowCode(param.getFlowCode());
+        return employeeFlowVo;
     }
 
     @Transactional(rollbackFor = {Exception.class})
@@ -158,11 +188,11 @@ public class EmployeeFlowServImpl extends ServiceImpl<EmployeeFlowMapper, Employ
     public EmployeeFlowVo submitAndFlowStart(EmployeeFlowParam param) {
 //        long day = DateUtil.betweenDay(param.getStartDate(), param.getEndDate(), true);
         if (ObjectUtil.isNull(param.getId())) {
+            param.setId(snGen.nextId());
             param.setStatus(BusinessStatusEnum.DRAFT.getStatus());
             param.setApplyCode(System.currentTimeMillis() + StrUtil.EMPTY);
         }
         EmployeeFlow employeeFlow = MapstructUtils.convert(param, EmployeeFlow.class);
-        employeeFlow.setId(snGen.nextId());
         boolean flag = baseMapper.insertOrUpdate(employeeFlow);
         if (flag) {
             param.setId(employeeFlow.getId());
@@ -240,12 +270,17 @@ public class EmployeeFlowServImpl extends ServiceImpl<EmployeeFlowMapper, Employ
                 String businessCode = MapUtil.getStr(params, "businessCode", StrUtil.EMPTY);
                 employeeFlow.setApplyCode(businessCode);
             }
+            this.handleProcessSubmit(processEvent.getFlowCode(), employeeFlow.getEmployeeId());
         } else if (processEvent.getStatus().equals(BusinessStatusEnum.FINISH.getStatus())) {
             List<SysAuditLog> auditLogs = new ArrayList<>(6);
             if (StrUtil.isNotBlank(employeeFlow.getLogIds())) {
                 auditLogs = employeeAuditLogServ.queryAuditLogs(employeeFlow.getLogIds());
             }
             this.handleProcessFinished(processEvent.getFlowCode(), employeeFlow, auditLogs);
+        } else if (processEvent.getStatus().equals(BusinessStatusEnum.CANCEL.getStatus())
+                || processEvent.getStatus().equals(BusinessStatusEnum.TERMINATION.getStatus())
+                || processEvent.getStatus().equals(BusinessStatusEnum.INVALID.getStatus())) {
+            this.handleProcessEnd(processEvent.getFlowCode(), employeeFlow.getEmployeeId());
         }
         baseMapper.updateById(employeeFlow);
     }
@@ -282,6 +317,60 @@ public class EmployeeFlowServImpl extends ServiceImpl<EmployeeFlowMapper, Employ
         baseMapper.deleteById(employeeFlow.getId());
     }
 
+    /**
+     * 处理流程提交
+     */
+    private void handleProcessSubmit(String flowCode, Long employeeId) {
+        EmployeeInfo employeeInfo = employeeInfoMapper.selectById(employeeId);
+        switch (flowCode) {
+            case HrFlowTypeConstant.ENTRY_CODE:
+                employeeInfo.setEntryApplyStatus(HrFlowEnum.WAITING.getStatus());
+                break;
+            case HrFlowTypeConstant.TRANSFER_CODE:
+                employeeInfo.setTransferApplyStatus(HrFlowEnum.WAITING.getStatus());
+                break;
+            case HrFlowTypeConstant.RENEWAL_CONTRACT_CODE:
+                employeeInfo.setRenewalApplyStatus(HrFlowEnum.WAITING.getStatus());
+                break;
+            case HrFlowTypeConstant.REGULARIZATION_CODE:
+                employeeInfo.setRegularApplyStatus(HrFlowEnum.WAITING.getStatus());
+                break;
+            case HrFlowTypeConstant.RESIGN_CODE:
+                employeeInfo.setResignationApplyStatus(HrFlowEnum.WAITING.getStatus());
+                break;
+            default:
+                break;
+        }
+        employeeInfoMapper.updateById(employeeInfo);
+    }
+
+    /**
+     * 处理流程非正常结束
+     */
+    private void handleProcessEnd(String flowCode, Long employeeId) {
+        EmployeeInfo employeeInfo = employeeInfoMapper.selectById(employeeId);
+        switch (flowCode) {
+            case HrFlowTypeConstant.ENTRY_CODE:
+                employeeInfo.setEntryApplyStatus(HrFlowEnum.CANCEL.getStatus());
+                break;
+            case HrFlowTypeConstant.TRANSFER_CODE:
+                employeeInfo.setTransferApplyStatus(HrFlowEnum.CANCEL.getStatus());
+                break;
+            case HrFlowTypeConstant.RENEWAL_CONTRACT_CODE:
+                employeeInfo.setRenewalApplyStatus(HrFlowEnum.CANCEL.getStatus());
+                break;
+            case HrFlowTypeConstant.REGULARIZATION_CODE:
+                employeeInfo.setRegularApplyStatus(HrFlowEnum.CANCEL.getStatus());
+                break;
+            case HrFlowTypeConstant.RESIGN_CODE:
+                employeeInfo.setResignationApplyStatus(HrFlowEnum.CANCEL.getStatus());
+                break;
+            default:
+                break;
+        }
+        employeeInfoMapper.updateById(employeeInfo);
+    }
+
     /**
      * 流程结束处理
      *
@@ -415,7 +504,7 @@ public class EmployeeFlowServImpl extends ServiceImpl<EmployeeFlowMapper, Employ
                 employeeChangeLogServ.insertByEmployee(employeeFlow.getApplyCode(), oldEmployeeInfo, transferDate, EmployeeChangeLogTypeConstant.TransferOut);
                 employeeChangeLogServ.insertByEmployee(employeeFlow.getApplyCode(), employeeInfo, transferDate, EmployeeChangeLogTypeConstant.TransferIn);
                 break;
-            case HrFlowTypeConstant.RENEWAL_CONTRACT:
+            case HrFlowTypeConstant.RENEWAL_CONTRACT_CODE:
                 // 续签流程结束
                 employeeInfo.setRenewalApplyStatus(HrFlowEnum.FINISH.getStatus());
                 for (SysAuditLog auditLog : auditLogs) {

admin/src/main/java/com/anplus/hr/service/impl/EmployeeInfoServImpl.java

@@ -13,8 +13,10 @@ import com.anplus.hr.constant.HrEmployeeConstants;
 import com.anplus.hr.constant.HrFlowEnum;
 import com.anplus.hr.constant.HrFlowTypeConstant;
 import com.anplus.hr.constant.HrStatusEnum;
+import com.anplus.hr.domain.EmployeeFlow;
 import com.anplus.hr.domain.EmployeeInfo;
 import com.anplus.hr.domain.params.*;
+import com.anplus.hr.domain.vo.EmployeeFlowVo;
 import com.anplus.hr.domain.vo.EmployeeInfoImportVo;
 import com.anplus.hr.domain.vo.EmployeeInfoVo;
 import com.anplus.hr.mapper.EmployeeInfoMapper;
@@ -42,6 +44,7 @@ import top.binfast.common.core.enums.ResultCode;
 import top.binfast.common.core.exception.PlatformException;
 import top.binfast.common.core.util.LambdaUtil;
 import top.binfast.common.core.util.MapstructUtils;
+import top.binfast.common.core.util.StringUtils;
 import top.binfast.common.core.validate.AddGroup;
 import top.binfast.common.excel.core.ExcelContextHolder;
 import top.binfast.common.excel.image.CellImageData;
@@ -460,27 +463,33 @@ public class EmployeeInfoServImpl extends ServiceImpl<EmployeeInfoMapper, Employ
      */
     @Override
     @DSTransactional(rollbackFor = Exception.class)
-    public Boolean applyEntry(EmployeeEntryApplyParam param) {
-        EmployeeInfo employeeInfo = employeeInfoMapper.selectById(param.getId());
-        if (Objects.equals(employeeInfo.getEntryApplyStatus(), HrFlowEnum.WAITING.getStatus())) {
-            throw new PlatformException("当前员工正在申请入职，请勿重复申请");
+    public EmployeeFlowVo applyEntry(EmployeeEntryApplyParam param) {
+        if (Convert.toLong(param.getId(), 0L) > 0) {
+            checkAndRemoveAuditLogs(param.getId());
+        } else {
+            EmployeeInfo employeeInfo = employeeInfoMapper.selectById(param.getEmployeeId());
+            if (HrFlowEnum.isNotAbleToApply(employeeInfo.getEntryApplyStatus())) {
+                throw new PlatformException("当前员工正在申请入职，请勿重复申请");
+            }
+            employeeInfoMapper.update(null, new LambdaUpdateWrapper<EmployeeInfo>()
+                    .set(EmployeeInfo::getEntryApplyStatus, HrFlowEnum.DRAFT.getStatus())
+                    .eq(EmployeeInfo::getId, param.getEmployeeId()));
         }
-        employeeInfoMapper.update(null, new LambdaUpdateWrapper<EmployeeInfo>()
-                .set(EmployeeInfo::getEntryApplyStatus, HrFlowEnum.WAITING.getStatus())
-                .eq(EmployeeInfo::getId, param.getId()));
         List<SysAuditLog> list = new ArrayList<>(6);
         employeeAuditLogServ.initAuditLog("入职申请", "entryDate",
                 "入职时间", LocalDateTimeUtil.format(param.getEntryDate(), DatePattern.NORM_DATE_PATTERN), list);
         employeeAuditLogServ.saveAuditLogs(list);
         String logIds = LambdaUtil.join(list, (item) -> item.getId() + StrUtil.EMPTY, StrUtil.COMMA);
         EmployeeFlowParam flowParam = new EmployeeFlowParam();
+        flowParam.setId(param.getId());
         flowParam.setFlowCode(HrFlowTypeConstant.ENTRY_CODE);
         flowParam.setFlowType(HrFlowTypeConstant.ENTRY);
-        flowParam.setEmployeeId(param.getId());
+        flowParam.setEmployeeId(param.getEmployeeId());
         flowParam.setRemark(param.getRemark());
         flowParam.setLogIds(logIds);
-        employeeFlowServ.submitAndFlowStart(flowParam);
-        return true;
+        return employeeFlowServ.insertOrUpdateByParam(flowParam);
+//        employeeFlowServ.submitAndFlowStart(flowParam);
+//        return true;
     }
 
     /**
@@ -491,14 +500,18 @@ public class EmployeeInfoServImpl extends ServiceImpl<EmployeeInfoMapper, Employ
      */
     @Override
     @DSTransactional(rollbackFor = Exception.class)
-    public Boolean applyTransfer(EmployeeTransferApplyParam param) {
-        EmployeeInfo employeeInfo = employeeInfoMapper.selectById(param.getId());
-        if (Objects.equals(employeeInfo.getTransferApplyStatus(), HrFlowEnum.WAITING.getStatus())) {
-            throw new PlatformException("当前员工正在申请调配，请勿重复申请");
+    public EmployeeFlowVo applyTransfer(EmployeeTransferApplyParam param) {
+        if (Convert.toLong(param.getId(), 0L) > 0) {
+            checkAndRemoveAuditLogs(param.getId());
+        } else {
+            EmployeeInfo employeeInfo = employeeInfoMapper.selectById(param.getEmployeeId());
+            if (HrFlowEnum.isNotAbleToApply(employeeInfo.getTransferApplyStatus())) {
+                throw new PlatformException("当前员工正在申请调配，请勿重复申请");
+            }
+            employeeInfoMapper.update(null, new LambdaUpdateWrapper<EmployeeInfo>()
+                    .set(EmployeeInfo::getTransferApplyStatus, HrFlowEnum.DRAFT.getStatus())
+                    .eq(EmployeeInfo::getId, param.getEmployeeId()));
         }
-        employeeInfoMapper.update(null, new LambdaUpdateWrapper<EmployeeInfo>()
-                .set(EmployeeInfo::getTransferApplyStatus, HrFlowEnum.WAITING.getStatus())
-                .eq(EmployeeInfo::getId, param.getId()));
         List<SysAuditLog> list = new ArrayList<>(6);
         employeeAuditLogServ.initAuditLog("调职申请", "plate",
                 "板块", param.getPlate(), list);
@@ -516,13 +529,15 @@ public class EmployeeInfoServImpl extends ServiceImpl<EmployeeInfoMapper, Employ
         employeeAuditLogServ.saveAuditLogs(list);
         String logIds = LambdaUtil.join(list, (item) -> item.getId() + StrUtil.EMPTY, StrUtil.COMMA);
         EmployeeFlowParam flowParam = new EmployeeFlowParam();
+        flowParam.setId(param.getId());
         flowParam.setFlowCode(HrFlowTypeConstant.TRANSFER_CODE);
         flowParam.setFlowType(HrFlowTypeConstant.TRANSFER);
-        flowParam.setEmployeeId(param.getId());
+        flowParam.setEmployeeId(param.getEmployeeId());
         flowParam.setRemark(param.getRemark());
         flowParam.setLogIds(logIds);
-        employeeFlowServ.submitAndFlowStart(flowParam);
-        return true;
+        return employeeFlowServ.insertOrUpdateByParam(flowParam);
+//        employeeFlowServ.submitAndFlowStart(flowParam);
+//        return true;
     }
 
     /**
@@ -533,14 +548,18 @@ public class EmployeeInfoServImpl extends ServiceImpl<EmployeeInfoMapper, Employ
      */
     @Override
     @DSTransactional(rollbackFor = Exception.class)
-    public Boolean applyResign(EmployeeResignApplyParam param) {
-        EmployeeInfo employeeInfo = employeeInfoMapper.selectById(param.getId());
-        if (Objects.equals(employeeInfo.getResignationApplyStatus(), HrFlowEnum.WAITING.getStatus())) {
-            throw new PlatformException("当前员工正在申请离职，请勿重复申请");
+    public EmployeeFlowVo applyResign(EmployeeResignApplyParam param) {
+        if (Convert.toLong(param.getId(), 0L) > 0) {
+            checkAndRemoveAuditLogs(param.getId());
+        } else {
+            EmployeeInfo employeeInfo = employeeInfoMapper.selectById(param.getEmployeeId());
+            if (HrFlowEnum.isNotAbleToApply(employeeInfo.getResignationApplyStatus())) {
+                throw new PlatformException("当前员工正在申请离职，请勿重复申请");
+            }
+            employeeInfoMapper.update(null, new LambdaUpdateWrapper<EmployeeInfo>()
+                    .set(EmployeeInfo::getResignationApplyStatus, HrFlowEnum.DRAFT.getStatus())
+                    .eq(EmployeeInfo::getId, param.getEmployeeId()));
         }
-        employeeInfoMapper.update(null, new LambdaUpdateWrapper<EmployeeInfo>()
-                .set(EmployeeInfo::getResignationApplyStatus, HrFlowEnum.WAITING.getStatus())
-                .eq(EmployeeInfo::getId, param.getId()));
         List<SysAuditLog> list = new ArrayList<>(6);
         employeeAuditLogServ.initAuditLog("离职申请", "resignationType",
                 "离职类型", param.getResignationType(), list);
@@ -558,13 +577,15 @@ public class EmployeeInfoServImpl extends ServiceImpl<EmployeeInfoMapper, Employ
         employeeAuditLogServ.saveAuditLogs(list);
         String logIds = LambdaUtil.join(list, (item) -> item.getId() + StrUtil.EMPTY, StrUtil.COMMA);
         EmployeeFlowParam flowParam = new EmployeeFlowParam();
+        flowParam.setId(param.getId());
         flowParam.setFlowCode(HrFlowTypeConstant.RESIGN_CODE);
         flowParam.setFlowType(HrFlowTypeConstant.RESIGN);
-        flowParam.setEmployeeId(param.getId());
+        flowParam.setEmployeeId(param.getEmployeeId());
         flowParam.setRemark(param.getRemark());
         flowParam.setLogIds(logIds);
-        employeeFlowServ.submitAndFlowStart(flowParam);
-        return true;
+        return employeeFlowServ.insertOrUpdateByParam(flowParam);
+//        employeeFlowServ.submitAndFlowStart(flowParam);
+//        return true;
     }
 
     /**
@@ -575,14 +596,18 @@ public class EmployeeInfoServImpl extends ServiceImpl<EmployeeInfoMapper, Employ
      */
     @Override
     @DSTransactional(rollbackFor = Exception.class)
-    public Boolean applyRegular(EmployeeRegularApplyParam param) {
-        EmployeeInfo employeeInfo = employeeInfoMapper.selectById(param.getId());
-        if (Objects.equals(employeeInfo.getRegularApplyStatus(), HrFlowEnum.WAITING.getStatus())) {
-            throw new PlatformException("当前员工正在申请转正，请勿重复申请");
+    public EmployeeFlowVo applyRegular(EmployeeRegularApplyParam param) {
+        if (Convert.toLong(param.getId(), 0L) > 0) {
+            checkAndRemoveAuditLogs(param.getId());
+        } else {
+            EmployeeInfo employeeInfo = employeeInfoMapper.selectById(param.getEmployeeId());
+            if (HrFlowEnum.isNotAbleToApply(employeeInfo.getRegularApplyStatus())) {
+                throw new PlatformException("当前员工正在申请转正，请勿重复申请");
+            }
+            employeeInfoMapper.update(null, new LambdaUpdateWrapper<EmployeeInfo>()
+                    .set(EmployeeInfo::getRegularApplyStatus, HrFlowEnum.DRAFT.getStatus())
+                    .eq(EmployeeInfo::getId, param.getEmployeeId()));
         }
-        employeeInfoMapper.update(null, new LambdaUpdateWrapper<EmployeeInfo>()
-                .set(EmployeeInfo::getRegularApplyStatus, HrFlowEnum.WAITING.getStatus())
-                .eq(EmployeeInfo::getId, param.getId()));
         List<SysAuditLog> list = new ArrayList<>(6);
         String contractStartDateStr = LocalDateTimeUtil.format(param.getContractStartDate(), DatePattern.NORM_DATE_PATTERN);
         String contractEndDateStr = LocalDateTimeUtil.format(param.getContractEndDate(), DatePattern.NORM_DATE_PATTERN);
@@ -621,13 +646,15 @@ public class EmployeeInfoServImpl extends ServiceImpl<EmployeeInfoMapper, Employ
         employeeAuditLogServ.saveAuditLogs(list);
         String logIds = LambdaUtil.join(list, (item) -> item.getId() + StrUtil.EMPTY, StrUtil.COMMA);
         EmployeeFlowParam flowParam = new EmployeeFlowParam();
+        flowParam.setId(param.getId());
         flowParam.setFlowCode(HrFlowTypeConstant.REGULARIZATION_CODE);
         flowParam.setFlowType(HrFlowTypeConstant.REGULARIZATION);
-        flowParam.setEmployeeId(param.getId());
+        flowParam.setEmployeeId(param.getEmployeeId());
         flowParam.setRemark(param.getRemark());
         flowParam.setLogIds(logIds);
-        employeeFlowServ.submitAndFlowStart(flowParam);
-        return true;
+        return employeeFlowServ.insertOrUpdateByParam(flowParam);
+//        employeeFlowServ.submitAndFlowStart(flowParam);
+//        return true;
     }
 
     /**
@@ -638,14 +665,18 @@ public class EmployeeInfoServImpl extends ServiceImpl<EmployeeInfoMapper, Employ
      */
     @Override
     @DSTransactional(rollbackFor = Exception.class)
-    public Boolean applyRenewalContract(EmployeeRenewalContractApplyParam param) {
-        EmployeeInfo employeeInfo = employeeInfoMapper.selectById(param.getId());
-        if (Objects.equals(employeeInfo.getRenewalApplyStatus(), HrFlowEnum.WAITING.getStatus())) {
-            throw new PlatformException("当前员工正在申请合同续约，请勿重复申请");
+    public EmployeeFlowVo applyRenewalContract(EmployeeRenewalContractApplyParam param) {
+        if (Convert.toLong(param.getId(), 0L) > 0) {
+            checkAndRemoveAuditLogs(param.getId());
+        } else {
+            EmployeeInfo employeeInfo = employeeInfoMapper.selectById(param.getEmployeeId());
+            if (HrFlowEnum.isNotAbleToApply(employeeInfo.getRenewalApplyStatus())) {
+                throw new PlatformException("当前员工正在申请合同续约，请勿重复申请");
+            }
+            employeeInfoMapper.update(null, new LambdaUpdateWrapper<EmployeeInfo>()
+                    .set(EmployeeInfo::getRenewalApplyStatus, HrFlowEnum.DRAFT.getStatus())
+                    .eq(EmployeeInfo::getId, param.getEmployeeId()));
         }
-        employeeInfoMapper.update(null, new LambdaUpdateWrapper<EmployeeInfo>()
-                .set(EmployeeInfo::getRenewalApplyStatus, HrFlowEnum.WAITING.getStatus())
-                .eq(EmployeeInfo::getId, param.getId()));
         List<SysAuditLog> list = new ArrayList<>(6);
         String contractStartDateStr = LocalDateTimeUtil.format(param.getContractStartDate(), DatePattern.NORM_DATE_PATTERN);
         String contractEndDateStr = LocalDateTimeUtil.format(param.getContractEndDate(), DatePattern.NORM_DATE_PATTERN);
@@ -668,13 +699,29 @@ public class EmployeeInfoServImpl extends ServiceImpl<EmployeeInfoMapper, Employ
         employeeAuditLogServ.saveAuditLogs(list);
         String logIds = LambdaUtil.join(list, (item) -> item.getId() + StrUtil.EMPTY, StrUtil.COMMA);
         EmployeeFlowParam flowParam = new EmployeeFlowParam();
+        flowParam.setId(param.getId());
         flowParam.setFlowCode(HrFlowTypeConstant.RENEWAL_CONTRACT_CODE);
         flowParam.setFlowType(HrFlowTypeConstant.RENEWAL_CONTRACT);
-        flowParam.setEmployeeId(param.getId());
+        flowParam.setEmployeeId(param.getEmployeeId());
         flowParam.setRemark(param.getRemark());
         flowParam.setLogIds(logIds);
-        employeeFlowServ.submitAndFlowStart(flowParam);
-        return true;
+        return employeeFlowServ.insertOrUpdateByParam(flowParam);
+//        employeeFlowServ.submitAndFlowStart(flowParam);
+//        return true;
+    }
+
+    /**
+     * 删除原有审核信息
+     *
+     * @param flowId 主键
+     * @return 是否删除成功
+     */
+    private void checkAndRemoveAuditLogs(Long flowId) {
+        EmployeeFlow employeeFlow = employeeFlowServ.getById(flowId);
+        if (StrUtil.isNotBlank(employeeFlow.getLogIds())) {
+            List<Long> logIds = StringUtils.splitTo(employeeFlow.getLogIds(), Convert::toLong);
+            employeeAuditLogServ.removeAuditLogs(logIds);
+        }
     }
 
     /**