Merge remote-tracking branch 'origin/event_fusion' into event_fusion

src/main/java/com/zzsn/event/service/impl/SubjectServiceImpl.java

@@ -785,6 +785,7 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl
             String format = date.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
             dateList.add(format);
         }
+        redisUtil.rpushMultipleValues(Constants.HISTORY_SUBJECT_DATE_QUEUE + subject.getSubjectCode(), "noPublishDate");
         redisUtil.rpushMultipleValues(Constants.HISTORY_SUBJECT_DATE_QUEUE + subject.getSubjectCode(), dateList.toArray(new String[0]));
     }
 
@@ -840,6 +841,10 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl
                     }
                 }
                 if (CollectionUtils.isNotEmpty(newDateList)) {
+                    //防止重复
+                    newDateList.forEach(e -> {
+                       redisUtil.lRemove(Constants.HISTORY_SUBJECT_DATE_QUEUE + subject.getSubjectCode(), 1, e);
+                    });
                     redisUtil.rpushMultipleValues(Constants.HISTORY_SUBJECT_DATE_QUEUE + subject.getSubjectCode(), newDateList.toArray(new String[0]));
                 }
             }