Browse Source

【第一版开发】
1.增加线程池配置
2.修复ProductHunt数据重复拉取异常
3.ProductHunt定时任务增加翻译逻辑

1.增加过滤当天新股数据的逻辑

ChenYL 10 months ago
parent
commit
54826ff690

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

@@ -1,9 +1,12 @@
 package com.dataeasy.server.task;
 package com.dataeasy.server.task;
 
 
+import java.time.LocalDate;
 import java.util.ArrayList;
 import java.util.ArrayList;
+import java.util.Date;
 import java.util.List;
 import java.util.List;
 import java.util.stream.Collectors;
 import java.util.stream.Collectors;
 
 
+import com.dataeasy.server.utiis.DateUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -20,6 +23,7 @@ import com.dataeasy.server.feign.dto.finance.StockResponse;
 
 
 import lombok.extern.slf4j.Slf4j;
 import lombok.extern.slf4j.Slf4j;
 import me.chanjar.weixin.mp.bean.template.WxMpTemplateData;
 import me.chanjar.weixin.mp.bean.template.WxMpTemplateData;
+import org.springframework.util.StringUtils;
 
 
 /**
 /**
  * @author tyuio
  * @author tyuio
@@ -54,7 +58,11 @@ public class IpoStockTask extends AbstractDataTask {
             return false;
             return false;
         }
         }
 
 
-        List<DataIpoStock> ipoStocks = stockXgsglbEmList.stream().map(v -> {
+        // 过滤当天新股数据
+        String todayStr = DateUtils.YYYY_MM_DD_FORMATTER.format(LocalDate.now());
+        List<DataIpoStock> ipoStocks = stockXgsglbEmList.stream().filter(v -> StringUtils.hasText(v.getSubscriptionDate()))
+                .filter(v -> todayStr.equals(v.getSubscriptionDate()))
+                .map(v -> {
             DataIpoStock ipoStock = new DataIpoStock();
             DataIpoStock ipoStock = new DataIpoStock();
             BeanUtils.copyProperties(v, ipoStock);
             BeanUtils.copyProperties(v, ipoStock);
             return ipoStock;
             return ipoStock;