From 691f882740b46c5354fb33404fef6efb370e05dc Mon Sep 17 00:00:00 2001
From: yeg <1347747024@qq.com>
Date: 星期五, 09 十月 2026 15:52:05 +0800
Subject: [PATCH] 实时行也带上判定出的方向，实时页的工步名称才有值
---
battery-device-api/src/main/java/com/battery/device/api/TestDataObservationAdapter.java | 120 +++++++++++++++++++++++++++++++++++++++++++++++++++++++-----
1 files changed, 110 insertions(+), 10 deletions(-)
diff --git a/battery-device-api/src/main/java/com/battery/device/api/TestDataObservationAdapter.java b/battery-device-api/src/main/java/com/battery/device/api/TestDataObservationAdapter.java
index cee3010..22b3918 100644
--- a/battery-device-api/src/main/java/com/battery/device/api/TestDataObservationAdapter.java
+++ b/battery-device-api/src/main/java/com/battery/device/api/TestDataObservationAdapter.java
@@ -3,8 +3,8 @@
import java.math.BigDecimal;
import java.time.Instant;
import java.util.List;
-import com.battery.device.model.ChannelIdentity;
-import com.battery.device.model.Measurement;
+import com.battery.device.api.model.ChannelIdentity;
+import com.battery.device.api.model.Measurement;
/** 供业务持久化使用的厂商无关测试数据观测扩展。 */
public interface TestDataObservationAdapter extends DeviceObservationAdapter
@@ -12,24 +12,86 @@
/** 返回指定检测柜通道最近一次实时观测；没有成功观测时返回空值。 */
CabinetRealtime latestCabinet(ChannelIdentity channel);
- /** 返回采集器独立实时快照；不得通过历史下载补采。 */
- CollectorRealtime latestCollector(long collectorId);
+ /**
+ * 返回采集器独立实时快照；不得通过历史下载补采。
+ * 采集器测量按"同一来源的辅助测量"表达（ADR-0064），所以必须指名是哪个来源实例，
+ * 否则多实例下无法确定该向哪台机器请求。
+ */
+ CollectorRealtime latestCollector(String adapterCode, String collectorCode);
- /** 返回设备直接提供的工步统计，不从实时采样推导。 */
+ /**
+ * 返回该通道的工步统计。来源有工步层时读设备工步层并原样交出；来源没有工步层时由适配器
+ * 从采样段推导（ADR-0067），此时记录里的方向是推导出的方向名称（见 {@link StepRecord}）。
+ * 未结束的段不交出，也不推导来源根本没有的工步层。
+ */
List<StepRecord> stepRecords(ChannelIdentity channel);
- /** 返回设备直接提供的循环统计，不补齐设备未返回的记录。 */
+ /**
+ * 返回该来源的循环统计。设备直接提供循环汇总行时原样返回；设备只有工步层时由适配器按循环聚合，
+ * 并用 {@link CycleRecord#sourceKind()} 标注为聚合来源，使调用方与界面能区分推导值与设备事实。
+ * 不补齐来源未提供的循环，也不跨循环借值。
+ */
List<CycleRecord> cycleRecords(ChannelIdentity channel);
/** 返回适配器定义的实时持久化槽位间隔。 */
long persistenceIntervalMillis(ChannelIdentity channel);
+ /**
+ * 返回工步与循环这些汇总记录的读取间隔。默认与实时持久化间隔一致；来源的汇总产出节奏与
+ * 数据行节奏不同的实现覆盖它——推式来源的落地表在本地（实时行按展示节奏取），
+ * 而汇总最快也要等来源写下下一行才可能变化，按展示节奏重算只是空跑。
+ */
+ default long aggregateIntervalMillis(ChannelIdentity channel) { return persistenceIntervalMillis(channel); }
+
+ /** 返回设备计划方案；设备未提供时保持为空，不推导计划。 */
+ default TestPlan testPlan(ChannelIdentity channel) { return null; }
+
+ /**
+ * 读取通道当前的接收水位。水位是来源里已存在的最新一行（设备绝对时间 + 协议序号），
+ * 用于把"开始接收"和"继续接收"切在这一时刻之后：水位之前的数据行即使仍在来源里也不进本测试。
+ *
+ * <p>返回空值表示该来源不按设备数据行接收（例如由系统轮询产生槽位的来源），此时不启用逐行接收。
+ * 设备时间为空的水位表示这一刻来源里没有任何可用行，之后出现的行全部属于本次接收。
+ * 来源不可达时必须抛出异常，不能返回空值——空值会被误当作"来源不按行接收"。
+ */
+ default SampleWatermark currentWatermark(ChannelIdentity channel) { return null; }
+
+ /**
+ * 返回严格晚于水位的设备数据行，按设备时间与协议序号升序。
+ * 同一绝对秒内的多行各自成立，调用方不得按秒合并。
+ * 水位为空表示调用方尚未取得水位，此时返回空列表：不把来源里的设备历史并入本次接收。
+ */
+ default List<CabinetRealtime> samplesSince(ChannelIdentity channel, SampleWatermark watermark) { return List.of(); }
+
+ /** 接收水位：设备绝对时间与协议序号的二元组；序号在同一厂商测试内有效。 */
+ record SampleWatermark(Instant deviceTime, long sequenceId) { }
+
+ record TestPlan(int currentCycleNo, int currentStepNo, int plannedCycleCount, List<PlanRow> rows) { }
+ record PlanRow(String rowType, int stepNo, Integer cyclePosition, String stepName, double durationSeconds,
+ Double voltageV, String executionStatus, Integer cycleCount, Long recordCount) { }
+
+ /**
+ * 柜端成功观测；相对时长使用设备提供的秒数，缺失不按采样时间推算。
+ * {@code sourceRecordId} 是来源行的稳定身份（如厂商测试编号加协议序号），
+ * 供幂等与冲突判定使用；来源不提供时保持为空，调用方退化为按协议序号识别。
+ */
record CabinetRealtime(long sequenceId, Instant deviceTime, double currentA, double voltageV,
double capacityAh, double energyWh, int cycleNo, int stepNo, String stepName, String stepType,
- Instant serverReceivedAt) { }
+ Instant serverReceivedAt, String deviceTimeRaw, String timezoneId, Long relativeTimeSeconds,
+ String sourceRecordId)
+ {
+ /** 兼容不携带来源行身份的既有适配器。 */
+ public CabinetRealtime(long sequenceId, Instant deviceTime, double currentA, double voltageV,
+ double capacityAh, double energyWh, int cycleNo, int stepNo, String stepName, String stepType,
+ Instant serverReceivedAt, String deviceTimeRaw, String timezoneId, Long relativeTimeSeconds)
+ {
+ this(sequenceId, deviceTime, currentA, voltageV, capacityAh, energyWh, cycleNo, stepNo, stepName,
+ stepType, serverReceivedAt, deviceTimeRaw, timezoneId, relativeTimeSeconds, null);
+ }
+ }
record CollectorRealtime(String collectorCode, boolean online, int sampleIntervalMs,
- List<CollectorMeasurement> measurements)
+ List<CollectorMeasurement> measurements, String timezoneId)
{
public CollectorRealtime { measurements = measurements == null ? List.of() : List.copyOf(measurements); }
}
@@ -37,10 +99,48 @@
record CollectorMeasurement(String channelCode, long sequenceId, Instant deviceTime, String deviceTimeRaw,
Instant serverReceivedAt, String metricCode, BigDecimal value, String unit) { }
+ /**
+ * 一条设备工步层记录。来源给出工步类型时 {@code stepType} 原样保留（新威为数字枚举），
+ * 方向由调用方按该类型解释，适配器不按电流符号改写它。
+ *
+ * <p>来源**没有**工步类型列时（推式来源的厂商库里既没有工步层也没有循环汇总表，ADR-0067），
+ * 适配器交出的是按已核对列语义判定出的方向名称（{@code charge} / {@code discharge} / {@code rest}），
+ * 判定不出来时留空；此时该工步的其余一切仍是设备采样行上的原文事实。
+ *
+ * <p>{@code endVoltageV} 与 {@code endCurrentA} 是该工步结束时的设备读数。
+ * {@code capacityAh} 与 {@code energyWh} 是该工步自身累计的单项值，只在方向已确认时给出；
+ * 方向未知时保持为空，四个方向的容量能量仍在 {@code measurements} 中作为设备事实保留。
+ */
record StepRecord(String sourceRecordId, int cycleNo, int stepNo, String stepName, String stepType,
- Instant startedAt, Instant endedAt, double endVoltageV, double capacityAh, double energyWh) { }
+ Instant startedAt, Instant endedAt, double endVoltageV, double endCurrentA, Double capacityAh,
+ Double energyWh, String deviceTimeRaw, String timezoneId, Instant serverReceivedAt,
+ java.util.Map<String, BigDecimal> measurements) { }
+ /**
+ * 一条循环统计。{@code sourceRecordId} 是来源行的稳定身份，供幂等与冲突判定使用。
+ *
+ * <p>设备没有循环汇总行时，循环统计由工步层按循环聚合得出；{@code sourceKind} 记录这个来源事实，
+ * 使界面与导出能明确标注"这个数是聚合的还是设备给的"，取值只能是下面三个常量之一。
+ *
+ * <p>{@code efficiency} 为单位为百分比的充放电效率。该循环没有可用的充电容量时保持为空：
+ * 未知比率不用零代替，零值只表示设备确实给出零。
+ */
record CycleRecord(String sourceRecordId, int cycleNo, Instant startedAt, Instant endedAt,
double chargeCapacityAh, double dischargeCapacityAh, double chargeEnergyWh,
- double dischargeEnergyWh, double efficiency) { }
+ double dischargeEnergyWh, Double efficiency, String deviceTimeRaw, String timezoneId,
+ Instant serverReceivedAt, String sourceKind)
+ {
+ /** 来源类别：设备直接提供。 */
+ public static final String SOURCE_DEVICE = "DEVICE";
+ /** 来源类别：来源没有循环汇总行，由工步层按循环聚合得出。 */
+ public static final String SOURCE_AGGREGATED = "AGGREGATED";
+ /** 来源类别：授权文件导入。 */
+ public static final String SOURCE_IMPORTED = "IMPORTED";
+
+ public CycleRecord
+ {
+ // 未标注一律按设备事实：引入聚合之前写进库的循环记录都来自设备或文件。
+ sourceKind = sourceKind == null || sourceKind.isBlank() ? SOURCE_DEVICE : sourceKind;
+ }
+ }
}
--
Gitblit v1.7.1