From 724963324aaa63feca2c6aed13785dc8485bc02c Mon Sep 17 00:00:00 2001 From: 648540858 <648540858@qq.com> Date: 星期一, 26 六月 2023 19:06:14 +0800 Subject: [PATCH] 修复上级点播时如果推流信息中mediaServerID错误的情况 --- src/main/java/com/genersoft/iot/vmp/service/IStreamProxyService.java | 52 ++++++++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 50 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/service/IStreamProxyService.java b/src/main/java/com/genersoft/iot/vmp/service/IStreamProxyService.java index 12e4898..576ad3c 100644 --- a/src/main/java/com/genersoft/iot/vmp/service/IStreamProxyService.java +++ b/src/main/java/com/genersoft/iot/vmp/service/IStreamProxyService.java @@ -1,8 +1,11 @@ package com.genersoft.iot.vmp.service; -import com.alibaba.fastjson.JSONObject; +import com.alibaba.fastjson2.JSONObject; +import com.genersoft.iot.vmp.common.GeneralCallback; +import com.genersoft.iot.vmp.common.StreamInfo; import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem; import com.genersoft.iot.vmp.media.zlm.dto.StreamProxyItem; +import com.genersoft.iot.vmp.vmanager.bean.ResourceBaceInfo; import com.github.pagehelper.PageInfo; public interface IStreamProxyService { @@ -11,7 +14,7 @@ * 淇濆瓨瑙嗛浠g悊 * @param param */ - String save(StreamProxyItem param); + void save(StreamProxyItem param, GeneralCallback<StreamInfo> callback); /** * 娣诲姞瑙嗛浠g悊鍒皕lm @@ -51,6 +54,16 @@ boolean start(String app, String stream); /** + * 鏇存柊鐘舵�� + * @param status 鐘舵�� + * @param app + * @param stream + */ + int updateStatus(boolean status, String app, String stream); + + + + /** * 鍋滅敤鐢ㄨ棰戜唬鐞� * @param app * @param stream @@ -63,4 +76,39 @@ * @return */ JSONObject getFFmpegCMDs(MediaServerItem mediaServerItem); + + /** + * 鏍规嵁app涓巗tream鑾峰彇streamProxy + * @return + */ + StreamProxyItem getStreamProxyByAppAndStream(String app, String streamId); + + + /** + * 鏂扮殑鑺傜偣鍔犲叆 + * @param mediaServerId + * @return + */ + void zlmServerOnline(String mediaServerId); + + /** + * 鑺傜偣绂荤嚎 + * @param mediaServerId + * @return + */ + void zlmServerOffline(String mediaServerId); + + void clean(); + + /** + * 鏇存柊浠g悊娴� + */ + boolean updateStreamProxy(StreamProxyItem streamProxyItem); + + /** + * 鑾峰彇缁熻淇℃伅 + * @return + */ + ResourceBaceInfo getOverview(); + } -- Gitblit v1.8.0