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 ++++++--
data_server.py | 2 +-
main.py | 4 +++-
strategy/data_cache.py | 7 +++++--
4 files changed, 15 insertions(+), 6 deletions(-)
diff --git a/data_server.py b/data_server.py
index 13d7b51..3e39b96 100644
--- a/data_server.py
+++ b/data_server.py
@@ -253,7 +253,7 @@
response_data = json.dumps({"code": 0, "data": {}})
elif url.path == "/get_market_sift_plate_stock_dict":
# 鑾峰彇寮�鐩樺暒鏉垮潡绮鹃�夋祦鍏�
- data = data_cache.market_sift_plate_stock_dict
+ data = data_cache.market_sift_plates
response_data = json.dumps({"code": 0, "data": data})
self.send_response(200)
diff --git a/main.py b/main.py
index 4c27122..962c9b1 100644
--- a/main.py
+++ b/main.py
@@ -107,11 +107,13 @@
daemon=True).start()
# # 寮�鐩樺暒鐨勬澘鍧楀己搴︿笅鐨勪釜鑲″己搴﹀洖璋冨嚱鏁�
- def get_market_sift_plate_its_stock_power_process(market_sift_plate_stock_dict):
+ def get_market_sift_plate_its_stock_power_process(market_sift_plate_info):
# print(f"鍥炶皟鎴愬姛===绮鹃�夋澘鍧楄偂绁ㄥ己搴︽暟鎹洿鏂�==={market_sift_plate_stock_dict}")
# logger_kpl_jingxuan_in.info(f"{market_sift_plate_stock_dict}")
+ market_sift_plate_stock_dict, market_sift_plates = market_sift_plate_info[0], market_sift_plate_info[1]
if market_sift_plate_stock_dict:
data_cache.market_sift_plate_stock_dict = market_sift_plate_stock_dict
+ data_cache.market_sift_plates = market_sift_plates
# 鏉垮潡寮哄害涓嬩釜鑲″己搴︾嚎绋�
threading.Thread(target=plate_strength_analysis.get_market_sift_plate_its_stock_power_process,
diff --git a/strategy/data_cache.py b/strategy/data_cache.py
index 0771658..eb5a8a0 100644
--- a/strategy/data_cache.py
+++ b/strategy/data_cache.py
@@ -76,8 +76,8 @@
# stock.startswith('SHSE.60') or (stock.startswith('SZSE.00'))]
self.filtered_stocks = [stock['symbol'] for stock in self.all_stocks if
isinstance(stock.get('symbol'), str) and (
- stock['symbol'].startswith('SHSE.60') or stock['symbol'].startswith(
- 'SZSE.00'))]
+ stock['symbol'].startswith('SHSE.60') or stock['symbol'].startswith(
+ 'SZSE.00'))]
# self.filtered_stocks = self.filtered_stocks[:10]
print(f"杩囨护鍚庝笂璇丄鑲″拰娣辫瘉A鑲℃暟閲廸iltered_stocks锛歿len(self.filtered_stocks)}")
# 澹版槑涓�涓嬮渶瑕佹媺鍙朘绾跨殑鍒楄〃
@@ -156,6 +156,9 @@
limit_up_block_names = []
# 鍒濆鍖栨澘鍧楀己搴︿笅鐨勪釜鑲″己搴�
market_sift_plate_stock_dict = {}
+# 绮鹃�夋祦鍏ユ澘鍧�
+market_sift_plates = []
+
# 鍒濆鍖栧疄鏃跺ぇ鐩樿鎯呭競鍦烘儏缁患鍚堝己搴︺�愬畬鏁淬�戝瓧鍏�
rise_and_fall_statistics_dirt = {}
# 鍒濆鍖栧疄鏃跺ぇ鐩樿鎯呮儏缁患鍚堝己搴鍒嗘暟]
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