From d9360acb5f4a7817a0b472cb2cbbebd80ca86a9b Mon Sep 17 00:00:00 2001
From: Jerry Yan <792602257@qq.com>
Date: Thu, 8 May 2025 17:21:09 +0800
Subject: [PATCH] bug

---
 .../com/ycwl/basic/task/DownloadNotificationTasker.java   | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java b/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java
index f109cd2..9e33c0d 100644
--- a/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java
+++ b/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java
@@ -167,11 +167,11 @@ public class DownloadNotificationTasker {
             log.info("当前景区{}，配置了{}", scenic.getName(), scenicConfig.getExtraNotificationTime());
 
             videoMapper.listRelationByCreateTime(DateUtil.beginOfDay(new Date()), new Date())
-                    .parallelStream()
+                    .stream()
+                    .filter(item -> item.getIsBuy() == 0)
+                    .filter(item -> item.getScenicId().equals(scenicId))
+                    .parallel()
                     .forEach(item -> {
-                        if (item.getIsBuy() == 1) {
-                            return;
-                        }
                         MemberRespVO member = memberMapper.getById(item.getMemberId());
                         MpConfigEntity scenicMp = scenicRepository.getScenicMpConfig(member.getScenicId());
                         // 发送模板消息