jBPM4入门
- - CSDN博客推荐文章jBPM4是一个可扩展的、灵活的流程引擎,可以作为一个独立的服务器运行或嵌入到任何Java应用程序中. jBPM项目不支持从jBPM3到jBPM4的迁移. jBPM4的运行环境需要jdk5或者以上版本；如果需要执行一些ant脚本，则需要在apache ant1.70或者以上的版本. jBPM4有两个核心对象Configuration和ProcessEngine.
JBPM4.4 撤销任务/回退任务/自由流
标签：
jbpm4
任务
回退
| 发表时间：2014-02-20 22:48 | 作者：saintsaya
出处：http://www.iteye.com
JBPM4.4任务撤销操作/回退操作/自由流
详细操作看注释。
操作示意图
task.jpdl.xml
TestUndoTask.java
已有 0 人发表留言，猛击->> 这里<<-参与讨论
ITeye推荐
详细操作看注释。
操作示意图
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();
}
}
}
已有 0 人发表留言，猛击->> 这里<<-参与讨论
ITeye推荐
相关 [jbpm4 任务 回退] 推荐：
JBPM4.4 撤销任务/回退任务/自由流
- - 企业架构 - ITeye博客JBPM4.4任务撤销操作/回退操作/自由流. System.out.println("显示流程定义 "+pd.getId()+" "+pd. //johndoe的任务列表这时有了1条待办任务. //查看第一个待办任务所有流出的节点. // 查看johndoe的待办任务列表是否空了. //打印在此节点流程的相关信息.
任务完成
- pp2moonbird - YesKafei Daily这段令人激动又伤感的视频，集合了航天飞机的自始至终. 你可以一览航天飞机执行的所有任务，人类探索太空的渴望和梦想，但也看到了挑战者号和哥伦比亚号的悲剧画面. 如同视频中的配乐，每一次失败，并不能动摇航天飞机冲向太空的决心，航天飞机的再次发射升空令失去得到尊重. 现在，她完美的谢幕，科技永不止步，下一代STS（Space Transportation System）会更强大.
Java 任务处理
- - 码蜂笔记最近梳理其他同事以前写的 job 后有点想法，记录下. 在大多数的系统都有类似这样的逻辑，比如下单了给用户赠送积分，用户在论坛上发表了帖子，给用户增加积分等等. 下单赠送积分，那么一个订单肯定不能重复赠送积分，所以需要一些状态来比较来哪些是已赠送的，哪些是没有赠送的. 或许可以在订单表里加个字段来标记是否赠送了积分.
Spark 任务调度
- - IT瘾-dev Spark的核心是基于RDD来实现的，Spark任务调度就是如何组织任务去处理RDD中每个分区的数据，根据RDD的依赖关系构建DAG，基于DAG划分Stage，然后将每个Stage中的任务（Task）分发到指定的节点去运行得到最终的结果. Application：用户编写的Spark应用程序，由一个或多个Job组成.
Linux Crontab 定时任务
- - CSDN博客推荐文章crontab命令的功能是在一定的时间间隔调度一些命令的执行. 1.1 /etc/Crontab文件. 在/etc目录下有一个crontab文件，这里存放有系统运行的一些调度程序. 每个用户可以建立自己的调度crontab（在/var/spool/cron目录下）. 以下是我本机上的crontab文件，.
浅谈多任务管理
- tossking - 爱范儿 · Beats of Bits移动系统的多任务管理看起来是个很简单的问题，但是实际做好却并不容易. Android 2.x 和 iOS. 在使用 Android 2.x 或 iOS 的过程中，多任务管理几乎是个废弃的功能. 在进行应用切换的时候，与其使用多任务管理界面，不如直接返回主屏更方便. 先看 android 2.x，多任务管理界面只显示最近打开过的六个应用的图标，想切换到的应用常常被挤掉，或者挤在一堆暂时无用的应用中间.
quartz 任务的增删改
- - 编程语言 - ITeye博客从网上找了好多例子，要么太老，要么用不了. * 添加一个定时任务，使用默认的任务组名，触发器名，触发器组名. * @param jobName 任务名. * @param cls 任务. * @param time 时间设置，参考quartz说明文档. Scheduler scheduler = schedulerFactory.getScheduler();//创建一个触发器表.
mysql 定时任务执行
- - 数据库 - ITeye博客 查看待执行event:. 创建执行活动. 执行周期以及起始时间等. 两种：1.在某个时间点执行：at 某个时间点+某个时间长度：. 如上面的：AT CURRENT_TIMESTAMP + INTERVAL 10 SECOND 标识从现在起，10秒后执行；. 2.周期性执行：every 每间隔多长时间执行一次，从 某时间点开始，到某个时间点结束.
通过eclipse调试MapReduce任务
- - 淘宝网通用产品团队博客利用MapReduce利器作开发，不论从思想上还是技能上都是新的体验. 以下罗列下如何利用eclipse调试MR任务. (本人环境： hadoop 1.0.2，部署在linux上，本地windows开发). 先在linux上安装好hadoop，为更接近线上环进，我的是 安装成Cluster.