update - REQ-2324-修复批量驳回待办未恢复问题

This commit is contained in:
yangqicheng 2024-05-28 11:20:08 +08:00
parent 43e5e1219f
commit 2db59cc660

View File

@ -6,6 +6,7 @@ import cn.axzo.workflow.core.common.utils.BpmnMetaParserHelper;
import cn.axzo.workflow.core.engine.event.MessagePushEvent;
import cn.axzo.workflow.core.engine.event.MessagePushEventBuilder;
import cn.axzo.workflow.core.engine.job.AsyncApproveTaskJobHandler;
import cn.axzo.workflow.core.engine.job.AsyncRejectTaskJobHandler;
import cn.axzo.workflow.core.listener.BpmnAsyncJobEventListener;
import cn.hutool.json.JSONUtil;
import lombok.extern.slf4j.Slf4j;
@ -45,6 +46,10 @@ public class ApproveErrorReporterEventListener implements BpmnAsyncJobEventListe
TASK_COMPLETE_FAIL_NOT_EXISTS.getRespCode(),
TASK_COMPLETE_FAIL_ASSIGN_NOT_SELF.getRespCode());
private final List<String> RESOLVE_HANDLER_TYPES = Arrays.asList(
AsyncApproveTaskJobHandler.TYPE,
AsyncRejectTaskJobHandler.TYPE);
@Override
public boolean support(FlowableEngineEventType eventType) {
return Objects.equals(JOB_MOVED_TO_DEADLETTER, eventType);
@ -60,8 +65,8 @@ public class ApproveErrorReporterEventListener implements BpmnAsyncJobEventListe
JobInfo jobInfo = (JobInfo) jobEvent.getEntity();
String handlerType = jobInfo.getJobHandlerType();
//只处理审批类型任务
if (!AsyncApproveTaskJobHandler.TYPE.equals(handlerType)) {
log.warn("非审批类型任务,handlerType:{}", handlerType);
if (!RESOLVE_HANDLER_TYPES.contains(handlerType)) {
log.warn("非审批类型任务,handlerType:{},event:{}", handlerType, JSONUtil.toJsonStr(flowableEvent));
return;
}
if (StringUtils.isBlank(jobInfo.getCustomValues())) {