From cea6eee0edb661e0215a90a61642bf31afb3e502 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期二, 17 六月 2025 14:13:17 +0800
Subject: [PATCH] 增加测试/记录精选流入板块
---
strategy/plate_strength_analysis.py | 8 ++++++--
1 files changed, 6 insertions(+), 2 deletions(-)
diff --git a/strategy/plate_strength_analysis.py b/strategy/plate_strength_analysis.py
index 89e054b..7650689 100644
--- a/strategy/plate_strength_analysis.py
+++ b/strategy/plate_strength_analysis.py
@@ -13,6 +13,10 @@
# 鑾峰彇琛屾儏绮鹃�夋澘鍧� 寮哄害鎺掑悕
def get_market_sift_plate_its_stock_power():
+ """
+
+ :return: {鏉垮潡:[浠ｇ爜淇℃伅]}, 绮鹃�夋祦鍏ユ澘鍧�
+ """
@dask.delayed
def batch_get_plate_codes(fs):
return fs
@@ -105,7 +109,7 @@
# 鍙湪鐩樹腑鏃堕棿鑾峰彇
KPLMarketStockHeatLogManager().add_log(market_sift_plate['list'], log_datas)
# 琛屾儏銆嬬簿閫夋澘鍧椼�嬫帓鍚嶅墠20涓�嬪搴斾釜鑲°�嬬鍚堟潯浠剁殑涓偂
- return market_sift_plate_stock_dict
+ return market_sift_plate_stock_dict, market_sift_plate.get("list",[])
# 璋冪敤涓�涓嬭幏鍙栫簿閫夋澘鍧楄偂绁ㄥ己搴︽暟鎹嚱鏁� 銆愭湰妯″潡鍐呬娇鐢ㄦ椂璋冪敤銆�
@@ -124,7 +128,7 @@
time_str = datetime.datetime.now().strftime("%H%M%S")
if 92900 < int(time_str) < 95000:
# logger_kpl_jingxuan_in 鎵撳嵃鐨勬棩蹇椾笓鐢ㄤ簬寮�鐩樹簡鏁版嵁鐨勫瓨鍌ㄥ垎鏋愶紝涓嶈兘杞绘槗鍒犻櫎
- logger_kpl_jingxuan_in.info(f"鑰楁椂锛歿time.time() - start_time} 鏁版嵁锛歿its_stock_power}")
+ logger_kpl_jingxuan_in.info(f"鑰楁椂锛歿time.time() - start_time} 鏁版嵁锛歿its_stock_power[0]}")
callback(its_stock_power)
# print(f"绮鹃�夋澘鍧楁媺鍗囦釜鑲℃洿鏂�===={its_stock_power}")
except Exception as e:
--
Gitblit v1.8.0