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); } }