nhanvubk/ger-market-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新闻定时任务新增日志信息

Browse Source
This commit is contained in:
dengli
2024-02-16 18:09:40 +08:00
parent 2b3f511ff6
commit 3ec78dbe9a
1 changed files with 27 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

48
src/main/java/cn/stock/market/infrastructure/job/InvestingTask.java
View File

@@ -109,28 +109,34 @@ public class InvestingTask {
/*新闻接口*/ /*新闻接口*/
@Scheduled(cron = "0 0 1 * * ?") @Scheduled(cron = "0 0 1 * * ?")
public void saveStockNews() { public void saveStockNews() {
String news = stockService.getNews(); log.info("英文股票新闻数据同步开始");
List<String> newsList = Arrays.asList(news.split("<a href=")); try {
newsList = newsList.subList(1, newsList.size()); String news = stockService.getNews();
newsList.forEach( n -> { List<String> newsList = Arrays.asList(news.split("<a href="));
String contentUrl = n.substring(1, n.indexOf("class=\"img-smllnews\"") - 2); newsList = newsList.subList(1, newsList.size());
String id = contentUrl.substring(contentUrl.lastIndexOf("-") + 1, contentUrl.lastIndexOf("_")); newsList.forEach( n -> {
String imgUrl = n.substring(n.indexOf("img loading=\"lazy\" src=") + 24, n.indexOf("?")); String contentUrl = n.substring(1, n.indexOf("class=\"img-smllnews\"") - 2);
String time = n.substring(n.indexOf("Last Updated") + 23, n.indexOf("IST") - 9); 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 siteNews = new SiteNews();
siteNews.setAddTime(new Date()); siteNews.setAddTime(new Date());
siteNews.setSourceId(id); siteNews.setSourceId(id);
siteNews.setDescription(time); siteNews.setDescription(time);
siteNews.setImgurl(imgUrl); siteNews.setImgurl(imgUrl);
List<String> newsInfo = stockService.getNewsInfo(contentUrl); List<String> newsInfo = stockService.getNewsInfo(contentUrl);
siteNews.setContent(newsInfo.get(0)); siteNews.setContent(newsInfo.get(0));
siteNews.setTitle(newsInfo.get(1)); siteNews.setTitle(newsInfo.get(1));
List<SiteNews> list = newsRepository.findAll(QSiteNewsPO.siteNewsPO.sourceId.eq(id)); List<SiteNews> list = newsRepository.findAll(QSiteNewsPO.siteNewsPO.sourceId.eq(id));
if (list.size() == 0) { if (list.size() == 0) {
newsRepository.save(siteNews); newsRepository.save(siteNews);
} }
}); });
log.info("英文股票新闻数据同步完成");
} catch (Exception e) {
log.info("新闻数据同步异常，异常信息{}。。。。",e.getMessage());
}
} }
} }