JBPM工作流

一、JBPM定義

JBPM，全稱是Java Business Process Management（業務流程管理），它是覆蓋了業務流程管理、工作流、服務協作等領域的一個開源的、靈活的、易擴展的可執行流程語言框架。

二、為什么用JBPM

 業務分析師和開發人員使用的是同一種語言來交談，大大降低了開發的風險，如果要開發一個項目，速度也更快了，因為開發人員不用再將用戶需求轉化成軟件設計了。其次，JBPM采用的不是一般的開發工具，而是自己的圖形化開發工具，非常方便隨時了解和掌握運行的進程。最后，JBPM的流程框架非常靈活，使用起來也非常安全，它經過了安全認證，因此可以保證一些商業機密不被泄露。

---

三、JBPM環境配置詳解

首先在Eclipse中配置環境。如下：

① 配置GPD(流程設計器)

Help  ------>  Install New Software

點擊add，出現一個Add Repository

點擊Archive，選擇jbbm4.4/install/src/gpd/jbpm-gpd-site.zip

 

 ② 選擇所有插件，然后點Next即可

③ 配置JBPM運行時

1） 打開window --- preferences

1） 選擇 JBoss jBPM --> Runtime Locations

2） 點擊 Add...

3） 在 Add Location 對話框中，輸入一個名字，比如 jbpm-4.4 然后點擊 Search...

4） 在 Browse For Folder 對話框中，選擇你的jbpm 根目錄，然后點擊 OK

④ 在目錄中添加JPDL4模式

如果你想直接編輯XML 源碼， 最好是在你的XML 目錄中指定一下模式（schema），這樣當你在編輯流程源碼的時候，可以更好的幫助你編寫代碼。

1） 點擊窗口 --> 屬性（Windows --> Preferences）

2） 選擇XML --> 目錄（XML --> XML CataLog）

3） 點擊添加（Add）

4） 添加XML 目錄（Add XML Catalog Entry）的窗口打開

5） 點擊map-icon 的圖標下面的按鈕並選擇文件系統（File System）

6） 在打開的對話框中， 選擇jBPM 安裝目錄下src 文件夾中jpdl.xsd 文件

7） 點擊打開（Open）並且關閉所有的對話框

 

 

---

 

 四、JBPM開發步驟詳解

 ① 引入JAR文件

在jbpm4.4的解壓包中根目錄Jbpm的jar包還有lib文件夾中除report-engine，war包外所有jar包

注：因為Jbpm4.4是用Mysql作為DB的，如果要用Oracle作為DB需要引入相應的驅動包。

 

---

 

② 創建配置文件

---

③ 畫流程圖---[新建jpdl.xml文件]

 

 

並生成jbpmtest.jpdl.xml文件：

 

---

 五、關鍵代碼

① 創建表18張

[http://www.cnblogs.com/a757956132/p/4774188.html]表的詳細說明

---

②獲取工作流引擎

  ProcessEngine processEngine=new Configuration().setResource("jbpm.cfg.xml").buildProcessEngine();
    
    @Test
    public void test01(){
    	System.out.println(processEngine);
    }

③部署流程定義

@Test
    public void deploy(){
    	String deployid = processEngine.getRepositoryService()
    			.createDeployment()
    			.addResourceFromClasspath("jbpmtest.jpdl.xml")
    	        .addResourceFromClasspath("jbpmtest.png").deploy();
    	
    	System.out.println("部署流程 id:"+deployid);
    }

 

④啟動流程實例

   @Test
    public void startTest(){
    //啟動流程實例  通過key，key是process節點中的key，如果不寫，默認為name的值
   ProcessInstance pi=processEngine.getExecutionService().startProcessInstanceByKey("jbpmtest");
   System.out.println("start ok!");
   System.out.println("id:"+pi.getId()+",狀態:"+pi.getState()+",流程定義的ID:"+pi.getProcessDefinitionId());
    }

 

⑤查看任務列表

 @Test
	public void selectTask(){
    	String user="張三";
    	String users="王五";
    	List<Task> tasks = processEngine.getTaskService().findPersonalTasks(user);
    
    	for (Task task : tasks) {
			System.out.println("任務ID："+task.getId()+"\t任務名稱："+task.getName()+"\t任務辦理人："+task.getAssignee());
		}
    }

　　

⑥查看當前任務所在點

@Test
	public void findSelect(){
    	String name = processEngine.getExecutionService().createProcessInstanceQuery().processInstanceId("jbpmtest.80001").uniqueResult().findActiveActivityNames().toString();
        System.out.println(name);
    }

　　

⑦辦理任務

  @Test
    public void testCompleteTask(){
    	processEngine.getTaskService().completeTask("10002");
    	System.out.println("OK");
    }

　　

---

 

六、流程管理 

 ①查詢所有流程定義

 

ProcessEngine pro=Configuration.getProcessEngine();　　

 

	@Test
	public void findAll(){
		List<ProcessDefinition> list = pro.getRepositoryService().createProcessDefinitionQuery().list();
	
		for (ProcessDefinition pd : list) {
			System.out.println("id:"+pd.getId()+"\tname:"+pd.getName()+"\tkey:"+pd.getKey()+"\t版本號："+pd.getVersion()+"\t部署的id:"+pd.getDeploymentId());
			
			
		}
	}
	

　　

②查詢最新版的流程定義

 

@Test
	public void getNewFindAll(){
		//查詢所有，讓最大的版本排到最后面
		List<ProcessDefinition> all = pro.getRepositoryService().createProcessDefinitionQuery().orderAsc(ProcessDefinitionQuery.PROPERTY_VERSION).list();
	
		//過濾出所有最新的版本
		Map<String, ProcessDefinition> map=new HashMap<String, ProcessDefinition>();
	
		for (ProcessDefinition pd : all) {
			map.put(pd.getKey(), pd);
		}
		//顯示
		for (ProcessDefinition pd : map.values()) {
			  System.out.println("id=" + pd.getId()// 格式為：{key}-{version}，用於唯一的標識一個流程定義  
			    + ", name=" + pd.getName()// 流程定義的名稱，jpdl.xml中根元素的name屬性的值  
			    + ", key=" + pd.getKey()// 流程定義的key，jpdl.xml中根元素的key屬性的值，默認是name屬性的值  
			    + ", version=" + pd.getVersion()// 自動生成的，同一個名稱的第一個為1，以后的自動加1.  
			    + ", deploymentId=" + pd.getDeploymentId()); // 所屬的部署對象  
			   
		}
	}

　　

③根據id刪除

注：deleteDeploymentCascade級聯刪除

 

@Test
	public void delById(){
		pro.getRepositoryService().deleteDeploymentCascade("1");
		System.out.println("del ok!!!");
	}

④刪除指定key的所有版本的流程　　

@Test
	public void delByKey(){
		List<ProcessDefinition> list = pro.getRepositoryService().createProcessDefinitionQuery().processDefinitionKey("jbpmtest").list();
	
		for (ProcessDefinition pd : list) {
			pro.getRepositoryService().deleteDeploymentCascade(pd.getDeploymentId());
		}
	}

　⑤ZIP 部署　

 

@Test
	public void addZip(){
		//部署zip格式的資源
		InputStream is=this.getClass().getClassLoader().getResourceAsStream("src.zip");
		ZipInputStream zs=new ZipInputStream(is);
		String id= pro.getRepositoryService().createDeployment().addResourcesFromZipInputStream(zs).deploy();
		  System.out.println("部署成功：deploymentid："+id);

	}