From 99935242ecccd94e76978e2b71cbc46b87d31dc6 Mon Sep 17 00:00:00 2001
From: yeg <1347747024@qq.com>
Date: 星期五, 09 十月 2026 11:17:44 +0800
Subject: [PATCH] 推式来源的工步与循环改为从采样段推导
---
battery-business/src/main/java/com/battery/business/mapper/TDeviceIngestRecordMapper.java | 10 ++++++++++
1 files changed, 10 insertions(+), 0 deletions(-)
diff --git a/battery-business/src/main/java/com/battery/business/mapper/TDeviceIngestRecordMapper.java b/battery-business/src/main/java/com/battery/business/mapper/TDeviceIngestRecordMapper.java
index c4c6745..5e251f0 100644
--- a/battery-business/src/main/java/com/battery/business/mapper/TDeviceIngestRecordMapper.java
+++ b/battery-business/src/main/java/com/battery/business/mapper/TDeviceIngestRecordMapper.java
@@ -41,6 +41,16 @@
@Param("devtype") int devtype, @Param("devid") int devid, @Param("subdevid") int subdevid,
@Param("chlid") int chlid);
+ /**
+ * 某个来源库（厂商侧一次测试）在该通道上的全部采样行，按 (设备时间, 协议序号) 升序。
+ *
+ * <p>推式来源没有设备侧工步层，工步与循环由这些采样行按「来源库 + 循环号 + 工步号」分段推导
+ * （ADR-0067）；读取范围限于一个来源库，也就是一次厂商测试，不随落地表无限增长。
+ */
+ List<TDeviceIngestRecord> selectSamplesOfSource(@Param("adapterCode") String adapterCode,
+ @Param("devtype") int devtype, @Param("devid") int devid, @Param("subdevid") int subdevid,
+ @Param("chlid") int chlid, @Param("sourceRef") String sourceRef);
+
/** 严格晚于 (设备时间, 协议序号) 的采样行，按二元组升序；水位为空表示不取数据。 */
List<TDeviceIngestRecord> selectSamplesSince(@Param("adapterCode") String adapterCode,
@Param("devtype") int devtype, @Param("devid") int devid, @Param("subdevid") int subdevid,
--
Gitblit v1.7.1