Merge branch 'wvp-28181-2.0'

648540858

2023-02-22 019d95cfba07f0231bd5b385f6736883c6e90623

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

@@ -2,10 +2,8 @@

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

@@ -26,38 +24,6 @@
    * @return true:存在  false：不存在
    */
   public boolean exists(String deviceId);
	
   /**   
    * 视频设备创建
    * 
    * @param device 设备对象
    * @return true：创建成功  false：创建失败
    */
   public boolean create(Device device);
	
   /**   
    * 视频设备更新
    * 
    * @param device 设备对象
    * @return true：创建成功  false：创建失败
    */
   public boolean updateDevice(Device device);

   /**
    * 添加设备通道
    *
    * @param deviceId 设备id
    * @param channel 通道
    */
   public void updateChannel(String deviceId, DeviceChannel channel);

   /**
    * 批量添加设备通道
    *
    * @param deviceId 设备id
    * @param channels 多个通道
    */
   public int updateChannels(String deviceId, List<DeviceChannel> channels);

   /**
    * 开始播放
@@ -90,16 +56,10 @@
    * @param count 每页数量
    * @return
    */
   public PageInfo queryChannelsByDeviceId(String deviceId, String query, Boolean hasSubChannel, Boolean online, int page, int count);
   public PageInfo<DeviceChannel> queryChannelsByDeviceId(String deviceId, String query, Boolean hasSubChannel, Boolean online, Boolean catalogUnderDevice, int page, int count);
   
   public List<DeviceChannel> queryChannelsByDeviceIdWithStartAndLimit(String deviceId, String query, Boolean hasSubChannel, Boolean online, int start, int limit);
   public List<DeviceChannel> queryChannelsByDeviceIdWithStartAndLimit(String deviceId, String query, Boolean hasSubChannel, Boolean online, int start, int limit,List<String> channelIds);

   /**
    *  获取某个设备的通道树
    * @param deviceId 设备ID
    * @return
    */
   List<DeviceChannelTree> tree(String deviceId);

   /**
    * 获取某个设备的通道列表
@@ -107,7 +67,7 @@
    * @param deviceId 设备ID
    * @return
    */
   public List<DeviceChannel> queryChannelsByDeviceId(String deviceId);
   public List<DeviceChannel> queryChannelsByDeviceId(String deviceId,Boolean online,List<String> channelIds);
   public List<DeviceChannel> queryOnlineChannelsByDeviceId(String deviceId);

   /**
@@ -130,45 +90,15 @@
    * @param count 每页数量
    * @return List<Device> 设备对象数组
    */
   public PageInfo<Device> queryVideoDeviceList(int page, int count);
   public PageInfo<Device> queryVideoDeviceList(int page, int count,Boolean online);

   /**
    * 获取多个设备
    *
    * @return List<Device> 设备对象数组
    */
   public List<Device> queryVideoDeviceList();
   public List<Device> queryVideoDeviceList(Boolean online);

   /**   
    * 删除设备
    * 
    * @param deviceId 设备ID
    * @return true：删除成功  false：删除失败
    */
   public boolean delete(String deviceId);
	
   /**   
    * 更新设备在线
    * 
    * @param deviceId 设备ID
    * @return true：更新成功  false：更新失败
    */
   public boolean online(String deviceId);
	
   /**   
    * 更新设备离线
    * 
    * @param deviceId 设备ID
    * @return true：更新成功  false：更新失败
    */
   public boolean outline(String deviceId);

   /**
    * 更新所有设备离线
    *
    * @return true：更新成功  false：更新失败
    */
   public boolean outlineForAll();


   /**
@@ -180,7 +110,7 @@
    * @param count
    * @return
    */
   PageInfo 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, Boolean online, int page, int count);


   /**
@@ -208,15 +138,6 @@
    * @param parentPlatform
    */
   boolean deleteParentPlatform(ParentPlatform parentPlatform);


   /**
    * 分页获取上级平台
    * @param page
    * @param count
    * @return
    */
   PageInfo<ParentPlatform> queryParentPlatformList(int page, int count);

   /**
    * 获取所有已启用的平台
@@ -247,13 +168,6 @@
   List<DeviceChannelInPlatform> queryChannelListInParentPlatform(String platformId);


   /**
    * 更新上级平台的通道信息
    * @param platformId
    * @param channelReduces
    * @return
    */
   int updateChannelForGB(String platformId, List<ChannelReduce> channelReduces, String catalogId);

   /**
    *  移除上级平台的通道信息
@@ -271,7 +185,13 @@

    Device queryVideoDeviceByPlatformIdAndChannelId(String platformId, String channelId);


   /**
    * 针对deviceinfo指令的查询接口
    * @param platformId 平台id
    * @param channelId 通道id
    * @return 设备信息
    */
   Device queryDeviceInfoByPlatformIdAndChannelId(String platformId, String channelId);
   /**
    * 添加Mobile Position设备移动位置
    * @param mobilePosition
@@ -285,7 +205,7 @@
    * @param startTime
    * @param endTime
    */
   public List<MobilePosition> queryMobilePositions(String deviceId, String startTime, String endTime);
   public List<MobilePosition> queryMobilePositions(String deviceId, String channelId, String startTime, String endTime);

   /**
    * 查询最新移动位置
@@ -298,20 +218,6 @@
    * @param deviceId
    */
   public int clearMobilePositionsByDeviceId(String deviceId);

   /**
    * 新增代理流
    * @param streamProxyDto
    * @return
    */
   public boolean addStreamProxy(StreamProxyItem streamProxyDto);

   /**
    * 更新代理流
    * @param streamProxyDto
    * @return
    */
   public boolean updateStreamProxy(StreamProxyItem streamProxyDto);

   /**
    * 移除代理流
@@ -357,19 +263,7 @@
    * @param platformId
    * @return
    */
   List<GbStream> queryGbStreamListInPlatform(String platformId);

   /**
    * 批量更新推流列表
    * @param streamPushItems
    */
   void updateMediaList(List<StreamPushItem> streamPushItems);

   /**
    * 更新单个推流
    * @param streamPushItem
    */
   void updateMedia(StreamPushItem streamPushItem);
   List<DeviceChannel> queryGbStreamListInPlatform(String platformId);

   /**
    * 移除单个推流
@@ -378,22 +272,18 @@
    */
   int removeMedia(String app, String stream);


   /**
    * 清空推流列表
    */
   void clearMediaList();

   /**
    * 设置流离线
    * @param app
    * @param streamId
    */
   int mediaOutline(String app, String streamId);
   int mediaOffline(String app, String streamId);

   /**
    * 设置流上线
    */
   int mediaOnline(String app, String streamId);

   /**
    * 设置平台在线/离线
    * @param online
    */
   void updateParentPlatformStatus(String platformGbID, boolean online);

@@ -439,6 +329,8 @@
    */
   boolean resetChannels(String deviceId, List<DeviceChannel> deviceChannelList);

   boolean updateChannels(String deviceId, List<DeviceChannel> deviceChannelList);

   /**
    * 获取目录信息
    * @param platformId
@@ -457,7 +349,7 @@

   int setDefaultCatalog(String platformId, String catalogId);

   List<PlatformCatalog> queryCatalogInPlatform(String serverGBId);
   List<DeviceChannel> queryCatalogInPlatform(String serverGBId);

    int delRelation(PlatformCatalog platformCatalog);

@@ -477,5 +369,9 @@

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

    void updateChannelPotion(String deviceId, String channelId, double longitude, double latitude);
    void updateChannelPosition(DeviceChannel deviceChannel);

   void cleanContentForPlatform(String serverGBId);

   List<DeviceChannel> queryChannelWithCatalog(String serverGBId);
}