diff --git a/src/main/java/cn/stock/market/infrastructure/job/RefinitivTask.java b/src/main/java/cn/stock/market/infrastructure/job/RefinitivTask.java index 887ceb4..29e8466 100644 --- a/src/main/java/cn/stock/market/infrastructure/job/RefinitivTask.java +++ b/src/main/java/cn/stock/market/infrastructure/job/RefinitivTask.java @@ -53,7 +53,8 @@ public class RefinitivTask { try { List stockList = refinitivConsumer.getRefinitivStockList(String.join(",", symbolList)); retifiveStockService.repository().saveAll(stockList); - log.info("每天18点定时同步Refinitiv股票数据结束, 受影响数{}, 耗时:{}毫秒", symbolList.size(), stopwatch.elapsed(TimeUnit.MILLISECONDS)); + log.info("每天18点定时同步Refinitiv股票数据结束, 当前股票总数 {}, 新增数{}, 耗时:{}毫秒", + allRetifiveStocks.size(), symbolList.size(), stopwatch.elapsed(TimeUnit.MILLISECONDS)); } catch (Exception e) { log.error("每天18点定时同步Refinitiv股票数据异常, 错误:", e); }