查询流地址时mediaServerId改为可选

648540858

2021-11-22 0199676a6d120e825bcd11c6e46fbe0a01ceae59

查询流地址时mediaServerId改为可选

 src/main/java/com/genersoft/iot/vmp/service/IMediaServerService.java

@@ -61,4 +61,6 @@
    boolean checkMediaRecordServer(String ip, int port);

    void delete(String id);

    MediaServerItem getDefaultMediaServer();
}

 src/main/java/com/genersoft/iot/vmp/service/impl/MediaServerServiceImpl.java

@@ -242,6 +242,11 @@
    }

    @Override
    public MediaServerItem getDefaultMediaServer() {
        return mediaServerMapper.queryDefault();
    }

    @Override
    public void clearMediaServerForOnline() {
        String key = VideoManagerConstants.MEDIA_SERVERS_ONLINE_PREFIX;
        redisUtil.del(key);

 src/main/java/com/genersoft/iot/vmp/service/impl/MediaServiceImpl.java

@@ -38,7 +38,13 @@
    @Override
    public StreamInfo getStreamInfoByAppAndStreamWithCheck(String app, String stream, String mediaServerId, String addr) {
        StreamInfo streamInfo = null;
        MediaServerItem mediaInfo = mediaServerService.getOne(mediaServerId);

        MediaServerItem mediaInfo;
        if (mediaServerId == null) {
            mediaInfo = mediaServerService.getDefaultMediaServer();
        }else {
            mediaInfo = mediaServerService.getOne(mediaServerId);
        }
        if (mediaInfo == null) {
            return streamInfo;
        }
@@ -55,6 +61,8 @@
        return streamInfo;
    }



    @Override
    public StreamInfo getStreamInfoByAppAndStreamWithCheck(String app, String stream, String mediaServerId) {
        return getStreamInfoByAppAndStreamWithCheck(app, stream, mediaServerId, null);

 src/main/java/com/genersoft/iot/vmp/storager/dao/MediaServerMapper.java

@@ -105,4 +105,7 @@

    @Select("SELECT * FROM media_server WHERE ip='${host}' and httpPort=${port}")
    MediaServerItem queryOneByHostAndPort(String host, int port);

    @Select("SELECT * FROM media_server WHERE defaultServer=1")
    MediaServerItem queryDefault();
}

 src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/media/MediaController.java

@@ -44,11 +44,11 @@
    @ApiImplicitParams({
            @ApiImplicitParam(name = "app", value = "应用名", dataTypeClass = String.class),
            @ApiImplicitParam(name = "stream", value = "流id", dataTypeClass = String.class),
            @ApiImplicitParam(name = "mediaServerId", value = "媒体服务器id", dataTypeClass = String.class),
            @ApiImplicitParam(name = "mediaServerId", value = "媒体服务器id", dataTypeClass = String.class, required = false),
    })
    @GetMapping(value = "/stream_info_by_app_and_stream")
    @ResponseBody
    public WVPResult<StreamInfo> getStreamInfoByAppAndStream(@RequestParam String app, @RequestParam String stream, @RequestParam String mediaServerId){
    public WVPResult<StreamInfo> getStreamInfoByAppAndStream(@RequestParam String app, @RequestParam String stream, @RequestParam(required = false) String mediaServerId){
        StreamInfo streamInfoByAppAndStreamWithCheck = mediaService.getStreamInfoByAppAndStreamWithCheck(app, stream, mediaServerId);
        WVPResult<StreamInfo> result = new WVPResult<>();
        if (streamInfoByAppAndStreamWithCheck != null){