From 147428971be43eed90a79f3849f15000d3855390 Mon Sep 17 00:00:00 2001
From: yeg <1347747024@qq.com>
Date: 星期一, 28 九月 2026 15:15:22 +0800
Subject: [PATCH] 实现新威 7.6 直连取数与逐行接收
---
battery-device-simulator/src/test/java/com/battery/device/simulator/SimulatorObservationAdapterContractTest.java | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/battery-device-simulator/src/test/java/com/battery/device/simulator/SimulatorObservationAdapterContractTest.java b/battery-device-simulator/src/test/java/com/battery/device/simulator/SimulatorObservationAdapterContractTest.java
index 9407dfd..a35fb53 100644
--- a/battery-device-simulator/src/test/java/com/battery/device/simulator/SimulatorObservationAdapterContractTest.java
+++ b/battery-device-simulator/src/test/java/com/battery/device/simulator/SimulatorObservationAdapterContractTest.java
@@ -16,7 +16,7 @@
{
simulator.updateChannel(1, 1, true, DeviceWorkStatus.PROTECTED);
simulator.updateCollectorChannelStatus(1, "S-01", DeviceWorkStatus.UNOBSERVABLE);
- var collector = simulator.latestCollector("dev-sim-collector-1");
+ var collector = simulator.latestCollector(BtsDevelopmentSimulator.ADAPTER_CODE, "dev-sim-collector-1");
assertTrue(collector.measurements().stream().noneMatch(item -> item.channelCode().equals("S-01")));
firstSequence = collector.measurements().get(0).sequenceId();
simulator.setSoftwareAccessible(false);
@@ -30,7 +30,7 @@
assertEquals(DeviceWorkStatus.PROTECTED, restored.snapshot().devices().get(0).channels().get(0).workStatus());
assertTrue(restored.snapshot().collectors().get(0).latestMeasurements().isEmpty());
restored.setSoftwareAccessible(true);
- assertTrue(restored.latestCollector("dev-sim-collector-1").measurements().get(0).sequenceId() > firstSequence);
+ assertTrue(restored.latestCollector(BtsDevelopmentSimulator.ADAPTER_CODE, "dev-sim-collector-1").measurements().get(0).sequenceId() > firstSequence);
assertEquals(DeviceWorkStatus.UNOBSERVABLE, restored.snapshot().collectors().get(0).channels().get(0).workStatus());
}
}
@@ -63,14 +63,14 @@
simulator.updateChannel(1, 1, true, DeviceWorkStatus.WORKING);
var first = simulator.latestCabinet(channel);
assertNotNull(first);
- assertFalse(simulator.latestCollector("dev-sim-collector-1").measurements().isEmpty());
+ assertFalse(simulator.latestCollector(BtsDevelopmentSimulator.ADAPTER_CODE, "dev-sim-collector-1").measurements().isEmpty());
simulator.setSoftwareAccessible(false);
assertEquals(channel, simulator.discoverChannels().get(0).identity());
assertTrue(simulator.snapshot().devices().get(0).online());
assertEquals(DeviceWorkStatus.UNOBSERVABLE,
simulator.observe(java.util.Set.of(channel)).get(channel).workStatus());
assertNull(simulator.latestCabinet(channel));
- assertTrue(simulator.latestCollector("dev-sim-collector-1").measurements().isEmpty());
+ assertTrue(simulator.latestCollector(BtsDevelopmentSimulator.ADAPTER_CODE, "dev-sim-collector-1").measurements().isEmpty());
simulator.setSoftwareAccessible(true);
var next = simulator.latestCabinet(channel);
assertTrue(next.sequenceId() > first.sequenceId());
--
Gitblit v1.7.1