Преглед на файлове

savePublishContentCache fix

wangyunpeng преди 1 ден
родител
ревизия
0570101d06
променени са 1 файла, в които са добавени 5 реда и са изтрити 2 реда
  1. 5 2
      long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/service/XxlJobService.java

+ 5 - 2
long-article-recommend-service/src/main/java/com/tzld/longarticle/recommend/server/service/XxlJobService.java

@@ -1135,12 +1135,15 @@ public class XxlJobService {
         if (findAll) {
             longArticleBaseMapper.deleteGzhWaitingByPlanIdAccountId(planId, accountId);
         }
-        List<PublishContentGzhWaiting> existList = publishContentGzhWaitingRepository.getByIdIn(contentIds);
+        List<PublishContentGzhWaiting> existList = new ArrayList<>();
+        if (!findAll) {
+            existList = publishContentGzhWaitingRepository.getByIdIn(contentIds);
+        }
         List<String> existContentIds = existList.stream().map(PublishContentGzhWaiting::getId).collect(Collectors.toList());
         List<PublishContentGzhWaiting> saveList = new ArrayList<>();
         for (Content content : contentList) {
             // 已存在跳过
-            if (existContentIds.contains(content.getId())) {
+            if (!findAll && existContentIds.contains(content.getId())) {
                 continue;
             }
             // 新增