Activiti——将绘制的流程图存入act数据库并进行流程推进与状态流转

文章目录

  • 前言
  • 流程图入库操作 RepositoryService
    • 项目结构
    • 数据库连接配置文件
    • 入库Java测试代码
    • zip 方式进行流程的批量部署
  • 流程启动 RuntimeService
  • 待处理任务查看 TaskService
  • 流程状态的扭转
  • 查询流程定义信息 RepositoryService
  • 查询正在执行的流程实例 RuntimeService
  • 已部署流程删除
  • 查询流程的历史记录信息 HistoryService

前言

之前的博客中,重点说明了activiti表的创建,以及第一张流程图的绘制。但是绘制的第一张流程图并非存在于对应的数据库中,今天需要做的就是将绘制的流程图,使用activiti的代码自动的填充进对应的数据表中。然后做一个简单的状态流转。

流程图入库操作 RepositoryService

项目结构

依旧是基于之前的项目依赖与结构。
在这里插入图片描述

数据库连接配置文件

其中数据库的连接配置文件activiti.cfg.xml,配置内容如下所示:

<?xml version="1.0" encoding="UTF-8"?>
<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/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexhttp://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx.xsd"><bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration"><property name="jdbcDriver" value="com.mysql.cj.jdbc.Driver"/><property name="jdbcUrl" value="jdbc:mysql://xxxx:3306/activiti_02?useSSL=false&amp;useUnicode=true&amp;characterEncoding=utf-8&amp;serverTimezone=GMT%2B8&amp;nullCatalogMeansCurrent=true"/><property name="jdbcUsername" value="root"/><property name="jdbcPassword" value="root"/><property name="databaseSchemaUpdate" value="true"/></bean><!-- <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"><property name="driverClassName" value="com.mysql.jdbc.Driver" /><property name="url" value="jdbc:mysql://xxxx:3306/activiti?useSSL=false&amp;useUnicode=true&amp;characterEncoding=utf-8&amp;serverTimezone=GMT%2B8" /><property name="username" value="root" /><property name="password" value="root" /><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>

配置文件中的一些注意事项在前面的博客中做了一些说明,此处不进行额外的讲解,有问题的参考之前的博客内容。

入库Java测试代码

编写一个测试类,其中的入库逻辑如下所示:

// 单个任务的部署
@Test
public void addTable(){ProcessEngine defaultProcessEngine = ProcessEngines.getDefaultProcessEngine();RepositoryService repositoryService = defaultProcessEngine.getRepositoryService();Deployment demo1 = repositoryService.createDeployment().addClasspathResource("bpmn/demo01.bpmn") // 添加流程图.addClasspathResource("bpmn/demo01.png") // 对应的流程图片 支持 png|jpg|gif|svg.name("第一个流程测试用例").deploy();System.out.println("流程部署id===》"+demo1.getId());System.out.println("流程部署name===》"+demo1.getName());
}

虽然都是使用addClasspathResource关联xml与png 图片,但是其中的底层原理则是根据文件后缀,自动去判断识别存入对应的数据表字段中。

查看控制台输出日志与数据库,可以发现能够将对应的流程图xml与流程图进行入库处理。

在这里插入图片描述
查看数据库是否存在对应的数据信息。

select * from ACT_RE_DEPLOYMENT;
select * from ACT_RE_PROCDEF;

在这里插入图片描述
在这里插入图片描述
上传后的文件内容存储表,可以通过查找act_ge_bytearray看见。
在这里插入图片描述
【注意点】

除了流程图的最初部署,会将流程图存入act_ge_bytearray表之外。
在流程审批的各个节点中,都能将对应的文件进行存储,方便后续进行文件的回显。

zip 方式进行流程的批量部署

将对应的 流程图 png 与 xml 汇总打包成一个zip文件,此时则需要注意 两个文件除了后缀不同之外,一定要保证前面的文件名称一致。
在这里插入图片描述
编写代码逻辑,将zip创建数据流,并使用activiti的DeploymentaddZipInputStream,将zip数据流解析并存入数据表中。

/*** zip 包方式批量上传流程图与流程xml文件*/
@Test
public void zipInsertTable(){// 获取zip文件流InputStream inputStream = this.getClass().getClassLoader().getResourceAsStream("bpmn/activitis.zip");ZipInputStream zipInputStream = new ZipInputStream(inputStream);ProcessEngine defaultProcessEngine = ProcessEngines.getDefaultProcessEngine();RepositoryService repositoryService = defaultProcessEngine.getRepositoryService();Deployment deploy = repositoryService.createDeployment().addZipInputStream(zipInputStream).deploy();System.out.println("流程部署id===》"+deploy.getId());System.out.println("流程部署name===》"+deploy.getName());
}

代码执行后,观察控制台打印日志信息与数据表的查询。
在这里插入图片描述

select * from ACT_RE_PROCDEF;

在这里插入图片描述

流程启动 RuntimeService

当对应的流程图的结构信息已经进行了入库操作,此时就可以编写代码进行流程的启动测试了。
在这里插入图片描述

启动流程的逻辑如下所示:

/*** 流程启动  初次启动* 注意: 每次执行一次  就是以当前的流程图模板  创建了一个新的 activiti 的对象*/
@Test
public void startFlow(){ProcessEngine defaultProcessEngine = ProcessEngines.getDefaultProcessEngine();RuntimeService runtimeService = defaultProcessEngine.getRuntimeService();// 注意此处的 key  就是流程图的 id ProcessInstance demo01 = runtimeService.startProcessInstanceByKey("demo01");System.out.println("流程定义 id===》"+demo01.getProcessDefinitionId());System.out.println("流程实例 id===》"+demo01.getId());System.out.println("当前活动 id===》"+demo01.getActivityId());
}

代码执行后查看控制台的相关日志输出。
在这里插入图片描述
【注意点】startProcessInstanceByKey("demo01") 指定的 key 必须与 流程图中的 id 一致
在这里插入图片描述
如果不一致,则会出现org.activiti.engine.ActivitiObjectNotFoundException: no processes deployed with key 'demoxxxx'的报错问题!!

【注意点】每次执行创建流程的代码,都会以工作流流程图作为模板,构建一个新的实例
在这里插入图片描述

待处理任务查看 TaskService

流程启动,在有些项目中的首页,需要展示当前登录者的待处理任务列表信息。

进行了启动工作流操作,此时的工作流中的节点流转,如下:
在这里插入图片描述

此时可以通过TaskService查看,下面是一个简单的例子。

/*** 查询当前个人待执行的任务*/
@Test
public void viewReDoTask(){// 工作流从启动开始  就会流转至 第一个 UserTask 节点,// 此时可以通过配置的 Assignee 查询指定的人的  一些待处理 任务信息String assignee = "worker";// 数据库连接配置操作ProcessEngine defaultProcessEngine = ProcessEngines.getDefaultProcessEngine();// 根据对应的流程 查询当前指定人的待处理任务信息TaskService taskService = defaultProcessEngine.getTaskService();List<Task> list = taskService.createTaskQuery().processDefinitionKey("demo01") // 指定哪个流程图模板.taskAssignee(assignee) // 指定是谁负责待处理的任务.list();if(!CollectionUtil.isEmpty(list)){list.forEach(x->{System.out.println("流程实例 id "+x.getProcessInstanceId());System.out.println("任务 id "+x.getId());System.out.println("任务负责人 "+x.getAssignee());System.out.println("任务名称"+x.getName());System.out.println("===========================================");});}
}

测试代码运行后,在控制台中可以看到以下的信息。
在这里插入图片描述

这里有两个流程实例,是因为为了验证启动流程是否同实例对象,执行了两次开启流程的代码逻辑。

流程状态的扭转

work节点中,上面进行了待处理任务的查看操作,如果用户进行了处理,需要将状态进行向下扭转,如何扭转任务的节点,接下来看下面的代码逻辑。

/*** 工作流的节点与状态的扭转*/
@Test
public void doTask(){// 获取数据库的连接信息ProcessEngine defaultProcessEngine = ProcessEngines.getDefaultProcessEngine();TaskService taskService = defaultProcessEngine.getTaskService();// 完成当前节点的任务  并向下推进String taskId = "7505";taskService.complete(taskId);
}

在这里插入图片描述

当任务进行推进操作后,再执行查询当前登录人员需要待处理的任务节点,那么任务id为 7505的相关任务不能查询到。查询一下。
在这里插入图片描述

任务编号为7505的已经成功推进!

查询流程定义信息 RepositoryService

再上面的startFlow()执行后,就会依据对应的工作流模板,创建一个工作流流程实例。查看指定的流程模板下已创建的相关流程实例信息,可以使用下面的代码逻辑实现。

/*** 查询流程定义 的一些内容*/
@Test
public void queryProcessDefinition(){// 获取数据库的连接信息ProcessEngine defaultProcessEngine = ProcessEngines.getDefaultProcessEngine();RepositoryService repositoryService = defaultProcessEngine.getRepositoryService();ProcessDefinitionQuery processDefinitionQuery = repositoryService.createProcessDefinitionQuery();// 指定需要查询哪个流程模板信息String flowId = "demo01";List<ProcessDefinition> list = processDefinitionQuery.processDefinitionKey(flowId) // 指定是哪个流程模板.orderByProcessDefinitionVersion() // 排序字段.desc().list();if(!CollectionUtil.isEmpty(list)){list.forEach(process->{System.out.println("流程定义 id "+process.getId());System.out.println("流程定义 name "+process.getName());System.out.println("流程定义 key "+process.getKey());System.out.println("流程定义 version "+process.getVersion());System.out.println("流程部署 id "+process.getDeploymentId());System.out.println("=============================");});}
}

查看控制台执行后的日志信息,如下所示:
在这里插入图片描述

查询正在执行的流程实例 RuntimeService

如果需要查询当前指定的流程模板,存在哪些流程实例处于流程中的状态,以及对应的流程实例的信息,以达到随时跟踪任务的执行情况。

可以使用如下方式进行查看:

/*** 查询指定工作流模板中,哪些实例正在执行流程中*/
@Test
public void queryDoProcessInstance(){// 指定工作流流程模板idString flowId= "demo01";// 获取数据库的连接信息ProcessEngine defaultProcessEngine = ProcessEngines.getDefaultProcessEngine();RuntimeService runtimeService = defaultProcessEngine.getRuntimeService();List<ProcessInstance> list = runtimeService.createProcessInstanceQuery().processDefinitionKey(flowId).list();if(!CollectionUtil.isEmpty(list)){list.forEach(processInstance->{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());System.out.println("=============================");});}
}

在这里插入图片描述

已部署流程删除

有些已经部署后的流程,需要进行删除操作,则可以使用下列的逻辑实现。

这里说的已部署,是指已经执行了addTable()做了流程文件的上传操作。

/*** 删除 已部署 的流程实例。* 注意:如果当前流程实例并未执行完成,进行删除时会出现报错。*/
@Test
public void deleteDeployment(){// 流程部署idString deployMentId = "5001";// 获取数据库的连接信息ProcessEngine defaultProcessEngine = ProcessEngines.getDefaultProcessEngine();RepositoryService repositoryService = defaultProcessEngine.getRepositoryService();// 当该已部署的流程,存在流程中的实例时,执行当前流程会报错!repositoryService.deleteDeployment(deployMentId);// 如果需要进行强制删除  则可以采取下列的方式进行//repositoryService.deleteDeployment(deployMentId,true);
}

如果当前已部署的流程存在流程中的实例时,执行删除操作会出现下面的报错信息。
在这里插入图片描述

查询流程的历史记录信息 HistoryService

在一般的审批详情列表中,通常需要展示一些已审批处理节点的记录信息,此时则可以使用 HistoryService 查询指定流程实例下的各个已处理的审批节点数据记录。

当然了,测试操作需要指定指定工作流模板的流程id,先查询可以测试的流程编号。

/*** 查询指定工作流模板中,哪些实例正在执行流程中*/
@Test
public void queryDoProcessInstance(){// 指定工作流流程模板idString flowId= "demo01";// 获取数据库的连接信息ProcessEngine defaultProcessEngine = ProcessEngines.getDefaultProcessEngine();RuntimeService runtimeService = defaultProcessEngine.getRuntimeService();List<ProcessInstance> list = runtimeService.createProcessInstanceQuery().processDefinitionKey(flowId).list();if(!CollectionUtil.isEmpty(list)){list.forEach(processInstance->{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());System.out.println("=============================");});}
}

在这里插入图片描述
使用对应的流程实例id,这里使用10001

使用下列代码进行历史数据的检索:

/*** 查询 历史信息*/
@Test
public void queryHistoryInfo(){String processInstanceId = "10001";ProcessEngine defaultProcessEngine = ProcessEngines.getDefaultProcessEngine();HistoryService historyService = defaultProcessEngine.getHistoryService();HistoricActivityInstanceQuery historicActivityInstanceQuery = historyService.createHistoricActivityInstanceQuery();historicActivityInstanceQuery.processInstanceId(processInstanceId);// 流程实例idhistoricActivityInstanceQuery.orderByHistoricActivityInstanceStartTime().asc();List<HistoricActivityInstance> list = historicActivityInstanceQuery.list();if(!CollectionUtil.isEmpty(list)){list.forEach(hi->{System.out.println(hi.getActivityId());System.out.println(hi.getActivityName());System.out.println(hi.getProcessDefinitionId());System.out.println(hi.getProcessInstanceId());System.out.println("=============================");});}
}

执行成功后在控制台的日志中可以看到下列信息:
在这里插入图片描述

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Springboot+Vue项目-基于Java+MySQL的在线文档管理系统(附源码+演示视频+LW)

大家好&#xff01;我是程序猿老A&#xff0c;感谢您阅读本文&#xff0c;欢迎一键三连哦。 &#x1f49e;当前专栏&#xff1a;Java毕业设计 精彩专栏推荐&#x1f447;&#x1f3fb;&#x1f447;&#x1f3fb;&#x1f447;&#x1f3fb; &#x1f380; Python毕业设计 &…

实测14us,Linux-RT实时性能及开发案例分享—基于全志T507-H国产平台

本文带来的是基于全志T507-H&#xff08;硬件平台&#xff1a;创龙科技TLT507-EVM评估板&#xff09;&#xff0c;Linux-RT内核的硬件GPIO输入和输出实时性测试及应用开发案例的分享。本次演示的开发环境如下&#xff1a; Windows开发环境&#xff1a;Windows 7 64bit、Window…

在 Linux 上通过 udev 规则绑定 ttyUSB 设备的相对地址

文章目录 问题描述解决方案1. 分辨当前 USB 设备的绝对地址2. 使用绝对地址查看设备属性3. 使用 udev 规则绑定设备到相对地址3.1. 区分多个不同型号 USB 设备3.2. 区分多个相同型号 USB 设备 问题描述 Linux 系统开机时会随机为连接的 USB 设备随机分配 /dev/ttyUSB* 这样的绝…

java学习之路-抽象类和接口

目录 前言 1.抽象类 1.2抽象类语法 1.3抽象类特性 1.4抽象类的作用 2.接口 2.1接口概念 2.2接口的定义 2.3接口的使用 接口使用栗子 2.4接口特性 2.5 实现多个接口 请看栗子 2.6接口间的继承 2.7接口使用实例 2.8Clonable 接口和深浅拷贝 2.9 抽象类和接口的区别…

华为是如何开经营分析会的?

添加图片注释&#xff0c;不超过 140 字&#xff08;可选&#xff09; 企业不可避免开各种会议&#xff0c;而其中经营分析会对于企业发展至关重要。该会议主要是对企业经营目标进行复盘&#xff0c;需要公司全体上下共同重视&#xff0c;其目的是让企业集中力量&#xff0c;解…

Java | Leetcode Java题解之第35题搜索插入位置

题目&#xff1a; 题解&#xff1a; class Solution {public int searchInsert(int[] nums, int target) {int n nums.length;int left 0, right n - 1, ans n;while (left < right) {int mid ((right - left) >> 1) left;if (target < nums[mid]) {ans mi…

根据表格该列数据的长度动态变化该列的宽度;

提示:记录工作中遇到的需求及解决办法 文章目录 前言一、代码前言 在使用elementui的表格将数据展示出来时,我们想根据表格该列数据的长度动态变化该列的宽度; 1.看了一下elementui文档有一个 width 的属性,可用它来修改对应列。 2.那么我们需要拿到该列的所有数据去比较…

java基础之类运行与双亲委派机制简介

一 类加载运行过程 通过java命令运行某个类的main函数来启动程序时&#xff0c;首先需要通过类加载器将主类加载到JVM中&#xff1b; 源码&#xff1a; package com.ddu.jvm;public class HelloWordHelper {public static void main(String[] args) {User user new User();…

初识java——jdk?环境变量?及关于安装jdk的步骤

文章目录 JDK的安装在安装JDK时遇到的问题&#xff1a; 背景知识一 什么是jdkjdk简介jdk文件详解&#xff1a;1 bin目录&#xff1a;2 lib目录&#xff1a;3 include目录.exe文件是可执行的应用程序&#xff0c;这个我们都清楚&#xff0c;但.dll文件又是做什么的呢&#xff1f…

数据结构学习之路--玩转队列的内核知识(附C源码)

嗨嗨大家~我又来啦&#xff01;今天为大家带来的是与队列相关的知识。我们马上进入知识的海洋~ 目录 前言 一、队列 1 队列的概念 2 队列的实现 2.1 队列的定义 2.2 队列的初始化 2.3 队列的判空 2.4 入队 2.5 出队 2.6 取队头元素 2.7 取队尾元素 2.8 取…

37、Tomato(VulnHub)

Tomato 一、nmap 2211是ssh的端口&#xff0c;21的ftp也不是弱密码 二、web渗透 随便看看 目录爆破 /seclists/Discovery/Web-Content/common.txt /antibot_image/antibots/readme.txt 发现该站点存在反爬机制 /antibot_image/antibots/info.php 提示我们该网页存在个参数 GET&…

SFP、SFP+、SFP28 与 QSFP28 收发器之间的差异:兼容性和性能

近年来&#xff0c;网络技术发展迅速&#xff0c;因此&#xff0c;计算专业人员面临着越来越令人困惑的术语和缩写词。 管理数据中心时必须了解的一个关键领域是收发器&#xff0c;特别是 SFP (1550nm/1310nm)、SFP (850nm) 和 QSFP28 (4x25G) 之间的差异。 这些型号在兼容性方…

深入浅出 SQL 优化:全面提升查询性能的技巧

文章目录 前言一、表结构分析1. 索引分析2. 数据类型分析3. 思考反范式设计的适用场景与潜在风险3.1数据冗余3.2 数据一致性3.3 更新性能 4. 关注临时表的创建与使用。4.1.尽量减少临时表的使用&#xff0c;以降低系统资源的消耗。4.2 使用合适的索引和数据类型优化临时表的性能…

HarmonyOS ArkUI实战开发-窗口模块(Window)

窗口模块用于在同一物理屏幕上&#xff0c;提供多个应用界面显示、交互的机制。 对应用开发者而言&#xff0c;窗口模块提供了界面显示和交互能力。对于终端用户而言&#xff0c;窗口模块提供了控制应用界面的方式。对于操作系统而言&#xff0c;窗口模块提供了不同应用界面的…

swiper 去掉轮播图上的小点点 小圆圈(完美解决方案)

文章目录 问题描述解决方案问题复现处理方案 问题描述 大家好&#xff01;我是夏小花&#xff0c;今天是2024年4月22日|农历三月十四&#xff0c;今天这篇博文主要解决swiper 去掉轮播图上的小点点 小圆圈&#xff0c;具体解决方案如下所示 解决方案 问题复现 现在现在可以看…

数据结构初阶-二叉树

&#x1f308;个人主页&#xff1a;羽晨同学 &#x1f4ab;个人格言:“成为自己未来的主人~” 二叉树 树概念和结构 树的概念 树是一种非线性的数据结构&#xff0c;它是由n&#xff08;n>0&#xff09;个有限节点组成的一个具有层次关系的集合&#xff0c;把它叫做树…

python--pyQt5 进度条:QProgressBar

https://www.cnblogs.com/itwangqiang/articles/14959401.html https://blog.csdn.net/weixin_43990846/article/details/123880081 进度条用于向用户指示操作的进度&#xff0c;并向他们保证应用程序仍在运行 例 1 import sys from PyQt5.QtWidgets import QApplication, QWi…

【机器学习】特征筛选:提升模型性能的关键步骤

一、引言 在机器学习领域&#xff0c;特征筛选是一个至关重要的预处理步骤。随着数据集的日益庞大和复杂&#xff0c;特征的数量往往也随之激增。然而&#xff0c;并非所有的特征都对模型的性能提升有所贡献&#xff0c;有些特征甚至可能是冗余的、噪声较大的或者与目标变量无关…

Webpack-

定义 静态模块&#xff1a;指的是编写代码过程中的html&#xff0c;css&#xff0c;js&#xff0c;图片等固定内容的文件 打包&#xff1a;把静态模块内容压缩、整合、翻译等&#xff08;前端工程化&#xff09; 1&#xff09;把less/sass转成css代码 2&#xff09;把ES6降级…

OpenHarmony鸿蒙南向开发案例:【智能加湿器】

样例简介 智能加湿器具有实时监控其所处环境温度、湿度&#xff0c;并通过数字管家设置日程&#xff0c;自动打开加湿器控制湿度功能。显示界面使用DevEco Studio 编写的js应用&#xff0c;具有很好的兼容和移植特性。硬件上采用了带有HDF框架的驱动模型&#xff0c;通过GPIO和…