mom-pro2-after.git

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

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

			private static final String PROCESS_DEFINITION_KEY = "misc_receipt_approve";

			@Resource
			private MesWmMiscReceiptService miscReceiptService;

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

			@Override
			protected void onEvent(BpmProcessInstanceStatusEvent event) {
			Long receiptId;
			try {
			receiptId = Long.parseLong(event.getBusinessKey());
			} catch (NumberFormatException e) {
			log.warn("[onEvent] businessKey({}) ä¸æ¯ææçæé¡¹å¥åºåç¼å·", event.getBusinessKey());
			return;
			}
			log.info("[onEvent] æ¶å°æé¡¹å¥åºåå®¡æ¹äºä»¶ï¼receiptId={}, status={}", receiptId, event.getStatus());
			try {
			miscReceiptService.updateMiscReceiptAuditStatus(receiptId, event.getStatus(), event.getReason());
			} catch (Exception e) {
			log.error("[onEvent] ååæé¡¹å¥åºåå®¡æ¹ç¶æå¤±è´¥ï¼receiptId={}", receiptId, e);
			}
			}

			}