Activiti7工作流实战：手把手教你实现审批驳回与打回功能（附完整代码）

Activiti7工作流实战：深度解析审批驳回与打回功能的工程化实现

当部门经理在OA系统中点击"驳回"按钮时，系统背后究竟发生了什么？这个看似简单的操作背后，隐藏着工作流引擎中复杂的流程转向逻辑。本文将带您深入Activiti7的流程控制内核，从业务场景出发，构建一套健壮的审批驳回体系。

1. 审批驳回的业务本质与技术实现路径

在传统纸质审批时代，领导只需用红笔在表单上划个叉并写上"重填"二字。但在数字化流程中，这种"打回"操作需要精确控制三个核心要素：

1. 流程方向的重定向：动态修改BPMN节点的流向关系
2. 任务执行人的重置：确保任务能正确回到指定处理人
3. 流程上下文的保留：维持业务数据的完整性与一致性

以典型的请假流程为例，当流程走到"部门经理审批"节点时，驳回操作需要实现以下技术路径：

// 伪代码展示核心流程 public void rejectApproval(String taskId, String comment) { // 1. 获取当前任务及流程实例 Task currentTask = taskService.createTaskQuery().taskId(taskId).singleResult(); ProcessInstance instance = runtimeService.createProcessInstanceQuery() .processInstanceId(currentTask.getProcessInstanceId()).singleResult(); // 2. 定位目标回退节点 HistoricActivityInstance targetNode = findPreviousNode(instance.getId(), currentTask.getTaskDefinitionKey()); // 3. 动态修改流向 redirectFlow(currentTask, targetNode); // 4. 添加审批意见 taskService.addComment(taskId, instance.getId(), "REJECT", comment); // 5. 完成任务触发流转 taskService.complete(taskId); }

这种实现方式与简单回退到上一节点不同，它需要处理以下特殊场景：

2. 动态流程转向的工程实现

Activiti的流程转向本质上是修改BPMN模型的运行时表现。我们需要采用"搭桥-过河-拆桥"的策略：

1. 保存当前状态：备份原始流向关系
2. 建立临时路径：创建指向目标节点的序列流
3. 执行转向操作：完成任务触发流转
4. 恢复初始状态：还原原始流向关系

以下是带异常处理的完整实现：

public void redirectFlow(Task currentTask, HistoricActivityInstance targetNode) { RepositoryService repositoryService = processEngine.getRepositoryService(); BpmnModel bpmnModel = repositoryService.getBpmnModel(currentTask.getProcessDefinitionId()); try { // 获取当前节点元素 FlowNode currentFlowNode = (FlowNode) bpmnModel .getMainProcess() .getFlowElement(currentTask.getTaskDefinitionKey()); // 获取目标节点元素 FlowNode targetFlowNode = (FlowNode) bpmnModel .getMainProcess() .getFlowElement(targetNode.getActivityId()); // 保存原始流向 List<SequenceFlow> originalFlows = new ArrayList<>(currentFlowNode.getOutgoingFlows()); // 创建临时转向 SequenceFlow tempFlow = new SequenceFlow(); tempFlow.setId("TEMP_FLOW_" + UUID.randomUUID()); tempFlow.setSourceFlowElement(currentFlowNode); tempFlow.setTargetFlowElement(targetFlowNode); // 应用临时流向 currentFlowNode.getOutgoingFlows().clear(); currentFlowNode.getOutgoingFlows().add(tempFlow); // 执行转向 taskService.complete(currentTask.getId()); // 恢复原始流向 currentFlowNode.getOutgoingFlows().clear(); currentFlowNode.getOutgoingFlows().addAll(originalFlows); } catch (Exception e) { throw new WorkflowException("流程转向失败: " + e.getMessage()); } }

关键注意事项：

必须确保在分布式环境下，流程转向操作是原子性的。建议在方法上添加@Transactional注解，或在异常处理中加入流程状态回滚逻辑。

3. 驳回与打回的决策模型

在实际业务中，我们需要根据不同的业务场景选择不同的回退策略。以下是两种典型模式的对比分析：

策略一：渐进式回退（单步驳回）

• 适用场景：仅需局部修改的审批场景
• 技术特点：
  • 回退到直接上游节点
  • 保留大部分审批痕迹
  • 实现相对简单
• 业务影响：审批周期较短，但可能需多次驳回

策略二：激进式打回（退回起点）

• 适用场景：需要彻底重填的场景
• 技术特点：
  • 直接跳转至流程起始节点
  • 重置整个审批链
  • 需要处理历史数据冲突
• 业务影响：审批周期重置，但确保数据完整性

决策矩阵示例：

在实际项目中，我们通常会采用混合策略。以下是通过规则引擎实现智能路由的示例：

public String determineRejectType(ProcessInstance instance, Task currentTask) { // 获取业务表单数据 FormData formData = formService.getTaskFormData(currentTask.getId()); // 分析驳回原因 String comment = (String) taskService.getVariable(currentTask.getId(), "rejectComment"); RejectReason reason = rejectAnalyzer.analyze(comment); // 应用决策规则 if (reason.requiresFullRestart()) { return findStartNode(instance.getProcessDefinitionId()); } else if (reason.needsDepartmentReview()) { return "deptVerify"; } else { return findPreviousUserTask(currentTask); } }

4. 会签场景下的特殊处理

会签节点的驳回需要额外考虑多实例任务的特性。当会签环节需要驳回时，我们面临以下技术挑战：

1. 实例计数器的重置：需要处理nrOfInstances等内置变量
2. 并行任务的终止：要确保所有活动实例被正确清理
3. 审批结果的保留：保留已完成的会签意见供后续参考

解决方案示例：

public void rejectCountersign(Task task, String targetNodeId) { // 1. 终止所有活动实例 List<Task> activeTasks = taskService.createTaskQuery() .processInstanceId(task.getProcessInstanceId()) .taskDefinitionKey(task.getTaskDefinitionKey()) .list(); activeTasks.forEach(t -> { taskService.addComment(t.getId(), task.getProcessInstanceId(), "ABORT", "会签驳回终止"); taskService.setVariableLocal(t.getId(), "forceComplete", true); taskService.complete(t.getId()); }); // 2. 跳转到目标节点 runtimeService.createChangeActivityStateBuilder() .processInstanceId(task.getProcessInstanceId()) .moveActivityIdTo(task.getTaskDefinitionKey(), targetNodeId) .changeState(); // 3. 重置会签变量 runtimeService.setVariable(task.getProcessInstanceId(), "countersignResults", new HashMap<>()); }

性能优化技巧：

• 对于大型会签(参与人>20)，建议采用分批处理
• 使用异步执行器处理实例终止操作
• 考虑引入快照机制保存会签进度

5. 生产环境中的增强实践

在真实项目部署时，我们还需要考虑以下增强功能：

审批链可视化

// 前端展示驳回路径的示例代码 function renderRejectPath(processInstanceId) { axios.get(`/api/process/${processInstanceId}/reject-path`) .then(response => { const pathData = response.data; // 使用流程图库展示路径 bpmnViewer.highlightPath(pathData); }); }

驳回次数限制

// 驳回频率控制 @RejectLimit(maxCount=3, period=24*60*60*1000) public void rejectTask(String taskId) { // 驳回实现 }

智能填充建议

public class RejectHelper { public List<RejectSuggestion> analyzeForm(FormData formData) { // 使用规则引擎分析表单问题 return ruleEngine.check(formData.getFields()); } }

在大型ERP系统中实施时，我们通常会建立专门的驳回控制模块，包含以下组件：

com.example.workflow.reject ├── controller │ └── RejectController.java ├── service │ ├── RejectStrategyFactory.java │ ├── impl │ │ ├── SimpleRejectStrategy.java │ │ ├── CountersignRejectStrategy.java │ │ └── ComplexGatewayRejectStrategy.java ├── model │ ├── RejectCommand.java │ └── RejectResult.java └── aop └── RejectAuditAspect.java

这种架构设计使得驳回逻辑可以灵活扩展，同时保持核心流程的稳定性。在实际项目中，我们通过策略模式支持了17种不同的驳回场景，包括跨流程跳转、条件驳回等复杂需求。