From 691f882740b46c5354fb33404fef6efb370e05dc Mon Sep 17 00:00:00 2001
From: yeg <1347747024@qq.com>
Date: 星期五, 09 十月 2026 15:52:05 +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