From 3a8c49426eb95f50bc3223098e9c4a1ddea90b06 Mon Sep 17 00:00:00 2001
From: yeg <1347747024@qq.com>
Date: 星期六, 05 九月 2026 11:54:27 +0800
Subject: [PATCH] 整理控制台接口验收后的业务注释
---
ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TTestLiveServiceImpl.java | 1 +
ruoyi-system/src/main/java/com/ruoyi/system/service/ITestLiveService.java | 3 ++-
ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TestDataQueryServiceImpl.java | 2 +-
3 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/service/ITestLiveService.java b/ruoyi-system/src/main/java/com/ruoyi/system/service/ITestLiveService.java
index d39ebc9..65a51d2 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/service/ITestLiveService.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/service/ITestLiveService.java
@@ -5,7 +5,7 @@
import java.util.Map;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
-/** 提供测试控制台的双状态实时事实与鉴权 SSE。 */
+/** 分别提供测试、接收及设备实时事实与鉴权 SSE。 */
public interface ITestLiveService
{
/** 返回指定测试及其绑定来源的最新设备、接收和测试状态。 */
@@ -13,6 +13,7 @@
/** 打开实时 SSE；连接初次发送当前事实，后续只推送最新快照。 */
SseEmitter stream(Long testId);
+ /** 当前观测快照；updatedAt 为毫秒时间戳，不代表历史数据已完整接收。 */
record LiveState(Long testId, String testStatus, String receptionStatus, long updatedAt,
List<LiveSource> sources, List<Map<String, Object>> exceptions, TestPlanSnapshot testPlan)
{
diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TTestLiveServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TTestLiveServiceImpl.java
index 34cf5e1..284bdda 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TTestLiveServiceImpl.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TTestLiveServiceImpl.java
@@ -214,6 +214,7 @@
{
Map<String, Object> value = new LinkedHashMap<>();
value.put("source", "采集器"); value.put("sampleIntervalMs", collector.sampleIntervalMs());
+ // 在业务响应边界转换毫秒时间，设备时间与服务器接收时间分别保留。
value.put("measurements", collector.latestMeasurements().stream().map(item -> {
Map<String, Object> measurement = new LinkedHashMap<>();
measurement.put("metricCode", item.metricCode());
diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TestDataQueryServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TestDataQueryServiceImpl.java
index 7cb8cd8..1c17e7a 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TestDataQueryServiceImpl.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TestDataQueryServiceImpl.java
@@ -87,7 +87,7 @@
return rows;
}
- /** 将最新人工覆盖应用到设备事实，删除只影响当前有效视图，不抹除原始采样。 */
+ /** 合并既有导入记录和人工修订供当前有效数据查询；不在此处执行物理删除。 */
private List<Map<String, Object>> applyEffectiveData(Long testId, String dataType,
List<Map<String, Object>> source)
{
--
Gitblit v1.7.1