From e34f7eab3636702a23ed187c4a7516bae3782ec5 Mon Sep 17 00:00:00 2001 From: wuchunlei Date: Thu, 9 Jan 2025 15:57:17 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E7=94=A8=E6=88=B7=E8=AF=BE?= =?UTF-8?q?=E7=A8=8B=E8=BF=87=E6=9C=9F=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../modules/mq/Consumer/CourseConsumer.java | 18 ++++++++++-------- 1 file changed, 10 insertions(+), 8 deletions(-) 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()); + } } }