소스 검색

Merge branch 'dev_20230222_live' into saas

Eric 2 년 전
부모
커밋
dc12cb5149
1개의 변경된 파일13개의 추가작업 그리고 6개의 파일을 삭제
  1. 13 6
      mec-biz/src/main/java/com/ym/mec/biz/service/impl/ImLiveBroadcastRoomServiceImpl.java

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

@@ -827,13 +827,20 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
      */
     @Override
     public void syncLike(String roomUid, Integer likeNum) {
-        redissonClient.getBucket(LIVE_ROOM_LIKE.replace(ROOM_UID, roomUid)).set(likeNum);
 
-        // 同步点赞数到直播间数据表
-        ImLiveBroadcastRoomVo roomVo = getImLiveBroadcastRoomVo(roomUid);
-        setGroupDefinedData(roomVo,EGroupDefinedDataType.LIKES,likeNum.toString());
-        //增加房间心跳
-        redissonClient.getBucket(LIVE_ROOM_SPEAKER_HEART_BEAT.replace(ROOM_UID, roomUid)).set(new Date());
+        // 同步直播间点赞数
+        if (Optional.ofNullable(likeNum).orElse(0) > 0) {
+
+            redissonClient.getBucket(LIVE_ROOM_LIKE.replace(ROOM_UID, roomUid)).set(likeNum);
+
+            // 同步点赞数到直播间数据表
+            ImLiveBroadcastRoomVo roomVo = getImLiveBroadcastRoomVo(roomUid);
+            setGroupDefinedData(roomVo,EGroupDefinedDataType.LIKES,likeNum.toString());
+            //增加房间心跳
+            redissonClient.getBucket(LIVE_ROOM_SPEAKER_HEART_BEAT.replace(ROOM_UID, roomUid)).set(new Date());
+        }
+
+        // TODO: 后续同步直播间数据(在线用户等),暂时不做
     }
 
     /**