From 42a2772d1aa7493bcc4fac3e24ee8eda4eebc23d Mon Sep 17 00:00:00 2001
From: xubinbin <1323875150@qq.com>
Date: 星期二, 12 十二月 2023 17:09:04 +0800
Subject: [PATCH] bugfix：请求头带token， SecurityUtils 获取用户id 一直为0 #1195
---
src/main/java/com/genersoft/iot/vmp/vmanager/streamProxy/StreamProxyController.java | 17 +++++++++++++++++
1 files changed, 17 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/vmanager/streamProxy/StreamProxyController.java b/src/main/java/com/genersoft/iot/vmp/vmanager/streamProxy/StreamProxyController.java
index 0689f42..e28ca11 100755
--- a/src/main/java/com/genersoft/iot/vmp/vmanager/streamProxy/StreamProxyController.java
+++ b/src/main/java/com/genersoft/iot/vmp/vmanager/streamProxy/StreamProxyController.java
@@ -67,6 +67,16 @@
return streamProxyService.getAll(page, count);
}
+ @Operation(summary = "鏌ヨ娴佷唬鐞�")
+ @Parameter(name = "app", description = "搴旂敤鍚�")
+ @Parameter(name = "stream", description = "娴両d")
+ @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),
})
@@ -80,9 +90,16 @@
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();
--
Gitblit v1.8.0