From 841c89af04ef0cd58d9cf2e83446f3f856107bc7 Mon Sep 17 00:00:00 2001 From: Jerry Yan <792602257@qq.com> Date: Fri, 24 Oct 2025 16:22:20 +0800 Subject: [PATCH] =?UTF-8?q?refactor(task):=20=E7=A7=BB=E9=99=A4=E8=A7=86?= =?UTF-8?q?=E9=A2=91=E7=94=9F=E6=88=90=E9=80=9A=E7=9F=A5=E7=9A=84Redis?= =?UTF-8?q?=E7=BC=93=E5=AD=98=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 删除了检查Redis中memberId是否在3分钟内已发送过通知的代码 - 移除了发送成功后设置Redis缓存的逻辑 - 简化了通知发送流程,直接发送消息而不进行缓存控制- 更新了日志记录,移除了缓存相关的调试信息- 保留了核心的通知发送功能和必要的业务逻辑 --- .../service/task/impl/TaskTaskServiceImpl.java | 14 +------------- 1 file changed, 1 insertion(+), 13 deletions(-) diff --git a/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java b/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java index ecd3a236..e6735fdb 100644 --- a/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java +++ b/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java @@ -626,15 +626,6 @@ public class TaskTaskServiceImpl implements TaskService { @Override public void sendVideoGeneratedServiceNotification(Long taskId, Long memberId) { - // 检查Redis中该memberId是否在3分钟内已发送过通知 - String notificationCacheKey = String.format(VIDEO_NOTIFICATION_CACHE_KEY, memberId); - String cachedValue = redisTemplate.opsForValue().get(notificationCacheKey); - - if (cachedValue != null) { - log.info("memberId:{} 在3分钟内已发送过通知,跳过本次发送", memberId); - return; - } - MemberVideoEntity item = videoMapper.queryRelationByMemberTask(memberId, taskId); MemberRespVO member = memberMapper.getById(memberId); String openId = member.getOpenId(); @@ -694,10 +685,7 @@ public class TaskTaskServiceImpl implements TaskService { msg.setSendReason("视频生成通知"); msg.setSendBiz("视频生成"); ztMessageProducerService.send(msg); - - // 发送成功后,设置Redis缓存,2分钟过期 - redisTemplate.opsForValue().set(notificationCacheKey, String.valueOf(System.currentTimeMillis()), NOTIFICATION_CACHE_EXPIRE_MINUTES, TimeUnit.MINUTES); - log.debug("memberId:{} 通知发送成功,已设置{}分钟缓存", memberId, NOTIFICATION_CACHE_EXPIRE_MINUTES); + log.info("memberId:{} 视频生成通知发送成功", memberId); } }