正文

Activiti6.0获取下一节点任务的心路历程

IP云
IP云V管理员/2 阅读
10/29
提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

在我的开发任务中，我被分配了一个像下一个节点审批人发送短信的任务，这个任务看起来非常的简单，但在开发过程中遇到了许多的坑，在这里进行记录，如果你想要快速知道结果，请看代码版本（3）。

  1. 首先，就是获取下一节点的任务信息，这里说简单也简单，说难也难，初期，我查阅了大量的资料，那些资料中都是在代码层面获取下一节点任务信息，我尝试了一下，非常的复杂，后来，我仔细研究了activiti流程变化与数据库变化之间的联系，发现act_ru_task表的执行特性，它会在当前节点任务完成后自动加载下一节点任务，根据这一点，我们就能能够获取到下一节点的相关信息。

/**
* @author : ADun
* 获取当前节点的下一节点所有节点信息
* 解释：当当前节点任务完成后，ac_ru_task表会删除当前任务保存下一待办任务，因此可以获得下一节点任务相关信息
* @param task
* @return
*/
public List<Task> nextAllNodeTaskList(Task task) {
List<Task> taskList = null;
taskList = taskService.createTaskQuery().processInstanceId(task.getProcessInstanceId()).list();
return taskList;
}

  1. 接着就是判断流程是怎样执行的了，何时给下一节点发信息，何时不发，在这里我由于对项目流程图不够熟悉，出现了各种的逻辑漏洞
    （1）代码的第一个版本

/**
* 发送待办提醒的通用入口（包含短信+邮箱提醒）
* @param task 当前节点的任务信息
*/
@Override
public void sendTaskNotice(Task task){
//1、获取下一节点所有任务信息，实际是查询act_ru_task表中的信息
List<Task> nextNodeUserTask = taskQueryService.nextAllNodeTaskList(task);
if(nextNodeUserTask == null || nextNodeUserTask.size() <= 0){//下一节点任务为空，即当前节点为最后一个节点
return;
} for (Task nextNodeTask : nextNodeUserTask) {
List<Execution> executionList = runtimeService.createExecutionQuery().processInstanceId(nextNodeTask.getProcessInstanceId()).list();//查询出所有的执行实例
for (int i = 0; i < executionList.size(); i++) {
//如果当前任务的执行实例id是下一节点任务执行实例的父id，则进行下一步
if(task.getExecutionId() == executionList.get(i).getParentId()){
String assignee = nextNodeTask.getAssignee();//下一节点任务的参与者uid
if (assignee == null || "".equals(assignee)){
log.error("下一节点任务参与者为空");
return;
}
SysUser assigneeUser = sysUserService.selectUserByUserName(assignee);//下一节点任务参与者用户信息
//2、获取流程实例的任务属性
GatherTaskProperty gatherTaskProperty = gatherTaskPropertyMapper.selectGatherTaskPropertyByProcessInstanceId(task.getProcessInstanceId());
SysUser initialUser = sysUserService.selectUserByUserName(gatherTaskProperty.getCreateBy());//发起人用户信息 //3、发送邮件、短信提醒
sendTaskSMNotice(nextNodeTask, assigneeUser, initialUser);
sendTaskMailNotice(nextNodeTask, assigneeUser, initialUser);
}
}
}
}

在这一个版本的代码逻辑中，我的的逻辑是这样的，这里使用到了activiti流程引擎在执行过程中的一个特性，如果流程是单线流程，那么在执行过程中只会在act_ru_exection执行实例表【这个表中会保存流程实例与执行实例，它们有细微的区别，不明白的可以去了解一下】中保存一条流程实例信息，如果是并行流程，那么在act_ru_exection表中会同时保存流程实例与执行实例，并且执行实例属于流程实例，在表中可以发现，这里包含三条信息，第一条就是流程实例的信息，下面两条是执行实例的信息

由此我们也能够得出此时是一个下图这种类型的流程图

当初是这样想的，现在看起来非常的智障：：当1号节点任务完成时，act_ru_task表会自动加载2与4任务节点的信息【并行网关的特性】，此时的2与3属于一个执行实例，4与5属于一个执行实例，当任务2完成时，act_ru_task表会自动删除2号节点，加载3号任务，此时3号执行实例的parentid我认为是2号节点的执行id，但后来发现，act_ru_exection表中一直会保存三条数据，变化的只是act_id，第一版本宣布失败
（2）代码的第二个版本

/**
* 发送待办提醒的通用入口（包含短信+邮箱提醒）
* @param task 当前节点的任务信息
*/
@Override
public void sendTaskNotice(Task task){
//1、获取下一节点所有任务信息，实际是查询act_ru_task表中的信息
List<Task> nextNodeUserTask = taskQueryService.nextAllNodeTaskList(task);
if(nextNodeUserTask == null || nextNodeUserTask.size() <= 0){//下一节点任务为空，即当前节点为最后一个节点
return;
} //2、如果下一节点只有一个任务，act_ru_task中只有一条数据
if (nextNodeUserTask.size() == 1) {
String assignee =null;
//判断是单线流程还是并行流程，根据当前任务的执行流程实例id查询act_ru_exection，只有一条数据说明是单线流程，否则时多线
List<Execution> executionList = runtimeService.createExecutionQuery().processInstanceId(nextNodeUserTask.get(0).getProcessInstanceId()).list();
if(executionList.size()==1){
//单线流程，直接向下一节点任务负责人发送信息
assignee = nextNodeUserTask.get(0).getAssignee();//下一节点任务的参与者uid
if (assignee == null || "".equals(assignee)){
log.error("下一节点任务参与者为空");
return;
}
SysUser assigneeUser = sysUserService.selectUserByUserName(assignee);//下一节点任务参与者用户信息
//2、获取流程实例的任务属性
GatherTaskProperty gatherTaskProperty = gatherTaskPropertyMapper.selectGatherTaskPropertyByProcessInstanceId(task.getProcessInstanceId());
SysUser initialUser = sysUserService.selectUserByUserName(gatherTaskProperty.getCreateBy());//发起人用户信息 //3、发送邮件、短信提醒
sendTaskSMNotice(nextNodeUserTask.get(0), assigneeUser, initialUser);
sendTaskMailNotice(nextNodeUserTask.get(0), assigneeUser, initialUser);
sendTask(task,nextNodeUserTask.get(0));
}else{
//多线流程，只有一条执行实例完成时有可能出现一个任务节点，此时跳过
return;
} } //3、如果下一节点任务不只一个任务，act_ru_task中有多条数据
Set<Task> taskArraySet = new HashSet<>();//去重
if (nextNodeUserTask.size() > 1) {
for (int i = 0; i < nextNodeUserTask.size() - 1; i++) {
Date timeOne = nextNodeUserTask.get(i).getCreateTime();
Date timeTwo = nextNodeUserTask.get(i + 1).getCreateTime();
if (timeOne.compareTo(timeTwo) == 0) {
//如果当前任务的创建时间相同，都发送
taskArraySet.add(nextNodeUserTask.get(i));
taskArraySet.add(nextNodeUserTask.get(i + 1));
} else if (timeOne.compareTo(timeTwo) > 0) {
//如果当前任务的创建时间不同，timeOne在timeTwo时间之后
taskArraySet.add(nextNodeUserTask.get(i));//只发送最近时间创建的任务
} else {
//如果当前任务的创建时间不同，timeOne在timeTwo时间之前
taskArraySet.add(nextNodeUserTask.get(i + 1));//只发送最近时间创建的任务
}
} }
for (Task nextNodeTask : taskArraySet) {
sendTask(task, nextNodeTask) ;
}
}

在这一个版本的代码，我加入了大量的判断，在后期发现这里的逻辑只能适用于两条并行的流程，三条并行会有重复发送的情况，而且在单线流程与并行流程的判断处有逻辑错误，不适合下图流程

在2、3、4任务完成后不会向5发送信息，这是严重的逻辑性错误

（3）代码的最终版本

/**
* @param task 当前节点的任务信息
* @author : ADun
* 发送待办提醒的通用入口（包含短信+邮箱提醒）
*/
public void sendTaskNotice(Task task) {
//1、获取下一节点所有任务信息，实际是查询act_ru_task表中的信息
List<Task> nextNodeUserTask = taskQueryService.nextAllNodeTaskList(task);
//下一节点任务为空，即当前节点为最后一个节点
if (nextNodeUserTask == null || nextNodeUserTask.size() <= 0) {
return;
} for (Task nextNodeTask : nextNodeUserTask) {
String assignee = nextNodeTask.getAssignee();
if(assignee == null || "".equals(assignee)){
log.error("taskId为" + nextNodeTask.getId() + "的任务参与者不存在！");
continue;
}
//获取当前任务的结束时间
HistoricTaskInstance hisTask = historyService.createHistoricTaskInstanceQuery().taskId(task.getId()).singleResult();
Date hisTaskEndTime = hisTask.getEndTime();
//获取下一任务开始时间
Date nextNodeTaskCreateTime = nextNodeTask.getCreateTime();
//只有下一任务节点创建时间与当前任务完成时间相等时，向下一节点发送信息
if (nextNodeTaskCreateTime.compareTo(hisTaskEndTime) == 0) {
sendTask(task, nextNodeTask);
}
} }

在这一版本中我还是沿用上一版本代码的思想，在时间中做文章，因为这是一个公司内部的OA系统，网络延时非常小，几乎不计，最后我是通过判断当前任务的完成时间是否下一任务的开始时间相同，相同就向下一任务审批人发送信息，我认为这里还是存在漏洞，可能时间会存在秒级的不准确，大家有什么好的想法可以在评论区留言。