SpringBoot集成Flowable案例

前言

Flowable 是一个使用 Java 编写的轻量级业务流程引擎。Flowable 流程引擎可用于部署 BPMN2.0 流程定义（用于定义流程的行业 XML 标准），创建这些流程定义的流程实例，进行查询，访问运行中或历史的流程实例与相关数据，等等。

代码实现

  • 流程部署、查询流程定义
  • 启动流程、查询流程
  • 待办任务、完成任务
  • 已结束流程、已完成任务

引入依赖

<!-- flowable -->
<dependency><groupId>org.flowable</groupId><artifactId>flowable-spring-boot-starter</artifactId><version>6.7.2</version>
</dependency>

配置文件

# 服务配置
# 服务配置
server:port: 8024# spring配置
spring:# 数据源配置datasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://127.0.0.1:3306/boot_flowable?useUnicode=true&useSSL=false&serverTimezone=UTC&characterEncoding=UTF8&nullCatalogMeansCurrent=trueusername: rootpassword: root# flowable配置
flowable:# 更新表策略，可选值：true,false,create,create-drop,drop-createdatabase-schema-update: true# 使用历史表db-history-used: true# 禁用自动部署/processes下的BPMN XML流程文件check-process-definitions: false# 保存历史数据的最高级别history-level: full

流程定义

package com.qiangesoft.flowable.controller;import com.qiangesoft.flowable.constant.ProcessConstant;
import com.qiangesoft.flowable.constant.R;
import org.flowable.engine.RepositoryService;
import org.flowable.engine.repository.Deployment;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.List;/*** 流程定义 控制器** @author qiangesoft* @date 2024-04-30*/
@RestController
@RequestMapping("/definition")
public class ProcessDefinitionController {@Autowiredprivate RepositoryService repositoryService;@GetMapping("/deploy")public R deploy() {// 部署流程Deployment deployment = repositoryService.createDeployment().addClasspathResource("bpmn/test.bpmn20.xml").deploy();return R.ok(deployment);}@GetMapping("/list")public R list() {// 查询部署流程List<Deployment> deploymentList = repositoryService.createDeploymentQuery().processDefinitionKey(ProcessConstant.PROCESS_KEY)
//                .deploymentName("").orderByDeploymentTime().desc().list();return R.ok(deploymentList);}@GetMapping("/get")public R get() {Deployment deployment = repositoryService.createDeploymentQuery().processDefinitionKey(ProcessConstant.PROCESS_KEY)
//                .deploymentName("").latest().singleResult();return R.ok(deployment);}}

流程实例

package com.qiangesoft.flowable.controller;import com.qiangesoft.flowable.constant.ProcessConstant;
import com.qiangesoft.flowable.constant.R;
import org.flowable.engine.RuntimeService;
import org.flowable.engine.runtime.ProcessInstance;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.List;/*** 流程实例 控制器** @author qiangesoft* @date 2024-04-30*/
@RestController
@RequestMapping("/instance")
public class ProcessInstanceController {@Autowiredprivate RuntimeService runtimeService;@GetMapping("/start")public R start() {// 启动流程：提供流程key，业务key，主题String businessId = "101";ProcessInstance processInstance = runtimeService.createProcessInstanceBuilder().processDefinitionKey(ProcessConstant.PROCESS_KEY).businessKey(ProcessConstant.BUSINESS_KEY_PREFIX + businessId).name("请假流程").start();return R.ok(processInstance.toString());}@GetMapping("/list")public R list() {// 查询进行中的流程实例List<ProcessInstance> processInstanceList = runtimeService.createProcessInstanceQuery().processDefinitionKey(ProcessConstant.PROCESS_KEY)
//                .deploymentId("")
//                .processInstanceId("")
//                .processInstanceBusinessKey("")
//                .processInstanceNameLike("请假流程").active().orderByProcessInstanceId().desc().list();return R.ok(processInstanceList.toString());}@GetMapping("/get")public R get(String instanceId) {// 某个实例ProcessInstance processInstance = runtimeService.createProcessInstanceQuery().processInstanceId(instanceId).singleResult();return R.ok(processInstance == null ? null : processInstance.toString());}}

流程任务

package com.qiangesoft.flowable.controller;import com.qiangesoft.flowable.constant.R;
import org.flowable.engine.TaskService;
import org.flowable.task.api.Task;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.List;/*** 流程待办 控制器** @author qiangesoft* @date 2024-04-30*/
@RestController
@RequestMapping("/task")
public class TaskController {@Autowiredprivate TaskService taskService;@GetMapping("/mine")public R mine() {// 某人的待办任务：按照时间倒序String userId = "zhangsan";List<Task> taskList = taskService.createTaskQuery()
//                .processDefinitionKey("")
//                .taskCandidateOrAssigned("").taskAssignee(userId).active().orderByTaskCreateTime().desc().list();return R.ok(taskList.toString());}@GetMapping("/handle")public R handle(String taskId) {// 完成任务taskService.complete(taskId);return R.ok();}}

流程历史

package com.qiangesoft.flowable.controller;import com.qiangesoft.flowable.constant.ProcessConstant;
import com.qiangesoft.flowable.constant.R;
import org.flowable.engine.HistoryService;
import org.flowable.engine.history.HistoricProcessInstance;
import org.flowable.task.api.history.HistoricTaskInstance;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.List;/*** 历史 控制器** @author qiangesoft* @date 2024-04-30*/
@RestController
@RequestMapping("/history")
public class HistoryController {@Autowiredprivate HistoryService historyService;@GetMapping("/finished")public R finished() {// 已结束的流程：按照结束时间倒序List<HistoricProcessInstance> processInstanceList = historyService.createHistoricProcessInstanceQuery()
//                .processInstanceId("")
//                .deploymentId("")
//                .processDefinitionName("")
//                .processInstanceBusinessKey("").processDefinitionKey(ProcessConstant.PROCESS_KEY).finished().orderByProcessInstanceEndTime().desc().list();return R.ok(processInstanceList.toString());}@GetMapping("/completed")public R completed() {// 某人已完成的任务：按照完成时间倒序String userId = "zhangsan";List<HistoricTaskInstance> processInstanceList = historyService.createHistoricTaskInstanceQuery()
//                .processInstanceId("")
//                .deploymentId("")
//                .processDefinitionName("")
//                .processInstanceBusinessKey("").taskAssignee(userId).processDefinitionKey(ProcessConstant.PROCESS_KEY).finished().orderByHistoricTaskInstanceEndTime().desc().list();return R.ok(processInstanceList.toString());}}

在这里插入图片描述

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

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

相关文章

SAP-MM-SD批次管理的影响点M3530

SAP-MM-SD批次管理的影响点M3530

业务场景： 业务部门在创建物料主数据时，勾选了“批次管理”实际不需要。收货时提示输入批次，不能收货了，那回到物料主数据修改，取消勾选“批次管理”发现取消不了，报错M3530，大致内容如下： “显示错误”按钮仅在对话框模式下出现，而不是在数据传输或大规模维护中。 步…
阅读更多...
【代码问题】【Pytorch】训练模型时Loss为NaN或INF

【代码问题】【Pytorch】训练模型时Loss为NaN或INF

解决方法或者问题排查&#xff1a; 加归一化层&#xff1a; 我的问题是我新增的一个模块与原来的模块得到的张量相加&#xff0c;原张量是归一化后的&#xff0c;我的没有&#xff1a; class Module(nn.Module):def __init__(self,dim,):super().__init__()# 新增一个LayerNo…
阅读更多...
一、交换网络基础

一、交换网络基础

目录 1.交换机的转发行为 2.数据帧的类型 3.ARP地址解析步骤 Hub&#xff1a;物理层设备 交换机&#xff1a;数据链路层设备 1.交换机的转发行为 泛洪&#xff08;Flooding&#xff09;&#xff08;有可能是单播帧&#xff08;未知单播帧&#xff09;&#xff0c;也有可能是…
阅读更多...
有没有一种可能性，你不投递简历，让HR主动联系你

有没有一种可能性，你不投递简历，让HR主动联系你

你是否觉得自己得主动给某个公司投递了简历，他们才会联系你，亦或者是自己得主动在招聘APP上联系那个BOSS，他才会反过来跟你说话，又或者是你千方百计的跟他打招呼了，还是没有回应，这一节有可能让你明白，有时候是可以，你不主动，他也会主动联系你的。 目录 1 简历是如何…
阅读更多...
webpack3升级webpack4遇到的各种问题汇总

webpack3升级webpack4遇到的各种问题汇总

webpack3升级webpack4遇到的各种问题汇总 问题1 var outputNamecompilation.mainTemplate.applyPluginWaterfull(asset-path,outputOptions.filename,{......)TypeError: compilation.mainTemplate.applyPluginsWaterfall is not a function解决方法 html-webpack-plugin 版…
阅读更多...
scikit-learn：Python中的机器学习-1

scikit-learn：Python中的机器学习-1

简介&#xff1a;问题设置 什么是机器学习&#xff1f; 机器学习是关于构建具有可调参数的程序&#xff0c;这些参数可以自动调整&#xff0c;以便通过适应先前看到的数据来改善其行为。机器学习可以被认为是人工智能的一个子领域&#xff0c;因为这些算法可以被视为构建模块…
阅读更多...
实战—登录功能引发的逻辑漏洞

实战—登录功能引发的逻辑漏洞

密码找回功能可能存在的漏洞 1.验证码发送后前端返回 2.验证码无次数限制可爆破 3.验证码可控/邮箱篡改为自己的接收短信验证码/手机号码篡改为自己的接收短信验证码 4.越权漏洞—>自己验证码通过改包然后修改他们密码 5.任意用户密码重置 6.密保问题在前端源码 实战…
阅读更多...
【AGX】Ubuntu20.04 + ROS_ noetic+ 大疆Mid360激光 雷达评测

【AGX】Ubuntu20.04 + ROS_ noetic+ 大疆Mid360激光 雷达评测

大家好&#xff0c;我是虎哥&#xff0c;最近组装机器人&#xff0c;使用到了大疆孵化的圳市览沃科技有限公司&#xff08;简称Livox览沃科技&#xff09;推出的觅道系列全新混合固态激光雷达Mid-360&#xff0c;顺便试试效果&#xff0c;也记录一下使用入门过程。 "觅道M…
阅读更多...
如何保证Redis双写一致性？

如何保证Redis双写一致性？

目录 数据不一致问题 数据库和缓存不一致解决方案 1. 先更新缓存&#xff0c;再更新数据 该方案数据不一致的原因 2. 先更新数据库&#xff0c;再更新缓存 3. 先删除缓存&#xff0c;再更新数据库 延时双删 4. 先更新数据库&#xff0c;再删除缓存 该方案数据不一致的…
阅读更多...
【C语言进阶】程序编译中的预处理操作

【C语言进阶】程序编译中的预处理操作

&#x1f4da;作者简介&#xff1a;爱编程的小马&#xff0c;正在学习C/C&#xff0c;Linux及MySQL.. &#x1f4da;以后会将数据结构收录为一个系列&#xff0c;敬请期待 ● 本期内容讲解C语言中程序预处理要做的事情 目录 1.1 预处理符号 1.2 #define 1.2.1 #define定义标识…
阅读更多...
Transformer 模型

Transformer 模型

Transformer 模型 输入编码多头自注意力机制前馈网络层编码器解码器当前主流的大语言模型都基于 Transformer 模型进行设计的。Transformer 是由多层的多头自注意力模块堆叠而成的神经网络模型。原始的 Transformer 模型由编码器和解码器两个部分构成，而这两个部分实际上可以独…
阅读更多...
【imazing骗局】imazing软件安全吗 需要越狱吗 为什么iPhone都会装iMazing来管理

【imazing骗局】imazing软件安全吗 需要越狱吗 为什么iPhone都会装iMazing来管理

鉴于苹果设备的封闭性与安全性&#xff0c;我们大部分情况下都需要搭配iTunes进行设备的管理。但作为一款全方位的iOS设备管理软件&#xff0c;iMazing竟然可以突破iTunes的限制&#xff0c;与设备直接连接&#xff0c;进行备份、管理等操作。 因此&#xff0c;很多人都会有疑…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023