From d68f9c813341afa82726e6182cca8af61248fc5e Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: 星期一, 06 十二月 2021 10:44:33 +0800
Subject: [PATCH] 修复选择直播通道缺失了通道类型的问题
---
src/main/java/com/genersoft/iot/vmp/service/impl/StreamProxyServiceImpl.java | 60 ++++++++++++++++++++++++++++++------------------------------
1 files changed, 30 insertions(+), 30 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/service/impl/StreamProxyServiceImpl.java b/src/main/java/com/genersoft/iot/vmp/service/impl/StreamProxyServiceImpl.java
index a10e340..2961bc6 100644
--- a/src/main/java/com/genersoft/iot/vmp/service/impl/StreamProxyServiceImpl.java
+++ b/src/main/java/com/genersoft/iot/vmp/service/impl/StreamProxyServiceImpl.java
@@ -79,44 +79,38 @@
StringBuffer result = new StringBuffer();
boolean streamLive = false;
param.setMediaServerId(mediaInfo.getId());
+ boolean saveResult;
// 鏇存柊
if (videoManagerStorager.queryStreamProxy(param.getApp(), param.getStream()) != null) {
- if (videoManagerStorager.updateStreamProxy(param)) {
- result.append("淇濆瓨鎴愬姛");
- if (param.isEnable()){
- JSONObject jsonObject = addStreamProxyToZlm(param);
- if (jsonObject == null) {
- result.append(", 浣嗘槸鍚敤澶辫触锛岃妫�鏌ユ祦鍦板潃鏄惁鍙敤");
- param.setEnable(false);
- videoManagerStorager.updateStreamProxy(param);
- }else {
- StreamInfo streamInfo = mediaService.getStreamInfoByAppAndStream(
- mediaInfo, param.getApp(), param.getStream(), null);
- wvpResult.setData(streamInfo);
- }
- }
- }
+ saveResult = videoManagerStorager.updateStreamProxy(param);
}else { // 鏂板
- if (videoManagerStorager.addStreamProxy(param)){
- result.append("淇濆瓨鎴愬姛");
- streamLive = true;
- if (param.isEnable()) {
- JSONObject jsonObject = addStreamProxyToZlm(param);
- if (jsonObject == null) {
- streamLive = false;
- result.append(", 浣嗘槸鍚敤澶辫触锛岃妫�鏌ユ祦鍦板潃鏄惁鍙敤");
- param.setEnable(false);
- videoManagerStorager.updateStreamProxy(param);
- }else {
+ saveResult = videoManagerStorager.addStreamProxy(param);
+ }
+ if (saveResult) {
+ result.append("淇濆瓨鎴愬姛");
+ if (param.isEnable()) {
+ JSONObject jsonObject = addStreamProxyToZlm(param);
+ if (jsonObject == null) {
+ streamLive = false;
+ result.append(", 浣嗘槸鍚敤澶辫触锛岃妫�鏌ユ祦鍦板潃鏄惁鍙敤");
+ param.setEnable(false);
+ videoManagerStorager.updateStreamProxy(param);
+ }else {
+ Integer code = jsonObject.getInteger("code");
+ if (code == 0) {
StreamInfo streamInfo = mediaService.getStreamInfoByAppAndStream(
mediaInfo, param.getApp(), param.getStream(), null);
wvpResult.setData(streamInfo);
+ }else {
+ result.append(", 浣嗘槸鍚敤澶辫触锛岃妫�鏌ユ祦鍦板潃鏄惁鍙敤");
+ param.setEnable(false);
+ videoManagerStorager.updateStreamProxy(param);
}
- }
- }else {
- result.append("淇濆瓨澶辫触");
- }
+ }
+ }
+ }else {
+ result.append("淇濆瓨澶辫触");
}
if (param.getPlatformGbId() != null && streamLive) {
List<GbStream> gbStreams = new ArrayList<>();
@@ -228,4 +222,10 @@
return result;
}
+
+
+ @Override
+ public StreamProxyItem getStreamProxyByAppAndStream(String app, String streamId) {
+ return videoManagerStorager.getStreamProxyByAppAndStream(app, streamId);
+ }
}
--
Gitblit v1.8.0