Activiti执行流查询

短命女 2021-07-24 18:25 402阅读 0赞

**一 代码**

/**
    * Copyright (C), 2020-2020, 软件公司
    * FileName: ExecutionQuery.java
    * Author:   cakin
    * Date:     2020/4/25
    * Description: 执行流查询
    */
    package com.syc.activiti.chapter9;
    
    
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    
    
    import lombok.extern.slf4j.Slf4j;
    import org.activiti.engine.ProcessEngine;
    import org.activiti.engine.ProcessEngines;
    import org.activiti.engine.RepositoryService;
    import org.activiti.engine.RuntimeService;
    import org.activiti.engine.runtime.Execution;
    import org.activiti.engine.runtime.ProcessInstance;
    
    
    /**
    * @className: ExecutionQuery
    * @description: 执行流查询
    * @date: 2020/4/25
    * @author: cakin
    */
    @Slf4j
    public class ExecutionQuery {
        /**
         * 数字常量
         */
        private static final int NUM8 = 8;
        /**
         * 数字常量
         */
        private static final int NUM5 = 5;
        /**
         * 数字常量
         */
        private static final int NUM7 = 7;
        /**
         * 数字常量
         */
        private static final int NUM6 = 6;
    
    
        public static void main( String[] args ) {
            // 创建流程引擎
            ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
            // 得到流程存储服务实例
            RepositoryService repositoryService = engine.getRepositoryService();
            // 得到运行时服务组件
            RuntimeService runtimeService = engine.getRuntimeService();
            // 部署流程描述文件
            repositoryService.createDeployment()
                    .addClasspathResource("bpmn/chapter9/ExecutionQuery.bpmn").deploy();
            //设置参数
            Map<String, Object> vars1 = new HashMap<>();
            vars1.put("days", NUM5);
            Map<String, Object> vars2 = new HashMap<>();
            vars2.put("days", NUM6);
            Map<String, Object> vars3 = new HashMap<>();
            vars3.put("days", NUM7);
            vars3.put("name", "crazyit");
    
            /***********************************************************
    mysql> select ID_,NAME_, KEY_, DEPLOYMENT_ID_,RESOURCE_NAME_,DGRM_RESOURCE_NAME_,SUSPENSION_STATE_ from act_re_procdef;
    +----------------------+--------------+-------------+----------------+-----------------------------------+----------------------------------------------+-------------------+
    | ID_                  | NAME_        | KEY_        | DEPLOYMENT_ID_ | RESOURCE_NAME_                    | DGRM_RESOURCE_NAME_                          | SUSPENSION_STATE_ |
    +----------------------+--------------+-------------+----------------+-----------------------------------+----------------------------------------------+-------------------+
    | testProcess:1:222504 | testProcess2 | testProcess | 222501         | bpmn/chapter9/ExecutionQuery.bpmn | bpmn/chapter9/ExecutionQuery.testProcess.png |                 1 |
    +----------------------+--------------+-------------+----------------+-----------------------------------+----------------------------------------------+-------------------+
    1 row in set (0.00 sec)
    
    
    mysql> select * from act_re_deployment;
    +--------+-------+-----------+------+------------+-------------------------+-----------------+
    | ID_    | NAME_ | CATEGORY_ | KEY_ | TENANT_ID_ | DEPLOY_TIME_            | ENGINE_VERSION_ |
    +--------+-------+-----------+------+------------+-------------------------+-----------------+
    | 222501 | NULL  | NULL      | NULL |            | 2020-04-25 20:27:12.527 | NULL            |
    +--------+-------+-----------+------+------------+-------------------------+-----------------+
    1 row in set (0.00 sec)
             **********************************************************/
    
            // 开始流流程
            ProcessInstance pi1 = runtimeService.startProcessInstanceByKey("testProcess",
                    "businessKey1", vars1);
            ProcessInstance pi2 = runtimeService.startProcessInstanceByKey("testProcess",
                    "businessKey2", vars2);
            ProcessInstance pi3 = runtimeService.startProcessInstanceByKey("testProcess",
                    "businessKey3", vars3);
    
            /***********************************************************
    mysql> select ID_, REV_,PROC_INST_ID_ ,BUSINESS_KEY_ ,PARENT_ID_ ,PROC_DEF_ID_ ,SUPER_EXEC_,ROOT_PROC_INST_ID_ ,ACT_ID_ from act_ru_execution;
    +--------+------+---------------+---------------+------------+----------------------+-------------+--------------------+--------------------------------+
    | ID_    | REV_ | PROC_INST_ID_ | BUSINESS_KEY_ | PARENT_ID_ | PROC_DEF_ID_         | SUPER_EXEC_ | ROOT_PROC_INST_ID_ | ACT_ID_                        |
    +--------+------+---------------+---------------+------------+----------------------+-------------+--------------------+--------------------------------+
    | 222505 |    1 | 222505        | businessKey1  | NULL       | testProcess:1:222504 | NULL        | 222505             | NULL                           |
    | 222507 |    1 | 222505        | NULL          | 222505     | testProcess:1:222504 | NULL        | 222505             | messageintermediatecatchevent1 |
    | 222511 |    1 | 222511        | businessKey2  | NULL       | testProcess:1:222504 | NULL        | 222511             | NULL                           |
    | 222513 |    1 | 222511        | NULL          | 222511     | testProcess:1:222504 | NULL        | 222511             | messageintermediatecatchevent1 |
    | 222517 |    1 | 222517        | businessKey3  | NULL       | testProcess:1:222504 | NULL        | 222517             | NULL                           |
    | 222520 |    1 | 222517        | NULL          | 222517     | testProcess:1:222504 | NULL        | 222517             | messageintermediatecatchevent1 |
    +--------+------+---------------+---------------+------------+----------------------+-------------+--------------------+--------------------------------+
    6 rows in set (0.00 sec)
    
    
    mysql> select * from act_ru_event_subscr;
    +--------+------+-------------+-------------+---------------+---------------+--------------------------------+----------------+-------------------------+----------------------+------------+
    | ID_    | REV_ | EVENT_TYPE_ | EVENT_NAME_ | EXECUTION_ID_ | PROC_INST_ID_ | ACTIVITY_ID_                   | CONFIGURATION_ | CREATED_                | PROC_DEF_ID_         | TENANT_ID_ |
    +--------+------+-------------+-------------+---------------+---------------+--------------------------------+----------------+-------------------------+----------------------+------------+
    | 222510 |    1 | message     | messageName | 222507        | 222505        | messageintermediatecatchevent1 | NULL           | 2020-04-25 20:30:43.428 | testProcess:1:222504 |            |
    | 222516 |    1 | message     | messageName | 222513        | 222511        | messageintermediatecatchevent1 | NULL           | 2020-04-25 20:30:43.595 | testProcess:1:222504 |            |
    | 222523 |    1 | message     | messageName | 222520        | 222517        | messageintermediatecatchevent1 | NULL           | 2020-04-25 20:30:43.647 | testProcess:1:222504 |            |
    +--------+------+-------------+-------------+---------------+---------------+--------------------------------+----------------+-------------------------+----------------------+------------+
    3 rows in set (0.00 sec)
    
    
    mysql> select * from act_ru_variable;
    +--------+------+---------+-------+---------------+---------------+----------+---------------+---------+-------+---------+--------+
    | ID_    | REV_ | TYPE_   | NAME_ | EXECUTION_ID_ | PROC_INST_ID_ | TASK_ID_ | BYTEARRAY_ID_ | DOUBLE_ | LONG_ | TEXT_   | TEXT2_ |
    +--------+------+---------+-------+---------------+---------------+----------+---------------+---------+-------+---------+--------+
    | 222506 |    1 | integer | days  | 222505        | 222505        | NULL     | NULL          |    NULL |     5 | 5       | NULL   |
    | 222512 |    1 | integer | days  | 222511        | 222511        | NULL     | NULL          |    NULL |     6 | 6       | NULL   |
    | 222518 |    1 | string  | name  | 222517        | 222517        | NULL     | NULL          |    NULL |  NULL | crazyit | NULL   |
    | 222519 |    1 | integer | days  | 222517        | 222517        | NULL     | NULL          |    NULL |     7 | 7       | NULL   |
    +--------+------+---------+-------+---------------+---------------+----------+---------------+---------+-------+---------+--------+
             **********************************************************/
    
            // 使用执行流查询方法
            List<Execution> exes = runtimeService.createExecutionQuery()
                    .processDefinitionKey("testProcess").list();
            log.info("使用processDefinitionKey方法查询执行流：" + exes.size());
            exes = runtimeService.createExecutionQuery()
                    .processInstanceBusinessKey("businessKey1").list();
            log.info("使用processInstanceBusinessKey方法查询执行流：" + exes.size());
            exes = runtimeService.createExecutionQuery()
                    .messageEventSubscriptionName("messageName").list();
            log.info("使用messageEventSubscriptionName方法查询执行流：" + exes.size());
            // 根据节点id属性查询当前的执行流
            Execution exe = runtimeService.createExecutionQuery()
                    .activityId("messageintermediatecatchevent1")
                    .processInstanceId(pi1.getId()).singleResult();
            log.info("使用activityId和processInstanceId方法查询执行流，得到执行ID：" + exe.getId());
            //让流程往下执行
            runtimeService.messageEventReceived("messageName", exe.getId());
    
            /***********************************************************
    mysql> select ID_, REV_,PROC_INST_ID_ ,BUSINESS_KEY_ ,PARENT_ID_ ,PROC_DEF_ID_ ,SUPER_EXEC_,ROOT_PROC_INST_ID_ ,ACT_ID_ from act_ru_execution;
    +--------+------+---------------+---------------+------------+----------------------+-------------+--------------------+--------------------------------+
    | ID_    | REV_ | PROC_INST_ID_ | BUSINESS_KEY_ | PARENT_ID_ | PROC_DEF_ID_         | SUPER_EXEC_ | ROOT_PROC_INST_ID_ | ACT_ID_                        |
    +--------+------+---------------+---------------+------------+----------------------+-------------+--------------------+--------------------------------+
    | 222505 |    1 | 222505        | businessKey1  | NULL       | testProcess:1:222504 | NULL        | 222505             | NULL                           |
    | 222507 |    2 | 222505        | NULL          | 222505     | testProcess:1:222504 | NULL        | 222505             | signalintermediatecatchevent1  |
    | 222511 |    1 | 222511        | businessKey2  | NULL       | testProcess:1:222504 | NULL        | 222511             | NULL                           |
    | 222513 |    1 | 222511        | NULL          | 222511     | testProcess:1:222504 | NULL        | 222511             | messageintermediatecatchevent1 |
    | 222517 |    1 | 222517        | businessKey3  | NULL       | testProcess:1:222504 | NULL        | 222517             | NULL                           |
    | 222520 |    1 | 222517        | NULL          | 222517     | testProcess:1:222504 | NULL        | 222517             | messageintermediatecatchevent1 |
    +--------+------+---------------+---------------+------------+----------------------+-------------+--------------------+--------------------------------+
    
    mysql> select * from act_ru_event_subscr;
    +--------+------+-------------+-------------+---------------+---------------+--------------------------------+----------------+-------------------------+----------------------+------------+
    | ID_    | REV_ | EVENT_TYPE_ | EVENT_NAME_ | EXECUTION_ID_ | PROC_INST_ID_ | ACTIVITY_ID_                   | CONFIGURATION_ | CREATED_                | PROC_DEF_ID_         | TENANT_ID_ |
    +--------+------+-------------+-------------+---------------+---------------+--------------------------------+----------------+-------------------------+----------------------+------------+
    | 222516 |    1 | message     | messageName | 222513        | 222511        | messageintermediatecatchevent1 | NULL           | 2020-04-25 20:30:43.595 | testProcess:1:222504 |            |
    | 222523 |    1 | message     | messageName | 222520        | 222517        | messageintermediatecatchevent1 | NULL           | 2020-04-25 20:30:43.647 | testProcess:1:222504 |            |
    | 222525 |    1 | signal      | signalName  | 222507        | 222505        | signalintermediatecatchevent1  | NULL           | 2020-04-25 20:45:13.063 | testProcess:1:222504 |            |
    +--------+------+-------------+-------------+---------------+---------------+--------------------------------+----------------+-------------------------+----------------------+------------+
             **********************************************************/
    
            exes = runtimeService.createExecutionQuery().signalEventSubscriptionName("signalName").list();
            log.info("使用signalEventSubscriptionName方法查询执行流：" + exes.size());
            // 根据参数查询执行流
            exes = runtimeService.createExecutionQuery().variableValueEquals("name", "crazyit").list();
            log.info("使用variableValueEquals方法查询执行流：" + exes.size());
            exes = runtimeService.createExecutionQuery().variableValueGreaterThan("days", NUM5).list();
            log.info("使用variableValueGreaterThan方法查询执行流：" + exes.size());
            exes = runtimeService.createExecutionQuery().variableValueGreaterThanOrEqual("days", NUM5).list();
            log.info("使用variableValueGreaterThanOrEqual方法查询执行流：" + exes.size());
            exes = runtimeService.createExecutionQuery().variableValueLessThan("days", NUM6).list();
            log.info("使用variableValueLessThan方法查询执行流：" + exes.size());
            exes = runtimeService.createExecutionQuery().variableValueLessThanOrEqual("days", NUM6).list();
            log.info("使用variableValueLessThanOrEqual方法查询执行流：" + exes.size());
            exes = runtimeService.createExecutionQuery().variableValueLike("name", "%crazy%").list();
            log.info("使用variableValueLike方法查询执行流：" + exes.size());
            exes = runtimeService.createExecutionQuery().variableValueNotEquals("days", NUM8).list();
            log.info("使用variableValueNotEquals方法查询执行流：" + exes.size());
        }
    }

**二 测试**

使用processDefinitionKey方法查询执行流：6
    使用processInstanceBusinessKey方法查询执行流：1
    使用messageEventSubscriptionName方法查询执行流：3
    使用activityId和processInstanceId方法查询执行流，得到执行ID：222507
    使用signalEventSubscriptionName方法查询执行流：1
    使用variableValueEquals方法查询执行流：1
    使用variableValueGreaterThan方法查询执行流：2
    使用variableValueGreaterThanOrEqual方法查询执行流：3
    使用variableValueLessThan方法查询执行流：1
    使用variableValueLessThanOrEqual方法查询执行流：2
    使用variableValueLike方法查询执行流：1
    使用variableValueNotEquals方法查询执行流：3