在 Flowable 中使用 Group 去歸類某一類用戶，但是這個實際上類似于我們在自己系統(tǒng)中平時所用的角色 Role。也就是說，我們可以按照角色去給每一個 UserTask 設置處理人。

接下來松哥就來和小伙伴們聊一聊這里的一些細節(jié)。

1. 用戶與用戶組

首先我們先來看下用戶組的一些基本操作。

1.1 添加組

組的屬性相對來說少一些，添加方式和 user 比較像：

@Test
void test09() {
    GroupEntityImpl g = new GroupEntityImpl();
    g.setName("組長");
    g.setId("leader");
    g.setRevision(0);
    identityService.saveGroup(g);
}

添加之后，組的信息保存在 ACT_ID_GROUP 表中，如下圖：

組創(chuàng)建好之后，接下來還要給組添加用戶，添加方式如下：

identityService.createMembership("zhangsan", "leader");
identityService.createMembership("lisi", "leader");

這就是設置 zhangsan 和 lisi 是組長（注意用戶和組的關(guān)聯(lián)關(guān)系表中有外鍵，所以需要確保兩個參數(shù)都是真實存在的）。

添加了關(guān)聯(lián)關(guān)系之后，我們再去查看 ACT_ID_MEMBERSHIP 表，如下：

掉用如下方法可以刪除關(guān)聯(lián)關(guān)系：

identityService.deleteMembership("zhangsan","leader");

1.2 修改組

如下，將 id 為 leader 的組名更新為主管，如下：

Group g = identityService.createGroupQuery().groupId("leader").singleResult();
g.setName("主管");
identityService.saveGroup(g);

1.3 刪除組

刪除組方式如下：

identityService.deleteGroup("leader");

刪除組的同時，也會刪除掉組和用戶之間的關(guān)聯(lián)關(guān)系，不過不用擔心用戶被刪除。

1.4 查詢組

可以根據(jù) id 或者 name 或者組員信息等去查詢組：

Group g1 = identityService.createGroupQuery().groupId("leader").singleResult();
System.out.println("g1.getName() = " + g1.getName());

Group g2 = identityService.createGroupQuery().groupName("組長").singleResult();
System.out.println("g2.getId() = " + g2.getId());

List<Group> list = identityService.createGroupQuery().groupMember("zhangsan").list();
for (Group group : list) {
    System.out.println("group.getName() = " + group.getName());
}

2. 設置候選組

在我們繪制流程圖的時候，我們可以為 UserTask 設置一個候選組，方式如下：

從這個地方大家也可以看到，后選擇是可以給多個的。

好了，設置完成后，我們下載流程圖的 XML 文件，然后來看下這個地方與眾不同之處：

<process id="demo01" name="測試流程" isExecutable="true">
  <documentation>測試流程</documentation>
  <startEvent id="startEvent1" flowable:formFieldValidation="true"></startEvent>
  <userTask id="sid-F2F3C468-79B9-447B-943F-7CD18CE9BECF" flowable:candidateGroups="leader" flowable:formFieldValidation="true"></userTask>
  <sequenceFlow id="sid-79C79920-2AD8-48FE-A59C-CC4D23C1895D" sourceRef="startEvent1" targetRef="sid-F2F3C468-79B9-447B-943F-7CD18CE9BECF"></sequenceFlow>
  <endEvent id="sid-2236991E-3643-4590-9001-E22C256CA584"></endEvent>
  <sequenceFlow id="sid-51105EB7-07F6-4190-9B2E-8F1F20A307D1" sourceRef="sid-F2F3C468-79B9-447B-943F-7CD18CE9BECF" targetRef="sid-2236991E-3643-4590-9001-E22C256CA584"></sequenceFlow>
</process>

小伙伴們看到，flowable:candidateGroups="leader"? 就表示這個任務由一個候選用戶組來處理，如果有多個候選的用戶組，則不同用戶組之間用 , 隔開。

當然，這是硬編碼。如果想像候選用戶一樣，通過動態(tài)變量來傳遞用戶組名稱也是可以的，具體做法像下面這樣：

這樣，最終生成的 XML 文件則類似這樣：flowable:candidateGroups="${g1}"。

3. 根據(jù)用戶組查詢?nèi)蝿?/h4>

接下來，我們部署并啟動一個流程，具體的部署和啟動方式松哥在之前的文章中都已經(jīng)和大家介紹過了，這里簡單看下方法就行了：

@Test
void test01() {
    Map<String, Object> variables = new HashMap<>();
    variables.put("g1", "leader");
    ProcessInstance pi = runtimeService.startProcessInstanceByKey("demo01",variables);
    logger.info("id:{},activityId:{}", pi.getId(), pi.getActivityId());
}

這個就是流程啟動的過程，注意啟動的時候加了參數(shù)，用來描述下一個 UserTask 的處理組。

啟動成功之后，我們可以在 ACT_RU_IDENTITYLINK 表中查看到用戶組和 UserTask 之間的關(guān)系：

接下來我們可以按照查詢候選人任務的方式，查詢 zhangsan 需要完成的工作，如下：

@Test
void test19() {
    List<Task> list = taskService.createTaskQuery().taskCandidateUser("zhangsan").list();
    for (Task task : list) {
        logger.info("name:{},createTime:{}", task.getName(), task.getCreateTime());
    }
}

這個查詢的內(nèi)部實現(xiàn)，我們可以拆分為兩步：

查詢出來 zhangsan 是屬于哪個 group，這個查詢執(zhí)行的 SQL 如下：

SELECT RES.* from ACT_ID_GROUP RES WHERE exists(select 1 from ACT_ID_MEMBERSHIP M where M.GROUP_ID_ = RES.ID_ and M.USER_ID_ = ?) order by RES.ID_ asc

這個查詢中有一個參數(shù)，參數(shù)的值就是 zhangsan，上面這個 SQL 可以查詢出來 zhangsan 這個用戶屬于 leader 這個分組，在接下來的查詢中，會 zhangsan 和 leader 兩個參數(shù)都會用到。

查詢 zhangsan 或者 leader 的任務，執(zhí)行 SQL 如下：

SELECT RES.* from ACT_RU_TASK RES WHERE RES.ASSIGNEE_ is null and exists(select LINK.ID_ from ACT_RU_IDENTITYLINK LINK where LINK.TYPE_ = 'candidate' and LINK.TASK_ID_ = RES.ID_ and ( LINK.USER_ID_ = ? or ( LINK.GROUP_ID_ IN ( ? ) ) ) ) order by RES.ID_ asc

可以看到，這個查詢里，有兩個參數(shù)了，兩個參數(shù)的值分別是 zhangsan 和 leader。

也就是說，雖然我們這里代碼寫的是按照 zhangsan 去查詢，實際上查詢的是 zhangsan 所屬的用戶組的 Task（這個邏輯也好理解，因為 zhangsan 所屬的用戶組的 Task 實際上也就是 zhangsan 的 Task）。

當然，我們也可以直接按照 group 去查詢，如下：

@Test
void test20() {
    List<Task> list = taskService.createTaskQuery().taskCandidateGroup("leader").list();
    for (Task task : list) {
        logger.info("name:{},createTime:{}", task.getName(), task.getCreateTime());
    }
}

這個查詢原理跟上面的差不多，不過省事的是，這里一條 SQL 就搞定了（不需要根據(jù)用戶名查詢用戶所屬的分組了），如下：

SELECT RES.* from ACT_RU_TASK RES WHERE RES.ASSIGNEE_ is null and exists(select LINK.ID_ from ACT_RU_IDENTITYLINK LINK where LINK.TYPE_ = 'candidate' and LINK.TASK_ID_ = RES.ID_ and ( ( LINK.GROUP_ID_ IN ( ? ) ) ) ) order by RES.ID_ as

好啦，當這些任務查詢出來后，接下來該如何執(zhí)行，就和前面介紹的內(nèi)容一樣了，我這里就不再贅述了。