package cn.iocoder.yudao.module.mes.service.pro.feedback.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.pro.feedback.MesProFeedbackService;
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.util.StrUtil;
|
import cn.iocoder.yudao.module.bpm.framework.flowable.core.enums.BpmnVariableConstants;
|
import cn.iocoder.yudao.module.bpm.service.task.BpmTaskService;
|
import org.flowable.task.api.history.HistoricTaskInstance;
|
import jakarta.annotation.Resource;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Comparator;
|
import java.util.List;
|
|
/**
|
* 生产报工审批状态监听器
|
*
|
* 监听 BPM 流程实例状态变更事件，更新生产报工的审批状态
|
*
|
* @author 超级管理员
|
*/
|
@Component
|
@Slf4j
|
public class MesProFeedbackStatusListener extends BpmProcessInstanceStatusEventListener {
|
|
/**
|
* BPM 生产报工审批流程定义 key
|
*/
|
private static final String BPM_PROCESS_DEFINITION_KEY = "mes-pro-feedback-audit";
|
|
@Resource
|
private MesProFeedbackService feedbackService;
|
|
@Resource
|
private BpmTaskService bpmTaskService;
|
|
@Override
|
protected String getProcessDefinitionKey() {
|
return BPM_PROCESS_DEFINITION_KEY;
|
}
|
|
@Override
|
protected void onEvent(BpmProcessInstanceStatusEvent event) {
|
Long feedbackId;
|
try {
|
feedbackId = Long.parseLong(event.getBusinessKey());
|
} catch (NumberFormatException e) {
|
log.warn("[onEvent] businessKey({}) 不是有效的生产报工编号", event.getBusinessKey());
|
return;
|
}
|
String reason = event.getReason();
|
if (StrUtil.isEmpty(reason) && event.getId() != null) {
|
// 当 event.getReason() 为空时，尝试从最后一个完成的任务中获取审批意见
|
List<HistoricTaskInstance> tasks = bpmTaskService.getTaskListByProcessInstanceId(event.getId(), false);
|
if (CollUtil.isNotEmpty(tasks)) {
|
HistoricTaskInstance lastTask = tasks.stream()
|
.filter(task -> task.getEndTime() != null)
|
.max(Comparator.comparing(HistoricTaskInstance::getEndTime))
|
.orElse(null);
|
if (lastTask != null && lastTask.getTaskLocalVariables() != null) {
|
reason = (String) lastTask.getTaskLocalVariables().get(BpmnVariableConstants.TASK_VARIABLE_REASON);
|
}
|
}
|
}
|
|
log.info("[onEvent] 收到BPM审批事件，feedbackId={}, status={},Reason={}", feedbackId, event.getStatus(), reason);
|
|
feedbackService.handleBpmProcessResult(feedbackId, event.getStatus(), reason);
|
}
|
|
}
|
