Activiti工作流的定義部署和執行

   

工作流引擎

    個人覺得直接理解工作流引擎概念有點難度，我們可以先通過了解工作流引擎的職責再反過來理解工作流引擎，工作流引擎一般都做兩件事情：

    1.定義流程，也就是給我們提供某種規范來定義規則，以及如何定義一個流程的這種規范，同事我們可以根據工作流引擎提供的相關概念來定義更為復雜的流程，這就是工作流引擎做的第一件事叫做定義流程。

    2.執行流程，也就是工作流引擎需要解釋這個規則，還要負責流程，它相當於流程的調度者，監控每個流程的執行情況，並將流程操作發往下一步，或者根據條件休眠或終止流程的這么一個過程就叫做執行流程。

    了解完工作流引擎的這兩個職責，我相信對於什么是工作流引擎一定已經有了一定的認識了，我們在用一句稍微有點官方的話來總結一下工作流引擎，工作流引擎為我們提供相關規則概念的定義，給我們提供了相關的API來調用這個引擎去執行流程。流程的操作實際上就是工作流引擎提供相關的api我們去調用它。

工作流框架與工作流引擎

    上面我們提及了常見了幾個工作流框架，其中現在的Activiti和JBPM5.0之前的版本都是基於ProcessEngine 工作流引擎的工作流框架；JBPM5.0開始是基於DroolsFlow為工作流引擎的工作流框架；其中OSWorkflow是以工作流引擎命名的工作流框架，所以OSWorkflow是基於OSWorkflow工作流引擎的工作流框架；ActiveBPEL是基於工作流BPEL引擎的工作流框架…….

    到這里關於工作流的相關概念就介紹完了，接下來我們先了解一下我們的主角activiti的前世今生。

Activiti前世今生

      Activiti 的創始人是  Tom Baeyens 說到Tom Baeyens 就不能不提他與jbpm的淵源。TomBaeyens 是 jBPM 的創始人，在 2002年，Tom Baeyens創建了基於狀態機原理的jBPM流程引擎。jBPM經過了JBoss和Redhat公司之后，發展到了 jBPM 4。由於jBPM使用的是 GPL開源協議，並且與JBoss和Redhat公司的其他產品線結合的越來越緊密，對jBPM在更廣泛的范圍使用形成了阻礙。JBoss內部對jBPM未來版本的架構實現產生了嚴重的意見分歧，在2005年 Tom Baeyens離開了JBoss公司加入了Alfresco 公司，創建了使用Apache based-license V2的、獨立於Alfresco產品的開源流程產品Activiti 。Activiti在2010年3月份開始啟動，到了2010年12月份正式發布第一個版本，新的基於jBPM4的開源工作流系統Activiti 5.0  ！所以說Activiti5是在jBPM 3、jBPM 4的基礎上發展而來的，是原jBPM 的延續。

    整個Activiti的生命周期經過了如下的幾個步驟：1.流程部署 ， 2.啟動流程實例 ， 3.執行流程對象(一個流程實例包含多執行對象) ， 4.完成整個流程

   如下就是具體代碼:

package process;
import java.io.File;
import java.io.InputStream;
import java.util.Date;
import java.util.List;
import java.util.zip.ZipInputStream;

import org.activiti.engine.HistoryService;
import org.activiti.engine.IdentityService;
import org.activiti.engine.ManagementService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.RuntimeService;
import org.activiti.engine.TaskService;
import org.activiti.engine.history.HistoricTaskInstance;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.repository.ProcessDefinition;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.junit.Test;
import com.mysql.fabric.xmlrpc.base.Data;

public class TestProcess {

    /***
    * 整個Activiti的生命周期經過了如下的幾個步驟：
    * 1.流程部署
    * 2.啟動流程實例   
    * 3.執行流程對象(一個流程實例包含多執行對象)
    * 4.完成整個流程
    */
    //流程引擎ProcessEngine對象 ,所有操作都要依賴流程引擎對象
    ProcessEngine processEngine=ProcessEngines.getDefaultProcessEngine();
    //由流程引擎創建各service
    RepositoryService repositoryService=processEngine.getRepositoryService();
    //創建運行時服務
    RuntimeService runtimeService=processEngine.getRuntimeService();
    //創建任務服務
    TaskService taskService=processEngine.getTaskService();
    //歷史任務相關的服務
    HistoryService historyService=processEngine.getHistoryService();
　　//身份服務
　　IdentityService identityService=processEngine.getIdentityService();
　　//管理服務
　　ManagementService managermentService=processEngine.getManagementService();

}

1：部署流程---bpmn方式

@Test
public void deploymenyProcessDefinition(){
　　Deployment deployment=repositoryService//與流程定義和部署對象相關的service
　　　　　　　　　.createDeployment()//創建一個部署對象
　　　　　　　　　.name("activiti_Introduction")//添加部署的名稱
　　　　　　　　　.addClasspathResource("diagrams/simpleProcess/MyProcess.bpmn")//從classpath資源中加載文件,一次加載一個
　　　　　　　　  .deploy();//部署
　　　　　　System.out.println("流程Id:"+deployment.getId());
　　　　　　System.out.println("流程名稱:"+deployment.getName());
}

2：部署流程---zip方式

@Test
public void deploymenyProcessDefinition_zip(){
　　　　InputStream in=this.getClass().getClassLoader().getResourceAsStream("diagrams/simpleProcess/MyProcess.zip");
　　　　ZipInputStream zipInputStream=new ZipInputStream(in);
　　　　Deployment deployment=repositoryService//與流程定義和部署對象相關的service
　　　　　　　　　　　　　　　　　.createDeployment()//創建一個部署對象
　　　　　　　　　　　　　　　　　.name("activiti_Introduction")//添加部署的名稱 activiti入門
　　　　　　　　　　　　　　　　　.addZipInputStream(zipInputStream)
　　　　　　　　　　　　　　　　　.deploy();//完成部署
　　　　System.out.println("部署流程Id:"+deployment.getId());
　　　　System.out.println("部署流程名稱:"+deployment.getName());
}

3：啟動流程實例

@Test
public void startProcessInstance(){
　　//流程定義的key
　　String processDedinitionKey="activiti_Introduction";
　　ProcessInstance pi=runtimeService //與正在執行的流程實例和執行對象相關的service
　　　　            .startProcessInstanceByKey(processDedinitionKey);//通過key啟動流程實例,key對應***.bpmn文件中id的屬性值
　　System.out.println("流程實例id:"+pi.getId());
　　System.out.println("流程定義id:"+pi.getProcessDefinitionId());
}

4：查看流程

@Test
public void viewProcess(){
　　//流程定義的key
　　String deploymengId="801";
　　List<String> list=repositoryService
 　　　　　　　　　　　　.getDeploymentResourceNames(deploymengId);

　　String resourceName="";
　　if(list!=null && list.size()>0){
　　　　for(String name:list){
　　　　　　if(name.indexOf(".png")>0){
　　　　　　　　resourceName=name;
          }
       }
    }

　　//獲取圖片的輸入流
　　InputStream is=repositoryService
　　　　　　　　　　 .getResourceAsStream(deploymengId, resourceName);

　　File file=new File("D:/"+resourceName);

　　//將輸入流的圖片寫入到磁盤下
　　//FileUtils.copy(is, file);

}

5：查看當前人的個人任務

@Test
public void findMyProcessTask(){
　　String assignee="張三";
　　List<Task> tasklist=taskService //與正在執行任務管理 相關的service
　　　　　　　　　　　　　　.createTaskQuery()//創建任務查詢對象
　　　　　　　　　　　　　　.taskAssignee(assignee)//指定個人任務查詢 指定辦理人
　　　　　　　　　　　　　　.list();//返回結果集

　　if(tasklist!=null && tasklist.size()>0){
　　　　for(Task task:tasklist){
　　　　　　System.out.println("任務Id:"+task.getId());
　　　　　　System.out.println("任務 名稱:"+task.getName());
　　　　　　System.out.println("任務的創建時間:"+task.getCreateTime());
　　　　　　System.out.println("任務的辦理人:"+task.getAssignee());
　　　　　　System.out.println("流程實例Id:"+task.getProcessInstanceId());
　　　　　　System.out.println("流程執行對象Id:"+task.getExecutionId());
　　　　　　System.out.println("流程定義Id:"+task.getProcessDefinitionId());
　　　　}

　　}
}

6：查詢流程定義

@Test
public void findProcessDefinition(){
　　List<ProcessDefinition> proDefList=repositoryService//與流程定義和部署對象相關的service
　　　　　　　　　　　　　　　　　　.createProcessDefinitionQuery()//創建一個流程定義的查詢
　　　　　　　　　　　　　　　　　　.orderByProcessDefinitionVersion()//按照版本的升序排列
　　　　　　　　　　　　　　　　　　.list();//返回的結果集
　　if(proDefList!=null && proDefList.size()>0){
　　　　for(ProcessDefinition pd:proDefList){
　　　　　　System.out.println("流程定義Id:"+pd.getId());
　　　　　　System.out.println("流程定義名稱:"+pd.getName());
　　　　　　System.out.println("流程定義的key:"+pd.getKey());
　　　　　　System.out.println("流程定義的版本:"+pd.getVersion());
　　　　　　System.out.println("資源名稱bpmn文件:"+pd.getResourceName());
　　　　　　System.out.println("資源名稱png文件:"+pd.getDiagramResourceName());
　　　　　　System.out.println("部署對象Id:"+pd.getDeploymentId());
   　}
　 }
}

7：刪除流程定義

@Test
public void deleteProcessDefinition(){
　　String deploymentId="601";
　　//不帶級聯刪除
　　repositoryService.deleteDeployment(deploymentId);

　　//級聯刪除
　　repositoryService.deleteDeployment(deploymentId, true);

　　System.out.println("刪除成功");
}

8：完成我的任務

@Test
public void completeMyProcess(){
　　//任務Id
　　String taskId="1201";
　　taskService.complete(taskId);
　　System.out.println("完成任務,任務Id為:"+taskId);

}

9：查詢流程狀態 (判斷流程是正在執行還是結束了)

@Test
public void isProcessEnd(){
　　//正在執行的流程Id
　　String processInstanceId="1001";
　　ProcessInstance pi=runtimeService
　　　　　　　　　　　　　.createProcessInstanceQuery() //創建流程實例查詢
　　　　　　　　　　　　　.processInstanceId(processInstanceId)//使用流程實例id查詢
　　　　　　　　　　　　　.singleResult();
　　if(pi==null){
　　　　System.out.println("流程已結束");
　　}else{
　　　　System.out.println("流程還在執行中");
　　}
}

10：查詢歷史任務

@Test
public void findHistoryTask(){
　　String taskAssignee="";
　　List<HistoricTaskInstance> hisList=historyService
　　　　　　　　　　　　　　.createHistoricTaskInstanceQuery()//創建歷史任務實例查詢
　　　　　　　　　　　　　　.taskAssignee(taskAssignee)//指定歷史任務的辦理人
　　　　　　　　　　　　　　.list();
　　if(hisList!=null && hisList.size()>0){
　　for(HistoricTaskInstance hti:hisList){
　　　　System.out.println(hti.getId()+" "+hti.getName()+" "+hti.getProcessInstanceId()+" "+hti.getStartTime()+" ");
　　}
　}
}

11：設置流程變量

@Test
public void setVariables(){
　　//任務Id
　　String taskId="2046";
　　taskService.setVariableLocal(taskId, "請假天數", 3); //與任務ID綁定
　　taskService.setVariable(taskId, "請假日期", new Data());
　　taskService.setVariable(taskId, "請假原因", "回家有事");
　　System.out.println("設置流程變量成功");
}

12：獲取流程變量

@Test
public void getVarables(){
　　//任務Id
　　String taskId="2046";
　　//獲取流程變量 使用基本數據類型
　　Integer days=(Integer) taskService.getVariable(taskId, "請假天數");
　　Date date=(Date) taskService.getVariable(taskId, "請假日期");
　　String leaveReason= (String) taskService.getVariable(taskId, "請假原因");
　　System.out.println("請假天數:"+days+" 請假時間:"+date+" 請假原因:"+leaveReason);
}