package com.battery.business.runtime;
|
|
import java.util.List;
|
import java.util.Set;
|
import java.time.Instant;
|
import org.springframework.stereotype.Service;
|
import com.battery.device.api.discovery.DeviceDiscoveryCandidateStore;
|
import com.battery.business.domain.vo.DiscoveredCollectorVo;
|
import com.battery.business.service.ICollectorDiscoveryService;
|
import com.battery.business.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;
|
}
|
|
/** 返回未过期且未登记的采集器，离线事实不影响发现展示或登记资格。 */
|
@Override
|
public List<DiscoveredCollectorVo> selectDiscoveredCollectorList()
|
{
|
Set<String> registeredCodes = collectorService.selectRegisteredCollectorCodes();
|
return candidateStore.snapshot(Instant.now()).collectors().stream()
|
.filter(collector -> !registeredCodes.contains(collector.deviceCode()))
|
.map(collector -> new DiscoveredCollectorVo(collector.deviceCode(), collector.ip(), collector.mac(),
|
collector.name(), collector.manufacturer(), collector.model(), collector.channelCount(),
|
collector.online() ? "在线" : "离线", "空闲", "-"))
|
.toList();
|
}
|
}
|
