基于Flowable全局监听器实现智能节点跳过：告别重复审批

1. 为什么需要智能跳过重复审批节点想象一下这样的场景你设计了一个采购审批流程部门经理需要先后审批采购申请和采购确认两个节点。但当这两个节点都分配给同一位经理时他会在系统里看到两个完全相同的待办事项——先审批一次申请再审批一次确认。这种重复操作不仅浪费时间还会让审批人产生困惑我刚才不是已经批过了吗这就是典型的相邻节点重复审批问题。在Flowable流程引擎中这种情况经常发生在按角色配置审批人时如所有部门经理审批节点多级审批中同一岗位人员连续处理不同阶段会签场景中部分审批人重叠的情况传统解决方案比如在流程设计时添加条件网关或者配置跳过表达式都存在明显缺陷侵入性强需要修改现有流程图定义灵活性差审批人变更时需要重新发布流程维护困难条件逻辑分散在各个网关中2. 全局监听器方案设计原理2.1 核心思路事件驱动架构我们采用非侵入式的全局事件监听方案其工作原理就像给流程引擎安装了一个智能监控摄像头监听所有任务创建事件TASK_CREATED当新任务产生时自动检查其与前置任务的关系发现审批人相同时触发自动跳过机制这种设计有三大优势零改造不影响现有流程图定义动态生效实时判断审批人关系完整记录跳过操作会留下完整日志2.2 关键技术实现点// 监听器配置示例 Configuration public class FlowableGlobListenerConfing implements ApplicationListenerContextRefreshedEvent { Autowired private SpringProcessEngineConfiguration configuration; Override public void onApplicationEvent(ContextRefreshedEvent event) { configuration.getEventDispatcher() .addEventListener(globalTaskCreateListener, FlowableEngineEventType.TASK_CREATED); } }关键判断逻辑需要处理多种流程结构单节点串联A→B→C的线性流程网关分支包含并行网关、排他网关的复杂流程会签场景多审批人场景下的部分重复3. 完整实现步骤详解3.1 基础环境准备首先确保项目中已集成Flowable Spring Boot Starterdependency groupIdorg.flowable/groupId artifactIdflowable-spring-boot-starter/artifactId version6.7.2/version /dependency3.2 核心监听器实现Component public class GlobalTaskCreateListener extends AbstractFlowableEngineEventListener { Override protected void taskCreated(FlowableEngineEntityEvent event) { TaskEntity currentTask (TaskEntity)event.getEntity(); String processInstanceId currentTask.getProcessInstanceId(); // 获取流程定义 Process process repositoryService.getBpmnModel(currentTask.getProcessDefinitionId()) .getMainProcess(); // 获取当前任务对应的流程节点 UserTask currentUserTask (UserTask)process.getFlowElement(currentTask.getTaskDefinitionKey()); // 获取所有流入当前节点的连线 ListSequenceFlow incomingFlows currentUserTask.getIncomingFlows(); // 处理不同类型的上游节点 if(incomingFlows.size() 1) { FlowElement sourceElement incomingFlows.get(0).getSourceFlowElement(); if(sourceElement instanceof UserTask) { checkAndSkip(currentTask, (UserTask)sourceElement); } } } private void checkAndSkip(TaskEntity currentTask, UserTask previousUserTask) { // 实现审批人比对逻辑 String previousApprover getLastApprover(currentTask.getProcessInstanceId()); if(currentTask.getAssignee().equals(previousApprover)) { skipTask(currentTask); } } }3.3 审批人比对策略需要考虑的比对场景包括固定审批人直接比较assignee值表达式审批人如${departmentManager}会签列表多审批人场景下的包含关系动态变量通过流程变量确定的审批人private String getLastApprover(String processInstanceId) { // 从历史记录中获取最近完成的同流程节点任务 HistoricTaskInstance lastTask historyService.createHistoricTaskInstanceQuery() .processInstanceId(processInstanceId) .orderByHistoricTaskInstanceEndTime().desc() .list() .get(0); return lastTask.getAssignee(); }4. 生产环境注意事项4.1 历史记录完整性保障自动跳过操作需要保留完整的审批痕迹添加跳过类型的审批意见记录跳过操作的时间戳保持流程变量的一致性private void skipTask(TaskEntity task) { // 添加跳过记录 taskService.addComment(task.getId(), task.getProcessInstanceId(), SKIP, 自动跳过相同审批人节点); // 完成当前任务 taskService.complete(task.getId()); }4.2 性能优化建议在大流量系统中需要注意使用缓存减少历史记录查询异步处理非关键路径逻辑添加熔断机制防止事件堆积我在实际项目中曾遇到一个典型案例某电商平台的退款审批流程原本需要先后经过客服主管→财务主管→运营总监三级审批。但当这三个角色都由同一个人兼任时采用本方案后平均处理时间从原来的2天缩短到2小时。这种方案特别适合具有以下特征的业务场景审批层级较多的垂直管理体系中小型企业存在岗位兼任情况需要动态调整审批路线的灵活流程实现时最常遇到的坑是网关节点的处理——比如当两个用户任务之间隔着排他网关时需要特殊处理网关的入向流。这时可以通过判断sourceFlowElement类型来区分不同情况。