helloworldprocesstest.java

工做流方面的知识 绝对经典

package jbpm.java;

import junit.framework.TestCase; 

import org.jbpm.JbpmConfiguration; 
import org.jbpm.JbpmContext; 
import org.jbpm.context.exe.ContextInstance; 
import org.jbpm.graph.def.ProcessDefinition; 
import org.jbpm.graph.exe.ProcessInstance; 

public class HelloworldProcessTest extends TestCase { 

	private JbpmConfiguration config = JbpmConfiguration.getInstance(); 
	private JbpmContext ctx = config.createJbpmContext(); 
	// helloworld 对应于 jbpm_processdefinition 表的 name 字段值，也即 processdefinition.xml 的 name 
	// 这个值得取比较耗时，实际项目里最好和“数据库的 JDBC 连接”一样，让它共享，不要频繁打开关闭。 
	private ProcessDefinition processDefinition = ctx.getGraphSession().findLatestProcessDefinition("helloworld"); 
	
	int processVersion=ctx.getGraphSession().findLatestProcessDefinition("helloworld").getVersion(); 
	
	public void testNewRequest() { 
		long id = newRequest(); 
		System.out.println("id=" + id); 
		checkNewRequest(id); 
		confirmRequest(id); 
		checkConfirmRequest(id); 
		ctx.close();// 关闭 jbpm 容器 
		System.out.println("版本号："+processVersion);
	} 

	/** 
	  * 创建一个请假单 
	  * 
	  * @return 
	  */ 
	private long newRequest() { 
		// 创建一个新流程 
		ProcessInstance pi = processDefinition.createProcessInstance(); 
		// 取得流程的数据环境 
		ContextInstance ci = pi.getContextInstance(); 
		// 创建一张请假单 
		ci.setVariable("name", " 陈刚 www.chengang.com.cn" ); 
		ci.setVariable("day", 2); 
		assertEquals(null, ci.getVariable("note")); 
		// 请假申请结束，转到下一个流程结点 
		pi.signal(); 
		return pi.getId(); 
	} 

	/** 
	  * 检查请假单的数据 
	  * 
	  * @param id 
	  */ 
	private void checkNewRequest(long id) { 
		// 从数据库提取原流程 
		ProcessInstance pi = ctx.loadProcessInstance(id); 
		// 取得流程的数据环境 
		ContextInstance ci = pi.getContextInstance(); 
		// 创建一张请假单 
		assertEquals(" 陈刚 www.chengang.com.cn" , ci.getVariable("name")); 
		assertEquals(Integer.valueOf(2), ci.getVariable("day")); 
		assertEquals("我要请假" , ci.getVariable("note")); 

		// 当前是结点为 confirm 
		assertEquals(pi.getRootToken().getNode().getName(), "confirm"); 
		// 流程还没结束 
		assertFalse(pi.hasEnded()); 
	} 

	/** 
	  * 审批陈刚的请假申请 
	  * 
	  * @param id 
	  */ 
	private void confirmRequest(long id) { 
		ProcessInstance pi = ctx.loadProcessInstance(id); 
		ContextInstance ci = pi.getContextInstance(); 
		// 不通过 
		ci.setVariable("note", " 不准请假，继续加班 " ); 
		// 审批结束，到下一个流程结点 
		pi.signal(); 
	} 

	private void checkConfirmRequest(long id) { 
		ProcessInstance pi = ctx.loadProcessInstance(id); 
		ContextInstance ci = pi.getContextInstance(); 
		// ConfirmAction 类在 signal 后执行，所以覆盖了经理的审批意见 
		assertEquals("准假" , ci.getVariable("note")); 
        System.out.println("流程结束！");
		// 当前是结点为 end 
		assertEquals(pi.getRootToken().getNode().getName(), "end"); 
		// 流程结束了 
		assertTrue(pi.hasEnded()); 
	} 

}