• Activiti7 Maven笔记


    代码整合

    创建maven项目

    导入一下依赖

    >
            >17>
            >17>
            >UTF-8>
            >1.6.6>
            >1.2.12>
            >7.0.0.Beta1>
        >
    
    
        >
            >
                >org.activiti>
                >activiti-engine>
                >${activiti.version}>
            >
            >
                >org.activiti>
                >activiti-spring>
                >${activiti.version}>
            >
            <!-- bpmn 模型处理 -->
            
                org.activiti
                activiti-bpmn-model
                ${activiti.version}
            
            
            
                org.activiti
                activiti-bpmn-converter
                ${activiti.version}
            
            
            
                org.activiti
                activiti-json-converter
                ${activiti.version}
            
            
            
                org.activiti
                activiti-bpmn-layout
                ${activiti.version}
            
            
            
                org.activiti.cloud
                activiti-cloud-services-api
                ${activiti.version}
            
            
            
                mysql
                mysql-connector-java
                8.0.31
            
            
            
                org.mybatis
                mybatis
                3.4.5
            
            
            
                commons-dbcp
                commons-dbcp
                1.4
            
            
                junit
                junit
                4.12
            
            
            
                log4j
                log4j
                ${log4j.version}
            
            
                org.slf4j
                slf4j-api
                ${slf4j.version}
            
            
                org.slf4j
                slf4j-log4j12
                ${slf4j.version}
            
        >
    

    添加log4j日志配置

    #log4j.rootCategory=INFO, CONSOLE debug info warn error fatal
    log4j.rootCategory=debug, CONSOLE, LOGFILE
    # Set the enterprise logger category to FATAL and its only appender to CONSOLE.
    log4j.logger.org.apache.axis.enterprise=FATAL, CONSOLE
    # CONSOLE is set to be a ConsoleAppender using a PatternLayout.
    log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
    log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
    log4j.appender.CONSOLE.layout.ConversionPattern=%d{ISO8601} %-6r[%15.15t] %-5p %30.30c %x - %m\n
    # LOGFILE is set to be a File appender using a PatternLayout.
    log4j.appender.LOGFILE=org.apache.log4j.FileAppender
    log4j.appender.LOGFILE.File=d:\activiti.log
    log4j.appender.LOGFILE.Append=true
    log4j.appender.LOGFILE.layout=org.apache.log4j.PatternLayout
    log4j.appender.LOGFILE.layout.ConversionPattern=%d{ISO8601} %-6r[%15.15t] %-5p %30.30c %x - %m\n
    
    

    添加activiti配置文件

    
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:context="http://www.springframework.org/schema/context"
           xmlns:tx="http://www.springframework.org/schema/tx"
           xsi:schemaLocation="http://www.springframework.org/schema/beans
                        http://www.springframework.org/schema/beans/spring-beans.xsd
    http://www.springframework.org/schema/contex
    http://www.springframework.org/schema/context/spring-context.xsd
    http://www.springframework.org/schema/tx
    http://www.springframework.org/schema/tx/spring-tx.xsd">
    
        
        <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
            <property name="driverClassName" value="com.mysql.cj.jdbc.Driver" />
            <property name="url" value="jdbc:mysql://localhost:3306/activiti" />
            <property name="username" value="root" />
            <property name="password" value="123456" />
            <property name="maxActive" value="3" />
            <property name="maxIdle" value="1" />
        bean>
    
        <bean id="processEngineConfiguration"
              class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
            
            <property name="dataSource" ref="dataSource" />
            
            <property name="databaseSchemaUpdate" value="true"/>
        bean>
    beans>
    
    

    创建数据库 activiti

    java类编写程序生成表

     /**
         * 生成 activiti的数据库表
         */
        @Test
        public void testCreateDbTable() {
            //使用classpath下的activiti.cfg.xml中的配置创建processEngine
    		ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    		System.out.println(processEngine);
        }
    

    如果代码运行,没有生成表,可能是没有读取到activiti的配置文件

    请参考文章 https://blog.csdn.net/m0_46267506/article/details/139333129

    执行完成后我们查看数据库, 创建了 25 张表,结果如下:
    在这里插入图片描述

    Activiti数据表介绍

    表分类表名解释
    一般数据
    ACT_GE_BYTEARRAY通用的流程定义和流程资源
    ACT_GE_PROPERTY系统相关属性
    流程历史记录
    ACT_HI_ACTINST历史的流程实例
    ACT_HI_ATTACHMENT历史的流程附件
    ACT_HI_COMMENT历史的说明性信息
    ACT_HI_DETAIL历史的流程运行中的细节信息
    ACT_HI_IDENTITYLINK历史的流程运行过程中用户关系
    ACT_HI_PROCINST历史的流程实例
    ACT_HI_TASKINST历史的任务实例
    ACT_HI_VARINST历史的流程运行中的变量信息
    流程定义表
    ACT_RE_DEPLOYMENT部署单元信息
    ACT_RE_MODEL模型信息
    ACT_RE_PROCDEF已部署的流程定义
    运行实例表
    ACT_RU_EVENT_SUBSCR运行时事件
    ACT_RU_EXECUTION运行时流程执行实例
    ACT_RU_IDENTITYLINK运行时用户关系信息,存储任务节点与参与者的相关信息
    ACT_RU_JOB运行时作业
    ACT_RU_TASK运行时任务
    ACT_RU_VARIABLE运行时变量表

    类关系图

    在这里插入图片描述

    工作流引擎创建

    工作流引擎(ProcessEngine),相当于一个门面接口,通过ProcessEngineConfiguration创建processEngine,通过ProcessEngine创建各个service接口。

    默认创建方式

    将activiti.cfg.xml文件名及路径固定,且activiti.cfg.xml文件中有 processEngineConfiguration的配置, 可以使用如下代码创建processEngine:

    //直接使用工具类 ProcessEngines,使用classpath下的activiti.cfg.xml中的配置创建processEngine
    ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    System.out.println(processEngine);
    

    一般创建方式

    //先构建ProcessEngineConfiguration
    ProcessEngineConfiguration configuration = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml");
    //通过ProcessEngineConfiguration创建ProcessEngine,此时会创建数据库
    ProcessEngine processEngine = configuration.buildProcessEngine();
    

    Servcie服务接口

    Service是工作流引擎提供用于进行工作流部署、执行、管理的服务接口,我们使用这些接口可以就是操作服务对应的数据表

    Service创建方式

    通过ProcessEngine创建Service
    方式如下:

    RuntimeService runtimeService = processEngine.getRuntimeService();
    RepositoryService repositoryService = processEngine.getRepositoryService();
    TaskService taskService = processEngine.getTaskService();
    

    Service总览

    在这里插入图片描述
    简单介绍:

    RepositoryService

    是activiti的资源管理类,提供了管理和控制流程发布包和流程定义的操作。使用工作流建模工具设计的业务流程图需要使用此service将流程定义文件的内容部署到计算机。

    除了部署流程定义以外还可以:查询引擎中的发布包和流程定义。

    暂停或激活发布包,对应全部和特定流程定义。 暂停意味着它们不能再执行任何操作了,激活是对应的反向操作。获得多种资源,像是包含在发布包里的文件, 或引擎自动生成的流程图。

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

    RuntimeService

    Activiti的流程运行管理类。可以从这个服务类中获取很多关于流程执行相关的信息

    TaskService

    Activiti的任务管理类。可以从这个类中获取任务的信息。

    HistoryService

    Activiti的历史管理类,可以查询历史信息,执行流程时,引擎会保存很多数据(根据配置),比如流程实例启动时间,任务的参与者, 完成任务的时间,每个流程实例的执行路径,等等。 这个服务主要通过查询功能来获得这些数据。

    ManagementService

    Activiti的引擎管理类,提供了对 Activiti 流程引擎的管理和维护功能,这些功能不在工作流驱动的应用程序中使用,主要用于 Activiti 系统的日常维护。

    绘制流程(定义流程)

    添加节点,然后点击空白处 设置流程的id和name
    在这里插入图片描述
    为每个用户节点指定处理人和名称

    1. zhangsan 请假申请

    在这里插入图片描述

    下面两个用户节点分别是

    Assigneename
    lisi组长审批
    wangwu班长审批
    zhaoliu老师审批

    连接每个节点

    更改刚刚创建的文件为ecevtion.bpmn文件 因为创建的文件名是xml结尾的.

    保存png图片
    在这里插入图片描述
    最终结果
    在这里插入图片描述

    部署流程

     /**
         * 部署流程
         */
        @Test
        public void deploymentTest(){
            // 通过指定的配置文件(和指定id的bean)来创建activiti引擎配置ProcessEngineConfiguration,通过buildProcessEngine()创建流程引擎
            ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml", "processEngineConfiguration");
          // 1、创建ProcessEngine
            ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
    //        2、得到RepositoryService实例
            RepositoryService repositoryService = processEngine.getRepositoryService();
            //        3、使用RepositoryService进行部署
            Deployment deployment = repositoryService.createDeployment()
                    .name("请假申请流程")
                    .addClasspathResource("bpmn/evection.bpmn")
                    .addClasspathResource("bpmn/evection.png")
                    //禁止校验文件
                    //.disableSchemaValidation()
                    .deploy();
            //        4、输出部署信息
            System.out.println(deployment.getId()+"流程部署id");
            System.out.println(deployment.getName()+"流程部署名称");
        }
    

    完成部署

    在这里插入图片描述

    数据库 有哪些变化

    ACT_RE_DEPLOYMENT 流程定义部署表,每部署一次增加一条记录
    在这里插入图片描述

    act_ge_bytearray 流程资源表 存储的是bpmn文件和流程图
    在这里插入图片描述
    act_re_procdef 流程定义表,部署每个新的流程定义都会在这张表中增加一条记录 一个BPMN文件可以部署多个。
    这些记录包含了与流程定义相关的各种信息,包括流程定义的标识符(ID)、名称、版本号、部署 ID、资源文件名称等。 通常情况下,这些信息是从 BPMN 文件中提取并存储在数据库中的。因此,您可以将 ACT_RE_PROCDEF 表看作是存储了 BPMN 文件中的一些重要信息的映射表
    act_re_deployment和act_re_procdef一对多关系,一次部署在流程部署表生成一条记录,但一次部署可以部署多个流程定义,每个流程定义在流程定义表生成一条记录。每一个流程定义在act_ge_bytearray会存在两个资源记录,bpmn和png。

    在这里插入图片描述

    启动流程实例

    @Test
        public void start(){
            // 通过指定的配置文件(和指定id的bean)来创建activiti引擎配置ProcessEngineConfiguration,通过buildProcessEngine()创建流程引擎
            ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml", "processEngineConfiguration");
            // 1、创建ProcessEngine
            ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
            // 2、获取RunTimeService
            RuntimeService runtimeService = processEngine.getRuntimeService();
            //        3、根据流程定义key启动流程 操作的是ACT_RE_PROCDEF的key
            ProcessInstance processInstance = runtimeService
                    .startProcessInstanceByKey("myEvection");
    
            System.out.println("流程定义id:" + processInstance.getProcessDefinitionId());
            System.out.println("流程实例id:" + processInstance.getId());
            System.out.println("当前活动Id:" + processInstance.getActivityId());
    
        }
    

    act_hi_actinst 流程实例执行历史 记录的是流程图已经结束或者这在进行的节点
    在这里插入图片描述

    act_hi_identitylink 流程的参与用户历史信息 当前节点的处理人

    在这里插入图片描述

    act_hi_procinst 流程实例历史信息 就是当前流程实例的开始时间 结束时间 实例id 等信息
    在这里插入图片描述

    act_hi_taskinst 流程任务历史信息以及当前正在执行的任务 就是当前流程实例的执行人 开始时间 结束时间 实例id 等信息 当执行到这个节点的时候就会记录
    在这里插入图片描述

    act_ru_execution 流程执行信息
    在这里插入图片描述

    act_ru_identitylink 流程的参与用户信息
    在这里插入图片描述

    act_ru_task 任务信息 当前正在执行的任务
    在这里插入图片描述

    任务查询

    @Test
        public void selectTask(){
            // 通过指定的配置文件(和指定id的bean)来创建activiti引擎配置ProcessEngineConfiguration,通过buildProcessEngine()创建流程引擎
            ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml", "processEngineConfiguration");
            // 1、创建ProcessEngine
            ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
    
            TaskService taskService = processEngine.getTaskService();
    
            List list = taskService.createTaskQuery()
                    //流程Key
                    .processDefinitionKey("myEvection")
                    //只查询该任务负责人的任务
                    .taskAssignee("zhagnsan")
                    .list();
            for (Task task : list) {
                System.out.println("流程实例id:" + task.getProcessInstanceId());
                System.out.println("任务id:" + task.getId());
                System.out.println("任务负责人:" + task.getAssignee());
                System.out.println("任务名称:" + task.getName());
    
            }
    
        }
    

    具体的SQL语句是

    select distinct RES.* from ACT_RU_TASK RES
    inner join 
    ACT_RE_PROCDEF D
    on RES.PROC_DEF_ID_ = D.ID_ 
    WHERE RES.ASSIGNEE_ = ?
    and D.KEY_ = ? order by RES.ID_ asc LIMIT ? OFFSET ? 
    

    在这里插入图片描述

    完成任务

     // 完成任务
        @Test
        public void commitTask(){
    //        获取引擎
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    //        获取taskService
            TaskService taskService = processEngine.getTaskService();
    
    //        根据流程key 和 任务的负责人 查询任务
    //        返回一个任务对象
            Task task = taskService.createTaskQuery()
                    .processDefinitionKey("myEvection") //流程Key
                    .taskAssignee("zhagnsan")  //要查询的负责人
                    .singleResult();
    
    //        完成任务,参数:任务id
          //  taskService.complete("2505");
            taskService.complete(task.getId());
        }
    

    ACT_RU_TASK 由原来的请假申请更新为 组长审批
    在这里插入图片描述

    ACT_RU_IDENTITYLINK 增加了 lisi审批人
    在这里插入图片描述

    ACT_HI_ACTINST 新增了组长审批的数据 同时修改请假申请的完成时间
    在这里插入图片描述
    ACT_HI_IDENTITYLINK 增加了 lisi审批人
    在这里插入图片描述
    ACT_HI_TASKINST 新增了组长审批的数据 同时修改请假申请的完成时间
    在这里插入图片描述

    依次完成 lisi、wangwu、zhaoliu的申请

    lisi审批

     @Test
        public void commitTask(){
    //        获取引擎
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    //        获取taskService
            TaskService taskService = processEngine.getTaskService();
    
    //        根据流程key 和 任务的负责人 查询任务
    //        返回一个任务对象
            Task task = taskService.createTaskQuery()
                    .processDefinitionKey("myEvection") //流程Key
                    .taskAssignee("lisi")  //要查询的负责人
                    .singleResult();
    
    //        完成任务,参数:任务id
          //  taskService.complete("2505");
            taskService.complete(task.getId());
        }
    

    ACT_RU_TASK 变化
    在这里插入图片描述
    wangwu审批

     @Test
        public void commitTask(){
    //        获取引擎
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    //        获取taskService
            TaskService taskService = processEngine.getTaskService();
    
    //        根据流程key 和 任务的负责人 查询任务
    //        返回一个任务对象
            Task task = taskService.createTaskQuery()
                    .processDefinitionKey("myEvection") //流程Key
                    .taskAssignee("wangwu")  //要查询的负责人
                    .singleResult();
    
    //        完成任务,参数:任务id
          //  taskService.complete("2505");
            taskService.complete(task.getId());
        }
    

    ACT_RU_TASK变化
    在这里插入图片描述
    zhaoliu审批

     @Test
        public void commitTask(){
    //        获取引擎
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    //        获取taskService
            TaskService taskService = processEngine.getTaskService();
    
    //        根据流程key 和 任务的负责人 查询任务
    //        返回一个任务对象
            Task task = taskService.createTaskQuery()
                    .processDefinitionKey("myEvection") //流程Key
                    .taskAssignee("zhaoliu")  //要查询的负责人
                    .singleResult();
    
    //        完成任务,参数:任务id
          //  taskService.complete("2505");
            taskService.complete(task.getId());
        }
    

    ACT_RU_TASK变化 发现正在进行的流程没了 ,流程结束,没有审批人了
    在这里插入图片描述

    数据库整体变化

    ACT_HI_ACTINST
    在这里插入图片描述

    发现正对应画的流程图 从开始节点到结束节点。有开始时间,结束时间,审批人,节点的名称

    ACT_HI_IDENTITYLINK
    在这里插入图片描述

    当前所有参与节点审批的人

    ACT_HI_PROCINST
    在这里插入图片描述

    更新了结束时间和结束节点的id

    ACT_HI_TASKINST
    在这里插入图片描述

    只有流程节点的审批人 没有开始节点和结束节点 也是更新了结束时间

    ACT_RU_EXECUTION
    在这里插入图片描述

    变空了,因为没有正在运行的流程实例了 对应的下面的ACT_RU_IDENTITYLINK也变空了

    ACT_RU_IDENTITYLINK
    在这里插入图片描述

    删除流程

        /**
        * 删除流程
        */
       @Test
       public void deleteDeployment() {
           // 流程部署id
           String deploymentId = "1";
    
           ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
           // 通过流程引擎获取repositoryService
           RepositoryService repositoryService = processEngine
                   .getRepositoryService();
           //删除流程定义,如果该流程定义已有流程实例启动则删除时出错
           repositoryService.deleteDeployment(deploymentId);
           //设置true 级联删除流程定义,即使该流程有流程实例启动也可以删除,设置为false非级别删除方式,如果流程
           //repositoryService.deleteDeployment(deploymentId, true);
       }
    
  • 相关阅读:
    Redis 备份恢复(持久化)手册
    实在是解决不了来提问一下。UE5,打开项目地变成黑色怎么解决?
    文件相关的操作------Python
    Salesforce-Visualforce-4.标准控制器(Standard Controller)
    基于Java的酒店管理系统设计与实现
    如何确保亚马逊、速卖通等平台测评补单的环境稳定性和安全性?
    D咖饮品机器人惊艳亮相:智能硬件改变生活习惯
    uni-app 之 NoticeBar 滚动通知,横向滚动,竖/纵向滚动
    CSS中常见选择器的用法
    HandBrake :MacOS专业视频转码工具
  • 原文地址:https://blog.csdn.net/m0_46267506/article/details/139362471