Activity7-流程初体验

news2024/10/6 22:24:40

流程符号详解：

创建Activiti工作流的主要步骤包含以下几步:

1. 定义流程。按照BPMN的规范，使用流程定义工具，将整个流程描述出来。

2. 部署流程。把画好的BPMN流程定义文件加载到数据库中，生成相关的表数据。

3. 启动流程。使用java代码来操作数据库表中的内容。

部署请假流程：

整体代码如下：

package com.nanjing;

import org.activiti.engine.*;
import org.activiti.engine.history.HistoricActivityInstance;
import org.activiti.engine.history.HistoricActivityInstanceQuery;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.repository.ProcessDefinition;
import org.activiti.engine.repository.ProcessDefinitionQuery;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.apache.commons.io.IOUtils;
import org.junit.Test;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.List;
import java.util.zip.ZipInputStream;

/**
 * @author ：楼兰
 * @date ：Created in 2021/4/7
 * @description:
 **/

public class ActivitiDemo {

    /**
     * 部署流程定义  文件上传方式
     */
    @Test
    public void testDeployment(){
//        1、创建ProcessEngine
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//        2、得到RepositoryService实例
        RepositoryService repositoryService = processEngine.getRepositoryService();
//        3、使用RepositoryService进行部署
        Deployment deployment = repositoryService.createDeployment()
                .addClasspathResource("leave.bpmn20.xml") // 添加bpmn资源
                //png资源命名是有规范的。Leave.myleave.png|jpg|gif|svg  或者Leave.png|jpg|gif|svg
                .addClasspathResource("leave.png")  // 添加png资源
                .name("请假申请流程")
                .deploy();
//        4、输出部署信息
        System.out.println("流程部署id：" + deployment.getId());
        System.out.println("流程部署名称：" + deployment.getName());
    }

    /**
     * zip压缩文件上传方式
     */
    @Test
    public void deployProcessByZip() {
        // 定义zip输入流
        InputStream inputStream = this
                .getClass()
                .getClassLoader()
                .getResourceAsStream(
                        "leave.zip");
        ZipInputStream zipInputStream = new ZipInputStream(inputStream);
        // 获取repositoryService
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        RepositoryService repositoryService = processEngine
                .getRepositoryService();
        // 流程部署
        Deployment deployment = repositoryService.createDeployment()
                .addZipInputStream(zipInputStream)
                .deploy();
        System.out.println("流程部署id：" + deployment.getId());
        System.out.println("流程部署名称：" + deployment.getName());
    }

    /**
     * 启动流程实例
     */
    @Test
    public void testStartProcess(){
//        1、创建ProcessEngine
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//        2、获取RunTimeService
        RuntimeService runtimeService = processEngine.getRuntimeService();
//        3、根据流程定义Id启动流程
        ProcessInstance processInstance = runtimeService
                .startProcessInstanceByKey("myleave");
//        输出内容
        System.out.println("流程定义id：" + processInstance.getProcessDefinitionId());
        System.out.println("流程实例id：" + processInstance.getId());
        System.out.println("当前活动Id：" + processInstance.getActivityId());
    }


    /**
     * 查询当前个人待执行的任务
     */
    @Test
    public void testFindPersonalTaskList() {
//        任务负责人
        String assignee = "worker";
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//        创建TaskService
        TaskService taskService = processEngine.getTaskService();
//        根据流程key 和 任务负责人 查询任务
        List<Task> list = taskService.createTaskQuery()
                .processDefinitionKey("myleave") //流程Key
                .taskAssignee(assignee)//只查询该任务负责人的任务
                .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());

        }
    }

    // 完成任务
    @Test
    public void completTask(){
//        获取引擎
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//        获取taskService
        TaskService taskService = processEngine.getTaskService();

//        根据流程key 和 任务的负责人 查询任务
//        返回一个任务对象
        Task task = taskService.createTaskQuery()
                .processDefinitionKey("myleave") //流程Key
                .taskAssignee("worker")  //要查询的负责人
                .singleResult();

//        完成任务,参数：任务id
        taskService.complete(task.getId());
    }

    /**
     * 查询流程定义
     */
    @Test
    public void queryProcessDefinition(){
        //        获取引擎
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//        repositoryService
        RepositoryService repositoryService = processEngine.getRepositoryService();
//        得到ProcessDefinitionQuery 对象
        ProcessDefinitionQuery processDefinitionQuery = repositoryService.createProcessDefinitionQuery();
//          查询出当前所有的流程定义
//          条件：processDefinitionKey =evection
//          orderByProcessDefinitionVersion 按照版本排序
//        desc倒叙
//        list 返回集合
        List<ProcessDefinition> definitionList = processDefinitionQuery.processDefinitionKey("myleave")
                .orderByProcessDefinitionVersion()
                .desc()
                .list();
//      输出流程定义信息
        for (ProcessDefinition processDefinition : definitionList) {
            System.out.println("流程定义 id="+processDefinition.getId());
            System.out.println("流程定义 name="+processDefinition.getName());
            System.out.println("流程定义 key="+processDefinition.getKey());
            System.out.println("流程定义 Version="+processDefinition.getVersion());
            System.out.println("流程部署ID ="+processDefinition.getDeploymentId());
        }
    }

    /**
     * 查询流程实例
     */
    @Test
    public void queryProcessInstance() {
        // 流程定义key
        String processDefinitionKey = "myleave";
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        // 获取RunTimeService
        RuntimeService runtimeService = processEngine.getRuntimeService();
        List<ProcessInstance> list = runtimeService
                .createProcessInstanceQuery()
                .processDefinitionKey(processDefinitionKey)//
                .list();

        for (ProcessInstance processInstance : list) {
            System.out.println("----------------------------");
            System.out.println("流程实例id："
                    + processInstance.getProcessInstanceId());
            System.out.println("所属流程定义id："
                    + processInstance.getProcessDefinitionId());
            System.out.println("是否执行完成：" + processInstance.isEnded());
            System.out.println("是否暂停：" + processInstance.isSuspended());
            System.out.println("当前活动标识：" + processInstance.getActivityId());
            System.out.println("业务关键字："+processInstance.getBusinessKey());
        }
    }

    @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);
    }

    @Test
    public void  queryBpmnFile() throws IOException {
//        1、得到引擎
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//        2、获取repositoryService
        RepositoryService repositoryService = processEngine.getRepositoryService();
//        3、得到查询器：ProcessDefinitionQuery，设置查询条件,得到想要的流程定义
        ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery()
                .processDefinitionKey("myleave")
                .singleResult();
//        4、通过流程定义信息，得到部署ID
        String deploymentId = processDefinition.getDeploymentId();
//        5、通过repositoryService的方法，实现读取图片信息和bpmn信息
//        png图片的流
        InputStream pngInput = repositoryService.getResourceAsStream(deploymentId, processDefinition.getDiagramResourceName());
//        bpmn文件的流
        InputStream bpmnInput = repositoryService.getResourceAsStream(deploymentId, processDefinition.getResourceName());
//        6、构造OutputStream流
        File file_png = new File("/Users/zhou/myleave.png");
        File file_bpmn = new File("/Users/zhou/leave.bpmn20.xml");
        FileOutputStream bpmnOut = new FileOutputStream(file_bpmn);
        FileOutputStream pngOut = new FileOutputStream(file_png);
//        7、输入流，输出流的转换
        IOUtils.copy(pngInput,pngOut);
        IOUtils.copy(bpmnInput,bpmnOut);
//        8、关闭流
        pngOut.close();
        bpmnOut.close();
        pngInput.close();
        bpmnInput.close();
    }

    /**
     * 查看历史信息
     */
    @Test
    public void findHistoryInfo(){
//      获取引擎
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//        获取HistoryService
        HistoryService historyService = processEngine.getHistoryService();
//        获取 actinst表的查询对象
        HistoricActivityInstanceQuery instanceQuery = historyService.createHistoricActivityInstanceQuery();
//        查询 actinst表，条件：根据 InstanceId 查询，查询一个流程的所有历史信息
        instanceQuery.processInstanceId("2501");
//        查询 actinst表，条件：根据 DefinitionId 查询，查询一种流程的所有历史信息
//        instanceQuery.processDefinitionId("myleave:1:22504");
//        增加排序操作,orderByHistoricActivityInstanceStartTime 根据开始时间排序 asc 升序
        instanceQuery.orderByHistoricActivityInstanceStartTime().asc();
//        查询所有内容
        List<HistoricActivityInstance> activityInstanceList = instanceQuery.list();
//        输出
        for (HistoricActivityInstance hi : activityInstanceList) {
            System.out.println(hi.getActivityId());
            System.out.println(hi.getActivityName());
            System.out.println(hi.getProcessDefinitionId());
            System.out.println(hi.getProcessInstanceId());
            System.out.println("<==========================>");
        }
    }

}

1.部署流程，执行这个方法：testDeployment 

也可以通过zip压缩文件上传方式，一次定义多个流程，这里我就不尝试了

2.启动流程实例，执行testStartProcess

一个业务流程部署到activiti后，就可以使用了。例如这个出差申请的流程部署完成 后，就可以启动

一个流程进行一次出差申请了。流程的执行过程主要通过 RuntimeService服务来管理。

3.任务查询

流程启动后，任务的负责人就可以查询自己当前需要处理的待办任务了。

任务相关 的服务都是由TaskService管理。

当前请假流程启动后，就该等待worker用户提交请假申请了。实际中的 请假申请流程应该是从

worker提交请假申请开始，但是在activiti工作流 中，都是从starter事件开始，这个关系要理清楚。

4.流程任务处理

任务负责人查询到代办任务后，可以选择任务进行处理，完成任务。

这个任务完成后，这一个请假流程就推动到了下一个步骤，部门经理审批了。后续

可以用不同的用户来推动流程结束。

其实在完成审批任务的过程中，可以针对这个taskId，进行其他一些补充操作。例 如添加

Comment，添加附件，添加子任务，添加候选负责人等等。具体可以看下 taskService的API。

5.流程定义信息查询

这一步可以查询流程相关信息，包含流程定义，流程部署，流程版本。

6.流程实例信息查询 

7.删除流程

注:

1、这里只删除了流程定义，不会删除历史表信息

2、删除任务时，可以选择传入一个boolean型的变量cascade ，表示是 否级联删除。

默认是false，表示普通删除。

如果该流程下存在已经运行的流程，使用普通删除会报错，而级联删除

可以将流程及相关记录全部删除。删除没有完成的流程节点后，就可以

完全删除流程定义信息了。

项目开发中，级联删除操作一般只开放给管理员使用。

由于刚刚已经发起了流程，还没有走完，删除报错 

8.流程资源下载

在流程执行过程中，可以上传流程资源文件。我们之前在部署流程时，已经将 bpmn和描述bpmn

的png图片都上传了，并且在流程执行过程中，也可以上传资源 文件。如果其他用户想要查看这些

资源文件，可以从数据库中把资源文件下载下 来。

但是文件是以Blob的方式存在数据库中的，要获取Blob文件，可以使用JDBC来处 理。也可以使用

activiti提供的api来辅助实现。我们这里采用activiti的方式来实现。

注: 在获取资源文件名时，png图片资源的文件名是

processDefinition.getDiagramResourceName()，他来自于ACT_RE_PROCDEF表中的

DGRM_RESOURCE_NAME字段。这个字段 的值是在部署流程时根据文件名后缀判断出来的。

支持的格式为 [ResourceName].[key].[png|jpg|gif|svg]或者[ResourceName]. [png|jpg|gif|svg]

而bpmn文件的文件名是processDefinition.getResourceName()，他 来自于ACT_RE_PROCDEF表

中的RESOURCE_NAME字段。

9.流程历史信息查看

流程的历史信息都保存在activiti的act_hi_*相关的表中，我们可以查询流程执行的历 史信息。

这里需要通过HistoryService来查看相关的历史记录。

注:

1、关于流程历史信息，要注意，在删除流程时，如果是采取级联删 除的方式，那这个历史信息也

会随着一起删除。而普通删除方式不会删 除历史信息。

2、历史信息有不同的种类，具体可以通过historyService构建不同类型 的Query对象来获取结果。

 

 

 

 

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/71508.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

基于粒子群优化算法的微电网调度(光伏、储能、电动车、电网交互)（Matlab代码实现）

基于粒子群优化算法的微电网调度(光伏、储能、电动车、电网交互)（Matlab代码实现）

&#x1f4a5;&#x1f4a5;&#x1f4a5;&#x1f49e;&#x1f49e;&#x1f49e;欢迎来到本博客❤️❤️❤️&#x1f4a5;&#x1f4a5;&#x1f4a5;&#x1f3c6;博主优势&#xff1a;&#x1f31e;&#x1f31e;&#x1f31e;博客内容尽量做到思维缜密&#xff0c;逻辑清…
阅读更多...
目标检测3

目标检测3

还是目标检测相关~这次是Box Size置信度偏差会损害目标检测器 检测器的置信度预测在目标大小和位置方面存在偏差&#xff0c;但目前尚不清楚这种偏差与受影响的目标检测器的性能有何关系。 无数应用依赖于目标检测器的可靠置信度估计的准确预测。然而&#xff0c;众所周知&am…
阅读更多...
[附源码]Python计算机毕业设计Django在线招聘网站

[附源码]Python计算机毕业设计Django在线招聘网站

项目运行 环境配置&#xff1a; Pychram社区版 python3.7.7 Mysql5.7 HBuilderXlist pipNavicat11Djangonodejs。 项目技术&#xff1a; django python Vue 等等组成&#xff0c;B/S模式 pychram管理等等。 环境需要 1.运行环境&#xff1a;最好是python3.7.7&#xff0c;…
阅读更多...
突破40%！新能源汽车L2级辅助驾驶搭载率创新高

突破40%！新能源汽车L2级辅助驾驶搭载率创新高

新能源汽车正在成为智能化的主力军。 高工智能汽车研究院监测数据显示&#xff0c;2022年1-10月中国市场&#xff08;不含进出口&#xff09;新能源汽车前装标配搭载L2级辅助驾驶交付上险167.51万辆&#xff0c;前装搭载率首次突破40%&#xff0c;达到41.93%&#xff1b;同期&…
阅读更多...
[Java反序列化]CommonsBeanutils1利用链学习

[Java反序列化]CommonsBeanutils1利用链学习

0x01 前篇shiro的利用&#xff0c;需要动态字节码 &#xff0c;而这种方式需要我们自己添加依赖&#xff0c;所以很局限&#xff0c;而CommonsBeanutils 是shiro的依赖&#xff0c; CommonsBeanutils 是应用于 javabean 的工具 javabean的定义 类必须是具体的和公共的&#…
阅读更多...
传统服务器与云服务器

传统服务器与云服务器

传统服务器 传统服务器即物理服务器&#xff0c;是指独立服务器&#xff0c;也就是指物理上的单独服务器&#xff0c;物理服务器的构成包括处理器、硬盘、内存、系统总线等&#xff0c;和通用的计算机架构类似。 裸机物理服务器(BMS) 裸机服务器的官方定义是&#xff1a;裸机…
阅读更多...
【嵌入式硬件芯片开发笔记】4-2 mADAC芯片AD5421配置流程

【嵌入式硬件芯片开发笔记】4-2 mADAC芯片AD5421配置流程

【嵌入式硬件芯片开发笔记】4-2 mADAC芯片AD5421配置流程 16位、串行输入、环路供电、4 mA至20 mA DAC 可用于HART协议相关电路 同AD5700配合使用 AD5421的SPI和普通的不一样 回读时要发两段 CS中间拉高一次 数据在SCLK上升沿逐个输出&#xff0c;而且在 SCLK下降沿有效 固CPO…
阅读更多...
微服务框架 SpringCloud微服务架构 26 数据聚合 26.2 DSL 实现Bucket聚合

微服务框架 SpringCloud微服务架构 26 数据聚合 26.2 DSL 实现Bucket聚合

微服务框架 【SpringCloudRabbitMQDockerRedis搜索分布式&#xff0c;系统详解springcloud微服务技术栈课程|黑马程序员Java微服务】 SpringCloud微服务架构 文章目录微服务框架SpringCloud微服务架构26 数据聚合26.2 DSL 实现Bucket聚合26.2.1 DSL 实现Bucket聚合26.2.2 Buc…
阅读更多...
【设计模式】享元模式（Flyweight Pattern）

【设计模式】享元模式（Flyweight Pattern）

享元模式属于结构型模式&#xff0c;主要解决系统需要使用大量相似对象&#xff08;细粒度对象&#xff09;而消耗大量内存资源的问题。享元模式运用共享技术有效地支持大量细粒度的对象&#xff0c;其通过提取对象共同的信息抽象出享元对象&#xff0c;实现共享功能&#xff0…
阅读更多...
mysql详解之B树的查询时间复杂度

mysql详解之B树的查询时间复杂度

前言 本文是我在看了这篇文章之后&#xff08;这篇文章对b树的时间复杂度总结的很全面&#xff09;&#xff0c;关于B树&#xff08;或B树&#xff09;时间复杂度做的进一步思考&#xff08;如果对解题过程不感兴趣&#xff0c;可以直接看最后的总结&#xff09;。 正题 在这…
阅读更多...
Java继承（extends）简明教程

Java继承（extends）简明教程

继承是面向对象的三大特征之一。继承和现实生活中的“继承”的相似之处是保留一些父辈的特性&#xff0c;从而减少代码冗余&#xff0c;提高程序运行效率。 Java 中的继承就是在已经存在类的基础上进行扩展&#xff0c;从而产生新的类。已经存在的类称为父类、基类或超类&…
阅读更多...
物联网和大数据可应用在哪些领域？

物联网和大数据可应用在哪些领域？

物联网和大数据可应用在哪些领域&#xff1f;物联网和大数据是近年来最受媒体和企业关注的两大宏观技术趋势。两者也并驾齐驱&#xff0c;物联网旨在特定组织或环境中创建一个互联网络&#xff0c;使用该网络来收集数据并集中执行特定功能。物联网部署会生成大量以前未开发的数…
阅读更多...
【MR】C++ bullet客户端基于MR的动力学仿真

【MR】C++ bullet客户端基于MR的动力学仿真

程序基于&#xff08;A minimal example showing how to use PyBullet from C over shared memory.一个展示如何在共享内存上从c使用PyBullet的最小示例。https://github.com/erwincoumans/pybullet_cpp_sharedmemory_example&#xff09;实现与pybullet服务器通信交互。加上MR…
阅读更多...
MySql按条件插入数据，MySQL插入语句写where条件，MySQL在插入时做幂等

MySql按条件插入数据，MySQL插入语句写where条件，MySQL在插入时做幂等

文章目录写在前面根据条件插入数据1、先准备测试数据2、正常的插入语句3、有条件的插入语句&#xff08;重点&#xff09;4、查看最终结果总结分析写在前面 使用MySQL的删、改、查功能时&#xff0c;我们都可以根据where条件来对指定数据进行操作。 插入语句如何通过where条件…
阅读更多...
Git —— 关于创建多对非对称公钥时对不同服务器的匹配问题

Git —— 关于创建多对非对称公钥时对不同服务器的匹配问题

Git —— 关于创建多对非对称密钥时对不同服务器的匹配问题 《工欲善其事&#xff0c;必先利其器》—— 既然点进来了&#xff0c;麻烦你看下去&#xff0c;希望你有不一样的收获~ 《 前言 》 大概是半年前&#xff0c;我写过一篇关于 git 连接托管平台提示 permission denied…
阅读更多...
经典算法冒泡排序之标志位优化版

经典算法冒泡排序之标志位优化版

前言 今天总结一下优化版的经典算法——冒泡排序&#xff0c;不同于以往的暴力二重for循环&#xff0c;这里的冒泡排序增加了一个标志位。我们要理解该冒泡排序的概念&#xff0c;算法流程与算法思想&#xff0c;探讨时间复杂度。 冒泡排序算法解析 一、理解冒泡排序思想 1…
阅读更多...
Selenium4+Python3系列（十一） - Page Factory设计模式

Selenium4+Python3系列（十一） - Page Factory设计模式

写在前面&#xff1a; Page Object模式&#xff0c;目的是将元素定位和元素操作分层&#xff0c;只接触测试内容&#xff0c;不写基础内容&#xff0c;便于后续对自动化测试用例体系的维护&#xff0c;这是中心思想&#xff0c;也是核心。 那么我们继续将简洁延续&#xff0c…
阅读更多...
Allegro如何铺网格铜详细操作指导

Allegro如何铺网格铜详细操作指导

Allegro如何铺网格铜的三种方法操作指导 在做PCB设计的时候，时常需要铺网格铜，尤其是对于绕性有要求的时候，Allegro可以快捷铺出网格铜，类似下图 具体操作如下 直接铺网格铜 选择Shape add Rect命令 Option Type选择Static Crosshatch 画出需要的图形 鼠标右击done，…
阅读更多...
详解go语言包管理方式(go mod), 分析多目录多文件下的管理，不同工程下包的相互调用

详解go语言包管理方式(go mod), 分析多目录多文件下的管理，不同工程下包的相互调用

先明白一个点&#xff0c; 想要成功运行一个go程序&#xff0c; 有两种模式 一&#xff1a; 以前的默认模式&#xff0c;必须将项目放在gopath/src下 二&#xff1a;使用go mod 包管理方式&#xff0c; 项目可以放到任意位置&#xff0c;这样目录下需要有go.mod文件 下边我会分…
阅读更多...
毕业设计 stm32单片机的目标检测与跟踪系统 -物联网 openmv 嵌入式

毕业设计 stm32单片机的目标检测与跟踪系统 -物联网 openmv 嵌入式

文章目录0 前言课题简介设计框架3 硬件设计4 软件设计对被测物体的识别判断被测物体所在区域5 最后0 前言 &#x1f525; 这两年开始毕业设计和毕业答辩的要求和难度不断提升&#xff0c;传统的毕设题目缺少创新和亮点&#xff0c;往往达不到毕业答辩的要求&#xff0c;这两年…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023