lawrencehj
2021-04-15 a70e327a8efaf38d74911ea568419a087fbd235a
src/main/java/com/genersoft/iot/vmp/storager/IVideoManagerStorager.java
@@ -2,12 +2,10 @@
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.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;
/**    
@@ -238,7 +236,7 @@
   /**
    * 添加Mobile Position设备移动位置
    * @param MobilePosition
    * @param mobilePosition
    * @return
    */
   public boolean insertMobilePosition(MobilePosition mobilePosition);
@@ -268,14 +266,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 +288,7 @@
    * @param enable
    * @return
    */
   public List<StreamProxyDto> getStreamProxyListForEnable(boolean enable);
   public List<StreamProxyItem> getStreamProxyListForEnable(boolean enable);
   /**
    * 按照是app和stream获取代理流
@@ -298,7 +296,7 @@
    * @param stream
    * @return
    */
   public StreamProxyDto queryStreamProxy(String app, String stream);
   public StreamProxyItem queryStreamProxy(String app, String stream);
   /**
    * 获取代理流
@@ -306,5 +304,52 @@
    * @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);
}