From 0b0d0e790fec8c7edfdbcab5c31d625e0c2eadd6 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期四, 19 六月 2025 16:54:49 +0800
Subject: [PATCH] 添加必要的数据日志
---
strategy/plate_strength_analysis.py | 12 ++++++++++--
1 files changed, 10 insertions(+), 2 deletions(-)
diff --git a/strategy/plate_strength_analysis.py b/strategy/plate_strength_analysis.py
index e8ec8f3..efe40f4 100644
--- a/strategy/plate_strength_analysis.py
+++ b/strategy/plate_strength_analysis.py
@@ -4,8 +4,10 @@
import time
import dask
import constant
+from log_module import async_log_util
-from log_module.log import logger_common, logger_kpl_jingxuan_in, logger_debug, logger_kpl_market_sift_plate
+from log_module.log import logger_common, logger_kpl_jingxuan_in, logger_debug, logger_kpl_market_sift_plate, \
+ logger_kpl_limit_up, logger_kpl_code_plates
from strategy import kpl_api, data_cache, basic_methods
from strategy.kpl_data_manager import KPLMarketStockHeatLogManager
from utils import tool, hx_qc_value_util
@@ -75,6 +77,8 @@
return log_data
# 瀹氫箟涓�涓椂闂存锛屽湪杩欎釜鏃堕棿娈靛唴鎵嶄細鎵ц涓嬮潰鐨勪唬鐮侊紝涓昏灏辨槸鎶婂己搴︽暟鎹綔涓烘棩蹇楁墦鍗板瓨鍌ㄤ笅鏉ャ��
now_time = tool.get_now_time_str()
+ if '11:30:10' < now_time < '12:59:50':
+ return
data = (kpl_api.getMarketJingXuanRealRankingInfo())
market_sift_plate = json.loads(data)
# print(f"market_sift_plate 鏁� ======{len(market_sift_plate['list'])}")
@@ -140,7 +144,7 @@
# 璁惧畾褰撳墠鏃堕棿鐐�
now_time = tool.get_now_time_str()
# print(f"now_time===={now_time}")
- if data_cache.SERVER_RESTART_TIME < now_time < data_cache.UPDATE_DATA_TIME:
+ if data_cache.OPEN_BIDDING_TIME < now_time < data_cache.CLOSING_TIME:
# print(f"鍦ㄦ椂闂村唴浣跨敤--------------------------")
# 鑾峰彇娑ㄥ仠淇℃伅鍒楄〃
limit_up_info = kpl_api.get_limit_up_info()
@@ -159,6 +163,8 @@
# most_common_element, most_common_count = counter.most_common(1)[0]
# # 鎵撳嵃鍑虹幇娆℃暟鏈�澶氱殑鍏冪礌
# print(f"涓荤嚎姒傚康锛歿most_common_element}锛屽嚭鐜颁簡 {most_common_count} 娆�")
+ async_log_util.info(logger_kpl_limit_up, f"{limit_up_info}")
+
return limit_up_block_names
@@ -455,6 +461,8 @@
# 鍐欏叆鏂囦欢
with open(constant.ALL_STOCKS_PLATE_PATH, 'w', encoding='utf-8') as f:
f.write(json_data)
+ # 璁板綍鍒版棩蹇�
+ async_log_util.info(logger_kpl_code_plates, json_data)
now_time = datetime.datetime.now() # 鑾峰彇鏈満鏃堕棿
logger_common.info(f"鍐欏叆鎵�鏈変釜鑲℃澘鍧楁枃浠跺畬鎴愶紒::{now_time}")
--
Gitblit v1.8.0