From cab41175eaad28fc5f2153bf860046db80d52d59 Mon Sep 17 00:00:00 2001
From: dengli <dengli@juyou88.com>
Date: Wed, 3 Jan 2024 18:32:34 +0800
Subject: [PATCH] =?UTF-8?q?=E7=88=AC=E5=8F=96=E6=96=B0=E9=97=BB=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E6=B5=8B=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../infrastructure/job/InvestingTask.java     | 40 ++++++++++++++
 .../market/infrastructure/job/StockTask.java  | 52 +++++++++----------
 2 files changed, 66 insertions(+), 26 deletions(-)

diff --git a/src/main/java/cn/stock/market/infrastructure/job/InvestingTask.java b/src/main/java/cn/stock/market/infrastructure/job/InvestingTask.java
index e74913e..1609373 100644
--- a/src/main/java/cn/stock/market/infrastructure/job/InvestingTask.java
+++ b/src/main/java/cn/stock/market/infrastructure/job/InvestingTask.java
@@ -1,8 +1,12 @@
 package cn.stock.market.infrastructure.job;
 
+import cn.stock.market.domain.basic.entity.SiteNews;
 import cn.stock.market.domain.basic.entity.Stock;
+import cn.stock.market.domain.basic.repository.SiteNewsRepository;
 import cn.stock.market.domain.basic.repository.StockRepository;
+import cn.stock.market.domain.basic.service.StockService;
 import cn.stock.market.infrastructure.api.investing.InvestingInvokerApis;
+import cn.stock.market.infrastructure.db.po.QSiteNewsPO;
 import cn.stock.market.utils.Utils;
 import com.ag.utils.CollectionUtils;
 import com.alibaba.fastjson.JSON;
@@ -11,10 +15,12 @@ import com.alibaba.fastjson.JSONObject;
 import com.google.common.base.Stopwatch;
 import com.google.common.collect.Lists;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 import java.io.IOException;
+import java.util.Arrays;
 import java.util.Date;
 import java.util.List;
 import java.util.Map;
@@ -24,6 +30,11 @@ import java.util.concurrent.TimeUnit;
 @Component
 public class InvestingTask {
 
+    @Autowired
+    StockService stockService;
+    @Autowired
+    SiteNewsRepository newsRepository;
+
 //    @Scheduled(cron = "0 0 6 * * ?")
     public void syncIndiaData(){
         log.info("同步股票数据开始。。。。");
@@ -94,4 +105,33 @@ public class InvestingTask {
         }
 
     }
+
+    /*新闻接口*/
+    //@Scheduled(cron = "0 0 1 * * ?")
+    @Scheduled(cron = "*/10 * * * * ?")
+    public void saveStockNews() {
+        String news = stockService.getNews();
+        List<String> newsList = Arrays.asList(news.split("<a href="));
+        newsList = newsList.subList(1, newsList.size());
+        newsList.forEach( n -> {
+            String contentUrl = n.substring(1, n.indexOf("class=\"img-smllnews\"") - 2);
+            String id = contentUrl.substring(contentUrl.lastIndexOf("-") + 1, contentUrl.lastIndexOf("_"));
+            String imgUrl = n.substring(n.indexOf("img src=") + 9, n.indexOf("?"));
+            String time = n.substring(n.indexOf("Last Updated") + 23, n.indexOf("IST") - 9);
+            String title = n.substring(n.indexOf("html\">") + 6, n.indexOf("<div class=\"short-video-img\">") - 47);
+
+            SiteNews siteNews = new SiteNews();
+            siteNews.setAddTime(new Date());
+            siteNews.setSourceId(id);
+            siteNews.setTitle(title);
+            siteNews.setDescription(time);
+            siteNews.setImgurl(imgUrl);
+            siteNews.setContent(stockService.getNewsInfo(contentUrl));
+            List<SiteNews> list = newsRepository.findAll(QSiteNewsPO.siteNewsPO.sourceId.eq(id));
+            if (list.size() == 0) {
+                newsRepository.save(siteNews);
+            }
+        });
+
+    }
 }
diff --git a/src/main/java/cn/stock/market/infrastructure/job/StockTask.java b/src/main/java/cn/stock/market/infrastructure/job/StockTask.java
index cbf31fc..eec6087 100644
--- a/src/main/java/cn/stock/market/infrastructure/job/StockTask.java
+++ b/src/main/java/cn/stock/market/infrastructure/job/StockTask.java
@@ -349,30 +349,30 @@ public class StockTask {
 //    }
 
 	/*新闻接口*/
-	@Scheduled(cron = "0 0 1 * * ?")
-	public void saveStockNews() {
-		String news = stockService.getNews();
-		List<String> newsList = Arrays.asList(news.split("<a href="));
-		newsList = newsList.subList(1, newsList.size());
-		newsList.forEach( n -> {
-			String contentUrl = n.substring(1, n.indexOf("class=\"img-smllnews\"") - 2);
-			String id = contentUrl.substring(contentUrl.lastIndexOf("-") + 1, contentUrl.lastIndexOf("_"));
-			String imgUrl = n.substring(n.indexOf("img src=") + 9, n.indexOf("?"));
-			String time = n.substring(n.indexOf("Last Updated") + 23, n.indexOf("IST") - 9);
-			String title = n.substring(n.indexOf("html\">") + 6, n.indexOf("<div class=\"short-video-img\">") - 47);
-
-			SiteNews siteNews = new SiteNews();
-			siteNews.setAddTime(new Date());
-			siteNews.setSourceId(id);
-			siteNews.setTitle(title);
-			siteNews.setDescription(time);
-			siteNews.setImgurl(imgUrl);
-			siteNews.setContent(stockService.getNewsInfo(contentUrl));
-			List<SiteNews> list = newsRepository.findAll(QSiteNewsPO.siteNewsPO.sourceId.eq(id));
-			if (list.size() == 0) {
-				newsRepository.save(siteNews);
-			}
-		});
-
-	}
+	//@Scheduled(cron = "0 0 1 * * ?")
+	//@Scheduled(cron = "*/5 * * * * ?")
+	//public void saveStockNews() {
+	//	String news = stockService.getNews();
+	//	List<String> newsList = Arrays.asList(news.split("<a href="));
+	//	newsList = newsList.subList(1, newsList.size());
+	//	newsList.forEach( n -> {
+	//		String contentUrl = n.substring(1, n.indexOf("class=\"img-smllnews\"") - 2);
+	//		String id = contentUrl.substring(contentUrl.lastIndexOf("-") + 1, contentUrl.lastIndexOf("_"));
+	//		String imgUrl = n.substring(n.indexOf("img src=") + 9, n.indexOf("?"));
+	//		String time = n.substring(n.indexOf("Last Updated") + 23, n.indexOf("IST") - 9);
+	//		String title = n.substring(n.indexOf("html\">") + 6, n.indexOf("<div class=\"short-video-img\">") - 47);
+//
+	//		SiteNews siteNews = new SiteNews();
+	//		siteNews.setAddTime(new Date());
+	//		siteNews.setSourceId(id);
+	//		siteNews.setTitle(title);
+	//		siteNews.setDescription(time);
+	//		siteNews.setImgurl(imgUrl);
+	//		siteNews.setContent(stockService.getNewsInfo(contentUrl));
+	//		List<SiteNews> list = newsRepository.findAll(QSiteNewsPO.siteNewsPO.sourceId.eq(id));
+	//		if (list.size() == 0) {
+	//			newsRepository.save(siteNews);
+	//		}
+	//	});
+	//}
 }