社区精选 | Flowable 按角色分配任务

业界 作者:SegmentFault 2023-01-25 14:33:11
今天小编为大家带来的是社区作者 江南一点雨 的文章,让我们一起来看看 Flowable 。

前面松哥和大家分享的都是给 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


好啦,当这些任务查询出来后,接下来该如何执行,就和前面介绍的内容一样了,我这里就不再赘述了。



点击左下角阅读原文,到 SegmentFault 思否社区 和文章作者展开更多互动和交流,“公众号后台回复“ 入群 ”即可加入我们的技术交流群,收获更多的技术文章~

- END -


关注公众号:拾黑(shiheibook)了解更多

赞助链接:

关注数据与安全,洞悉企业级服务市场:https://www.ijiandao.com/
四季很好,只要有你,文娱排行榜:https://www.yaopaiming.com/
让资讯触达的更精准有趣:https://www.0xu.cn/

公众号 关注网络尖刀微信公众号
随时掌握互联网精彩
赞助链接