Springboot +Flowable，按角色分配任务

news2024/12/26 22:27:50

一.简介

在为 UserTask 设置处理人的时候，除了设置单个的处理人，也可以设置 Group（分组），就是某一个用户组内的所有用户都可以处理该 Task。

二.绘制流程图

首先我们还是使用之前旧的流程图，流程图截图如下：
在这里插入图片描述

三. 用户与用户组

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

1.添加组

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

@Test
@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");

2.修改组

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

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

3.删除组

删除组。代码如下：

identityService.deleteGroup("leader");

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

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

四. 用户与用户组

在绘制流程图的时候，我们可以为 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}”。

四.根据用户组查询任务

接下来部署并启动一个流程，代码如下：

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

注意启动的时候加了参数variables.put(“g1”, “leader”);，用来描述下一个 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。

当然，也可以直接按照 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

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/499841.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！