From 654f4eebf519f015506b90d71637e6aad75e5b5c Mon Sep 17 00:00:00 2001 From: xiangpei <xiangpei@timesnew.cn> Date: 星期三, 25 六月 2025 14:33:26 +0800 Subject: [PATCH] 视频评论点赞通过mq异步添加数据库,点赞数缓存redis --- lmk-job/src/main/java/cn/lili/job/VideoJob.java | 17 +++++++++++++++++ 1 files changed, 17 insertions(+), 0 deletions(-) diff --git a/lmk-job/src/main/java/cn/lili/job/VideoJob.java b/lmk-job/src/main/java/cn/lili/job/VideoJob.java index 7b3b710..9ff9d00 100644 --- a/lmk-job/src/main/java/cn/lili/job/VideoJob.java +++ b/lmk-job/src/main/java/cn/lili/job/VideoJob.java @@ -3,6 +3,7 @@ import cn.lili.modules.lmk.domain.vo.CollectTypeNumVO; import cn.lili.modules.lmk.enums.general.CollectTypeEnum; import cn.lili.modules.lmk.service.MyCollectService; +import cn.lili.modules.lmk.service.ThumbsUpRecordService; import cn.lili.modules.lmk.service.VideoCommentService; import cn.lili.modules.lmk.service.VideoService; import com.xxl.job.core.context.XxlJobHelper; @@ -26,6 +27,7 @@ private final VideoService videoService; private final MyCollectService myCollectService; private final VideoCommentService videoCommentService; + private final ThumbsUpRecordService thumbsUpRecordService; /** * 瑙嗛鏀惰棌鏁扮粺璁� @@ -55,4 +57,19 @@ } } + /** + * 瑙嗛璇勮鐐硅禐鏁扮粺璁� + * + * @throws Exception + */ + @XxlJob("videoCommentThumbsUpNumJob") + public void videoCommentThumbsUpNumJob() throws Exception { + XxlJobHelper.log("寮�濮嬫墽琛岋細璇勮鐐硅禐鏁扮粺璁�"); + + List<CollectTypeNumVO> numList = thumbsUpRecordService.countNumGroupByComment(); + if (CollectionUtils.isNotEmpty(numList)) { + videoCommentService.updateCommentThumbsUpNumBatch(numList); + } + } + } -- Gitblit v1.8.0