抽奖活动弹窗

zxl

4 天以前 f0893131c84e18a40daa04b73c0573aac989f9d2

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

}