1000字范文,内容丰富有趣,学习的好帮手!
1000字范文 > Activiti第二篇【管理流程定义 执行任务和流程实例 流程变量】

Activiti第二篇【管理流程定义 执行任务和流程实例 流程变量】

时间:2018-08-27 19:41:16

相关推荐

Activiti第二篇【管理流程定义 执行任务和流程实例 流程变量】

tags: Activiti

上篇Activiti只是一个快速入门案例,这篇就讲定义、部署、查看任务等等的一些细节【涉及到的数据库表、对象等等】...

管理流程定义

管理流程定义主要涉及到以下的4张表:

-- 流程部署相关的表SELECT * FROM act_ge_bytearray # 通用字节资源表SELECT * FROM act_ge_property # 通用属性表,可以生成部署idSELECT * FROM act_re_deployment #部署表SELECT * FROM act_re_procdef # 流程定义表复制代码

PNG资源

在Eclipse中Activiti插件会自动生成一个BPMN与之对应的PNG图片,是需要通过加载PNG图片的

@Testpublic void deploy() {//获取仓库服务 :管理流程定义RepositoryService repositoryService = processEngine.getRepositoryService();Deployment deploy = repositoryService.createDeployment()//创建一个部署的构建器.addClasspathResource("LeaveActiviti.bpmn")//从类路径中添加资源,一次只能添加一个资源.name("请求单流程")//设置部署的名称.category("办公类别")//设置部署的类别.deploy();System.out.println("部署的id"+deploy.getId());System.out.println("部署的名称"+deploy.getName());}复制代码

而我们的Intellij idea插件不会自动生成PNG图片,但是我们在加载BPMN文件的时候,好像会自动插入PNG图片,数据库是有对应的记录的【我们是没有手动加载PNG图片资源的】

我们查看一下

//查看bpmn 资源图片@Testpublic void viewImage() throws Exception{String deploymentId="201";String imageName=null;//取得某个部署的资源的名称 deploymentIdList<String> resourceNames = processEngine.getRepositoryService().getDeploymentResourceNames(deploymentId);// buybill.bpmn buybill.pngif(resourceNames!=null&&resourceNames.size()>0){for(String temp :resourceNames){if(temp.indexOf(".png")>0){imageName=temp;}}}/*** 读取资源* deploymentId:部署的id* resourceName:资源的文件名*/InputStream resourceAsStream = processEngine.getRepositoryService().getResourceAsStream(deploymentId, imageName);//把文件输入流写入到文件中File file=new File("d:/"+imageName);FileUtils.copyInputStreamToFile(resourceAsStream, file);}复制代码

可惜的是,查看出来的图片的中文数据会乱码...

查看流程定义

我们当时候查询流程定义是通过我们设置流程图的id来查看的....其实我们可以通过其他的属性来查询...并且可以查询出更加详细的数据

//查看流程定义@Testpublic void queryProcessDefination(){String processDefiKey="buyBill";//流程定义key//获取流程定义列表List<ProcessDefinition> list = processEngine.getRepositoryService().createProcessDefinitionQuery()//查询 ,好比where//.processDefinitionId(proDefiId) //流程定义id// 流程定义id : buyBill:2:704 组成 : proDefikey(流程定义key)+version(版本)+自动生成id.processDefinitionKey(processDefiKey)//流程定义key 由bpmn 的 process 的 id属性决定//.processDefinitionName(name)//流程定义名称 由bpmn 的 process 的 name属性决定//.processDefinitionVersion(version)//流程定义的版本.latestVersion()//最新版本//排序.orderByProcessDefinitionVersion().desc()//按版本的降序排序//结果//.count()//统计结果//.listPage(arg0, arg1)//分页查询.list();//遍历结果if(list!=null&&list.size()>0){for(ProcessDefinition temp:list){System.out.print("流程定义的id: "+temp.getId());System.out.print("流程定义的key: "+temp.getKey());System.out.print("流程定义的版本: "+temp.getVersion());System.out.print("流程定义部署的id: "+temp.getDeploymentId());System.out.println("流程定义的名称: "+temp.getName());}}}复制代码

资源来自ZIP

我们还可以加载的是ZIP类型的资源数据

//部署流程定义,资源来自zip格式@Testpublic void deployProcessDefiByZip(){InputStream in=getClass().getClassLoader().getResourceAsStream("BuyBill.zip");Deployment deploy = processEngine.getRepositoryService().createDeployment().name("采购流程").addZipInputStream(new ZipInputStream(in)).deploy();System.out.println("部署名称:"+deploy.getName());System.out.println("部署id:"+deploy.getId());}复制代码

删除流程定义

//删除流程定义@Testpublic void deleteProcessDefi(){//通过部署id来删除流程定义String deploymentId="101";processEngine.getRepositoryService().deleteDeployment(deploymentId);}复制代码

再次查询的时候,已经没有101这个流程定义的数据了。

流程实例与任务执行

流程实例与任务执行的常用表有以下几个:

-- 流程实例与任务SELECT * FROM act_ru_execution # 流程执行对象信息SELECT * FROM act_ru_task # 正在运行的任务表SELECT * FROM act_hi_procinst # 历史流程实例表SELECT * FROM act_hi_taskinst # 历史流程任务表复制代码

这里就简单简述一下流程实例与流程对象的区别:

(1)如果是单例流程,执行对象ID就是流程实例ID(2)如果一个流程有分支和聚合,那么执行对象ID和流程实例ID就不相同(3)一个流程中,流程实例只有1个,执行对象可以存在多个。

开始流程##

@Testpublic void startProcess(){String processDefiKey="leaveActiviti";//bpmn 的 process id属性ProcessInstance pi = processEngine.getRuntimeService().startProcessInstanceByKey(processDefiKey);System.out.println("流程执行对象的id:"+pi.getId());//Execution 对象System.out.println("流程实例的id:"+pi.getProcessInstanceId());//ProcessInstance 对象System.out.println("流程定义的id:"+pi.getProcessDefinitionId());//默认执行的是最新版本的流程定义}复制代码

查看正在运行的任务

//查询正在运行任务 @Testpublic void queryTask(){//取得任务服务TaskService taskService = processEngine.getTaskService();//创建一个任务查询对象TaskQuery taskQuery = taskService.createTaskQuery();//办理人的任务列表List<Task> list = taskQuery.list();//遍历任务列表if(list!=null&&list.size()>0){for(Task task:list){System.out.println("任务的办理人:"+task.getAssignee());System.out.println("任务的id:"+task.getId());System.out.println("任务的名称:"+task.getName());}}}复制代码

查询SELECT * FROM act_ru_task 表

获取流程实例的状态

有的时候,我们需要判断它是在该流程,还是该流程已经结束了。我们可以根据获取出来的对象是否为空来进行判断

//获取流程实例的状态@Testpublic void getProcessInstanceState(){String processInstanceId="605";ProcessInstance pi = processEngine.getRuntimeService().createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();//返回的数据要么是单行,要么是空 ,其他情况报错//判断流程实例的状态if(pi!=null){System.out.println("该流程实例"+processInstanceId+"正在运行... "+"当前活动的任务:"+pi.getActivityId());}else{System.out.println("当前的流程实例"+processInstanceId+" 已经结束!");}}复制代码

查看历史流程实例的信息

//查看历史执行流程实例信息@Testpublic void queryHistoryProcInst(){List<HistoricProcessInstance> list = processEngine.getHistoryService().createHistoricProcessInstanceQuery().list();if(list!=null&&list.size()>0){for(HistoricProcessInstance temp:list){System.out.println("历史流程实例id:"+temp.getId());System.out.println("历史流程定义的id:"+temp.getProcessDefinitionId());System.out.println("历史流程实例开始时间--结束时间:"+temp.getStartTime()+"-->"+temp.getEndTime());}}}复制代码

查询表:

查看历史实例执行任务信息

@Testpublic void queryHistoryTask(){String processInstanceId="605";List<HistoricTaskInstance> list = processEngine.getHistoryService().createHistoricTaskInstanceQuery().processInstanceId(processInstanceId).list();if(list!=null&&list.size()>0){for(HistoricTaskInstance temp:list){System.out.print("历史流程实例任务id:"+temp.getId());System.out.print("历史流程定义的id:"+temp.getProcessDefinitionId());System.out.print("历史流程实例任务名称:"+temp.getName());System.out.println("历史流程实例任务处理人:"+temp.getAssignee());}}}复制代码

给予对应的实例id就可以查询出执行到哪个任务了...

执行任务

根据任务的id,就可以把该任务执行了。

@Testpublic void compileTask(){String taskId="608";//taskId:任务idprocessEngine.getTaskService().complete(taskId);System.out.println("当前任务执行完毕");}复制代码

流程变量

流程变量涉及到的数据库表:

act_ru_variable:正在执行的流程变量表act_hi_varinst:流程变量历史表复制代码

流程变量在工作流中扮演着一个非常重要的角色。例如:请假流程中有请假天数、请假原因等一些参数都为流程变量的范围**。流程变量的作用域范围是只对应一个流程实例**。也就是说各个流程实例的流程变量是不相互影响的。流程实例结束完成以后流程变量还保存在数据库中(存放到流程变量的历史表中)。

设置流程变量

我们有两种服务可以设置流程变量,TaskService【任务服务】和RuntimeService【运行时服务】

场景

在流程开始的时候设置流程变量在完成某个任务的时候设置流程变量使用TaskService设置服务使用RuntimeService设置服务

作用:

传递业务参数动态指定代理人【我们快速入门的例子是固定在流程定义图上写上代理人的】指定连接【决定流程往哪边走】

流程变量支持类型

如果我们使用JavaBean来作为流程的变量,那么我们需要将JavaBean实现Serializable接口

Javabean类型设置获取流程变量,除了需要这个javabean实现了Serializable接口外,还要求流程变量对象的属性不能发生变化,否则抛出异常。解决方案,固定序列化ID

setVariable和setVariableLocal的区别

例子

//模拟流程变量设置@Testpublic void getAndSetProcessVariable(){//有两种服务可以设置流程变量//TaskService taskService = processEngine.getTaskService();//RuntimeService runtimeService = processEngine.getRuntimeService();/**1.通过 runtimeService 来设置流程变量* executionId: 执行对象* variableName:变量名* values:变量值*///runtimeService.setVariable(executionId, variableName, values);//runtimeService.setVariableLocal(executionId, variableName, values);//设置本执行对象的变量 ,该变量的作用域只在当前的execution对象//runtimeService.setVariables(executionId, variables); //可以设置多个变量 放在 Map<key,value> Map<String,Object>/**2. 通过TaskService来设置流程变量* taskId:任务id*///taskService.setVariable(taskId, variableName, values);//taskService.setVariableLocal(taskId, variableName, values);设置本执行对象的变量 ,该变量的作用域只在当前的execution对象//taskService.setVariables(taskId, variables); //设置的是Map<key,values>/**3. 当流程开始执行的时候,设置变量参数* processDefiKey: 流程定义的key* variables: 设置多个变量 Map<key,values>*///processEngine.getRuntimeService()//.startProcessInstanceByKey(processDefiKey, variables)/**4. 当任务完成时候,可以设置流程变量* taskId:任务id* variables: 设置多个变量 Map<key,values>*///processEngine.getTaskService().complete(taskId, variables);/** 5. 通过RuntimeService取变量值* exxcutionId: 执行对象* *///runtimeService.getVariable(executionId, variableName);//取变量//runtimeService.getVariableLocal(executionId, variableName);//取本执行对象的某个变量//runtimeService.getVariables(variablesName);//取当前执行对象的所有变量/** 6. 通过TaskService取变量值* TaskId: 执行对象* *///taskService.getVariable(taskId, variableName);//取变量//taskService.getVariableLocal(taskId, variableName);//取本执行对象的某个变量//taskService.getVariables(taskId);//取当前执行对象的所有变量}复制代码

//设置流程变量值@Testpublic void setVariable(){String taskId="1804";//任务id//采用TaskService来设置流程变量//1. 第一次设置流程变量//TaskService taskService = processEngine.getTaskService();//taskService.setVariable(taskId, "cost", 1000);//设置单一的变量,作用域在整个流程实例//taskService.setVariable(taskId, "申请时间", new Date());//taskService.setVariableLocal(taskId, "申请人", "何某某");//该变量只有在本任务中是有效的//2. 在不同的任务中设置变量//TaskService taskService = processEngine.getTaskService();//taskService.setVariable(taskId, "cost", 5000);//设置单一的变量,作用域在整个流程实例//taskService.setVariable(taskId, "申请时间", new Date());//taskService.setVariableLocal(taskId, "申请人", "李某某");//该变量只有在本任务中是有效的/*** 3. 变量支持的类型* - 简单的类型 :String 、boolean、Integer、double、date * - 自定义对象bean */TaskService taskService = processEngine.getTaskService();//传递的一个自定义bean对象AppayBillBean appayBillBean=new AppayBillBean();appayBillBean.setId(1);appayBillBean.setCost(300);appayBillBean.setDate(new Date());appayBillBean.setAppayPerson("何某某");taskService.setVariable(taskId, "appayBillBean", appayBillBean);System.out.println("设置成功!");}复制代码

//查询流程变量@Testpublic void getVariable(){String taskId="1804";//任务id//TaskService taskService = processEngine.getTaskService();//Integer cost=(Integer) taskService.getVariable(taskId, "cost");//取变量//Date date=(Date) taskService.getVariable(taskId, "申请时间");//取本任务中的变量Date date=(Date) taskService.getVariableLocal(taskId, "申请时间");//取本任务中的变量//String appayPerson=(String) taskService.getVariableLocal(taskId, "申请人");//取本任务中的变量String appayPerson=(String) taskService.getVariable(taskId, "申请人");//取本任务中的变量////System.out.println("金额:"+cost);//System.out.println("申请时间:"+date);//System.out.println("申请人:"+appayPerson);//读取实现序列化的对象变量数据TaskService taskService = processEngine.getTaskService();AppayBillBean appayBillBean=(AppayBillBean) taskService.getVariable(taskId, "appayBillBean");System.out.println(appayBillBean.getCost());System.out.println(appayBillBean.getAppayPerson());}复制代码

public class AppayBillBean implements Serializable{private Integer id;private Integer cost;//金额private String appayPerson;//申请人private Date date;//申请日期public Integer getId() {return id;}public void setId(Integer id) {this.id = id;}public Integer getCost() {return cost;}public void setCost(Integer cost) {this.cost = cost;}public String getAppayPerson() {return appayPerson;}public void setAppayPerson(String appayPerson) {this.appayPerson = appayPerson;}public Date getDate() {return date;}public void setDate(Date date) {this.date = date;}}复制代码

总结

流程定义涉及到了四张数据库表 我们可以通过API把我们的流程定义图读取出来可以根据查询最新版本的流程定义删除流程定义部署流程定义的时候也可以是ZIP文件流程在运行中,涉及到两个对象,四张数据库表:流程实例流程任务流程实例可以有多个,流程对象只能有一个。如果流程没有分支的话,那么流程实例就等于流程对象基于这么两个对象,我们就可以做很多事情了获取流程实例和任务的历史信息判断流程实例是否为空来判断流程是否结束了查看正在运行服务的详细信息通过流程实例来开启流程流程变量:它涉及到了两张表。流程变量实际上就是我们的条件。流程变量的作用域只在流程实例中。我们可以在流程开始的时候设置流程变量,在任务完成的时候设置流程变量。运行时服务和流程任务都可以设置流程变量。

如果您觉得这篇文章帮助到了您,可以给作者一点鼓励

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。