提交 758d8ef0 作者: obcy

【专题日期缓存倒叙入队列--专题添加字段】

上级 23ecd299
......@@ -101,6 +101,8 @@ public class Subject implements Serializable {
private Integer enterpriseCheck;
/**备注*/
private String remark;
/**是否处理无发布时间的资讯:1是,0否*/
private Integer noPublishTimeFlag;
/**是否是平台创建的专题(0否--外部创建 1是--平台创建 )*/
private String isPlatform;
/**第一次启用时间*/
......
......@@ -795,14 +795,17 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl
}
//循环 start 到 end 的每一天
List<String> dateList = new ArrayList<>();
for (LocalDate date = start; !date.isAfter(end); date = date.plusDays(1)) {
for (LocalDate date = end; !date.isBefore(start); date = date.minusDays(1)) {
// 在这里处理每一天的逻辑
//格式化date成字符串
String format = date.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
dateList.add(format);
}
redisUtil.rpushMultipleValues(Constants.HISTORY_SUBJECT_DATE_QUEUE + subject.getSubjectCode(), dateList.toArray(new String[0]));
if (ObjectUtil.isNotEmpty(subject.getNoPublishTimeFlag()) && 1 == subject.getNoPublishTimeFlag()) {
//配置了需要拉取无发布时间的才处理
redisUtil.rpushMultipleValues(Constants.HISTORY_SUBJECT_DATE_QUEUE + subject.getSubjectCode(), "noPublishDate");
}
}
......@@ -849,7 +852,7 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl
if (timeDisable != null) {
LocalDate end = timeDisable.toInstant().atZone(ZoneId.systemDefault()).toLocalDate();
if (end.isAfter(oldEnd)) {
for (LocalDate date = oldEnd.plusDays(1); !date.isAfter(end); date = date.plusDays(1)) {
for (LocalDate date = end; !date.isBefore(oldEnd.plusDays(1)); date = date.minusDays(1)) {
// 在这里处理每一天的逻辑
//格式化date成字符串
String format = date.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
......
......@@ -183,4 +183,6 @@ public class SubjectPage {
private List<ClbModelArrange> clbModelArranges;
/** 环境 1-测试 2-正式 */
private String environment;
/**是否处理无发布时间的资讯:1是,0否--默认为0*/
private Integer noPublishTimeFlag=0;
}
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论