yeg
2026-08-29 d2b53841c31b82df4f71b800ad18a323694c10d7
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();