648540858
2022-02-28 9c5b1060af4e6c468b2cf95fbb9ec6d0a05fad5c
src/main/java/com/genersoft/iot/vmp/storager/IVideoManagerStorager.java
@@ -1,17 +1,18 @@
package com.genersoft.iot.vmp.storager;
import java.util.List;
import com.genersoft.iot.vmp.gb28181.bean.*;
import com.genersoft.iot.vmp.media.zlm.ZLMServerConfig;
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.service.bean.GPSMsgInfo;
import com.genersoft.iot.vmp.vmanager.bean.DeviceChannelTree;
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     
 */
@@ -51,6 +52,14 @@
   public void updateChannel(String deviceId, DeviceChannel channel);
   /**
    * 批量添加设备通道
    *
    * @param deviceId 设备id
    * @param channels 多个通道
    */
   public int updateChannels(String deviceId, List<DeviceChannel> channels);
   /**
    * 开始播放
    * @param deviceId 设备id
    * @param channelId 通道ID
@@ -82,6 +91,15 @@
    * @return
    */
   public PageInfo queryChannelsByDeviceId(String deviceId, String query, Boolean hasSubChannel, Boolean online, int page, int count);
   public List<DeviceChannel> queryChannelsByDeviceIdWithStartAndLimit(String deviceId, String query, Boolean hasSubChannel, Boolean online, int start, int limit);
   /**
    *  获取某个设备的通道树
    * @param deviceId 设备ID
    * @return
    */
   List<DeviceChannelTree> tree(String deviceId);
   /**
    * 获取某个设备的通道列表
@@ -90,6 +108,7 @@
    * @return
    */
   public List<DeviceChannel> queryChannelsByDeviceId(String deviceId);
   public List<DeviceChannel> queryOnlineChannelsByDeviceId(String deviceId);
   /**
    * 获取某个设备的通道
@@ -97,6 +116,13 @@
    * @param channelId 通道ID
    */
   public DeviceChannel queryChannel(String deviceId, String channelId);
   /**
    * 删除通道
    * @param deviceId 设备ID
    * @param channelId 通道ID
    */
   public int delChannel(String deviceId, String channelId);
   /**
    * 获取多个设备
@@ -213,7 +239,7 @@
   /**
    * 查询通道信息,不区分设备(已关联平台或全部)
    */
   PageInfo<ChannelReduce> queryAllChannelList(int page, int count, String query, Boolean online, Boolean channelType, String platformId, Boolean inPlatform);
   PageInfo<ChannelReduce> queryAllChannelList(int page, int count, String query, Boolean online, Boolean channelType, String platformId, String catalogId);
   /**
    * 查询设备的通道信息
@@ -227,7 +253,7 @@
    * @param channelReduces
    * @return
    */
   int updateChannelForGB(String platformId, List<ChannelReduce> channelReduces);
   int updateChannelForGB(String platformId, List<ChannelReduce> channelReduces, String catalogId);
   /**
    *  移除上级平台的通道信息
@@ -239,6 +265,9 @@
    DeviceChannel queryChannelInParentPlatform(String platformId, String channelId);
    List<PlatformCatalog> queryChannelInParentPlatformAndCatalog(String platformId, String catalogId);
    List<PlatformCatalog> queryStreamInParentPlatformAndCatalog(String platformId, String catalogId);
    Device queryVideoDeviceByPlatformIdAndChannelId(String platformId, String channelId);
@@ -347,7 +376,7 @@
    * @param app
    * @param stream
    */
   void removeMedia(String app, String stream);
   int removeMedia(String app, String stream);
   /**
@@ -360,7 +389,7 @@
    * @param app
    * @param streamId
    */
   void mediaOutline(String app, String streamId);
   int mediaOutline(String app, String streamId);
   /**
    * 设置平台在线/离线
@@ -369,10 +398,81 @@
   void updateParentPlatformStatus(String platformGbID, boolean online);
   /**
    * 更新媒体节点
    * @param mediaServerItem
    * 根据媒体ID获取启用/不启用的代理列表
    * @param id 媒体ID
    * @param enable 启用/不启用
    * @param status 状态
    * @return
    */
   void updateMediaServer(MediaServerItem mediaServerItem);
   List<StreamProxyItem> getStreamProxyListForEnableInMediaServer(String id,  boolean enable, boolean status);
   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);
   /**
    * 通过app与stream获取StreamProxy
    * @param app
    * @param streamId
    * @return
    */
    StreamProxyItem getStreamProxyByAppAndStream(String app, String streamId);
   /**
    * catlog查询结束后完全重写通道信息
    * @param deviceId
    * @param deviceChannelList
    */
   boolean resetChannels(String deviceId, List<DeviceChannel> deviceChannelList);
   /**
    * 获取目录信息
    * @param platformId
    * @param parentId
    * @return
    */
    List<PlatformCatalog> getChildrenCatalogByPlatform(String platformId, String parentId);
   int addCatalog(PlatformCatalog platformCatalog);
   PlatformCatalog getCatalog(String id);
   int delCatalog(String id);
   int updateCatalog(PlatformCatalog platformCatalog);
   int setDefaultCatalog(String platformId, String catalogId);
   List<PlatformCatalog> queryCatalogInPlatform(String serverGBId);
    int delRelation(PlatformCatalog platformCatalog);
   int updateStreamGPS(List<GPSMsgInfo> gpsMsgInfo);
   List<ParentPlatform> queryPlatFormListForGBWithGBId(String channelId, List<String> platforms);
   List<ParentPlatform> queryPlatFormListForStreamWithGBId(String app, String stream, List<String> platforms);
   GbStream getGbStream(String app, String streamId);
   void delCatalogByPlatformId(String serverGBId);
   void delRelationByPlatformId(String serverGBId);
    PlatformCatalog queryDefaultCatalogInPlatform(String platformId);
}