From e556104b1e2e01c98ceb1c16448cd4681ef70105 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期四, 22 五月 2025 14:10:31 +0800
Subject: [PATCH] 1.整理删除不必要的todo 2.将主要使用的策略分支弃用elif 3.修改有概念分支中瞬时量幅比的特别门槛（大市值票不看瞬时量幅比） 4.打印行情-精选-板块的具体数据
---
strategy/plate_strength_analysis.py | 14 +++++++++-----
1 files changed, 9 insertions(+), 5 deletions(-)
diff --git a/strategy/plate_strength_analysis.py b/strategy/plate_strength_analysis.py
index b6418b6..b9db66c 100644
--- a/strategy/plate_strength_analysis.py
+++ b/strategy/plate_strength_analysis.py
@@ -5,7 +5,7 @@
import dask
import constant
-from log_module.log import logger_common, logger_kpl_jingxuan_in, logger_debug
+from log_module.log import logger_common, logger_kpl_jingxuan_in, logger_debug, logger_kpl_market_sift_plate
from strategy import kpl_api, data_cache, basic_methods
from utils import tool, hx_qc_value_util
@@ -75,16 +75,19 @@
data = (kpl_api.getMarketJingXuanRealRankingInfo())
market_sift_plate = json.loads(data)
- # logger_kpl_jingxuan_in 鎵撳嵃鐨勬棩蹇椾笓鐢ㄤ簬寮�鐩樹簡鏁版嵁鐨勫瓨鍌ㄥ垎鏋愶紝涓嶈兘杞绘槗鍒犻櫎
# print(f"market_sift_plate 鏁� ======{len(market_sift_plate['list'])}")
- # 琛屾儏銆嬬簿閫夋澘鍧椼�嬫帓鍚嶅墠20涓�嬪搴斾釜鑲°�嬬鍚堟潯浠剁殑涓偂
- # logger.info(f"market_sift_plate['list']======{market_sift_plate['list']}")
+
+ # 绮鹃�夋澘鍧椼�愬墠20銆� market_sift_plate['list'] ======
+ logger_kpl_market_sift_plate.info(f"{market_sift_plate['list']}")
+ # market_sift_plate['list'][0] = ['801062', '鍐涘伐', 3520, -0.49, 0.666, 139133934669, 383864272, 9077352839, -8693488567, 1.183, 6129448037490,-0.12, 168245858, 7088854452019, -290614763, 50.2408, 30.3672, 3520, 0]
+ # 琛屾儏绮鹃�夋澘鍧楀垪琛� 鍓�20 涓殑 绗竴涓澘鍧楀垪琛ㄦ暟鎹� = 銆愪唬鐮侊紝鏉垮潡鍚嶇О锛屽己搴︼紝娑ㄥ箙锛燂紝0.666锛燂紝鎴愪氦棰濓紵锛岀幇棰濓紵锛屼富涔帮紝涓诲崠锛�1.183锛燂紝娴侀�氬�硷紵锛�-0.12锛燂紝300W澶у崟鍑�棰濓紵锛屾�诲競鍊硷紵锛屼笂瀛ｅ害鏈烘瀯澧炰粨锛屼粖骞村钩鍧嘝E锛屾骞村钩鍧嘝E锛屽己搴︼紝鏈煡0鍊笺��
# logger.info(f"market_sift_plate['list'][0] ======{market_sift_plate['list'][0]}")
# 鍒濆鍖栫簿閫夋澘鍧楀搴斾釜鑲″瓧鍏�
market_sift_plate_stock_dict = {}
if 'list' in market_sift_plate:
ds = []
for d in market_sift_plate['list']:
+ # todo 鑾峰彇鏉垮潡鍚嶇О鍜屾澘鍧椾唬鐮� 涓昏鏄澘鍧楃殑寮哄害鍜屼富鍔涘噣棰濊繖浜�
ds.append(request_plate_codes(d))
dask_result = batch_get_plate_codes(ds)
compute_results = dask_result.compute()
@@ -98,7 +101,7 @@
# logger.info(f"绮鹃�夋澘鍧楄偂绁ㄥ己搴︽暟鎹洿鏂� == {market_sift_plate_stock_dict}")
# 鍙湪鐩樹腑鏃堕棿鑾峰彇
kpl_api.KPLStockOfMarketsPlateLogManager().add_log(market_sift_plate['list'], log_datas)
-
+ # 琛屾儏銆嬬簿閫夋澘鍧椼�嬫帓鍚嶅墠20涓�嬪搴斾釜鑲°�嬬鍚堟潯浠剁殑涓偂
return market_sift_plate_stock_dict
@@ -116,6 +119,7 @@
its_stock_power = get_market_sift_plate_its_stock_power()
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}")
callback(its_stock_power)
# print(f"绮鹃�夋澘鍧楁媺鍗囦釜鑲℃洿鏂�===={its_stock_power}")
--
Gitblit v1.8.0