手动开启直播间

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

@@ -1686,7 +1686,13 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
                                                      .collect(Collectors.toMap(o -> o.getSpeakerId(), o -> o, (k1, k2) -> k1))
                                                      .values();
 
-        CompletableFuture.runAsync(() -> values.forEach(this::createLiveRoom));
+        for (ImLiveBroadcastRoom value : values) {
+            try {
+                createLiveRoom(value);
+            } catch (Exception e) {
+                log.error("createLiveRoom error:{}", e.getMessage());
+            }
+        }
         createLock.delete();
     }
 
@@ -1694,6 +1700,7 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
      * 去融云创建房间
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void createLiveRoom(ImLiveBroadcastRoom room) {
         log.info("createLiveRoom>>>>>>roomUid:{}", room.getRoomUid());
         try {