X-Git-Url: https://git.wpitchoune.net/gitweb/?a=blobdiff_plain;f=war%2Fsrc%2Fmain%2Fjava%2Fpnews%2Fservlet%2FArticleProvider.java;h=90955260e9018c3136176dae66952dadc7712b27;hb=f054556aba464d783802add05ffb374b7f9cc26b;hp=11689e5d14605d403beda883afa16e3c469d3e4e;hpb=8af1496b5e593b74c386d6e7c2e2fc461605c94c;p=pnews.git diff --git a/war/src/main/java/pnews/servlet/ArticleProvider.java b/war/src/main/java/pnews/servlet/ArticleProvider.java index 11689e5..9095526 100644 --- a/war/src/main/java/pnews/servlet/ArticleProvider.java +++ b/war/src/main/java/pnews/servlet/ArticleProvider.java @@ -25,7 +25,6 @@ import com.rometools.rome.feed.synd.SyndEntry; import com.rometools.rome.feed.synd.SyndFeed; import com.rometools.rome.io.FeedException; import com.rometools.rome.io.SyndFeedInput; -import com.rometools.rome.io.XmlReader; import pnews.Article; import pnews.Category; @@ -38,7 +37,7 @@ public class ArticleProvider { private ArticleProvider() { for (Category cat:Category.values()) - scheduler.scheduleAtFixedRate(new Refresher(cat), 2, 120, TimeUnit.SECONDS); + scheduler.scheduleAtFixedRate(new Refresher(cat), 2, 600, TimeUnit.SECONDS); } private static SyndFeed getSyndFeed(String u) throws IllegalArgumentException, FeedException, MalformedURLException, IOException { @@ -57,10 +56,12 @@ public class ArticleProvider { result.put(Category.TOP, new String[] { "http://www.francetvinfo.fr/titres.rss", - "http://www.france24.com/fr/actualites/rss", - //"https://www.franceinter.fr/rss/a-la-une.xml", + "http://www.france24.com/fr/actualites/rss", "http://www.rfi.fr/general/rss", "http://www.cnews.fr/rss/une", + "http://www.ladepeche.fr/rss/a-la-une.rss", + "https://www.franceinter.fr/rss/a-la-une.xml", + "https://www.francebleu.fr/rss/a-la-une.xml", "http://www.bfmtv.com/rss/info/flux-rss/flux-toutes-les-actualites/" }); @@ -97,12 +98,19 @@ public class ArticleProvider { private void addArticles(Category cat, SyndFeed feed) { String thumbnail; - String desc, link, title; + String desc, link, title, feedTitle, feedImage; Date date; List
articles; boolean exist; - LOG.info("addArticles" + cat.getId()); + feedTitle = feed.getTitle().trim(); + + if (feed.getImage() != null) + feedImage = feed.getImage().getUrl(); + else + feedImage = null; + + LOG.info("addArticles " + cat.getId() + " " + feedTitle + " number of articles: " + feed.getEntries().size()); for (SyndEntry entry: feed.getEntries()) { thumbnail = null; @@ -111,21 +119,29 @@ public class ArticleProvider { thumbnail = e.getUrl(); break; } + if (thumbnail == null) + thumbnail = feedImage; + title = entry.getTitle().trim(); + if (entry.getDescription() != null) { desc = Jsoup.parse(entry.getDescription().getValue()).text(); } else { desc = null; - LOG.severe("No description for " + feed.getTitle() + " - " + entry.getTitle()); + LOG.severe("No description for " + feedTitle + " - " + title); } date = entry.getPublishedDate(); if (date == null) date = entry.getUpdatedDate(); + if (date == null) { + LOG.severe("The article " + feedTitle + " - " + title + " does not have a date"); + continue; + } synchronized(articlesByCategory) { link = entry.getLink().trim(); - title = entry.getTitle().trim(); + articles = articlesByCategory.get(cat); exist = false; if (articles == null) { @@ -134,13 +150,13 @@ public class ArticleProvider { } else { for (Article a: articles) if (a.link.equals(link)) { - LOG.info(link + " already present"); + LOG.fine("addArticles " + link + " is already present"); exist = true; } } if (!exist) { - LOG.info("add " + cat.getId() + " " + feed.getTitle() + " " + title); + LOG.fine("add " + cat.getId() + " " + feedTitle + " " + title); articles.add(new Article(link, cat, title, desc, thumbnail, date, feed.getTitle())); @@ -152,9 +168,13 @@ public class ArticleProvider { } }); + } else { + LOG.finest("addArticles already exist: " + title); } } - } + } + + LOG.info("addArticles done " + cat.getId()); } private void retrieveArticles(Category cat) throws IllegalArgumentException, MalformedURLException, FeedException, IOException { @@ -166,8 +186,10 @@ public class ArticleProvider { for (String str: feeds) try { addArticles(cat, getSyndFeed(str)); - } catch (IOException e) { - LOG.log(Level.SEVERE, "retrieveArticles failure " + cat.getId(), e); + } catch (Throwable e) { + LOG.log(Level.SEVERE, + "retrieveArticles failure " + cat.getId() + " " + str, + e); } else LOG.severe("No feed for category " + cat); @@ -203,6 +225,7 @@ public class ArticleProvider { articles.subList(0, 100)); } + LOG.info("refresher " + category.getId() + " number of articles: " + articles.size()); } } catch (IllegalArgumentException | FeedException | IOException e) { LOG.log(Level.SEVERE, "refresher failure", e);