2022年7月26日15:05:44 增加能否修改主题字段

王明元
1 parent 381454c1
Showing 2 changed files with 39 additions and 37 deletions
fw-dalaran-domain/src/main/java/cn/fw/dalaran/domain/vo/ActivityThemeVo.java
fw-dalaran-service/src/main/java/cn/fw/dalaran/service/data/impl/ActivityThemeServiceImpl.java
@@ -72,6 +72,10 @@ public class ActivityThemeVo {
      */
     @NotEmpty(message = "必须指定封面图文件")
     private List<FileDesc> allFileDesc;
+    /**
+     * 能否修改主题
+     */
+    private boolean canAlert;
  
     /**
      * vo->db
@@ -173,8 +173,7 @@ public class ActivityThemeServiceImpl extends ServiceImpl&lt;ActivityThemeDao, Acti
         List<String> oldTopic = Arrays.asList(theme.getTopic().split(",").clone());
         ArrayList<String> result = new ArrayList<>(newTopic);
         result.retainAll(oldTopic);
-        long timeSub = System.currentTimeMillis() - theme.getEndTime().getTime();
-        if (timeSub > 24 * 3600 * 1000 + 1000)
+        if (this.themeHaveStopCatchData(theme.getEndTime()))
             throw new BusinessException("活动已经结束数据抓取, 不能再增加话题");
         if (result.size() < oldTopic.size())
             throw new BusinessException("不允许删除原有话题");
@@ -199,8 +198,7 @@ public class ActivityThemeServiceImpl extends ServiceImpl&lt;ActivityThemeDao, Acti
                 .peek(item -> item.setType(FileTypeEnum.THEME_COVER.getValue()))
                 .collect(Collectors.toList());
         ActivityTheme theme = this.getById(themeId);
-        long timeSub = System.currentTimeMillis() - theme.getEndTime().getTime();
-        if (timeSub > 24 * 3600 * 1000 + 1000)
+        if (this.themeHaveStopCatchData(theme.getEndTime()))
             throw new BusinessException("活动已经结束数据抓取, 不能再增加封面");
         this.saveFiles(themeId, fileList);
         this.downloadAndConvertCover(theme, fileList);
@@ -223,17 +221,7 @@ public class ActivityThemeServiceImpl extends ServiceImpl&lt;ActivityThemeDao, Acti
                 .list()
                 .stream()
                 .map(ActivityTheme::toVO)
-                .peek(item -> item.setAllFileDesc(Optional.ofNullable(
-                        themeFileService
-                                .lambdaQuery()
-                                .eq(ThemeFile::getThemeId, item.getId())
-                                .eq(ThemeFile::getType, FileTypeEnum.THEME_COVER.getValue())
-                                .list())
-                        .orElse(new ArrayList<>())
-                        .stream()
-                        .map(ThemeFile::toVO)
-                        .collect(Collectors.toList()))
-                )
+                .peek(this::peekActivityThemeVo)
                 .collect(Collectors.toList());
     }
  
@@ -259,17 +247,7 @@ public class ActivityThemeServiceImpl extends ServiceImpl&lt;ActivityThemeDao, Acti
         }
         pageList.setData(dbList.stream()
                 .map(ActivityTheme::toVO)
-                .peek(item -> item.setAllFileDesc(Optional.ofNullable(
-                        themeFileService
-                                .lambdaQuery()
-                                .eq(ThemeFile::getThemeId, item.getId())
-                                .eq(ThemeFile::getType, FileTypeEnum.THEME_COVER.getValue())
-                                .list())
-                        .orElse(new ArrayList<>())
-                        .stream()
-                        .map(ThemeFile::toVO)
-                        .collect(Collectors.toList()))
-                )
+                .peek(this::peekActivityThemeVo)
                 .collect(Collectors.toList())
         );
         return pageList;
@@ -298,17 +276,7 @@ public class ActivityThemeServiceImpl extends ServiceImpl&lt;ActivityThemeDao, Acti
                 .stream()
                 .filter(item -> this.validDateOverlap(item.getStartTime(), item.getEndTime(), startTime, finalEndTime))
                 .map(ActivityTheme::toVO)
-                .peek(item -> item.setAllFileDesc(Optional.ofNullable(
-                        themeFileService
-                                .lambdaQuery()
-                                .eq(ThemeFile::getThemeId, item.getId())
-                                .eq(ThemeFile::getType, FileTypeEnum.THEME_COVER.getValue())
-                                .list())
-                        .orElse(new ArrayList<>())
-                        .stream()
-                        .map(ThemeFile::toVO)
-                        .collect(Collectors.toList()))
-                )
+                .peek(this::peekActivityThemeVo)
                 .sorted(Comparator.comparing(ActivityThemeVo::getStartTime))
                 .collect(Collectors.toList())
                 ;
@@ -434,4 +402,34 @@ public class ActivityThemeServiceImpl extends ServiceImpl&lt;ActivityThemeDao, Acti
                 .update();
     }
  
+    /**
+     * 判断主题是否结束数据抓取
+     *
+     * @param themeEndTime 主题结束时间
+     * @retur 主题是否结束数据抓取
+     */
+    private boolean themeHaveStopCatchData(Date themeEndTime) {
+        long timeSub = System.currentTimeMillis() - themeEndTime.getTime();
+        return timeSub > 24 * 3600 * 1000 + 1000;
+    }
+
+    /**
+     * 处理活动主题, 赋其他值
+     *
+     * @param item 待处理的活动主题
+     */
+    private void peekActivityThemeVo(ActivityThemeVo item) {
+        item.setCanAlert(!this.themeHaveStopCatchData(item.getEndTime()));
+        item.setAllFileDesc(Optional.ofNullable(
+                themeFileService.lambdaQuery()
+                        .eq(ThemeFile::getThemeId, item.getId())
+                        .eq(ThemeFile::getType, FileTypeEnum.THEME_COVER.getValue())
+                        .list())
+                .orElse(new ArrayList<>())
+                .stream()
+                .map(ThemeFile::toVO)
+                .collect(Collectors.toList())
+        );
+    }
+
 }