From 11599b2f05948ebb6df041f836f56d2b367fdef5 Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: Tue, 31 Dec 2024 16:10:00 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=B4=E6=97=B6=E6=8F=90=E4=BA=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/redisMsg/control/RedisRpcStreamPushController.java  | 2 +-
 .../iot/vmp/streamPush/service/impl/StreamPushServiceImpl.java  | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/control/RedisRpcStreamPushController.java b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/control/RedisRpcStreamPushController.java
index d4d0d256..d9fd90ed 100644
--- a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/control/RedisRpcStreamPushController.java
+++ b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/control/RedisRpcStreamPushController.java
@@ -191,7 +191,7 @@ public class RedisRpcStreamPushController extends RpcController {
         streamPushPlayService.start(id, (code, msg, data) -> {
             if (code == ErrorCode.SUCCESS.getCode()) {
                 response.setStatusCode(ErrorCode.SUCCESS.getCode());
-                response.setBody(data);
+                response.setBody(JSONObject.toJSONString(data));
                 sendResponse(response);
             }
         }, null, null);
diff --git a/src/main/java/com/genersoft/iot/vmp/streamPush/service/impl/StreamPushServiceImpl.java b/src/main/java/com/genersoft/iot/vmp/streamPush/service/impl/StreamPushServiceImpl.java
index 1d8d2f0e..acfb564a 100755
--- a/src/main/java/com/genersoft/iot/vmp/streamPush/service/impl/StreamPushServiceImpl.java
+++ b/src/main/java/com/genersoft/iot/vmp/streamPush/service/impl/StreamPushServiceImpl.java
@@ -89,6 +89,7 @@ public class StreamPushServiceImpl implements IStreamPushService {
         if (streamPushInDb == null) {
             StreamPush streamPush = StreamPush.getInstance(event, userSetting.getServerId());
             streamPush.setPushing(true);
+            streamPush.setServerId(userSetting.getServerId());
             streamPush.setUpdateTime(DateUtil.getNow());
             streamPush.setPushTime(DateUtil.getNow());
             add(streamPush);