测试页兼容流媒体1.8.4

liusuyi

2024-07-11 1fe9f918a907193e84e16de1c4c2d51c2f25c5ec

 ard-work/src/main/java/com/ruoyi/media/controller/MediaController.java

@@ -4,10 +4,12 @@
import com.ruoyi.common.annotation.Anonymous;

import com.ruoyi.common.core.controller.BaseController;

import com.ruoyi.common.core.domain.AjaxResult;

import com.ruoyi.common.core.domain.BaseEntity;

import com.ruoyi.common.core.page.TableDataInfo;

import com.ruoyi.common.utils.StringUtils;

import com.ruoyi.common.utils.uuid.IdUtils;

import com.ruoyi.media.domain.Config;

import com.ruoyi.media.domain.Paths;

import com.ruoyi.media.domain.StreamInfo;

import com.ruoyi.media.domain.Vtdu;

import com.ruoyi.media.service.IMediaService;

@@ -112,7 +114,7 @@
    @PreAuthorize("@ss.hasPermi('media:stream:remove')")

    @DeleteMapping("/{sessionId}")

    public AjaxResult removePullStreamSession(@PathVariable String sessionId) {

        List<StreamInfo> pullStreamList = mediaService.getPullStreamList();

        List<StreamInfo> pullStreamList = mediaService.getPullStreamList(1,1000);

        StreamInfo streamInfo = pullStreamList.stream()

                .filter(object -> object.getId().equals(sessionId))

                .collect(Collectors.toList()).get(0);

@@ -143,9 +145,9 @@
    @GetMapping("/path/list")

    @ApiOperation("获取当前通道列表")

    @ApiOperationSupport(order = 5)

    public TableDataInfo getPaths() {

    public TableDataInfo getPaths(Integer pageNum,Integer pageSize) {

        startPage();

        return getDataTable(mediaService.paths());

        return getDataTable(mediaService.paths(pageNum,pageSize));

    }



    /**

@@ -154,7 +156,7 @@
    @GetMapping("/getRtspSessionById")

    @ApiOperation("按ID查询拉流详情")

    public AjaxResult getRtspSessionById(String sessionId) {

        List<StreamInfo> pullStreamList = mediaService.getPullStreamList();

        List<StreamInfo> pullStreamList = mediaService.getPullStreamList(1,1000);

        StreamInfo streamInfo = pullStreamList.stream()

                .filter(object -> object.getId().equals(sessionId))

                .collect(Collectors.toList()).get(0);

@@ -176,9 +178,9 @@
    @GetMapping("/pushList")

    @ApiOperation("获取推流列表")

    @ApiOperationSupport(order = 6)

    public TableDataInfo getPushStreamList() {

    public TableDataInfo getPushStreamList(Integer pageNum,Integer pageSize) {

        startPage();

        return getDataTable(mediaService.getPushStreamList());

        return getDataTable(mediaService.getPushStreamList(pageNum,pageSize));

    }



    /**

@@ -188,18 +190,9 @@
    @GetMapping("/pullList")

    @ApiOperation("获取拉流列表")

    @ApiOperationSupport(order = 7)

    public TableDataInfo getPullStreamList() {

    public TableDataInfo getPullStreamList(Integer pageNum,Integer pageSize) {

        startPage();

        return getDataTable(mediaService.getPullStreamList());

        return getDataTable(mediaService.getPullStreamList(pageNum,pageSize));

    }



    /**

     * 配置流媒体参数

     */

    @PostMapping("/setConfig")

    @ApiOperation("配置流媒体参数")

    @ApiOperationSupport(order = 8)

    public AjaxResult setConfig(@RequestBody Config config) {

        return AjaxResult.success(mediaService.setConfig(config));

    }

}