| | |
| | | import cn.iocoder.yudao.framework.common.exception.ServiceException; |
| | | 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.crm.api.customer.CrmCustomerApi; |
| | | import cn.iocoder.yudao.module.crm.api.customer.dto.CrmCustomerRespDTO; |
| | | import cn.iocoder.yudao.module.mes.controller.admin.pd.techconfirm.vo.ProductTechConfirmImportExcelVO; |
| | |
| | | */ |
| | | private static final String TECH_CONFIRM_APPROVE_BIZ_TYPE = "pd_tech_confirm_approve"; |
| | | |
| | | /** |
| | | * 技术确认函审批的 BPM 流程定义 Key |
| | | */ |
| | | private static final String TECH_CONFIRM_APPROVE_PROCESS_KEY = "pd_tech_confirm_approve"; |
| | | |
| | | @Resource |
| | | private ProductTechConfirmMapper techConfirmMapper; |
| | | |
| | | @Resource |
| | | private BpmProcessInstanceApi bpmProcessInstanceApi; |
| | | |
| | | @Resource |
| | | private AdminUserApi adminUserApi; |
| | |
| | | // 用 UpdateWrapper 而非 updateById:MyBatis-Plus 默认更新策略会忽略 null, |
| | | // 直接 updateById 无法把审核不通过后残留的审核人 / 审核时间 / 审核意见真正清空。 |
| | | techConfirmMapper.submitAndResetAuditInfo(id, MesPdTechConfirmStatusEnum.PENDING_AUDIT.getStatus()); |
| | | // 4. 创建 BPM 流程实例,使审批出现在「协同办公 - 我的流程」 |
| | | bpmProcessInstanceApi.createProcessInstance(getLoginUserId(), |
| | | new BpmProcessInstanceCreateReqDTO() |
| | | .setProcessDefinitionKey(TECH_CONFIRM_APPROVE_PROCESS_KEY) |
| | | .setBusinessKey(String.valueOf(id))); |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void updateTechConfirmAuditStatus(Long id, Integer bpmStatus, String reason) { |
| | | // BPM 审批结果映射为确认函状态:通过=已审核 / 不通过=审核不通过(可修改后重新提交) |
| | | Integer status; |
| | | if (BpmTaskStatusEnum.APPROVE.getStatus().equals(bpmStatus)) { |
| | | status = MesPdTechConfirmStatusEnum.AUDITED.getStatus(); |
| | | } else if (BpmTaskStatusEnum.REJECT.getStatus().equals(bpmStatus)) { |
| | | status = MesPdTechConfirmStatusEnum.REJECTED.getStatus(); |
| | | } else { |
| | | // 技术确认函没有「已取消」状态,其余 BPM 结果(如撤消)忽略 |
| | | log.warn("[updateTechConfirmAuditStatus] 忽略不支持的 BPM 状态({}),techConfirmId={}", bpmStatus, id); |
| | | return; |
| | | } |
| | | if (techConfirmMapper.updateAuditStatusByBpm(id, status, reason) != 1) { |
| | | log.warn("[updateTechConfirmAuditStatus] 技术确认函({}) 不处于待审核状态,忽略 BPM 结果({})", id, bpmStatus); |
| | | } |
| | | } |
| | | |
| | | @Override |