mom-pro2-after.git

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

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

			/**
			* éè´è®¢åå®¡æ¹ç¶æçå¬å¨
			*
			* çå¬ BPM æµç¨å®ä¾ç¶æåæ´äºä»¶ï¼æ´æ°éè´è®¢åçå®¡æ¹ç¶æï¼åååå¬å®¡æ¹åååï¼
			*
			* @author è¶çº§ç®¡çå
			*/
			@Component
			@Slf4j
			public class ErpPurchaseOrderStatusListener extends BpmProcessInstanceStatusEventListener {

			/**
			* éè´è®¢åå®¡æ¹æµç¨å®ä¹ Key
			*/
			private static final String PROCESS_DEFINITION_KEY = "purchase_order_approve";

			@Resource
			private ErpPurchaseOrderService purchaseOrderService;

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

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

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

			try {
			purchaseOrderService.updatePurchaseOrderAuditStatus(orderId, event.getStatus());
			log.info("[onEvent] éè´è®¢å({}) å®¡æ¹ç¶ææ´æ°å®æ", orderId);
			} catch (Exception e) {
			log.error("[onEvent] æ´æ°éè´è®¢åå®¡æ¹ç¶æå¤±è´¥ï¼orderId={}", orderId, e);
			}
			}

			}