|
@@ -158,6 +158,12 @@ public class LiveController extends AppBaseController {
|
|
|
sendMsgVo.setMsg("结束直播");
|
|
|
sendMsgVo.setCmd("live_end");
|
|
|
webSocketServer.broadcastMessage(Long.valueOf(params.get("stream_id")), JSONObject.toJSONString(R.ok().put("data",sendMsgVo)));
|
|
|
+ Live live = new Live();
|
|
|
+ live.setLiveId(Long.valueOf(params.get("stream_id")));
|
|
|
+ live.setStatus(1);
|
|
|
+ live.setFinishTime(LocalDateTime.now());
|
|
|
+ live.setLiveType(2);
|
|
|
+ liveService.updateLive(live);
|
|
|
return R.ok();
|
|
|
// {app=200149.push.tlivecloud.com, appid=1319721001, appname=live, channel_id=673,
|
|
|
// errcode=1, errmsg=The push client actively stopped the push, event_time=1755571239,
|