在实际的工作流业务开发中, 当用户完成当前用户任务时, 需要指定下一个用户任务的审核人。此时我们需要获取下一个节点的一些信息, 来确定下一个用户任务的审核人有哪些。
在实际工作流程中, 当前用户任务后的节点可能为用户任务, 也可能为网关。如果下一个节点为网关我们需要判断流程线路。
/** * 获取下一个用户任务用户组信息 * @param String taskId 任务Id信息 * @return 下一个用户任务用户组信息 * @throws Exception */ public Set<Expression> getNextTaskGroup(String taskId) throws Exception { ProcessDefinitionEntity processDefinitionEntity = null; String id = null; TaskDefinition task = null; //获取流程实例Id信息 String processInstanceId = taskService.createTaskQuery().taskId(taskId).singleResult().getProcessInstanceId(); //获取流程发布Id信息 String definitionId = runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult().getProcessDefinitionId(); processDefinitionEntity = (ProcessDefinitionEntity) ((RepositoryServiceImpl) repositoryService) .getDeployedProcessDefinition(definitionId); ExecutionEntity execution = (ExecutionEntity) runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult(); //当前流程节点Id信息 String activitiId = execution.getActivityId(); //获取流程所有节点信息 List<ActivityImpl> activitiList = processDefinitionEntity.getActivities(); //遍历所有节点信息 for(ActivityImpl activityImpl : activitiList){ id = activityImpl.getId(); // 找到当前节点信息 if (activitiId.equals(id)) { //获取下一个节点信息 task = nextTaskDefinition(activityImpl, activityImpl.getId(), null, processInstanceId); break; } } return task.getCandidateGroupIdExpressions(); } /** * 下一个任务节点信息, * * 如果下一个节点为用户任务则直接返回, * * 如果下一个节点为排他网关, 获取排他网关Id信息, 根据排他网关Id信息和execution获取流程实例排他网关Id为key的变量值, * 根据变量值分别执行排他网关后线路中的el表达式, 并找到el表达式通过的线路后的用户任务信息 * @param ActivityImpl activityImpl 流程节点信息 * @param String activityId 当前流程节点Id信息 * @param String elString 排他网关顺序流线段判断条件, 例如排他网关顺序留线段判断条件为${money>1000}, 若满足流程启动时设置variables中的money>1000, 则流程流向该顺序流信息 * @param String processInstanceId 流程实例Id信息 * @return */ private TaskDefinition nextTaskDefinition(ActivityImpl activityImpl, String activityId, String elString, String processInstanceId){ PvmActivity ac = null; Object s = null; //如果遍历节点为用户任务并且节点不是当前节点信息 if("userTask".equals(activityImpl.getProperty("type")) && !activityId.equals(activityImpl.getId())){ //获取该节点下一个节点信息 TaskDefinition taskDefinition = ((UserTaskActivityBehavior)activityImpl.getActivityBehavior()).getTaskDefinition(); return taskDefinition; }else{ //获取节点所有流向线路信息 List<PvmTransition> outTransitions = activityImpl.getOutgoingTransitions(); List<PvmTransition> outTransitionsTemp = null; for(PvmTransition tr : outTransitions){ ac = tr.getDestination(); //获取线路的终点节点 //如果流向线路为排他网关 if("exclusiveGateway".equals(ac.getProperty("type"))){ outTransitionsTemp = ac.getOutgoingTransitions(); //如果网关路线判断条件为空信息 if(StrUtils.isEmpty(elString)) { //获取流程启动时设置的网关判断条件信息 elString = getGatewayCondition(ac.getId(), processInstanceId); } //如果排他网关只有一条线路信息 if(outTransitionsTemp.size() == 1){ return nextTaskDefinition((ActivityImpl)outTransitionsTemp.get(0).getDestination(), activityId, elString, processInstanceId); }else if(outTransitionsTemp.size() > 1){ //如果排他网关有多条线路信息 for(PvmTransition tr1 : outTransitionsTemp){ s = tr1.getProperty("conditionText"); //获取排他网关线路判断条件信息 //判断el表达式是否成立 if(isCondition(ac.getId(), StrUtils.trim(s.toString()), elString)){ return nextTaskDefinition((ActivityImpl)tr1.getDestination(), activityId, elString, processInstanceId); } } } }else if("userTask".equals(ac.getProperty("type"))){ return ((UserTaskActivityBehavior)((ActivityImpl)ac).getActivityBehavior()).getTaskDefinition(); }else{ } } return null; } } /** * 查询流程启动时设置排他网关判断条件信息 * @param String gatewayId 排他网关Id信息, 流程启动时设置网关路线判断条件key为网关Id信息 * @param String processInstanceId 流程实例Id信息 * @return */ public String getGatewayCondition(String gatewayId, String processInstanceId) { Execution execution = runtimeService.createExecutionQuery().processInstanceId(processInstanceId).singleResult(); return runtimeService.getVariable(execution.getId(), gatewayId).toString(); } /** * 根据key和value判断el表达式是否通过信息 * @param String key el表达式key信息 * @param String el el表达式信息 * @param String value el表达式传入值信息 * @return */ public boolean isCondition(String key, String el, String value) { ExpressionFactory factory = new ExpressionFactoryImpl(); SimpleContext context = new SimpleContext(); context.setVariable(key, factory.createValueExpression(value, String.class)); ValueExpression e = factory.createValueExpression(context, el, boolean.class); return (Boolean) e.getValue(context); }
参考文档: 工作流引擎 Activiti 中获取下一节点
相关推荐
NULL 博文链接:https://chun521521.iteye.com/blog/2182997
Activiti12流程跟踪任务节点和线高亮显示,能标记流程所走过节点和线为红色,未走过的节点和线不标记,支持驳回和子流程。
工作流 activiti 5.22 退回代码实现。 activiti在设计的时候没有回退相关的...这里写一个比较简单的回退。不支持回退到并行网关前面节点,虽然回退到前面节点不会报错 但会导致任务无法结束。使用没有并行网关的回退。
原创博客:https://blog.csdn.net/a704020443/article/details/107939512 里面有介绍
在用activiti的时候经常遇到取会签人员的问题,这个文档解决怎么获取会签人员。
整个过程不影响activiti的设计,使用的是ExecutionEntity实现任务的销毁及重新指定任务节点的方式实现最终的撤回操作
2、获取节点的所有流出流向,把流向保存到临时变量oldPvmTransitionList 3、清空流向,即删除流向 4、新增流向,将流向的Destination设置成跳转节点 5、领取任务,完成任务 6、删除当前节点的流向,将流向还原成临时...
我花了半天时间把网上零散的资源整理成了一张excel表单,activiti 24张表及其每个字段都做了比较详细的介绍,看上去一目了然
activiti 5.22 explorer的war包
NULL 博文链接:https://cooperay.iteye.com/blog/1457161
用的是activiti6,demo中有bpmn流程图、创建流程、启动流程、得到代办、代办人传值、代办审批、节点之间传数据以及删除流程实例等操作。bpmn图,你需要下载插件要不然看到的是XML文件
4. TaskService: 在Activiti中业务流程定义中的每一个执行节点被称为一个Task,对流程中的数据存取,状态变更等操作均需要在Task中完成。TaskService提供了对用户Task 和Form相关的操作。它提供了运行时任务查询、...
获得一个分支的所有活动节点 - URL参数 15.93. 获得一个分支的所有活动节点 - 响应码 15.94. 获取分支列表 - URL参数 15.95. 获取分支列表 - 响应码 15.96. 查询分支 - 响应码 15.97. 获取分支的变量列表 - ...
activiti三种表单的demo实现 运行方式: 1,修改连接的数据库 2,sql文件在resources\sql下 3,访问地址http://localhost:8080/activiti-demo/main/index
Activiti工作流的课件整体、讲师: 刘洋 内容如下: 1:工作流的概念 1 2:工作流的执行过程 1 3:Activiti介绍 1 3.1:工作流引擎 2 3.2:BPMN 2 3.3:数据库(先学后看) 2 3.4:activiti.cfg.xml(activiti的配置...
做一个最简单的HellWorld流程用代码的方式实现并且走完流程。 1.首先是需要部署流程定义。...act_hi_actinst 历史活动节点表加了三条流程活动节点信息的数据(每个流程实例具体的执行活动节点的信息);
中业务流程定义中的每一个执行节点被称为一个 Task,对流程中的数据存取,状态变更等操作均需要在 Task 中完成。Task Service 提供了对用户 Task 和 Form 相关的操作。它提供了运行时任务查询、领取、完成、删除以及...
1.办理任务(获取任务节点form key中的值).avi 2.办理任务(使用任务ID,查询请假单).avi 3.办理任务(使用任务ID,查询任务完成后的连线名称集合).avi 4.完成任务.avi 5.查询办理任务时操作的历史批注信息1.avi ...
获取工作流下一个流程节点,获取流程图像,流程通过,取回,驳回
自定义属性插件获取不同的信息并添加到属性列表中,稍后 Maven 可以使用这些信息。 截至目前,它有两个目标: gitInfo :获取上次提交的 SHA1 Id、作者、时间戳和当前分支(仅在 git 存储库时使用) hostInfo :它...