| | |
|---|
| | | # 代码行业映射 |
|---|
| | | import pymongo |
|---|
| | | |
|---|
| | | import code_volumn_manager |
|---|
| | | import ths_industry_util |
|---|
| | | import gpcode_manager |
|---|
| | | import mongo_data |
|---|
| | | |
|---|
| | | TEST = False |
|---|
| | | |
|---|
| | | code_industry_map = {} |
|---|
| | | # 行业代码映射 |
|---|
| | |
|---|
| | | big_money_num = {} |
|---|
| | | # 涨停时间 |
|---|
| | | limit_up_time = {} |
|---|
| | | |
|---|
| | | |
|---|
| | | def init(): |
|---|
| | | load_volumn() |
|---|
| | | load_zyltgb() |
|---|
| | | load_industry() |
|---|
| | | |
|---|
| | | |
|---|
| | | # 加载行业数据 |
|---|
| | |
|---|
| | | zyltgb_map[code] = round(float(result["zyltgb"]) * 10000) |
|---|
| | | |
|---|
| | | |
|---|
| | | # 加载量 |
|---|
| | | def load_volumn(): |
|---|
| | | codes = gpcode_manager.get_gp_list() |
|---|
| | | for code in codes: |
|---|
| | | max60, yesterday = code_volumn_manager.get_histry_volumn(code) |
|---|
| | | today = code_volumn_manager.get_today_volumn(code) |
|---|
| | | max60_volumn[code] = max60 |
|---|
| | | yesterday_volumn[code] = yesterday |
|---|
| | | today_volumn[code] = today |
|---|
| | | |
|---|
| | | |
|---|
| | | # 添加今日涨停数据 |
|---|
| | | def add_limit_up_codes(datas, clear=False): |
|---|
| | | if clear: |
|---|
