From 1cdb060a8aa59b0979f7609db1781805528e76e7 Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期三, 25 六月 2025 18:25:42 +0800
Subject: [PATCH] 视频评论数、收藏数通过mq、redis实现
---
consumer/src/main/java/cn/lili/listener/CommentMessageListener.java | 14 ++------------
1 files changed, 2 insertions(+), 12 deletions(-)
diff --git a/consumer/src/main/java/cn/lili/listener/CommentMessageListener.java b/consumer/src/main/java/cn/lili/listener/CommentMessageListener.java
index 5d87495..f5204ac 100644
--- a/consumer/src/main/java/cn/lili/listener/CommentMessageListener.java
+++ b/consumer/src/main/java/cn/lili/listener/CommentMessageListener.java
@@ -1,18 +1,11 @@
package cn.lili.listener;
-import cn.lili.base.Result;
import cn.lili.cache.Cache;
-import cn.lili.cache.CachePrefix;
-import cn.lili.common.security.context.UserContext;
-import cn.lili.modules.lmk.constant.RedisKeyExpireConstant;
import cn.lili.modules.lmk.domain.entity.ThumbsUpRecord;
-import cn.lili.modules.lmk.domain.entity.VideoComment;
-import cn.lili.modules.lmk.domain.form.ThumbsUpRecordForm;
import cn.lili.modules.lmk.service.ThumbsUpRecordService;
import cn.lili.modules.lmk.service.VideoCommentService;
import cn.lili.rocketmq.tags.CommentTagsEnum;
import com.alibaba.fastjson.JSON;
-import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.rocketmq.common.message.MessageExt;
@@ -20,9 +13,6 @@
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
-
-import java.util.Objects;
-import java.util.concurrent.TimeUnit;
/**
* 璇勮娑堟伅娑堣垂鑰�
@@ -87,7 +77,7 @@
* @param msg
*/
public void cancelThumbsUp(String msg) {
- ThumbsUpRecordForm form = JSON.parseObject(msg, ThumbsUpRecordForm.class);
- videoCommentService.mqCancelThumbsUp(form);
+ ThumbsUpRecord record = JSON.parseObject(msg, ThumbsUpRecord.class);
+ videoCommentService.mqCancelThumbsUp(record);
}
}
--
Gitblit v1.8.0