Merge branch '648540858:wvp-28181-2.0' into wvp-28181-2.0

sc.dm

2022-03-10 4abbf4df07f02c0c94baa2787fdcf4a14dcb3463

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

@@ -1,14 +1,19 @@
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.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.service.bean.GPSMsgInfo;

import com.genersoft.iot.vmp.storager.dao.dto.ChannelSourceInfo;

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     

 */

@@ -48,6 +53,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

@@ -79,6 +92,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);



   /**

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

@@ -87,6 +109,7 @@
    * @return

    */

   public List<DeviceChannel> queryChannelsByDeviceId(String deviceId);

   public List<DeviceChannel> queryOnlineChannelsByDeviceId(String deviceId);



   /**

    * 获取某个设备的通道

@@ -94,6 +117,13 @@
    * @param channelId 通道ID

    */

   public DeviceChannel queryChannel(String deviceId, String channelId);



   /**

    * 删除通道

    * @param deviceId 设备ID

    * @param channelId 通道ID

    */

   public int delChannel(String deviceId, String channelId);



   /**

    * 获取多个设备

@@ -134,6 +164,13 @@
    */

   public boolean outline(String deviceId);



   /**

    * 更新所有设备离线

    *

    * @return true：更新成功  false：更新失败

    */

   public boolean outlineForAll();





   /**

    * 查询子设备

@@ -153,10 +190,93 @@
    */

   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 queryParentPlatByServerGBId(String platformGbId);



   /**

    * 所有平台离线

    */

   void outlineForAllParentPlatform();



   /**

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

    */

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



   /**

    * 查询设备的通道信息

    */

   List<ChannelReduce> queryChannelListInParentPlatform(String platformId);





   /**

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

    * @param platformId

    * @param channelReduces

    * @return

    */

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



   /**

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

    * @param platformId

    * @param channelReduces

    * @return

    */

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





    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);





   /**

    * 添加Mobile Position设备移动位置

    * @param MobilePosition

    * @return 
    * @param mobilePosition

    * @return

    */

   public boolean insertMobilePosition(MobilePosition mobilePosition);



@@ -179,4 +299,183 @@
    * @param deviceId

    */

   public int clearMobilePositionsByDeviceId(String deviceId);



   /**

    * 新增代理流

    * @param streamProxyDto

    * @return

    */

   public boolean addStreamProxy(StreamProxyItem streamProxyDto);



   /**

    * 更新代理流

    * @param streamProxyDto

    * @return

    */

   public boolean updateStreamProxy(StreamProxyItem streamProxyDto);



   /**

    * 移除代理流

    * @param app

    * @param stream

    * @return

    */

   public int deleteStreamProxy(String app, String stream);



   /**

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

    * @param enable

    * @return

    */

   public List<StreamProxyItem> getStreamProxyListForEnable(boolean enable);



   /**

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

    * @param app

    * @param stream

    * @return

    */

   public StreamProxyItem queryStreamProxy(String app, String stream);



   /**

    * 获取代理流

    * @param page

    * @param count

    * @return

    */

   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

    */

   int removeMedia(String app, String stream);





   /**

    * 清空推流列表

    */

   void clearMediaList();



   /**

    * 设置流离线

    * @param app

    * @param streamId

    */

   int mediaOutline(String app, String streamId);



   /**

    * 设置平台在线/离线

    * @param online

    */

   void updateParentPlatformStatus(String platformGbID, boolean online);



   /**

    * 根据媒体ID获取启用/不启用的代理列表

    * @param id 媒体ID

    * @param enable 启用/不启用

    * @param status 状态

    * @return

    */

   List<StreamProxyItem> getStreamProxyListForEnableInMediaServer(String id,  boolean enable, boolean status);



   /**

    * 根据通道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);



   List<ChannelSourceInfo> getChannelSource(String platformId, String gbId);

}