【第一版开发】

1.提交漏提交代码
2.定时任务增加清除缓存代码

data-easy/src/main/java/com/dataeasy/server/pojo/task/ProductHuntTranslateDto.java

@@ -3,10 +3,10 @@ package com.dataeasy.server.pojo.task;
 import lombok.Data;
 
 /**
- * @author myou
+ * @author tyuio
  * @version 1.0.0
- * @date 2025/3/15 15:58
- * @description ProductHunt 翻译数据
+ * @date 2025/3/17 19:28
+ * @description ProductHunt翻译模板 DTO
  */
 @Data
 public class ProductHuntTranslateDto {
@@ -16,6 +16,11 @@ public class ProductHuntTranslateDto {
      */
     private Long id;
 
+    /**
+     * 关键词
+     */
+    private String key;
+
     /**
      * 标语
      */
@@ -25,9 +30,4 @@ public class ProductHuntTranslateDto {
      * 描述
      */
     private String description;
-
-    /**
-     * 关键词
-     */
-    private String key;
 }

data-easy/src/main/java/com/dataeasy/server/task/AbstractDataTask.java

@@ -8,6 +8,7 @@ import java.util.Set;
 import java.util.stream.Collectors;
 
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cache.CacheManager;
 import org.springframework.util.CollectionUtils;
 import org.springframework.util.StringUtils;
 
@@ -58,6 +59,9 @@ public abstract class AbstractDataTask {
     @Autowired
     protected WxMessageProperties wxMessageProperties;
 
+    @Autowired
+    protected CacheManager cacheManager;
+
     /**
      * 定时任务执行逻辑
      */

data-easy/src/main/java/com/dataeasy/server/task/DaLeTouTask.java

@@ -4,6 +4,7 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;
 
+import com.dataeasy.server.constant.CacheNameConstant;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -58,6 +59,9 @@ public class DaLeTouTask extends AbstractHzApiTask {
         BeanUtils.copyProperties(daLeTouResponse, addDaLeTou);
         daLeTouService.insert(addDaLeTou);
 
+        // 清除缓存，以防缓存中数据过时
+        cacheManager.getCache(CacheNameConstant.DATA_DA_LE_TOU_LIST).evict(addDaLeTou.getQihao());
+
         return true;
     }
 

data-easy/src/main/java/com/dataeasy/server/task/IpoBondTask.java

@@ -5,6 +5,7 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.stream.Collectors;
 
+import com.dataeasy.server.constant.CacheNameConstant;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -67,6 +68,9 @@ public class IpoBondTask extends AbstractDataTask {
         // 数据入库
         ipoBondService.insertList(ipoBonds);
 
+        // 清除缓存，以防缓存中数据过时
+        cacheManager.getCache(CacheNameConstant.DATA_IPO_BOND_LIST).evict(todayStr);
+
         return true;
     }
 

data-easy/src/main/java/com/dataeasy/server/task/IpoStockTask.java

@@ -5,6 +5,7 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.stream.Collectors;
 
+import com.dataeasy.server.constant.CacheNameConstant;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -77,6 +78,9 @@ public class IpoStockTask extends AbstractDataTask {
         // 数据入库
         ipoStockService.insertList(ipoStocks);
 
+        // 清除缓存，以防缓存中数据过时
+        cacheManager.getCache(CacheNameConstant.DATA_IPO_STOCK_LIST).evict(todayStr);
+
         return true;
     }
 

data-easy/src/main/java/com/dataeasy/server/task/ProductHuntTask.java

@@ -16,6 +16,7 @@ import java.util.function.Function;
 import java.util.stream.Collectors;
 
 import com.dataeasy.server.common.exception.BusinessException;
+import com.dataeasy.server.constant.CacheNameConstant;
 import com.dataeasy.server.pojo.task.ProductHuntTranslateDto;
 import com.dataeasy.server.utiis.DateUtils;
 import com.fasterxml.jackson.core.type.TypeReference;
@@ -198,6 +199,9 @@ public class ProductHuntTask extends AbstractDataTask {
         // 数据入库
         productHuntPostService.insertList(posts);
 
+        // 清除缓存，以防缓存中数据过时
+        cacheManager.getCache(CacheNameConstant.DATA_PRODUCT_HUNT_POST_LIST).evict(rankDate);
+
         return true;
     }
 

data-easy/src/main/java/com/dataeasy/server/task/ShuangSeQiuTask.java

@@ -4,6 +4,7 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;
 
+import com.dataeasy.server.constant.CacheNameConstant;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -58,6 +59,9 @@ public class ShuangSeQiuTask extends AbstractHzApiTask {
         BeanUtils.copyProperties(shuangSeQiuResponse, addShuangSeQiu);
         shuangSeQiuService.insert(addShuangSeQiu);
 
+        // 清除缓存，以防缓存中数据过时
+        cacheManager.getCache(CacheNameConstant.DATA_SHUANG_SE_QIU_LIST).evict(addShuangSeQiu.getQihao());
+
         return true;
     }