| | |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | /** |
| | | * 设计项目审批状态监听器 |
| | | * MES 设计项目审批状态监听器 |
| | | * |
| | | * 监听 BPM 流程实例状态变更事件,更新设计项目的审批状态 |
| | | * |
| | | * @author 超级管理员 |
| | | * 监听 BPM 审批结果,回写设计项目状态,使审批统一在「协同办公 - 我的流程」中流转。 |
| | | */ |
| | | @Component |
| | | @Slf4j |
| | | public class MesPdProjectStatusListener extends BpmProcessInstanceStatusEventListener { |
| | | |
| | | /** |
| | | * BPM 设计项目审批流程定义 key |
| | | */ |
| | | private static final String BPM_PROCESS_DEFINITION_KEY = "mes-pd-project-audit"; |
| | | private static final String PROCESS_DEFINITION_KEY = "mes-pd-project-audit"; |
| | | |
| | | @Resource |
| | | private MesPdProjectService projectService; |
| | | |
| | | @Override |
| | | protected String getProcessDefinitionKey() { |
| | | return BPM_PROCESS_DEFINITION_KEY; |
| | | return PROCESS_DEFINITION_KEY; |
| | | } |
| | | |
| | | @Override |
| | |
| | | log.warn("[onEvent] businessKey({}) 不是有效的设计项目编号", event.getBusinessKey()); |
| | | return; |
| | | } |
| | | log.info("[onEvent] 收到BPM审批事件,projectId={}, status={}", projectId, event.getStatus()); |
| | | projectService.updateProjectAuditStatus(projectId, event.getStatus()); |
| | | log.info("[onEvent] 收到设计项目审批事件,projectId={}, status={}", projectId, event.getStatus()); |
| | | try { |
| | | projectService.updateProjectAuditStatus(projectId, event.getStatus(), event.getReason()); |
| | | } catch (Exception e) { |
| | | log.error("[onEvent] 回写设计项目审批状态失败,projectId={}", projectId, e); |
| | | } |
| | | } |
| | | |
| | | } |