bug修改

admin

2025-03-24 289a70c3d76fee4724bc97de96b4664e88d35b1e

bug修改

 strategy/data_cache.py

@@ -166,10 +166,13 @@
# 初始化实时大盘行情情绪综合强度分时列表
time_sharing_market_strong_dirt = {}


# 为所有个股的带属性K线 字典初始化
all_stocks_all_K_line_property_dict = {}
# 为指数的带属性K线 字典初始化
all_index_k_line_property_dict = {}
# 为所有个股的所属板块概念字典初始化
all_stocks_plate_dict = {}
# 声明K线属性中所有涨停类型
limit_up_type = ['one_line_limit_up', 'limit_down_then_limit_up', 'limit_up_then_limit_down_then_limit_up',
                 'limit_up']

 strategy/index_market_trend_strategy.py

@@ -143,7 +143,10 @@
    else:
        index_composite_tick_increase = '三大指数：涨跌不一'
    logger.info(f"开盘指数开盘瞬时走势播报：{index_composite_tick_increase}")
    logger.info(f"指数带属性K线数据的昨日是否为空:{data_cache.all_index_k_line_property_dict['000001'][0]}")
    # print(f"指数K线{data_cache.all_index_k_line_property_dict}")
    if len(data_cache.all_index_k_line_property_dict) > 0 or data_cache.all_index_k_line_property_dict is not None:
        logger.info(f"指数带属性K线数据的昨日是否为空:{data_cache.all_index_k_line_property_dict['SHSE.000001'][0]}")
        print(f"指数带属性K线数据的昨日是否为空:{data_cache.all_index_k_line_property_dict['SHSE.000001'][0]['open']}")
    return index_trend_expectation_score


@@ -401,4 +404,5 @@
if __name__ == '__main__':
    # all_index_K_line_dict = get_index_K_line()

    all_index_k_line_dict_write()
    # all_index_k_line_dict_write()
    print(f"指数K线{data_cache.all_index_k_line_property_dict}")

 strategy/local_data_management.py

@@ -24,7 +24,7 @@
        with open(constant.INDEX_K_BARS_PATH, 'r', encoding='utf-8') as f:
            data_cache.all_index_k_line_property_dict = json.load(f)
            print(
                f"data_cache.all_stocks_all_K_line_property_dict的个数==={len(data_cache.all_index_k_line_property_dict)}")
                f"data_cache.all_index_k_line_property_dict==={len(data_cache.all_index_k_line_property_dict)}")


# 读取本地的个股所属概念板块数据
@@ -37,5 +37,9 @@
            json_data = f.read()
    else:
        json_data = "{}"
    all_stocks_plate_dict = json.loads(json_data)
    logger.info(f"all_stocks_plate_dict的数量={len(all_stocks_plate_dict)}")
    data_cache.all_stocks_plate_dict = json.loads(json_data)
    logger.info(f"all_stocks_plate_dict的数量={len(data_cache.all_stocks_plate_dict)}")


if __name__ == '__main__':
    read_local_K_line_data()