提交 4138b031 作者: obcy

【fix】

上级 376cdb94
...@@ -353,6 +353,7 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl ...@@ -353,6 +353,7 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl
//插入新的 //插入新的
saveMapMain(subject, subjectPage); saveMapMain(subject, subjectPage);
if (oldSubject.getSubjectType() == 1) { if (oldSubject.getSubjectType() == 1) {
log.info("更新专题,专题类型为1,更新redis缓存");
//修改redis缓存,,用于向专题里补充数据 //修改redis缓存,,用于向专题里补充数据
updateRedisCache(subject, oldSubject); updateRedisCache(subject, oldSubject);
} }
...@@ -823,6 +824,7 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl ...@@ -823,6 +824,7 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl
private void updateRedisCache(Subject subject, Subject oldSubject) { private void updateRedisCache(Subject subject, Subject oldSubject) {
Date firstOpenTime = oldSubject.getFirstOpenTime(); Date firstOpenTime = oldSubject.getFirstOpenTime();
if (firstOpenTime != null) { if (firstOpenTime != null) {
log.info("修改专题时间缓存,专题id:{}", subject.getId());
Date oldTimeEnable = oldSubject.getTimeEnable(); Date oldTimeEnable = oldSubject.getTimeEnable();
Date oldTimeDisable = oldSubject.getTimeDisable(); Date oldTimeDisable = oldSubject.getTimeDisable();
LocalDate oldStart; LocalDate oldStart;
...@@ -864,13 +866,16 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl ...@@ -864,13 +866,16 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl
} }
} }
if (CollectionUtils.isNotEmpty(newDateList)) { if (CollectionUtils.isNotEmpty(newDateList)) {
if (redisUtil.hasKey(Constants.HISTORY_SUBJECT_DATE_QUEUE + oldSubject.getSubjectCode())) {
//防止重复 //防止重复
if (redisUtil.hasKey(Constants.HISTORY_SUBJECT_DATE_QUEUE + subject.getSubjectCode())) { log.info("防止日期重复");
newDateList.forEach(e -> { newDateList.forEach(e -> {
redisUtil.lRemove(Constants.HISTORY_SUBJECT_DATE_QUEUE + subject.getSubjectCode(), 0, e); redisUtil.lRemove(Constants.HISTORY_SUBJECT_DATE_QUEUE + oldSubject.getSubjectCode(), 0, e);
}); });
} }
redisUtil.rpushMultipleValues(Constants.HISTORY_SUBJECT_DATE_QUEUE + subject.getSubjectCode(), newDateList.toArray(new String[0])); redisUtil.rpushMultipleValues(Constants.HISTORY_SUBJECT_DATE_QUEUE + oldSubject.getSubjectCode(), newDateList.toArray(new String[0]));
log.info("修改专题时间缓存,专题id:{},新增时间完成", oldSubject.getId());
} }
} }
} }
......
...@@ -573,6 +573,7 @@ public class RedisUtil { ...@@ -573,6 +573,7 @@ public class RedisUtil {
} }
public void rpushMultipleValues(String key, Object... values) { public void rpushMultipleValues(String key, Object... values) {
log.info("key:{},values:{}",key,values);
redisTemplate.opsForList().rightPushAll(key, values); redisTemplate.opsForList().rightPushAll(key, values);
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论