Flowable 按角色分配任務(wù)

作者：江南一點(diǎn)雨 2022-10-13 11:38:16

雖然我們這里代碼寫(xiě)的是按照 zhangsan 去查詢(xún)，實(shí)際上查詢(xún)的是 zhangsan 所屬的用戶(hù)組的 Task（這個(gè)邏輯也好理解，因?yàn)?zhangsan 所屬的用戶(hù)組的 Task 實(shí)際上也就是 zhangsan 的 Task）。

在 Flowable 中使用 Group 去歸類(lèi)某一類(lèi)用戶(hù)，但是這個(gè)實(shí)際上類(lèi)似于我們?cè)谧约合到y(tǒng)中平時(shí)所用的角色 Role。也就是說(shuō)，我們可以按照角色去給每一個(gè) UserTask 設(shè)置處理人。

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

1. 用戶(hù)與用戶(hù)組

首先我們先來(lái)看下用戶(hù)組的一些基本操作。

1.1 添加組

組的屬性相對(duì)來(lái)說(shuō)少一些，添加方式和 user 比較像：

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

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

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

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

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

添加了關(guān)聯(lián)關(guān)系之后，我們?cè)偃ゲ榭?nbsp;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");

刪除組的同時(shí)，也會(huì)刪除掉組和用戶(hù)之間的關(guān)聯(lián)關(guān)系，不過(guò)不用擔(dān)心用戶(hù)被刪除。

1.4 查詢(xún)組

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

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

Group g2 = identityService.createGroupQuery().groupName("組長(zhǎng)").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. 設(shè)置候選組

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

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

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

<process id="demo01" name="測(cè)試流程" isExecutable="true">
  <documentation>測(cè)試流程</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"? 就表示這個(gè)任務(wù)由一個(gè)候選用戶(hù)組來(lái)處理，如果有多個(gè)候選的用戶(hù)組，則不同用戶(hù)組之間用 , 隔開(kāi)。

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

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

3. 根據(jù)用戶(hù)組查詢(xún)?nèi)蝿?wù)

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

@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());
}

這個(gè)就是流程啟動(dòng)的過(guò)程，注意啟動(dòng)的時(shí)候加了參數(shù)，用來(lái)描述下一個(gè) UserTask 的處理組。

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

接下來(lái)我們可以按照查詢(xún)候選人任務(wù)的方式，查詢(xú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());
    }
}

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

查詢(xún)出來(lái) zhangsan 是屬于哪個(gè) group，這個(gè)查詢(xún)執(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

這個(gè)查詢(xún)中有一個(gè)參數(shù)，參數(shù)的值就是 zhangsan，上面這個(gè) SQL 可以查詢(xún)出來(lái) zhangsan 這個(gè)用戶(hù)屬于 leader 這個(gè)分組，在接下來(lái)的查詢(xún)中，會(huì) zhangsan 和 leader 兩個(gè)參數(shù)都會(huì)用到。

查詢(xún) zhangsan 或者 leader 的任務(wù)，執(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

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

也就是說(shuō)，雖然我們這里代碼寫(xiě)的是按照 zhangsan 去查詢(xún)，實(shí)際上查詢(xún)的是 zhangsan 所屬的用戶(hù)組的 Task（這個(gè)邏輯也好理解，因?yàn)?zhangsan 所屬的用戶(hù)組的 Task 實(shí)際上也就是 zhangsan 的 Task）。

當(dāng)然，我們也可以直接按照 group 去查詢(xún)，如下：

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

這個(gè)查詢(xún)?cè)砀厦娴牟畈欢?，不過(guò)省事的是，這里一條 SQL 就搞定了（不需要根據(jù)用戶(hù)名查詢(xún)用戶(hù)所屬的分組了），如下：

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