From 0f2c1b35813fd47dd33f3757f59758cfe8edf3a2 Mon Sep 17 00:00:00 2001
From: zhaowenyu <35589726@qq.com>
Date: Wed, 17 Dec 2025 14:40:45 +0800
Subject: [PATCH] 2025-12-16 zwy 优化视频直播开始与停止，加打印失败日志
---
ard-sample/src/main/java/com/ard/sample/manage/service/impl/LiveStreamServiceImpl.java | 42 ++++++++++++++++++++++++++++++++++++++++++
1 files changed, 42 insertions(+), 0 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 28d5dff..e66be60 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
@@ -1,5 +1,6 @@
package com.ard.sample.manage.service.impl;
+import com.ard.sample.common.error.CommonErrorEnum;
import com.ard.sample.common.error.LiveErrorEnum;
import com.ard.sample.common.model.ResponseResult;
import com.ard.sample.component.mqtt.model.CommonTopicResponse;
@@ -118,6 +119,7 @@
ServiceReply receiveReply = this.publishLiveStart(respTopic, liveParam);
if (ResponseResult.CODE_SUCCESS != receiveReply.getResult()) {
+ log.info("机场直播开启失败，错误码：{},错误描述：{}", receiveReply.getResult(), LiveErrorEnum.find(receiveReply.getResult()).getErrorMsg());
return ResponseResult.error(receiveReply.getResult(), LiveErrorEnum.find(receiveReply.getResult()).getErrorMsg());
}
@@ -201,6 +203,7 @@
ServiceReply receiveReply = this.publishLiveStop(respTopic, videoId);
if (receiveReply.getResult() != 0) {
+ log.info("机场直播停止失败，错误码：{},错误描述：{}", receiveReply.getResult(), LiveErrorEnum.find(receiveReply.getResult()).getErrorMsg());
return ResponseResult.error(LiveErrorEnum.find(receiveReply.getResult()));
}
//注释掉删除流媒体管理库中的信息
@@ -233,6 +236,7 @@
@Override
public ResponseResult liveLensChange(LiveTypeDTO liveParam) {
+ log.info("切换镜头参数：{}", liveParam);
ResponseResult<DeviceDTO> responseResult = this.checkBeforeLive(liveParam.getVideoId());
if (ResponseResult.CODE_SUCCESS != responseResult.getCode()) {
return responseResult;
@@ -258,6 +262,44 @@
}
@Override
+ public ResponseResult<List<String>> getLiveLens(String sn) {
+ List<String> videoTypes = new ArrayList<>();
+ // 检查设备是否在线
+ if (!deviceService.checkDeviceOnline(sn)) {
+ log.info("SN: {}-设备不在线，请检查网络连接！", sn);
+ // 抛弃出异常，给调用者处理
+ //throw new Exception("设备不在线，请检查网络连接！");
+ return ResponseResult.error(CommonErrorEnum.DEVICE_OFFLINE.getErrorCode(),CommonErrorEnum.DEVICE_OFFLINE.getErrorMsg());
+ }
+ // 读取直播能力拼接参数
+ List<CapacityDeviceDTO> devicesList = getLiveCapacity();
+ if (devicesList == null || devicesList.isEmpty()) {
+ log.info("SN: {}-未获得设备直播能力！", sn);
+ // 抛弃出异常，给调用者处理
+ //throw new Exception("未获得设备直播能力！");
+ return ResponseResult.error(22222200,"未获得设备直播能力！");
+ }
+ for (CapacityDeviceDTO device : devicesList) {
+ if (!device.getSn().equals(sn)) {
+ continue;
+ }
+ List<CapacityCameraDTO> camerasList = device.getCamerasList();
+ for (CapacityCameraDTO camera : camerasList) {
+ // 机场3中飞行器，没有name，需要其他条件确定主摄像头参数
+ for (CapacityVideoDTO video : camera.getVideosList()) {
+ if (video.getSwitchVideoTypes().size() == 1 && camera.getName() == null) {
+ continue;
+ }
+ videoTypes = video.getSwitchVideoTypes();
+
+ }
+ }
+ }
+
+ return ResponseResult.success(videoTypes);
+ }
+
+ @Override
public ResponseResult liveCameraChange(LiveTypeDTO liveParam) {
if (liveParam.getCameraPosition() == null) {
return ResponseResult.error(LiveErrorEnum.ERROR_PARAMETERS);
--
Gitblit v1.9.3