| | |
| | | import cn.hutool.core.util.StrUtil; |
| | | import cn.iocoder.yudao.framework.common.pojo.PageResult; |
| | | import cn.iocoder.yudao.framework.common.util.object.BeanUtils; |
| | | import cn.iocoder.yudao.module.bpm.api.task.BpmProcessInstanceApi; |
| | | import cn.iocoder.yudao.module.bpm.api.task.dto.BpmProcessInstanceCreateReqDTO; |
| | | import cn.iocoder.yudao.module.bpm.enums.task.BpmTaskStatusEnum; |
| | | import cn.iocoder.yudao.module.mes.controller.admin.wm.miscreceipt.vo.MesWmMiscReceiptImportExcelVO; |
| | | import cn.iocoder.yudao.module.mes.controller.admin.wm.miscreceipt.vo.MesWmMiscReceiptImportRespVO; |
| | | import cn.iocoder.yudao.module.mes.controller.admin.wm.miscreceipt.vo.MesWmMiscReceiptPageReqVO; |
| | |
| | | */ |
| | | private static final String MISC_RECEIPT_APPROVE_BIZ_TYPE = "misc_receipt_approve"; |
| | | |
| | | /** |
| | | * 杂项入库单审批的 BPM 流程定义 Key |
| | | */ |
| | | private static final String MISC_RECEIPT_APPROVE_PROCESS_KEY = "misc_receipt_approve"; |
| | | |
| | | @Resource |
| | | private MesWmMiscReceiptMapper miscReceiptMapper; |
| | | |
| | | @Resource |
| | | private BpmProcessInstanceApi bpmProcessInstanceApi; |
| | | |
| | | @Resource |
| | | @Lazy |
| | |
| | | approvalConfigApi.validateApprovalEnabledAndGetApprovers(MISC_RECEIPT_APPROVE_BIZ_TYPE); |
| | | // 4. 提交审批(草稿 → 审批中),并清空上一轮审核结果 |
| | | miscReceiptMapper.submitAndResetAuditInfo(id, MesWmMiscReceiptStatusEnum.APPROVING.getStatus()); |
| | | // 5. 创建 BPM 流程实例,使审批出现在「协同办公 - 我的流程」 |
| | | bpmProcessInstanceApi.createProcessInstance(getLoginUserId(), |
| | | new BpmProcessInstanceCreateReqDTO() |
| | | .setProcessDefinitionKey(MISC_RECEIPT_APPROVE_PROCESS_KEY) |
| | | .setBusinessKey(String.valueOf(id))); |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void updateMiscReceiptAuditStatus(Long id, Integer bpmStatus, String reason) { |
| | | // BPM 审批结果映射为单据状态:通过=已审批 / 不通过=草稿 / 取消=已取消 |
| | | Integer status; |
| | | if (BpmTaskStatusEnum.APPROVE.getStatus().equals(bpmStatus)) { |
| | | status = MesWmMiscReceiptStatusEnum.APPROVED.getStatus(); |
| | | } else if (BpmTaskStatusEnum.REJECT.getStatus().equals(bpmStatus)) { |
| | | status = MesWmMiscReceiptStatusEnum.PREPARE.getStatus(); |
| | | } else if (BpmTaskStatusEnum.CANCEL.getStatus().equals(bpmStatus)) { |
| | | status = MesWmMiscReceiptStatusEnum.CANCELED.getStatus(); |
| | | } else { |
| | | return; |
| | | } |
| | | if (miscReceiptMapper.updateAuditStatusByBpm(id, status, reason) != 1) { |
| | | log.warn("[updateMiscReceiptAuditStatus] 杂项入库单({}) 不处于审批中状态,忽略 BPM 结果({})", id, bpmStatus); |
| | | } |
| | | } |
| | | |
| | | @Override |