From 98d067d59a144a5ca930ca91ee5439a4c89f7a9f Mon Sep 17 00:00:00 2001
From: zhangjian <zhangjian@main99.com>
Date: Sat, 11 May 2024 15:42:17 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=AE=9A=E6=97=B6=E5=90=8C?=
 =?UTF-8?q?=E6=AD=A5Refinitiv=E8=82=A1=E7=A5=A8=E6=95=B0=E6=8D=AE=E6=97=A5?=
 =?UTF-8?q?=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/cn/stock/market/infrastructure/job/RefinitivTask.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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<RetifiveStock> 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);
         }