diff --git a/src/main/java/com/sqx/modules/course/service/impl/CourseCollectServiceImpl.java b/src/main/java/com/sqx/modules/course/service/impl/CourseCollectServiceImpl.java
index 749d1665..017178eb 100644
--- a/src/main/java/com/sqx/modules/course/service/impl/CourseCollectServiceImpl.java
+++ b/src/main/java/com/sqx/modules/course/service/impl/CourseCollectServiceImpl.java
@@ -148,6 +148,9 @@ public class CourseCollectServiceImpl extends ServiceImpl<CourseCollectDao, Cour
         //详情id
         Set<Long> courseDetailIds = new HashSet<>();
         courses.forEach(s -> {
+            if (s==null) {
+                return;
+            }
             courseIdList.add(s.getCourseId());
             courseDetailIds.add(s.getCourseDetailsId());
         });
diff --git a/src/main/java/com/sqx/modules/course/service/impl/CourseDetailsServiceImpl.java b/src/main/java/com/sqx/modules/course/service/impl/CourseDetailsServiceImpl.java
index 4ad75762..b99edaad 100644
--- a/src/main/java/com/sqx/modules/course/service/impl/CourseDetailsServiceImpl.java
+++ b/src/main/java/com/sqx/modules/course/service/impl/CourseDetailsServiceImpl.java
@@ -163,6 +163,10 @@ public class CourseDetailsServiceImpl extends ServiceImpl<CourseDetailsDao, Cour
                 .eq("user_id", userId).eq("course_id", courseId)
                 .eq("classify", 1).last("limit 1"));
         Course bean = courseDao.selectById(courseId);
+        if(bean==null){
+            log.error("未找到该剧集 用户id:{} 剧集:{}",userId,courseId);
+            return Result.error("未找到该剧集");
+        }
         //查询用户是否购买了整集
         CourseUser courseUser = courseUserDao.selectCourseUser(courseId, userId);
         // 每天购买超过上限，获得免费时间段资格