From 095c52c6ec7882ce11177178b49d33e6c886af61 Mon Sep 17 00:00:00 2001
From: peng <peng.com>
Date: 星期一, 17 十一月 2025 15:02:38 +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