From d73df3ed85355d7877d9d4ff96af105d7a329b99 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 25 六月 2025 15:33:45 +0800
Subject: [PATCH] 定时强制更新K线
---
third_data/history_k_data_manager.py | 10 ++++++----
1 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/third_data/history_k_data_manager.py b/third_data/history_k_data_manager.py
index c6c2cca..d8ed82f 100644
--- a/third_data/history_k_data_manager.py
+++ b/third_data/history_k_data_manager.py
@@ -15,7 +15,7 @@
from utils import tool, init_data_util
-def update_history_k_bars():
+def update_history_k_bars(force=False):
"""
鏇存柊鍘嗗彶K绾�
@return: 姝ゆ鏇存柊鐨勬暟閲�
@@ -26,7 +26,8 @@
try:
datas = init_data_util.get_volumns_by_code(code, 150)
if datas:
- HistoryKDataManager().save_history_bars(code, datas[0]['bob'].strftime("%Y-%m-%d"), datas)
+ HistoryKDataManager().save_history_bars(code, datas[0]['bob'].strftime("%Y-%m-%d"), datas,
+ force=force)
except Exception as e:
logger_debug.exception(e)
@@ -40,8 +41,9 @@
for code_byte in codes_sz:
codes.add(code_byte.decode())
# 鑾峰彇宸茬粡鏇存柊鐨勬暟鎹�
- codes_record = HistoryKDataManager().get_history_bars_codes(latest_trading_date)
- codes = codes - codes_record
+ if not force:
+ codes_record = HistoryKDataManager().get_history_bars_codes(latest_trading_date)
+ codes = codes - codes_record
threading.Thread(target=lambda: update(codes), daemon=True).start()
return len(codes)
--
Gitblit v1.8.0