refactor(task): 移除视频生成通知的Redis缓存逻辑
All checks were successful
ZhenTu-BE/pipeline/head This commit looks good

- 删除了检查Redis中memberId是否在3分钟内已发送过通知的代码
- 移除了发送成功后设置Redis缓存的逻辑
- 简化了通知发送流程,直接发送消息而不进行缓存控制- 更新了日志记录,移除了缓存相关的调试信息- 保留了核心的通知发送功能和必要的业务逻辑
This commit is contained in:
2025-10-24 16:22:20 +08:00
parent bed3a4e3c9
commit 841c89af04

View File

@@ -626,15 +626,6 @@ public class TaskTaskServiceImpl implements TaskService {
@Override @Override
public void sendVideoGeneratedServiceNotification(Long taskId, Long memberId) { 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); MemberVideoEntity item = videoMapper.queryRelationByMemberTask(memberId, taskId);
MemberRespVO member = memberMapper.getById(memberId); MemberRespVO member = memberMapper.getById(memberId);
String openId = member.getOpenId(); String openId = member.getOpenId();
@@ -694,10 +685,7 @@ public class TaskTaskServiceImpl implements TaskService {
msg.setSendReason("视频生成通知"); msg.setSendReason("视频生成通知");
msg.setSendBiz("视频生成"); msg.setSendBiz("视频生成");
ztMessageProducerService.send(msg); ztMessageProducerService.send(msg);
log.info("memberId:{} 视频生成通知发送成功", memberId);
// 发送成功后,设置Redis缓存,2分钟过期
redisTemplate.opsForValue().set(notificationCacheKey, String.valueOf(System.currentTimeMillis()), NOTIFICATION_CACHE_EXPIRE_MINUTES, TimeUnit.MINUTES);
log.debug("memberId:{} 通知发送成功,已设置{}分钟缓存", memberId, NOTIFICATION_CACHE_EXPIRE_MINUTES);
} }
} }