diff --git a/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java b/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java
index 4738b435..c005f973 100644
--- a/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java
+++ b/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java
@@ -66,6 +66,10 @@ public class DownloadNotificationTasker {
                     }
 
                     MemberRespVO member = memberMapper.getById(item.getMemberId());
+                    if (member == null || member.getOpenId() == null) {
+                        log.debug("用户[memberId={}]不存在或未绑定微信，跳过", item.getMemberId());
+                        return;
+                    }
                     // 发送模板消息
                     HashMap<String, Object> variables = new HashMap<>();
                     ScenicV2DTO scenic = scenicRepository.getScenicBasic(item.getScenicId());
@@ -111,6 +115,10 @@ public class DownloadNotificationTasker {
                     sentMemberIds.add(item.getMemberId());
                     
                     MemberRespVO member = memberMapper.getById(item.getMemberId());
+                    if (member == null || member.getOpenId() == null) {
+                        log.debug("用户[memberId={}]不存在或未绑定微信，跳过", item.getMemberId());
+                        return;
+                    }
                     ScenicConfigManager scenicConfig = scenicRepository.getScenicConfigManager(item.getScenicId());
                     Integer videoStoreDay = scenicConfig.getInteger("video_store_day");
                     if (videoStoreDay == null) {
@@ -161,6 +169,10 @@ public class DownloadNotificationTasker {
                     sentMemberIds.add(item.getMemberId());
 
                     MemberRespVO member = memberMapper.getById(item.getMemberId());
+                    if (member == null || member.getOpenId() == null) {
+                        log.debug("用户[memberId={}]不存在或未绑定微信，跳过", item.getMemberId());
+                        return;
+                    }
                     ScenicConfigManager scenicConfig = scenicRepository.getScenicConfigManager(item.getScenicId());
                     Integer videoStoreDay = scenicConfig.getInteger("video_store_day");
                     if (videoStoreDay == null) {
@@ -237,6 +249,10 @@ public class DownloadNotificationTasker {
                         }
                         
                         MemberRespVO member = memberMapper.getById(item.getMemberId());
+                        if (member == null || member.getOpenId() == null) {
+                            log.debug("用户[memberId={}]不存在或未绑定微信，跳过", item.getMemberId());
+                            return;
+                        }
                         // 发送模板消息
                         HashMap<String, Object> variables = new HashMap<>();
                         variables.put("scenicName", scenic.getName());