flowable执行监听器动态指定审批人在退回时产生的bug

场景： 退回产生的bug，有一个结点，本身是通过执行监听器判断上一个结点的审批人来得到这个结点的审批人。之前是通过直接的获取最新task来拿到，但是在退回场景下，最新task为退回结点，故产生错误。

解决： 遍历原始bpmn模型找到正确的前驱结点，再从HistoricTask中拿到历史任务信息进行比对
首先：

//历史任务结点信息
List<HistoricTaskInstance> historicTaskInstanceList = historyService.createHistoricTaskInstanceQuery().processInstanceId(processInstance.getId()).list().stream().sorted(Comparator.comparing(HistoricTaskInstance::getCreateTime)).collect(Collectors.toList());
//这里按照时间排序得到正确的流程流转顺序

然后：

//在BpmnModel中找到当前任务结点的前驱节点集合
// 加载BPMN模型
BpmnModel bpmnModel = repositoryService.getBpmnModel(processDefinition.getId());
Map<String, FlowElement> flowElementMap = bpmnModel.getMainProcess().getFlowElementMap();//前驱结点集合
List<String> preNodeList = new ArrayList<>();
// 遍历FlowElementMapMap<String, SequenceFlow> sequenceFlowMap = new HashMap<>();
//找到当前结点的前去结点集合
for (Map.Entry<String, FlowElement> entry : flowElementMap.entrySet()) {FlowElement flowElement = entry.getValue();// 检查FlowElement是否是SequenceFlow的实例if (flowElement instanceof SequenceFlow) {// 如果是，就将其转换为SequenceFlow并添加到新的映射中SequenceFlow sequenceFlow = (SequenceFlow) flowElement;sequenceFlowMap.put(entry.getKey(), sequenceFlow);}
}//遍历sequenceFlowMap找前驱结点
for (Map.Entry<String, SequenceFlow> entry : sequenceFlowMap.entrySet()) {SequenceFlow sequenceFlow = entry.getValue();String targetRef = sequenceFlow.getTargetRef(); // 需要找到目标为当前结点的String sourceRef = sequenceFlow.getSourceRef(); // 保存指向当前结点的if (Objects.equals(targetRef, curTaskDefinitionKey)) {if (flowElementMap.get(sourceRef) instanceof ExclusiveGateway) {//是网关//去找指向该网关的 也就是deepTarget=sourceRef  不会出现网关指向网关//遍历for (Map.Entry<String, SequenceFlow> deepEntry : sequenceFlowMap.entrySet()) {SequenceFlow deepSequenceFlow = deepEntry.getValue();String deepTargetRef = deepSequenceFlow.getTargetRef(); //目标都是网关String deepSourceRef = deepSequenceFlow.getSourceRef(); //指向网关的源结点if (Objects.equals(sourceRef, deepTargetRef)) {if (targetRef.equals(deepSourceRef)) {continue; //循环部分不认为是前驱结点}preNodeList.add(deepSourceRef);}}} else {if (targetRef.equals(sourceRef)) {continue; //循环部分不认为是前驱结点}preNodeList.add(sourceRef);}}
}
for (int i = historicTaskInsListLen - 1; i >= 0; i--) {if (preNodeList.contains(historicTaskInstanceList.get(i).getTaskDefinitionKey())) {//找到第一个包含的//不是循环审批，找到上一个审批人设定为初始结点lastHistoricTaskInstance = historicTaskInstanceList.get(i);break;}
}

lastHistoricTaskInstance即为正确的前驱结点

给出我自己业务中的完整代码，有需要可按自己情况进行更改，核心代码如上

@Component
public class LastHandlerLeaderCycleTaskListener implements ExecutionListener {private final SysUserMapper userMapper = SpringUtil.getBean(SysUserMapper.class);private final SysDeptMapper sysDeptMapper = SpringUtil.getBean(SysDeptMapper.class);private final HistoryService historyService = SpringUtil.getBean(HistoryService.class);private final RepositoryService repositoryService = SpringUtil.getBean(RepositoryService.class);private final RuntimeService runtimeService = SpringUtil.getBean(RuntimeService.class);@Overridepublic void notify(DelegateExecution execution) {ProcessInstance processInstance = runtimeService.createProcessInstanceQuery().processInstanceId(execution.getProcessInstanceId()).singleResult();ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionId(execution.getProcessDefinitionId()).singleResult();//针对回退：//1.在BpmnModel中找到当前任务结点的前驱节点集合//2.从HistoricTaskInstance中从后向前找到第一个出现在前驱节点集合的元素//3.把该元素对饮的审批人设定为前一个节点的审批人，然后重新进入循环审批环节中//历史任务结点信息List<HistoricTaskInstance> historicTaskInstanceList = historyService.createHistoricTaskInstanceQuery().processInstanceId(processInstance.getId()).list().stream().sorted(Comparator.comparing(HistoricTaskInstance::getCreateTime)).collect(Collectors.toList());int historicTaskInsListLen = historicTaskInstanceList.size();//接下来要进入的结点信息String curTaskDefinitionKey = execution.getCurrentActivityId();Long lastDeptId = null; //上一次的部门idHistoricTaskInstance lastHistoricTaskInstance = null;
//        2. 如果上一个任务结点刚好为自身结点，那么进入循环审批，指定上一个结点审批人领导为自身领导if (Objects.equals(historicTaskInstanceList.get(historicTaskInsListLen - 1).getTaskDefinitionKey(), curTaskDefinitionKey)) {//是循环审批，指定上一个结点审批人为初始结点lastHistoricTaskInstance = historicTaskInstanceList.get(historicTaskInsListLen - 1);//获取上一次的部门信息lastDeptId = (Long) execution.getVariable(FlowableStoreInfosEnum.lastLeaderCycleDeptId.name());}
//        3. 如果上一个结点与不是自身结点，那么开始向前找第一个出现的前向结点，把他的信息认为是前向审批人else {//在BpmnModel中找到当前任务结点的前驱节点集合// 加载BPMN模型BpmnModel bpmnModel = repositoryService.getBpmnModel(processDefinition.getId());Map<String, FlowElement> flowElementMap = bpmnModel.getMainProcess().getFlowElementMap();//前驱结点集合List<String> preNodeList = new ArrayList<>();// 遍历FlowElementMapMap<String, SequenceFlow> sequenceFlowMap = new HashMap<>();//找到当前结点的前去结点集合for (Map.Entry<String, FlowElement> entry : flowElementMap.entrySet()) {FlowElement flowElement = entry.getValue();// 检查FlowElement是否是SequenceFlow的实例if (flowElement instanceof SequenceFlow) {// 如果是，就将其转换为SequenceFlow并添加到新的映射中SequenceFlow sequenceFlow = (SequenceFlow) flowElement;sequenceFlowMap.put(entry.getKey(), sequenceFlow);}}//遍历sequenceFlowMap找前驱结点for (Map.Entry<String, SequenceFlow> entry : sequenceFlowMap.entrySet()) {SequenceFlow sequenceFlow = entry.getValue();String targetRef = sequenceFlow.getTargetRef(); // 需要找到目标为当前结点的String sourceRef = sequenceFlow.getSourceRef(); // 保存指向当前结点的if (Objects.equals(targetRef, curTaskDefinitionKey)) {if (flowElementMap.get(sourceRef) instanceof ExclusiveGateway) {//是网关//去找指向该网关的 也就是deepTarget=sourceRef  不会出现网关指向网关//遍历for (Map.Entry<String, SequenceFlow> deepEntry : sequenceFlowMap.entrySet()) {SequenceFlow deepSequenceFlow = deepEntry.getValue();String deepTargetRef = deepSequenceFlow.getTargetRef(); //目标都是网关String deepSourceRef = deepSequenceFlow.getSourceRef(); //指向网关的源结点if (Objects.equals(sourceRef, deepTargetRef)) {if (targetRef.equals(deepSourceRef)) {continue; //循环部分不认为是前驱结点}preNodeList.add(deepSourceRef);}}} else {if (targetRef.equals(sourceRef)) {continue; //循环部分不认为是前驱结点}preNodeList.add(sourceRef);}}}for (int i = historicTaskInsListLen - 1; i >= 0; i--) {if (preNodeList.contains(historicTaskInstanceList.get(i).getTaskDefinitionKey())) {//找到第一个包含的//不是循环审批，找到上一个审批人设定为初始结点lastHistoricTaskInstance = historicTaskInstanceList.get(i);break;}}}//先找直属部门 再找直属部门对应leader 下一次来的话，需要找到上一次部门的父部门，也就是中途肯定需要某种方法保存当前次的部门idString lastAssignee = lastHistoricTaskInstance.getAssignee();SysUser leaderUser = null;if (lastDeptId == null) { //刚进入循环SysUser lastTaskUser = userMapper.selectUserById(Long.valueOf(lastAssignee)); //找自己lastDeptId = lastTaskUser.getDeptId();SysDept lastSysDept = sysDeptMapper.selectById(lastDeptId); //找上一次部门//找领导leaderUser = userMapper.selectUserByEmpCode(lastSysDept.getLeader()); //这次审批人是上传审批人的所在部门execution.setVariable(FlowableStoreInfosEnum.lastLeaderCycleDeptLevel.name(), lastSysDept.getDeptLevel()); //存储等级，以供流程跳出execution.setVariable(FlowableStoreInfosEnum.lastLeaderCycleDeptId.name(), lastSysDept.getDeptId()); //存储id，以供前端判断 这次对于下次来说就是上次} else {SysDept lastSysDept = sysDeptMapper.selectById(lastDeptId); //找上一次的部门SysDept nowSysDept = sysDeptMapper.selectById(lastSysDept.getParentId()); //找这次的部门leaderUser = userMapper.selectUserByEmpCode(nowSysDept.getLeader()); //这次审批人是上传审批人的所在部门execution.setVariable(FlowableStoreInfosEnum.lastLeaderCycleDeptLevel.name(), nowSysDept.getDeptLevel()); //存储等级，以供流程跳出execution.setVariable(FlowableStoreInfosEnum.lastLeaderCycleDeptId.name(), nowSysDept.getDeptId()); //存储id，以供前端判断 这次对于下次来说就是上次}String leaderIdStr = leaderUser == null ? lastAssignee : leaderUser.getUserId().toString();//存储审批人id到candidateUsers，框架自行使用该字段execution.setVariable("candidateUsers", leaderIdStr);}
}

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

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

相关文章

C++ 正则库与HTTP请求

C++ 正则库与HTTP请求

正则表达式的概念和语法 用于描述和匹配字符串的工具&#xff0c;通过特定的语法规则&#xff0c;灵活的定义复杂字符串匹配条件 常用语法总结 基本字符匹配 a&#xff1a;匹配字符aabc&#xff1a;匹配字符串abc 元字符&#xff08;特殊含义的字符&#xff09; .&#xff1a;匹…
阅读更多...
stable diffusion webui环境配置遇到的问题

stable diffusion webui环境配置遇到的问题

环境配置步骤&#xff1a; conda创建一个python3.10的环境&#xff0c;起个名叫sdenv, 使用命令conda create -n denv python3.10进入创建好的环境在webui的路径下直接运行python launch.py会自动开始安装所需的包&#xff08;可能需要梯子或者在系统配置中添加pip的国内源&am…
阅读更多...
1Panel面板配置java运行环境及网站的详细操作教程

1Panel面板配置java运行环境及网站的详细操作教程

本篇文章主要讲解&#xff0c;通过1Panel面板实现java运行环境&#xff0c;部署网站并加载的详细教程。 日期&#xff1a;2024年7月21日 作者&#xff1a;任聪聪 独立博客&#xff1a;https://rccblogs.com/501.html 一、实际效果 二、详细操作 步骤一、给我的项目进行打包&am…
阅读更多...
在jsPsych中使用Vue

在jsPsych中使用Vue

jspsych 介绍 jsPsych是一个非常好用的心理学实验插件&#xff0c;可以用来构建心理学实验。具体的就不多介绍了&#xff0c;大家可以去看官网&#xff1a;https://www.jspsych.org/latest/ 但是大家在使用时就会发现&#xff0c;这个插件只能使用js绘制界面&#xff0c;或者…
阅读更多...
陌陌聊天数据案例分析

陌陌聊天数据案例分析

目录 背景介绍和需求分析基于hive数仓实现需求开发根据聊天数据建库建表加载数据ETL数据清洗背景分析原始数据出现的问题ETL实现 需求指标统计思路需求开发 基于FineBI实现可视化报表配置流程构建可视化报表 总结 背景介绍和需求分析 陌陌是一个聊天平台&#xff0c;每天都会产…
阅读更多...
不能包含中文的正则表达式

不能包含中文的正则表达式

原文 1、不包含汉字[^\u4e00-\u9fa5] var r /^[^\u4e00-\u9fa5]$/ if(r.test(str)){} 2、只能包含汉字 [\u4e00-\u9fa5]
阅读更多...
STM32自己从零开始实操10：PCB全过程

STM32自己从零开始实操10：PCB全过程

一、PCB总体分布 分布主要参考有&#xff1a; 方便供电布线。方便布信号线。方便接口。人体工学。 以下只能让大家看到各个模块大致分布在板子的哪一块&#xff0c;只能说每个人画都有自己的理由&#xff0c;我的理由如下。 还有很多没有表达出来的东西&#xff0c;我也不知…
阅读更多...
二叉树---二叉搜索树中的众数

二叉树---二叉搜索树中的众数

题目&#xff1a; 给你一个含重复值的二叉搜索树&#xff08;BST&#xff09;的根节点 root &#xff0c;找出并返回 BST 中的所有 众数&#xff08;即&#xff0c;出现频率最高的元素&#xff09;。 如果树中有不止一个众数&#xff0c;可以按 任意顺序 返回。 假定 BST 满…
阅读更多...
PingCAP 王琦智：下一代 RAG，tidb.ai 使用知识图谱增强 RAG 能力

PingCAP 王琦智：下一代 RAG，tidb.ai 使用知识图谱增强 RAG 能力

导读 随着 ChatGPT 的流行&#xff0c;LLMs&#xff08;大语言模型&#xff09;再次进入人们的视野。然而&#xff0c;在处理特定领域查询时&#xff0c;大模型生成的内容往往存在信息滞后和准确性不足的问题。如何让 RAG 和向量搜索技术在实际应用中更好地满足企业需求&#…
阅读更多...
昇思25天学习打卡营第14天|计算机视觉

昇思25天学习打卡营第14天|计算机视觉

昇思25天学习打卡营第14天 文章目录 昇思25天学习打卡营第14天FCN图像语义分割语义分割模型简介网络特点数据处理数据预处理数据加载训练集可视化 网络构建网络流程 训练准备导入VGG-16部分预训练权重损失函数自定义评价指标 Metrics 模型训练模型评估模型推理总结引用 打卡记录…
阅读更多...
Electron 和 React 开发桌面应用程序

Electron 和 React 开发桌面应用程序

目录 书籍推荐 Electron React 在线资源和教程 官方文档 在线教程 综合学习路径 经典开发案例 Visual Studio Code Hyper Tusk Notable Beekeeper Studio 开源项目和示例代码 Electron React Boilerplate Electron Forge + React Electron React Template 学…
阅读更多...
FPGA开发在verilog中关于阻塞和非阻塞赋值的区别

FPGA开发在verilog中关于阻塞和非阻塞赋值的区别

一、概念 阻塞赋值&#xff1a;阻塞赋值的赋值号用“”表示&#xff0c;对应的是串行执行。 对应的电路结构往往与触发沿没有关系&#xff0c;只与输入电平的变化有关系。阻塞赋值的操作可以认为是只有一个步骤的操作&#xff0c;即计算赋值号右边的语句并更新赋值号左边的语句…
阅读更多...
Transformer-Bert---散装知识点---mlm，nsp

Transformer-Bert---散装知识点---mlm，nsp

本文记录的是笔者在了解了transformer结构后嗑bert中记录的一些散装知识点&#xff0c;有时间就会整理收录&#xff0c;希望最后能把transformer一个系列都完整的更新进去。 1.自监督学习 bert与原始的transformer不同&#xff0c;bert是使用大量无标签的数据进行预训…
阅读更多...
规范：前后端接口规范

规范：前后端接口规范

1、前言 随着互联网的高速发展&#xff0c;前端页面的展示、交互体验越来越灵活、炫丽&#xff0c;响应体验也要求越来越高&#xff0c;后端服务的高并发、高可用、高性能、高扩展等特性的要求也愈加苛刻&#xff0c;从而导致前后端研发各自专注于自己擅长的领域深耕细作。 然…
阅读更多...
volatile，最轻量的同步机制

volatile，最轻量的同步机制

目录 一、volatile 二、如何使用&#xff1f; 三、volatile关键字能代替synchronized关键字吗&#xff1f; 四、总结&#xff1a; 还是老样子&#xff0c;先来看一段代码&#xff1a; 我们先由我们自己的常规思路分析一下代码&#xff1a;子线程中&#xff0c;一直循环&…
阅读更多...
NoSQL之Redis非关系型数据库

NoSQL之Redis非关系型数据库

目录 一、数据库类型 1&#xff09;关系型数据库 2&#xff09;非关系型数据库 二、Redis远程字典服务器 1&#xff09;redis介绍 2&#xff09;redis的优点 3&#xff09;Redis 为什么那么快&#xff1f; 4&#xff09;Redis使用场景 三、Redis安装部署 1&#xff0…
阅读更多...
kail-linux如何使用NAT连接修改静态IP

kail-linux如何使用NAT连接修改静态IP

1、Contos修改静态IP vi /etc/sysconfig/network-scripts/ifcfg-ens33&#xff0c; 标记红色处可能序号会变动 参考linux配置网络不通解决方案_kylinv10sp2 网关不通-CSDN博客https://tanrt06.blog.csdn.net/article/details/132430485?spm1001.2014.3001.5502 Kail时候NAT连…
阅读更多...
从 NextJS SSRF 漏洞看 Host 头滥用所带来的危害

从 NextJS SSRF 漏洞看 Host 头滥用所带来的危害

前言 本篇博文主要内容是通过代码审计以及场景复现一个 NextJS 的安全漏洞&#xff08;CVE-2024-34351&#xff09;来讲述滥用 Host 头的危害。 严正声明&#xff1a;本博文所讨论的技术仅用于研究学习&#xff0c;旨在增强读者的信息安全意识&#xff0c;提高信息安全防护技能…
阅读更多...
NCRE2-3 网络服务器选型

NCRE2-3 网络服务器选型

记忆的部分比较多&#xff0c;会有错误 网络服务器的分类 了解 应用领域不同 Internet通用服务器数据库服务器文件服务器应用服务器 按网络应用规模 基础级服务器工作组级服务器部门级服务器企业级服务器 按网络服务器主机的硬件体系结构 基于CISC处理器的Inter机构(IA)的…
阅读更多...
浅谈断言之XML Schema断言

浅谈断言之XML Schema断言

浅谈断言之XML Schema断言 “XML Schema断言”是一种专门用于验证基于XML的响应是否遵循特定XML Schema定义的标准和结构的断言类型。下面我们将详细探讨XML Schema断言的各个方面。 XML Schema断言简介 XML Schema断言&#xff08;XML Schema Assertion&#xff09;允许用户…
阅读更多...
最新文章

Copyright @ 2022~2023