java/BatteryDetection.git

			@@ -3,28 +3,97 @@
			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
			{
			/** 返回指定检测柜通道最近一次实时观测；没有成功观测时返回空值。 */
			CabinetRealtime latestCabinet(ChannelIdentity channel);

			CollectorRealtime latestCollector(long collectorId);
			/**
			* 返回采集器独立实时快照；不得通过历史下载补采。
			* 采集器测量按"同一来源的辅助测量"表达（ADR-0064），所以必须指名是哪个来源实例，
			* 否则多实例下无法确定该向哪台机器请求。
			*/
			CollectorRealtime latestCollector(String adapterCode, String collectorCode);

			/**
			* 返回该通道的工步统计。来源有工步层时读设备工步层并原样交出；来源没有工步层时由适配器
			* 从采样段推导（ADR-0067）。两种形态的记录里 {@code stepName} 都是方向名称
			* （{@link com.battery.device.api.StepDirectionResolver.Direction#displayName()}）：来源给出工步类型时按该类型解释，
			* 来源没有类型列时按已核对的列语义判定；判定不出方向时留空，不写默认名。
			* 未结束的段不交出，也不推导来源根本没有的工步层。
			*/
			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); }
			}
			@@ -32,10 +101,51 @@
			record CollectorMeasurement(String channelCode, long sequenceId, Instant deviceTime, String deviceTimeRaw,
			Instant serverReceivedAt, String metricCode, BigDecimal value, String unit) { }

			/**
			* 一条设备工步层记录。来源给出工步类型时 {@code stepType} 原样保留（新威为数字枚举），
			* 适配器不按电流符号改写它。
			*
			* <p>{@code stepName} 是方向名称（`充电` / `放电` / `搁置`，ADR-0067 §4b）：来源给出工步类型时
			* 按该类型解释（新威的 {@code 1}/{@code 2}/{@code 4}），来源没有类型列时（推式来源的厂商库里既没有
			* 工步层也没有循环汇总表，ADR-0067）按已核对列语义判定。方向判不出来时留空——不是设备给的名称，
			* 界面据此标注来源，调用方不得用默认名把未知说成已知。
			*
			* <p>来源没有工步层时，除方向名称外该工步的其余一切仍是设备采样行上的原文事实。
			*
			* <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;
			}
			}
			}