视频点赞实现

xiangpei

2025-07-01 07a8e96750473fbdf676993191c41155ddf8146e

 consumer/src/main/java/cn/lili/listener/VideoMessageListener.java

@@ -53,6 +53,9 @@
                case COLLECT:
                    this.collect(msg);
                    break;
                case THUMBS_UP:
                    this.changeThumbsUp(msg);
                    break;
                case ES_RECREATE:
                    this.recreateVideoIndex();
                    break;
@@ -120,4 +123,9 @@
        esService.deleteDocument(EsSuffix.VIDEO_INDEX_NAME, id);
    }

    public void changeThumbsUp(String msg) {
        ThumbsUpRecord thumbsUpRecord = JSON.parseObject(msg, ThumbsUpRecord.class);
        videoService.mqChangeThumbsUp(thumbsUpRecord);
    }

}