From 2e5e7a94ada4509fa286d8438b6b127aaa906570 Mon Sep 17 00:00:00 2001
From: zhaowenyu <35589726@qq.com>
Date: Sat, 29 Nov 2025 16:54:33 +0800
Subject: [PATCH] 2025-11-29 zwy 多路直播,將視頻地址存到列表里;在請求設備列表時調用機場推流。

---
 ard-sample/src/main/java/com/ard/sample/manage/service/impl/DeviceServiceImpl.java |   33 +++++++++++++++++++++++++++++----
 1 files changed, 29 insertions(+), 4 deletions(-)

diff --git a/ard-sample/src/main/java/com/ard/sample/manage/service/impl/DeviceServiceImpl.java b/ard-sample/src/main/java/com/ard/sample/manage/service/impl/DeviceServiceImpl.java
index 417c3ca..a0488e9 100644
--- a/ard-sample/src/main/java/com/ard/sample/manage/service/impl/DeviceServiceImpl.java
+++ b/ard-sample/src/main/java/com/ard/sample/manage/service/impl/DeviceServiceImpl.java
@@ -1,6 +1,7 @@
 package com.ard.sample.manage.service.impl;
 
 import com.alibaba.fastjson2.JSONObject;
+import com.ard.sample.component.websocket.handler.LiveStreamHandler;
 import com.ard.system.authorize.service.AuthorizeService;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
@@ -65,6 +66,9 @@
 @Slf4j
 @Transactional
 public class DeviceServiceImpl implements IDeviceService {
+
+    @Autowired
+    private LiveStreamHandler _liveStreamHandler;
 
     @Autowired
     private IMessageSenderService messageSender;
@@ -355,6 +359,11 @@
                 DeviceQueryParam.builder()
                         .domains(List.of(DeviceDomainEnum.GATEWAY.getVal(), DeviceDomainEnum.DOCK.getVal()))
                         .build());
+        // 在獲取设备列表时,顺便获取直播地址
+        for(DeviceDTO devices : devicesList){
+            _liveStreamHandler.StartLiveStreaming(devices.getDeviceSn());
+            _liveStreamHandler.StartLiveStreaming(devices.getChildDeviceSn());
+        }
 
         devicesList.stream()
                 .filter(gateway -> DeviceDomainEnum.DOCK.getVal() == gateway.getDomain() ||
@@ -499,10 +508,10 @@
     @Override
     @ServiceActivator(inputChannel = ChannelName.INBOUND_OSD)
     public void handleOSD(Message<?> message) {
-        String topic = message.getHeaders().get(MqttHeaders.RECEIVED_TOPIC).toString();
-        byte[] payload = (byte[]) message.getPayload();
-        CommonTopicReceiver receiver;
         try {
+            String topic = message.getHeaders().get(MqttHeaders.RECEIVED_TOPIC).toString();
+            byte[] payload = (byte[]) message.getPayload();
+            CommonTopicReceiver receiver;
             String from = topic.substring((THING_MODEL_PRE + PRODUCT).length(),
                     topic.indexOf(OSD_SUF));
 
@@ -540,7 +549,12 @@
 
             tsaService.handleOSD(receiver, device, webSessions, wsMessage);
 
-        } catch (IOException e) {
+        } catch (NullPointerException e) {
+            log.error("处理OSD消息NPE,headers={}, payload={}",
+                    message.getHeaders(), message.getPayload(), e); // 打印完整栈
+        }
+        catch (IOException e) {
+            log.error("处理OSD消息的IO异常:{}",e.getMessage(), e);
             e.printStackTrace();
         }
     }
@@ -748,6 +762,7 @@
                 .firmwareVersion(entity.getFirmwareVersion())
                 .deptId(entity.getDeptId())
                 .workType(entity.getWorkType())
+                .webrtcUrl(entity.getWebrtcUrl())
                 .workspaceName(entity.getDeptId() != null
                         ? Optional.ofNullable(sysDeptService.selectDeptById(entity.getDeptId()))
                         .map(SysDept::getDeptName)
@@ -795,6 +810,15 @@
                 // 只更新workType字段
                 .set(DeviceEntity::getWorkType, workType);
         // 执行更新(第一个参数传null,因为更新字段已通过wrapper的set指定)
+        int update = mapper.update(null, lambdaUpdateWrapper);
+        return update > 0;
+    }
+
+    @Override
+    public Boolean updateWebrtcUrl(String sn, String webrtcUrl){
+        LambdaUpdateWrapper<DeviceEntity> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();
+        lambdaUpdateWrapper.eq(DeviceEntity::getDeviceSn, sn)
+                .set(DeviceEntity::getWebrtcUrl, webrtcUrl);
         int update = mapper.update(null, lambdaUpdateWrapper);
         return update > 0;
     }
@@ -1188,6 +1212,7 @@
                 .domain(dto.getDomain())
                 .firmwareVersion(dto.getFirmwareVersion())
                 .workType(dto.getWorkType())
+                .webrtcUrl(dto.getWebrtcUrl())
                 .compatibleStatus(dto.getFirmwareStatus() == null ? null :
                         DeviceFirmwareStatusEnum.CONSISTENT_UPGRADE != DeviceFirmwareStatusEnum.find(dto.getFirmwareStatus()))
                 .build();

--
Gitblit v1.9.3