抽奖活动

zxl

2025-08-22 f97f81f5c118240183d5731745b243dd312c6a7c

 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);
    }

}