mom-pro2-after.git

¶Ô±ÈÐÂÎÄ¼þ
			@@ -0,0 +1,51 @@
			package cn.iocoder.yudao.module.erp.service.purchase.listener;

			import cn.iocoder.yudao.module.bpm.api.event.BpmProcessInstanceStatusEvent;
			import cn.iocoder.yudao.module.erp.service.purchase.ErpPurchaseRequestService;
			import jakarta.annotation.Resource;
			import lombok.extern.slf4j.Slf4j;
			import org.springframework.stereotype.Component;

			/**
			* éè´ç³è¯·å®¡æ¹ç¶æçå¬å¨
			*
			* çå¬ BPM æµç¨å®ä¾ç¶æåæ´äºä»¶ï¼æ´æ°éè´ç³è¯·çå®¡æ¹ç¶æ
			*/
			@Component
			@Slf4j
			public class ErpPurchaseRequestStatusListener extends cn.iocoder.yudao.module.bpm.api.event.BpmProcessInstanceStatusEventListener {

			/**
			* éè´ç³è¯·å®¡æ¹æµç¨å®ä¹ Key
			*/
			private static final String PROCESS_DEFINITION_KEY = "purchase_request_approve";

			@Resource
			private ErpPurchaseRequestService purchaseRequestService;

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

			@Override
			protected void onEvent(BpmProcessInstanceStatusEvent event) {
			Long requestId;
			try {
			requestId = Long.parseLong(event.getBusinessKey());
			} catch (NumberFormatException e) {
			log.warn("[onEvent] businessKey({}) ä¸æ¯ææçéè´ç³è¯·ç¼å·", event.getBusinessKey());
			return;
			}

			log.info("[onEvent] æ¶å°BPMå®¡æ¹äºä»¶ï¼requestId={}, status={}", requestId, event.getStatus());

			try {
			purchaseRequestService.updatePurchaseRequestAuditStatus(requestId, event.getStatus());
			log.info("[onEvent] éè´ç³è¯·({}) å®¡æ¹ç¶ææ´æ°å®æ", requestId);
			} catch (Exception e) {
			log.error("[onEvent] æ´æ°éè´ç³è¯·å®¡æ¹ç¶æå¤±è´¥ï¼requestId={}", requestId, e);
			}
			}

			}