From 4ccb6e629d3c39521435046e94d5bec927861247 Mon Sep 17 00:00:00 2001
From: zhaowenyu <35589726@qq.com>
Date: Mon, 08 Dec 2025 11:29:56 +0800
Subject: [PATCH] 2025-12-07 zwy 整理代码
---
ard-sample/src/main/java/com/ard/sample/component/mqtt/handler/StateLiveStatusHandler.java | 36 +++++++++++++++++++-----------------
1 files changed, 19 insertions(+), 17 deletions(-)
diff --git a/ard-sample/src/main/java/com/ard/sample/component/mqtt/handler/StateLiveStatusHandler.java b/ard-sample/src/main/java/com/ard/sample/component/mqtt/handler/StateLiveStatusHandler.java
index 2227171..c836da9 100644
--- a/ard-sample/src/main/java/com/ard/sample/component/mqtt/handler/StateLiveStatusHandler.java
+++ b/ard-sample/src/main/java/com/ard/sample/component/mqtt/handler/StateLiveStatusHandler.java
@@ -39,25 +39,27 @@
String deviceSn= stateReceiver.getGateway();
DeviceQueryParam param = DeviceQueryParam.builder().deviceSn(deviceSn).build();
List<DeviceDTO> deviceDTOS = _deviceService.getDevicesByParams(param);
- // List<DeviceDTO> gatewaysList = _deviceService.getDevicesByParams(DeviceQueryParam.builder().childSn(deviceSn).build());
- String childSn = deviceDTOS.get(0).getChildDeviceSn();
- List<LiveStatusTwoReceiver> list = mapper.convertValue(dataNode.get(StateDataEnum.LIVESTATUS.getDesc()), new TypeReference<List<LiveStatusTwoReceiver>>() {});
- for (LiveStatusTwoReceiver receiver : list) {
- if(receiver.getVideoId().contains(childSn)){
- stateReceiver.setData(receiver);
- continue;
+ if(deviceDTOS!=null && deviceDTOS.size()>0)
+ {
+ String childSn = deviceDTOS.get(0).getChildDeviceSn();
+ List<LiveStatusTwoReceiver> list = mapper.convertValue(dataNode.get(StateDataEnum.LIVESTATUS.getDesc()), new TypeReference<List<LiveStatusTwoReceiver>>() {});
+ for (LiveStatusTwoReceiver receiver : list) {
+ if(receiver.getVideoId().contains(childSn)){
+ stateReceiver.setData(receiver);
+ continue;
+ }
}
+ stateReceiver.setGateway(childSn);
+ String liveStatus = "";
+ try{
+ liveStatus=mapper.writeValueAsString(stateReceiver);
+ }
+ catch (Exception e){
+ log.error("接收state直播设备状态反馈转换异常:{}",e);
+ }
+ _deviceService.setChildRedisCamera(childSn, liveStatus);
}
- stateReceiver.setGateway(childSn);
- String liveStatus = "";
- try{
- liveStatus=mapper.writeValueAsString(stateReceiver);
- }
- catch (Exception e){
- log.error("接收state直播设备状态反馈转换异常:{}",e);
- }
- _deviceService.setChildRedisCamera(childSn, liveStatus);
- log.info("接收state直播设备状态反馈:{}",liveStatus);
+
return stateReceiver;
}
return handler.handleState(dataNode, stateReceiver, sn);
--
Gitblit v1.9.3