From b5b95f50e7905e9424628254b3cba7b92aa77cde Mon Sep 17 00:00:00 2001
From: zhaowenyu <35589726@qq.com>
Date: Wed, 03 Dec 2025 14:52:56 +0800
Subject: [PATCH] 2025-12-03 zwy 维护大疆上云、司空错误码!返回前端的错误码和错误详情。

---
 ard-sample/src/main/java/com/ard/sample/manage/service/impl/LiveStreamServiceImpl.java |   16 ++++++++++++----
 1 files changed, 12 insertions(+), 4 deletions(-)

diff --git a/ard-sample/src/main/java/com/ard/sample/manage/service/impl/LiveStreamServiceImpl.java b/ard-sample/src/main/java/com/ard/sample/manage/service/impl/LiveStreamServiceImpl.java
index 85aca57..e612f7b 100644
--- a/ard-sample/src/main/java/com/ard/sample/manage/service/impl/LiveStreamServiceImpl.java
+++ b/ard-sample/src/main/java/com/ard/sample/manage/service/impl/LiveStreamServiceImpl.java
@@ -22,6 +22,7 @@
 import com.ard.vtdu.domain.ArdVtdu;
 import com.ard.vtdu.service.IArdMediaService;
 import com.ard.vtdu.service.IArdVtduService;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -40,6 +41,7 @@
  * @version 0.1
  * @date 2021/11/22
  */
+@Slf4j
 @Service
 @Transactional
 public class LiveStreamServiceImpl implements ILiveStreamService {
@@ -116,7 +118,7 @@
         ServiceReply receiveReply = this.publishLiveStart(respTopic, liveParam);
 
         if (ResponseResult.CODE_SUCCESS != receiveReply.getResult()) {
-            return ResponseResult.error(LiveErrorEnum.find(receiveReply.getResult()));
+            return ResponseResult.error(receiveReply.getResult(), LiveErrorEnum.find(receiveReply.getResult()).getErrorMsg());
         }
 
         LiveUrlTypeEnum urlType = LiveUrlTypeEnum.find(liveParam.getUrlType());
@@ -145,8 +147,10 @@
                 // 查询是否已经存在该记录
                 ArdVtdu ardVtdu = ardVtduService.selectArdVtduByName(vtdu.getName());
                 int i = 0;
+                log.info("机场视频插入前vtdu:{}",vtdu);
                 if(ardVtdu == null){
                     i = ardVtduService.insertArdVtdu(vtdu);  // 保存到媒体表
+                    log.info("机场视频插入后 i:{}",i);
                     if (i > 0) {
                         live.setRtmpUrl(rtmpUrl);
                         live.setRtspUrl(rtspUrl);
@@ -154,9 +158,13 @@
                     }
                 }
                 else{
-                    live.setRtmpUrl(rtmpUrl);
-                    live.setRtspUrl(rtspUrl);
-                    live.setWebrtcUrl(webrtcUrl);
+                    i = ardVtduService.updateArdVtdu(vtdu);
+                    log.info("机场视频更新后 i:{}",i);
+                    if (i > 0) {
+                        live.setRtmpUrl(rtmpUrl);
+                        live.setRtspUrl(rtspUrl);
+                        live.setWebrtcUrl(webrtcUrl);
+                    }
                 }
                 //int i = ardVtduService.insertArdVtdu(vtdu);  // 保存到媒体表
 //                if (i > 0) {

--
Gitblit v1.9.3