From 0fcd0642efdff8d4e0584fa991aaea2178bc932b Mon Sep 17 00:00:00 2001
From: yeg <1347747024@qq.com>
Date: 星期二, 01 九月 2026 22:48:35 +0800
Subject: [PATCH] 测试控制台持续更新

---
 ruoyi-system/src/main/java/com/ruoyi/system/mapper/TTestMapper.java |   10 +++++++++-
 1 files changed, 9 insertions(+), 1 deletions(-)

diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/mapper/TTestMapper.java b/ruoyi-system/src/main/java/com/ruoyi/system/mapper/TTestMapper.java
index c000e5c..25139a7 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/mapper/TTestMapper.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/mapper/TTestMapper.java
@@ -58,6 +58,11 @@
     List<TTestWarningThreshold> selectTestThresholds(Long testId);
     /** 按来源和起始边界顺序返回测试接收区间。 */
     List<TTestReceptionInterval> selectTestReceptionIntervals(Long testId);
+    /** 查询当前正在接收的测试,供接收调度绑定测试事实。 */
+    List<Long> selectReceivingTestIds();
+    List<java.util.Map<String, Object>> selectPersistedRecords(@org.apache.ibatis.annotations.Param("testId") Long testId);
+    List<java.util.Map<String, Object>> selectPersistedSteps(@org.apache.ibatis.annotations.Param("testId") Long testId);
+    List<java.util.Map<String, Object>> selectPersistedCycles(@org.apache.ibatis.annotations.Param("testId") Long testId);
     List<TTestResult> selectTestResults(TTestResult result);
     String selectLogicStepMappingsJson(Long testId);
     int updateLogicStepMappings(@Param("testId") Long testId, @Param("mappingsJson") String mappingsJson,
@@ -139,12 +144,15 @@
     int updateTestNaturallyEnded(@Param("testId") Long testId, @Param("endedAtUtc") Date endedAtUtc);
     String selectSampleContentHash(@Param("channelId") Long channelId, @Param("btsTestId") String btsTestId,
             @Param("sequenceId") Long sequenceId);
+    /** 按测试事实查询通道序号,避免补采重复写入已即时接收的采样。 */
+    String selectTestSampleContentHash(@Param("testId") Long testId, @Param("channelId") Long channelId,
+            @Param("sequenceId") Long sequenceId);
     int insertBtsSample(@Param("testId") Long testId, @Param("bindingId") Long bindingId,
             @Param("channelId") Long channelId, @Param("intervalId") Long intervalId,
             @Param("btsTestId") String btsTestId, @Param("sequenceId") Long sequenceId,
             @Param("deviceTimeUtc") Date deviceTimeUtc, @Param("deviceTimeRaw") String deviceTimeRaw,
             @Param("receivedAtUtc") Date receivedAtUtc, @Param("cycleNo") Integer cycleNo,
-            @Param("stepNo") Integer stepNo, @Param("stepType") String stepType,
+            @Param("stepNo") Integer stepNo, @Param("stepType") String stepType, @Param("stepName") String stepName,
             @Param("testTimeMs") Long testTimeMs, @Param("voltageV") java.math.BigDecimal voltageV,
             @Param("currentA") java.math.BigDecimal currentA, @Param("capacityAh") java.math.BigDecimal capacityAh,
             @Param("energyWh") java.math.BigDecimal energyWh, @Param("contentSha256") byte[] contentSha256);

--
Gitblit v1.7.1