云端录制，未完成

mec-biz/src/main/java/com/ym/mec/biz/service/impl/ImLiveBroadcastRoomServiceImpl.java

@@ -267,7 +267,7 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
         UserInfo userInfo = getUserInfo(userId);
         list.add(userInfo);
         //如果是主播，录制视频
-        imFeignService.startRecord(roomUid);
+//        imFeignService.startRecord(roomUid);
     }
 
     private UserInfo getUserInfo(Integer userId) {

mec-client-api/src/main/java/com/ym/mec/im/ImFeignService.java

@@ -152,4 +152,14 @@ public interface ImFeignService {
     */
     @PostMapping(value = "/liveRoom/startRecord")
     void startRecord(@RequestParam("roomId") String roomId);
+
+    /**
+    * @description: 结束录制直播
+     * @param roomId
+    * @return void
+    * @author zx
+    * @date 2022/2/25 13:52
+    */
+    @PostMapping(value = "/liveRoom/stopRecord")
+    void stopRecord(@RequestParam("roomId") String roomId);
 }

mec-client-api/src/main/java/com/ym/mec/im/fallback/ImFeignServiceFallback.java

@@ -95,4 +95,9 @@ public class ImFeignServiceFallback implements ImFeignService {
     public void startRecord(String roomId) {
 
     }
+
+    @Override
+    public void stopRecord(String roomId) {
+
+    }
 }

mec-im/src/main/java/com/ym/controller/LiveRoomController.java

@@ -47,4 +47,10 @@ public class LiveRoomController {
     public void startRecord(String roomId) throws Exception {
         liveRoomService.startRecord(roomId);
     }
+
+    @ApiOperation("结束录制直播")
+    @RequestMapping(value = "/stopRecord")
+    public void stopRecord(String roomId) throws Exception {
+        liveRoomService.stopRecord(roomId);
+    }
 }

mec-im/src/main/java/com/ym/pojo/RecordConfig.java

@@ -13,12 +13,4 @@ public class RecordConfig {
     Integer renderMode = 1;
     String hostUserId;
     String hostStreamId;
-
-    public RecordConfig(Integer speakerId) {
-        this.hostUserId = speakerId.toString();
-        this.hostStreamId = speakerId.toString();
-    }
-
-    public RecordConfig() {
-    }
 }

mec-im/src/main/java/com/ym/service/Impl/LiveRoomServiceImpl.java

@@ -88,13 +88,9 @@ public class LiveRoomServiceImpl implements LiveRoomService {
 
     @Override
     public void startRecord(String roomId) throws Exception {
-        //是否需要录制视频
-
         log.error("开始录制直播：roomId : {} ",roomId);
         JSONObject paramJson = new JSONObject();
         paramJson.put("sessionId",getRoomSessionId(roomId));
-//        ImLiveBroadcastRoom imLiveBroadcastRoom = imLiveBroadcastRoomDao.selectOne(new QueryWrapper<ImLiveBroadcastRoom>()
-//                .eq("room_uid_", roomId));
         paramJson.put("config",new RecordConfig());
         String body = paramJson.toJSONString();
         HttpURLConnection conn = httpHelper.createIMRtcPostHttpConnection("/rtc/record/start.json", "application/json",roomId);