From af68ca73cb687b8e4ed14149b9a93bbcc238c816 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期二, 08 四月 2025 10:32:25 +0800
Subject: [PATCH] 解决 获取实时大盘行情情绪综合强度 [分数] 函数 中的 BUG
---
strategy/market_sentiment_analysis.py | 33 +++++++++++++++++----------------
1 files changed, 17 insertions(+), 16 deletions(-)
diff --git a/strategy/market_sentiment_analysis.py b/strategy/market_sentiment_analysis.py
index 1db75ab..d854e55 100644
--- a/strategy/market_sentiment_analysis.py
+++ b/strategy/market_sentiment_analysis.py
@@ -9,7 +9,7 @@
import constant
from log_module import async_log_util
-from log_module.log import logger_common, logger_Overall_market_strength_score
+from log_module.log import logger_common, logger_Overall_market_strength_score, logger_debug
# import time
# 寮曞叆鎺橀噾API
# from gm.api import *
@@ -572,22 +572,22 @@
data_cache.real_time_market_strong = kpl_api.get_market_strong()
# 鑾峰彇甯傚満鎯呯华瀛楀吀銆愬畬鏁淬�戯紝骞舵暣鐞�
data_cache.real_time_market_sentiment_dirt = kpl_api.changeStatistics()
- date_today = data_cache.real_time_market_sentiment_dirt.get(['Day'], None)
- significant_drawdown = data_cache.real_time_market_sentiment_dirt.get(['df_num'], None)
- sentiment_indicators = data_cache.real_time_market_sentiment_dirt.get(['ztjs'], None)
- limit_up_amount = data_cache.real_time_market_sentiment_dirt.get(['ztjs'], None)
- connecting_board_height = data_cache.real_time_market_sentiment_dirt.get(['lbgd'], None)
+ date_today = data_cache.real_time_market_sentiment_dirt.get('Day', None)
+ significant_drawdown = data_cache.real_time_market_sentiment_dirt.get('df_num', None)
+ sentiment_indicators = data_cache.real_time_market_sentiment_dirt.get('ztjs', None)
+ limit_up_amount = data_cache.real_time_market_sentiment_dirt.get('ztjs', None)
+ connecting_board_height = data_cache.real_time_market_sentiment_dirt.get('lbgd', None)
# 鑾峰彇甯傚満鎯呯华-娑ㄨ穼缁熻
data_cache.rise_and_fall_statistics_dirt = kpl_api.getMarketFelling()
- limit_up_numbers = data_cache.rise_and_fall_statistics_dirt.get(['ZT', None])
- actual_limit_up_numbers = data_cache.rise_and_fall_statistics_dirt.get(['SJZT', None])
- ST_limit_up_numbers = data_cache.rise_and_fall_statistics_dirt.get(['STZT', None])
- limit_down_numbers = data_cache.rise_and_fall_statistics_dirt.get(['DT', None])
- actual_limit_down_numbers = data_cache.rise_and_fall_statistics_dirt.get(['SJDT', None])
- ST_limit_down_numbers = data_cache.rise_and_fall_statistics_dirt.get(['STDT', None])
+ limit_up_numbers = data_cache.rise_and_fall_statistics_dirt.get('ZT', None)
+ actual_limit_up_numbers = data_cache.rise_and_fall_statistics_dirt.get('SJZT', None)
+ ST_limit_up_numbers = data_cache.rise_and_fall_statistics_dirt.get('STZT', None)
+ limit_down_numbers = data_cache.rise_and_fall_statistics_dirt.get('DT', None)
+ actual_limit_down_numbers = data_cache.rise_and_fall_statistics_dirt.get('SJDT', None)
+ ST_limit_down_numbers = data_cache.rise_and_fall_statistics_dirt.get('STDT', None)
- rise_numbers = data_cache.rise_and_fall_statistics_dirt.get(['SZJS', None])
- fall_numbers = data_cache.rise_and_fall_statistics_dirt.get(['XDJS', None])
+ rise_numbers = data_cache.rise_and_fall_statistics_dirt.get('SZJS', None)
+ fall_numbers = data_cache.rise_and_fall_statistics_dirt.get('XDJS', None)
# 璇ogger.info鐨勭殑鏃ュ織涓嶅啀闇�瑕佹墦鍗帮紝鍚庣画灏嗚浆鍏ュ埌GUI瀹㈡埛绔笂鐩存帴鏄剧ず锛岃鏁版嵁鐨勬墦鍗颁氦鐢变笅鏂圭殑鎵撳嵃鏈哄埗寮傛鎵ц鍗曠嫭瀛樺偍锛屼互渚垮悗缁彲瑙嗗寲鍛堢幇鍚庤繘琛屾洿楂樻晥鐨勬暟鎹垎鏋�
# logger.info(f"澶х洏琛屾儏鎯呯华缁煎悎寮哄害 [鍒嗘暟]==={data_cache.real_time_market_strong}鍒�")
@@ -617,7 +617,7 @@
data_cache.index_trend_expectation_score = index_trend_expectation()
logger.info(f"澶х洏鎸囨暟鎯呯华棰勬湡鍒嗘暟==={data_cache.index_trend_expectation_score}鍒�")
- print(f"澶х洏鎸囨暟鎯呯华棰勬湡鍒嗘暟==={data_cache.index_trend_expectation_score}鍒�")
+ # print(f"澶х洏鎸囨暟鎯呯华棰勬湡鍒嗘暟==={data_cache.index_trend_expectation_score}鍒�")
# # 鐩墠澶х洏鎸囨暟鎯呯华棰勬湡鍒嗘暟 灏氫笉绉戝 寮哄埗璁剧疆涓哄垵濮�0鍊�
# index_trend_expectation_score = 0
@@ -641,8 +641,9 @@
logger.info(f"閲囩敤GUI璁剧疆鏂瑰紡=銆嬩粖鏃ヨ鍒掍笅鍗曢噾棰�:{data_cache.today_planned_order_amount}")
except Exception as error:
- logger_common.exception(error)
+ logger_debug.exception(error)
logger.error(f"鑾峰彇瀹炴椂澶х洏琛屾儏鎯呯华缁煎悎寮哄害[鍒嗘暟] 鍑芥暟鎶ラ敊: {error}")
+ print(f"鑾峰彇瀹炴椂澶х洏琛屾儏鎯呯华缁煎悎寮哄害[鍒嗘暟] 鍑芥暟鎶ラ敊: {error}")
finally:
time.sleep(3)
--
Gitblit v1.8.0