在企业的业务流程管理中，Activiti 是一个非常受欢迎的 BPM（业务流程管理）框架。它提供了一个灵活的方式来定义和执行业务流程，并支持在流程的不同阶段进行回调，以实现复杂的业务逻辑扩展。本文将深入探讨如何使用 Activiti 的流程回调机制，从而在流程中嵌入自定义的业务逻辑。

1. Activiti 简介

Activiti 是一个开源的 BPM 和 RM（记录管理）框架，用于自动化业务流程。它提供了一个强大的平台来创建、执行和监控业务流程。Activiti 不仅可以定义简单的流程，还可以处理复杂的业务逻辑。

2. 流程回调的概念

在 Activiti 中，流程回调是指在某些关键节点，如流程开始、任务完成、事件触发等，自动执行一些预定义的操作。这些操作可以是Java代码，也可以是执行特定服务的逻辑。

3. 实现流程回调

要在 Activiti 中实现流程回调，可以通过以下步骤进行：

3.1 定义流程

首先，定义一个 BPMN（Business Process Model and Notation）流程，其中包含需要回调的节点。

<bpmn2:process id="myProcess" name="My Process">
  <bpmn2:startEvent id="start" />
  <bpmn2:serviceTask id="callbackTask" activiti:expression="callbackService" />
  <bpmn2:endEvent id="end" />
</bpmn2:process>

3.2 创建回调服务

然后，创建一个服务，该服务将在流程回调时执行。这个服务可以是 Spring Bean。

@Component
public class CallbackService {

  public void execute() {
    // 在这里实现回调逻辑
    System.out.println("Callback service executed!");
  }
}

3.3 将服务绑定到流程节点

最后，将创建的服务绑定到流程的特定节点。

<bpmn2:serviceTask id="callbackTask" activiti:expression="callbackService" />

这样，当流程执行到 callbackTask 节点时，就会自动调用 CallbackService 的 execute 方法。

4. 使用流程变量

在回调逻辑中，你可能需要访问或修改流程变量。可以使用 ExecutionService 来访问或更新变量。

ExecutionService executionService = processEngine.getRuntimeService();
VariableInstance variable = executionService.getVariable("myVariable");
executionService.setVariable("myVariable", "newValue");

5. 示例：请假流程中的回调

以下是一个简单的请假流程示例，其中包含在任务完成时触发的回调。

5.1 定义流程

<bpmn2:process id="leaveProcess" name="Leave Process">
  <bpmn2:startEvent id="start" />
  <bpmn2:serviceTask id="leaveTask" name="Apply for Leave" />
  <bpmn2:endEvent id="end" />
</bpmn2:process>

5.2 创建回调服务

@Component
public class LeaveCallbackService {

  public void leaveApplied(VariableInstance leaveInfo) {
    System.out.println("Leave applied: " + leaveInfo.getValue());
    // 在这里处理请假逻辑
  }
}

5.3 将服务绑定到流程节点

<bpmn2:serviceTask id="leaveTask" name="Apply for Leave" activiti:expression="leaveCallbackService" />

通过这种方式，每当请假任务完成时，就会执行 LeaveCallbackService 的 leaveApplied 方法。

6. 总结

使用 Activiti 的流程回调机制，可以轻松地在业务流程中实现复杂的业务逻辑扩展。通过定义和绑定服务，你可以在流程的关键节点执行自定义的回调逻辑。这样，你就可以在保持流程灵活性的同时，实现业务需求。