Activiti6.0获取下一节点任务的心路历程 |
您所在的位置：网站首页 › activiti获取下一个节点 › Activiti6.0获取下一节点任务的心路历程 |
Activiti6.0获取下一节点任务的心路历程
|
获取下一节点任务，这个看起来非常的简单，但在开发过程中遇到了许多的坑，在这里进行记录，如果你想要快速知道结果，请看代码版本（3）。 首先，就是获取下一节点的任务信息，这里说简单也简单，说难也难，初期，我查阅了大量的资料，那些资料中都是在代码层面获取下一节点任务信息，我尝试了一下，非常的复杂，后来，我仔细研究了activiti流程变化与数据库变化之间的联系，发现act_ru_task表的执行特性，它会在当前节点任务完成后自动加载下一节点任务，根据这一点，我们就能能够获取到下一节点的相关信息。 /** * @author : ADun * 获取当前节点的下一节点所有节点信息 * 解释：当当前节点任务完成后，ac_ru_task表会删除当前任务保存下一待办任务，因此可以获得下一节点任务相关信息 * @param task * @return */ public List nextAllNodeTaskList(Task task) { List taskList = null; taskList = taskService.createTaskQuery().processInstanceId(task.getProcessInstanceId()).list(); return taskList; } 接着就是判断流程是怎样执行的了，何时给下一节点发信息，何时不发，在这里我由于对项目流程图不够熟悉，出现了各种的逻辑漏洞 （1）代码的第一个版本 /** * 发送待办提醒的通用入口 * @param task 当前节点的任务信息 */ @Override public void sendTaskNotice(Task task){ //1、获取下一节点所有任务信息，实际是查询act_ru_task表中的信息 List nextNodeUserTask = taskQueryService.nextAllNodeTaskList(task); if(nextNodeUserTask == null || nextNodeUserTask.size() List executionList = runtimeService.createExecutionQuery().processInstanceId(nextNodeTask.getProcessInstanceId()).list();//查询出所有的执行实例 for (int i = 0; i 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表中会同时保存流程实例与执行实例，并且执行实例属于流程实例，在表中可以发现，这里包含三条信息，第一条就是流程实例的信息，下面两条是执行实例的信息 在这一个版本的代码，我加入了大量的判断，在后期发现这里的逻辑只能适用于两条并行的流程，三条并行会有重复发送的情况，而且在单线流程与并行流程的判断处有逻辑错误，不适合下图流程 （3）代码的最终版本 /** * @param task 当前节点的任务信息 * @author : ADun * 发送待办提醒的通用入口 */ public void sendTaskNotice(Task task) { //1、获取下一节点所有任务信息，实际是查询act_ru_task表中的信息 List nextNodeUserTask = taskQueryService.nextAllNodeTaskList(task); //下一节点任务为空，即当前节点为最后一个节点 if (nextNodeUserTask == null || nextNodeUserTask.size() 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); } } }在这一版本中我还是沿用上一版本代码的思想，在时间中做文章，这个思想适用于网络延时非常小，几乎不计，最后我是通过判断当前任务的完成时间是否下一任务的开始时间相同，相同就向下一任务审批人发送信息，我认为这里还是存在漏洞，可能时间会存在秒级的不准确。 最新思路： 通过bpmn文件内容来获取下一节点 进而使用taskService的api进行查询 List list = taskService.createTaskQuery().processInstanceId(processInstanceId).taskDefinitionKey(nodeId).list();这里通过bpmn目前只支持简单流程，条件分支、子流程暂不支持 大家有什么好的想法可以在评论区留言。 |
由此我们也能够得出此时是一个下图这种类型的流程图 
当初是这样想的，现在看起来非常的智障：：当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）代码的第二个版本
在2、3、4任务完成后不会向5发送信息，这是严重的逻辑性错误【本文地址】
今日新闻 |
推荐新闻 |