diff --git a/src/main/java/com/peanut/modules/mq/Consumer/CourseConsumer.java b/src/main/java/com/peanut/modules/mq/Consumer/CourseConsumer.java
index b5e26995..6ec8e3ca 100644
--- a/src/main/java/com/peanut/modules/mq/Consumer/CourseConsumer.java
+++ b/src/main/java/com/peanut/modules/mq/Consumer/CourseConsumer.java
@@ -19,14 +19,16 @@ public class CourseConsumer {
     @RabbitListener(queues = DelayQueueConfig.COURSE_QUEUE)
     public void courseConsumer(String userCourseBuyId) {
         UserCourseBuyEntity userCourseBuyEntity = userCourseBuyDao.selectById(userCourseBuyId);
-        if (userCourseBuyEntity.getStartTime()==null) {
-            //未开始学习，超过一年自动开始
-            userCourseBuyEntity.setStartTime(DateUtils.addYears(userCourseBuyEntity.getCreateTime(),1));
-            userCourseBuyEntity.setEndTime(DateUtils.addDays(userCourseBuyEntity.getStartTime(),userCourseBuyEntity.getDays()));
-            userCourseBuyDao.updateById(userCourseBuyEntity);
-        }else {
-            //结束时间，过期删除
-            userCourseBuyDao.deleteById(userCourseBuyEntity.getId());
+        if (userCourseBuyEntity!=null){
+            if (userCourseBuyEntity.getStartTime()==null) {
+                //未开始学习，超过一年自动开始
+                userCourseBuyEntity.setStartTime(DateUtils.addYears(userCourseBuyEntity.getCreateTime(),1));
+                userCourseBuyEntity.setEndTime(DateUtils.addDays(userCourseBuyEntity.getStartTime(),userCourseBuyEntity.getDays()));
+                userCourseBuyDao.updateById(userCourseBuyEntity);
+            }else {
+                //结束时间，过期删除
+                userCourseBuyDao.deleteById(userCourseBuyEntity.getId());
+            }
         }
     }