activiti 工作流会签 / 多人审批时一人通过也可 / 在当前节点获取下一节点的信息 / 流程部署之后发布之前获取所有节点的信息 / 流程启动开始之前传送之后节点办理人 / 同一结点设置多个监听
2017-09-05 09:41
1686 查看
下面是项目开发中使用到的内容，做一下记录
1. activiti 工作流会签时为所有的都审批通过才可进入下一环节：
1.1 编写监听类
public class MyTaksListener implements TaskListener {
public void notify(DelegateTask delegateTask) {
System.out.println("delegateTask.getEventName() = " + delegateTask.getEventName());
//添加会签的人员，以下所有的都审批通过才可进入下一环节
List<String> assigneeList = new ArrayList<String>();
assigneeList.add("wangba");
assigneeList.add("wangjiu");
delegateTask.setVariable("publicityList",assigneeList);
}
}
1.2 “员工请假申请”中添加此监听类
1.3 “项目组长审批”中
以上几个字段的解释可以参照下面这篇文章：http://www.wangchao.net.cn/it/detail_132191.html
1.4 项目组长审批时，通过taskAssignee来获取个人任务
[b]// 获取总记录数
[/b]
total = taskService.createTaskQuery().taskAssignee(userId).taskNameLike("%" + s_name + "%").count();
// 可以观察表 ACT_RU_TASK 的变化
taskList = taskService.createTaskQuery()
// 根据用户id查询
.taskAssignee(userId)
// 根据任务名称查询
.taskNameLike("%" + s_name + "%")
// 返回带分页的结果集合
.listPage(pageInfo.getPageIndex(), pageInfo.getPageSize());
==================================================================================
2. activiti 工作流多人审批时若一人通过也可进入下一环节：
2.1 编写监听类
public class MangerTaskHandlerCandidateUsers implements TaskListener{
public void notify(DelegateTask delegateTask) {
//添加审批的人员，以下任何一人通过即可进入下一环节
String[] empLoyees = {"wangba","wangjiu"};
delegateTask.addCandidateUsers(Arrays.asList(empLoyees));
}
}
2.2 “项目组长审批”中
2.3 项目组长审批时，通过taskCandidateUser来获取个人任务
[b]// 获取总记录数
[/b]
total = taskService.createTaskQuery().taskCandidateUser(userId).taskNameLike("%" + s_name + "%").count();
// 有想法的话，可以去数据库观察 ACT_RU_TASK 的变化
taskList = taskService.createTaskQuery()
// 根据用户id查询
.taskCandidateUser(userId)
// 根据任务名称查询
.taskNameLike("%" + s_name + "%")
// 返回带分页的结果集合
.listPage(pageInfo.getPageIndex(), pageInfo.getPageSize());
[b]============================================================================
[/b]
在当前节点获取下一节点的信息
/**
* 根据实例编号查找下一个任务节点
*
* @param String
* procInstId ：实例编号
* @return
*/
@RequestMapping("/backTaskTab")
public TaskDefinition backTaskTab(String taskId) {
Task task = taskService.createTaskQuery() // 创建任务查询
.taskId(taskId) // 根据任务id查询
.singleResult();
String procInstId = task.getProcessInstanceId();
// 流程标示
String processDefinitionId = historyService.createHistoricProcessInstanceQuery().processInstanceId(procInstId)
.singleResult().getProcessDefinitionId();
ProcessDefinitionEntity def = (ProcessDefinitionEntity) ((RepositoryServiceImpl) repositoryService)
.getDeployedProcessDefinition(processDefinitionId);
// 执行实例
ExecutionEntity execution = (ExecutionEntity) runtimeService.createProcessInstanceQuery()
.processInstanceId(procInstId).singleResult();
// 当前实例的执行到哪个节点
String activitiId = execution.getActivityId();
// 获得当前任务的所有节点
List<ActivityImpl> activitiList = def.getActivities();
ActivityImpl activityImpl=null;
for(int i=0;i< activitiList.size();i++){
String flag=activitiList.get(i).getId();
if(flag.equals(activitiId)){
activityImpl=activitiList.get(i);
}
}
String id = null;
int num=activitiList.indexOf(activityImpl);
ActivityImpl activityImpl_=activitiList.get(num+1);
TaskDefinition taskDefinition = ((UserTaskActivityBehavior) activityImpl_.getActivityBehavior())
.getTaskDefinition();
// 获取下一节点的代办人
System.out.println(taskDefinition.getCandidateGroupIdExpressions().toArray()[0]);
return null;
}
此篇文章，也具有一定的参照意义：
http://cheen.iteye.com/blog/1591900
[b][b]============================================================================[/b]
[/b]
流程部署之后发布之前获取所有节点的信息
（[b]参照此篇文章：http://blog.csdn.net/hiyohu/article/details/51682005）[/b]
初步设想实现一个部署完工作流之后，为UserTask节点动态分配任务执行者，或者在分支节点上添加进入条件的功能。为了实现这个功能需要解析流程定义文件取出文件中定义的所有节点。这里有两个方法可以实现此功能。
方法一（流程部署至服务器上之后可使用）：
[java]
//processDefinitionId为流程定义Id，该Id可以通过多种方式获得，如通过ProcessDefinitionQuery可以查询一个ProcessDefinition对象，Task对象中也包含 processDefinitionIdBpmnModel
model = repositoryService.getBpmnModel(processDefinitionId);
if (model != null) {
Collection<FlowElement> flowElements = model.getMainProcess().getFlowElements();
for (FlowElement e : flowElements) {
System.out.println("flowelement id:" + e.getId() + " name:" + e.getName() + " class:"
+ e.getClass().toString());
}
}
该方法适用于流程部署至服务器上之后，通过该方法可以简单快速的获取流程定义文件中各个节点信息。
方法二 读取流程定义文件方式
[java]
import java.io.InputStream;
import java.io.InputStreamReader;
import javax.xml.stream.XMLInputFactory;
import javax.xml.stream.XMLStreamException;
import javax.xml.stream.XMLStreamReader;
import org.activiti.bpmn.converter.BpmnXMLConverter;
import org.activiti.bpmn.model.BpmnModel;
import org.activiti.bpmn.model.FlowElement;
InputStream resouceStream = this.getClass().getClassLoader().getResourceAsStream("leave- formkey.bpmn20.xml");
XMLInputFactory xif = XMLInputFactory.newInstance();
InputStreamReader in;
XMLStreamReader xtr;
try {
in = new InputStreamReader(resouceStream, "UTF-8");
xtr = xif.createXMLStreamReader(in);
BpmnModel model = new BpmnXMLConverter().convertToBpmnModel(xtr);
Collection<FlowElement> flowElements = model.getMainProcess().getFlowElements();
for (FlowElement e : flowElements) {
System.out.println("flowelement id:" + e.getId() + " name:" + e.getName() + " class:"
+ e.getClass().toString());
}
} catch (XMLStreamException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (UnsupportedEncodingException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
该方法使用到了activiti的activiti-bpmn-converter-5.20.0.jar和activiti-bpmn-model-5.20.0.jar，用到了其中比较关键的一个类BpmnXMLConverter，该类将xml定义文件解析成BpmnModel对象，使用BpmnModel的getMainProcess()获取一个Process对象，该对象实际是一个继承自BaseElement、FlowElementContainer的节点容器，通过getFlowElements()获取当前流程定义文件中所有的节点对象。
该方法的好处在于可以解析本地或者未部署至Activiti引擎中的流程定义文件。
两次测试打印结果如下：
flowelement id:startevent1 name:Start class:class org.activiti.bpmn.model.StartEvent
flowelement id:deptLeaderAudit name:部门领导审批 class:class org.activiti.bpmn.model.UserTask
flowelement id:exclusivegateway5 name:Exclusive Gateway class:class org.activiti.bpmn.model.ExclusiveGateway
flowelement id:modifyApply name:调整申请 class:class org.activiti.bpmn.model.UserTask
flowelement id:hrAudit name:人事审批 class:class org.activiti.bpmn.model.UserTask
flowelement id:exclusivegateway6 name:Exclusive Gateway class:class org.activiti.bpmn.model.ExclusiveGateway
flowelement id:reportBack name:销假 class:class org.activiti.bpmn.model.UserTask
flowelement id:endevent1 name:End class:class org.activiti.bpmn.model.EndEvent
flowelement id:exclusivegateway7 name:Exclusive Gateway class:class org.activiti.bpmn.model.ExclusiveGateway
flowelement id:flow2 name: class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow3 name: class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow4 name:不同意 class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow5 name:同意 class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow6 name: class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow7 name:同意 class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow8 name: class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow9 name:不同意 class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow10 name:重新申请 class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow11 name: class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow12 name:结束流程 class:class org.activiti.bpmn.model.SequenceFlow
流程定义文件leave-formkey.bpmn20.xml：
[html]
<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC"
xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="OFFICE">
<process id="leave-formkey" name="病事假申请">
<documentation>请假流程演示</documentation>
<startEvent id="startevent1" name="Start" activiti:initiator="applyUserId"></startEvent>
<userTask id="deptLeaderAudit" name="部门领导审批" activiti:assignee="${applyUserId}" activiti:formKey="leaveHandle.form"></userTask>
<exclusiveGateway id="exclusivegateway5" name="Exclusive Gateway"></exclusiveGateway>
<userTask id="modifyApply" name="调整申请" activiti:assignee="${applyUserId}" activiti:formKey="leaveApplyAgain.form"></userTask>
<userTask id="hrAudit" name="人事审批" activiti:assignee="${applyUserId}" activiti:formKey="leaveHandle.form"></userTask>
<exclusiveGateway id="exclusivegateway6" name="Exclusive Gateway"></exclusiveGateway>
<userTask id="reportBack" name="销假" activiti:assignee="${applyUserId}" activiti:formKey="leaveHandle.form"></userTask>
<endEvent id="endevent1" name="End"></endEvent>
<exclusiveGateway id="exclusivegateway7" name="Exclusive Gateway"></exclusiveGateway>
<sequenceFlow id="flow2" name="" sourceRef="startevent1" targetRef="deptLeaderAudit"></sequenceFlow>
<sequenceFlow id="flow3" name="" sourceRef="deptLeaderAudit" targetRef="exclusivegateway5"></sequenceFlow>
<sequenceFlow id="flow4" name="不同意" sourceRef="exclusivegateway5" targetRef="modifyApply">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${deptLeaderPass == 'false'}]]></conditionExpression>
</sequenceFlow>
<sequenceFlow id="flow5" name="同意" sourceRef="exclusivegateway5" targetRef="hrAudit">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${deptLeaderPass == 'true'}]]></conditionExpression>
</sequenceFlow>
<sequenceFlow id="flow6" name="" sourceRef="hrAudit" targetRef="exclusivegateway6"></sequenceFlow>
<sequenceFlow id="flow7" name="同意" sourceRef="exclusivegateway6" targetRef="reportBack">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${hrPass == 'true'}]]></conditionExpression>
</sequenceFlow>
<sequenceFlow id="flow8" name="" sourceRef="reportBack" targetRef="endevent1"></sequenceFlow>
<sequenceFlow id="flow9" name="不同意" sourceRef="exclusivegateway6" targetRef="modifyApply">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${hrPass == 'false'}]]></conditionExpression>
</sequenceFlow>
<sequenceFlow id="flow10" name="重新申请" sourceRef="exclusivegateway7" targetRef="deptLeaderAudit">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${reApply == 'true'}]]></conditionExpression>
</sequenceFlow>
<sequenceFlow id="flow11" name="" sourceRef="modifyApply" targetRef="exclusivegateway7"></sequenceFlow>
<sequenceFlow id="flow12" name="结束流程" sourceRef="exclusivegateway7" targetRef="endevent1">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${reApply == 'false'}]]></conditionExpression>
</sequenceFlow>
</process>
<bpmndi:BPMNDiagram id="BPMNDiagram_leave-formkey">
<bpmndi:BPMNPlane bpmnElement="leave-formkey" id="BPMNPlane_leave-formkey">
<bpmndi:BPMNShape bpmnElement="startevent1" id="BPMNShape_startevent1">
<omgdc:Bounds height="35" width="35" x="10" y="90"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="deptLeaderAudit" id="BPMNShape_deptLeaderAudit">
<omgdc:Bounds height="55" width="105" x="90" y="80"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="exclusivegateway5" id="BPMNShape_exclusivegateway5">
<omgdc:Bounds height="40" width="40" x="250" y="87"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="modifyApply" id="BPMNShape_modifyApply">
<omgdc:Bounds height="55" width="105" x="218" y="190"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="hrAudit" id="BPMNShape_hrAudit">
<omgdc:Bounds height="55" width="105" x="358" y="80"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="exclusivegateway6" id="BPMNShape_exclusivegateway6">
<omgdc:Bounds height="40" width="40" x="495" y="87"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="reportBack" id="BPMNShape_reportBack">
<omgdc:Bounds height="55" width="105" x="590" y="80"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="endevent1" id="BPMNShape_endevent1">
<omgdc:Bounds height="35" width="35" x="625" y="283"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="exclusivegateway7" id="BPMNShape_exclusivegateway7">
<omgdc:Bounds height="40" width="40" x="250" y="280"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNEdge bpmnElement="flow2" id="BPMNEdge_flow2">
<omgdi:waypoint x="45" y="107"></omgdi:waypoint>
<omgdi:waypoint x="90" y="107"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow3" id="BPMNEdge_flow3">
<omgdi:waypoint x="195" y="107"></omgdi:waypoint>
<omgdi:waypoint x="250" y="107"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow4" id="BPMNEdge_flow4">
<omgdi:waypoint x="270" y="127"></omgdi:waypoint>
<omgdi:waypoint x="270" y="190"></omgdi:waypoint>
<bpmndi:BPMNLabel>
<omgdc:Bounds height="11" width="100" x="10" y="0"></omgdc:Bounds>
</bpmndi:BPMNLabel>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow5" id="BPMNEdge_flow5">
<omgdi:waypoint x="290" y="107"></omgdi:waypoint>
<omgdi:waypoint x="358" y="107"></omgdi:waypoint>
<bpmndi:BPMNLabel>
<omgdc:Bounds height="11" width="100" x="-24" y="-17"></omgdc:Bounds>
</bpmndi:BPMNLabel>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow6" id="BPMNEdge_flow6">
<omgdi:waypoint x="463" y="107"></omgdi:waypoint>
<omgdi:waypoint x="495" y="107"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow7" id="BPMNEdge_flow7">
<omgdi:waypoint x="535" y="107"></omgdi:waypoint>
<omgdi:waypoint x="590" y="107"></omgdi:waypoint>
<bpmndi:BPMNLabel>
<omgdc:Bounds height="11" width="100" x="-22" y="-17"></omgdc:Bounds>
</bpmndi:BPMNLabel>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow8" id="BPMNEdge_flow8">
<omgdi:waypoint x="642" y="135"></omgdi:waypoint>
<omgdi:waypoint x="642" y="283"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow9" id="BPMNEdge_flow9">
<omgdi:waypoint x="515" y="127"></omgdi:waypoint>
<omgdi:waypoint x="514" y="217"></omgdi:waypoint>
<omgdi:waypoint x="323" y="217"></omgdi:waypoint>
<bpmndi:BPMNLabel>
<omgdc:Bounds height="11" width="100" x="10" y="0"></omgdc:Bounds>
</bpmndi:BPMNLabel>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow10" id="BPMNEdge_flow10">
<omgdi:waypoint x="250" y="300"></omgdi:waypoint>
<omgdi:waypoint x="142" y="299"></omgdi:waypoint>
<omgdi:waypoint x="142" y="135"></omgdi:waypoint>
<bpmndi:BPMNLabel>
<omgdc:Bounds height="11" width="100" x="10" y="0"></omgdc:Bounds>
</bpmndi:BPMNLabel>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow11" id="BPMNEdge_flow11">
<omgdi:waypoint x="270" y="245"></omgdi:waypoint>
<omgdi:waypoint x="270" y="280"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow12" id="BPMNEdge_flow12">
<omgdi:waypoint x="290" y="300"></omgdi:waypoint>
<omgdi:waypoint x="625" y="300"></omgdi:waypoint>
<bpmndi:BPMNLabel>
<omgdc:Bounds height="11" width="100" x="10" y="0"></omgdc:Bounds>
</bpmndi:BPMNLabel>
</bpmndi:BPMNEdge>
</bpmndi:BPMNPlane>
</bpmndi:BPMNDiagram>
</definitions>
[b][b][b]============================================================================[/b][/b]
[/b]
流程启动开始之前将第二个和第三个节点所需要的人带过去
//下面name2和name3是前台传过来的第二个和第三个节点的办理人
Map<String, Object> variables = new HashMap<String, Object>();
variables.put("leaveId", leaveId);
variables.put("name2", "XXX");//（前台传过来的第二个节点的办理人）
variables.put("name3", "YYY");//（前台传过来的第三个节点的办理人）
// 启动流程
pi = runtimeService.startProcessInstanceByKey("activitiemployeeProcess", variables);
在第一个节点指定第二个节点的监听
public class MyTaksListener2 implements TaskListener {
public void notify(DelegateTask delegateTask) {
Map<String, Object> variables=delegateTask.getVariables();
variables.get("name2");（前台传过来的第二个节点的办理人）
//拆分variables
List<String> assigneeList = new ArrayList<String>();
assigneeList.add("wangba");
delegateTask.setVariable("publicityList",assigneeList);
}
}
在第三个节点指定本节点的办理人监听
public class MyTaksListener3 implements TaskListener {
public void notify(DelegateTask delegateTask) {
Map<String, Object> variables=delegateTask.getVariables();
System.out.println(variables);
variables.get("name3");
// String result=(String) variables.get("name3");（前台传过来的第三个节点的办理人）
String[] empLoyees = {"szx"};
delegateTask.addCandidateUsers(Arrays.asList(empLoyees));
}
}
同一结点设置多个监听
在同一结点设置两个监听，一个是设置本节点的监听，指定办理人；
一个是设置下一个节点的监听，指定会签人；
设置本节点的监听，指定办理人
public class MyTaksListener3 implements TaskListener {
public void notify(DelegateTask delegateTask) {
Map<String, Object> variables=delegateTask.getVariables();
System.out.println(variables);
String result=(String) variables.get("name3");
String[] empLoyees = {"szx"};
delegateTask.addCandidateUsers(Arrays.asList(empLoyees));
}
}
设置下一个节点的监听，指定会签人
public class MyTaksListener4 implements TaskListener {
public void notify(DelegateTask delegateTask) {
Map<String, Object> variables=delegateTask.getVariables();
String result=(String)variables.get("name2");
List<String> assigneeList = new ArrayList<String>();
assigneeList.add("ss");
delegateTask.setVariable("publicityList",assigneeList);
}
}
1. activiti 工作流会签时为所有的都审批通过才可进入下一环节：
1.1 编写监听类
public class MyTaksListener implements TaskListener {
public void notify(DelegateTask delegateTask) {
System.out.println("delegateTask.getEventName() = " + delegateTask.getEventName());
//添加会签的人员，以下所有的都审批通过才可进入下一环节
List<String> assigneeList = new ArrayList<String>();
assigneeList.add("wangba");
assigneeList.add("wangjiu");
delegateTask.setVariable("publicityList",assigneeList);
}
}
1.2 “员工请假申请”中添加此监听类
1.3 “项目组长审批”中
isSequential=false时，表示的并行执行，即该节点下的多条任务可以同时执行。 activiti:collection：用于执行该会签环节的参与参与的人，此处是使用的一个名叫publicityList的流程变量
activiti:elementVariable：此处表示的是每一个分支都有一个名叫publicity的流程变量，和上方的activiti:assignee结合
以上几个字段的解释可以参照下面这篇文章：http://www.wangchao.net.cn/it/detail_132191.html
1.4 项目组长审批时，通过taskAssignee来获取个人任务
[b]// 获取总记录数
[/b]
total = taskService.createTaskQuery().taskAssignee(userId).taskNameLike("%" + s_name + "%").count();
// 可以观察表 ACT_RU_TASK 的变化
taskList = taskService.createTaskQuery()
// 根据用户id查询
.taskAssignee(userId)
// 根据任务名称查询
.taskNameLike("%" + s_name + "%")
// 返回带分页的结果集合
.listPage(pageInfo.getPageIndex(), pageInfo.getPageSize());
==================================================================================
2. activiti 工作流多人审批时若一人通过也可进入下一环节：
2.1 编写监听类
public class MangerTaskHandlerCandidateUsers implements TaskListener{
public void notify(DelegateTask delegateTask) {
//添加审批的人员，以下任何一人通过即可进入下一环节
String[] empLoyees = {"wangba","wangjiu"};
delegateTask.addCandidateUsers(Arrays.asList(empLoyees));
}
}
2.2 “项目组长审批”中
2.3 项目组长审批时，通过taskCandidateUser来获取个人任务
[b]// 获取总记录数
[/b]
total = taskService.createTaskQuery().taskCandidateUser(userId).taskNameLike("%" + s_name + "%").count();
// 有想法的话，可以去数据库观察 ACT_RU_TASK 的变化
taskList = taskService.createTaskQuery()
// 根据用户id查询
.taskCandidateUser(userId)
// 根据任务名称查询
.taskNameLike("%" + s_name + "%")
// 返回带分页的结果集合
.listPage(pageInfo.getPageIndex(), pageInfo.getPageSize());
[b]============================================================================
[/b]
在当前节点获取下一节点的信息
/**
* 根据实例编号查找下一个任务节点
*
* @param String
* procInstId ：实例编号
* @return
*/
@RequestMapping("/backTaskTab")
public TaskDefinition backTaskTab(String taskId) {
Task task = taskService.createTaskQuery() // 创建任务查询
.taskId(taskId) // 根据任务id查询
.singleResult();
String procInstId = task.getProcessInstanceId();
// 流程标示
String processDefinitionId = historyService.createHistoricProcessInstanceQuery().processInstanceId(procInstId)
.singleResult().getProcessDefinitionId();
ProcessDefinitionEntity def = (ProcessDefinitionEntity) ((RepositoryServiceImpl) repositoryService)
.getDeployedProcessDefinition(processDefinitionId);
// 执行实例
ExecutionEntity execution = (ExecutionEntity) runtimeService.createProcessInstanceQuery()
.processInstanceId(procInstId).singleResult();
// 当前实例的执行到哪个节点
String activitiId = execution.getActivityId();
// 获得当前任务的所有节点
List<ActivityImpl> activitiList = def.getActivities();
ActivityImpl activityImpl=null;
for(int i=0;i< activitiList.size();i++){
String flag=activitiList.get(i).getId();
if(flag.equals(activitiId)){
activityImpl=activitiList.get(i);
}
}
String id = null;
int num=activitiList.indexOf(activityImpl);
ActivityImpl activityImpl_=activitiList.get(num+1);
TaskDefinition taskDefinition = ((UserTaskActivityBehavior) activityImpl_.getActivityBehavior())
.getTaskDefinition();
// 获取下一节点的代办人
System.out.println(taskDefinition.getCandidateGroupIdExpressions().toArray()[0]);
return null;
}
此篇文章，也具有一定的参照意义：
http://cheen.iteye.com/blog/1591900
[b][b]============================================================================[/b]
[/b]
流程部署之后发布之前获取所有节点的信息
（[b]参照此篇文章：http://blog.csdn.net/hiyohu/article/details/51682005）[/b]
初步设想实现一个部署完工作流之后，为UserTask节点动态分配任务执行者，或者在分支节点上添加进入条件的功能。为了实现这个功能需要解析流程定义文件取出文件中定义的所有节点。这里有两个方法可以实现此功能。
方法一（流程部署至服务器上之后可使用）：
[java]
//processDefinitionId为流程定义Id，该Id可以通过多种方式获得，如通过ProcessDefinitionQuery可以查询一个ProcessDefinition对象，Task对象中也包含 processDefinitionIdBpmnModel
model = repositoryService.getBpmnModel(processDefinitionId);
if (model != null) {
Collection<FlowElement> flowElements = model.getMainProcess().getFlowElements();
for (FlowElement e : flowElements) {
System.out.println("flowelement id:" + e.getId() + " name:" + e.getName() + " class:"
+ e.getClass().toString());
}
}
该方法适用于流程部署至服务器上之后，通过该方法可以简单快速的获取流程定义文件中各个节点信息。
方法二 读取流程定义文件方式
[java]
import java.io.InputStream;
import java.io.InputStreamReader;
import javax.xml.stream.XMLInputFactory;
import javax.xml.stream.XMLStreamException;
import javax.xml.stream.XMLStreamReader;
import org.activiti.bpmn.converter.BpmnXMLConverter;
import org.activiti.bpmn.model.BpmnModel;
import org.activiti.bpmn.model.FlowElement;
InputStream resouceStream = this.getClass().getClassLoader().getResourceAsStream("leave- formkey.bpmn20.xml");
XMLInputFactory xif = XMLInputFactory.newInstance();
InputStreamReader in;
XMLStreamReader xtr;
try {
in = new InputStreamReader(resouceStream, "UTF-8");
xtr = xif.createXMLStreamReader(in);
BpmnModel model = new BpmnXMLConverter().convertToBpmnModel(xtr);
Collection<FlowElement> flowElements = model.getMainProcess().getFlowElements();
for (FlowElement e : flowElements) {
System.out.println("flowelement id:" + e.getId() + " name:" + e.getName() + " class:"
+ e.getClass().toString());
}
} catch (XMLStreamException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (UnsupportedEncodingException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
该方法使用到了activiti的activiti-bpmn-converter-5.20.0.jar和activiti-bpmn-model-5.20.0.jar，用到了其中比较关键的一个类BpmnXMLConverter，该类将xml定义文件解析成BpmnModel对象，使用BpmnModel的getMainProcess()获取一个Process对象，该对象实际是一个继承自BaseElement、FlowElementContainer的节点容器，通过getFlowElements()获取当前流程定义文件中所有的节点对象。
该方法的好处在于可以解析本地或者未部署至Activiti引擎中的流程定义文件。
两次测试打印结果如下：
flowelement id:startevent1 name:Start class:class org.activiti.bpmn.model.StartEvent
flowelement id:deptLeaderAudit name:部门领导审批 class:class org.activiti.bpmn.model.UserTask
flowelement id:exclusivegateway5 name:Exclusive Gateway class:class org.activiti.bpmn.model.ExclusiveGateway
flowelement id:modifyApply name:调整申请 class:class org.activiti.bpmn.model.UserTask
flowelement id:hrAudit name:人事审批 class:class org.activiti.bpmn.model.UserTask
flowelement id:exclusivegateway6 name:Exclusive Gateway class:class org.activiti.bpmn.model.ExclusiveGateway
flowelement id:reportBack name:销假 class:class org.activiti.bpmn.model.UserTask
flowelement id:endevent1 name:End class:class org.activiti.bpmn.model.EndEvent
flowelement id:exclusivegateway7 name:Exclusive Gateway class:class org.activiti.bpmn.model.ExclusiveGateway
flowelement id:flow2 name: class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow3 name: class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow4 name:不同意 class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow5 name:同意 class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow6 name: class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow7 name:同意 class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow8 name: class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow9 name:不同意 class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow10 name:重新申请 class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow11 name: class:class org.activiti.bpmn.model.SequenceFlow
flowelement id:flow12 name:结束流程 class:class org.activiti.bpmn.model.SequenceFlow
流程定义文件leave-formkey.bpmn20.xml：
[html]
<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC"
xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="OFFICE">
<process id="leave-formkey" name="病事假申请">
<documentation>请假流程演示</documentation>
<startEvent id="startevent1" name="Start" activiti:initiator="applyUserId"></startEvent>
<userTask id="deptLeaderAudit" name="部门领导审批" activiti:assignee="${applyUserId}" activiti:formKey="leaveHandle.form"></userTask>
<exclusiveGateway id="exclusivegateway5" name="Exclusive Gateway"></exclusiveGateway>
<userTask id="modifyApply" name="调整申请" activiti:assignee="${applyUserId}" activiti:formKey="leaveApplyAgain.form"></userTask>
<userTask id="hrAudit" name="人事审批" activiti:assignee="${applyUserId}" activiti:formKey="leaveHandle.form"></userTask>
<exclusiveGateway id="exclusivegateway6" name="Exclusive Gateway"></exclusiveGateway>
<userTask id="reportBack" name="销假" activiti:assignee="${applyUserId}" activiti:formKey="leaveHandle.form"></userTask>
<endEvent id="endevent1" name="End"></endEvent>
<exclusiveGateway id="exclusivegateway7" name="Exclusive Gateway"></exclusiveGateway>
<sequenceFlow id="flow2" name="" sourceRef="startevent1" targetRef="deptLeaderAudit"></sequenceFlow>
<sequenceFlow id="flow3" name="" sourceRef="deptLeaderAudit" targetRef="exclusivegateway5"></sequenceFlow>
<sequenceFlow id="flow4" name="不同意" sourceRef="exclusivegateway5" targetRef="modifyApply">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${deptLeaderPass == 'false'}]]></conditionExpression>
</sequenceFlow>
<sequenceFlow id="flow5" name="同意" sourceRef="exclusivegateway5" targetRef="hrAudit">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${deptLeaderPass == 'true'}]]></conditionExpression>
</sequenceFlow>
<sequenceFlow id="flow6" name="" sourceRef="hrAudit" targetRef="exclusivegateway6"></sequenceFlow>
<sequenceFlow id="flow7" name="同意" sourceRef="exclusivegateway6" targetRef="reportBack">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${hrPass == 'true'}]]></conditionExpression>
</sequenceFlow>
<sequenceFlow id="flow8" name="" sourceRef="reportBack" targetRef="endevent1"></sequenceFlow>
<sequenceFlow id="flow9" name="不同意" sourceRef="exclusivegateway6" targetRef="modifyApply">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${hrPass == 'false'}]]></conditionExpression>
</sequenceFlow>
<sequenceFlow id="flow10" name="重新申请" sourceRef="exclusivegateway7" targetRef="deptLeaderAudit">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${reApply == 'true'}]]></conditionExpression>
</sequenceFlow>
<sequenceFlow id="flow11" name="" sourceRef="modifyApply" targetRef="exclusivegateway7"></sequenceFlow>
<sequenceFlow id="flow12" name="结束流程" sourceRef="exclusivegateway7" targetRef="endevent1">
<conditionExpression xsi:type="tFormalExpression"><![CDATA[${reApply == 'false'}]]></conditionExpression>
</sequenceFlow>
</process>
<bpmndi:BPMNDiagram id="BPMNDiagram_leave-formkey">
<bpmndi:BPMNPlane bpmnElement="leave-formkey" id="BPMNPlane_leave-formkey">
<bpmndi:BPMNShape bpmnElement="startevent1" id="BPMNShape_startevent1">
<omgdc:Bounds height="35" width="35" x="10" y="90"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="deptLeaderAudit" id="BPMNShape_deptLeaderAudit">
<omgdc:Bounds height="55" width="105" x="90" y="80"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="exclusivegateway5" id="BPMNShape_exclusivegateway5">
<omgdc:Bounds height="40" width="40" x="250" y="87"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="modifyApply" id="BPMNShape_modifyApply">
<omgdc:Bounds height="55" width="105" x="218" y="190"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="hrAudit" id="BPMNShape_hrAudit">
<omgdc:Bounds height="55" width="105" x="358" y="80"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="exclusivegateway6" id="BPMNShape_exclusivegateway6">
<omgdc:Bounds height="40" width="40" x="495" y="87"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="reportBack" id="BPMNShape_reportBack">
<omgdc:Bounds height="55" width="105" x="590" y="80"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="endevent1" id="BPMNShape_endevent1">
<omgdc:Bounds height="35" width="35" x="625" y="283"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape bpmnElement="exclusivegateway7" id="BPMNShape_exclusivegateway7">
<omgdc:Bounds height="40" width="40" x="250" y="280"></omgdc:Bounds>
</bpmndi:BPMNShape>
<bpmndi:BPMNEdge bpmnElement="flow2" id="BPMNEdge_flow2">
<omgdi:waypoint x="45" y="107"></omgdi:waypoint>
<omgdi:waypoint x="90" y="107"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow3" id="BPMNEdge_flow3">
<omgdi:waypoint x="195" y="107"></omgdi:waypoint>
<omgdi:waypoint x="250" y="107"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow4" id="BPMNEdge_flow4">
<omgdi:waypoint x="270" y="127"></omgdi:waypoint>
<omgdi:waypoint x="270" y="190"></omgdi:waypoint>
<bpmndi:BPMNLabel>
<omgdc:Bounds height="11" width="100" x="10" y="0"></omgdc:Bounds>
</bpmndi:BPMNLabel>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow5" id="BPMNEdge_flow5">
<omgdi:waypoint x="290" y="107"></omgdi:waypoint>
<omgdi:waypoint x="358" y="107"></omgdi:waypoint>
<bpmndi:BPMNLabel>
<omgdc:Bounds height="11" width="100" x="-24" y="-17"></omgdc:Bounds>
</bpmndi:BPMNLabel>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow6" id="BPMNEdge_flow6">
<omgdi:waypoint x="463" y="107"></omgdi:waypoint>
<omgdi:waypoint x="495" y="107"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow7" id="BPMNEdge_flow7">
<omgdi:waypoint x="535" y="107"></omgdi:waypoint>
<omgdi:waypoint x="590" y="107"></omgdi:waypoint>
<bpmndi:BPMNLabel>
<omgdc:Bounds height="11" width="100" x="-22" y="-17"></omgdc:Bounds>
</bpmndi:BPMNLabel>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow8" id="BPMNEdge_flow8">
<omgdi:waypoint x="642" y="135"></omgdi:waypoint>
<omgdi:waypoint x="642" y="283"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow9" id="BPMNEdge_flow9">
<omgdi:waypoint x="515" y="127"></omgdi:waypoint>
<omgdi:waypoint x="514" y="217"></omgdi:waypoint>
<omgdi:waypoint x="323" y="217"></omgdi:waypoint>
<bpmndi:BPMNLabel>
<omgdc:Bounds height="11" width="100" x="10" y="0"></omgdc:Bounds>
</bpmndi:BPMNLabel>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow10" id="BPMNEdge_flow10">
<omgdi:waypoint x="250" y="300"></omgdi:waypoint>
<omgdi:waypoint x="142" y="299"></omgdi:waypoint>
<omgdi:waypoint x="142" y="135"></omgdi:waypoint>
<bpmndi:BPMNLabel>
<omgdc:Bounds height="11" width="100" x="10" y="0"></omgdc:Bounds>
</bpmndi:BPMNLabel>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow11" id="BPMNEdge_flow11">
<omgdi:waypoint x="270" y="245"></omgdi:waypoint>
<omgdi:waypoint x="270" y="280"></omgdi:waypoint>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge bpmnElement="flow12" id="BPMNEdge_flow12">
<omgdi:waypoint x="290" y="300"></omgdi:waypoint>
<omgdi:waypoint x="625" y="300"></omgdi:waypoint>
<bpmndi:BPMNLabel>
<omgdc:Bounds height="11" width="100" x="10" y="0"></omgdc:Bounds>
</bpmndi:BPMNLabel>
</bpmndi:BPMNEdge>
</bpmndi:BPMNPlane>
</bpmndi:BPMNDiagram>
</definitions>
[b][b][b]============================================================================[/b][/b]
[/b]
流程启动开始之前将第二个和第三个节点所需要的人带过去
//下面name2和name3是前台传过来的第二个和第三个节点的办理人
Map<String, Object> variables = new HashMap<String, Object>();
variables.put("leaveId", leaveId);
variables.put("name2", "XXX");//（前台传过来的第二个节点的办理人）
variables.put("name3", "YYY");//（前台传过来的第三个节点的办理人）
// 启动流程
pi = runtimeService.startProcessInstanceByKey("activitiemployeeProcess", variables);
在第一个节点指定第二个节点的监听
public class MyTaksListener2 implements TaskListener {
public void notify(DelegateTask delegateTask) {
Map<String, Object> variables=delegateTask.getVariables();
variables.get("name2");（前台传过来的第二个节点的办理人）
//拆分variables
List<String> assigneeList = new ArrayList<String>();
assigneeList.add("wangba");
delegateTask.setVariable("publicityList",assigneeList);
}
}
在第三个节点指定本节点的办理人监听
public class MyTaksListener3 implements TaskListener {
public void notify(DelegateTask delegateTask) {
Map<String, Object> variables=delegateTask.getVariables();
System.out.println(variables);
variables.get("name3");
// String result=(String) variables.get("name3");（前台传过来的第三个节点的办理人）
String[] empLoyees = {"szx"};
delegateTask.addCandidateUsers(Arrays.asList(empLoyees));
}
}
同一结点设置多个监听
在同一结点设置两个监听，一个是设置本节点的监听，指定办理人；
一个是设置下一个节点的监听，指定会签人；
设置本节点的监听，指定办理人
public class MyTaksListener3 implements TaskListener {
public void notify(DelegateTask delegateTask) {
Map<String, Object> variables=delegateTask.getVariables();
System.out.println(variables);
String result=(String) variables.get("name3");
String[] empLoyees = {"szx"};
delegateTask.addCandidateUsers(Arrays.asList(empLoyees));
}
}
设置下一个节点的监听，指定会签人
public class MyTaksListener4 implements TaskListener {
public void notify(DelegateTask delegateTask) {
Map<String, Object> variables=delegateTask.getVariables();
String result=(String)variables.get("name2");
List<String> assigneeList = new ArrayList<String>();
assigneeList.add("ss");
delegateTask.setVariable("publicityList",assigneeList);
}
}
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- activiti中有任务id,获取当前流程节点的信息
- Activiti工作流之获取流程定义中所有的节点
- Activiti工作流之获取流程定义中所有的节点
- activiti 部署流程定义（InputStream） 流程变量设置 及获取流程变量、查询流程变量历史表
- activiti 工作流会签 / 多人审批时若一人通过即可
- Activiti获取某个流程实例已经审批的节点记录
- activiti任务监听可以获取启动流程时的参数
- activiti 工作流会签 / 多人审批时若一人通过即可
- infopath表单预览正常，发布后无法通过Web Service获取当前用户信息的解决方案
- activiti根据当前节点获取下一个节点信息
- 通过VBS访问WMI，获取当前所有进程信息
- activiti 工作流会签 / 多人审批时若一人通过即可
- 通过广播方式获取当前网络类型，如果是Wifi，获取对应的信息（附加有root之后可实现保存的无线网名称及密码获取）
- Launcher里获取当前的所有的app和widget的包名和启动activity类名
- Activiti 5.18启动流程到完成所有任务之间的数据库变化(转)
- activiti web流程设计器 工作流的 整合视频教程 SSM和独立部署
- 框架 day58 BOS项目练习(基于activiti物流配送流程,启动,查询,办理,项目知识点复习)
- 通过GlobalMemoryStatus函数获取当前虚拟内存和物理内存信息
- 工作流引擎Activiti学习第四天（七）--- 设置获取与流程变量
- 开始进行 64 位 Windows 系统编程之前需要了解的所有信息