人数同步

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

@@ -1300,7 +1300,7 @@ public class LiveRoomServiceImpl extends ServiceImpl<LiveRoomDao, LiveRoom> impl
         message.setContent(sendMap);
         //发送消息
         try {
-            this.publishRoomMessage(message);
+//            this.publishRoomMessage(message);
             log.info("sendOnlineUserCount>>>> message: {}", JSONObject.toJSONString(message));
         } catch (Exception e) {
             log.error("sendOnlineUserCount>>>> error {}", e.getMessage());

cooleshow-user/user-biz/src/main/java/com/yonge/redisson/RedissonTopicListener.java

@@ -68,7 +68,7 @@ public class RedissonTopicListener implements ApplicationRunner, Ordered {
                         try {
                             HttpResponseResult<RoomMemberNumDto> roomMemberNumDtoHttpResponseResult = gymFeignService.queryRoomInfo(message);
                             if (roomMemberNumDtoHttpResponseResult.getStatus()) {
-                                liveRoomVo.setLookNum(roomMemberNumDtoHttpResponseResult.getData().getOnlineNum() + liveRoomVo.getTotalLookNum());
+                                liveRoomVo.setLookNum(roomMemberNumDtoHttpResponseResult.getData().getOnlineNum() + liveRoomVo.getLookNum());
                                 liveRoomVo.setTotalLookNum(roomMemberNumDtoHttpResponseResult.getData().getTotalNum() + liveRoomVo.getTotalLookNum());
                             }
                             liveRoomService.setGroupMemberDefinedData(liveRoomVo,liveRoomVo.getLookNum(),liveRoomVo.getTotalLookNum());