| | |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.genersoft.iot.vmp.common.StreamInfo; |
|---|
| | | import com.genersoft.iot.vmp.gb28181.bean.GbStream; |
|---|
| | | import com.genersoft.iot.vmp.gb28181.bean.PlatformGbStream; |
|---|
| | | import com.genersoft.iot.vmp.service.IStreamPushService; |
|---|
| | | import com.genersoft.iot.vmp.storager.IRedisCatchStorage; |
|---|
| | | import com.genersoft.iot.vmp.vmanager.service.IMediaService; |
|---|
| | | import com.genersoft.iot.vmp.vmanager.service.IStreamProxyService; |
|---|
| | | import com.genersoft.iot.vmp.service.IMediaService; |
|---|
| | | import com.genersoft.iot.vmp.service.IStreamProxyService; |
|---|
| | | import com.genersoft.iot.vmp.storager.IVideoManagerStorager; |
|---|
| | | import io.swagger.annotations.Api; |
|---|
| | | import io.swagger.annotations.ApiImplicitParam; |
|---|
| | | import io.swagger.annotations.ApiImplicitParams; |
|---|
| | | import io.swagger.annotations.ApiOperation; |
|---|
| | | import org.slf4j.Logger; |
|---|
| | | import org.slf4j.LoggerFactory; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | |
|---|
| | | import org.springframework.web.bind.annotation.*; |
|---|
| | | |
|---|
| | | |
|---|
| | | @Api(tags = "媒体流相关") |
|---|
| | | @Controller |
|---|
| | | @CrossOrigin |
|---|
| | | @RequestMapping(value = "/api/media") |
|---|
| | |
|---|
| | | private final static Logger logger = LoggerFactory.getLogger(MediaController.class); |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private IRedisCatchStorage redisCatchStorage; |
|---|
| | | private IVideoManagerStorager storager; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private IStreamProxyService streamProxyService; |
|---|
| | | private IStreamPushService streamPushService; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private IMediaService mediaService; |
|---|
| | | |
|---|
| | | |
|---|
| | | @RequestMapping(value = "/list") |
|---|
| | | @ResponseBody |
|---|
| | | public JSONObject list( @RequestParam(required = false)Integer page, |
|---|
| | | @RequestParam(required = false)Integer count, |
|---|
| | | @RequestParam(required = false)String q, |
|---|
| | | @RequestParam(required = false)Boolean online ){ |
|---|
| | | |
|---|
| | | JSONObject jsonObject = redisCatchStorage.getMediaList(page - 1, page - 1 + count); |
|---|
| | | return jsonObject; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 根据应用名和流id获取播放地址 |
|---|
| | | * @param app 应用名 |
|---|
| | | * @param stream 流id |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | @ApiOperation("根据应用名和流id获取播放地址") |
|---|
| | | @ApiImplicitParams({ |
|---|
| | | @ApiImplicitParam(name = "app", value = "应用名"), |
|---|
| | | @ApiImplicitParam(name = "stream", value = "流id"), |
|---|
| | | }) |
|---|
| | | @RequestMapping(value = "/getStreamInfoByAppAndStream") |
|---|
| | | @ResponseBody |
|---|
| | | public StreamInfo getStreamInfoByAppAndStream(String app, String stream){ |
|---|
| | | return mediaService.getStreamInfoByAppAndStreamWithCheck(app, stream); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
