| | |
| | | """ |
| | | |
| | | # 代码行业映射 |
| | | import pymongo |
| | | |
| | | import mongo_data |
| | | import code_volumn_manager |
| | | import gpcode_manager |
| | | |
| | | import ths_industry_util |
| | | from code_data_util import ZYLTGBUtil |
| | | |
| | | TEST = False |
| | | TEST = True |
| | | |
| | | code_industry_map = {} |
| | | # 行业代码映射 |
| | |
| | | today_limit_up_codes = {} |
| | | # 行业热度指数 |
| | | industry_hot_num = {} |
| | | # 涨停股票的涨幅 |
| | | limit_up_codes_percent = {} |
| | | |
| | | # 名称代码映射 |
| | | name_codes = {} |
| | | |
| | | # 今日量 |
| | | today_volumn = {} |
| | | # 60日最大量 |
| | |
| | | load_volumn() |
| | | load_zyltgb() |
| | | load_industry() |
| | | load_name_codes() |
| | | |
| | | |
| | | # 加载行业数据 |
| | |
| | | zyltgb_map[code] = result |
| | | |
| | | |
| | | # 加载名称代码隐射 |
| | | def load_name_codes(): |
| | | dict_ = gpcode_manager.get_name_codes() |
| | | if dict_: |
| | | for key in dict_: |
| | | name_codes[key] = dict_[key] |
| | | |
| | | |
| | | # 加载量 |
| | | def load_volumn(): |
| | | codes = gpcode_manager.get_gp_list() |
| | |
| | | |
| | | # 添加今日涨停数据 |
| | | def add_limit_up_codes(datas, clear=False): |
| | | if datas is None: |
| | | return |
| | | if clear: |
| | | today_limit_up_codes.clear() |
| | | # 涨停数量 |