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 直连取数与逐行接收
---
ruoyi-admin/src/test/java/com/battery/business/runtime/DeviceAdapterRuntimeConfigTest.java | 9 ++++++---
1 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/ruoyi-admin/src/test/java/com/battery/business/runtime/DeviceAdapterRuntimeConfigTest.java b/ruoyi-admin/src/test/java/com/battery/business/runtime/DeviceAdapterRuntimeConfigTest.java
index 932c945..99f5714 100644
--- a/ruoyi-admin/src/test/java/com/battery/business/runtime/DeviceAdapterRuntimeConfigTest.java
+++ b/ruoyi-admin/src/test/java/com/battery/business/runtime/DeviceAdapterRuntimeConfigTest.java
@@ -8,19 +8,22 @@
import org.mockito.ArgumentCaptor;
import com.battery.device.api.registry.AdapterInstanceConfig;
import com.battery.device.api.registry.DeviceAdapterRegistry;
+import com.battery.device.simulator.BtsDevelopmentSimulator;
class DeviceAdapterRuntimeConfigTest
{
@Test
- void registersDevelopmentSimulatorBeforeApplicationReady() throws Exception
+ void registersDevelopmentSimulatorInstanceBeforeApplicationReady() throws Exception
{
DeviceAdapterRegistry registry = mock(DeviceAdapterRegistry.class);
- var runner = new DevelopmentSimulatorConfig().registerDevelopmentSimulatorAdapter(registry, 15021);
+ BtsDevelopmentSimulator simulator = mock(BtsDevelopmentSimulator.class);
+ var runner = new DevelopmentSimulatorConfig().registerDevelopmentSimulatorAdapter(registry, simulator, 15021);
runner.run(new DefaultApplicationArguments(new String[0]));
+ // 注册模拟器对象本身：发现与取数落在同一实例上，不再单独注入扩展观测 Bean。
ArgumentCaptor<AdapterInstanceConfig> adapter = ArgumentCaptor.forClass(AdapterInstanceConfig.class);
- verify(registry).synchronize(adapter.capture());
+ verify(registry).register(adapter.capture(), org.mockito.ArgumentMatchers.same(simulator));
assertEquals("dev-sim", adapter.getValue().adapterCode());
assertEquals("127.0.0.1", adapter.getValue().host());
assertEquals(15021, adapter.getValue().port());
--
Gitblit v1.7.1