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/test/java/com/battery/business/service/impl/FakeIngestLanding.java | 11 +++++++++++
1 files changed, 11 insertions(+), 0 deletions(-)
diff --git a/battery-business/src/test/java/com/battery/business/service/impl/FakeIngestLanding.java b/battery-business/src/test/java/com/battery/business/service/impl/FakeIngestLanding.java
index 1d175f7..21b6586 100644
--- a/battery-business/src/test/java/com/battery/business/service/impl/FakeIngestLanding.java
+++ b/battery-business/src/test/java/com/battery/business/service/impl/FakeIngestLanding.java
@@ -97,6 +97,17 @@
}
@Override
+ public List<TDeviceIngestRecord> selectSamplesOfSource(String adapterCode, int devtype, int devid, int subdevid,
+ int chlid, String sourceRef)
+ {
+ return samples(adapterCode, devtype, devid, subdevid, chlid).stream()
+ .filter(row -> sourceRef.equals(row.getSourceRef()))
+ .sorted(java.util.Comparator.comparing(TDeviceIngestRecord::getDeviceTimeUtc)
+ .thenComparing(TDeviceIngestRecord::getRecordSequence))
+ .toList();
+ }
+
+ @Override
public List<TDeviceIngestRecord> selectSamplesSince(String adapterCode, int devtype, int devid, int subdevid,
int chlid, Date watermarkTime, long watermarkSequence, int limit)
{
--
Gitblit v1.7.1