| | |
|---|
| | | # 历史日K数据 |
|---|
| | | self.kline_data = {} |
|---|
| | | # 历史涨停数据 |
|---|
| | | self.limit_up_record_data = {} |
|---|
| | | self.limit_up_record_data_dict = {} |
|---|
| | | self.limit_up_record_data_list = {} |
|---|
| | | # 历史数据 |
|---|
| | | self.timeline_data = {} |
|---|
| | | # 今日数据 |
|---|
| | |
|---|
| | | trade_days = self.data_loader.trade_days |
|---|
| | | # 加载历史数据 |
|---|
| | | self.kline_data = self.data_loader.load_kline_data() |
|---|
| | | limit_up_record_data_list = self.data_loader.load_limit_up_data() |
|---|
| | | for d in limit_up_record_data_list: |
|---|
| | | if d[0] not in self.limit_up_record_data: |
|---|
| | | self.limit_up_record_data[d[0]] = [] |
|---|
| | | self.limit_up_record_data[d[0]].append(d) |
|---|
| | | self.limit_up_record_data_list = self.data_loader.load_limit_up_data() |
|---|
| | | for d in self.limit_up_record_data_list: |
|---|
| | | if d[0] not in self.limit_up_record_data_dict: |
|---|
| | | self.limit_up_record_data_dict[d[0]] = [] |
|---|
| | | self.limit_up_record_data_dict[d[0]].append(d) |
|---|
| | | self.next_trade_day = self.data_loader.load_next_trade_day() |
|---|
| | | if not trade_days: |
|---|
| | | raise Exception("交易日历获取失败") |
|---|
| | | if not self.kline_data: |
|---|
| | | raise Exception("历史日K获取失败") |
|---|
| | | if not self.limit_up_record_data: |
|---|
| | | if not self.limit_up_record_data_list: |
|---|
| | | raise Exception("历史涨停获取失败") |
|---|
| | | |
|---|
| | | def __load_current_date_data_by_timeline(self): |
|---|
| | |
|---|
| | | return |
|---|
| | | stock_variables = StrategyVariableFactory.create_from_history_data( |
|---|
| | | self.kline_data.get(code_), None, |
|---|
| | | self.limit_up_record_data.get(code_), self.data_loader.trade_days) |
|---|
| | | self.limit_up_record_data_dict.get(code_), self.data_loader.trade_days) |
|---|
| | | |
|---|
| | | # 加载今日涨停价 |
|---|
| | | pre_close = self.kline_data.get(code_)[0]["close"] |
|---|
| | |
|---|
| | | days = self.data_loader.trade_days[:day] |
|---|
| | | stock_variables.__setattr__(f"日出现的板块_{day}", |
|---|
| | | KPLLimitUpDataAnalyzer.get_limit_up_reasons( |
|---|
| | | self.limit_up_record_data, min_day=days[-1], |
|---|
| | | self.limit_up_record_data_list, min_day=days[-1], |
|---|
| | | max_day=days[0])) |
|---|
| | | stock_variables.连续老题材 = KPLLimitUpDataAnalyzer.get_continuous_limit_up_reasons( |
|---|
| | | self.limit_up_record_data, self.data_loader.trade_days[:2]) |
|---|
| | | self.limit_up_record_data_list, self.data_loader.trade_days[:2]) |
|---|
| | | |
|---|
| | | # 加载Tick信息 |
|---|
| | | open_price_info = TickSummaryDataManager().open_price_info_dict.get(code_) |
|---|
