首页 > 代码库 > Activiti工作流-进阶
Activiti工作流-进阶
流程变量
流程变量非常重要,临时存储一些变量,该变量一般是与具体业务相关的,也可以是任意想保存的,比如后面用流程跳转,也无需要流程变量;
流程变量就是工作流对业务进行交流的一个途径,窗口。
主要功能(类似一个Map):
- 存放基本的业务信息,比如主键,基本字段值
- 存放临时的判断用的变量,用来判断连线走向等等
- 存放动态的办理人,运行的时候可以做到办理人动态指定
- ….
流程变量的基本使用
- 一种是在启动流程的时候保存了变量和值,比如,保存了一个业务表的主键id。
- 一种是在任务运行中保存了变量和值,比如保存一些临时业务信息以及判断连线走向的信息。
启动流程的同时保存变量
//流程变量
//在启动流程的时候同时保存一个变量
@Test
public void setVarOnStart(){
//参数2:就是流程变量,结果是map,里面是key和value
Map<String, Object> variables = new HashMap<>();
//保存公司的名字
variables.put("username", "张三");
//。。。。放入nduo的变量--全局的变量
runtimeService.startProcessInstanceByKey("LeaveProcess", variables);
}
任务执行过程中随时保存变量
//在任务流转过程中设置变量
@Test
public void setVarOnTask(){
//某个任务,从数据库查询出来一个值,根据这个值,判断 是否走下一个节点
// taskService.setVariable(taskId, variableName, value);//key:value
// taskService.setVariables(taskId, variables);//map
//某个任务节点设置一个变量:(全局的变量)
taskService.setVariable("2505", "age", 18);
taskService.setVariable("2505", "name", "Rose");
taskService.setVariable("2505", "birthday", new Date());
taskService.setVariable("2505", "简历", new User(1001,"Jack","123456"));
}
获取流程变量(使用运行时和任务api均可)
//获取流程变量
@Test
public void getVar(){
//在流程运行过程中随时可以取出,任意的变量,那条线中的变量
//参数1:执行id,参数2:变量名字
String company =(String) runtimeService.getVariable("2501", "company");
System.out.println(company);
//在任意的任务中获取:该任务可拥有的
//参数1:任务id,参数2:变量的名字
String company2 =(String)taskService.getVariable("2505", "company");
System.out.println(company2);
System.out.println("------");
System.out.println(runtimeService.getVariable("2501", "name"));
System.out.println(runtimeService.getVariable("2501", "age"));
System.out.println(runtimeService.getVariable("2501", "birthday"));
System.out.println(runtimeService.getVariable("2501", "简历"));//反序列化回来了
}
连线
连线—SequenceFlow,连线的作用:告诉工作流引擎,流程该怎么走。
编写画流程图
对于工作流系统,开始节点必须且只能有一个,结束节点必须有但可以有多个。
换句话:流程的发起,只能是从一个点。结束,可以有多个。
大部分流程都是一个开始,一个结束。一般是谁申请,谁最后确认。
设置连线的条件:
在Condition中设置一个布尔值,里面的表达式可以用{}或者#{},如:<script type="math/tex" id="MathJax-Element-2">{}或者#{},如:</script>{msgtype==’不重要’}
测试流程
//个人任务办理
@Test
public void completePersonTask2(){
Map<String, Object> variables=new HashMap<String, Object>();
variables.put("msgtype", "重要");
taskService.complete("5002", variables);
}
要点:使用流程变量控制连线的走向。
缺点:不容易清晰的描绘出分支的走向,尤其是并行或排他业务,得靠大量变量来判断。
网关(并行、排他、包含)
网关—Gateway,主要是用来控制分支流程的。并行(必须同时走多根),排他的(只能走一根),包含的走法(可以走多根,也可以走一根)。
1.并行网关—Parallel Gateway
测试流程
部署流程定义
发布流程定义
查询个人任务
完成个人任务
小结
1)一个流程中流程实例只有1个(启动一次,只能生成一个实例),执行对象有多个(有分支,同时在跑)
活动:任意的一个节点都是活动。包含用户任务。
用户任务:方块(用户任务,带小人,其他的任务,工作流不认为是用户任务),
2)并行网关的功能是基于进入和外出的顺序流的:
分支(fork): 并行后的所有外出顺序流,为每个顺序流都创建一个并发分支(执行对象)。
汇聚(join): 所有到达并行网关,在此等待的进入分支, 直到所有进入顺序流的分支都到达以后, 流程就会通过汇聚网关。(只有全部汇聚后,流程才能真正通过并行网关)
3)并行网关的进入和外出都是使用相同节点标识(jbpm是用了两种节点图标)
4)如果同一个并行网关有多个进入和多个外出顺序流, 它就同时具有分支和汇聚功能。 这时,网关会先汇聚所有进入的顺序流,然后再切分成多个并行分支。
5)并行网关不会解析条件。 即使顺序流中定义了条件,也会被忽略。
6)并行网关不需要是“平衡的”(比如, 对应并行网关的进入和外出节点数目不一定相等)。如图中标示是合法的:
排他网关—Exclusive Gateway
无论如何,只会走一条线。
排他网关和直接连线的最大区别:排他网关有个默认值,连线必须是每根先都得给条件。
排他网关必须给流程变量,当判断结果没有符合条件的话,就会走默认的连线。不给流程变量,会报错,因为无法判断。
连线:如果给流程变量,按照流程变量的判断走,没有默认指定的连线。可以不给流程变量,也会走个默认(先画的那根线,不容易控制)
两者根据实际情况,都可以选择。
包含网关—Inclusive Gateway
相当于并行+排他。
inclusiveGateway与 exclusiveGateway的区别
- exclusiveGateway 只会寻找唯一一条能走完的flow,也就是说当有一个flow可以走通的情况下,它不会再次去寻找第二条可以走通的flow ,如是没有符合条件的,就走defalut的flow。
- inclusiveGateway 会寻找所有符合条件的 flow,也就是说他会走完所有的符合条件的flow,如果没有符合的,那么就去走defalut的flow。
包含网关可以使用并行+排他来代替。
任务
常用任务
常用的task,有如下几个:
- User Task:用户任务,需由用户(参与者、必须有办理人)来完成任务。
- Java Service Task:服务任务,也称之为自动节点任务,当运行到该类型的任务节点的时候,会自动执行一个Java类(需实现一个接口)的一个方法。(发短信、处理数据等)
- Jave Receive Task:接收任务,也称之为等待任务,需手动来完成任务(调一个方法)。
任务中除了用户任务,有参与者(人),其他都没有参与者。
//服务任务的代理类:用来自动执行一段代码
public class MyServiceJavaDelegate implements JavaDelegate{
@Override
//命令模式
public void execute(DelegateExecution execution) throws Exception {
//do something
//当节点走到这里的的时候,会自动调用这个方法,执行里面的逻辑,无需人工参与
System.out.println("服务节点(自动节点)正在执行");
}
}
为服务任务指定服务的类
告知完成(等待)任务:
//调用执行等待任务(一般是嵌入到程序的一段代码中):告知任务
@Test
public void signalTask(){
//申明告知:告诉工作流,我程序已经处理完了,你继续走流程
runtimeService.signal("2501");
}
等待任务没有具体的参与人。
流程的某个任务,是在程序里面运行的一部分。
比如,我们需要写一个业务保存用户业务,但保存该用户之前,需要走一段流程,在流程的某个节点,我才有资格保存该用户,而且保存完了之后,还有后面流程。在保存用户的逻辑的地方调用一个方法就行。
换句话说,该任务,就等着程序去调用他(某些业务操作后),之后,才能往下走。
用户任务—UserTask
根据任务办理人的特点,分为两大类:个人任务和群组任务
用户任务必须由人(参与者)来完成。
个人任务的分配
某个人物节点是由一个具体的人来完成的.
个人任务可以通过三种方式指定办理人
- 为assignee属性指定固定办理人(不常用)
- 为assignee属性指定“变量”(动态)办理人,即通过变量,在程序运行过程中,通过设置变量来动态指定办理人。
- 通过task listeners来动态指定办理人。操作:我们需要实现一个接口,写个类,类里面有个方法,方法中设置该节点的办理人。在画节点的时候,无需指定办理人。办理人会在进入到该节点之前,被lisener监听掉,调用上面的方法,设置进去办理人。
- 在任务节点指定办理人,使用变量的方式,变了名字叫:initiator(发起人)
- 在开始节点上设置发起人的变量名字
- 为中间节点,使用task listeners来指定class
//用户任务的监听(当走到该节点的时候会自动调用该监听)
public class MyUserTaskListener implements TaskListener{
@Override
//将原来的任务包装
public void notify(DelegateTask delegateTask) {
//设置办理人:一般实际开发的后,需要从组织机构 树中获取领导来审批
delegateTask.setAssignee("张三");
}
}
2.测试流程
部署流程:(略)
启动流程:(略)
添加spring注入:
//注入用户service
private IdentityService identityService;
//用户任务--个人任务
//启动流程
@Test
public void startProceeInstanceForPerson(){
//使用任务用户id来进行给变量赋值
//调用该方法之前,需要在开始节点告诉工作流,你的认证用户所使用的变量是谁?
identityService.setAuthenticatedUserId("张三");//当前登录人
runtimeService.startProcessInstanceByKey("myProcess");
//在启动的时候加一个变量initiator发起人--map
// runtimeService.startProcessInstanceByKey(processDefinitionKey, variables)
}
完成个人任务:(略)
发起人在一个流程中一般参与的较多。
群组任务(候选人candidate)的分配
一个任务节点是由一堆人来完成的,不需要直接指定具体的某个人。但最终还是由某个具体人来完成。
群组任务可以通过两大类(各三种方式)指定:
第一类:候选人列表:
- 为Candidate Users属性指定固定的群组人员。
- 为Candidate Users属性指定 “变量”(动态)群组人员,即通过变量,在程序运行过程中,通过设置变量来动态指定群组。
- 通过task listeners在程序中动态的来指定群组人员。
第二类:候选人群组编号(人员和组、关系,都是工作流表中给你设计好了。)
- 为Candidate groups属性指定固定的群组id,该群组中包含群组人员。
- 为Candidate groups属性指定“变量”(动态)的群组id。
- 通过task listeners在程序中动态的来指定群组id。
第二类方式以前都不用。原因是:实际业务开发的时候,组织机构、人员信息,都是由业务系统维护的。
代码略
其他api
历史记录的查询—HistoryService
<!-- 历史Service -->
<bean id="historyService" factory-bean="processEngine" factory-method="getHistoryService"/>
本地SQL查询—NativeSQL
<!-- 管理Service -->
<bean id="managementService" factory-bean="processEngine" factory-method="getManagementService"/>
@Test
public void queryByNativeSQL(){
//当默认的api不能满足你的时候,你可以自定义sql语句进行查询
List<HistoricTaskInstance> list = historyService.createNativeHistoricTaskInstanceQuery()
// .sql("select * from act_hi_taskinst")//必须传入sql
.sql("select * from "+managementService.getTableName(HistoricTaskInstance.class))//不知道对象对应的表名,怎么办
.list();
for (HistoricTaskInstance historicTaskInstance : list) {
System.out.println("历史的任务名称:"+historicTaskInstance.getName());
}
}
表单操作—FormService
业务关联工作流系统:
1.使用流程变量:存放业务表的表名#id,比如t_leave#1001
2.businiessKey(就是变量),和流程变量做法一样
3.formKey
主要用于实现动态表单。(每一个节点的表单页面都不一样)
<!-- 表单Service -->
<bean id="formService" factory-bean="processEngine" factory-method="getFormService"/>
方法1:
表单由工作流创建和管理(开始节点或任务节点):
程序中可以获取表单
formService.getStartFormData(processDefinitionId);//申请表单的数据
formService.getTaskFormData(taskId);//任务表单数据
方法2:
表单由应用程序创建和管理,工作流通过表单的url(form key)来引用
在应用程序中,可以获取该key,从而知道表单的url
formService.getStartFormKey(processDefinitionId);
formService.getTaskFormKey(processDefinitionId, taskDefinitionKey);//将得到url,放到响应中
Activiti工作流-进阶