From 3ec78dbe9aecca164f2065b42e8fe7c97be7b8b3 Mon Sep 17 00:00:00 2001
From: dengli <dengli@juyou88.com>
Date: Fri, 16 Feb 2024 18:09:40 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E9=97=BB=E5=AE=9A=E6=97=B6=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=E6=96=B0=E5=A2=9E=E6=97=A5=E5=BF=97=E4=BF=A1=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../infrastructure/job/InvestingTask.java     | 48 +++++++++++--------
 1 file changed, 27 insertions(+), 21 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 dd740db..61c66b3 100644
--- a/src/main/java/cn/stock/market/infrastructure/job/InvestingTask.java
+++ b/src/main/java/cn/stock/market/infrastructure/job/InvestingTask.java
@@ -109,28 +109,34 @@ public class InvestingTask {
     /*新闻接口*/
     @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 loading=\"lazy\" src=") + 24, n.indexOf("?"));
-            String time = n.substring(n.indexOf("Last Updated") + 23, n.indexOf("IST") - 9);
+        log.info("英文股票新闻数据同步开始");
+        try {
+            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 loading=\"lazy\" src=") + 24, n.indexOf("?"));
+                String time = n.substring(n.indexOf("Last Updated") + 23, n.indexOf("IST") - 9);
 
-            SiteNews siteNews = new SiteNews();
-            siteNews.setAddTime(new Date());
-            siteNews.setSourceId(id);
-            siteNews.setDescription(time);
-            siteNews.setImgurl(imgUrl);
-            List<String> newsInfo = stockService.getNewsInfo(contentUrl);
-            siteNews.setContent(newsInfo.get(0));
-            siteNews.setTitle(newsInfo.get(1));
-            List<SiteNews> list = newsRepository.findAll(QSiteNewsPO.siteNewsPO.sourceId.eq(id));
-            if (list.size() == 0) {
-                newsRepository.save(siteNews);
-            }
-        });
+                SiteNews siteNews = new SiteNews();
+                siteNews.setAddTime(new Date());
+                siteNews.setSourceId(id);
+                siteNews.setDescription(time);
+                siteNews.setImgurl(imgUrl);
+                List<String> newsInfo = stockService.getNewsInfo(contentUrl);
+                siteNews.setContent(newsInfo.get(0));
+                siteNews.setTitle(newsInfo.get(1));
+                List<SiteNews> list = newsRepository.findAll(QSiteNewsPO.siteNewsPO.sourceId.eq(id));
+                if (list.size() == 0) {
+                    newsRepository.save(siteNews);
+                }
+            });
+            log.info("英文股票新闻数据同步完成");
+        } catch (Exception e) {
+            log.info("新闻数据同步异常，异常信息{}。。。。",e.getMessage());
+        }
 
     }
 }