核心api实操-Activiti7从入门到专家（5）

背景

上一节已经搭建了，具体的开发环境，数据库，并且找了一个可以用bpmnjs流程设计器，这一些，我们对核心api做个基础的实操，有个感性的认知，另外对数据库和基本数据流动有个理解。

部署

模板部署

为了接口调用，暂时不使用线上的流程设计器，使用安装的可视化流程设计器插件

然后如下目录结构下，构建一个标准的bpmn文件

画的比较急促，usertask中，都没有名字，下面的数据库中也没有名字，当然这节我们是感性认知，主要能能跑一些接口就行

<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/processdef">
  <process id="apply" name="apply" isExecutable="true">
    <startEvent id="sid-93eb9656-e7fa-46db-b867-5bf8c8ccfd28"/>
    <userTask id="sid-f436faf4-75c5-4004-993d-fde4c2efbd15" activiti:assignee="starter"/>
    <userTask id="sid-d78d057a-230f-4d2d-9b73-74907342c644" activiti:assignee="manager"/>
    <userTask id="sid-110669bd-2386-4fd1-a66f-82250f2971b9" activiti:candidateUsers="duster,hrer"/>
    <sequenceFlow id="sid-cf63b67a-6287-4b98-ad3d-3f5a6aab6456" sourceRef="sid-93eb9656-e7fa-46db-b867-5bf8c8ccfd28" targetRef="sid-f436faf4-75c5-4004-993d-fde4c2efbd15"/>
    <sequenceFlow id="sid-dc3e5702-3c9e-4f4f-a5aa-5d12d62e0531" sourceRef="sid-f436faf4-75c5-4004-993d-fde4c2efbd15" targetRef="sid-d78d057a-230f-4d2d-9b73-74907342c644"/>
    <sequenceFlow id="sid-f68d50f0-438c-42e6-b4a8-5441554908c7" sourceRef="sid-d78d057a-230f-4d2d-9b73-74907342c644" targetRef="sid-110669bd-2386-4fd1-a66f-82250f2971b9"/>
    <endEvent id="sid-68257716-77d4-464b-a07d-8a62969df00d"/>
    <sequenceFlow id="sid-b9534685-9617-4e88-9e24-622d58959337" sourceRef="sid-110669bd-2386-4fd1-a66f-82250f2971b9" targetRef="sid-68257716-77d4-464b-a07d-8a62969df00d"/>
  </process>
  <bpmndi:BPMNDiagram id="BPMNDiagram_apply">
    <bpmndi:BPMNPlane bpmnElement="apply" id="BPMNPlane_apply">
      <bpmndi:BPMNShape id="shape-b4673c70-2eb5-4096-9631-454c2d4f35f4" bpmnElement="sid-93eb9656-e7fa-46db-b867-5bf8c8ccfd28">
        <omgdc:Bounds x="-100.0" y="-65.0" width="30.0" height="30.0"/>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="shape-6cfc9bde-25fa-42f3-82fd-9a681b20e3eb" bpmnElement="sid-f436faf4-75c5-4004-993d-fde4c2efbd15">
        <omgdc:Bounds x="-35.0" y="-90.0" width="100.0" height="80.0"/>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="shape-6d9ee9d0-6a3e-4b3b-82ab-d901adcaac05" bpmnElement="sid-d78d057a-230f-4d2d-9b73-74907342c644">
        <omgdc:Bounds x="115.0" y="-90.0" width="100.0" height="80.0"/>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="shape-6d716fe2-0c5c-47f5-ab0b-fb5265c9fe58" bpmnElement="sid-110669bd-2386-4fd1-a66f-82250f2971b9">
        <omgdc:Bounds x="250.0" y="-90.0" width="100.0" height="80.0"/>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNEdge id="edge-edb64b8a-b281-4f74-9d4c-3b41480e7f15" bpmnElement="sid-cf63b67a-6287-4b98-ad3d-3f5a6aab6456">
        <omgdi:waypoint x="-70.0" y="-50.0"/>
        <omgdi:waypoint x="-35.0" y="-50.0"/>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="edge-0a7821f9-6b78-4009-a6cd-70ad14e278cf" bpmnElement="sid-dc3e5702-3c9e-4f4f-a5aa-5d12d62e0531">
        <omgdi:waypoint x="65.0" y="-50.0"/>
        <omgdi:waypoint x="115.0" y="-50.0"/>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="edge-5e5f8326-5409-417a-85ab-4b455830a086" bpmnElement="sid-f68d50f0-438c-42e6-b4a8-5441554908c7">
        <omgdi:waypoint x="215.0" y="-50.0"/>
        <omgdi:waypoint x="250.0" y="-50.0"/>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNShape id="shape-de420915-45e2-4275-9a4a-8096e3f5b152" bpmnElement="sid-68257716-77d4-464b-a07d-8a62969df00d">
        <omgdc:Bounds x="385.0" y="-65.0" width="30.0" height="30.0"/>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNEdge id="edge-2fe4e62f-ea4a-442c-9842-8b9690acb4f5" bpmnElement="sid-b9534685-9617-4e88-9e24-622d58959337">
        <omgdi:waypoint x="350.0" y="-50.0"/>
        <omgdi:waypoint x="385.0" y="-50.0"/>
      </bpmndi:BPMNEdge>
    </bpmndi:BPMNPlane>
  </bpmndi:BPMNDiagram>
</definitions>

以下是流程发布代码

  @Test
public void GetDeployInfos() {

// 流程模板部署，发布
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

RepositoryService repositoryService = processEngine.getRepositoryService();

Deployment deployment = repositoryService.createDeployment()
    .addClasspathResource("apply.bpmn20.xml")
    .addClasspathResource("apply.png")
    .name("申请示例")
    .key("apply")
    .deploy();

System.out.println(deployment.getId());

这是print的内容：

2024-04-12 18:07:26.602 INFO 21652 --- [ main] o.a.e.impl.bpmn.deployer.BpmnDeployer : Process deployed: {id: apply:1:76ccd0ba-f8b4-11ee-a0f0-8c8caa7a4f9c, key: apply, name: apply }

76b996d7-f8b4-11ee-a0f0-8c8caa7a4f9c

这是相关的数据库：

发布查询

// 部署后，查询流程模板
//  查询流程部署
Deployment deployment = repositoryService.createDeploymentQuery().deploymentKey("apply").singleResult();
//  查询流程定义
ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().deploymentId(deployment.getId()).singleResult();
//  流程定义是否被挂起/暂停
boolean suspended = processDefinition.isSuspended();
System.out.println(deployment.getId() + "当前流程状态："+suspended);
//  删除部署       repositoryService.deleteDeployment(deployment.getId());

//  挂起/暂停流程定义
repositoryService.suspendProcessDefinitionById(processDefinition.getId());
processDefinition = repositoryService.createProcessDefinitionQuery().deploymentId(deployment.getId()).singleResult();
//  流程定义是否被挂起/暂停
suspended = processDefinition.isSuspended();
System.out.println(deployment.getId() + "当前流程状态："+suspended);
//  激活流程定义
repositoryService.activateProcessDefinitionById(processDefinition.getId());
processDefinition = repositoryService.createProcessDefinitionQuery().deploymentId(deployment.getId()).singleResult();
//  流程定义是否被挂起/暂停
suspended = processDefinition.isSuspended();
System.out.println(deployment.getId() + "当前流程状态："+suspended);

启动流程实例

// 启动实例
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

RuntimeService runtimeService= processEngine.getRuntimeService();
Map<String, Object> userVariables = new HashMap<>();
//小兵申请，经理审批  user
userVariables.put("starter", "xiaobing");
userVariables.put("manager", "jingli");

ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("apply", userVariables);
// runtimeService.startProcessInstanceByKey("apply");

System.out.println(processInstance.getProcessInstanceId());
System.out.println(processInstance.getProcessDefinitionId());

用户任务

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
TaskService taskService = processEngine.getTaskService();
//  查询待办任务
List<Task> taskList = taskService.createTaskQuery().taskAssignee("starter").list();

for (Task task : taskList) {
  System.out.println("taskID:"+task.getId());
  //  完成任务
  taskService.complete(task.getId());

taskID:73cd61cd-f8b6-11ee-b5e3-8c8caa7a4f9c

接着是到了经理的任务

我们继续执行

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
TaskService taskService = processEngine.getTaskService();
//  查询待办任务
List<Task> taskList = taskService.createTaskQuery().taskAssignee("manager").list();

for (Task task : taskList) {
  System.out.println("taskID:"+task.getId());
  //  完成任务
  taskService.complete(task.getId());
}

taskID:82209be4-f8b8-11ee-9d92-8c8caa7a4f9c

历史记录

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
 HistoryService historyService = processEngine.getHistoryService();
 //  历史查询
 List<HistoricActivityInstance> list = historyService.createHistoricActivityInstanceQuery()
     .processInstanceId("73cb8d05-f8b6-11ee-b5e3-8c8caa7a4f9c").orderByHistoricActivityInstanceStartTime().asc().list();
for (HistoricActivityInstance historicActivityInstance : list) {
   System.out.println(historicActivityInstance.getActivityName() + ":" + historicActivityInstance.getAssignee());
 }