| | |
| | | package com.genersoft.iot.vmp.conf; |
| | | |
| | | import io.netty.util.internal.StringUtil; |
| | | import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.context.annotation.Configuration; |
| | | import org.springframework.util.StringUtils; |
| | | |
| | | import java.text.SimpleDateFormat; |
| | | import java.util.Date; |
| | | |
| | | @Configuration("mediaConfig") |
| | | public class MediaConfig { |
| | | public class MediaConfig{ |
| | | |
| | | // 修改必须配置,不再支持自动获取 |
| | | @Value("${media.id}") |
| | | private String id; |
| | | |
| | | @Value("${media.ip}") |
| | | private String ip; |
| | | |
| | | @Value("${media.hookIp:${sip.ip}}") |
| | | @Value("${media.hook-ip:${sip.ip}}") |
| | | private String hookIp; |
| | | |
| | | @Value("${media.sdpIp:${media.ip}}") |
| | | @Value("${sip.ip}") |
| | | private String sipIp; |
| | | |
| | | @Value("${sip.domain}") |
| | | private String sipDomain; |
| | | |
| | | @Value("${media.sdp-ip:${media.ip}}") |
| | | private String sdpIp; |
| | | |
| | | @Value("${media.httpPort}") |
| | | private String httpPort; |
| | | @Value("${media.stream-ip:${media.ip}}") |
| | | private String streamIp; |
| | | |
| | | @Value("${media.httpSSlPort:}") |
| | | private String httpSSlPort; |
| | | @Value("${media.http-port}") |
| | | private Integer httpPort; |
| | | |
| | | @Value("${media.rtmpPort:}") |
| | | private String rtmpPort; |
| | | @Value("${media.http-ssl-port:0}") |
| | | private Integer httpSSlPort = 0; |
| | | |
| | | @Value("${media.rtmpSSlPort:}") |
| | | private String rtmpSSlPort; |
| | | @Value("${media.rtmp-port:0}") |
| | | private Integer rtmpPort = 0; |
| | | |
| | | @Value("${media.rtpProxyPort:}") |
| | | private String rtpProxyPort; |
| | | @Value("${media.rtmp-ssl-port:0}") |
| | | private Integer rtmpSSlPort = 0; |
| | | |
| | | @Value("${media.rtspPort:}") |
| | | private String rtspPort; |
| | | @Value("${media.rtp-proxy-port:0}") |
| | | private Integer rtpProxyPort = 0; |
| | | |
| | | @Value("${media.rtspSSLPort:}") |
| | | private String rtspSSLPort; |
| | | @Value("${media.rtsp-port:0}") |
| | | private Integer rtspPort = 0; |
| | | |
| | | @Value("${media.autoConfig:true}") |
| | | private boolean autoConfig; |
| | | @Value("${media.rtsp-ssl-port:0}") |
| | | private Integer rtspSSLPort = 0; |
| | | |
| | | @Value("${media.auto-config:true}") |
| | | private boolean autoConfig = true; |
| | | |
| | | @Value("${media.secret}") |
| | | private String secret; |
| | | |
| | | @Value("${media.streamNoneReaderDelayMS:18000}") |
| | | private String streamNoneReaderDelayMS; |
| | | @Value("${media.stream-none-reader-delay-ms:10000}") |
| | | private int streamNoneReaderDelayMS = 10000; |
| | | |
| | | @Value("${media.rtp.enable}") |
| | | private boolean rtpEnable; |
| | | |
| | | @Value("${media.rtp.portRange}") |
| | | @Value("${media.rtp.port-range}") |
| | | private String rtpPortRange; |
| | | |
| | | @Value("${media.recordAssistPort}") |
| | | private int recordAssistPort; |
| | | |
| | | @Value("${media.rtp.send-port-range}") |
| | | private String sendRtpPortRange; |
| | | |
| | | @Value("${media.record-assist-port:0}") |
| | | private Integer recordAssistPort = 0; |
| | | |
| | | public String getId() { |
| | | return id; |
| | | } |
| | | |
| | | public String getIp() { |
| | | return ip; |
| | | } |
| | | |
| | | public void setIp(String ip) { |
| | | this.ip = ip; |
| | | } |
| | | |
| | | public String getHookIp() { |
| | | return hookIp; |
| | | if (StringUtils.isEmpty(hookIp)){ |
| | | return sipIp; |
| | | }else { |
| | | return hookIp; |
| | | } |
| | | |
| | | } |
| | | |
| | | public void setHookIp(String hookIp) { |
| | | this.hookIp = hookIp; |
| | | public String getSipIp() { |
| | | if (sipIp == null) { |
| | | return this.ip; |
| | | }else { |
| | | return sipIp; |
| | | } |
| | | } |
| | | |
| | | public String getHttpPort() { |
| | | public int getHttpPort() { |
| | | return httpPort; |
| | | } |
| | | |
| | | public void setHttpPort(String httpPort) { |
| | | this.httpPort = httpPort; |
| | | public int getHttpSSlPort() { |
| | | return httpSSlPort; |
| | | } |
| | | |
| | | public int getRtmpPort() { |
| | | return rtmpPort; |
| | | } |
| | | |
| | | public int getRtmpSSlPort() { |
| | | return rtmpSSlPort; |
| | | } |
| | | |
| | | public int getRtpProxyPort() { |
| | | if (rtpProxyPort == null) { |
| | | return 0; |
| | | }else { |
| | | return rtpProxyPort; |
| | | } |
| | | |
| | | } |
| | | |
| | | public int getRtspPort() { |
| | | return rtspPort; |
| | | } |
| | | |
| | | public int getRtspSSLPort() { |
| | | return rtspSSLPort; |
| | | } |
| | | |
| | | public boolean isAutoConfig() { |
| | | return autoConfig; |
| | | } |
| | | |
| | | public boolean getAutoConfig() { |
| | | return autoConfig; |
| | | } |
| | | |
| | | public void setAutoConfig(boolean autoConfig) { |
| | | this.autoConfig = autoConfig; |
| | | } |
| | | |
| | | public String getSecret() { |
| | | return secret; |
| | | } |
| | | |
| | | public void setSecret(String secret) { |
| | | this.secret = secret; |
| | | } |
| | | |
| | | public String getStreamNoneReaderDelayMS() { |
| | | public int getStreamNoneReaderDelayMS() { |
| | | return streamNoneReaderDelayMS; |
| | | } |
| | | |
| | | public void setStreamNoneReaderDelayMS(String streamNoneReaderDelayMS) { |
| | | this.streamNoneReaderDelayMS = streamNoneReaderDelayMS; |
| | | } |
| | | |
| | | public boolean isRtpEnable() { |
| | | return rtpEnable; |
| | | } |
| | | |
| | | public void setRtpEnable(boolean rtpEnable) { |
| | | this.rtpEnable = rtpEnable; |
| | | } |
| | | |
| | | public String getRtpPortRange() { |
| | | return rtpPortRange; |
| | | } |
| | | |
| | | public void setRtpPortRange(String rtpPortRange) { |
| | | this.rtpPortRange = rtpPortRange; |
| | | } |
| | | |
| | | public String getHttpSSlPort() { |
| | | return httpSSlPort; |
| | | } |
| | | |
| | | public void setHttpSSlPort(String httpSSlPort) { |
| | | this.httpSSlPort = httpSSlPort; |
| | | } |
| | | |
| | | public String getRtmpPort() { |
| | | return rtmpPort; |
| | | } |
| | | |
| | | public void setRtmpPort(String rtmpPort) { |
| | | this.rtmpPort = rtmpPort; |
| | | } |
| | | |
| | | public String getRtmpSSlPort() { |
| | | return rtmpSSlPort; |
| | | } |
| | | |
| | | public void setRtmpSSlPort(String rtmpSSlPort) { |
| | | this.rtmpSSlPort = rtmpSSlPort; |
| | | } |
| | | |
| | | public String getRtpProxyPort() { |
| | | return rtpProxyPort; |
| | | } |
| | | |
| | | public void setRtpProxyPort(String rtpProxyPort) { |
| | | this.rtpProxyPort = rtpProxyPort; |
| | | } |
| | | |
| | | public String getRtspPort() { |
| | | return rtspPort; |
| | | } |
| | | |
| | | public void setRtspPort(String rtspPort) { |
| | | this.rtspPort = rtspPort; |
| | | } |
| | | |
| | | public String getRtspSSLPort() { |
| | | return rtspSSLPort; |
| | | } |
| | | |
| | | public void setRtspSSLPort(String rtspSSLPort) { |
| | | this.rtspSSLPort = rtspSSLPort; |
| | | } |
| | | |
| | | |
| | | public int getRecordAssistPort() { |
| | | return recordAssistPort; |
| | | } |
| | | |
| | | public void setRecordAssistPort(int recordAssistPort) { |
| | | this.recordAssistPort = recordAssistPort; |
| | | } |
| | | |
| | | public String getSdpIp() { |
| | | if (StringUtils.isEmpty(sdpIp)) { |
| | | if (StringUtils.isEmpty(sdpIp)){ |
| | | return ip; |
| | | }else { |
| | | return sdpIp; |
| | | } |
| | | } |
| | | |
| | | public void setSdpIp(String sdpIp) { |
| | | this.sdpIp = sdpIp; |
| | | public String getStreamIp() { |
| | | if (StringUtils.isEmpty(streamIp)){ |
| | | return ip; |
| | | }else { |
| | | return streamIp; |
| | | } |
| | | } |
| | | |
| | | public String getSipDomain() { |
| | | return sipDomain; |
| | | } |
| | | |
| | | public String getSendRtpPortRange() { |
| | | return sendRtpPortRange; |
| | | } |
| | | |
| | | public MediaServerItem getMediaSerItem(){ |
| | | MediaServerItem mediaServerItem = new MediaServerItem(); |
| | | mediaServerItem.setId(id); |
| | | mediaServerItem.setIp(ip); |
| | | mediaServerItem.setDefaultServer(true); |
| | | mediaServerItem.setHookIp(getHookIp()); |
| | | mediaServerItem.setSdpIp(getSdpIp()); |
| | | mediaServerItem.setStreamIp(getStreamIp()); |
| | | mediaServerItem.setHttpPort(httpPort); |
| | | mediaServerItem.setHttpSSlPort(httpSSlPort); |
| | | mediaServerItem.setRtmpPort(rtmpPort); |
| | | mediaServerItem.setRtmpSSlPort(rtmpSSlPort); |
| | | mediaServerItem.setRtpProxyPort(getRtpProxyPort()); |
| | | mediaServerItem.setRtspPort(rtspPort); |
| | | mediaServerItem.setRtspSSLPort(rtspSSLPort); |
| | | mediaServerItem.setAutoConfig(autoConfig); |
| | | mediaServerItem.setSecret(secret); |
| | | mediaServerItem.setStreamNoneReaderDelayMS(streamNoneReaderDelayMS); |
| | | mediaServerItem.setRtpEnable(rtpEnable); |
| | | mediaServerItem.setRtpPortRange(rtpPortRange); |
| | | mediaServerItem.setSendRtpPortRange(sendRtpPortRange); |
| | | mediaServerItem.setRecordAssistPort(recordAssistPort); |
| | | mediaServerItem.setHookAliveInterval(120); |
| | | |
| | | SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | mediaServerItem.setCreateTime(format.format(System.currentTimeMillis())); |
| | | mediaServerItem.setUpdateTime(format.format(System.currentTimeMillis())); |
| | | |
| | | return mediaServerItem; |
| | | } |
| | | |
| | | } |