| | |
|---|
| | | import constant |
|---|
| | | from db.redis_manager_delegate import RedisUtils |
|---|
| | | from log_module import async_log_util, log |
|---|
| | | from third_data.kpl_data_constant import LimitUpDataConstant |
|---|
| | | from utils import tool |
|---|
| | | |
|---|
| | | # 开盘啦历史涨停数据管理 |
|---|
| | |
|---|
| | | cls.latest_origin_datas = records |
|---|
| | | cls.__LimitUpCodesPlateKeyManager.set_today_limit_up( |
|---|
| | | [(r[0], r[5], r[6].split('、') if r[6] else []) for r in records]) |
|---|
| | | kpl_data_constant.current_limit_up_datas = records |
|---|
| | | LimitUpDataConstant.set_current_limit_up_datas(records) |
|---|
| | | |
|---|
| | | code_reasons_dict = {} |
|---|
| | | reason_codes_dict = {} |
|---|
| | |
|---|
| | | if dd[0] in cls.latest_datas: |
|---|
| | | cls.latest_datas.pop(dd[0]) |
|---|
| | | cls.total_datas = KPLLimitUpDataRecordManager.list_all(tool.get_now_date_str()) |
|---|
| | | LimitUpDataConstant.set_history_limit_up_datas(cls.total_datas) |
|---|
| | | |
|---|
| | | @classmethod |
|---|
| | | def load_total_datas(cls): |
|---|
