博客 / 詳情

返回

Flowable 按角色分配任務

@[toc]
前面鬆哥和大家分享的都是給 UserTask 設置處理人或者是候選用户,不過小夥伴們也知道,在我們為 UserTask 設置處理人的時候,除了設置單個的處理人,也可以設置 Group,就是某一個用户組內的所有用户都可以處理該 Task。

在 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 或者組員信息等去查詢組:

//根據 id 查詢組信息
Group g1 = identityService.createGroupQuery().groupId("leader").singleResult();
System.out.println("g1.getName() = " + g1.getName());
//根據 name 查詢組信息
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());
    }
}

這個查詢的內部實現,我們可以拆分為兩步:

  1. 查詢出來 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 兩個參數都會用到。

  1. 查詢 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_ asc

好啦,當這些任務查詢出來後,接下來該如何執行,就和前面介紹的內容一樣了,我這裏就不再贅述了。

user avatar
0 位用戶收藏了這個故事!

發佈 評論

Some HTML is okay.