| | |
| | | } |
| | | |
| | | @Override |
| | | public PageInfo<StreamPushItem> getPushList(Integer page, Integer count) { |
| | | public PageInfo<StreamPushItem> getPushList(Integer page, Integer count, String query, Boolean pushing, String mediaServerId) { |
| | | PageHelper.startPage(page, count); |
| | | List<StreamPushItem> all = streamPushMapper.selectAll(); |
| | | List<StreamPushItem> all = streamPushMapper.selectAllForList(query, pushing, mediaServerId); |
| | | return new PageInfo<>(all); |
| | | } |
| | | |
| | | @Override |
| | | public List<StreamPushItem> getPushList(String mediaServerId) { |
| | | return streamPushMapper.selectAllByMediaServerId(mediaServerId); |
| | | return streamPushMapper.selectAllByMediaServerIdWithOutGbID(mediaServerId); |
| | | } |
| | | |
| | | @Override |
| | |
| | | Map<String, MediaItem> streamInfoPushItemMap = new HashMap<>(); |
| | | if (pushList.size() > 0) { |
| | | for (StreamPushItem streamPushItem : pushList) { |
| | | pushItemMap.put(streamPushItem.getApp() + streamPushItem.getStream(), streamPushItem); |
| | | if (StringUtils.isEmpty(streamPushItem.getGbId())) { |
| | | pushItemMap.put(streamPushItem.getApp() + streamPushItem.getStream(), streamPushItem); |
| | | } |
| | | } |
| | | } |
| | | if (mediaItems.size() > 0) { |
| | |
| | | |
| | | @Override |
| | | public void zlmServerOffline(String mediaServerId) { |
| | | List<StreamPushItem> streamPushItems = streamPushMapper.selectAllByMediaServerId(mediaServerId); |
| | | List<StreamPushItem> streamPushItems = streamPushMapper.selectAllByMediaServerIdWithOutGbID(mediaServerId); |
| | | // 移除没有GBId的推流 |
| | | streamPushMapper.deleteWithoutGBId(mediaServerId); |
| | | gbStreamMapper.deleteWithoutGBId("push", mediaServerId); |