码农的世界Java 杂谈程序员De天堂

最简单的Activiti入门教程

2018-10-25  本文已影响95人  清枫_小天

这篇文章主要讲以下三个方面

工作流介绍

以我们公司的报销流程为例：
小明--->提交申请--->人事审批-->经理审批-->财务审批--->结束
我们先思考一下，需要实现这的一个需求我们需要怎么做？
    我们可能需要去维护一个变量，来不断传递过去下一个处理者，或者是建相关的任务表之类的，如果需求不会变，没有什么条件处理，这样也好设计。
    但是，如果有条件【不同职位员工审批方式不一样】，需求更改了【不需要人事审批了】，那么我们的代码就会乱，不好维护。
    再来看这种问题就是一种流式的控制管理，基于这么一个原因，我们需要学习一个框架来帮我们完成并管理这样的报销流程，他可以在上级点击同意后自动将提交记录录到电脑并流转到下一节点，这就是我们这里要讲的工作流技术。

工作流(Workflow)，就是“业务过程的部分或整体在计算机应用环境下的自动化”，它主要解决的是“使在多个参与者之间按照某种预定义的规则传递文档、信息或任务的过程自动进行，从而实现某个预期的业务目标，或者促使此目标的实现”

这里我们也可以比对出工作流的优点：
  1. 提高系统的柔性，适应业务流程的变化
  2. 实现更好的业务过程控制，提高顾客服务质量
  3. 降低系统开发和维护成本

工作流执行过程

我们以官网提供的示例包演示：
官网https://www.activiti.org/get-started下载对应的jar包，解压出来，在wars包目录下有个activiti-app.war，把这个包放到tomgcat运行（运行之前我把数据库配置改成我本地的mysql：WEB-INF\classes\META-INF\activiti-app\activiti-app.properties）

项目启动成功进入到首页

1.png

进入第三个菜单Identity management
新建用户：这边新建用户小明假设他为员工，王五是经理

2.png
3.png

定义流程

在主界面点击Kickstart App，点击create Process按钮弹出新建流程模型界面


4.png
5.png
6.png

上图中定义了一个开始事件、两个用户任务、一个结束事件。我们定义的请假业务，需要将该用户任务分配给 小明。点击第一个用户任务，并修改“Assignment”属性，将“提交申请”任务分配给“xiaoming”用户。保存成功后，再使用同样的方法将“部门经理审批”任务分配给 王五用户，保存流程模型后，就可以将流程发布。


7.png

发布流程

在 activiti-app 中，一个 App 可包含多个流程模型，因此在发布流程前，先新建一个 App并为其设置流程模型。点击 Apps 菜单，再点击“Creaea App”按钮，新建一个 App，该App就包含我们前面所设计的请假流程模型

8.png
建好之后需要为其设置流程模型
9.png
点击一下即可，在关闭
q.png
点击进入到app中，点击发布public进行发布
w.png
发布成功后使用小明账户登录，进入到首页可以看到
e.png
进入请假流程模型App并且点击“Processes”菜单，在界面左上角，可以看到“Start a process”按钮，点击启动请假流程后，可以看到界面如图所示
r.png
点击complete，完成，任务跳转到下一个执行人
t.png
直至整个流程审批完成，结束
y.png

工作流模拟执行

在我们模拟工作流流程之前在介绍下工作流引擎

ProcessEngine对象，这是Activiti工作的核心。负责生成流程运行时的各种实例及数据、监控和管理流程的运行，其主要有以下两个职责

    了解完工作流引擎的这两个职责，我相信对于什么是工作流引擎一定已经有了一定的认识了，我们在用一句稍微有点官方的话来总结一下工作流引擎：工作流引擎为我们提供相关规则概念的定义，给我们提供了相关的API来调用这个引擎去执行流程。流程的操作实际上就是工作流引擎提供相关的api我们去调用它。

activiti.cfg.xml（activiti的配置文件）

Activiti核心配置文件，配置流程引擎创建工具的基本参数和数据库连接池参数
定义数据库配置参数

基于JDBC参数配置的数据库连接 会使用默认的MyBatis连接池。 下面的参数可以用来配置连接池（来自MyBatis参数）

下面所有的操作都需要用到工作流引擎对象，我们可以如下方式获取：

    ProcessEngine processEngine= ProcessEngines.getDefaultProcessEngine();

这里默认会去资源路径下读取配置文件activiti.cfg.xml

我们再来回顾下工作流执行过程，首先需要画好流程图，然后部署到app上
这个步骤我们叫：部署流程定义

 public void deploymentProcessDefinition(){
        Deployment deploy = processEngine.getRepositoryService()  //与流程定义和部署对象相关的Service
                .createDeployment()  //创建一个部署对象
                .name("审批流程")     //添加部署名称
                .addClasspathResource("diagrams/audit.xml")  //从classPath资源中加载，一次只能加载一个文件
                .addClasspathResource("diagrams/audit.png")
                .deploy();  //完成部署
    }

说明：

这一步在数据库中将操作三张表
然后需要发布：启动流程
    public void startProcess(){
        ProcessInstance process = processEngine.getRuntimeService().startProcessInstanceByKey("myProcess_1");
    }

操作数据库的act_ru_execution表,如果是用户任务节点，同时也会在act_ru_task添加一条记录，我们可以看到小明会有一条任务，查询操作如下：

        List<Task> taskList = processEngine.getTaskService()//与正在执行的任务管理相关的Service
                .createTaskQuery()//创建任务查询对象
                /**查询条件（where部分）*/
                .taskAssignee("小明")//指定个人任务查询，指定办理人
//                      .taskCandidateUser(candidateUser)//组任务的办理人查询
//                      .processDefinitionId(processDefinitionId)//使用流程定义ID查询
//                      .processInstanceId(processInstanceId)//使用流程实例ID查询
//                      .executionId(executionId)//使用执行对象ID查询
                /**排序*/
                .orderByTaskCreateTime().asc()//使用创建时间的升序排列
                /**返回结果集*/
//                      .singleResult()//返回惟一结果集
//                      .count()//返回结果集的数量
//                      .listPage(firstResult, maxResults);//分页查询
                .list();//返回列表
        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());
        }

说明

完成任务
    public void completeMyPersonalTask(){
        processEngine.getTaskService().  //正在执行任务相关的Service
                complete("104");  //根据taskid完成任务
    }

说明

综上，我们可以总结出这个几个Service
亦可以总结所用到的表

资源库流程规则表

  1. act_re_deployment 部署信息表
  2. act_re_model 流程设计模型部署表
  3. act_re_procdef 流程定义数据表
    运行时数据库表
  4. act_ru_execution 运行时流程执行实例表
  5. act_ru_identitylink 运行时流程人员表，主要存储任务节点与参与者的相关信息
  6. act_ru_task 运行时任务节点表
  7. act_ru_variable 运行时流程变量数据表
  8. act_ru_job 工作数据表
  9. act_ru_event_subscr 事件描述表
    历史数据库表
  10. act_hi_actinst 历史节点表
  11. act_hi_attachment 历史附件表
  12. act_hi_comment 历史意见表
  13. act_hi_identitylink 历史流程人员表
  14. act_hi_detail 历史详情表，提供历史变量的查询
  15. act_hi_procinst 历史流程实例表
  16. act_hi_taskinst 历史任务实例表
  17. act_hi_varinst 历史变量表
    组织机构表
  18. act_id_group 用户组信息表
  19. act_id_info 用户扩展信息表
  20. act_id_membership 用户与用户组对应信息表
  21. act_id_user 用户信息表
    通用数据表
  22. act_ge_bytearray 二进制数据表

  23. act_ge_property 属性数据表存储整个流程引擎级别的数据,初始化表结构时，会默认插入三条记录，


    27102725_uKzQ.jpg

企业中的应用

未完

上一篇 下一篇

猜你喜欢

热点阅读