| | |
| | | 数据加载器类,用于集中管理策略变量所需的各类数据加载逻辑 |
| | | """ |
| | | |
| | | 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" |
| | |
| | | (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] |
| | |
| | | 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() |
| | |
| | | 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)) |