浏览代码

云端录制,未完成

zouxuan 3 年之前
父节点
当前提交
ba89e7a593

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

@@ -266,6 +266,8 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
         RList<UserInfo> list = redissonClient.getList(LIVE_ROOM_USER_LIST.replace(ROOM_UID, roomUid));
         UserInfo userInfo = getUserInfo(userId);
         list.add(userInfo);
+        //录制视频
+        imFeignService.startRecord(roomUid);
     }
 
     private UserInfo getUserInfo(Integer userId) {

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

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

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

@@ -90,4 +90,9 @@ public class ImFeignServiceFallback implements ImFeignService {
     public Object destroyLiveRoom(String roomId) {
         return null;
     }
+
+    @Override
+    public void startRecord(String roomId) {
+
+    }
 }

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

@@ -41,4 +41,10 @@ public class LiveRoomController {
         RecordNotify recordNotify = JSONObject.parseObject(body, RecordNotify.class);
         liveRoomService.recordSync(recordNotify);
     }
+
+    @ApiOperation("录制直播")
+    @RequestMapping(value = "/recordSync")
+    public void startRecord(String roomId) throws Exception {
+        liveRoomService.startRecord(roomId);
+    }
 }

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

@@ -86,6 +86,8 @@ public class LiveRoomServiceImpl implements LiveRoomService {
 
     @Override
     public void startRecord(String roomId) throws Exception {
+        //是否需要录制视频
+
         JSONObject paramJson = new JSONObject();
         paramJson.put("sessionId",getRoomSessionId(roomId));
         ImLiveBroadcastRoom imLiveBroadcastRoom = imLiveBroadcastRoomDao.selectById(roomId);
@@ -101,7 +103,7 @@ public class LiveRoomServiceImpl implements LiveRoomService {
 
     @Override
     public void recordSync(RecordNotify recordNotify) {
-        log.info("recordSync paramJson{}",recordNotify);
+        log.info("recordSync recordNotify:{}",recordNotify);
     }
 
     public String getRoomSessionId(String roomId){