diff --git a/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java b/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java index 127e7520..07a62fc5 100644 --- a/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java +++ b/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java @@ -46,18 +46,14 @@ public class DownloadNotificationTasker { @Autowired private WechatSubscribeNotifyTriggerService notifyTriggerService; @Autowired - private ZtMessageProducerService ztMessageProducerService; - @Autowired - private NotificationAuthUtils notificationAuthUtils; - @Autowired private VideoTaskRepository videoTaskRepository; - @Scheduled(cron = "0 0 21 * * *") + @Scheduled(cron = "0 0 9,21 * * *") public void sendDownloadNotification() { log.info("开始执行定时任务"); // 用于记录已发送通知的用户ID,避免重复发送 Set sentMemberIds = ConcurrentHashMap.newKeySet(); - videoMapper.listRelationByCreateTime(new Date(System.currentTimeMillis() - 24 * 60 * 60 * 1000), new Date()) + videoMapper.listRelationByCreateTime(new Date(System.currentTimeMillis() - 12 * 60 * 60 * 1000), new Date()) .forEach(item -> { // 检查该用户是否已经发送过通知,避免重复发送 if (sentMemberIds.contains(item.getMemberId())) {