人数同步

mec-application/src/main/java/com/ym/mec/web/controller/ImGroupController.java

@@ -1,5 +1,6 @@
 package com.ym.mec.web.controller;
 
+import com.alibaba.fastjson.JSON;
 import com.google.common.collect.Lists;
 import com.ym.mec.auth.api.entity.SysUser;
 import com.ym.mec.biz.dal.dto.ImGroupDto;

mec-biz/src/main/java/com/mec/redisson/RedissonTopicListener.java

@@ -69,7 +69,7 @@ public class RedissonTopicListener implements ApplicationRunner, Ordered {
                             HttpResponseResult<RoomMemberNumDto> queriedRoomInfo =
                                 klxFeignService.queryRoomInfo(message);
                             if(queriedRoomInfo.getStatus()){
-                                imLiveBroadcastRoomVo.setLookNum(queriedRoomInfo.getData().getOnlineNum() + imLiveBroadcastRoomVo.getTotalLookNum());
+                                imLiveBroadcastRoomVo.setLookNum(queriedRoomInfo.getData().getOnlineNum() + imLiveBroadcastRoomVo.getLookNum());
                                 imLiveBroadcastRoomVo.setTotalLookNum(queriedRoomInfo.getData().getTotalNum() + imLiveBroadcastRoomVo.getTotalLookNum());
                             }
                             imLiveBroadcastRoomService.setGroupMemberDefinedData(imLiveBroadcastRoomVo,imLiveBroadcastRoomVo.getLookNum(),imLiveBroadcastRoomVo.getTotalLookNum());

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

@@ -1250,7 +1250,7 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
 
         //发送消息
         try {
-            livePluginContext.getPluginService(roomVo.getServiceProvider()).sendChatRoomMessage(message);
+//            livePluginContext.getPluginService(roomVo.getServiceProvider()).sendChatRoomMessage(message);
             log.info("sendOnlineUserCount>>>> message: {}", JSONObject.toJSONString(message));
         } catch (Exception e) {
             log.error("sendOnlineUserCount>>>> error {}", e.getMessage());