package cn.iocoder.yudao.module.mes.service.pro.mps.listener;
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.util.StrUtil;
|
import cn.iocoder.yudao.module.bpm.api.event.BpmProcessInstanceStatusEvent;
|
import cn.iocoder.yudao.module.bpm.api.event.BpmProcessInstanceStatusEventListener;
|
import cn.iocoder.yudao.module.bpm.framework.flowable.core.enums.BpmnVariableConstants;
|
import cn.iocoder.yudao.module.bpm.service.task.BpmTaskService;
|
import cn.iocoder.yudao.module.mes.service.pro.mps.MesProMpsService;
|
import jakarta.annotation.Resource;
|
import lombok.extern.slf4j.Slf4j;
|
import org.flowable.task.api.history.HistoricTaskInstance;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Comparator;
|
import java.util.List;
|
|
/**
|
* 生产主计划（MPS）审批状态监听器
|
*
|
* 监听 BPM 流程实例状态变更事件，把协同办公的审批结果回写到 MPS 状态
|
*
|
* @author 超级管理员
|
*/
|
@Component
|
@Slf4j
|
public class MesProMpsStatusListener extends BpmProcessInstanceStatusEventListener {
|
|
/**
|
* MPS 审批流程定义 Key
|
*/
|
private static final String BPM_PROCESS_DEFINITION_KEY = "mes-pro-mps-audit";
|
|
@Resource
|
private MesProMpsService mpsService;
|
|
@Resource
|
private BpmTaskService bpmTaskService;
|
|
@Override
|
protected String getProcessDefinitionKey() {
|
return BPM_PROCESS_DEFINITION_KEY;
|
}
|
|
@Override
|
protected void onEvent(BpmProcessInstanceStatusEvent event) {
|
Long mpsId;
|
try {
|
mpsId = Long.parseLong(event.getBusinessKey());
|
} catch (NumberFormatException e) {
|
log.warn("[onEvent] businessKey({}) 不是有效的生产计划编号", event.getBusinessKey());
|
return;
|
}
|
String reason = event.getReason();
|
Long auditUserId = null;
|
if (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)
|
// 排除多实例或签满足条件后，被系统自动取消的兄弟任务（deleteReason 非空）
|
.filter(task -> task.getDeleteReason() == null)
|
.max(Comparator.comparing(HistoricTaskInstance::getEndTime))
|
.orElse(null);
|
if (lastTask != null) {
|
if (StrUtil.isEmpty(reason) && lastTask.getTaskLocalVariables() != null) {
|
reason = (String) lastTask.getTaskLocalVariables().get(BpmnVariableConstants.TASK_VARIABLE_REASON);
|
}
|
if (StrUtil.isNotEmpty(lastTask.getAssignee())) {
|
try {
|
auditUserId = Long.parseLong(lastTask.getAssignee());
|
} catch (NumberFormatException ignored) {
|
log.warn("[onEvent] 审批人({}) 不是有效的用户编号", lastTask.getAssignee());
|
}
|
}
|
}
|
}
|
}
|
|
log.info("[onEvent] 收到BPM审批事件，mpsId={}, status={}, reason={}, auditUserId={}",
|
mpsId, event.getStatus(), reason, auditUserId);
|
mpsService.handleBpmProcessResult(mpsId, event.getStatus(), reason, auditUserId);
|
}
|
|
}
|
