首页 > 代码库 > 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,放到响应中
<script type="text/javascript"> $(function () { $(‘pre.prettyprint code‘).each(function () { var lines = $(this).text().split(‘\n‘).length; var $numbering = $(‘
    ‘).addClass(‘pre-numbering‘).hide(); $(this).addClass(‘has-numbering‘).parent().append($numbering); for (i = 1; i <= lines; i++) { $numbering.append($(‘
  • ‘).text(i)); }; $numbering.fadeIn(1700); }); }); </script>

    Activiti工作流-进阶