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);