From eca1e05aeed3c51cce36bbce80c71bc3cbcea87d Mon Sep 17 00:00:00 2001 From: 648540858 <648540858@qq.com> Date: 星期五, 12 十一月 2021 14:40:39 +0800 Subject: [PATCH] 维护目录订阅消息与接口 --- src/main/java/com/genersoft/iot/vmp/storager/IVideoManagerStorager.java | 131 ++++++++++++++++++++++++++++++++++++++----- 1 files changed, 115 insertions(+), 16 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/storager/IVideoManagerStorager.java b/src/main/java/com/genersoft/iot/vmp/storager/IVideoManagerStorager.java index 7656898..931530a 100644 --- a/src/main/java/com/genersoft/iot/vmp/storager/IVideoManagerStorager.java +++ b/src/main/java/com/genersoft/iot/vmp/storager/IVideoManagerStorager.java @@ -1,17 +1,16 @@ package com.genersoft.iot.vmp.storager; -import java.util.List; - -import com.genersoft.iot.vmp.gb28181.bean.Device; -import com.genersoft.iot.vmp.gb28181.bean.DeviceChannel; -import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform; -import com.genersoft.iot.vmp.media.zlm.dto.StreamProxyDto; -import com.genersoft.iot.vmp.vmanager.platform.bean.ChannelReduce; -import com.genersoft.iot.vmp.gb28181.bean.MobilePosition; +import com.genersoft.iot.vmp.gb28181.bean.*; +import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem; +import com.genersoft.iot.vmp.media.zlm.dto.StreamProxyItem; +import com.genersoft.iot.vmp.media.zlm.dto.StreamPushItem; +import com.genersoft.iot.vmp.vmanager.gb28181.platform.bean.ChannelReduce; import com.github.pagehelper.PageInfo; +import java.util.List; + /** - * @Description:瑙嗛璁惧鏁版嵁瀛樺偍鎺ュ彛 + * @description:瑙嗛璁惧鏁版嵁瀛樺偍鎺ュ彛 * @author: swwheihei * @date: 2020骞�5鏈�6鏃� 涓嬪崍2:14:31 */ @@ -99,6 +98,13 @@ public DeviceChannel queryChannel(String deviceId, String channelId); /** + * 鍒犻櫎閫氶亾 + * @param deviceId 璁惧ID + * @param channelId 閫氶亾ID + */ + public int delChannel(String deviceId, String channelId); + + /** * 鑾峰彇澶氫釜璁惧 * @param page 褰撳墠椤垫暟 * @param count 姣忛〉鏁伴噺 @@ -136,6 +142,13 @@ * @return true锛氭洿鏂版垚鍔� false锛氭洿鏂板け璐� */ public boolean outline(String deviceId); + + /** + * 鏇存柊鎵�鏈夎澶囩绾� + * + * @return true锛氭洿鏂版垚鍔� false锛氭洿鏂板け璐� + */ + public boolean outlineForAll(); /** @@ -196,7 +209,7 @@ * @param platformGbId * @return */ - ParentPlatform queryParentPlatById(String platformGbId); + ParentPlatform queryParentPlatByServerGBId(String platformGbId); /** * 鎵�鏈夊钩鍙扮绾� @@ -238,7 +251,7 @@ /** * 娣诲姞Mobile Position璁惧绉诲姩浣嶇疆 - * @param MobilePosition + * @param mobilePosition * @return */ public boolean insertMobilePosition(MobilePosition mobilePosition); @@ -268,14 +281,14 @@ * @param streamProxyDto * @return */ - public int addStreamProxy(StreamProxyDto streamProxyDto); + public boolean addStreamProxy(StreamProxyItem streamProxyDto); /** * 鏇存柊浠ｇ悊娴� * @param streamProxyDto * @return */ - public int updateStreamProxy(StreamProxyDto streamProxyDto); + public boolean updateStreamProxy(StreamProxyItem streamProxyDto); /** * 绉婚櫎浠ｇ悊娴� @@ -290,7 +303,7 @@ * @param enable * @return */ - public List<StreamProxyDto> getStreamProxyListForEnable(boolean enable); + public List<StreamProxyItem> getStreamProxyListForEnable(boolean enable); /** * 鎸夌収鏄痑pp鍜宻tream鑾峰彇浠ｇ悊娴� @@ -298,7 +311,7 @@ * @param stream * @return */ - public StreamProxyDto queryStreamProxy(String app, String stream); + public StreamProxyItem queryStreamProxy(String app, String stream); /** * 鑾峰彇浠ｇ悊娴� @@ -306,5 +319,91 @@ * @param count * @return */ - PageInfo<StreamProxyDto> queryStreamProxyList(Integer page, Integer count); + PageInfo<StreamProxyItem> queryStreamProxyList(Integer page, Integer count); + + /** + * 鏍规嵁鍥芥爣ID鑾峰彇骞冲彴鍏宠仈鐨勭洿鎾祦 + * @param platformId + * @param channelId + * @return + */ + GbStream queryStreamInParentPlatform(String platformId, String channelId); + + /** + * 鑾峰彇骞冲彴鍏宠仈鐨勭洿鎾祦 + * @param platformId + * @return + */ + List<GbStream> queryGbStreamListInPlatform(String platformId); + + /** + * 鎵归噺鏇存柊鎺ㄦ祦鍒楄〃 + * @param streamPushItems + */ + void updateMediaList(List<StreamPushItem> streamPushItems); + + /** + * 鏇存柊鍗曚釜鎺ㄦ祦 + * @param streamPushItem + */ + void updateMedia(StreamPushItem streamPushItem); + + /** + * 绉婚櫎鍗曚釜鎺ㄦ祦 + * @param app + * @param stream + */ + void removeMedia(String app, String stream); + + + /** + * 娓呯┖鎺ㄦ祦鍒楄〃 + */ + void clearMediaList(); + + /** + * 璁剧疆娴佺绾� + * @param app + * @param streamId + */ + void mediaOutline(String app, String streamId); + + /** + * 璁剧疆骞冲彴鍦ㄧ嚎/绂荤嚎 + * @param online + */ + void updateParentPlatformStatus(String platformGbID, boolean online); + + /** + * 鏇存柊濯掍綋鑺傜偣 + * @param mediaServerItem + */ + void updateMediaServer(MediaServerItem mediaServerItem); + + /** + * 鏍规嵁濯掍綋ID鑾峰彇鍚敤/涓嶅惎鐢ㄧ殑浠ｇ悊鍒楄〃 + * @param id 濯掍綋ID + * @param b 鍚敤/涓嶅惎鐢� + * @return + */ + List<StreamProxyItem> getStreamProxyListForEnableInMediaServer(String id, boolean b); + + /** + * 鏍规嵁閫氶亾ID鑾峰彇鍏舵墍鍦ㄨ澶� + * @param channelId 閫氶亾ID + * @return + */ + Device queryVideoDeviceByChannelId(String channelId); + + /** + * 閫氶亾涓婄嚎 + * @param channelId 閫氶亾ID + */ + void deviceChannelOnline(String deviceId, String channelId); + + /** + * 閫氶亾绂荤嚎 + * @param channelId 閫氶亾ID + */ + void deviceChannelOffline(String deviceId, String channelId); } -- Gitblit v1.8.0