当前位置： 首页 > news >正文

flowable汇总查询方式

news 2025/8/17 6:54:31

背景：小程序开发申请流程。使用flowable流程框架。用户需要在后台统揽用户申请的汇总表。
设计思路：通过查询流程实例分页查询获取数据， 其中可以通过查询条件进行查询，查询条件是流程申请时添加到流程变量当中的，方便进行查询

具体内容。

  • 涉及到前端页面和后端代码，还有导出部分实现。
  • PC页面
    在这里插入图片描述
  • 后端代码：此部分为具体实现流程。
@Override
public TableDataInfo<WfTaskVo> selectPageInitiatorProcessList(ProcessQuery processQuery, PageQuery pageQuery) {Page<WfTaskVo> page = new Page<>();HistoricProcessInstanceQuery historicProcessInstanceQuery = historyService.createHistoricProcessInstanceQuery().orderByProcessInstanceStartTime().desc();// 使用buildProcessSearch拼接查询条件ProcessUtils.buildProcessSearch(historicProcessInstanceQuery, processQuery);int offset = pageQuery.getPageSize() * (pageQuery.getPageNum() - 1);List<HistoricProcessInstance> historicProcessInstances = historicProcessInstanceQuery.includeProcessVariables().listPage(offset, pageQuery.getPageSize());page.setTotal(historicProcessInstanceQuery.count());List<WfTaskVo> taskVoList = new ArrayList<>();for (HistoricProcessInstance hisIns : historicProcessInstances) {WfTaskVo taskVo = new WfTaskVo();taskVo.setProcInsId(hisIns.getId());taskVo.setProcDefId(hisIns.getProcessDefinitionId());taskVo.setProcDefName(hisIns.getProcessDefinitionName());taskVo.setCreateTime(hisIns.getStartTime());taskVo.setFinishTime(hisIns.getEndTime());// 计算耗时if (Objects.nonNull(hisIns.getEndTime())) {taskVo.setDuration(DateUtils.getDatePoor(hisIns.getEndTime(), hisIns.getStartTime()));} else {taskVo.setDuration(DateUtils.getDatePoor(DateUtils.getNowDate(), hisIns.getStartTime()));}// 获取发起人信息Long userId = Long.parseLong(hisIns.getStartUserId());String nickName = userService.selectNickNameById(userId);taskVo.setStartUserId(userId);taskVo.setStartUserName(nickName);Object name = hisIns.getProcessVariables().get("name");if (name != null) {taskVo.setName(name.toString());}Object projectId = hisIns.getProcessVariables().get(BusiConstants.PROJECT_ID);if (projectId != null) {taskVo.setProjectId(projectId.toString());}taskVoList.add(taskVo);}page.setRecords(taskVoList);return TableDataInfo.build(page);
}
  • 此部分为添加的查询条件处理。ProcessUtils.buildProcessSearch(historicProcessInstanceQuery, processQuery);对入参进行处理
public static void buildProcessSearch(Query<?, ?> query, ProcessQuery process) {if (query instanceof ProcessDefinitionQuery) {buildProcessDefinitionSearch((ProcessDefinitionQuery) query, process);} else if (query instanceof TaskQuery) {buildTaskSearch((TaskQuery) query, process);} else if (query instanceof HistoricTaskInstanceQuery) {buildHistoricTaskInstanceSearch((HistoricTaskInstanceQuery) query, process);} else if (query instanceof HistoricProcessInstanceQuery) {buildHistoricProcessInstanceSearch((HistoricProcessInstanceQuery) query, process);}
}
...
public static void buildHistoricProcessInstanceSearch(HistoricProcessInstanceQuery query, ProcessQuery process) {Map<String, Object> params = process.getParams();// 流程标识if (StringUtils.isNotBlank(process.getProcessKey())) {query.processDefinitionKey(process.getProcessKey());}// 流程名称if (StringUtils.isNotBlank(process.getProcessName())) {query.processDefinitionName(process.getProcessName());}// 流程名称if (StringUtils.isNotBlank(process.getCategory())) {query.processDefinitionCategory(process.getCategory());}if (params.get("beginTime") != null && params.get("endTime") != null) {query.startedAfter(DateUtils.parseDate(params.get("beginTime")));query.startedBefore(DateUtils.parseDate(params.get("endTime")));}// 判断项目idif (ObjectUtil.isNotEmpty(params.get("projectId"))) {query.variableValueEquals("projectId", params.get("projectId"));}// 判断病种idif (ObjectUtil.isNotEmpty(params.get("diseaseInfoId"))) {query.variableValueEquals("diseaseInfoId", params.get("diseaseInfoId"));}// 模糊查询姓名if (ObjectUtil.isNotEmpty(params.get("name"))) {query.variableValueLike("name", "%" + params.get("name").toString() + "%");}// 查询省份if (ObjectUtil.isNotEmpty(params.get("provinceCode"))) {query.variableValueEquals("provinceCode", params.get("provinceCode"));}// 流程状态（已完成未完成）if (ObjectUtil.isNotEmpty(params.get("status"))) {if ("1".equals(params.get("status"))) {query.finished();}else {query.unfinished();}}
}

导出方案及实现

  • 核心内容： 大模型给的方案中，我使用了分批导出。相比于延长超时时间、分页导出等更合理。是使用前端进行导出的方式，只获取后端接口数据。
 /** 导出按钮操作 */async handleExport() {try {// 显示进度对话框this.exportProgress.visible = true;this.exportProgress.percentage = 0;this.exportProgress.currentBatch = 0;this.exportProgress.totalBatches = 0;this.exportProgress.currentCount = 0;this.exportProgress.totalCount = 0;const batchSize = 1000; // 每批1000条数据let allData = [];let currentPage = 1;let hasMore = true;// 构建基础查询参数const baseParams = {name: this.queryParams.name,projectId: this.queryParams.projectId,startUserName: this.queryParams.startUserName,status: this.queryParams.status};// 添加日期范围参数if (this.dateRange && this.dateRange.length === 2) {baseParams.beginTime = this.dateRange[0];baseParams.endTime = this.dateRange[1];} else {// 如果没有选择时间范围，设置默认值（最近30天）const endDate = new Date();const startDate = new Date();startDate.setDate(startDate.getDate() - 30);baseParams.beginTime = startDate.toISOString().slice(0, 19).replace('T', ' ');baseParams.endTime = endDate.toISOString().slice(0, 19).replace('T', ' ');}// 先获取总数，用于计算进度const countResponse = await fetchInitiatorList({pageNum: 1,pageSize: 1,params: baseParams});if (countResponse.code === 200) {this.exportProgress.totalCount = countResponse.total || 0;this.exportProgress.totalBatches = Math.ceil(this.exportProgress.totalCount / batchSize);}// 分批获取数据while (hasMore) {const batchParams = {pageNum: currentPage,pageSize: batchSize,params: baseParams};// 更新进度信息this.exportProgress.currentBatch = currentPage;this.exportProgress.currentCount = allData.length;this.exportProgress.percentage = Math.round((allData.length / this.exportProgress.totalCount) * 100);const response = await fetchInitiatorList(batchParams);if (response.code === 200 && response.rows && response.rows.length > 0) {allData = allData.concat(response.rows);currentPage++;// 检查是否还有更多数据hasMore = response.rows.length === batchSize;// 添加小延迟，避免请求过于频繁await new Promise((resolve) => setTimeout(resolve, 100));} else {hasMore = false;}}if (allData.length > 0) {// 更新最终进度this.exportProgress.currentCount = allData.length;this.exportProgress.percentage = 100;// 显示最终进度this.$message.info(`数据获取完成，共 ${allData.length} 条，正在生成Excel文件...`);// 格式化数据为Excel格式const excelData = this.formatDataForExcel(allData);// 生成Excel文件this.generateAndDownloadExcel(excelData);this.$message.success(`导出成功，共导出 ${allData.length} 条数据`);} else {this.$message.warning('没有数据可导出');}// 关闭进度对话框setTimeout(() => {this.exportProgress.visible = false;}, 2000);} catch (error) {console.error('导出失败:', error);// 关闭进度对话框this.exportProgress.visible = false;if (error.message && error.message.includes('timeout')) {this.$message.error('导出超时，请尝试缩小查询范围或联系管理员');} else {this.$message.error('导出失败，请重试');}}},
http://www.lryc.cn/news/622741.html

相关文章：

  • SAP-FI配置与业务解析之内部交易核算
  • 双向SSL认证之Apache实战配置
  • 3 种方式玩转网络继电器！W55MH32 实现网页 + 阿里云 + 本地控制互通
  • 数据清洗与机器学习贷款偿还预测建模
  • （职业分析）讨好型人格适合什么职业？
  • 【LLM微调】
  • 每日算法刷题Day62:8.16:leetcode 堆8道题，用时2h30min
  • java项目中什么时候使用static、final
  • Docker数据卷挂载和本地目录挂载
  • 暴雨服务器：以定制化满足算力需求多样化
  • dify 调用本地的 stable diffusion api生成图片的工作流搭建
  • 掌握长尾关键词优化SEO技巧
  • 神经网络 常见分类
  • 分布式存储与存储阵列：从传统到现代的存储革命
  • 本地部署前端构建工具 Vite 并实现外部访问
  • 模式组合应用-桥接模式(一)
  • 容器化部署：用Docker封装机器翻译模型与服务详解
  • 她的热情为何突然冷却？—— 解析 Kafka 吞吐量下降之谜
  • 数据结构：满二叉树 (Full Binary Tree) 和 完全二叉树 (Complete Binary Tree)
  • 无痕HOOK 检测及对抗
  • 数据结构：构建 (create) 一个二叉树
  • OpenJDK 17的C1和C2编译器实现中，方法返回前插入安全点（Safepoint Poll）的机制
  • 【lubancat】鲁班猫4实现开机后自动播放视频
  • 攻击者如何毒害人工智能工具和防御系统
  • 罗技MX Anywhere 2S鼠标修复记录
  • 【攻防实战】红队攻防之Goby反杀
  • 云原生俱乐部-RH124知识点总结（1）
  • PHP反序列化的CTF题目环境和做题复现第2集_POP链构造
  • 布隆过滤器的原理及使用
  • 基于STM32的智能书房系统设计与实现