临时提交
This commit is contained in:
@@ -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);
|
||||
|
||||
@@ -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);
|
||||
|
||||
Reference in New Issue
Block a user