支持从redis消息更新推流设备状态

648540858

2022-07-12 81f69eb6f47b69cd89da7621889629f4f456dce1

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

@@ -5,7 +5,6 @@
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,22 +25,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);

   /**
    * 添加设备通道
@@ -90,16 +73,10 @@
    * @param count 每页数量
    * @return
    */
   public PageInfo queryChannelsByDeviceId(String deviceId, String query, Boolean hasSubChannel, Boolean online, int page, int count);
   public PageInfo 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);

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

   /**
    * 获取某个设备的通道列表
@@ -180,7 +157,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);


   /**
@@ -285,7 +262,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);

   /**
    * 查询最新移动位置
@@ -380,20 +357,31 @@


   /**
    * 获取但个推流
    * @param app
    * @param stream
    * @return
    */
   StreamPushItem getMedia(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);

@@ -401,10 +389,9 @@
    * 根据媒体ID获取启用/不启用的代理列表
    * @param id 媒体ID
    * @param enable 启用/不启用
    * @param status 状态
    * @return
    */
   List<StreamProxyItem> getStreamProxyListForEnableInMediaServer(String id,  boolean enable, boolean status);
   List<StreamProxyItem> getStreamProxyListForEnableInMediaServer(String id,  boolean enable);

   /**
    * 根据通道ID获取其所在设备
@@ -478,5 +465,5 @@

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

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