From f1d079f9c0b3d384090477ca54e0548373d62b57 Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Thu, 16 Jan 2025 11:56:39 +0800
Subject: [PATCH] 配置修改
---
src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java | 86 +++++++++++++++++++++++++++++--------------
1 files changed, 58 insertions(+), 28 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java b/src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java
index 5094853..ab9a831 100644
--- a/src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java
+++ b/src/main/java/com/genersoft/iot/vmp/storager/IRedisCatchStorage.java
@@ -3,12 +3,12 @@
import com.alibaba.fastjson.JSONObject;
import com.genersoft.iot.vmp.common.StreamInfo;
import com.genersoft.iot.vmp.gb28181.bean.*;
-import com.genersoft.iot.vmp.media.zlm.dto.MediaItem;
-import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem;
-import com.genersoft.iot.vmp.media.zlm.dto.StreamPushItem;
+import com.genersoft.iot.vmp.media.zlm.dto.*;
import com.genersoft.iot.vmp.service.bean.GPSMsgInfo;
+import com.genersoft.iot.vmp.service.bean.MessageForPushChannel;
import com.genersoft.iot.vmp.service.bean.SSRCInfo;
import com.genersoft.iot.vmp.service.bean.ThirdPartyGB;
+import com.genersoft.iot.vmp.storager.dao.dto.PlatformRegisterInfo;
import java.util.List;
import java.util.Map;
@@ -18,10 +18,9 @@
/**
* 计数器。为cseq进行计数
*
- * @param method sip 方法
* @return
*/
- Long getCSEQ(String method);
+ Long getCSEQ();
/**
* 开始播放时将流存入
@@ -57,23 +56,21 @@
StreamInfo queryPlayback(String deviceId, String channelID, String stream, String callId);
+ String queryPlaybackForKey(String deviceId, String channelId, String stream, String callId);
+
void updatePlatformCatchInfo(ParentPlatformCatch parentPlatformCatch);
ParentPlatformCatch queryPlatformCatchInfo(String platformGbId);
void delPlatformCatchInfo(String platformGbId);
- void updatePlatformKeepalive(ParentPlatform parentPlatform);
-
void delPlatformKeepalive(String platformGbId);
-
- void updatePlatformRegister(ParentPlatform parentPlatform);
void delPlatformRegister(String platformGbId);
- void updatePlatformRegisterInfo(String callId, String platformGbId);
+ void updatePlatformRegisterInfo(String callId, PlatformRegisterInfo platformRegisterInfo);
- String queryPlatformRegisterInfo(String callId);
+ PlatformRegisterInfo queryPlatformRegisterInfo(String callId);
void delPlatformRegisterInfo(String callId);
@@ -111,23 +108,6 @@
void clearCatchByDeviceId(String deviceId);
/**
- * 获取mediaServer节点
- * @param mediaServerId
- * @return
- */
-// MediaServerItem getMediaInfo(String mediaServerId);
-
- /**
- * 设置所有设备离线
- */
- void outlineForAll();
-
- /**
- * 获取所有在线的
- */
- List<String> getOnlineForAll();
-
- /**
* 在redis添加wvp的信息
*/
void updateWVPInfo(JSONObject jsonObject, int time);
@@ -137,6 +117,12 @@
* @param jsonObject 消息内容
*/
void sendStreamChangeMsg(String type, JSONObject jsonObject);
+
+ /**
+ * 发送报警消息
+ * @param msg 消息内容
+ */
+ void sendAlarmMsg(AlarmChannelMessage msg);
/**
* 添加流信息到redis
@@ -168,6 +154,8 @@
boolean startDownload(StreamInfo streamInfo, String callId);
StreamInfo queryDownload(String deviceId, String channelId, String stream, String callId);
+
+ boolean stopDownload(String deviceId, String channelId, String stream, String callId);
/**
* 查找第三方系统留下的国标预设值
@@ -210,4 +198,46 @@
void addNetInfo(Map<String, String> networkInterfaces);
+ void sendMobilePositionMsg(JSONObject jsonObject);
+
+ void sendStreamPushRequestedMsg(MessageForPushChannel messageForPushChannel);
+
+ /**
+ * 判断设备状态
+ * @param deviceId 设备ID
+ * @return
+ */
+ public boolean deviceIsOnline(String deviceId);
+
+ /**
+ * 存储推流的鉴权信息
+ * @param app 应用名
+ * @param stream 流
+ * @param streamAuthorityInfo 鉴权信息
+ */
+ void updateStreamAuthorityInfo(String app, String stream, StreamAuthorityInfo streamAuthorityInfo);
+
+ /**
+ * 移除推流的鉴权信息
+ * @param app 应用名
+ * @param streamId 流
+ */
+ void removeStreamAuthorityInfo(String app, String streamId);
+
+ /**
+ * 获取推流的鉴权信息
+ * @param app 应用名
+ * @param stream 流
+ * @return
+ */
+ StreamAuthorityInfo getStreamAuthorityInfo(String app, String stream);
+
+ /**
+ * 发送redis消息 查询所有推流设备的状态
+ */
+ void sendStreamPushRequestedMsgForStatus();
+
+ List<SendRtpItem> querySendRTPServerByChnnelId(String channelId);
+
+ List<SendRtpItem> querySendRTPServerByStream(String stream);
}
--
Gitblit v1.9.3