使用Java动态创建Flowable会签模型的示例代码

<dependencies>
    <dependency>
        <groupId>org.flowable</groupId>
        <artifactId>flowable-spring-boot-starter</artifactId>
        <version>${flowable.version}</version>
    </dependency>
    <!-- 其他依赖... -->
</dependencies>

import org.flowable.bpmn.model.BpmnModel;
import org.flowable.bpmn.model.EndEvent;
import org.flowable.bpmn.model.ParallelGateway;
import org.flowable.bpmn.model.Process;
import org.flowable.bpmn.model.SequenceFlow;
import org.flowable.bpmn.model.StartEvent;
import org.flowable.bpmn.model.UserTask;
import org.flowable.engine.RepositoryService;
import org.flowable.engine.repository.Deployment;

// 假设repositoryService已经注入或获取到了
public void createParallelGatewayProcess() {
    // 创建BpmnModelInstance
    BpmnModelInstance modelInstance = Bpmn.createEmptyModel();

    // 创建流程定义
    Process process = new Process();
    process.setId("parallelGatewayProcess");
    process.setName("Parallel Gateway Example");
    modelInstance.addProcess(process);

    // 添加开始事件
    StartEvent startEvent = modelInstance.newInstance(StartEvent.class);
    startEvent.setId("startEvent");
    process.addChildElement(startEvent);

    // 添加并行网关
    ParallelGateway parallelGateway = modelInstance.newInstance(ParallelGateway.class);
    parallelGateway.setId("parallelGateway");
    process.addChildElement(parallelGateway);

    // 连接开始事件到并行网关
    SequenceFlow flow1 = modelInstance.newInstance(SequenceFlow.class);
    flow1.setId("flow1");
    flow1.setSource(startEvent);
    flow1.setTarget(parallelGateway);
    modelInstance.addFlowElement(flow1);

    // 添加用户任务1
    UserTask userTask1 = modelInstance.newInstance(UserTask.class);
    userTask1.setId("userTask1");
    userTask1.setName("Task A");
    process.addChildElement(userTask1);

    // 添加用户任务2
    UserTask userTask2 = modelInstance.newInstance(UserTask.class);
    userTask2.setId("userTask2");
    userTask2.setName("Task B");
    process.addChildElement(userTask2);

    // 从并行网关到两个用户任务
    SequenceFlow flow2 = modelInstance.newInstance(SequenceFlow.class);
    flow2.setId("flow2");
    flow2.setSource(parallelGateway);
    flow2.setTarget(userTask1);
    modelInstance.addFlowElement(flow2);

    SequenceFlow flow3 = modelInstance.newInstance(SequenceFlow.class);
    flow3.setId("flow3");
    flow3.setSource(parallelGateway);
    flow3.setTarget(userTask2);
    modelInstance.addFlowElement(flow3);

    // 添加另一个并行网关用于汇聚
    ParallelGateway joinGateway = modelInstance.newInstance(ParallelGateway.class);
    joinGateway.setId("joinGateway");
    joinGateway.setParallelGatewayType(ParallelGateway.Type.DIVERGING); // 设置为汇聚类型
    process.addChildElement(joinGateway);

    // 连接两个用户任务到汇聚网关
    SequenceFlow flow4 = modelInstance.newInstance(SequenceFlow.class);
    flow4.setId("flow4");
    flow4.setSource(userTask1);
    flow4.setTarget(joinGateway);
    modelInstance.addFlowElement(flow4);

    SequenceFlow flow5 = modelInstance.newInstance(SequenceFlow.class);
    flow5.setId("flow5");
    flow5.setSource(userTask2);
    flow5.setTarget(joinGateway);
    modelInstance.addFlowElement(flow5);

    // 添加结束事件
    EndEvent endEvent = modelInstance.newInstance(EndEvent.class);
    endEvent.setId("endEvent");
    process.addChildElement(endEvent);

    // 从汇聚网关到结束事件
    SequenceFlow flow6 = modelInstance.newInstance(SequenceFlow.class);
    flow6.setId("flow6");
    flow6.setSource(joinGateway);
    flow6.setTarget(endEvent);
    modelInstance.addFlowElement(flow6);

    // 部署流程模型
    RepositoryService repositoryService = /* 获取RepositoryService */;
    Deployment deployment = repositoryService.createDeployment()
            .addModelInstance("parallelGatewayExample.bpmn", modelInstance)
            .name("Parallel Gateway Example Process")
            .deploy();

    System.out.println("流程已部署，部署ID: " + deployment.getId());
}