解决 获取实时大盘行情情绪综合强度 [分数] 函数 中的 BUG

admin

2025-04-08 af68ca73cb687b8e4ed14149b9a93bbcc238c816

解决 获取实时大盘行情情绪综合强度 [分数] 函数 中的 BUG

 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)

                    # 该logger.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)