diff --git a/novel-front/src/main/java/xyz/zinglizingli/books/core/crawl/BiquCrawlSource.java b/novel-front/src/main/java/xyz/zinglizingli/books/core/crawl/BiquCrawlSource.java index 4b1c16a..e90df5f 100644 --- a/novel-front/src/main/java/xyz/zinglizingli/books/core/crawl/BiquCrawlSource.java +++ b/novel-front/src/main/java/xyz/zinglizingli/books/core/crawl/BiquCrawlSource.java @@ -125,7 +125,6 @@ public class BiquCrawlSource extends BaseHtmlCrawlSource { @Override public void update() { List logs = bookService.queryBookParseLogs(); - List successLogIds = new ArrayList<>(); for (BookParseLog bookParseLog : logs) { try { @@ -241,7 +240,7 @@ public class BiquCrawlSource extends BaseHtmlCrawlSource { } } - successLogIds.add(bookParseLog.getId()); + bookService.deleteBookParseLog(bookParseLog.getId()); } @@ -266,7 +265,7 @@ public class BiquCrawlSource extends BaseHtmlCrawlSource { } } - bookService.deleteBookParseLogs(successLogIds); + } diff --git a/novel-front/src/main/java/xyz/zinglizingli/books/core/listener/StartListener.java b/novel-front/src/main/java/xyz/zinglizingli/books/core/listener/StartListener.java index 6c85894..9e892b5 100644 --- a/novel-front/src/main/java/xyz/zinglizingli/books/core/listener/StartListener.java +++ b/novel-front/src/main/java/xyz/zinglizingli/books/core/listener/StartListener.java @@ -66,7 +66,6 @@ public class StartListener implements ServletContextListener { log.info("updateBooks执行中。。。。。。。。。。。。"); crawlSource.update(); - Thread.sleep(new Float(1000 * 60 * bookUpdatePeriod).longValue()); } catch (Exception e) { log.error(e.getMessage(), e); } diff --git a/novel-front/src/main/java/xyz/zinglizingli/books/service/BookService.java b/novel-front/src/main/java/xyz/zinglizingli/books/service/BookService.java index 68ae867..7f958c8 100644 --- a/novel-front/src/main/java/xyz/zinglizingli/books/service/BookService.java +++ b/novel-front/src/main/java/xyz/zinglizingli/books/service/BookService.java @@ -510,4 +510,12 @@ public class BookService { } } } + + /** + * 删除已经成功更新的解析日志 + * */ + public void deleteBookParseLog(Long id) { + bookParseLogMapper.deleteByPrimaryKey(id); + + } }