deason 8 months ago
parent
commit
43a91840d2

+ 2 - 1
src/main/java/com/qmth/exam/reserve/cache/impl/ApplyTaskCacheService.java

@@ -359,6 +359,7 @@ public class ApplyTaskCacheService implements CacheConstants {
         }
         }
 
 
         // 缓存不存在时,从数据库再查一次
         // 缓存不存在时,从数据库再查一次
+        /*
         StudentApplyEntity entity = this.getStudentApplyRecordFormDB(studentId, examSiteId, timePeriodId);
         StudentApplyEntity entity = this.getStudentApplyRecordFormDB(studentId, examSiteId, timePeriodId);
         if (entity != null) {
         if (entity != null) {
             cacheBean = new ApplyRecordCacheBean();
             cacheBean = new ApplyRecordCacheBean();
@@ -369,7 +370,7 @@ public class ApplyTaskCacheService implements CacheConstants {
             cacheBean.setOperateId(entity.getOperateId());
             cacheBean.setOperateId(entity.getOperateId());
             cacheBean.setOperateTime(entity.getUpdateTime());
             cacheBean.setOperateTime(entity.getUpdateTime());
             return cacheBean;
             return cacheBean;
-        }
+        }*/
 
 
         return null;
         return null;
     }
     }

+ 2 - 0
src/main/java/com/qmth/exam/reserve/mq/ExamReserveMQConsumer.java

@@ -57,6 +57,8 @@ public class ExamReserveMQConsumer implements RocketMQListener<MessageExt> {
 
 
             // 若缓存数据不存在,则采用队列数据持久化
             // 若缓存数据不存在,则采用队列数据持久化
             bean = queueBean;
             bean = queueBean;
+            // 更新缓存
+            applyTaskCacheService.saveStudentApplyRecord(bean);
         } else {
         } else {
             if (cacheBean.getBizId() != null && cacheBean.getBizId() >= queueBean.getBizId()) {
             if (cacheBean.getBizId() != null && cacheBean.getBizId() >= queueBean.getBizId()) {
                 log.info("【考生预约队列】MQ消息消费!bizId:{} cacheBizId:{} msgId:{}", queueBean.getBizId(),
                 log.info("【考生预约队列】MQ消息消费!bizId:{} cacheBizId:{} msgId:{}", queueBean.getBizId(),