- 浏览: 73908 次
- 性别:
- 来自: 沈阳
文章分类
- 全部博客 (75)
- spring (5)
- hibernate (4)
- struts (1)
- ibatis (1)
- others (3)
- java (6)
- 整合 (5)
- linux (4)
- easyui (1)
- javascript (4)
- web (11)
- eclipse (0)
- freemarker (0)
- maven (0)
- mongodb (0)
- spring security (1)
- log4j (0)
- jbpm (1)
- jms (3)
- redis (1)
- mysql (3)
- solr (3)
- nginx (2)
- rabbitmq (6)
- druid (1)
- jenkins (2)
- vmware (1)
- memcached (2)
- idea (1)
- elasticsearch (2)
最新评论
JBPM4.4任务撤销操作/回退操作/自由流
详细操作看注释。
操作示意图
task.jpdl.xml
TestUndoTask.java
详细操作看注释。
操作示意图
task.jpdl.xml
<?xml version="1.0" encoding="UTF-8"?> <process name="TaskAssignee" xmlns="http://jbpm.org/4.3/jpdl"> <start g="20,20,48,48"> <transition g="-23,-17" name="123" to="review"/> </start> <task assignee="#{order.owner}" g="96,16,127,52" name="review"> <transition g="-59,-17" name="to state1" to="state1"/> <transition g="-53,-17" name="to task1" to="task1"/> </task> <state g="143,142,92,52" name="state1"> <transition g="-47,-17" name="to end1" to="end1"/> </state> <task assignee="#{order.owner}" g="348,86,92,52" name="task1"> <transition name="to end1" to="end1" g="-47,-17"/> </task> <end g="213,298,48,48" name="end1"/> </process>
<?xml version="1.0" encoding="UTF-8"?> <process name="TaskAssignee" xmlns="http://jbpm.org/4.3/jpdl"> <start g="20,20,48,48"> <transition g="-23,-17" name="123" to="review"/> </start> <task assignee="#{order.owner}" g="96,16,127,52" name="review"> <transition g="-59,-17" name="to state1" to="state1"/> <transition g="-53,-17" name="to task1" to="task1"/> </task> <state g="143,142,92,52" name="state1"> <transition g="-47,-17" name="to end1" to="end1"/> </state> <task assignee="#{order.owner}" g="348,86,92,52" name="task1"> <transition name="to end1" to="end1" g="-47,-17"/> </task> <end g="213,298,48,48" name="end1"/> </process>
TestUndoTask.java
package TestPackage; import static org.junit.Assert.*; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Set; import javax.annotation.Resource; import org.jbpm.api.Configuration; import org.jbpm.api.ExecutionService; import org.jbpm.api.HistoryService; import org.jbpm.api.ProcessDefinition; import org.jbpm.api.ProcessEngine; import org.jbpm.api.ProcessInstance; import org.jbpm.api.RepositoryService; import org.jbpm.api.TaskService; import org.jbpm.api.history.HistoryActivityInstance; import org.jbpm.api.task.Task; import org.jbpm.examples.task.assignee.Order; import org.jbpm.pvm.internal.env.EnvironmentFactory; import org.jbpm.pvm.internal.env.EnvironmentImpl; import org.jbpm.pvm.internal.model.ActivityImpl; import org.jbpm.pvm.internal.model.ExecutionImpl; import org.jbpm.pvm.internal.model.ProcessDefinitionImpl; import org.jbpm.pvm.internal.model.TransitionImpl; import org.jbpm.pvm.internal.task.TaskImpl; import org.junit.*; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.AbstractJUnit4SpringContextTests; import IdentitySessionImp.DhbsIdentitySessionImp; @ContextConfiguration("classpath:applicationContext.xml") public class TestUndoTask extends AbstractJUnit4SpringContextTests { private String deploymentId; private ProcessEngine processEngine; private TaskService taskService; private RepositoryService repositoryService; private ExecutionService executionService; private HistoryService historyService; public TestUndoTask() { } @BeforeClass public static void setUpClass() throws Exception { } @AfterClass public static void tearDownClass() throws Exception { } @Before public void setUp() { processEngine = Configuration.getProcessEngine(); repositoryService = processEngine .getRepositoryService(); executionService = processEngine.getExecutionService(); taskService = processEngine.getTaskService(); historyService = processEngine.getHistoryService(); deploymentId = repositoryService.createDeployment() .addResourceFromClasspath("task.jpdl.xml") .deploy(); } @After public void tearDown() { repositoryService.deleteDeploymentCascade(deploymentId); } /*@Resource private DhbsIdentitySessionImp identitySession;*/ @Test public void testTaskAssignee() { //显示流程定义 ProcessDefinition pd = repositoryService.createProcessDefinitionQuery().uniqueResult(); System.out.println("显示流程定义 "+pd.getId()+" "+pd.getKey()+" "+" "+pd.getName()); Map<String, Object> variables = new HashMap<String, Object>(); variables.put("order", new Order("johndoe")); //启动1个实例 ProcessInstance processInstance3 = executionService.startProcessInstanceByKey("TaskAssignee", variables); String p3id = processInstance3.getId(); //johndoe的任务列表这时有了1条待办任务 List<Task> taskList = taskService.findPersonalTasks("johndoe"); assertEquals(1, taskList.size()); for(Task task : taskList){ System.out.println("task.getId() = "+task.getId()); System.out.println("task.getName() = "+task.getName()); } Task task1 = taskList.get(0); //查看第一个待办任务所有流出的节点 Set<String> outcomes = taskService.getOutcomes(task1.getId()); Iterator it = outcomes.iterator(); while(it.hasNext()){ String str = (String) it.next(); System.out.println("outcome = "+str); } assertEquals("review", task1.getName()); assertEquals("johndoe", task1.getAssignee()); //流程向下运行 Map<String, Object> assignMap = new HashMap<String, Object>(); assignMap.put("order", new Order("we")); taskService.completeTask(task1.getId(),"to task1",assignMap); //重新查询才能看到状态改变 List<ProcessInstance> piList = executionService.createProcessInstanceQuery().list(); for(ProcessInstance pi : piList){ System.out.println(pi.findActiveActivityNames()); } // 查看johndoe的待办任务列表是否空了 List<Task> johndoetaskList_ = taskService.findPersonalTasks("johndoe"); System.out.println("johndoetaskList0.size() = "+johndoetaskList_.size()); assertEquals(0, johndoetaskList_.size()); //打印在此节点流程的相关信息。这里可以看出getExecutionId()就是流程实例的id即processInstance.getId() List<HistoryActivityInstance> list = historyService.createHistoryActivityInstanceQuery().activityName("state1").list(); for(HistoryActivityInstance activity : list){ System.out.println("getActivityName() = "+activity.getActivityName()); System.out.println("getExecutionId() = "+activity.getExecutionId()); } // 查看撤销前johndoe的待办任务列表是否为零个 List<Task> johndoetaskList0 = taskService.findPersonalTasks("johndoe"); System.out.println("查看撤销前johndoe的待办任务列表是否为零个"); System.out.println("johndoe_taskList1.size() = "+johndoetaskList0.size()); if(johndoetaskList0.size() > 0){ TaskImpl before_johndoetask = (TaskImpl)johndoetaskList0.get(0); String before_johndoetask_actName = before_johndoetask.getActivityName(); String before_johndoetask_ExecutionId = before_johndoetask.getExecutionId(); System.out.println("before_johndoetask_actName = "+before_johndoetask_actName); System.out.println("before_johndoetask_ExecutionId = "+before_johndoetask_ExecutionId); assertEquals(0, johndoetaskList0.size()); } //查看撤销前we的待办任务列表是否为一个 List<Task> wetaskList1 = taskService.findPersonalTasks("we"); System.out.println("查看撤销前we的待办任务列表是否为一个"); System.out.println("we_taskList1.size() = "+wetaskList1.size()); if(wetaskList1.size() > 0){ TaskImpl before_wetask = (TaskImpl)wetaskList1.get(0); String before_wetask_actName = before_wetask.getActivityName(); String before_wetask_ExecutionId = before_wetask.getId(); System.out.println("before_wetask_actName = "+before_wetask_actName); System.out.println("before_wetask_ExecutionId = "+before_wetask_ExecutionId); } assertEquals(1, wetaskList1.size()); ProcessDefinitionImpl pdi = (ProcessDefinitionImpl)pd; TaskImpl wetask = (TaskImpl)wetaskList1.get(0); //进行撤销操作 addOutTransition(pdi,wetask,"review"); //重新查询才能看到状态改变 List<ProcessInstance> piList1 = executionService.createProcessInstanceQuery().list(); for(ProcessInstance pi : piList1){ System.out.println(pi.findActiveActivityNames()); } // 查看撤销后johndoe的待办任务列表是否为一个 List<Task> johndoetaskList1 = taskService.findPersonalTasks("johndoe"); System.out.println("查看撤销后johndoe的待办任务列表是否为一个"); System.out.println("johndoetaskList1.size() = "+johndoetaskList1.size()); if(johndoetaskList1.size() > 0){ TaskImpl johndoetask = (TaskImpl)johndoetaskList1.get(0); String johndoetask_actName = johndoetask.getActivityName(); String johndoetask_ExecutionId = johndoetask.getExecutionId(); System.out.println("johndoetask_actName = "+johndoetask_actName); System.out.println("johndoetask_ExecutionId = "+johndoetask_ExecutionId); } //assertEquals(1, johndoetaskList1.size()); //查看撤销后we的待办任务列表是否变为零个 List<Task> wetaskList = taskService.findPersonalTasks("we"); System.out.println("查看撤销后we的待办任务列表是否为零个"); System.out.println("wetaskList.size() = "+wetaskList.size()); if(wetaskList.size() > 0){ TaskImpl taskwww = (TaskImpl)wetaskList.get(0); String wetask_actName = taskwww.getActivityName(); String wetask_ExecutionId = taskwww.getExecutionId(); System.out.println("wetask_actName = "+wetask_actName); System.out.println("wetask_ExecutionId = "+wetask_ExecutionId); } } /** * 动态创建连接当前任务节点至名称为destName的节点的Transition * @param taskId 任务节点ID * @param sourceTask 源节点Task * @param destName 目标节点名称 */ public void addOutTransition(ProcessDefinitionImpl pd,TaskImpl sourceTask,String destName){ EnvironmentFactory environmentFactory = (EnvironmentFactory) processEngine; EnvironmentImpl env=null; try { env = environmentFactory.openEnvironment(); //取得当前流程的活动定定义 ActivityImpl sourceActivity = pd.findActivity(sourceTask.getActivityName()); //取得目标的活动定义 ActivityImpl destActivity=pd.findActivity(destName); //为两个节点创建连接 TransitionImpl transition = sourceActivity.createOutgoingTransition(); transition.setName("to" + destName); transition.setDestination(destActivity); sourceActivity.addOutgoingTransition(transition); System.out.println("sourceActivity.getName() = "+sourceActivity.getName()); System.out.println("destActivity.getName() = "+destActivity.getName()); Map<String, Object> variables = new HashMap<String, Object>(); variables.put("order", new Order("johndoe")); System.out.println("task1.getId() = "+sourceTask.getId()); taskService.completeTask(sourceTask.getId(),transition.getName(),variables); }catch(Exception ex){ ex.getMessage(); }finally{ env.close(); } } }
相关推荐
【】(01)jbpm4.4简介【】(02)JBPM4.4开发环境搭建【】(03)jbpm4.4环境搭建续【】(04)jbpm4.4配置文件和开发前准备【】(05)jbpm4.4部署流程发起流程实例【】(06)jbpm4.4完成任务查看任务当前节点【】(07)jbpm4.4 资源...
jbpm4.4 schema.xsd jbpm4.4 schema.xsd jbpm4.4 schema.xsd jbpm4.4 schema.xsd jbpm4.4 schema.xsd
JBPM5工作流引擎 S2SH+JBPM4.4开发工作流的一个完整的请假流程例子。带有文档教程和所有源码+JAR包。在网上找了半天jbpm6\jbpm7的资料,都很少。所以 环境:Myeclipse2015 JDK1.7 mysql 5.0 Struts2+Spring3.1 1...
jbpm4.4下载地址
jBPM4.4开发指南 开发手册 JBPM4.4 开发
jBPM4.4工作流开发指南
JBPM4.4与SSH2之整合(附完整源码) 这些天,想着把jbpm4.4与ssh2整合一下,由于之前从来没用过jbpm,也不知道各版本之间会有什么差异(经过网上的收集对比,还真有些差异),整合起来,还真是有些步履艰难。收集了...
jBPM4.4入门开发实例
jbpm4.4开发指南,jbpm4.4用户指南
首先感谢原创,相关信息请查询原创。... 看到好多朋友找不到相应的jar包,致使jbpm4.4的学习遇到困难,现提供除jbpm4.4自身jar包外的所有包,以便大家更快的学习jbpm4.4,希望能帮朋友们少走弯路!
jBPM4.4课程文档
eclipse 下安装jbpm-4.4 的安装步骤
jbpm4.4整合s2sh 请假流程例子
JBPM4.4之HelloWorld示例
JBPM4.4工作流数据表结构的详解 对每个数据表字段都有注释
JBPM4.4学习文档.ppt
jBPM4.4工作流开发指南(改进版) 开发环境搭建
jbpm4.4+ssh配置
父项目中,根据Maven的规范,配置了相关依赖包的引用,包括:Jbpm4.4的引用包引用、Junit4.9的测试包引用,hibernate的引用包,以及应用服务器Jboss的Client引用等。 接口中,提供了部署流程、创建实例、获得当前...
jBPM4.4数据库表简单介绍