package com.sample;
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 SimpleProcessTest 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");
public void testNewRequest() {
long id = newRequest();
System.out.println("id=" + id);
checkNewRequest(id);
confirmRequest(id);
checkconfirmRequest(id);
ctx.close();// 關閉 jbpm 容器
}
/**
* 創建一個請假單
*
* @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"));
// 當前是結點為 end
assertEquals(pi.getRootToken().getNode().getName(), "end");
// 流程結束了
assertTrue(pi.hasEnded());
}
}