From 02177e65c3443c8714301e4a3d891d7d12cde633 Mon Sep 17 00:00:00 2001
From: yeg <1347747024@qq.com>
Date: 星期三, 09 九月 2026 12:03:44 +0800
Subject: [PATCH] 裁剪修订详情的大字段查询并直接返回记录数量
---
ruoyi-admin/src/test/java/com/battery/business/web/ConsoleSingleSheetImportDatabaseTest.java | 42 +++++++++++++++++++++++++++++++++++++++++-
1 files changed, 41 insertions(+), 1 deletions(-)
diff --git a/ruoyi-admin/src/test/java/com/battery/business/web/ConsoleSingleSheetImportDatabaseTest.java b/ruoyi-admin/src/test/java/com/battery/business/web/ConsoleSingleSheetImportDatabaseTest.java
index fd609aa..bc52da0 100644
--- a/ruoyi-admin/src/test/java/com/battery/business/web/ConsoleSingleSheetImportDatabaseTest.java
+++ b/ruoyi-admin/src/test/java/com/battery/business/web/ConsoleSingleSheetImportDatabaseTest.java
@@ -25,7 +25,7 @@
import org.springframework.test.util.ReflectionTestUtils;
/** 使用生产 Mapper 和 Spring 事务验证导入；内存数据库不连接共享开发库。 */
-class ConsoleSingleSheetImportDatabaseTest
+public class ConsoleSingleSheetImportDatabaseTest
{
private java.sql.Connection keepAlive;
private TTestController controller;
@@ -38,6 +38,8 @@
var source = new UnpooledDataSource("org.h2.Driver", "jdbc:h2:mem:" + UUID.randomUUID() + ";MODE=MySQL;DATABASE_TO_LOWER=TRUE", "sa", "");
keepAlive = source.getConnection();
jdbc = new JdbcTemplate(source);
+ // H2 无 MySQL JSON_LENGTH；仅在测试中适配计数，真实 SQL 另在 MySQL 验证。
+ jdbc.execute("create alias JSON_LENGTH for 'com.battery.business.web.ConsoleSingleSheetImportDatabaseTest.jsonLength'");
jdbc.execute("create table sys_user(user_id bigint, nick_name varchar(64), del_flag varchar(1))");
jdbc.execute("create table t_test_type(test_type_id bigint, test_type_name varchar(64), del_flag int)");
jdbc.execute("create table t_test(test_id bigint primary key, test_name varchar(100), creator_id bigint, principal_id bigint, test_type_id bigint, test_purpose varchar(100), test_status varchar(20), reception_status varchar(20), monitor_timeout_minutes int, started_at_utc timestamp, reception_boundary_at_utc timestamp, ended_at_utc timestamp, del_flag int default 0, create_by varchar(64), create_time timestamp, update_by varchar(64), update_time timestamp, remark varchar(100), logic_step_mappings_json varchar(100), console_detail_json varchar(100))");
@@ -79,6 +81,15 @@
@AfterEach void closeDatabase() throws Exception { if (keepAlive != null) keepAlive.close(); }
+ /** 模拟 JSON 数组长度；H2 的 JSON 参数可能多包一层字符串。 */
+ public static Integer jsonLength(String value)
+ {
+ if (value == null) return null;
+ Object parsed = JSON.parse(value);
+ if (parsed instanceof String text) parsed = JSON.parse(text);
+ return parsed instanceof List<?> rows ? rows.size() : 1;
+ }
+
@Test void threeTypesPersistActualBindingsTimesAndNumbersAndSkipRetries()
{
for (String type : List.of("REALTIME", "STEP", "CYCLE"))
@@ -106,6 +117,35 @@
assertTrue(service.selectActions(new TTestDataRevisionAction()).isEmpty());
}
+ @Test void importAndDeleteDetailsReturnOnlySummaryWhileAuditRemainsStored() throws Exception
+ {
+ for (String operation : List.of("IMPORT", "DELETE"))
+ {
+ var action = new TTestDataRevisionAction();
+ action.setTestId(1L); action.setDataType("REALTIME"); action.setOperationType(operation);
+ action.setScopeSummary("批量8000条"); action.setReason("摘要查询验证");
+ action.setIdentitySummary(JSON.toJSONString(java.util.stream.IntStream.range(0, 8000).mapToObj(i -> "realtime:" + i).toList()));
+ action.setChangesSummary(JSON.toJSONString(java.util.Collections.nCopies(8000, Map.of("voltage", 1.5))));
+ action.setBeforeContentJson(action.getChangesSummary());
+ mapper.insertDataRevisionAction(action);
+ var summary = service.selectActionById(action.getActionId());
+ assertNull(summary.getIdentitySummary(), "详情查询不得将批量身份 JSON 加载到服务层");
+ assertNull(summary.getChangesSummary(), "详情查询不得将批量变化 JSON 加载到服务层");
+ assertNull(summary.getBeforeContentJson(), "详情查询不得加载完整审计快照");
+ var details = new TTestDataRevisionController();
+ ReflectionTestUtils.setField(details, "service", service);
+ var json = new com.fasterxml.jackson.databind.ObjectMapper();
+ String response = json.writeValueAsString(details.detail(action.getActionId()));
+ assertEquals(8000, json.readTree(response).get("data").get("affectedRecordCount").intValue());
+ assertTrue(response.length() < 1500, "摘要响应不能随批量明细膨胀");
+ // 展示裁剪只发生在 SELECT；数据库审计原文仍完整保留。
+ assertTrue(jdbc.queryForObject("select length(cast(changes_summary as varchar)) from t_test_data_revision_action where action_id=?", Integer.class, action.getActionId()) > 100000);
+ }
+ var list = service.selectActions(new TTestDataRevisionAction());
+ assertEquals(2, list.size());
+ assertTrue(list.stream().allMatch(row -> row.getIdentitySummary() == null && row.getChangesSummary() == null && row.getBeforeContentJson() == null));
+ }
+
@Test void stepMedianVoltagesPersistAndRemainIndependentOfLegacyPeaks()
{
var imported = row();
--
Gitblit v1.7.1