项目之中jbpm实例

package com.hisoft.shipping.meetingSummary.jbpm.test; import java.io.InputStream; import java.util.Collection; import java.util.Iterator; 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; import org.jbpm.graph.node.Join; import org.jbpm.taskmgmt.exe.TaskInstance; import com.hisoft.shipping.leave.common.LeaveVariables; public class LeaveProcessTest extends TestCase { // static JbpmConfiguration cfg = JbpmConfiguration.getInstance(); ProcessDefinition pdf; ProcessInstance pi; String userId; boolean isChiefHere; public void setUp() { userId = "zwchen"; isChiefHere = true; } public void test14DayAndBossNotApprove() throws Exception { this.deployProcessDefinition(); this.createProcessInstance(); this.userWriteRequest(14); this.chiefDecide(true); this.bossDecide(true); // this.checkTasks(); } public void test4DayAndChiefApprove() throws Exception { this.deployProcessDefinition(); this.createProcessInstance(); this.userWriteRequest(4); this.chiefDecide(true); this.checkTasks(); } public void test14DayAndChiefApproveAndUserCancel() throws Exception { this.deployProcessDefinition(); this.createProcessInstance(); this.userWriteRequest(14); this.chiefDecide(true); this.userCancel(); this.checkTasks(); } public void testDeployProcessDefinition() throws Exception { System.out.println("begin to deploy process definition: "); System.out.println("-------------------------------------------------"); // retrieve context JbpmConfiguration config = JbpmConfiguration.getInstance(); JbpmContext context = config.createJbpmContext(); // retrieve definition InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream( "leave3/processdefinition.xml"); ProcessDefinition pd = ProcessDefinition.parseXmlInputStream(is); context.deployProcessDefinition(pd); context.close(); System.out.println("------------------------------------------------"); System.out.println("deploy ended!"); } public void testDeleteProcessInstance() throws Exception { long pid = 14; JbpmContext jContext = JbpmConfiguration.getInstance().createJbpmContext(); jContext.getGraphSession().deleteProcessInstance(pid); jContext.close(); } public void testUndeployProcessDefinition() throws Exception { long pd = 2; JbpmContext jContext = JbpmConfiguration.getInstance().createJbpmContext(); jContext.getGraphSession().deleteProcessDefinition(pd); jContext.close(); } protected void deployProcessDefinition() throws Exception { System.out.println("==MyRequestProcessTest.deployProcessDefinition()=="); InputStream fis = Thread.currentThread().getContextClassLoader().getResourceAsStream( "leave/processdefinition.xml"); pdf = ProcessDefinition.parseXmlInputStream(fis); assertNotNull("Definition should not be null", pdf); } protected void createProcessInstance() throws Exception { System.out.println("==MyRequestProcessTest.createProcessInstance()=="); assertNotNull("Definition should not be null", pdf); pi = new ProcessInstance(pdf); assertNotNull("processInstance should not be null", pi); Join join_Request = (Join) pi.getProcessDefinition().getNode("Join_Request"); assertNotNull("should find join_request node !", join_Request); join_Request.setDiscriminator(true); // 设置申请人 pi.getContextInstance().createVariable(LeaveVariables.applicant, this.userId); // 设置流程运行是，部门主管是否在岗 pi.getContextInstance().createVariable(LeaveVariables.isChiefHere, new Boolean(this.isChiefHere)); // 启动流程 pi.getRootToken().signal(); } /** * * @param daycount * 请假天数 * */ protected void userWriteRequest(int daycount) { System.out.println("==MyRequestProcessTest.userWriteRequest()=="); TaskInstance wr = (TaskInstance) pi.getTaskMgmtInstance().getTaskInstances().iterator().next(); assertEquals(this.userId, wr.getActorId()); ContextInstance ci = pi.getContextInstance(); ci.setVariable("dayCount", new Integer(daycount)); wr.end(); } /** * * @param isApprove * 部门主管是否同意请假 * */ protected void chiefDecide(boolean isApprove) { System.out.println("==MyRequestProcessTest.chiefDecide()=="); // String chiefId="today123"; /** * * 如果后台使用数据库的话，就可以使用 * * org.jbpm.db.TaskMgmtSession.findTaskInstances(java.lang.String * actorId) 得到所有分配给chiefId的taskInstance * */ Collection coll = pi.getTaskMgmtInstance().getTaskInstances(); Iterator it = coll.iterator(); while (it.hasNext()) { TaskInstance ti = (TaskInstance) it.next(); if (ti.getName().equals("Task_ChiefDecide")) { assertEquals("wangbo", ti.getActorId()); if (isApprove) ti.end("Tr_ChiefApprove"); else ti.end("Tr_ChiefNotApprove"); return; } } } /** * * @param isApprove * 老板是否同意请假 * */ protected void bossDecide(boolean isApprove) { System.out.println("==MyRequestProcessTest.bossDecide()=="); // String bossId="elena"; /** * * 如果后台使用数据库的话，就可以使用 * * org.jbpm.db.TaskMgmtSession.findTaskInstances(java.lang.String * actorId) 得到所有分配给bossId的taskInstance * */ Collection coll = pi.getTaskMgmtInstance().getTaskInstances(); Iterator it = coll.iterator(); while (it.hasNext()) { TaskInstance ti = (TaskInstance) it.next(); if (ti.getName().equals("Task_BossDecide")) { assertEquals("caidehui", ti.getActorId()); if (isApprove) ti.end("Tr_BossApprove"); else ti.end("Tr_BossNotApprove"); return; } } } protected void userCancel() { System.out.println("==MyRequestProcessTest.userCancel()=="); /** * * 如果后台使用数据库的话，就可以使用 * * org.jbpm.db.TaskMgmtSession.findTaskInstances(java.lang.String * actorId) 得到所有分配给userid的taskInstance * */ Collection coll = pi.getTaskMgmtInstance().getTaskInstances(); Iterator it = coll.iterator(); while (it.hasNext()) { TaskInstance ti = (TaskInstance) it.next(); if (ti.getName().equals("Task_CancelRequest")) { assertEquals(this.userId, ti.getActorId()); ti.end(); return; } } } protected void checkTasks() { System.out.println("==MyRequestProcessTest.checkTasks()=="); Collection coll = pi.getTaskMgmtInstance().getTaskInstances(); Iterator it = coll.iterator(); System.out.println("***************************Process has task: ******************************"); while (it.hasNext()) { TaskInstance ti = (TaskInstance) it.next(); System.out.println("==" + ti.getName() + "=="); System.out.println("==" + ti.getActorId() + "=="); System.out.println("==" + ti.getVariables().toString() + "=="); } System.out.println("====end===="); } }