flowable的变量实操及排坑

news2024/11/17 20:44:11

主要理解一下知识点
在这里插入图片描述

一、名字解释

详情解释传送门
setVariables 和 setVariablesLocal区别?

1.流程变量
在流程执行或者任务执行的过程中,用于设置和获取变量,使用流程变量在流程传递的过程中传递业务参数。
对应的表:
act_ru_variable:正在执行的流程变量表
act_hi_varinst:流程变量历史表

2.setVariable和setVariableLocal的区别

setVariable:设置流程变量的时候,流程变量名称相同的时候,后一次的值替换前一次的值,而且可以看到TASK_ID的字段不会存放任务ID的值

setVariableLocal:

1)设置流程变量的时候,针对当前活动的节点设置流程变量,如果一个流程中存在2个活动节点,对每个活动节点都设置流程变量,即使流程变量的名称相同,后一次的版本的值也不会替换前一次版本的值,它会使用不同的任务ID作为标识,存放2个流程变量值,而且可以看到TASK_ID的字段会存放任务ID的值。

例如act_hi_varinst 表的数据:不同的任务节点,即使流程变量名称相同,存放的值也是不同的。

2)还有,使用setVariableLocal说明流程变量绑定了当前的任务,当流程继续执行时,下个任务获取不到这个流程变量(因为正在执行的流程变量中没有这个数据),所有查询正在执行的任务时不能查询到我们需要的数据,此时需要查询历史的流程变量。

可以简单认为,variable都是针对processInstance的。

local可能是针对某个execution分支的,也可能针对task的。

这里就要谈一下变量的作用域,变量肯定是依附于某个流程里的概念而存在的,所以才能在流程流转过程中使用这些变量。

默认的变量都是流程实例级别的,也就是说,分支execution和task都可以读取到对应processInstance里的变量。

与之相对的就是local变量,简单来说就不是processInstance范围的变量,如何区分global和local呢?差别就是local的作用范围小,如果是分支execution的local变量,就只能在execution分支生存期使用。

比如并发分支结束了,变量也就没了

比如task结束了,变量也就没了。

local变量的好处是,可以在每个分支使用同名的变量,互相之间不受影响,会签multi-instance就是通过local局部变量实现的。

流程实例结束完成以后流程变量还保存在数据库中(存放到流程变量的历史表中)。

   1)流程变量的作用域就是流程实例,所以只要设置就行了,不用管在哪个阶段设置

   2)基本类型设置流程变量,在taskService中使用任务ID,定义流程变量的名称,设置流程变量的值

   3)Javabean类型设置流程变量,需要这个javabean实现了Serializable接口

    4)设置流程变量的时候,向act_ru_variable这个表添加数据

    5)流程变量的获取针对流程实例(1个流程),每个流程实例获取的流程变量是不同的

    6)使用基本类型获取流程变量,在taskService中使用任务ID,流程变量的名称,获取流程变量的值。

    7)Javabean类型设置获取流程变量,除了需要这个javabean实现了Serializable接口外,还要求流程变量对象的属性不能发生变化,否则抛出异常。解决方案,固定序列化ID

二、实操

test公用代码

 ProcessEngineConfiguration configuration= null;

    @Before
    public void before(){
        //获取 ProcessEngineConfiguration 对象
        configuration = new StandaloneProcessEngineConfiguration();
        // 配置数据库连接信息
        configuration.setJdbcDriver("com.mysql.cj.jdbc.Driver");
        configuration.setJdbcUsername("root");
        configuration.setJdbcPassword("123456");
        configuration.setJdbcUrl("jdbc:mysql://localhost:3306/flowable-learn?serverTimezone=UTC&nullCatalogMeansCurrent=true");
        //如果数据库中不存在表结构就新建
        configuration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
    }

    @Test
    public void test(){
        ProcessEngine processEngine = configuration.buildProcessEngine();
        RepositoryService repositoryService = processEngine.getRepositoryService();
        //完成流程部署
        Deployment deployment = repositoryService.createDeployment()
                .addClasspathResource("test.bpmn20.xml")
                .name("测试流程 部署")
                .deploy();
        System.out.println("deployment.getName() : " + deployment.getName());
        System.out.println("deployment.getId() : " + deployment.getId());
    }

先注意一个小细节

ProcessInstance instance1 = runtimeService.createProcessInstanceQuery().processInstanceId("75001").singleResult();
 System.out.println("instance1 proVar: "+instance.getProcessVariables()); // 结果{}

instance.getProcessVariables()为什么为空

这个问题,要从模型说起。
flowable自己实现了一个命令模式,所有的操作都是通过命令模式实现的,命令模式的好处是可以在执行命令前打开环境,命名结束后关闭环境。
很不幸的是,flowable是通过这种方式,打开jdbc和关闭jdbc的。
所以,一旦关闭jdbc,也就是执行cmd后,就不能操作数据库里,它没有hibernate那种OpenSessionInVIew的功能。
所以,你必须在cmd执行完之前,告诉activiti,需要取变量,否则它根本就不会去搜索,不发sql,就算数据库里有变量,也取不出来啊。
告诉flowable的方式,就是通过includeProcessVariables。
比如runtimeService.createProcessInstanceQuery().includeProcessVariables().list()就有变量
比如runtimeService.createProcessInstanceQuery().list()就没变量

1. 全局变量的替换规则

    @Test
    public void test02(){
        ProcessEngine processEngine = configuration.buildProcessEngine();
        RuntimeService runtimeService = processEngine.getRuntimeService();
        Map<String, Object> var = new HashMap<>();
        var.put("test","申请变量");
        ProcessInstance instance = runtimeService.startProcessInstanceById("test:2:47504",var);
        Map<String, Object> variables = new HashMap<>();
//        variables.put("Local","proInst");
        variables.put("test","proInst");
        runtimeService.setVariables(instance.getId(),variables);
        System.out.println(" instanceid: "+instance.getId());
        
    }
    
        @Test
    public void complete(){

        ProcessEngine processEngine = configuration.buildProcessEngine();
        TaskService taskService = processEngine.getTaskService();
        RuntimeService runtimeService = processEngine.getRuntimeService();
        ProcessInstance instance1 = runtimeService.createProcessInstanceQuery().processInstanceId("77501").includeProcessVariables().singleResult();
        ProcessInstance instance = runtimeService.createProcessInstanceQuery().processInstanceId("77501").includeProcessVariables().singleResult();
        System.out.println("instance proVar: "+instance.getProcessVariables());
        System.out.println("instance1 proVar: "+instance1.getProcessVariables());
        // instance proVar: {test=proInst}
// instance1 proVar: {test=proInst}

    }

结果被后面一个值所替换,如果其中一个设置为局部变量就不会被替换 == runtimeService.setVariablesLocal(instance.getId(),variables); ==

2. 任务变量

代码实操


	// 设置流程变量
    @Test
    public void test02(){
        ProcessEngine processEngine = configuration.buildProcessEngine();
        RuntimeService runtimeService = processEngine.getRuntimeService();
        Map<String, Object> var = new HashMap<>();
        var.put("test","申请变量");
        ProcessInstance instance = runtimeService.startProcessInstanceById("test:2:47504",var);
        Map<String, Object> variables = new HashMap<>();
        variables.put("Local","proInst");
        runtimeService.setVariablesLocal(instance.getId(),variables);
        System.out.println(" instanceid: "+instance.getId());
        // 1. 50001 2. 57501 3. 62501 4.70001 5.
    }
    
    // 完成任务,同时设置任务的局部变量
    @Test
    public void complete(){

        ProcessEngine processEngine = configuration.buildProcessEngine();
        TaskService taskService = processEngine.getTaskService();
        RuntimeService runtimeService = processEngine.getRuntimeService();
        // 62501  局部70001  全局72501
//        ProcessInstance instance1 = runtimeService.createProcessInstanceQuery().processInstanceId("77501").includeProcessVariables().singleResult();
//        ProcessInstance instance = runtimeService.createProcessInstanceQuery().processInstanceId("77501").includeProcessVariables().singleResult();
//        System.out.println("instance proVar: "+instance.getProcessVariables());
//        System.out.println("instance1 proVar: "+instance1.getProcessVariables());
        Map<String, Object> var = new HashMap<>();
        // 如果scope 为false,则任务变量都是空的,只有统一的流程实例变量
        var.put("complete","完成任务65003的变量,scope true");
        taskService.complete("65003",var,true);

    }

	//	查看变量
    @Test
    public void var(){

        ProcessEngine processEngine = configuration.buildProcessEngine();
        TaskService taskService = processEngine.getTaskService();
        HistoryService historyService = processEngine.getHistoryService();
        RuntimeService runtimeService = processEngine.getRuntimeService();
        HistoricProcessInstance historicProcessInstance = historyService.createHistoricProcessInstanceQuery()
                .processInstanceId("62501")
                .includeProcessVariables()
                .singleResult();
//        ProcessInstance instance = runtimeService.createProcessInstanceQuery().processInstanceId("50001").singleResult();
        System.out.println("流程实例 ProcessVariables: "+historicProcessInstance.getProcessVariables());


        List<HistoricVariableInstance> list1 = historyService.createHistoricVariableInstanceQuery().processInstanceId("62501").list();
        System.out.println("流程实例变量 =================== ");
        list1.forEach(item -> {
            System.out.println("name: "+item.getVariableName());
            System.out.println("value: "+item.getValue());
        });
        System.out.println("流程实例变量 =================== ");

        // ("50006");
        List<HistoricVariableInstance> list = historyService.createHistoricVariableInstanceQuery().taskId("62506").list();
        System.out.println("任务1的变量 =================== ");
        list.forEach(item -> {
            System.out.println(item.getVariableName());
            System.out.println(item.getValue());
        });
        System.out.println("任务1的变量 =================== ");
        List<HistoricVariableInstance> list2 = historyService.createHistoricVariableInstanceQuery().taskId("65003").list();
        System.out.println("任务2的变量 =================== ");
        list2.forEach(item -> {
            System.out.println(item.getVariableName());
            System.out.println(item.getValue());
        });
        System.out.println("任务2的变量 =================== ");
//        Map<String, Object> variables02 = taskService.getVariables("52503");
//        System.out.println("任务2的变量: "+variables02);
//        Map<String, Object> var = new HashMap<>();
//        var.put("complete","完成任务50006的变量");
//        taskService.complete("50006",var);


        /**
         * 流程实例 ProcessVariables: {test=申请变量, Local=proInst}
         * 流程实例变量 =================== 
         * name: test
         * value: 申请变量
         * name: Local
         * value: proInst
         * name: complete
         * value: 完成任务62506的变量,scope true
         * name: complete
         * value: 完成任务65003的变量,scope true
         * 流程实例变量 =================== 
         * 任务1的变量 =================== 
         * complete
         * 完成任务62506的变量,scope true
         * 任务1的变量 =================== 
         * 任务2的变量 =================== 
         * complete
         * 完成任务65003的变量,scope true
         * 任务2的变量 =================== 
         */
    }


结果

在这里插入图片描述

taskService.complete(“65003”,var,true)

complete可以增加每个任务的环境变量(就是一个任务关联一些独有变量),比如一个任务一个表单,scope 要设置为true(true为局部,false为全局 [ 默认 ])

scope为true时

在这里插入图片描述
历史变量表就会关联taskid

scope为false时

在这里插入图片描述
历史变量表就不会关联taskid,是实例全局变量,会发生替换之前的变量值问题

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

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

相关文章

操作系统——4.操作系统的运行机制和体系结构

这篇文章&#xff0c;我们一起来学习一下操作系统的运行机制和体系结构 目录 1.概述 2.运行机制 2.1两种指令 2.2两种处理器状态 ​编辑2.3两种程序 ​编辑2.4 操作系统运行机制小结 3.操作系统内核 ​4.操作系统的体系结构 5.小结 1.概述 首先&#xff0c;我们来看一下…

OpenResty | nginx内部发送请求

文章目录一. http请求的API二. 封装http工具函数三. CJSON工具类四. hash均衡(1) 原理(2) 实现一. http请求的API 关于OpenResty如何安装和编写业务逻辑可以参考这篇文章&#xff1a;点击跳转 nginx提供了内部API用以发送http请求&#xff1a; local resp ngx.location.capt…

听说2年以上的自动化测试都有16k+,4年10k的你还要等待奇迹吗?

个人简介学渣一枚&#xff0c;2017年6月某xx学校毕业。从事自动化测试已经4年&#xff0c;。2018年的时候&#xff0c;由于项目的原因&#xff0c;开始使用Robot Framework测试框架&#xff0c;正因为有Python的基础所以很快就理解了Robot Framework框架的工作原理&#xff0c;…

【Vue】浅谈vue2、vue3响应式原理,vue中数组的响应式,响应式常见问题分析

前言&#xff1a;此处响应式指的是数据响应式变化&#xff0c;而不是页面的响应式布局&#xff0c;页面的响应式布局在我的其他文章中有提到。 一、什么是vue响应式 Vue 最标志性的功能就是其低侵入性的响应式系统。组件状态都是由响应式的 JavaScript 对象组成的。当更改它们…

以太网基础

1.系统概述网卡(Network Interface Card&#xff0c;简称NIC)&#xff0c;也称网络适配器&#xff0c;一个网卡主要包括OSI的最下面的两层&#xff0c;物理层和数据链路层。物理层定义了数据传送与接收所需要的电与光信号、线路状态、时钟基准、数据编码和电路等&#xff0c;并…

Ambire 最新消息——2023 年 1 月

大家好&#xff0c;这里是我们在过去几周所做的一切的快速回顾。 发展 整个钱包的交易模拟和余额预测 我们推出了一项真正改变加密钱包 UX 游戏规则的功能&#xff1a;Ambire 现在向用户显示他们的钱包余额将如何更新&#xff0c;甚至在签署交易之前。 这项新功能可以分解为 Am…

PMP证书在哪个行业比较有用?

PMP 各个行业都能用&#xff0c;PMP 的知识体系是通用的&#xff0c;管理层的考试也有借鉴PMP知识的地方。历年考生考的最多的是IT 行业&#xff0c;其他行业也都有分布。PMP认证从国外引进大陆这么多年了&#xff0c;其火热程度依然不减&#xff0c;我个人认为是取决于市场的运…

34、基于51单片机锂电池电压电流容量检测仪表LCD液晶显示 原理图PCB程序设计

方案选择 单片机的选择 方案一&#xff1a;AT89C52是美国ATMEL公司生产的低电压&#xff0c;高性能CMOS型8位单片机&#xff0c;器件采用ATMEL公司的高密度、非易失性存储技术生产&#xff0c;兼容标准MCS-51指令系统&#xff0c;片内置通用8位中央处理器(CPU)和Flash存储单元…

水泥|物流行业停车场电动发卡机读卡器K720的维护及使用注意事项

水泥|物流行业停车场电动发卡机读卡器K720采用工业级设计&#xff0c;表面烤漆处理&#xff0c;具有良好的耐磨耐腐蚀性。适应各种高、低温&#xff0c; 多灰尘等恶劣 环境。其发卡原理为拟人型摩擦式发卡&#xff0c;对各类变形卡有非常好的适应性。预留了活动式票箱安装位&am…

MyBatis 插件 + 注解轻松实现数据脱敏

问题在项目中需要对用户敏感数据进行脱敏处理&#xff0c;例如身份号、手机号等信息进行加密再入库。解决思路就是&#xff1a;一种最简单直接的方式&#xff0c;在所有涉及数据敏感的查询到对插入时进行密码加解密方法二&#xff1a;有方法一到出现对所有重大问题的影响&#…

C++如何实现系统语言切换功能,MessageBox的确认/取消按钮语言显示如何跟程序一致

文章目录前言 一、新建工程二、添加多国语言的资源三、程序语言设置四、语言切换五、字符串处理六、MessageBox的问题七、相关函数和类型参考文章前言 目前很多软件都是要出口到多个国家&#xff0c;多个地区&#xff0c;因此&#xff0c;为软件提供多国语言支持就成为了一个基…

20230215使用X99主板的电脑的性能测试(intel E5-2696V3 )

20230215使用X99主板的电脑的性能测试 2023/2/15 22:59 1850&#xffe5; 套餐七 模拟器参考20开 18核心36线程单路 适用 设计渲染 模拟器虚拟机工作室游戏多开 处理器 intel E5-2696V3 主频2.3G 18核心36线程 散热器 定制12CM大六铜管温控静音 主板 intel芯片X99-D3全固态大…

[项目篇] 音乐播放器开发报告

文章目录1. 项目描述:2. 项目上线展现&#xff1a;3. 项目具体实现&#xff1a;1. 登录2. 注册3.退出系统4.添加音乐4.1前后端交互约定4.2上传文件业务逻辑&#xff1a;4.3创建model包中的music类4.4在MusicMapper接口中&#xff0c;声明insertMusic抽象方法4.5在mybatis包中添…

既然有HTTP协议,为什么还要有RPC

既然有HTTP协议&#xff0c;为什么还要有RPC&#xff1f; 从TCP聊起 作为一个程序员&#xff0c;假设我们需要在A电脑的进程发一段数据到B电脑的进程&#xff0c;我们一般会在代码里使用socket进行编程。 这时候&#xff0c;我们可选项一般也就TCP和UDP二选一。TCP可靠&…

第六章 - 数据过滤where(where与and和or的组合用法)

第六章 - 数据过滤&#xff08;where的用法&#xff09;基本用法where的条件限制符等于号不等号! 或者<>小于<大于>小于等于<大于等于>between 的用法空值和非空值组合条件 and组合条件 orand 和 or 的计算次序in 和 not in基本用法 在查询语句中&#xff0…

JAVA面试八股文一(并发与线程)

并发的三大特性原子性&#xff1a;cpu在执行过程不可以暂停然后再调度&#xff0c;不可以中断&#xff0c;要不全部执行完&#xff0c;要不全部不执行。可见性&#xff1a;当多个线程访问同一个变量时&#xff0c;一个线程改变了这个变量的值&#xff0c;其他线程能够立即看到修…

PDF加密如何批量解除?快来了解下这个方法

在现代办公环境中&#xff0c;PDF文档的使用非常普遍。然而&#xff0c;由于一些安全需求&#xff0c;有时候PDF文档会被加密&#xff0c;使得只有授权人员可以查看或修改它。但是&#xff0c;如果您需要对许多加密PDF文档进行操作&#xff0c;逐个解密这些文档可能非常费时费力…

一文了解JAVA中同步、异步、阻塞和非阻塞

&#x1f3c6;今日学习目标&#xff1a; &#x1f340;JAVA中同步、异步、阻塞和非阻塞 ✅创作者&#xff1a;林在闪闪发光 ⏰预计时间&#xff1a;30分钟 &#x1f389;个人主页&#xff1a;林在闪闪发光的个人主页 &#x1f341;林在闪闪发光的个人社区&#xff0c;欢迎你的加…

阿里云服务器入门使用流程 新手学习教程

一、阿里云根据个人需要选合适的云服务器&#xff0c;选好cpu、内存、带宽&#xff0c;地域&#xff0c;这四个是主要的。其他可以默认选择。 二、登陆控制台 输入账号密码&#xff0c;进去看到服务界面&#xff0c;新手可能不容易看懂。点击左侧菜单&#xff0c;点击云服务器…

ASE12N65SE-ASEMI高压MOS管ASE12N65SE

编辑-Z ASE12N65SE在ITO-220AB封装里的静态漏极源导通电阻&#xff08;RDS(ON)&#xff09;为0.68Ω&#xff0c;是一款N沟道高压MOS管。ASE12N65SE的最大脉冲正向电流ISM为48A&#xff0c;零栅极电压漏极电流(IDSS)为10uA&#xff0c;其工作时耐温度范围为-55~150摄氏度。ASE…