发送消息

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/LiveRoomServiceImpl.java

@@ -1243,9 +1243,10 @@ public class LiveRoomServiceImpl extends ServiceImpl<LiveRoomDao, LiveRoom> impl
                 .toChatRoomId(message.getToChatroomId())
                 .content(messageContent)
                 .build();
+        LiveRoom liveRoom = getByRoomUid(message.getToChatroomId());
         try {
 
-            LivePluginService pluginService = livePluginContext.getPluginService(message.getServiceProvider());
+            LivePluginService pluginService = livePluginContext.getPluginService(liveRoom.getServiceProvider());
             pluginService.sendChatRoomMessage(build);
             log.info("sendLiveRoomMessage>>>> looker {} : roomId={}, userId={}",message.getObjectName(), message.getToChatroomId(), message.getFromUserId());
         } catch (Exception e) {