package com.genersoft.iot.vmp.common; import io.swagger.v3.oas.annotations.media.Schema; import java.net.URL; @Schema(description = "流信息") public class StreamInfo { @Schema(description = "应用名") private String app; @Schema(description = "流ID") private String stream; @Schema(description = "设备编号") private String deviceID; @Schema(description = "通道编号") private String channelId; @Schema(description = "IP") private String ip; @Schema(description = "HTTP-FLV流地址") private StreamURL flv; @Schema(description = "HTTPS-FLV流地址") private StreamURL https_flv; @Schema(description = "Websocket-FLV流地址") private StreamURL ws_flv; @Schema(description = "Websockets-FLV流地址") private StreamURL wss_flv; @Schema(description = "HTTP-FMP4流地址") private StreamURL fmp4; @Schema(description = "HTTPS-FMP4流地址") private StreamURL https_fmp4; @Schema(description = "Websocket-FMP4流地址") private StreamURL ws_fmp4; @Schema(description = "Websockets-FMP4流地址") private StreamURL wss_fmp4; @Schema(description = "HLS流地址") private StreamURL hls; @Schema(description = "HTTPS-HLS流地址") private StreamURL https_hls; @Schema(description = "Websocket-HLS流地址") private StreamURL ws_hls; @Schema(description = "Websockets-HLS流地址") private StreamURL wss_hls; @Schema(description = "HTTP-TS流地址") private StreamURL ts; @Schema(description = "HTTPS-TS流地址") private StreamURL https_ts; @Schema(description = "Websocket-TS流地址") private StreamURL ws_ts; @Schema(description = "Websockets-TS流地址") private StreamURL wss_ts; @Schema(description = "RTMP流地址") private StreamURL rtmp; @Schema(description = "RTMPS流地址") private StreamURL rtmps; @Schema(description = "RTSP流地址") private StreamURL rtsp; @Schema(description = "RTSPS流地址") private StreamURL rtsps; @Schema(description = "RTC流地址") private StreamURL rtc; @Schema(description = "RTCS流地址") private StreamURL rtcs; @Schema(description = "流媒体ID") private String mediaServerId; @Schema(description = "流编码信息") private Object tracks; @Schema(description = "开始时间") private String startTime; @Schema(description = "结束时间") private String endTime; @Schema(description = "进度(录像下载使用)") private double progress; @Schema(description = "是否暂停(录像回放使用)") private boolean pause; public void setRtmp(String host, int port, int sslPort, String app, String stream, String callIdParam) { String file = String.format("%s/%s/%s", app, stream, callIdParam); this.rtmp = new StreamURL("rtmp", host, port, file); if (sslPort != 0) { this.rtmps = new StreamURL("rtmps", host, sslPort, file); } } public void setRtsp(String host, int port, int sslPort, String app, String stream, String callIdParam) { String file = String.format("%s/%s/%s", app, stream, callIdParam); this.rtsp = new StreamURL("rtsp", host, port, file); if (sslPort != 0) { this.rtsps = new StreamURL("rtsps", host, sslPort, file); } } public void setFlv(String host, int port, int sslPort, String app, String stream, String callIdParam) { String file = String.format("%s/%s.live.flv%s", app, stream, callIdParam); this.flv = new StreamURL("http", host, port, file); this.ws_flv = new StreamURL("ws", host, port, file); if (sslPort != 0) { this.https_flv = new StreamURL("https", host, sslPort, file); this.wss_flv = new StreamURL("wss", host, sslPort, file); } } public void setFmp4(String host, int port, int sslPort, String app, String stream, String callIdParam) { String file = String.format("%s/%s.live.mp4%s", app, stream, callIdParam); this.fmp4 = new StreamURL("http", host, port, file); this.ws_fmp4 = new StreamURL("ws", host, port, file); if (sslPort != 0) { this.https_fmp4 = new StreamURL("https", host, sslPort, file); this.wss_fmp4 = new StreamURL("wss", host, sslPort, file); } } public void setHls(String host, int port, int sslPort, String app, String stream, String callIdParam) { String file = String.format("%s/%s/hls.m3u8%s", app, stream, callIdParam); this.hls = new StreamURL("http", host, port, file); this.ws_hls = new StreamURL("ws", host, port, file); if (sslPort != 0) { this.https_hls = new StreamURL("https", host, sslPort, file); this.wss_hls = new StreamURL("wss", host, sslPort, file); } } public void setTs(String host, int port, int sslPort, String app, String stream, String callIdParam) { String file = String.format("%s/%s.live.ts%s", app, stream, callIdParam); this.ts = new StreamURL("http", host, port, file); this.ws_ts = new StreamURL("ws", host, port, file); if (sslPort != 0) { this.https_ts = new StreamURL("https", host, sslPort, file); this.wss_ts = new StreamURL("wss", host, sslPort, file); } } public void setRtc(String host, int port, int sslPort, String app, String stream, String callIdParam) { String file = String.format("index/api/webrtc?app=%s&stream=%s&type=play%s", app, stream, callIdParam); this.rtc = new StreamURL("http", host, port, file); if (sslPort != 0) { this.rtcs = new StreamURL("https", host, sslPort, file); } } public void channgeStreamIp(String localAddr) { this.flv.setHost(localAddr); this.ws_flv.setHost(localAddr); this.hls.setHost(localAddr); this.ws_hls.setHost(localAddr); this.ts.setHost(localAddr); this.ws_ts.setHost(localAddr); this.fmp4.setHost(localAddr); this.ws_fmp4.setHost(localAddr); this.rtc.setHost(localAddr); if (this.https_flv != null) { this.https_flv.setHost(localAddr); this.wss_flv.setHost(localAddr); this.https_hls.setHost(localAddr); this.wss_hls.setHost(localAddr); this.wss_ts.setHost(localAddr); this.https_fmp4.setHost(localAddr); this.wss_fmp4.setHost(localAddr); this.rtcs.setHost(localAddr); } this.rtsp.setHost(localAddr); if (this.rtsps != null) { this.rtsps.setHost(localAddr); } this.rtmp.setHost(localAddr); if (this.rtmps != null) { this.rtmps.setHost(localAddr); } } public static class TransactionInfo{ public String callId; public String localTag; public String remoteTag; public String branch; } private TransactionInfo transactionInfo; public String getApp() { return app; } public void setApp(String app) { this.app = app; } public String getDeviceID() { return deviceID; } public void setDeviceID(String deviceID) { this.deviceID = deviceID; } public String getChannelId() { return channelId; } public void setChannelId(String channelId) { this.channelId = channelId; } public String getStream() { return stream; } public void setStream(String stream) { this.stream = stream; } public String getIp() { return ip; } public void setIp(String ip) { this.ip = ip; } public StreamURL getFlv() { return flv; } public StreamURL getHttps_flv() { return https_flv; } public StreamURL getWs_flv() { return ws_flv; } public StreamURL getWss_flv() { return wss_flv; } public StreamURL getFmp4() { return fmp4; } public StreamURL getHttps_fmp4() { return https_fmp4; } public StreamURL getWs_fmp4() { return ws_fmp4; } public StreamURL getWss_fmp4() { return wss_fmp4; } public StreamURL getHls() { return hls; } public StreamURL getHttps_hls() { return https_hls; } public StreamURL getWs_hls() { return ws_hls; } public StreamURL getWss_hls() { return wss_hls; } public StreamURL getTs() { return ts; } public StreamURL getHttps_ts() { return https_ts; } public StreamURL getWs_ts() { return ws_ts; } public StreamURL getWss_ts() { return wss_ts; } public StreamURL getRtmp() { return rtmp; } public StreamURL getRtmps() { return rtmps; } public StreamURL getRtsp() { return rtsp; } public StreamURL getRtsps() { return rtsps; } public StreamURL getRtc() { return rtc; } public StreamURL getRtcs() { return rtcs; } public String getMediaServerId() { return mediaServerId; } public void setMediaServerId(String mediaServerId) { this.mediaServerId = mediaServerId; } public Object getTracks() { return tracks; } public void setTracks(Object tracks) { this.tracks = tracks; } public String getStartTime() { return startTime; } public void setStartTime(String startTime) { this.startTime = startTime; } public String getEndTime() { return endTime; } public void setEndTime(String endTime) { this.endTime = endTime; } public double getProgress() { return progress; } public void setProgress(double progress) { this.progress = progress; } public boolean isPause() { return pause; } public void setPause(boolean pause) { this.pause = pause; } public TransactionInfo getTransactionInfo() { return transactionInfo; } public void setTransactionInfo(TransactionInfo transactionInfo) { this.transactionInfo = transactionInfo; } }