From 07a8e96750473fbdf676993191c41155ddf8146e Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期二, 01 七月 2025 15:55:20 +0800
Subject: [PATCH] 视频点赞实现
---
consumer/src/main/java/cn/lili/listener/VideoMessageListener.java | 8 ++++++++
1 files changed, 8 insertions(+), 0 deletions(-)
diff --git a/consumer/src/main/java/cn/lili/listener/VideoMessageListener.java b/consumer/src/main/java/cn/lili/listener/VideoMessageListener.java
index 1bedb96..e970292 100644
--- a/consumer/src/main/java/cn/lili/listener/VideoMessageListener.java
+++ b/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);
+ }
+
}
--
Gitblit v1.8.0