From b9b8b93a1b8ec1954ffc690093cb4628477de8c2 Mon Sep 17 00:00:00 2001
From: peng <peng.com>
Date: 星期三, 22 十月 2025 14:11:49 +0800
Subject: [PATCH] 导出excel添加用户id
---
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