绿满筐商城java服务
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xiangpei
9 天以前 1cdb060a8aa59b0979f7609db1781805528e76e7 
 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);


    }


}