【2023最新Activiti7全网最全】4、Activiti7进阶篇

爱被打了一巴掌 2024-03-25 17:48 36阅读 0赞

### 1.流程实例 ###

#### 1.1 什么是流程实例 ####

流程实例(ProcessInstance)代表流程定义的执行实例,一个流程实例包括了所有的运行节点，我们可以利用这个对象来了解当前流程实例的进度等信息  
  例如：用户或者程序安装流程定义的内容发起了一个流程，这个就是一个流程实例

![3c905bee5bec4f2383660cb6da13762a.png][]

#### 1.2 业务管理 ####

流程定义部署在Activiti后，我们就可以在系统中通过Activiti去管理流程的执行，但是如果我们要将我们的流程实例和业务数据关联，这时我们需要使用到Activiti中预留的BusinessKey(业务标识)来关联

![1ac2e281c385462e9e0a1478e6b77f4f.png][]

实现代码：

/**
         * 启动流程实例，添加businessKey
         */
        @Test
        public void test01(){
            // 1.获取ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            // 2.获取RuntimeService对象
            RuntimeService runtimeService = processEngine.getRuntimeService();
            // 3.启动流程实例
            ProcessInstance instance = runtimeService
                    .startProcessInstanceByKey("evection", "1001");
            // 4.输出processInstance相关属性
            System.out.println("businessKey = "+instance.getBusinessKey());
        }

![50c5790fe8264fd4bd655d77c55bb4bd.png][]

#### 1.3 流程实例的挂起和激活 ####

在实际场景中可能由于流程变更需要将当前运行的流程暂停而不是删除，流程暂停后将不能继续执行。

**1.3.1 全部流程挂起**

操作流程的定义为挂起状态，该流程定义下边所有的流程实例全部暂停。

流程定义为挂起状态，该流程定义将不允许启动新的流程实例，同时该流程定义下的所有的流程实例都将全部挂起暂停执行。

/**
         * 全部流程挂起实例与激活
         */
        @Test
        public void test02(){
           // 1.获取ProcessEngine对象
            ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
            // 2.获取RepositoryService对象
            RepositoryService repositoryService = engine.getRepositoryService();
            // 3.查询流程定义的对象
            ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery()
                    .processDefinitionKey("evection")
                    .singleResult();
            // 4.获取当前流程定义的状态
            boolean suspended = processDefinition.isSuspended();
            String id = processDefinition.getId();
            // 5.如果挂起就激活，如果激活就挂起
            if(suspended){
                // 表示当前定义的流程状态是 挂起的
                repositoryService.activateProcessDefinitionById(
                        id // 流程定义的id
                ,true // 是否激活
                ,null // 激活时间
                );
                System.out.println("流程定义：" + id + ",已激活");
            }else{
                // 非挂起状态，激活状态 那么需要挂起流程定义
                repositoryService.suspendProcessDefinitionById(
                        id // 流程id
                        ,true // 是否挂起
                        ,null // 挂起时间
                );
                System.out.println("流程定义：" + id + ",已挂起");
            }
        }

挂起流程定义后，对于的实例对象中的状态会修改为2

![9a717b2df745427a9fee828619ee0f99.png][]

然后再去操作对于的流程实例会抛异常信息

![82b237cb73a948ca968ba79977eb3dcf.png][]

我们再将挂起的流程转变为激活状态，对于的状态值会从2更新为1

![93decf22ef844d8db15d012541a056ed.png][]

然后就是业务流程可以正常处理了

**1.3.2 单个实例挂起**

操作流程实例对象，针对单个流程执行挂起操作，某个流程实例挂起则此流程不再继续执行，当前流程定义的其他流程实例是不受干扰的。完成该流程实例的当前任务会抛异常

/**
         * 单个流程实例挂起与激活
         */
        @Test
        public void test03(){
            // 1.获取ProcessEngine对象
            ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
            // 2.获取RuntimeService
            RuntimeService runtimeService = engine.getRuntimeService();
            // 3.获取流程实例对象
            ProcessInstance processInstance = runtimeService.createProcessInstanceQuery()
                    .processInstanceId("25001")
                    .singleResult();
            // 4.获取相关的状态操作
            boolean suspended = processInstance.isSuspended();
            String id = processInstance.getId();
            if(suspended){
                // 挂起--》激活
                runtimeService.activateProcessInstanceById(id);
                System.out.println("流程定义：" + id + "，已激活");
            }else{
                // 激活--》挂起
                runtimeService.suspendProcessInstanceById(id);
                System.out.println("流程定义：" + id + "，已挂起");
            }
    
        }

然后我们可以在数据库中查看到状态的更新

![2ff5c968a65c453c96a56e0c50ac8490.png][]

**2. 个人任务**

#### 2.1 分配任务责任人 ####

2.1.1 固定分配

在进行业务流程建模的时候指定固定的任务负责人：

![db14119dd66e46208f5bd246bcd65abd.png][]

在Properties视图中，填写Assiginee项为任务负责人

**2.1.2 表达式分配**

在Activiti中支持使用UEL表达式，UEL表达式是Java EE6 规范的一部分， UEL(Unified Expression Language) 即 统一表达式语音， Activiti支持两种UEL表达式： UEL-value 和UEL-method

**UEL-value**

![d91ae095fdea4904b5c6b27dabc2dd2c.png][]

在assignee中使用流程变量处理

![a2e9c8e651824af2a76d74e4ea562d3a.png][]

![39802f5a877d4df0bfa1352b78abc664.png][]

![2aeed02a39724cd18555ad778567cc10.png][]

![8bf82f6c77eb4e25aec0afb1ac935a96.png][]

然后我们可以来操作

首先我们需要将定义的流程部署到Activiti数据库中

/**
         * 先将新定义的流程部署到Activiti中数据库中
         */
        @Test
        public void test01(){
            // 1.获取ProcessEngine对象
            ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
            // 2.获取RepositoryService进行部署操作
            RepositoryService service = engine.getRepositoryService();
            // 3.使用RepositoryService进行部署操作
            Deployment deploy = service.createDeployment()
                    .addClasspathResource("bpmn/evection-uel.bpmn") // 添加bpmn资源
                    .addClasspathResource("bpmn/evection-uel.png") // 添加png资源
                    .name("出差申请流程-UEL")
                    .deploy();// 部署流程
            // 4.输出流程部署的信息
            System.out.println("流程部署的id:" + deploy.getId());
            System.out.println("流程部署的名称：" + deploy.getName());
        }

部署成功后我们需要启动一个新的流程实例，然后在流程实例创建的其实关联UEL表达式

/**
         * 创建一个流程实例
         *    给流程定义中的 UEL表达式赋值
         */
        @Test
        public void test02(){
          // 获取流程引擎
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            // 获取RuntimeService对象
            RuntimeService runtimeService = processEngine.getRuntimeService();
            // 设置 assignee 的取值，
            Map<String,Object> map = new HashMap<>();
            map.put("assignee0","张三");
            map.put("assignee1","李四");
            map.put("assignee2","王五");
            map.put("assignee3","赵财务");
            // 创建流程实例
            runtimeService.startProcessInstanceByKey("evection-uel",map);
        }

启动成功后我们在 act\_ru\_variable中可以看到UEL表达式对应的赋值信息

![463d073537bc469fb211e7ceac4a3587.png][]

UEL-method

![6bb830d4bc73448488edeb302bc46b84.png][]

userBean 是 spring 容器中的一个 bean，表示调用该 bean 的 getUserId()方法。

**UEL-method 与 UEL-value 结合**

再比如：  
$\{ldapService.findManagerForEmployee(emp)\}  
ldapService 是 spring 容器的一个 bean，findManagerForEmployee 是该 bean 的一个方法，emp 是 activiti  
流程变量， emp 作为参数传到 ldapService.findManagerForEmployee 方法中。  
**其它**

表达式支持解析基础类型、 bean、 list、 array 和 map，也可作为条件判断。  
  如下：  
  $\{order.price > 100 && order.price < 250\}

**2.1.3 监听器分配**

可以使用监听器来完成很多Activiti的流程业务。我们在此处使用监听器来完成负责人的指定，那么我们在流程设计的时候就不需要指定assignee

Event选项

![51d565f0c2bd4e58a4b88965be4bb192.png][]

> create:任务创建后触发  
> assignment:任务分配后触发  
> Delete:任务完成后触发  
> All：所有事件都触发

自定义的监听器

import org.activiti.engine.delegate.DelegateTask;
    import org.activiti.engine.delegate.TaskListener;
    
    public class MyTaskListener implements TaskListener {
        @Override
        public void notify(DelegateTask delegateTask) {
            if("创建请假单".equals(delegateTask.getName())
            && "create".equals(delegateTask.getEventName())){
                // 指定任务的负责人
                delegateTask.setAssignee("张三-Listener");
            }
    
        }
    }

测试代码

/**
     * 先将新定义的流程部署到Activiti中数据库中
     */
    @Test
    public void test01(){
        // 1.获取ProcessEngine对象
        ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
        // 2.获取RepositoryService进行部署操作
        RepositoryService service = engine.getRepositoryService();
        // 3.使用RepositoryService进行部署操作
        Deployment deploy = service.createDeployment()
                .addClasspathResource("bpmn/evection-listener.bpmn") // 添加bpmn资源
                .addClasspathResource("bpmn/evection-listener.png") // 添加png资源
                .name("出差申请流程-UEL")
                .deploy();// 部署流程
        // 4.输出流程部署的信息
        System.out.println("流程部署的id:" + deploy.getId());
        System.out.println("流程部署的名称：" + deploy.getName());
    }
    
    /**
     * 创建一个流程实例
     *    给流程定义中的 UEL表达式赋值
     */
    @Test
    public void test02(){
      // 获取流程引擎
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        // 获取RuntimeService对象
        RuntimeService runtimeService = processEngine.getRuntimeService();
    
        // 创建流程实例
        runtimeService.startProcessInstanceByKey("evection-listener");
    }

![62b605fc79a2483cbbbda3537e84e4af.png][]

![db67280b00a1419a88847ddc08dd9a81.png][]

**2.2 查询任务**

**查询任务负责人的待办任务**

代码如下：

// 查询当前个人待执行的任务
    @Test
    public void findPersonalTaskList() {
        // 流程定义key
        String processDefinitionKey = "myEvection1";
        // 任务负责人
        String assignee = "张三";
        // 获取TaskService
        TaskService taskService = processEngine.getTaskService();
        List<Task> taskList = taskService.createTaskQuery()
        	.processDefinitionKey(processDefinitionKey)
        	.includeProcessVariables()
            .taskAssignee(assignee)
            .list();
        for (Task task : taskList) {
            System.out.println("----------------------------");
            System.out.println("流程实例id： " + task.getProcessInstanceId());
            System.out.println("任务id： " + task.getId());
            System.out.println("任务负责人： " + task.getAssignee());
            System.out.println("任务名称： " + task.getName());
        }
    }

**关联 businessKey**

需求：  
  在 activiti 实际应用时，查询待办任务可能要显示出业务系统的一些相关信息。

比如：查询待审批出差任务列表需要将出差单的日期、 出差天数等信息显示出来。

出差天数等信息在业务系统中存在，而并没有在 activiti 数据库中存在，所以是无法通过 activiti 的 api 查询到出差天数等信息。  
实现：  
  在查询待办任务时，通过 businessKey（业务标识 ）关联查询业务系统的出差单表，查询出出差天数等信息。

@Test
        public void findProcessInstance(){
    //        获取processEngine
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    //        获取TaskService
            TaskService taskService = processEngine.getTaskService();
    //        获取RuntimeService
            RuntimeService runtimeService = processEngine.getRuntimeService();
    //        查询流程定义的对象
            Task task = taskService.createTaskQuery()
                    .processDefinitionKey("myEvection1")
                    .taskAssignee("张三")
                    .singleResult();
    //        使用task对象获取实例id
            String processInstanceId = task.getProcessInstanceId();
    //          使用实例id，获取流程实例对象
            ProcessInstance processInstance = runtimeService.createProcessInstanceQuery()
                    .processInstanceId(processInstanceId)
                    .singleResult();
    //        使用processInstance，得到 businessKey
            String businessKey = processInstance.getBusinessKey();
    
            System.out.println("businessKey=="+businessKey);
    
        }

**2.3 办理任务**

注意：在实际应用中，完成任务前需要校验任务的负责人是否具有该任务的办理权限 。

/**
         * 完成任务，判断当前用户是否有权限
         */
        @Test
        public void completTask() {
            //任务id
            String taskId = "15005";
    //        任务负责人
            String assingee = "张三";
            //获取processEngine
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            // 创建TaskService
            TaskService taskService = processEngine.getTaskService();
    //        完成任务前，需要校验该负责人可以完成当前任务
    //        校验方法：
    //        根据任务id和任务负责人查询当前任务，如果查到该用户有权限，就完成
            Task task = taskService.createTaskQuery()
                    .taskId(taskId)
                    .taskAssignee(assingee)
                    .singleResult();
            if(task != null){
                taskService.complete(taskId);
                System.out.println("完成任务");
            }
        }

**3.流程变量**  
**3.1、什么是流程变量**  
  流程变量在 activiti 中是一个非常重要的角色，流程运转有时需要靠流程变量，业务系统和 activiti结合时少不了流程变量，流程变量就是 activiti 在管理工作流时根据管理需要而设置的变量。比如：在出差申请流程流转时如果出差天数大于 3 天则由总经理审核，否则由人事直接审核， 出差天数就可以设置为流程变量，在流程流转时使用。

**注意：虽然流程变量中可以存储业务数据可以通过activiti的api查询流程变量从而实现 查询业务数据，但是不建议这样使用，因为业务数据查询由业务系统负责，activiti设置流程变量是为了流程执行需要而创建。**

**3.2、流程变量类型**  
  如果将 pojo 存储到流程变量中，必须实现序列化接口 serializable，为了防止由于新增字段无法反序列化，需要生成 serialVersionUID。  
![a0a9c69afc0d4fb2b0c4824945e542a5.png][]

**3.3、流程变量作用域**  
  流程变量的作用域可以是一个流程实例(processInstance)，或一个任务(task)，或一个执行实例  
(execution)

**3.3.1、globa变量**  
  流程变量的默认作用域是流程实例。当一个流程变量的作用域为流程实例时，可以称为 global 变量

注意：

如： Global变量：userId（变量名）、zhangsan（变量值）

global 变量中变量名不允许重复，设置相同名称的变量，后设置的值会覆盖前设置的变量值。

**3.3.2、local变量**  
  任务和执行实例仅仅是针对一个任务和一个执行实例范围，范围没有流程实例大， 称为 local 变量。Local 变量由于在不同的任务或不同的执行实例中，作用域互不影响，变量名可以相同没有影响。Local 变量名也可以和 global 变量名相同，没有影响。

**3.4、流程变量的使用方法**  
**3.4.1、在属性上使用UEL表达式**  
  可以在 assignee 处设置 UEL 表达式，表达式的值为任务的负责人，比如： $\{assignee\}， assignee 就是一个流程变量名称。

Activiti获取UEL表达式的值，即流程变量assignee的值 ，将assignee的值作为任务的负责人进行任务分配

**3.4.2、在连线上使用UEL表达式**  
  可以在连线上设置UEL表达式，决定流程走向。比如：$\{price<10000\} 。price就是一个流程变量名称，uel表达式结果类型为布尔类型。如果UEL表达式是true，要决定 流程执行走向。

**3.5 流程变量使用**  
**3.5.1 需求**  
  员工创建出差申请单，由部门经理审核，部门经理申请通过后3天以下由财务直接申批，3天以上先由总经理审批，总经理审批通过后再由财务审批。

![12c7db02369e449fa5d1b4e854eedb3c.png][]

**3.5.2 流程定义**

先通过UEL-value来设置负责人

![1df35f871efb4345b818ebe1203cdaae.png][]

然后在分支线上来设置条件

![cf217dbb6937421b86f93d7d4e06a879.png][] 那么还可以通过对象参数命名，比如 evection.num:

![fde1a8a282df4b9a933ec1680c984e13.png][]

另一根线对应的设置

![8e531e4681be4068a8ce00bf4d773047.png][]

![960c7f87344147a3a44b965b6b7a6e01.png][]

然后可以将相关的资源文件拷贝到项目中，

**3.5.3 使用Global变量**

接下来使用Global变量控制流程

**3.5.3.1 POJO创建**

首先创建POJO对象

/**
     * 出差申请的POJO对象
     */
    @Data
    public class Evection {
    
        private long id;
    
        private String evectionName;
    
    
        /**
         * 出差的天数
         */
        private double num;
    
        private Date beginDate;
    
        private Date endDate;
    
        private String destination;
    
        private String reson;
    }

**3.5.3.2 流程的部署**

/**
         * 部署流程
         */
        @Test
        public void test01(){
            // 1.获取ProcessEngine对象
            ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
            // 2.获取RepositoryService进行部署操作
            RepositoryService service = engine.getRepositoryService();
            // 3.使用RepositoryService进行部署操作
            Deployment deploy = service.createDeployment()
                    .addClasspathResource("bpmn/evection-variable.bpmn") // 添加bpmn资源
                    .addClasspathResource("bpmn/evection-variable.png") // 添加png资源
                    .name("出差申请流程-流程变量")
                    .deploy();// 部署流程
            // 4.输出流程部署的信息
            System.out.println("流程部署的id:" + deploy.getId());
            System.out.println("流程部署的名称：" + deploy.getName());
        }

**3.5.3.3 设置流程变量**

**a.启动时设置流程变量**

在启动流程时设置流程变量，变量的作用域是整个流程实例。

完成任务

/**
         * 完成任务
         */
        @Test
        public void test03(){
            String key = "evection-variable";
            String assignee = "李四1";
            ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = engine.getTaskService();
            Task task = taskService.createTaskQuery()
                    .processDefinitionKey(key)
                    .taskAssignee(assignee)
                    .singleResult();
            if(task != null){
                taskService.complete(task.getId());
                System.out.println("任务执行完成...");
            }
        }

通过startProcessInstanceByKey方法设置流程变量的作用域是一个流程实例，流程变量使用Map存储，同一个流程实例map中的key相同，后者会覆盖前者

**b.任务办理时设置**  
  在完成任务时设置流程变量，该流程变量只有在该任务完成后其它结点才可使用该变量，它的作用域是整个流程实例，如果设置的流程变量的key在流程实例中已存在相同的名字则后设置的变量替换前边设置的变量。

这里需要在创建出差单任务完成时设置流程变量

/**
         * 启动流程实例，设置流程变量
         */
        @Test
        public void test02(){
            ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
            RuntimeService runtimeService = engine.getRuntimeService();
            // 流程定义key
            String key = "evection-variable";
            // 创建变量集合
            Map<String,Object> variables = new HashMap<>();
            
            // 设置assignee的取值
            variables.put("assignee0","张三1");
            variables.put("assignee1","李四1");
            variables.put("assignee2","王五1");
            variables.put("assignee3","赵财务1");
            ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(key, variables);
            // 输出信息
            System.out.println("获取流程实例名称："+processInstance.getName());
            System.out.println("流程定义ID：" + processInstance.getProcessDefinitionId());
        }
    
        /**
         * 完成任务
         */
        @Test
        public void test03(){
            String key = "evection-variable";
            String assignee = "李四1";
            ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = engine.getTaskService();
            Task task = taskService.createTaskQuery()
                    .processDefinitionKey(key)
                    .taskAssignee(assignee)
                    .singleResult();
    
            Map<String,Object> variables = new HashMap<>();
            // 创建出差对象 POJO
            Evection evection = new Evection();
            // 设置出差天数
            evection.setNum(4d);
            // 定义流程变量到集合中
            variables.put("evection",evection);
    
            if(task != null){
                taskService.complete(task.getId(),variables);
                System.out.println("任务执行完成...");
            }
        }

说明：  
通过当前任务设置流程变量，需要指定当前任务id，如果当前执行的任务id不存在则抛出异常。  
任务办理时也是通过map<key,value>设置流程变量，一次可以设置多个变量。

**c.当前流程实例设置**

通过流程实例id设置全局变量，该流程实例必须未执行完成。

@Test
        public void setGlobalVariableByExecutionId(){
    //    当前流程实例执行 id，通常设置为当前执行的流程实例
            String executionId="2601";
    //     获取processEngine
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    //        获取RuntimeService
            RuntimeService runtimeService = processEngine.getRuntimeService();
    //        创建出差pojo对象
            Evection evection = new Evection();
    //        设置天数
            evection.setNum(3d);
    //      通过流程实例 id设置流程变量
            runtimeService.setVariable(executionId, "evection", evection);
    //      一次设置多个值
    //      runtimeService.setVariables(executionId, variables)
        }

注意：  
  executionId必须当前未结束 流程实例的执行id，通常此id设置流程实例 的id。也可以通runtimeService.getVariable()获取流程变量。

**d.当前任务设置**

@Test
    	public void setGlobalVariableByTaskId(){
    		
    		//当前待办任务id
    		String taskId="1404";
    //     获取processEngine
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    		TaskService taskService = processEngine.getTaskService();
    		Evection evection = new Evection();
    		evection.setNum(3);
    		//通过任务设置流程变量
    		taskService.setVariable(taskId, "evection", evection);
    		//一次设置多个值 
    		//taskService.setVariables(taskId, variables)
    	}

注意：  
  任务id必须是当前待办任务id，act\_ru\_task中存在。如果该任务已结束，会报错也可以通过taskService.getVariable()获取流程变量。

**3.5.4 设置local流程变量**  
**3.5.4.1、任务办理时设置**  
  任务办理时设置local流程变量，当前运行的流程实例只能在该任务结束前使用，任务结束该变量无法在当前流程实例使用，可以通过查询历史任务查询。

/*
    *处理任务时设置local流程变量
    */
    @Test
    public void completTask() {
       //任务id
       String taskId = "1404";
    //  获取processEngine
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        TaskService taskService = processEngine.getTaskService();
    //  定义流程变量
       Map<String, Object> variables = new HashMap<String, Object>();
       Evection evection = new Evection ();
       evection.setNum(3d);
    // 定义流程变量
       Map<String, Object> variables = new HashMap<String, Object>();
    //  变量名是holiday，变量值是holiday对象
        variables.put("evection", evection);
    //  设置local变量，作用域为该任务
        taskService.setVariablesLocal(taskId, variables);
    //  完成任务
       taskService.complete(taskId);
    }

说明：  
  设置作用域为任务的local变量，每个任务可以设置同名的变量，互不影响。

**3.5.4.2、通过当前任务设置**

@Test
    public void setLocalVariableByTaskId(){
    //   当前待办任务id
        String taskId="1404";
    //  获取processEngine
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        TaskService taskService = processEngine.getTaskService();
        Evection evection = new Evection ();
        evection.setNum(3d);
    //  通过任务设置流程变量
        taskService.setVariableLocal(taskId, "evection", evection);
    //  一次设置多个值 
        //taskService.setVariablesLocal(taskId, variables)
    }

注意：  
  任务id必须是当前待办任务id，act\_ru\_task中存在。

**3.5.4.3、 Local变量测试1**  
  如果上边例子中设置global变量改为设置local变量是否可行？为什么？  
  Local变量在任务结束后无法在当前流程实例执行中使用，如果后续的流程执行需要用到此变量则会报错。

**3.5.4.4、 Local变量测试2**  
  在部门经理审核、总经理审核、财务审核时设置local变量，可通过historyService查询每个历史任务时将流程变量的值也查询出来。

代码如下：

// 创建历史任务查询对象
          HistoricTaskInstanceQuery historicTaskInstanceQuery = historyService.createHistoricTaskInstanceQuery();
          // 查询结果包括 local变量
          historicTaskInstanceQuery.includeTaskLocalVariables();
    for (HistoricTaskInstance historicTaskInstance : list) {
             System.out.println("==============================");
             System.out.println("任务id：" + historicTaskInstance.getId());
             System.out.println("任务名称：" + historicTaskInstance.getName());
             System.out.println("任务负责人：" + historicTaskInstance.getAssignee());
         System.out.println("任务local变量："+ historicTaskInstance.getTaskLocalVariables());
    
    }

注意：查询历史流程变量，特别是查询pojo变量需要经过反序列化，不推荐使用。

**4.组任务  
4.1、需求**  
  在流程定义中在任务结点的 assignee 固定设置任务负责人，在流程定义时将参与者固定设置在.bpmn 文件中，如果临时任务负责人变更则需要修改流程定义，系统可扩展性差。  
  针对这种情况可以给任务设置多个候选人，可以从候选人中选择参与者来完成任务。

**4.2、设置任务候选人**  
  在流程图中任务节点的配置中设置 candidate-users(候选人)，多个候选人之间用逗号分开。  
![627a88e99a74482f877eb838e35bf3dc.png][]

查看bpmn文件

> <userTask activiti:candidateUsers="lisi,wangwu" activiti:exclusive="true" id="\_3" name="经理审批"/>

我们可以看到部门经理的审核人已经设置为 lisi,wangwu 这样的一组候选人，可以使用activiti:candiateUsers=”用户 1,用户 2,用户 3”的这种方式来实现设置一组候选人

**4.3、组任务  
4.3.1、组任务办理流程**  
**a、查询组任务**  
  指定候选人，查询该候选人当前的待办任务。候选人不能立即办理任务。

**b、拾取(claim)任务**  
  该组任务的所有候选人都能拾取。将候选人的组任务，变成个人任务。原来候选人就变成了该任务的负责人。如果拾取后不想办理该任务？需要将已经拾取的个人任务归还到组里边，将个人任务变成了组任务。

**c、查询个人任务**  
  查询方式同个人任务部分，根据assignee查询用户负责的个人任务。

**d、办理个人任务  
4.3.2、 查询组任务**  
   根据候选人查询组任务

/**
         * 查询组任务
         */
        @Test
        public void test03(){
            String key = "evection1";
            String candidateUser = "lisi";
            ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = engine.getTaskService();
            List<Task> list = taskService.createTaskQuery()
                    .processDefinitionKey(key)
                    .taskCandidateUser(candidateUser)
                    .list();
            for (Task task : list) {
                System.out.println("流程实例Id：" + task.getProcessInstanceId());
                System.out.println("任务ID：" + task.getId());
                System.out.println("负责人:" + task.getAssignee());
                System.out.println("任务名称：" + task.getName());
            }
        }

**4.3.3 、 拾取组任务**

候选人员拾取组任务后该任务变为自己的个人任务。

/**
         * 候选人 拾取任务
         */
        @Test
        public void test04(){
            ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = engine.getTaskService();
            String taskId = "72505";
            // 候选人
            String userId = "lisi";
            // 拾取任务
            Task task = taskService.createTaskQuery()
                    .taskId(taskId)
                    .taskCandidateUser(userId) // 根据候选人查询
                    .singleResult();
            if(task != null){
                // 可以拾取任务
                taskService.claim(taskId,userId);
                System.out.println("拾取成功");
            }
        }

**4.3.4、 查询个人待办任务**

查询方式同个人任务查询

@Test
        public void test03(){
            String key = "evection1";
            String candidateUser = "lisi";
            ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = engine.getTaskService();
            List<Task> list = taskService.createTaskQuery()
                    .processDefinitionKey(key)
                    //.taskCandidateUser(candidateUser)
                    //.taskCandidateOrAssigned(candidateUser)
                    .taskAssignee(candidateUser)
                    .list();
            for (Task task : list) {
                System.out.println("流程实例Id：" + task.getProcessInstanceId());
                System.out.println("任务ID：" + task.getId());
                System.out.println("负责人:" + task.getAssignee());
                System.out.println("任务名称：" + task.getName());
            }
        }

**4.3.5、 办理个人任务**

同个人任务办理

/**
         * 完成个人任务
         */
        @Test
        public void test05(){
            String  taskId = "72505";
            ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = engine.getTaskService();
            taskService.complete(taskId);
            System.out.println("完成任务：" + taskId);
        }

**4.3.6、 归还组任务**

如果个人不想办理该组任务，可以归还组任务，归还后该用户不再是该任务的负责人

/**
         * 归还任务
         */
        @Test
        public void test06(){
            ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = engine.getTaskService();
            String taskId = "75002";
            String userId= "zhangsan";
            Task task = taskService.createTaskQuery()
                    .taskId(taskId)
                    .taskAssignee(userId)
                    .singleResult();
            if(task != null){
                // 如果设置为null，归还组任务，任务没有负责人
                taskService.setAssignee(taskId,null);
            }
        }

**4,3,7 任务交接**

任务负责人将任务交给其他负责人来处理

/**
         * 任务交接
         */
        @Test
        public void test07(){
            ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = engine.getTaskService();
            String taskId = "75002";
            String userId= "zhangsan";
            Task task = taskService.createTaskQuery()
                    .taskId(taskId)
                    .taskAssignee(userId)
                    .singleResult();
            if(task != null){
                // 设置该任务的新的负责人
                taskService.setAssignee(taskId,"赵六");
            }
        }

4.3.8、 数据库表操作

查询当前任务执行表

SELECT * FROM act_ru_task

任务执行表，记录当前执行的任务，由于该任务当前是组任务，所有assignee为空，当拾取任务后该字段就是拾取用户的id,查询任务参与者

SELECT * FROM act_ru_identitylink

任务参与者，记录当前参考任务用户或组，当前任务如果设置了候选人，会向该表插入候选人记录，有几个候选就插入几个与act\_ru\_identitylink对应的还有一张历史表act\_hi\_identitylink，向act\_ru\_identitylink插入记录的同时也会向历史表插入记录。任务完成

**5.网关**  
  网关用来控制流程的流向

**5.1 排他网关ExclusiveGateway  
5.1.1 什么是排他网关：**  
  排他网关，用来在流程中实现决策。 当流程执行到这个网关，所有分支都会判断条件是否为true，如果为true则执行该分支，

注意：排他网关只会选择一个为true的分支执行。如果有两个分支条件都为true，排他网关会选择id值较小的一条分支去执行。

为什么要用排他网关？

不用排他网关也可以实现分支，如：在连线的condition条件上设置分支条件。在连线设置condition条件的缺点：如果条件都不满足，流程就结束了(是异常结束)。如果 使用排他网关决定分支的走向，如下：

![0f9c1cadb567465593a7bfe48eb9f398.png][]

如果从网关出去的线所有条件都不满足则系统抛出异常。

org.activiti.engine.ActivitiException: No outgoing sequence flow of the exclusive gateway 'exclusivegateway1' could be selected for continuing the process
       at org.activiti.engine.impl.bpmn.behavior.ExclusiveGatewayActivityBehavior.leave(ExclusiveGatewayActivityBehavior.java:85)

**5.1.2 流程定义**

排他网关图标，红框内：  
![在这里插入图片描述][20210611203758162.png]

**5.1.3 测试**

在部门经理审核后，走排他网关，从排他网关出来的分支有两条，一条是判断出差天数是否大于3天，另一条是判断出差天数是否小于等于3天。设置分支条件时，如果所有分支条件都不是true，报错：

org.activiti.engine.ActivitiException: No outgoing sequence flow of the exclusive gateway 'exclusivegateway1' could be selected for continuing the process
    
           at org.activiti.engine.impl.bpmn.behavior.ExclusiveGatewayActivityBehavior.leave(ExclusiveGatewayActivityBehavior.java:85)

#### 5.2 并行网关ParallelGateway ####

5.2.1 什么是并行网关

并行网关允许将流程分成多条分支，也可以把多条分支汇聚到一起，并行网关的功能是基于进入和外出顺序流的：

l fork分支：

并行后的所有外出顺序流，为每个顺序流都创建一个并发分支。

l join汇聚：

所有到达并行网关，在此等待的进入分支， 直到所有进入顺序流的分支都到达以后， 流程就会通过汇聚网关。  
注意，如果同一个并行网关有多个进入和多个外出顺序流， 它就同时具有分支和汇聚功能。 这时，网关会先汇聚所有进入的顺序流，然后再切分成多个并行分支。  
**与其他网关的主要区别是，并行网关不会解析条件。** **即使顺序流中定义了条件，也会被忽略。**

![c527e0afc8d04a6a969f98f798608004.png][]

例子：

说明：

技术经理和项目经理是两个execution分支，在act\_ru\_execution表有两条记录分别是技术经理和项目经理，act\_ru\_execution还有一条记录表示该流程实例。待技术经理和项目经理任务全部完成，在汇聚点汇聚，通过parallelGateway并行网关。并行网关在业务应用中常用于会签任务，会签任务即多个参与者共同办理的任务。

5.2.2 流程定义  
  并行网关图标，红框内：

![在这里插入图片描述][20210611203829158.png]  
5.2.3 测试  
  当执行到并行网关数据库跟踪如下：当前任务表：SELECT \* FROM act\_ru\_task

![在这里插入图片描述][20210611203851897.png]  
上图中：有两个任务当前执行。查询流程实例执行表：SELECT \* FROM act\_ru\_execution

![在这里插入图片描述][20210611203903740.png]

上图中，说明当前流程实例有多个分支(两个)在运行。

对并行任务的执行：  
并行任务执行不分前后，由任务的负责人去执行即可。  
执行技术经理任务后，查询当前任务表 SELECT \* FROM act\_ru\_task

![在这里插入图片描述][20210611203918346.png]

已完成的技术经理任务在当前任务表act\_ru\_task\_已被删除。  
在流程实例执行表：SELECT \* FROM act\_ru\_execution有中多个分支存在且有并行网关的汇聚结点。

![在这里插入图片描述][20210611203931754.png]  
有并行网关的汇聚结点：说明有一个分支已经到汇聚，等待其它的分支到达。  
当所有分支任务都完成，都到达汇聚结点后：  
流程实例执行表：SELECT \* FROM act\_ru\_execution，执行流程实例已经变为总经理审批，说明流程执行已经通过并行网关

![在这里插入图片描述][20210611203949354.png]

总结：所有分支到达汇聚结点，并行网关执行完成。

#### 5.3 包含网关InclusiveGateway ####

**5.3.1 什么是包含网关**

包含网关可以看做是排他网关和并行网关的结合体。 和排他网关一样，你可以在外出顺序流上定义条件，包含网关会解析它们。 但是主要的区别是包含网关可以选择多于一条顺序流，这和并行网关一样。  
  包含网关的功能是基于进入和外出顺序流的：

l 分支：

所有外出顺序流的条件都会被解析，结果为true的顺序流会以并行方式继续执行， 会为每个顺序流创建一个分支。

l 汇聚：

所有并行分支到达包含网关，会进入等待状态， 直到每个包含流程token的进入顺序流的分支都到达。 这是与并行网关的最大不同。换句话说，包含网关只会等待被选中执行了的进入顺序流。 在汇聚之后，流程会穿过包含网关继续执行。

**5.3.2 流程定义：**  
  出差申请大于等于3天需要由项目经理审批，小于3天由技术经理审批，出差申请必须经过人事经理审批。  
包含网关图标，红框内：

![在这里插入图片描述][20210611204009314.png]

定义流程：

![62e339f67fab424a9f71be685ade4da5.png][]

注意：通过包含网关的每个分支的连线上设置condition条件。

**5.3.3 测试**  
  如果包含网关设置的条件中，流程变量不存在，报错;

org.activiti.engine.ActivitiException: Unknown property used in expression: ${evection.num>=3}

需要在流程启动时设置流程变量evection.num。

1）、当流程执行到第一个包含网关后，会根据条件判断，当前要走哪几个分支：

流程实例执行表：SELECT \* FROM act\_ru\_execution

![在这里插入图片描述][20210611204038806.png]  
第一条记录：包含网关分支。

后两条记录代表两个要执行的分支：  
ACT\_ID = “\_13” 代表 项目经理神品  
ACT\_ID = “\_5” 代表 人事经理审批  
当前任务表：ACT\_RU\_TASK

![在这里插入图片描述][2021061120405650.png]

上图中，项目经理审批、人事经理审批 都是当前的任务，在并行执行。  
如果有一个分支执行先走到汇聚结点的分支，要等待其它执行分支走到汇聚。

2）、先执行项目经理审批，然后查询当前任务表：ACT\_RU\_TASK

![在这里插入图片描述][20210611204115132.png]

当前任务还有人事经理审批需要处理。  
流程实例执行表：SELECT \* FROM act\_ru\_execution

发现人事经理的分支还存在，而项目经理分支已经走到ACT\_ID = \_18的节点。而ACT\_ID=\_\_18就是第二个包含网关这时，因为有2个分支要执行，包含网关会等所有分支走到汇聚才能执行完成。

3）、执行人事经理审批  
然后查询当前任务表：ACT\_RU\_TASK

![在这里插入图片描述][20210611204151386.png]  
  当前任务表已经不是人事经理审批了，说明人事经理审批已经完成。 流程实例执行表：SELECT \* FROM act\_ru\_execution

![在这里插入图片描述][20210611204211522.png]

包含网关执行完成，分支和汇聚就从act\_ru\_execution删除。

小结：在分支时，需要判断条件，**符合条件的分支，将会执行**，符合条件的分支最终才进行汇聚。  
**5.4 事件网关EventGateway**

事件网关允许根据事件判断流向。网关的每个外出顺序流都要连接到一个中间捕获事件。 当流程到达一个基于事件网关，网关会进入等待状态：会暂停执行。与此同时，会为每个外出顺序流创建相对的事件订阅。

事件网关的外出顺序流和普通顺序流不同，这些顺序流不会真的"执行"， 相反它们让流程引擎去决定执行到事件网关的流程需要订阅哪些事件。 要考虑以下条件：

事件网关必须有两条或以上外出顺序流；  
事件网关后，只能使用intermediateCatchEvent类型（activiti不支持基于事件网关后连接ReceiveTask）  
连接到事件网关的中间捕获事件必须只有一个入口顺序流。  
**5.4.1流程定义**

事件网关图标，红框内

![在这里插入图片描述][20210611204230587.png]

intermediateCatchEvent：

![1c04415320194153a5e191fbd7ce7d6d.png][]

intermediateCatchEvent支持的事件类型：  
Message Event: 消息事件  
Singal Event： 信号事件  
Timer Event： 定时事件

![3b7502249266455396b832dfa90c4029.png][]

使用事件网关定义流程：

![06ad3904d2234f37b3fb65088584dbe6.png][]

进阶篇的内容就给大家介绍到这儿了。

[3c905bee5bec4f2383660cb6da13762a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/f1cbaf44fd1f454aad2cb8d47374123e.png
[1ac2e281c385462e9e0a1478e6b77f4f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/9c0044bcfe6c473ca2012548c2502efd.png
[50c5790fe8264fd4bd655d77c55bb4bd.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/b2262c64768c4df5a4c167cb81c8d15b.png
[9a717b2df745427a9fee828619ee0f99.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/e0c1708a428148fb83134429e1730490.png
[82b237cb73a948ca968ba79977eb3dcf.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/dbaffe53544f461b89d3d2e9b0217d15.png
[93decf22ef844d8db15d012541a056ed.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/a3f757ce854243949f3c3f257ee75f1b.png
[2ff5c968a65c453c96a56e0c50ac8490.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/4a45cdae42294e14a557b43a31f4c149.png
[db14119dd66e46208f5bd246bcd65abd.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/fa9eb83e541b44a6855f0a1c21ce1791.png
[d91ae095fdea4904b5c6b27dabc2dd2c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/87a65e7c68134a76b9ca9439d69a2477.png
[a2e9c8e651824af2a76d74e4ea562d3a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/e4b6a6a176694cd390d558880f37b19e.png
[39802f5a877d4df0bfa1352b78abc664.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/a2fc16fccd4c43ce88fb74ba67d8887a.png
[2aeed02a39724cd18555ad778567cc10.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/ef696e18989a46c3a7cb0435c5d2d9f1.png
[8bf82f6c77eb4e25aec0afb1ac935a96.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/8bc4e861aaee4e2094a9d3aa5297e3ab.png
[463d073537bc469fb211e7ceac4a3587.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/2d6beabbf6f848f1846563f8dc609d06.png
[6bb830d4bc73448488edeb302bc46b84.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/0945a750eb1a4b03b7b89f2a4797dbe1.png
[51d565f0c2bd4e58a4b88965be4bb192.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/dd25448d23b7423b93af54d5b8855bb8.png
[62b605fc79a2483cbbbda3537e84e4af.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/85da430e362742a187c1b7ff2b7ce8be.png
[db67280b00a1419a88847ddc08dd9a81.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/3008b4ef140142edb4ca253c5a96130f.png
[a0a9c69afc0d4fb2b0c4824945e542a5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/4344f8a09e624f27ae8911fc0eab737e.png
[12c7db02369e449fa5d1b4e854eedb3c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/1d37f2246b9741d3b2c12e0b45d7977d.png
[1df35f871efb4345b818ebe1203cdaae.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/da6b76461d2541b7921e5c536d37882c.png
[cf217dbb6937421b86f93d7d4e06a879.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/65a4c00df7ae4408b35726b4300bf998.png
[fde1a8a282df4b9a933ec1680c984e13.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/c3395c9e45da44198dc178ac51a8f0d8.png
[8e531e4681be4068a8ce00bf4d773047.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/e5f85918a20d4dc5b6bc498826c413b5.png
[960c7f87344147a3a44b965b6b7a6e01.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/bed27610654b4b968bb95f593276f5be.png
[627a88e99a74482f877eb838e35bf3dc.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/7de3d5d26c37486083be457bde1c0768.png
[0f9c1cadb567465593a7bfe48eb9f398.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/795ce1d326b64bffa07066bc8c18f1a4.png
[20210611203758162.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/6e99a973b0ca47c08d03288d47fe9204.png
[c527e0afc8d04a6a969f98f798608004.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/7621f51618d443999e0ba3a4e0b61ed8.png
[20210611203829158.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/1a02f12fc6c74acc91bbf8eeffaa56a1.png
[20210611203851897.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/a8a5eec80c6b4b65901d3bf72ec8e26b.png
[20210611203903740.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/d0767f571c9d446fba6cc1fee8101a46.png
[20210611203918346.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/7626a9aafa5f455fad74d8c4b44abcbc.png
[20210611203931754.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/bd085e8ac93c4dce96eb813d047ac5a9.png
[20210611203949354.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/d31e67441ff349aead195e8bbdad42db.png
[20210611204009314.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/fb5db3fc17414a47b121ef78c9f52368.png
[62e339f67fab424a9f71be685ade4da5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/19e8e7dea74f4afab876cd964d614ff8.png
[20210611204038806.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/d3d8fecba1df488183ec397bd8c78830.png
[2021061120405650.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/5b1259d359554b6eadab82c859fcbb27.png
[20210611204115132.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/febb7656a3d94e00b2cb974d114969b7.png
[20210611204151386.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/c4c4429e76c5457badd2d20540a7fc57.png
[20210611204211522.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/bf91353130b243868da71231f022875a.png
[20210611204230587.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/5adfc37999d143f2962b06b3c1aab66a.png
[1c04415320194153a5e191fbd7ce7d6d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/ca7920aefcc049fca4d29b9e0cb656f3.png
[3b7502249266455396b832dfa90c4029.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/09c26466fd0844f4a87d9b60e4e01c42.png
[06ad3904d2234f37b3fb65088584dbe6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/65335834378e4cae97c3e8de8d232c10.png