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