TienChin
10 分钟 读完 (大约 1554 个字)

Flowable 按角色分配任务

[TOC]

前面松哥和大家分享的都是给 UserTask 设置处理人或者是候选用户，不过小伙伴们也知道，在我们为 UserTask 设置处理人的时候，除了设置单个的处理人，也可以设置 Group，就是某一个用户组内的所有用户都可以处理该 Task。

在 Flowable 中使用 Group 去归类某一类用户，但是这个实际上类似于我们在自己系统中平时所用的角色 Role。也就是说，我们可以按照角色去给每一个 UserTask 设置处理人。

接下来松哥就来和小伙伴们聊一聊这里的一些细节。

1. 用户与用户组

首先我们先来看下用户组的一些基本操作。

1.1 添加组

组的属性相对来说少一些，添加方式和 user 比较像：

1
2
3
4
5
6
7
8
@Test
void test09() {
    GroupEntityImpl g = new GroupEntityImpl();
    g.setName("组长");
    g.setId("leader");
    g.setRevision(0);
    identityService.saveGroup(g);
}

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

组创建好之后，接下来还要给组添加用户，添加方式如下：

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

这就是设置 zhangsan 和 lisi 是组长（注意用户和组的关联关系表中有外键，所以需要确保两个参数都是真实存在的）。

添加了关联关系之后，我们再去查看 ACT_ID_MEMBERSHIP 表，如下：

掉用如下方法可以删除关联关系：

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

1.2 修改组

如下，将 id 为 leader 的组名更新为主管，如下：

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

1.3 删除组

删除组方式如下：

1
identityService.deleteGroup("leader");

删除组的同时，也会删除掉组和用户之间的关联关系，不过不用担心用户被删除。

1.4 查询组

可以根据 id 或者 name 或者组员信息等去查询组：

1
2
3
4
5
6
7
8
9
10
11
//根据 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 文件，然后来看下这个地方与众不同之处：

1
2
3
4
5
6
7
8
<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. 根据用户组查询任务

接下来，我们部署并启动一个流程，具体的部署和启动方式松哥在之前的文章中都已经和大家介绍过了，这里简单看下方法就行了：

1
2
3
4
5
6
7
8

@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 需要完成的工作，如下：

1
2
3
4
5
6
7
@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 如下：
1
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 如下：
1
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 去查询，如下：

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

这个查询原理跟上面的差不多，不过省事的是，这里一条 SQL 就搞定了（不需要根据用户名查询用户所属的分组了），如下：

1
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

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

# Flowable, TienChin

喜欢这篇文章吗？扫码关注公众号【江南一点雨】，【江南一点雨】专注于 SPRING BOOT+微服务以及前后端分离技术，每天推送原创技术干货，关注后回复 JAVA，领取松哥为你精心准备的 JAVA 干货!

觉得不错，可以给小编加个鸡腿

Flowable 服务任务执行的三种方式
Flowable 任务如何认领，回退？

评论

扫码关注微信公众号

分类

标签云

2019-article Actuator Blog Bug CAS CORS Chrome Docker Druid Ehcache ElasticJob ElasticSearch ElasticSerach Eureka FastDFS Flowable Flyway Freemarker Git GitHub HDC Https I18N IDEA IDEA，EasyCode IntelliJ IDEA JDK16 JWT Java JavaWeb JdbcTemplate Jedis Jenkins Jpa LiveReload Log Lombok MacBook MacBookPro Mail Maven MongoDB MyBatis MyBatisPlus MyCat MySQL MySQL8 Nacos Nginx OAuth2 PicGo Platform Plugin RabbitMQ Redis Resume SSM Shiro Spring Spring Boot Spring Cloud Spring Data Spring Security Spring6 SpringBoot SpringBoot3 SpringCloud SpringData SpringDataJpa SpringMVC SpringSecurity Swagger Swagger2 Swagger3 TLS Tencent Thymeleaf TienChin Transaction Video ViewResolver Vue Vue3 Web WebFlux blog docker domain elasticjob es gRPC hdz hexo huawei i18n idea java life mail nginx redis router saga seata tcc transaction vhr video vue vuepress weixin xa xxl-job yaml 七牛云 中间件 主从复制 事务 侃侃而谈 全局ID 分布式 分布式事务 分布式锁 前后端分离 华为 单体应用 外包 学习资源 定时任务 工具 干货汇总 延迟队列 微人事 微服务 杂谈 条件注解 死信队列 消息过期 消息驱动 源码解析 源码解读 生活 私活 程序人生 程序员 腾讯 自学 视频 视频教程 训练营 资料 逆向工程 面试

最新文章

归档

友链

Your browser is out-of-date!

Update your browser to view this website correctly. Update my browser now

×