| | |
| | | import datetime |
| | | import json |
| | | |
| | | import juejin |
| | | import tool |
| | | from utils import tool |
| | | from db import redis_manager |
| | | from db import mysql_data |
| | | import limit_up_time_manager |
| | | import gpcode_manager |
| | | from code_attribute import limit_up_time_manager, gpcode_manager |
| | | from l2 import code_price_manager |
| | | from third_data.history_k_data_util import HistoryKDatasUtils |
| | | |
| | | __redisManager = redis_manager.RedisManager(0) |
| | | INVALID_BLOCKS = ["其他", "ST股", "ST摘帽", "业绩增长", "业绩预增", "公告", "次新股"] |
| | |
| | | if now_day in __blocks_dict: |
| | | return __blocks_dict[now_day] |
| | | now_date = datetime.datetime.now() |
| | | end_date = juejin.JueJinManager.get_previous_trading_date(tool.get_now_date_str()) |
| | | end_date = HistoryKDatasUtils.get_previous_trading_date(tool.get_now_date_str()) |
| | | start_date = now_date - datetime.timedelta(days=(day_count * 2 + 10)) |
| | | start_date = start_date.strftime("%Y-%m-%d") |
| | | days = juejin.JueJinManager.get_trading_dates(start_date, end_date) |
| | | days = HistoryKDatasUtils.get_trading_dates(start_date, end_date) |
| | | days = days[0 - day_count:] |
| | | results = XGBHotBlockDataManager.list_blocks_with_day(days) |
| | | __blocks_dict[now_day] = results |