码迷，mamicode.com
首页 > Windows程序 > 详细

activiti入门2流程引擎的API和服务基础

时间：2014-12-23 13:45:55      阅读：768      评论：0      收藏：0      [点我收藏+]

标签：

 

技术分享

 

RepositoryService : 管理和控制发布包和流程定义(包含了一个流程每个环节的结构和行为)的操作

 

 

除此之外，服务可以

  • 查询引擎中的发布包和流程定义。

  • 暂停或激活发布包，对应全部和特定流程定义。 暂停意味着它们不能再执行任何操作了，激活是对应的反向操作。

  • 获得多种资源，像是包含在发布包里的文件， 或引擎自动生成的流程图。

  • 获得流程定义的pojo版本， 可以用来通过java解析流程，而不必通过xml。

RuntimeService :负责启动一个流程定义的新实例,获取和保存流程变量,查询流程实例和执行

TaskService :所有与任务有关的功能

 

  • 查询分配给用户或组的任务

  • 创建独立运行任务。这些任务与流程实例无关。

  • 手工设置任务的执行者，或者这些用户通过何种方式与任务关联。

  • 认领并完成一个任务。认领意味着一个人期望成为任务的执行者， 即这个用户会完成这个任务。完成意味着“做这个任务要求的事情”。 通常来说会有很多种处理形式。

 

IdentityService: 管理（创建，更新，删除，查询...）群组和用户

 FormService: 一个可选服务,这个服务提供了启动表单和任务表单两个概念

 HistoryService: 提供了Activiti引擎的所有历史数据

ManagementService :在使用Activiti的定制环境中基本上不会用到。 它可以查询数据库的表和表的元数据。另外，它提供了查询和管理异步操作的功能。 

 

RepositoryService

获取方式:

 

[java] view plaincopy
 
  1. //通过activiti.cfg.xml获取流程引擎  
  2. ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();  
[java] view plaincopy
 
  1. RepositoryService repositoryService = processEngine.getRepositoryService();  

任何与“静态”资源有关的数据（比如流程定义）都可以通过 RepositoryService访问。 从概念上讲，所以静态数据都是Activiti的资源内容。

 

部署流程文件:

 

[java] view plaincopy
 
  1. /** 
  2.      * 发布流程 
  3.      * 发布流程后，流程文件会保存到数据库中 
  4.      */  
  5.     @Test  
  6.     public void deployFlow(){  
  7.         RepositoryService repositoryService = processEngine.getRepositoryService();  
  8.           
  9.         //获取在classpath下的流程文件  
  10.         InputStream in = this.getClass().getClassLoader().getResourceAsStream("myleave.zip");  
  11.         ZipInputStream zipInputStream = new ZipInputStream(in);  
  12.         //使用deploy方法发布流程  
  13.         repositoryService.createDeployment()  
  14.                          //通过ZIP方式来部署流程文件  
  15.                          .addZipInputStream(zipInputStream)  
  16.                          //通过输入流来部署流程文件  
  17.                          //.addInputStream("xx.bpmn",inputStream)  
  18.                          //.addInputStream("xx.png", inputStream)  
  19.                          .name("Myleave")//设置流程定义的别名  
  20.                          .deploy();//部署  
  21.     }  
当文件部署成功后,会操作数据库中的这三张表

 

act_re_deployment  (部署信息表) 

存放流程定义的别名和部署时间

act_re_procdef(流程定义数据表)

 

存放流程定义的信息，每部署一个新的流程定义都会在这张表中增加一条记录。

如果当KEY相同 也就是 bpmn流程文件的 ID 相同是  增加的记录里面的版本会升级一个版本

 

act_ge_bytearray（资源文件表）

存放部署后的流程文件

 

查看流程定义信息:

 

[java] view plaincopy
 
  1. /** 
  2.  * 查看流程定义 
  3.  * 查询act_re_procdef表 流程定义表 
  4.  */  
  5. @Test  
  6. public void queryProcdef(){  
  7.     RepositoryService repositoryService = processEngine.getRepositoryService();  
  8.     //创建查询对象  
  9.     ProcessDefinitionQuery query = repositoryService.createProcessDefinitionQuery();  
  10.     //添加查询条件  
  11.     query.processDefinitionKey("myProcess");//通过key获取  
  12.         // .processDefinitionName("My process")//通过name获取  
  13.         // .orderByProcessDefinitionId()//根据ID排序  
  14.            //.processDefinitionKeyLike(processDefinitionKeyLike)//支持模糊查询  
  15.             //.listPage(firstResult, maxResults)//分页  
  16.     //执行查询获取流程定义明细  
  17.     List<ProcessDefinition> pds = query.list();//获取批量的明细  
  18.                     //.singleResult()//获取单个的明细  
  19.     for (ProcessDefinition pd : pds) {  
  20.         System.out.println("ID:"+pd.getId()+",NAME:"+pd.getName()+",KEY:"+pd.getKey()+",VERSION:"+pd.getVersion()+",RESOURCE_NAME:"+pd.getResourceName()+",DGRM_RESOURCE_NAME:"+pd.getDiagramResourceName());  
  21.         System.out.println("------------------------------------------------");  
  22.     }  
  23.       
  24. }  

 

运行结果:

 

[plain] view plaincopy
 
  1. ID:myProcess:1:604,NAME:My process,KEY:myProcess,DEPLOYMENT_ID:601,VERSION:1,RESOURCE_NAME:MyLeave.bpmn,DGRM_RESOURCE_NAME:MyLeave.png  
  2. ------------------------------------------------  
  3. ID:myProcess:2:809,NAME:My process,KEY:myProcess,DEPLOYMENT_ID:806,VERSION:2,RESOURCE_NAME:MyLeave.bpmn,DGRM_RESOURCE_NAME:MyLeave.png  
  4. ------------------------------------------------  

 

显示图片:

通过repositoryService查看流程定义信息,并且获取DEPLOYMENT_ID到 act_ge_bytearray 查询到 资源文件名

通过资源文件名和deploymentId获取流并输出到文件中

 

[java] view plaincopy
 
  1. /** 
  2.      * 显示图片信息 
  3.      * @throws IOException 
  4.      */  
  5.     @Test  
  6.     public void showImg() throws IOException{  
  7.         String deploymentId = "601";  
  8.         //通过deploymentId获取资源名称  
  9.         List<String> names = processEngine.getRepositoryService()  
  10.                     .getDeploymentResourceNames(deploymentId);  
  11.         String imgName = null;  
  12.         for (String name : names) {  
  13.             System.out.println("name:"+name);  
  14.             if (name.endsWith(".png")) {  
  15.                 imgName = name;  
  16.             }  
  17.         }  
  18.         System.out.println("imgName:"+imgName);  
  19.         if (imgName != null) {  
  20.             File file = new File("e:/"+imgName);  
  21.             //获取资源文件的流  
  22.             InputStream in = processEngine.getRepositoryService()  
  23.                     .getResourceAsStream(deploymentId, imgName);  
  24.             //通过FileUtils将资源文件以流的信息输出到指定文件  
  25.             FileUtils.copyInputStreamToFile(in, file);  
  26.         }  
  27.     }  
在E盘下查看 生成的照片

技术分享

 

删除流程定义:

 

[java] view plaincopy
 
  1. /** 
  2.  * 删除流程定义 
  3.  */  
  4. @Test  
  5. public void delDeployment(){  
  6.     String deploymentId = "1";  
  7.     processEngine.getRepositoryService()  
  8.                 //普通删除,删除没有在执行的流程,如果流程正在执行,则抛出异常  
  9.                 //.deleteDeployment(deploymentId);  
  10.                 //级联删除,不管你在不在运行,会删除当前关联的所有信息,包括在历史表里的数据  
  11.                 .deleteDeployment(deploymentId, true);  
  12. }  

 

 

RuntimeService

获取方式:

 

[java] view plaincopy
 
  1. //通过activiti.cfg.xml获取流程引擎  
  2. ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();  
[java] view plaincopy
 
  1. RuntimeService runtimeService = processEngine.getRuntimeService();  

启动一个流程实例:

 

 

[java] view plaincopy
 
  1. /** 
  2.  * 启动流程实例 
  3.  */  
  4. @Test  
  5. public void startFlow(){  
  6.       
  7.     RuntimeService runtimeService = processEngine.getRuntimeService();  
  8.       
  9.     //通过Id来启动一个流程并返回一个流程实例  
  10.     ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("myProcess");  
  11.     System.out.println("id:"+processInstance.getId()+",activitiId:"+processInstance.getActivityId());  
  12. }  
当一个流程实例启动后,会在 act_ru_execution 表中插入一条记录,如果是用户任务节点,同时也会在act_ru_task表中插入一条记录

 

查询流程状态:

 

[java] view plaincopy
 
  1. /** 
  2.      * 查看流程状态 
  3.      */  
  4.     @Test  
  5.     public void queryState(){  
  6.         String processInstanceId = "701";  
  7.         ProcessInstance pi = processEngine.getRuntimeService()  
  8.                     //创建执行对象查询,查询正在执行的执行对象  
  9.                     //.createExecutionQuery()  
  10.                     .createProcessInstanceQuery()//创建流程实例查询,查询正在执行的流程实例  
  11.                     .processInstanceId(processInstanceId)//通过流程实例ID查询  
  12.                     //返回批量结果  
  13.                     //.list()  
  14.                     .singleResult();//返回唯一的结果  
  15.         if (pi != null) {  
  16.             System.out.println("当前流程:"+pi.getActivityId());  
  17.         }else {  
  18.             System.out.println("流程已经结束");  
  19.         }  
  20.     }  
在整个流程执行的过程中,流程ID 都是 唯一不变的,当流程结束后 流程记录就会在 act_ru_execution 表中被删除,存入到历史表

 

设置和获取流程变量:

 

[java] view plaincopy
 
  1. /** 
  2.  * 通过runtimeService设置流程变量 
  3.  * 设置流程变量 
  4.  */  
  5. public void setAndGetVariables(){  
  6.     RuntimeService runtimeService = processEngine.getRuntimeService();  
  7.     //通过执行对象ID和key value设置变量  
  8.     //value是一个object对象,当一个pojo类实现Serializable接口的时候就可以存入流程变量中  
  9.     //runtimeService.setVariable(executionId, key, value);  
  10.     //设置专属于一个执行对象ID的流程变量  
  11.     //runtimeService.setVariableLocal(executionId, key, value);  
  12.     //通过执行对象ID和Map设置多个变量  
  13.     Map<String, Object> paramMap = new HashMap<String, Object>();  
  14.     //runtimeService.setVariables(executionId, paramMap);  
  15.     //设置专属于一个执行对象ID的多个流程变量  
  16.     //runtimeService.setVariablesLocal(executionId, paramMap);  
  17.     //通过执行对象ID获取变量,返回object,需要强转  
  18.     //runtimeService.getVariable(executionId, key);  
  19.     //通过执行对象ID获取一个Map<String, Object>对象  
  20.     //runtimeService.getVariables(executionId);  
  21. }  

流程变量所支持的类型

技术分享

 

设置的流程变量会存入到act_ru_variable表

act_ru_variable表  的BYTEARRAY_ID_对应的是 act_ge_bytearray 如果是复杂类型的数据  会存入二进制字段中

 

TaskService

获取方式:

 

[java] view plaincopy
 
  1. //通过activiti.cfg.xml获取流程引擎  
  2. ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();  
[java] view plaincopy
 
  1. //获取任务服务对象  
  2.         TaskService taskService = processEngine.getTaskService();  
查看个人任务:

 

 

[java] view plaincopy
 
  1. /** 
  2.      * 查看任务 
  3.      */  
  4.     @Test  
  5.     public void queryTask(){  
  6.         //获取任务服务对象  
  7.         TaskService taskService = processEngine.getTaskService();  
  8.         //根据接受人查询该用户的任务  
  9.         List<Task> tasks = taskService.createTaskQuery()  
  10.                                     //模糊查询  
  11.                                     //.taskAssigneeLike(assigneeLike)  
  12.                                     //通过执行对象ID查询任务  
  13.                                     //.executionId(executionId)  
  14.                                     .taskAssignee("张三")//通过接受人来查询个人任务  
  15.                                     .list();  
  16.         for (Task task : tasks) {  
  17.             System.out.println("ID:"+task.getId()+",姓名:"+task.getName()+",接收人:"+task.getAssignee()+",开始时间:"+task.getCreateTime());  
  18.         }  
  19.     }  

运行结果

 

[plain] view plaincopy
 
  1. ID:704,姓名:员工请假,接收人:张三,开始时间:Wed Oct 22 17:03:04 CST 2014  
  2. ID:804,姓名:员工请假,接收人:张三,开始时间:Thu Oct 23 11:27:47 CST 2014  

 

除了个人任务 还有 组任务

 

办理任务:

 

 

[java] view plaincopy
 
  1. /** 
  2.      * 办理任务 
  3.      */  
  4.     @Test  
  5.     public void startTask(){  
  6.         TaskService taskService = processEngine.getTaskService();  
  7.         //taskId 就是查询任务中的 ID  
  8.         String taskId = "704";  
  9.         //完成请假申请任务  
  10.         taskService.complete(taskId );  
  11.     }  

taskService 和 runtimeService 一样都是可以设置流程变量的

 


HistoryService

获取方式:

 

[java] view plaincopy
 
  1. //通过activiti.cfg.xml获取流程引擎  
  2. ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();  
[java] view plaincopy
 
  1. HistoryService historyService = processEngine.getHistoryService();  

查询历史任务:

 

 

[java] view plaincopy
 
  1. /** 
  2.      * 查询历史任务 
  3.      */  
  4.     @Test  
  5.     public void queryHistoryTask(){  
  6.         String assignee = "张三";  
  7.         HistoryService historyService = processEngine.getHistoryService();  
  8.           
  9.         List<HistoricTaskInstance> htis = historyService.createHistoricTaskInstanceQuery()//创建历史任务查询<span style="font-family: Arial, Helvetica, sans-serif;">对象</span>  
  10.                                                     //创建一个历史详细信息查询<span style="font-family: Arial, Helvetica, sans-serif;">对象</span>  
  11.                                                     //.createHistoricDetailQuery()  
  12.                                                     //创建历史流程实例查询对象  
  13.                                                     //.createHistoricProcessInstanceQuery()  
  14.                                                     .taskAssignee(assignee)//根据接受人查询历史任务  
  15.                                                     .list();//返回批量结果  
  16.           
  17.         for (HistoricTaskInstance hti : htis) {  
  18.             System.out.println("ID:"+hti.getId()+",流程实例ID:"+hti.getProcessInstanceId()+",接收人:"+hti.getAssignee()+",执行对象ID:"+hti.getExecutionId());  
  19.             System.out.println("------------------------------------------------");  
  20.         }  
  21.     }  
结果:

 

 

[plain] view plaincopy
 
  1. ID:704,流程实例ID:701,接收人:张三,执行对象ID:701  
  2. ------------------------------------------------  
  3. ID:804,流程实例ID:801,接收人:张三,执行对象ID:801  
  4. ------------------------------------------------  

 

主要是查询act_hi_taskinst表中的数据

 


查询历史流程实例:

 

[java] view plaincopy
 
  1. /** 
  2.      * 查询历史流程实例 
  3.      */  
  4.     @Test  
  5.     public void queryHistoryPi(){  
  6.         HistoryService historyService = processEngine.getHistoryService();  
  7.         String pi = "701";  
  8.           
  9.         List<HistoricProcessInstance> hpis = historyService.createHistoricProcessInstanceQuery()//创建历史流程实例查询对象  
  10.                                                         .processInstanceId(pi)  
  11.                                                         .list();  
  12.           
  13.         for (HistoricProcessInstance hpi : hpis) {  
  14.             SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  
  15.             System.out.println("实例ID:"+hpi.getId()+",开始时间:"+sdf.format(hpi.getStartTime())+",结束时间:"+sdf.format(hpi.getEndTime()));  
  16.             System.out.println("-------------------------------------");  
  17.         }  
  18.     }  
结果:

 

 

[plain] view plaincopy
 
  1. 实例ID:701,开始时间:2014-10-22 17:03:04,结束时间:2014-10-23 15:25:03  
  2. -------------------------------------  

 

主要是查询act_hi_procinst表中的数据

 

获取历史流程变量:

 

 

[java] view plaincopy
 
  1. /** 
  2.  * 获取历史流程变量 
  3.  */  
  4. @Test  
  5. public void getHistoryVariable(){  
  6.     HistoryService historyService = processEngine.getHistoryService();  
  7.       
  8.     List<HistoricVariableInstance> hvis = historyService.createHistoricVariableInstanceQuery()//创建一个历史流程变量实例查询对象  
  9.                                                     .variableName("key")//通过key查询  
  10.                                                     .list();  
  11.       
  12.     if (hvis != null) {  
  13.         for (HistoricVariableInstance hvi : hvis) {  
  14.             System.out.println("key:"+hvi.getVariableName()+",value:"+hvi.getValue());  
  15.         }  
  16.     }  
  17. }  

主要是查询act_hi_varinst表中的数据

查询历史活动信息:

 

 

[java] view plaincopy
 
  1. /** 
  2.      * 查询历史活动信息 
  3.      * 主要查询的是act_hi_actinst表中的数据 
  4.      */  
  5.     @Test  
  6.     public void queryHistoryAi(){  
  7.         String pi = "701";  
  8.         HistoryService historyService = processEngine.getHistoryService();  
  9.           
  10.         List<HistoricActivityInstance> hais = historyService.createHistoricActivityInstanceQuery()//创建历史活动实例查询对象  
  11.                                                             .processInstanceId(pi)  
  12.                                                             .list();  
  13.           
  14.         for (HistoricActivityInstance hai : hais) {  
  15.             System.out.println("活动ID:"+hai.getActivityId()+",活动名称:"+hai.getActivityName()+",活动类型:"+hai.getActivityType()+",流程实例ID:"+hai.getProcessInstanceId()+",接收人:"+hai.getAssignee());  
  16.             System.out.println("--------------------------------");  
  17.         }  
  18.           
  19.     }  
结果:

 

 

[plain] view plaincopy
 
  1. 活动ID:endevent1,活动名称:End,活动类型:endEvent,流程实例ID:701,接收人:null  
  2. --------------------------------  
  3. 活动ID:startevent1,活动名称:Start,活动类型:startEvent,流程实例ID:701,接收人:null  
  4. --------------------------------  
  5. 活动ID:员工请假,活动名称:员工请假,活动类型:userTask,流程实例ID:701,接收人:张三  
  6. --------------------------------  
  7. 活动ID:老板审批,活动名称:老板审批,活动类型:userTask,流程实例ID:701,接收人:老板  
  8. --------------------------------  

这几个是最常用的几个服务.

 

流程实例和执行对象的区别   流程实例和执行对象 2个是不同的一个概念

技术分享

 

技术分享

activiti入门2流程引擎的API和服务基础

标签：

原文地址：http://www.cnblogs.com/jiligalaer/p/4179829.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！