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());
                         // 发送模板消息