From dd0a234c051c451143137ebb5bfbd2d789a6d2f5 Mon Sep 17 00:00:00 2001 From: Lawrence <1934378145@qq.com> Date: 星期二, 12 一月 2021 13:48:42 +0800 Subject: [PATCH] 进一步优化录像列表获取算法 --- src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java | 39 +++++++++++++++++++++++++++++++++++++-- 1 files changed, 37 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java b/src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java index 92de14a..546a3e4 100644 --- a/src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java +++ b/src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java @@ -9,6 +9,7 @@ import com.genersoft.iot.vmp.storager.dao.DeviceChannelMapper; import com.genersoft.iot.vmp.storager.dao.DeviceMapper; import com.genersoft.iot.vmp.storager.dao.ParentPlatformMapper; +import com.genersoft.iot.vmp.vmanager.platform.bean.ChannelReduce; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import org.springframework.beans.factory.annotation.Autowired; @@ -16,6 +17,7 @@ import com.genersoft.iot.vmp.gb28181.bean.Device; import com.genersoft.iot.vmp.storager.IVideoManagerStorager; +import org.springframework.transaction.annotation.Transactional; /** * @Description:瑙嗛璁惧鏁版嵁瀛樺偍-jdbc瀹炵幇 @@ -33,6 +35,7 @@ @Autowired private ParentPlatformMapper platformMapper; + @Autowired private IRedisCatchStorage redisCatchStorage; @@ -92,6 +95,16 @@ } } + @Override + public void startPlay(String deviceId, String channelId, String streamId) { + deviceChannelMapper.startPlay(deviceId, channelId, streamId); + } + + @Override + public void stopPlay(String deviceId, String channelId) { + deviceChannelMapper.stopPlay(deviceId, channelId); + } + /** * 鑾峰彇璁惧 * @@ -110,8 +123,6 @@ List<DeviceChannel> all = deviceChannelMapper.queryChannelsByDeviceId(deviceId, null, query, hasSubChannel, online); return new PageInfo<>(all); } - - @Override public List<DeviceChannel> queryChannelsByDeviceId(String deviceId) { @@ -252,5 +263,29 @@ return platformMapper.getParentPlatById(platformGbId); } + @Override + public List<ParentPlatform> queryEnableParentPlatformList(boolean enable) { + return platformMapper.getEnableParentPlatformList(enable); + } + @Override + public void outlineForAllParentPlatform() { + platformMapper.outlineForAllParentPlatform(); + } + + + @Override + public PageInfo<ChannelReduce> queryChannelListInAll(int page, int count, String query, Boolean online, + Boolean channelType, String parentChannelId) { + PageHelper.startPage(page, count); + List<ChannelReduce> all = deviceChannelMapper.queryChannelListInAll(query, online, channelType, parentChannelId); + return new PageInfo<>(all); + } + + + @Transactional + @Override + public int updateChannelForGB(String platformId, List<ChannelReduce> channelReduces) { + return 0; + } } -- Gitblit v1.8.0