648540858
2022-01-25 1dbb559b388831b5f15e690d0b33d24b1faaa983
src/main/java/com/genersoft/iot/vmp/storager/IVideoManagerStorager.java
@@ -4,6 +4,7 @@
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.gb28181.platform.bean.ChannelReduce;
import com.github.pagehelper.PageInfo;
@@ -50,6 +51,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
@@ -81,6 +90,8 @@
    * @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);
   /**
    * 获取某个设备的通道列表
@@ -89,6 +100,7 @@
    * @return
    */
   public List<DeviceChannel> queryChannelsByDeviceId(String deviceId);
   public List<DeviceChannel> queryOnlineChannelsByDeviceId(String deviceId);
   /**
    * 获取某个设备的通道
@@ -233,7 +245,7 @@
    * @param channelReduces
    * @return
    */
   int updateChannelForGB(String platformId, List<ChannelReduce> channelReduces);
   int updateChannelForGB(String platformId, List<ChannelReduce> channelReduces, String catalogId);
   /**
    *  移除上级平台的通道信息
@@ -245,6 +257,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);
@@ -353,7 +368,7 @@
    * @param app
    * @param stream
    */
   void removeMedia(String app, String stream);
   int removeMedia(String app, String stream);
   /**
@@ -366,7 +381,7 @@
    * @param app
    * @param streamId
    */
   void mediaOutline(String app, String streamId);
   int mediaOutline(String app, String streamId);
   /**
    * 设置平台在线/离线
@@ -406,4 +421,53 @@
    * @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);
}