|
@@ -1,10 +1,12 @@
|
|
package com.ym.service.Impl;
|
|
package com.ym.service.Impl;
|
|
|
|
|
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import com.ym.http.HttpHelper;
|
|
import com.ym.http.HttpHelper;
|
|
import com.ym.mec.common.exception.BizException;
|
|
import com.ym.mec.common.exception.BizException;
|
|
import com.ym.mec.im.IMHelper;
|
|
import com.ym.mec.im.IMHelper;
|
|
import com.ym.pojo.IMApiResultInfo;
|
|
import com.ym.pojo.IMApiResultInfo;
|
|
|
|
+import com.ym.pojo.RecordConfig;
|
|
import com.ym.service.LiveRoomService;
|
|
import com.ym.service.LiveRoomService;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.apache.commons.lang3.StringUtils;
|
|
import org.apache.commons.lang3.StringUtils;
|
|
@@ -78,8 +80,17 @@ public class LiveRoomServiceImpl implements LiveRoomService {
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
- public void startRecord(String roomId) {
|
|
|
|
-
|
|
|
|
|
|
+ public void startRecord(String roomId) throws Exception {
|
|
|
|
+ JSONObject paramJson = new JSONObject();
|
|
|
|
+ paramJson.put("sessionId",getRoomSessionId(roomId));
|
|
|
|
+ paramJson.put("config",new RecordConfig());
|
|
|
|
+ String body = paramJson.toJSONString();
|
|
|
|
+ HttpURLConnection conn = httpHelper.createIMRtcPostHttpConnection("/rtc/record/start.json", "application/json",roomId);
|
|
|
|
+ httpHelper.setBodyParameter(body, conn);
|
|
|
|
+ IMApiResultInfo resultInfo = JSON.parseObject(httpHelper.returnResult(conn, body), IMApiResultInfo.class);
|
|
|
|
+ if(resultInfo.getCode() != 200){
|
|
|
|
+ log.error("直播视频录制失败:resultInfo : {} ",resultInfo);
|
|
|
|
+ }
|
|
}
|
|
}
|
|
|
|
|
|
public String getRoomSessionId(String roomId){
|
|
public String getRoomSessionId(String roomId){
|