（6）Flowable候选人和候选人组

╰半夏微凉° 2024-03-24 16:01 8阅读 0赞

## 1、候选人 ##

画流程图的时候在“固定值”tab页面指定 候选人。也可以通过“身份存储”tab页面码指定（UI里边的用户）。

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

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

在启动流程之后，发现task中的分配人是个null，分配人得需要从候选人中选择。

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

有如下的是三个候选人。

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

**查询任务**

在启动流程之后，根据登录的用户查询对应可以拾取的任务。

查询张三可以拾取的任务。

**拾取任务**

张三在拾取任务之后，发现分配人变成了张三。

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

一个候选人拾取了任务之后，其他的用户就没有办法拾取这个任务了。  
如果一个用户拾取了任务之后又不想处理了，那么可以退还。

**退还任务**

张三退还任务之后，分配人变成了null，意味着其他用户可以拾取了。

李四拾取任务。

**交接任务**

如果我获取了任务，但是不想执行，那么我可以把这个任务交接给其他的用户。

李四把任务交接给了王五。

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

**完成任务**

王五进行完成任务。任务到了下一个节点（经理审批）。

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

/**
         * 部署流程
         */
        @Test
        public void TestDeployment() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            RepositoryService repositoryService = processEngine.getRepositoryService();
            Deployment deployment  = repositoryService.createDeployment()
                    .addClasspathResource("请假流程-候选人.bpmn20.xml")
                    .name("请假流程-候选人")
                    .deploy();
    
            System.out.println("deployment.getId()" + deployment.getId());
            System.out.println("deployment.getName()" + deployment.getName());
        }
    
        /**
         * 删除流程定义
         */
        @Test
        public void TestDeploymentDelete() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            RepositoryService repositoryService = processEngine.getRepositoryService();
            // 第一个参数是id，如果部署的流程启动了，就不允许删除了
            // repositoryService.deleteDeployment("30001");
    
            // 第二个参数是级联删除，如果流程启动了，相关的任务一并会被删除
            repositoryService.deleteDeployment("57501", true);
        }
    
    
        /**
         * 启动流程实例
         */
        @Test
        public void TestDeploymentRun() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            RuntimeService runtimeService = processEngine.getRuntimeService();
            // 流程变量
            Map<String, Object> variables = new HashMap<String, Object>();
            variables.put("candidate1", "张三");
            variables.put("candidate2", "李四");
            variables.put("candidate3", "王五");
            // 启动流程实例
            ProcessInstance processInstance = runtimeService.startProcessInstanceById("holiday-candidate:1:80004", variables);
            System.out.println("processInstance.getProcessDefinitionId() = " + processInstance.getProcessDefinitionId());
            System.out.println("processInstance.getActivityId() = " + processInstance.getActivityId());
            System.out.println("processInstance.getId()" + processInstance.getId());
        }
    
    
        /**
         * 根据登录的用户查询对应可以拾取的任务
         */
        @Test
        public void TestQueryTaskCandidate() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = processEngine.getTaskService();
            List<Task> list = taskService.createTaskQuery()
                    // .processInstanceId("82501") //根据流程实例编号查找
                    .processDefinitionId("holiday-candidate:1:80004")
                    .taskCandidateUser("李四")
                    .list();
    
            for (Task task : list) {
        
                System.out.println("task.getId() = " + task.getId());
                System.out.println("task.getName() = " + task.getName());
            }
        }
    
        /**
         * 拾取任务
         * 一个候选人拾取了任务之后，其他的用户就没有办法拾取这个任务了
         * 如果一个用户拾取了任务之后又不想处理了，那么可以退还
         */
        @Test
        public void TestClaimTaskCandidate() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = processEngine.getTaskService();
            Task task = taskService.createTaskQuery()
                    // .processInstanceId("82501") //根据流程实例编号查找
                    .processDefinitionId("holiday-candidate:1:80004")
                    .taskCandidateUser("李四")
                    .singleResult();
    
           if(task != null){
        
               // 拾取对应的任务
               taskService.claim(task.getId(), "李四");
               System.out.println("拾取任务成功");
           }
        }
    
        /**
         * 退还任务
         */
        @Test
        public void TestUnClaimTaskCandidate() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = processEngine.getTaskService();
            Task task = taskService.createTaskQuery()
                    // .processInstanceId("82501") //根据流程实例编号查找
                    .processDefinitionId("holiday-candidate:1:80004")
                    .taskAssignee("张三")
                    .singleResult();
    
            if(task != null){
        
                // 退还任务
                taskService.unclaim(task.getId());
                System.out.println("退还任务成功");
            }
        }
    
        /**
         * 交接任务
         * 如果我获取了任务，但是不想执行，那么我可以把这个任务交接给其他的用户
         */
        @Test
        public void TestJoinTaskCandidate() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = processEngine.getTaskService();
            Task task = taskService.createTaskQuery()
                    // .processInstanceId("82501") //根据流程实例编号查找
                    .processDefinitionId("holiday-candidate:1:80004")
                    .taskAssignee("李四")
                    .singleResult();
    
            if(task != null){
        
                // 交接任务
                taskService.setAssignee(task.getId(), "王五");
                System.out.println("交接任务成功");
            }
        }
    
        /**
         * 完成任务
         */
        @Test
        public void TestCompleteTask() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = processEngine.getTaskService();
            Task task = taskService.createTaskQuery()
                    // .processInstanceId("82501") //根据流程实例编号查找
                    .processDefinitionId("holiday-candidate:1:80004")
                    .taskAssignee("王五")
                    .singleResult();
    
            if(task != null){
        
                // 完成任务
                taskService.complete(task.getId());
                System.out.println("完成任务成功");
            }
        }

## 2、候选人组 ##

当候选人很多的情况下，我们可以分组来处理。先创建组，然后把用户分配到这个组中。

这里是用到了flowable的用户相关的表结构，通过代码的方式进行用户的相关操作。

### 用户与组的维护 ###

**创建用户**

@Test
        public void TestCreateUser() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            IdentityService identityService = processEngine.getIdentityService();
            User user = identityService.newUser("田佳");
            user.setFirstName("tian");
            user.setLastName("jia");
            user.setEmail("tianjia@qq.com");
            identityService.saveUser(user);
        }

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

**创建用户组**

@Test
        public void TestCreateUserGroup() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            IdentityService identityService = processEngine.getIdentityService();
            Group group1 = identityService.newGroup("group2");
            group1.setName("开发部");
            group1.setType("type2");
            identityService.saveGroup(group1);
        }

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

**将用户分配给对应的组**

@Test
        public void TestUserGroup() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            IdentityService identityService = processEngine.getIdentityService();
            // 找到组
            Group group = identityService.createGroupQuery().groupId("group1").singleResult();
            // 找到用户
            List<User> list = identityService.createUserQuery().list();
            for (User user : list) {
        
                // 将用户分配给对应的组
                identityService.createMembership(user.getId(), group.getId());
            }
        }

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

### 案例讲解 ###

在画流程的时候，在“身份存储”、“固定值”tab页都可以指定候选人组。

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

启动流程实例之后，任务的分配人是null。

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

**拾取任务**

邓超拾取任务。其他人就不能再拾取这个任务了。

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

**退还任务**

邓超退还任务，这个任务的分配人又变成了null。其他人可以再拾取这个任务了。

李飞拾取任务。

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

**交接任务**

李飞把任务交接给田佳。

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

**完成任务**

田佳完成任务。任务走到了下一个节点（总经理审批–lisi）

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

/**
         * 部署流程
         */
        @Test
        public void TestDeployment() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            RepositoryService repositoryService = processEngine.getRepositoryService();
            Deployment deployment  = repositoryService.createDeployment()
                    .addClasspathResource("请假流程-候选人组.bpmn20.xml")
                    .name("请假流程-候选人组")
                    .deploy();
    
            System.out.println("deployment.getId()" + deployment.getId());
            System.out.println("deployment.getName()" + deployment.getName());
        }
    
        /**
         * 删除流程定义
         */
        @Test
        public void TestDeploymentDelete() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            RepositoryService repositoryService = processEngine.getRepositoryService();
            // 第一个参数是id，如果部署的流程启动了，就不允许删除了
            // repositoryService.deleteDeployment("30001");
    
            // 第二个参数是级联删除，如果流程启动了，相关的任务一并会被删除
            repositoryService.deleteDeployment("57501", true);
        }
    
    
        /**
         * 启动流程实例
         */
        @Test
        public void TestDeploymentRun() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            RuntimeService runtimeService = processEngine.getRuntimeService();
            IdentityService identityService = processEngine.getIdentityService();
            Group group = identityService.createGroupQuery().groupId("group1").singleResult();
            // 流程变量
            Map<String, Object> variables = new HashMap<String, Object>();
            // variables.put("g1", "group1");
            variables.put("g1", group.getId());
            // 启动流程实例
            ProcessInstance processInstance = runtimeService.startProcessInstanceById("holiday-group:1:102504", variables);
            System.out.println("processInstance.getProcessDefinitionId() = " + processInstance.getProcessDefinitionId());
            System.out.println("processInstance.getActivityId() = " + processInstance.getActivityId());
            System.out.println("processInstance.getId()" + processInstance.getId());
        }
    
    
        /**
         * 根据登录的用户找到所属的组，根据组找到相关的任务
         */
        @Test
        public void TestQueryTaskCandidateGroup() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            // 根据登录的用户找到所属的组
            IdentityService identityService = processEngine.getIdentityService();
            Group group = identityService.createGroupQuery().groupMember("邓超").singleResult();
            System.out.println("group.getId() = " + group.getId());
    
            TaskService taskService = processEngine.getTaskService();
            List<Task> list = taskService.createTaskQuery()
                    // .processInstanceId("82501") //根据流程实例编号查找
                    .processDefinitionId("holiday-group:1:102504")
                    .taskCandidateGroup("group1")// 根据组找到相关的任务
                    .list();
    
            for (Task task : list) {
        
                System.out.println("task.getId() = " + task.getId());
                System.out.println("task.getName() = " + task.getName());
            }
        }
    
        /**
         * 拾取任务
         * 一个候选人拾取了任务之后，其他的用户就没有办法拾取这个任务了
         * 如果一个用户拾取了任务之后又不想处理了，那么可以退还
         */
        @Test
        public void TestClaimTaskCandidate() {
        
            String userId = "李飞";
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            // 根据登录的用户找到所属的组
            IdentityService identityService = processEngine.getIdentityService();
            Group group = identityService.createGroupQuery().groupMember(userId).singleResult();
            System.out.println("group.getId() = " + group.getId());
    
            TaskService taskService = processEngine.getTaskService();
            Task task = taskService.createTaskQuery()
                    // .processInstanceId("82501") //根据流程实例编号查找
                    .processDefinitionId("holiday-group:1:102504")
                    .taskCandidateGroup(group.getId())
                    .singleResult();
    
           if(task != null){
        
               // 拾取对应的任务
               taskService.claim(task.getId(), userId);
               System.out.println("拾取任务成功");
           }
        }
    
        /**
         * 退还任务
         */
        @Test
        public void TestUnClaimTaskCandidate() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = processEngine.getTaskService();
            Task task = taskService.createTaskQuery()
                    // .processInstanceId("82501") //根据流程实例编号查找
                    .processDefinitionId("holiday-group:1:102504")
                    .taskAssignee("邓超")
                    .singleResult();
    
            if(task != null){
        
                // 退还任务
                taskService.unclaim(task.getId());
                System.out.println("退还任务成功");
            }
        }
    
        /**
         * 交接任务
         * 如果我获取了任务，但是不想执行，那么我可以把这个任务交接给其他的用户
         */
        @Test
        public void TestJoinTaskCandidate() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = processEngine.getTaskService();
            Task task = taskService.createTaskQuery()
                    // .processInstanceId("82501") //根据流程实例编号查找
                    .processDefinitionId("holiday-group:1:102504")
                    .taskAssignee("李飞")
                    .singleResult();
    
            if(task != null){
        
                // 交接任务
                taskService.setAssignee(task.getId(), "田佳");
                System.out.println("交接任务成功");
            }
        }
    
        /**
         * 完成任务
         */
        @Test
        public void TestCompleteTask() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = processEngine.getTaskService();
            Task task = taskService.createTaskQuery()
                    // .processInstanceId("82501") //根据流程实例编号查找
                    .processDefinitionId("holiday-group:1:102504")
                    .taskAssignee("田佳")
                    .singleResult();
    
            if(task != null){
        
                // 完成任务
                taskService.complete(task.getId());
                System.out.println("完成任务成功");
            }
        }

[782589e1b30d4381aaea76025d38cfb3.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/6cfb912027134815b5acbaea1ee07bb3.png
[a27d4514410748c18110bb5cfdf14f5f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/74fb5cb598304f548869877cc8bb5e84.png
[0b408058371c4d7a8a5a9c8c269210a6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/5ecf415741474a5cb4708507d429818d.png
[b3ff0656bd884b54bc50becd9b42d178.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/9bddb55fef514a0b921b3d6e598155d0.png
[a1a26cbc3f6c46448944bf8b27156b23.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/965c9053c9034943a2096dbe3174c0a8.png
[877489b49f384e5884a31e4d9e94886d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/d944a8b22a1d4afb8d1a2f2889a031c5.png
[87aec881649246e9941b33cdafa12d9a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/2edd9748655f498eae32a2cf8a3643d9.png
[81dba994fb7f4778b650c55251fc10d2.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/cc2888f972954e0eac97ab2987152f59.png
[e3d73951f5c34f1d843bebc1632672eb.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/829c5c858ea940ecbc91bb8777a41736.png
[92128924bbb146f5a73f2d1e8e702c2b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/8094915b925c4cbbb1f50b375ffb5811.png
[c6bbf5b6f94949a592eefd4e1cd6bd4a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/02a2fed56596499686051fb48756a5ce.png
[4945913ab2cc4756a669fd3d9087bcf3.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/f04abc78e4fd4cd7bf18b5b2f1528611.png
[6528532ed4c94bcfbda5cb4b67796735.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/1cc25a2a1297434d87f487ce9d3e952a.png
[d48e001b8b084cf7a94bba60671c75bc.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/be4ea7c6acd740a896711139c447d3e5.png
[80378eb623b748b78a3f7cb72e8eb694.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/0c3210ce15e94135b7c1b8cb0ee29e8d.png
[9ba6aca5a83546bea3349085e1882bf8.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/e0b91a7244cf4a3eabc52d9df8cceed9.png