bug修复/策略完善

Administrator

4 天以前 245979e3907d34bcd88ac0c4547f399bf33a44de

 strategy/strategy_variable_factory.py

@@ -22,7 +22,7 @@
    数据加载器类，用于集中管理策略变量所需的各类数据加载逻辑
    """

    def __init__(self, now_day, cache_path="D:/datas"):
    def __init__(self, now_day, cache_path=f"{constant.get_path_prefix()}/datas"):
        """
        初始化数据加载器
        :param now_day: 当前日期，格式为"2025-01-01"
@@ -236,7 +236,7 @@
                           (tool.is_can_buy_code(x[0]) and x[0] in valid_codes and x[0] not in exclude_codes)]
                # 取前1/3且涨停数是前10
                max_count = len(results) // 3 if len(results) % 3 == 0 else len(results) // 3 + 1
                results = results[:max_count]
                # results = results[:max_count]
                # 取前10
                results = results[:10]
                codes = [x[0] for x in results]
@@ -602,6 +602,12 @@
            kline_data_60s = kline_data_60s_dict.get(trade_days[0])
            fdata = K60SLineAnalyzer.get_close_price_of_max_volume(kline_data_60s)
            instance.__setattr__(f"昨日分时最高量价", fdata)

        if KTickLineAnalyzer.is_too_high_and_not_relase_volume(kline_data_1d):
            instance.涨得高未放量 = True
        else:
            instance.涨得高未放量 = False

        return instance


@@ -658,20 +664,17 @@
    plates = ["天然气", "军工"]
    print("==========新题材=======")
    for p in plates:
        codes = [x for x in results.get(p) ] # if get_zylt(x) < 31e8
        codes = [x for x in results.get(p)]  # if get_zylt(x) < 31e8
        print("======", p)
        for code in codes:
            print("\t\t", code, gpcode_manager.CodesNameManager().get_code_name(code))





if __name__ == "__main__":

    __load_target_codes_v1()
    # __load_target_codes_v1()

    __DataLoader = DataLoader("2025-06-12")
    __DataLoader = DataLoader("2025-06-17")
    # __test_jx_blocks(__DataLoader)

    # instance = StockVariables()
@@ -689,7 +692,7 @@
    results = __DataLoader.load_target_plate_and_codes()
    # for k in results:
    #     print(k, results[k])
    plates = ["汽车零部件", "文化传媒", "谷子经济"]
    plates = ["脑机接口"]
    print("==========新题材=======")
    for p in plates:
        print(p, results.get(p))