jbpm的入門1

昵稱15242507 2014-11-19

展開全文

這里使用的是mysql數(shù)據(jù)庫
開發(fā)工具是eclipse
首先我們需要初始化話數(shù)據(jù)庫

Java代碼

package test.config;
import org.jbpm.JbpmConfiguration;
public class InitDB {
public static void main(String[] args) {
InitDB initDB = new InitDB();
initDB.createJbpmDB();
}
//初始化JBPM的數(shù)據(jù)庫表
public void createJbpmDB(){
JbpmConfiguration.getInstance().createSchema();
}
//刪除JBPM的數(shù)據(jù)庫表
public void dropJbpmDB(){
JbpmConfiguration.getInstance().dropSchema();
}
}

相關(guān)的配置文件可以在jbpm的程序包中找到
hibernate.cfg.xml要與你的數(shù)據(jù)庫配置相匹配。

接下來我們繪制一個(gè)工作流，這里基本上用到j(luò)bpm的一個(gè)工作流繪制的插件。
我們繪制了一個(gè)簡單的流程：
大體過程如下
起始狀態(tài)--》任務(wù)1--》任務(wù)2--》結(jié)束

Java代碼

<?xml version="1.0" encoding="UTF-8"?>
<process-definition xmlns="" name="qj">
<start-state name="start-state1">
<transition to="apply"></transition>
</start-state>
<task-node name="apply">
<task name="apply">
<assignment actor-id="1"></assignment>
</task>
<transition to="approve"></transition>
</task-node>
<task-node name="approve">
<task name="approve">
<assignment actor-id="2"></assignment>
</task>
<transition to="end-state1"></transition>
</task-node>
<end-state name="end-state1"></end-state>
</process-definition>

這里的actor-id 是一個(gè)查看權(quán)限

現(xiàn)在我們將流程定義發(fā)布上去

Java代碼

package test.config;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.InputStream;
import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.graph.def.ProcessDefinition;
/**
* 部署流程
*
*/
public class Deploy {
public static void main(String[] args) throws FileNotFoundException {
JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
//取得流程定義
InputStream is = new FileInputStream("D:\\workspace\\fwk\\jbpm\\src\\test\\qj\\processdefinition.xml");
ProcessDefinition pd = ProcessDefinition.parseXmlInputStream(is);
//部署流程
jbpmContext.deployProcessDefinition(pd);
jbpmContext.close();
}
}

發(fā)布之后我們?cè)跀?shù)據(jù)庫中已經(jīng)可以看到相關(guān)的配置了。

下面我們創(chuàng)建一個(gè)流程實(shí)例。

Java代碼

package test;
import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.db.GraphSession;
import org.jbpm.graph.def.ProcessDefinition;
import org.jbpm.graph.exe.ProcessInstance;
public class CreatePDInstance {
/**
* @param args
*/
public static void main(String[] args) {
JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
GraphSession graphSession = jbpmContext.getGraphSession();
//取得流程定義
ProcessDefinition pd = graphSession.findLatestProcessDefinition("qj");
//創(chuàng)造實(shí)例
ProcessInstance pi = pd.createProcessInstance();
//token下移剛創(chuàng)建的實(shí)例token是指向start-state1，我們需要讓token完整這里流程去指向真正的任務(wù)節(jié)點(diǎn)
pi.signal();
//當(dāng)前token指向apply節(jié)點(diǎn)的第一個(gè)任務(wù)
jbpmContext.close();
}
}

signal();方法是將狀態(tài)進(jìn)行轉(zhuǎn)換，由于轉(zhuǎn)至第二個(gè)狀態(tài)，所以apply任務(wù)在結(jié)束完起始狀態(tài)的時(shí)候會(huì)被同步創(chuàng)建創(chuàng)建。

由于apply任務(wù)是分配給actorId=1進(jìn)行處理的，下面我們看看autorId=1的任務(wù)列表

Java代碼

package test;
import java.util.List;
import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.taskmgmt.exe.TaskInstance;
public class TaskActor1 {
/**
* @param args
*/
public static void main(String[] args) {
TaskActor1 ta1 = new TaskActor1();
ta1.showList();
}
public void showList(){
JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
String autorId="1";
List<TaskInstance> list = jbpmContext.getTaskList(autorId);
for(int i = 0 ;i<list.size();i++){
TaskInstance ti = list.get(i);
System.out.println("ID :" + ti.getId());
System.out.println("ActorId :" + ti.getActorId());
System.out.println("任務(wù)名稱 :" + ti.getName());
System.out.println("開始時(shí)間 :" + ti.getCreate());
System.out.println("開始時(shí)間 :" + ti.getStart());
System.out.println("結(jié)束時(shí)間 :" + ti.getEnd());
}
}
}

我們可以看到該用戶權(quán)限下的任務(wù)列表
ID :1
ActorId :1
任務(wù)名稱 :apply
開始時(shí)間 :2009-06-25 16:59:05.0
開始時(shí)間 :null
結(jié)束時(shí)間 :null
下面我們開始任務(wù)該任務(wù)
我的id已經(jīng)在之前獲取到，這里就直接用了，實(shí)際應(yīng)用中則應(yīng)通過傳參獲取

Java代碼

package test;
import java.util.List;
import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.taskmgmt.exe.TaskInstance;
public class TaskActor1 {
/**
* @param args
*/
public static void main(String[] args) {
TaskActor1 ta1 = new TaskActor1();
//ta1.showList();
ta1.startTask(new Long(1));
}
public void showList(){
JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
String autorId="1";
List<TaskInstance> list = jbpmContext.getTaskList(autorId);
for(int i = 0 ;i<list.size();i++){
TaskInstance ti = list.get(i);
System.out.println("ID :" + ti.getId());
System.out.println("ActorId :" + ti.getActorId());
System.out.println("任務(wù)名稱 :" + ti.getName());
System.out.println("開始時(shí)間 :" + ti.getCreate());
System.out.println("開始時(shí)間 :" + ti.getStart());
System.out.println("結(jié)束時(shí)間 :" + ti.getEnd());
}
jbpmContext.close();
}
public void startTask(Long i){
JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
TaskInstance ti = jbpmContext.loadTaskInstance(i);
//如果該任務(wù)沒有啟動(dòng)就將他啟動(dòng)
if(ti.getStart() == null)
ti.start();
jbpmContext.close();
showList();
}
}

ID :1
ActorId :1
任務(wù)名稱 :apply
開始時(shí)間 :2009-06-25 16:59:05.0
開始時(shí)間 :2009-06-25 19:25:52.0
結(jié)束時(shí)間 :null
此時(shí)已經(jīng)開始
下面我們進(jìn)行任務(wù)的完成

Java代碼

package test;
import java.util.List;
import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.taskmgmt.exe.TaskInstance;
public class TaskActor1 {
/**
* @param args
*/
public static void main(String[] args) {
TaskActor1 ta1 = new TaskActor1();
//ta1.showList();
//ta1.startTask(new Long(1));
ta1.endTask(new Long(1));
}
public void showList(){
JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
String autorId="1";
List<TaskInstance> list = jbpmContext.getTaskList(autorId);
for(int i = 0 ;i<list.size();i++){
TaskInstance ti = list.get(i);
System.out.println("ID :" + ti.getId());
System.out.println("ActorId :" + ti.getActorId());
System.out.println("任務(wù)名稱 :" + ti.getName());
System.out.println("開始時(shí)間 :" + ti.getCreate());
System.out.println("開始時(shí)間 :" + ti.getStart());
System.out.println("結(jié)束時(shí)間 :" + ti.getEnd());
}
jbpmContext.close();
}
public void startTask(Long i){
JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
TaskInstance ti = jbpmContext.loadTaskInstance(i);
//如果該任務(wù)沒有啟動(dòng)就將他啟動(dòng)
if(ti.getStart() == null)
ti.start();
jbpmContext.close();
showList();
}
public void endTask(Long i){
JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
TaskInstance ti = jbpmContext.loadTaskInstance(i);
//如果該任務(wù)沒有完成啟動(dòng)就將他完成
if(ti.getEnd() == null)
ti.end();
jbpmContext.close();
showList();
}
}

完成之后在任務(wù)列表中已經(jīng)沒有任務(wù)了。
下面我們看一下數(shù)據(jù)庫，第一個(gè)任務(wù)已經(jīng)完成，第二個(gè)任務(wù)已經(jīng)創(chuàng)建

點(diǎn)擊查看原始大小圖片

接下來我們對(duì)ActorId=2的任務(wù)進(jìn)行執(zhí)行，等同上面的,這里不進(jìn)行重復(fù)

Java代碼

package test;
import java.util.List;
import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.taskmgmt.exe.TaskInstance;
public class TaskActor2 {
/**
* @param args
*/
public static void main(String[] args) {
TaskActor2 ta2 = new TaskActor2();
ta2.showList();
ta2.startTask(new Long(2));
ta2.endTask(new Long(2));
}
public void showList(){
JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
String autorId="2";
List<TaskInstance> list = jbpmContext.getTaskList(autorId);
for(int i = 0 ;i<list.size();i++){
TaskInstance ti = list.get(i);
System.out.println("ID :" + ti.getId());
System.out.println("ActorId :" + ti.getActorId());
System.out.println("任務(wù)名稱 :" + ti.getName());
System.out.println("開始時(shí)間 :" + ti.getCreate());
System.out.println("開始時(shí)間 :" + ti.getStart());
System.out.println("結(jié)束時(shí)間 :" + ti.getEnd());
}
jbpmContext.close();
}
public void startTask(Long i){
JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
TaskInstance ti = jbpmContext.loadTaskInstance(i);
//如果該任務(wù)沒有啟動(dòng)就將他啟動(dòng)
if(ti.getStart() == null)
ti.start();
jbpmContext.close();
showList();
}
public void endTask(Long i){
JbpmContext jbpmContext = JbpmConfiguration.getInstance().createJbpmContext();
TaskInstance ti = jbpmContext.loadTaskInstance(i);
//如果該任務(wù)沒有完成啟動(dòng)就將他完成
if(ti.getEnd() == null)
ti.end();
jbpmContext.close();
showList();
}
}

當(dāng)?shù)诙€(gè)任務(wù)執(zhí)行完成之后，你會(huì)看到任務(wù)已經(jīng)整個(gè)流程已經(jīng)完成，db中流程的end字段已經(jīng)賦值

點(diǎn)擊查看原始大小圖片

之所以這樣分步來說，就是希望可以深入了解jbpm的執(zhí)行流程
在實(shí)際的項(xiàng)目中往往開始和結(jié)束都是同時(shí)進(jìn)行的
比如已經(jīng)請(qǐng)假（star--填單--審批--end）：往往是請(qǐng)假表單的填寫的提交的瞬間（創(chuàng)建實(shí)例，填寫請(qǐng)假單），審批的成功與否也是瞬間而且同時(shí)結(jié)束流程
即只有兩步操作。

原文鏈接

原文源碼

本站是提供個(gè)人知識(shí)管理的網(wǎng)絡(luò)存儲(chǔ)空間，所有內(nèi)容均由用戶發(fā)布，不代表本站觀點(diǎn)。請(qǐng)注意甄別內(nèi)容中的聯(lián)系方式、誘導(dǎo)購買等信息，謹(jǐn)防詐騙。如發(fā)現(xiàn)有害或侵權(quán)內(nèi)容，請(qǐng)點(diǎn)擊一鍵舉報(bào)。

轉(zhuǎn)藏 分享

QQ空間 QQ好友新浪微博微信

獻(xiàn)花（0） +1

來自：昵稱15242507 > 《Java》

舉報(bào)/認(rèn)領(lǐng)