diff --git a/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMHttpHookListener.java b/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMHttpHookListener.java index 3a94f796..f59f57e3 100644 --- a/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMHttpHookListener.java +++ b/src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMHttpHookListener.java @@ -496,13 +496,13 @@ public class ZLMHttpHookListener { // 拉流代理 StreamProxyItem streamProxyItem = streamProxyService.getStreamProxyByAppAndStream(param.getApp(), param.getStream()); if (streamProxyItem != null) { - if (streamProxyItem.isEnable_remove_none_reader()) { + if (streamProxyItem.isEnableRemoveNoneReader()) { // 无人观看自动移除 ret.put("close", true); streamProxyService.del(param.getApp(), param.getStream()); - String url = streamProxyItem.getUrl() != null ? streamProxyItem.getUrl() : streamProxyItem.getSrc_url(); + String url = streamProxyItem.getUrl() != null ? streamProxyItem.getUrl() : streamProxyItem.getSrcUrl(); logger.info("[{}/{}]<-[{}] 拉流代理无人观看已经移除", param.getApp(), param.getStream(), url); - } else if (streamProxyItem.isEnable_disable_none_reader()) { + } else if (streamProxyItem.isEnableDisableNoneReader()) { // 无人观看停用 ret.put("close", true); // 修改数据 @@ -587,7 +587,7 @@ public class ZLMHttpHookListener { } else { // 拉流代理 StreamProxyItem streamProxyByAppAndStream = streamProxyService.getStreamProxyByAppAndStream(param.getApp(), param.getStream()); - if (streamProxyByAppAndStream != null && streamProxyByAppAndStream.isEnable_disable_none_reader()) { + if (streamProxyByAppAndStream != null && streamProxyByAppAndStream.isEnableDisableNoneReader()) { streamProxyService.start(param.getApp(), param.getStream()); } DeferredResult result = new DeferredResult<>(); diff --git a/src/main/java/com/genersoft/iot/vmp/media/zlm/dto/StreamProxyItem.java b/src/main/java/com/genersoft/iot/vmp/media/zlm/dto/StreamProxyItem.java index b0e74e8f..8637e3f1 100644 --- a/src/main/java/com/genersoft/iot/vmp/media/zlm/dto/StreamProxyItem.java +++ b/src/main/java/com/genersoft/iot/vmp/media/zlm/dto/StreamProxyItem.java @@ -16,7 +16,7 @@ public class StreamProxyItem extends GbStream { @Schema(description = "流ID") private String stream; @Schema(description = "流媒体服务ID") - private String mediaServerId; + private String media_server_id; @Schema(description = "拉流地址") private String url; @Schema(description = "拉流地址") @@ -41,7 +41,7 @@ public class StreamProxyItem extends GbStream { @Schema(description = "是否 无人观看时自动停用") private boolean enable_disable_none_reader; @Schema(description = "创建时间") - private String createTime; + private String create_time; public String getType() { return type; @@ -73,12 +73,12 @@ public class StreamProxyItem extends GbStream { @Override public String getMediaServerId() { - return mediaServerId; + return media_server_id; } @Override public void setMediaServerId(String mediaServerId) { - this.mediaServerId = mediaServerId; + this.media_server_id = mediaServerId; } public String getUrl() { @@ -89,43 +89,43 @@ public class StreamProxyItem extends GbStream { this.url = url; } - public String getSrc_url() { + public String getSrcUrl() { return src_url; } - public void setSrc_url(String src_url) { + public void setSrcUrl(String src_url) { this.src_url = src_url; } - public String getDst_url() { + public String getDstUrl() { return dst_url; } - public void setDst_url(String dst_url) { + public void setDstUrl(String dst_url) { this.dst_url = dst_url; } - public int getTimeout_ms() { + public int getTimeoutMs() { return timeout_ms; } - public void setTimeout_ms(int timeout_ms) { + public void setTimeoutMs(int timeout_ms) { this.timeout_ms = timeout_ms; } - public String getFfmpeg_cmd_key() { + public String getFfmpegCmdKey() { return ffmpeg_cmd_key; } - public void setFfmpeg_cmd_key(String ffmpeg_cmd_key) { + public void setFfmpegCmdKey(String ffmpeg_cmd_key) { this.ffmpeg_cmd_key = ffmpeg_cmd_key; } - public String getRtp_type() { + public String getRtpType() { return rtp_type; } - public void setRtp_type(String rtp_type) { + public void setRtpType(String rtp_type) { this.rtp_type = rtp_type; } @@ -137,45 +137,45 @@ public class StreamProxyItem extends GbStream { this.enable = enable; } - public boolean isEnable_mp4() { + public boolean isEnableMp4() { return enable_mp4; } - public void setEnable_mp4(boolean enable_mp4) { + public void setEnableMp4(boolean enable_mp4) { this.enable_mp4 = enable_mp4; } @Override public String getCreateTime() { - return createTime; + return create_time; } @Override - public void setCreateTime(String createTime) { - this.createTime = createTime; + public void setCreateTime(String create_time) { + this.create_time = create_time; } - public boolean isEnable_remove_none_reader() { + public boolean isEnableRemoveNoneReader() { return enable_remove_none_reader; } - public void setEnable_remove_none_reader(boolean enable_remove_none_reader) { + public void setEnableRemoveNoneReader(boolean enable_remove_none_reader) { this.enable_remove_none_reader = enable_remove_none_reader; } - public boolean isEnable_disable_none_reader() { + public boolean isEnableDisableNoneReader() { return enable_disable_none_reader; } - public void setEnable_disable_none_reader(boolean enable_disable_none_reader) { + public void setEnableDisableNoneReader(boolean enable_disable_none_reader) { this.enable_disable_none_reader = enable_disable_none_reader; } - public boolean isEnable_audio() { + public boolean isEnableAudio() { return enable_audio; } - public void setEnable_audio(boolean enable_audio) { + public void setEnableAudio(boolean enable_audio) { this.enable_audio = enable_audio; } } diff --git a/src/main/java/com/genersoft/iot/vmp/service/impl/StreamProxyServiceImpl.java b/src/main/java/com/genersoft/iot/vmp/service/impl/StreamProxyServiceImpl.java index 3037e3f1..f73392f1 100644 --- a/src/main/java/com/genersoft/iot/vmp/service/impl/StreamProxyServiceImpl.java +++ b/src/main/java/com/genersoft/iot/vmp/service/impl/StreamProxyServiceImpl.java @@ -106,7 +106,7 @@ public class StreamProxyServiceImpl implements IStreamProxyService { } String dstUrl = String.format("rtmp://%s:%s/%s/%s", "127.0.0.1", mediaInfo.getRtmpPort(), param.getApp(), param.getStream() ); - param.setDst_url(dstUrl); + param.setDstUrl(dstUrl); StringBuffer resultMsg = new StringBuffer(); param.setMediaServerId(mediaInfo.getId()); boolean saveResult; @@ -127,7 +127,7 @@ public class StreamProxyServiceImpl implements IStreamProxyService { resultMsg.append(", 但是启用失败,请检查流地址是否可用"); param.setEnable(false); // 直接移除 - if (param.isEnable_remove_none_reader()) { + if (param.isEnableRemoveNoneReader()) { del(param.getApp(), param.getStream()); }else { updateStreamProxy(param); @@ -228,11 +228,11 @@ public class StreamProxyServiceImpl implements IStreamProxyService { } if ("default".equals(param.getType())){ result = zlmresTfulUtils.addStreamProxy(mediaServerItem, param.getApp(), param.getStream(), param.getUrl(), - param.isEnable_audio(), param.isEnable_mp4(), param.getRtp_type()); + param.isEnableAudio(), param.isEnableMp4(), param.getRtpType()); }else if ("ffmpeg".equals(param.getType())) { - result = zlmresTfulUtils.addFFmpegSource(mediaServerItem, param.getSrc_url(), param.getDst_url(), - param.getTimeout_ms() + "", param.isEnable_audio(), param.isEnable_mp4(), - param.getFfmpeg_cmd_key()); + result = zlmresTfulUtils.addFFmpegSource(mediaServerItem, param.getSrcUrl(), param.getDstUrl(), + param.getTimeoutMs() + "", param.isEnableAudio(), param.isEnableMp4(), + param.getFfmpegCmdKey()); } return result; } @@ -286,7 +286,7 @@ public class StreamProxyServiceImpl implements IStreamProxyService { updateStreamProxy(streamProxy); }else { logger.info("启用代理失败: {}/{}->{}({})", app, stream, jsonObject.getString("msg"), - streamProxy.getSrc_url() == null? streamProxy.getUrl():streamProxy.getSrc_url()); + streamProxy.getSrcUrl() == null? streamProxy.getUrl():streamProxy.getSrcUrl()); } } return result;