| | |
| | | return streamProxyService.getAll(page, count); |
| | | } |
| | | |
| | | @Operation(summary = "查询流代理") |
| | | @Parameter(name = "app", description = "应用名") |
| | | @Parameter(name = "stream", description = "流Id") |
| | | @GetMapping(value = "/one") |
| | | @ResponseBody |
| | | public StreamProxyItem one(String app, String stream){ |
| | | |
| | | return streamProxyService.getStreamProxyByAppAndStream(app, stream); |
| | | } |
| | | |
| | | @Operation(summary = "保存代理", parameters = { |
| | | @Parameter(name = "param", description = "代理参数", required = true), |
| | | }) |
| | |
| | | if (ObjectUtils.isEmpty(param.getType())) { |
| | | param.setType("default"); |
| | | } |
| | | if (ObjectUtils.isEmpty(param.getRtpType())) { |
| | | param.setRtpType("1"); |
| | | } |
| | | if (ObjectUtils.isEmpty(param.getGbId())) { |
| | | param.setGbId(null); |
| | | } |
| | | StreamProxyItem streamProxyItem = streamProxyService.getStreamProxyByAppAndStream(param.getApp(), param.getStream()); |
| | | if (streamProxyItem != null) { |
| | | streamProxyService.del(param.getApp(), param.getStream()); |
| | | } |
| | | |
| | | RequestMessage requestMessage = new RequestMessage(); |
| | | String key = DeferredResultHolder.CALLBACK_CMD_PROXY + param.getApp() + param.getStream(); |