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 newsList = Arrays.asList(news.split(" newsList = Arrays.asList(news.split(" newsInfo = stockService.getNewsInfo(contentUrl); - siteNews.setContent(newsInfo.get(0)); - siteNews.setTitle(newsInfo.get(1)); - List 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 newsInfo = stockService.getNewsInfo(contentUrl); + siteNews.setContent(newsInfo.get(0)); + siteNews.setTitle(newsInfo.get(1)); + List list = newsRepository.findAll(QSiteNewsPO.siteNewsPO.sourceId.eq(id)); + if (list.size() == 0) { + newsRepository.save(siteNews); + } + }); + log.info("英文股票新闻数据同步完成"); + } catch (Exception e) { + log.info("新闻数据同步异常,异常信息{}。。。。",e.getMessage()); + } } }