Flowable 按角色分配任務
在 Flowable 中使用 Group 去歸類某一類用戶，但是這個實際上類似于我們在自己系統中平時所用的角色 Role。也就是說，我們可以按照角色去給每一個 UserTask 設置處理人。
接下來松哥就來和小伙伴們聊一聊這里的一些細節。
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 表中，如下圖：
組創建好之后，接下來還要給組添加用戶，添加方式如下：
identityService.createMembership("zhangsan", "leader");
identityService.createMembership("lisi", "leader");
這就是設置 zhangsan 和 lisi 是組長（注意用戶和組的關聯關系表中有外鍵，所以需要確保兩個參數都是真實存在的）。
添加了關聯關系之后，我們再去查看 ACT_ID_MEMBERSHIP 表，如下：
掉用如下方法可以刪除關聯關系：
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");
刪除組的同時，也會刪除掉組和用戶之間的關聯關系，不過不用擔心用戶被刪除。
1.4 查詢組
可以根據 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"? 就表示這個任務由一個候選用戶組來處理，如果有多個候選的用戶組，則不同用戶組之間用 , 隔開。
當然，這是硬編碼。如果想像候選用戶一樣，通過動態變量來傳遞用戶組名稱也是可以的，具體做法像下面這樣：
這樣，最終生成的 XML 文件則類似這樣：flowable:candidateGroups="${g1}"。
3. 根據用戶組查詢任務
接下來，我們部署并啟動一個流程，具體的部署和啟動方式松哥在之前的文章中都已經和大家介紹過了，這里簡單看下方法就行了：
@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());
}
這個就是流程啟動的過程，注意啟動的時候加了參數，用來描述下一個 UserTask 的處理組。
啟動成功之后，我們可以在 ACT_RU_IDENTITYLINK 表中查看到用戶組和 UserTask 之間的關系：
接下來我們可以按照查詢候選人任務的方式，查詢 zhangsan 需要完成的工作，如下：
@Test
void test19() {
List<Task> list = taskService.createTaskQuery().taskCandidateUser("zhangsan").list();
for (Task task : list) {
logger.info("name:{},createTime:{}", task.getName(), task.getCreateTime());
}
}
這個查詢的內部實現，我們可以拆分為兩步：
查詢出來 zhangsan 是屬于哪個 group，這個查詢執行的 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
這個查詢中有一個參數，參數的值就是 zhangsan，上面這個 SQL 可以查詢出來 zhangsan 這個用戶屬于 leader 這個分組，在接下來的查詢中，會 zhangsan 和 leader 兩個參數都會用到。
查詢 zhangsan 或者 leader 的任務，執行 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
可以看到，這個查詢里，有兩個參數了，兩個參數的值分別是 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 就搞定了（不需要根據用戶名查詢用戶所屬的分組了），如下：
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
好啦，當這些任務查詢出來后，接下來該如何執行，就和前面介紹的內容一樣了，我這里就不再贅述了。
