| ¶Ô±ÈÐÂÎļþ |
| | |
| | | package cn.iocoder.yudao.module.mes.service.wm.miscissue.listener; |
| | | |
| | | import cn.iocoder.yudao.module.bpm.api.event.BpmProcessInstanceStatusEvent; |
| | | import cn.iocoder.yudao.module.bpm.api.event.BpmProcessInstanceStatusEventListener; |
| | | import cn.iocoder.yudao.module.mes.service.wm.miscissue.MesWmMiscIssueService; |
| | | import jakarta.annotation.Resource; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | /** |
| | | * MES æé¡¹åºåºå审æ¹ç¶æçå¬å¨ |
| | | * |
| | | * çå¬ BPM 审æ¹ç»æï¼ååæé¡¹åºåºåç¶æï¼ä½¿å®¡æ¹ç»ä¸å¨ãåååå
¬ - æçæµç¨ã䏿µè½¬ã |
| | | */ |
| | | @Component |
| | | @Slf4j |
| | | public class MesWmMiscIssueStatusListener extends BpmProcessInstanceStatusEventListener { |
| | | |
| | | private static final String PROCESS_DEFINITION_KEY = "misc_issue_approve"; |
| | | |
| | | @Resource |
| | | private MesWmMiscIssueService miscIssueService; |
| | | |
| | | @Override |
| | | protected String getProcessDefinitionKey() { |
| | | return PROCESS_DEFINITION_KEY; |
| | | } |
| | | |
| | | @Override |
| | | protected void onEvent(BpmProcessInstanceStatusEvent event) { |
| | | Long issueId; |
| | | try { |
| | | issueId = Long.parseLong(event.getBusinessKey()); |
| | | } catch (NumberFormatException e) { |
| | | log.warn("[onEvent] businessKey({}) 䏿¯ææçæé¡¹åºåºåç¼å·", event.getBusinessKey()); |
| | | return; |
| | | } |
| | | log.info("[onEvent] æ¶å°æé¡¹åºåºå审æ¹äºä»¶ï¼issueId={}, status={}", issueId, event.getStatus()); |
| | | try { |
| | | miscIssueService.updateMiscIssueAuditStatus(issueId, event.getStatus(), event.getReason()); |
| | | } catch (Exception e) { |
| | | log.error("[onEvent] ååæé¡¹åºåºå审æ¹ç¶æå¤±è´¥ï¼issueId={}", issueId, e); |
| | | } |
| | | } |
| | | |
| | | } |