Activiti 之 获取下一节点信息
基于Activiti的工作流，有时候我们需要处理以下情况，一个流程跑到了一个分支边缘，
我们需要只要这个流程将会往哪个方向流转，但我们需要在流转之前就明确他的方向以便用户选择下一个节点的处理人(每个节点的处理人选择范围是不一样的)
如果是直线类型的流程我们直接查询流程的定义就能明确下一个节点。
但如果当前节点下面是一个网关或者是网关组（多个连接在一起的网关），那么我们可能需要自己去判断这个流转了。
实现的大致步骤如下：
1.根据用户输入的任务id查询出这个流程实例的基本信息
2.递归查询这个节点定义的下级节点 直到找到用户节点（usertask）
3.在步骤2中，如果下级节点是网关，那么我们需要查询这个网关具体往哪走
由于我用的是外挂表单 所以每个流程都对应一张表单实例数据表 ，以“custom_form_”开头，后面接流程定义id
具体的实现代码如下
@RequestMapping("test")
public String test() throws Exception{
return getNextTaskGroup("1037509");
}
/**
* 获取下一个用户任务用户组信息
* @param String taskId 任务Id信息
* @return 下一个用户任务用户组信息
* @throws Exception
*/
public String getNextTaskGroup(String taskId) throws Exception {
ProcessDefinitionEntity processDefinitionEntity = null;
String id = null;
TaskDefinition task = null;
this.taskId=taskId;
//获取流程实例Id信息
processInstanceId = taskService.createTaskQuery().taskId(taskId).singleResult().getProcessInstanceId();
//获取流程发布Id信息
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.getKey();
}
/**
* 下一个任务节点信息,
*
* 如果下一个节点为用户任务则直接返回,
*
* 如果下一个节点为排他网关, 获取排他网关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
* @throws Exception
*/
private TaskDefinition nextTaskDefinition(ActivityImpl activityImpl, String activityId, String elString, String processInstanceId) throws Exception{
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(elString ==null || elString.equals("")) {
//获取流程启动时设置的网关判断条件信息
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(), s.toString().trim(), 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();
Object object= runtimeService.getVariable(execution.getId(), gatewayId);
return object==null? "":object.toString();
}
/**
* 根据key和value判断el表达式是否通过信息
* @param String key el表达式key信息
* @param String el el表达式信息
* @param String value el表达式传入值信息
* @return
* @throws Exception
*/
public boolean isCondition(String key, String el, String value) throws Exception {
ExpressionFactory factory = new ExpressionFactoryImpl();
SimpleContext context = new SimpleContext();
String TableName="custom_form_"+ definitionId.split(":")[0].replace("-", "").toLowerCase();
PageData pdData=(PageData)formService.searchInstantiationFormByKey(TableName, processInstanceId);
context.setVariable(key, factory.createValueExpression(value, String.class));
for (Object k : pdData.keySet()) {
context.setVariable(k.toString(), factory.createValueExpression(pdData.get(k),pdData.get(k).getClass()));
}
context.setVariable("Type", factory.createValueExpression("tongyi",String.class));
ValueExpression e = factory.createValueExpression(context, el, boolean.class);
return (Boolean) e.getValue(context);
}
