You've already forked FrameTour-BE
feat(device): 添加设备在线状态查询功能- 在DeviceV2Controller中新增getDeviceOnlineStatus接口,用于根据设备ID查询设备在线状态
All checks were successful
ZhenTu-BE/pipeline/head This commit looks good
All checks were successful
ZhenTu-BE/pipeline/head This commit looks good
- 引入DeviceStatusDTO和DeviceStatusIntegrationService以支持设备状态查询- 修改DeviceStatusDTO中的时间字段类型为Date,并调整JSON序列化格式- 在DeviceRepository中增加convertToEntityWithStatus方法,用于合并设备信息与状态信息 - 优化DeviceRepository中的getOnlineStatus方法,增加异常处理和降级机制- 完善设备在线状态查询的日志记录和错误处理逻辑
This commit is contained in:
@@ -7,7 +7,9 @@ import com.ycwl.basic.model.pc.device.entity.DeviceConfigEntity;
|
||||
import com.ycwl.basic.model.pc.device.entity.DeviceEntity;
|
||||
import com.ycwl.basic.utils.SnowFlakeUtil;
|
||||
import com.ycwl.basic.integration.device.service.DeviceIntegrationService;
|
||||
import com.ycwl.basic.integration.device.service.DeviceStatusIntegrationService;
|
||||
import com.ycwl.basic.integration.device.dto.device.DeviceV2DTO;
|
||||
import com.ycwl.basic.integration.device.dto.status.DeviceStatusDTO;
|
||||
import com.ycwl.basic.integration.common.manager.DeviceConfigManager;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.data.redis.core.RedisTemplate;
|
||||
@@ -33,6 +35,8 @@ public class DeviceRepository {
|
||||
public static final String DEVICE_CACHE_KEY = "device:%s";
|
||||
@Autowired
|
||||
private DeviceConfigIntegrationService deviceConfigIntegrationService;
|
||||
@Autowired
|
||||
private DeviceStatusIntegrationService deviceStatusIntegrationService;
|
||||
|
||||
/**
|
||||
* 将DeviceV2DTO转换为DeviceEntity
|
||||
@@ -57,6 +61,30 @@ public class DeviceRepository {
|
||||
return entity;
|
||||
}
|
||||
|
||||
/**
|
||||
* 将DeviceV2DTO和DeviceStatusDTO合并转换为DeviceEntity
|
||||
*/
|
||||
private DeviceEntity convertToEntityWithStatus(DeviceV2DTO deviceDto, DeviceStatusDTO statusDto) {
|
||||
if (deviceDto == null) {
|
||||
return null;
|
||||
}
|
||||
|
||||
DeviceEntity entity = convertToEntity(deviceDto);
|
||||
|
||||
// 合并状态信息
|
||||
if (statusDto != null) {
|
||||
// Boolean转Integer: true→1, false→0
|
||||
entity.setOnline(statusDto.getIsOnline() != null && statusDto.getIsOnline() ? 1 : 0);
|
||||
entity.setKeepaliveAt(statusDto.getLastActiveTime());
|
||||
entity.setIpAddr(statusDto.getClientIP());
|
||||
} else {
|
||||
// 默认离线状态
|
||||
entity.setOnline(0);
|
||||
}
|
||||
|
||||
return entity;
|
||||
}
|
||||
|
||||
public DeviceEntity getDevice(Long deviceId) {
|
||||
log.debug("获取设备信息, deviceId: {}", deviceId);
|
||||
DeviceV2DTO deviceDto = deviceIntegrationService.getDevice(deviceId);
|
||||
@@ -144,10 +172,31 @@ public class DeviceRepository {
|
||||
}
|
||||
|
||||
public DeviceEntity getOnlineStatus(Long deviceId) {
|
||||
if (redisTemplate.hasKey(String.format(DEVICE_ONLINE_CACHE_KEY, deviceId))) {
|
||||
return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(DEVICE_ONLINE_CACHE_KEY, deviceId)), DeviceEntity.class);
|
||||
} else {
|
||||
return null;
|
||||
log.debug("获取设备在线状态, deviceId: {}", deviceId);
|
||||
try {
|
||||
// 首先获取设备基本信息
|
||||
DeviceV2DTO deviceDto = deviceIntegrationService.getDevice(deviceId);
|
||||
if (deviceDto == null) {
|
||||
log.warn("设备不存在, deviceId: {}", deviceId);
|
||||
return null;
|
||||
}
|
||||
|
||||
// 通过设备编号获取设备状态
|
||||
DeviceStatusDTO statusDto = deviceStatusIntegrationService.getDeviceStatus(deviceDto.getNo());
|
||||
|
||||
// 合并设备信息和状态信息
|
||||
return convertToEntityWithStatus(deviceDto, statusDto);
|
||||
|
||||
} catch (Exception e) {
|
||||
log.error("获取设备在线状态异常, deviceId: {}", deviceId, e);
|
||||
// 降级处理:尝试仅返回设备基本信息
|
||||
try {
|
||||
DeviceV2DTO deviceDto = deviceIntegrationService.getDevice(deviceId);
|
||||
return convertToEntityWithStatus(deviceDto, null);
|
||||
} catch (Exception fallbackException) {
|
||||
log.error("降级获取设备信息也失败, deviceId: {}", deviceId, fallbackException);
|
||||
return null;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
Reference in New Issue
Block a user