mom-pro2-after.git

¶Ô±ÈÐÂÎÄ¼þ
			@@ -0,0 +1,46 @@
			package cn.iocoder.yudao.module.mes.service.pd.project.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.pd.project.MesPdProjectService;
			import jakarta.annotation.Resource;
			import lombok.extern.slf4j.Slf4j;
			import org.springframework.stereotype.Component;

			/**
			* MES è®¾è®¡é¡¹ç®å®¡æ¹ç¶æçå¬å¨
			*
			* çå¬ BPM å®¡æ¹ç»æï¼ååè®¾è®¡é¡¹ç®ç¶æï¼ä½¿å®¡æ¹ç»ä¸å¨ãåååå¬ - æçæµç¨ãä¸æµè½¬ã
			*/
			@Component
			@Slf4j
			public class MesPdProjectStatusListener extends BpmProcessInstanceStatusEventListener {

			private static final String PROCESS_DEFINITION_KEY = "mes-pd-project-audit";

			@Resource
			private MesPdProjectService projectService;

			@Override
			protected String getProcessDefinitionKey() {
			return PROCESS_DEFINITION_KEY;
			}

			@Override
			protected void onEvent(BpmProcessInstanceStatusEvent event) {
			Long projectId;
			try {
			projectId = Long.parseLong(event.getBusinessKey());
			} catch (NumberFormatException e) {
			log.warn("[onEvent] businessKey({}) ä¸æ¯ææçè®¾è®¡é¡¹ç®ç¼å·", event.getBusinessKey());
			return;
			}
			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);
			}
			}

			}