002.camunda入门（一个流程的欣赏）

目标

创建一个大众流程（请假流程）并且可以跑起来。

需要的预备知识

camunda数据库表的基本认识表介绍链接

流程图的制作

下载camunda的绘图工具流程图工具地址
绘制请假流程图（XML去掉了布局元素）

请假流程图.png

<?xml version="1.0" encoding="UTF-8"?>
<bpmn:definitions xmlns:bpmn="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" id="Definitions_0vl15c1" targetNamespace="http://bpmn.io/schema/bpmn" exporter="Camunda Modeler" exporterVersion="4.2.0">
  <bpmn:process id="Process_007jh58" isExecutable="true">
    <bpmn:startEvent id="StartEvent_1">
      <bpmn:outgoing>Flow_1l7o4ts</bpmn:outgoing>
    </bpmn:startEvent>
    <bpmn:sequenceFlow id="Flow_1l7o4ts" sourceRef="StartEvent_1" targetRef="Activity_1almw37" />
    <bpmn:exclusiveGateway id="Gateway_1l7w1cq">
      <bpmn:incoming>Flow_05ef0ej</bpmn:incoming>
      <bpmn:outgoing>Flow_16oi0x8</bpmn:outgoing>
      <bpmn:outgoing>Flow_1yq2gkb</bpmn:outgoing>
    </bpmn:exclusiveGateway>
    <bpmn:sequenceFlow id="Flow_16oi0x8" name="小于等于7天" sourceRef="Gateway_1l7w1cq" targetRef="Activity_0kms1lj">
      <bpmn:conditionExpression xsi:type="bpmn:tFormalExpression">${ts &lt;= 7}</bpmn:conditionExpression>
    </bpmn:sequenceFlow>
    <bpmn:sequenceFlow id="Flow_1yq2gkb" name="大于七天" sourceRef="Gateway_1l7w1cq" targetRef="Activity_0uw0hfc">
      <bpmn:conditionExpression xsi:type="bpmn:tFormalExpression">${ts &gt; 7}</bpmn:conditionExpression>
    </bpmn:sequenceFlow>
    <bpmn:exclusiveGateway id="Gateway_1sx3v29">
      <bpmn:incoming>Flow_0808fzz</bpmn:incoming>
      <bpmn:incoming>Flow_0y6yarx</bpmn:incoming>
      <bpmn:outgoing>Flow_122u7os</bpmn:outgoing>
    </bpmn:exclusiveGateway>
    <bpmn:sequenceFlow id="Flow_0808fzz" sourceRef="Activity_0kms1lj" targetRef="Gateway_1sx3v29" />
    <bpmn:sequenceFlow id="Flow_0y6yarx" sourceRef="Activity_0uw0hfc" targetRef="Gateway_1sx3v29" />
    <bpmn:userTask id="Activity_1almw37" name="申请人" camunda:assignee="sqr">
      <bpmn:incoming>Flow_1l7o4ts</bpmn:incoming>
      <bpmn:outgoing>Flow_15p6u4g</bpmn:outgoing>
    </bpmn:userTask>
    <bpmn:sequenceFlow id="Flow_15p6u4g" sourceRef="Activity_1almw37" targetRef="Activity_1wm4vx9" />
    <bpmn:sequenceFlow id="Flow_05ef0ej" sourceRef="Activity_1wm4vx9" targetRef="Gateway_1l7w1cq" />
    <bpmn:sequenceFlow id="Flow_122u7os" sourceRef="Gateway_1sx3v29" targetRef="Activity_01orex7" />
    <bpmn:endEvent id="Event_0cuwhfb">
      <bpmn:incoming>Flow_0zfntyp</bpmn:incoming>
    </bpmn:endEvent>
    <bpmn:sequenceFlow id="Flow_0zfntyp" sourceRef="Activity_01orex7" targetRef="Event_0cuwhfb" />
    <bpmn:userTask id="Activity_1wm4vx9" name="申请人上级" camunda:assignee="sjld">
      <bpmn:incoming>Flow_15p6u4g</bpmn:incoming>
      <bpmn:outgoing>Flow_05ef0ej</bpmn:outgoing>
    </bpmn:userTask>
    <bpmn:userTask id="Activity_0kms1lj" name="人事经理" camunda:assignee="rsjl">
      <bpmn:incoming>Flow_16oi0x8</bpmn:incoming>
      <bpmn:outgoing>Flow_0808fzz</bpmn:outgoing>
    </bpmn:userTask>
    <bpmn:userTask id="Activity_0uw0hfc" name="人事总监" camunda:assignee="rszj">
      <bpmn:incoming>Flow_1yq2gkb</bpmn:incoming>
      <bpmn:outgoing>Flow_0y6yarx</bpmn:outgoing>
    </bpmn:userTask>
    <bpmn:userTask id="Activity_01orex7" name="归档" camunda:assignee="sqr">
      <bpmn:incoming>Flow_122u7os</bpmn:incoming>
      <bpmn:outgoing>Flow_0zfntyp</bpmn:outgoing>
    </bpmn:userTask>
  </bpmn:process>
</bpmn:definitions>

流程的部署

复制如上的流程图xml信息到classpath目录下
部署流程

    /**
     * 部署bpmn。xml资源文件
     */
    public void bpmnImport() {
        Deployment deploy = repositoryService
                .createDeployment()
               // .name("请假申请")
                .addClasspathResource("diagram_1.bpmn")
                .deploy();
        log.info(deploy.getName());
        log.info(deploy.getId());
    }

运行后如下表会一些基本信息

运行后结果-未设置name.png

运行后结果-设置name.png

流程的运行

    /**
     * 开始一个流程实例
     */
    public void startBpm(String proInsId) {
        ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(proInsId);
        String id = processInstance.getId();
        log.info(id);
    }

流程运行结果.png

流程的审批

 /**
     * 完成一个任务 不带参数
     * @param taskId
     */
    public void comTask(String taskId) {
       taskService.complete(taskId);
    }

运行结果

 /**
     * 完成一个任务， 并且可以设置变量参数
     * @param taskId
     */
    public void comTask(String taskId, Map map) {
        taskService.complete(taskId, map);
    }

带参数测试结果

结束语

至此一个简单固定的流程就可以成功完成！

示例代码

服务代码

@Slf4j
@Service
public class ResService {

    @Autowired
    private RepositoryService repositoryService;
    @Autowired
    private RuntimeService runtimeService;
    @Autowired
    private TaskService taskService;

    /**
     * 部署bpmn。xml资源文件
     */
    public void bpmnImport() {
        Deployment deploy = repositoryService
                .createDeployment()
                .name("请假申请")
                .addClasspathResource("diagram_1.bpmn")
                .deploy();
        log.info(deploy.getName());
        log.info(deploy.getId());
    }
    /**
     * 开始一个流程实例
     */
    public void startBpm(String proInsId) {
        ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(proInsId);
        String id = processInstance.getId();
        log.info(id);
    }
    /**
     * 完成一个任务 不带参数
     * @param taskId
     */
    public void comTask(String taskId) {
       taskService.complete(taskId);
    }
    /**
     * 完成一个任务， 并且可以设置变量参数
     * @param taskId
     */
    public void comTask(String taskId, Map map) {
        taskService.complete(taskId, map);
    }
}

测试类代码

@RunWith(SpringRunner.class)
@SpringBootTest
class ResServiceTest {

    @Autowired
    private ResService resService;

    /**
     * 测试导入classpath下的bpmn资源
     */
    @Test
    void bpmnImport() {
        resService.bpmnImport();
    }

    /**
     * 开始一个流程实例， xml标签内的bpmn:process id="Process_007jh58"
     */
    @Test
    void startBpm() {
        resService.startBpm("Process_007jh58");
    }

    /**
     * 完成一个任务
     */
    @Test
    void comTask() {
        resService.comTask("f4bc7a2a-0a0c-11eb-9b55-c81f66132ec7");
    }

    /**
     * 完成一个任务， 带参数比如此流程的分叉需要判断请假天数， 我们需要传入当前的变量天数
     */
    @Test
    void comTask1() {
        Map map = new HashMap();
        map.put("ts", 8);
        resService.comTask("5cbe9b2b-0a0d-11eb-9439-c81f66132ec7", map);
    }
}