添加推流列表和拉流代理，下一步与国标关联

panlinlin

2021-03-30 56859d09df8d4226882d43934acf32d60a3b51d7

 src/main/java/com/genersoft/iot/vmp/storager/IVideoManagerStorager.java

@@ -1,20 +1,21 @@
package com.genersoft.iot.vmp.storager;



import java.util.List;

import java.util.Map;



import com.alibaba.fastjson.JSONObject;

import com.genersoft.iot.vmp.common.PageResult;

import com.genersoft.iot.vmp.common.StreamInfo;

import com.genersoft.iot.vmp.conf.MediaServerConfig;

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.github.pagehelper.PageInfo;



/**    

 * @Description:视频设备数据存储接口

 * @author: swwheihei

 * @date:   2020年5月6日 下午2:14:31     

 */

@SuppressWarnings("rawtypes")

public interface IVideoManagerStorager {



   /**   

@@ -48,6 +49,21 @@
    * @param channel 通道

    */

   public void updateChannel(String deviceId, DeviceChannel channel);



   /**

    * 开始播放

    * @param deviceId 设备id

    * @param channelId 通道ID

    * @param streamId 流地址

    */

   public void startPlay(String deviceId, String channelId, String streamId);



   /**

    * 停止播放

    * @param deviceId 设备id

    * @param channelId 通道ID

    */

   public void stopPlay(String deviceId, String channelId);

   

   /**   

    * 获取设备

@@ -65,7 +81,7 @@
    * @param count 每页数量

    * @return

    */

   public PageResult queryChannelsByDeviceId(String deviceId, String query, Boolean hasSubChannel, String online, int page, int count);

   public PageInfo queryChannelsByDeviceId(String deviceId, String query, Boolean hasSubChannel, Boolean online, int page, int count);



   /**

    * 获取某个设备的通道列表

@@ -82,13 +98,13 @@
    */

   public DeviceChannel queryChannel(String deviceId, String channelId);



   /**   
   /**

    * 获取多个设备

    * 
    * @param deviceIds 设备ID数组

    * @param page 当前页数

    * @param count 每页数量

    * @return List<Device> 设备对象数组

    */

   public PageResult<Device> queryVideoDeviceList(String[] deviceIds, int page, int count);

   public PageInfo<Device> queryVideoDeviceList(int page, int count);



   /**

    * 获取多个设备

@@ -131,7 +147,7 @@
    * @param count

    * @return

    */

    PageResult querySubChannels(String deviceId, String channelId, String query, Boolean hasSubChannel, String online, int page, int count);

   PageInfo querySubChannels(String deviceId, String channelId, String query, Boolean hasSubChannel, String online, int page, int count);





   /**

@@ -140,4 +156,155 @@
    */

   void cleanChannelsForDevice(String deviceId);





   /**

    * 更新上级平台

    * @param parentPlatform

    */

   boolean updateParentPlatform(ParentPlatform parentPlatform);





   /**

    * 添加上级平台

    * @param parentPlatform

    */

   boolean addParentPlatform(ParentPlatform parentPlatform);



   /**

    * 删除上级平台

    * @param parentPlatform

    */

   boolean deleteParentPlatform(ParentPlatform parentPlatform);





   /**

    * 分页获取上级平台

    * @param page

    * @param count

    * @return

    */

   PageInfo<ParentPlatform> queryParentPlatformList(int page, int count);



   /**

    * 获取所有已启用的平台

    * @return

    */

   List<ParentPlatform> queryEnableParentPlatformList(boolean enable);



   /**

    * 获取上级平台

    * @param platformGbId

    * @return

    */

   ParentPlatform queryParentPlatById(String platformGbId);



   /**

    * 所有平台离线

    */

   void outlineForAllParentPlatform();



   /**

    * 查询通道信息，不区分设备(已关联平台或全部)

    */

   PageInfo<ChannelReduce> queryAllChannelList(int page, int count, String query, Boolean online, Boolean channelType, String platformId, Boolean inPlatform);



   /**

    * 查询设备的通道信息

    */

   List<ChannelReduce> queryChannelListInParentPlatform(String platformId);





   /**

    * 更新上级平台的通道信息

    * @param platformId

    * @param channelReduces

    * @return

    */

   int updateChannelForGB(String platformId, List<ChannelReduce> channelReduces);



   /**

    *  移除上级平台的通道信息

    * @param platformId

    * @param channelReduces

    * @return

    */

   int delChannelForGB(String platformId, List<ChannelReduce> channelReduces);





    DeviceChannel queryChannelInParentPlatform(String platformId, String channelId);



    Device queryVideoDeviceByPlatformIdAndChannelId(String platformId, String channelId);





   /**

    * 添加Mobile Position设备移动位置

    * @param MobilePosition

    * @return

    */

   public boolean insertMobilePosition(MobilePosition mobilePosition);



   /**

    * 查询移动位置轨迹

    * @param deviceId

    * @param startTime

    * @param endTime

    */

   public List<MobilePosition> queryMobilePositions(String deviceId, String startTime, String endTime);



   /**

    * 查询最新移动位置

    * @param deviceId

    */

   public MobilePosition queryLatestPosition(String deviceId);



   /**

    * 删除指定设备的所有移动位置

    * @param deviceId

    */

   public int clearMobilePositionsByDeviceId(String deviceId);



   /**

    * 新增代理流

    * @param streamProxyDto

    * @return

    */

   public int addStreamProxy(StreamProxyDto streamProxyDto);



   /**

    * 更新代理流

    * @param streamProxyDto

    * @return

    */

   public int updateStreamProxy(StreamProxyDto streamProxyDto);



   /**

    * 移除代理流

    * @param app

    * @param stream

    * @return

    */

   public int deleteStreamProxy(String app, String stream);



   /**

    * 按照是否启用获取代理流

    * @param enable

    * @return

    */

   public List<StreamProxyDto> getStreamProxyListForEnable(boolean enable);



   /**

    * 按照是app和stream获取代理流

    * @param app

    * @param stream

    * @return

    */

   public StreamProxyDto queryStreamProxy(String app, String stream);



   /**

    * 获取代理流

    * @param page

    * @param count

    * @return

    */

   PageInfo<StreamProxyDto> queryStreamProxyList(Integer page, Integer count);

}