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 三、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); }