package com.ruoyi.device.service.impl; import com.alibaba.fastjson2.JSON; import com.ruoyi.device.domain.api.IDeviceDomain; import com.ruoyi.device.domain.api.IDockDomain; import com.ruoyi.device.domain.api.IAircraftDomain; import com.ruoyi.device.domain.api.IThingsBoardDomain; import com.ruoyi.device.domain.model.Device; import com.ruoyi.device.domain.model.Dock; import com.ruoyi.device.domain.model.thingsboard.AttributeMap; import com.ruoyi.device.domain.model.thingsboard.TelemetryMap; import com.ruoyi.device.service.api.IBufferDeviceService; import com.ruoyi.device.service.dto.AircraftDetailDTO; import com.ruoyi.device.service.dto.DockDetailDTO; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.List; import java.util.stream.Collectors; /** * 设备缓冲服务实现 * 整合数据库数据和ThingsBoard数据 * * @author ruoyi * @date 2026-01-20 */ @Service @Slf4j public class BufferDeviceImpl implements IBufferDeviceService { @Autowired private IDockDomain dockDomain; @Autowired private IDeviceDomain deviceDomain; @Autowired private IAircraftDomain aircraftDomain; @Autowired private IThingsBoardDomain thingsBoardDomain; @Override public DockDetailDTO getDockDetailById(Long dockId) { Dock dock = dockDomain.selectDockByDockId(dockId); log.info("selectDockByDockId {}",JSON.toJSONString(dock)); if (dock == null) { return null; } Device device = deviceDomain.selectDeviceByDeviceId(dock.getDeviceId()); log.info("selectDeviceByDeviceId {}",JSON.toJSONString(device)); DockDetailDTO dto = getChangeAbleDockDetailDTO(device.getIotDeviceId()); dto.setDockId(dock.getDockId()); dto.setDockName(dock.getDockName()); dto.setDockLocation(dock.getDockLocation()); dto.setDockIotId(device.getIotDeviceId()); return dto; } @Override public AircraftDetailDTO getAircraftDetailById(Long aircraftId) { return null; } private DockDetailDTO getChangeAbleDockDetailDTO(String deviceIotId) { DockDetailDTO dto = new DockDetailDTO(); AttributeMap attributeMap = thingsBoardDomain.getPredefinedDeviceAttributes(deviceIotId); TelemetryMap telemetryMap = thingsBoardDomain.getPredefinedDeviceTelemetry(deviceIotId); return dto; } private AircraftDetailDTO getChangeAbleAirDetailDTO(String deviceIotId) { return null; } }