From 2bf7cdc2df8482b775c05e783e49f3bb7ec58da5 Mon Sep 17 00:00:00 2001
From: ljm <1271952916@qq.com>
Date: 星期四, 20 十月 2022 16:04:47 +0800
Subject: [PATCH] 【zlm心跳hook】重复查询redis了 变量也不需要多次定义 数据库有的话应该恢复zlm

---
 src/main/java/com/genersoft/iot/vmp/service/IStreamProxyService.java |   41 ++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 40 insertions(+), 1 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..1395a52 100644
--- a/src/main/java/com/genersoft/iot/vmp/service/IStreamProxyService.java
+++ b/src/main/java/com/genersoft/iot/vmp/service/IStreamProxyService.java
@@ -1,6 +1,7 @@
 package com.genersoft.iot.vmp.service;
 
 import com.alibaba.fastjson.JSONObject;
+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.github.pagehelper.PageInfo;
@@ -11,7 +12,7 @@
      * 淇濆瓨瑙嗛浠g悊
      * @param param
      */
-    String save(StreamProxyItem param);
+    StreamInfo save(StreamProxyItem param);
 
     /**
      * 娣诲姞瑙嗛浠g悊鍒皕lm
@@ -51,6 +52,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 +74,32 @@
      * @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);
 }

--
Gitblit v1.8.0