博客

Activiti 7 是一个基于 Spring Boot 和 Spring Cloud 的工作流引擎，其执行流程的代码比较复杂，需要涉及到多个模块和类。下面是 Activiti 7 执行流程的主要代码：

1. 创建流程实例

复制BpmnModel bpmnModel = repositoryService.getBpmnModel(processDefinitionId);
Process process = bpmnModel.getProcesses().get(0);
FlowElement startElement = process.getFlowElements().stream()
    .filter(e -> e instanceof StartEvent)
    .findFirst()
    .orElseThrow(() -> new IllegalArgumentException("No start event found in process definition " + processDefinitionId));
    
ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinitionId, variables);

1. 执行用户任务

复制Task task = taskService.createTaskQuery().processInstanceId(processInstanceId).singleResult();
if (task != null) {
    taskService.complete(task.getId(), variables);
}

1. 完成流程实例

复制ProcessInstance processInstance = runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();
if (processInstance != null) {
    runtimeService.deleteProcessInstance(processInstanceId, reason);
}

1. 监听流程事件

复制@EventListener
public void onProcessStarted(ProcessStartedEvent event) {
    String processInstanceId = event.getProcessInstanceId();
    // 处理流程启动事件
}

@EventListener
public void onTaskCreated(TaskCreatedEvent event) {
    String taskId = event.getTaskId();
    // 处理任务创建事件
}

@EventListener
public void onTaskCompleted(TaskCompletedEvent event) {
    String taskId = event.getTaskId();
    // 处理任务完成事件
}

@EventListener
public void onProcessCompleted(ProcessCompletedEvent event) {
    String processInstanceId = event.getProcessInstanceId();
    // 处理流程完成事件
}

以上是 Activiti 7 执行流程的主要代码，详细的实现可以参考 Activiti 7 的源码。