From 328105ebdbb82a923c2a02ed01786c129a4aacb1 Mon Sep 17 00:00:00 2001
From: zxl <763096477@qq.com>
Date: 星期四, 23 十月 2025 17:33:07 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/user_action' into user_action
---
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