From d2b53841c31b82df4f71b800ad18a323694c10d7 Mon Sep 17 00:00:00 2001
From: yeg <1347747024@qq.com>
Date: 星期六, 29 八月 2026 23:13:40 +0800
Subject: [PATCH] 修复设备发现状态同步与开始接收边界
---
ruoyi-admin/src/test/java/com/ruoyi/config/DevelopmentCollectorStatusSynchronizerTest.java | 7 ++++++-
1 files changed, 6 insertions(+), 1 deletions(-)
diff --git a/ruoyi-admin/src/test/java/com/ruoyi/config/DevelopmentCollectorStatusSynchronizerTest.java b/ruoyi-admin/src/test/java/com/ruoyi/config/DevelopmentCollectorStatusSynchronizerTest.java
index cd05a02..16da2ef 100644
--- a/ruoyi-admin/src/test/java/com/ruoyi/config/DevelopmentCollectorStatusSynchronizerTest.java
+++ b/ruoyi-admin/src/test/java/com/ruoyi/config/DevelopmentCollectorStatusSynchronizerTest.java
@@ -4,6 +4,9 @@
import org.junit.jupiter.api.Test;
import com.ruoyi.device.bts.BtsDevelopmentSimulator;
import com.ruoyi.device.discovery.InMemoryDeviceDiscoveryCandidateStore;
+import com.ruoyi.system.mapper.TCollectorMapper;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.verify;
class DevelopmentCollectorStatusSynchronizerTest
{
@@ -13,13 +16,15 @@
try (BtsDevelopmentSimulator simulator = new BtsDevelopmentSimulator(0))
{
InMemoryDeviceDiscoveryCandidateStore store = new InMemoryDeviceDiscoveryCandidateStore();
+ TCollectorMapper collectorMapper = mock(TCollectorMapper.class);
DevelopmentCollectorStatusSynchronizer synchronizer =
- new DevelopmentCollectorStatusSynchronizer(simulator, store);
+ new DevelopmentCollectorStatusSynchronizer(simulator, store, collectorMapper);
simulator.updateCollector(1, "127.0.1.2", 4, false);
synchronizer.synchronizeOnlineStatus();
assertEquals(false, store.snapshot(java.time.Instant.now()).collectors().get(0).online());
+ verify(collectorMapper).updateRegisteredObservation("dev-sim-collector-1", "OFFLINE");
simulator.deleteCollector(1);
synchronizer.synchronizeOnlineStatus();
--
Gitblit v1.7.1