package com.ruoyi.config;
|
|
import java.util.List;
|
import java.util.Set;
|
import java.time.Instant;
|
import org.springframework.stereotype.Service;
|
import com.ruoyi.device.discovery.DeviceDiscoveryCandidateStore;
|
import com.ruoyi.system.domain.vo.DiscoveredCollectorVo;
|
import com.ruoyi.system.service.ICollectorDiscoveryService;
|
import com.ruoyi.system.service.ITCollectorService;
|
|
/** 在应用装配边界将临时模拟采集器暴露给现有采集器页面。 */
|
@Service
|
public class DevelopmentCollectorDiscoveryService implements ICollectorDiscoveryService
|
{
|
private final DeviceDiscoveryCandidateStore candidateStore;
|
private final ITCollectorService collectorService;
|
|
public DevelopmentCollectorDiscoveryService(DeviceDiscoveryCandidateStore candidateStore,
|
ITCollectorService collectorService)
|
{
|
this.candidateStore = candidateStore;
|
this.collectorService = collectorService;
|
}
|
|
/** 返回在线且未登记的独立采集器快照，不混入 BTS 检测柜设备。 */
|
@Override
|
public List<DiscoveredCollectorVo> selectDiscoveredCollectorList()
|
{
|
Set<String> registeredCodes = collectorService.selectRegisteredCollectorCodes();
|
return candidateStore.snapshot(Instant.now()).collectors().stream()
|
.filter(collector -> collector.online()
|
&& !registeredCodes.contains(collector.deviceCode()))
|
.map(collector -> new DiscoveredCollectorVo(collector.deviceCode(), collector.ip(), collector.mac(),
|
collector.name(), collector.manufacturer(), collector.model(), collector.channelCount(),
|
"在线", "空闲", "-"))
|
.toList();
|
}
|
}
|
