| | |
|---|
| | | from server import data_server |
|---|
| | | from strategy import strategy_manager |
|---|
| | | from strategy.env_info import RealTimeEnvInfo |
|---|
| | | from strategy.strategy_variable_factory import DataLoader |
|---|
| | | from third_data import hx_qc_value_util |
|---|
| | | from third_data.history_k_data_manager import TradeDateManager |
|---|
| | | from third_data.kpl_block_manager import KPLCodeJXBlocksManager |
|---|
| | | from trade.huaxin import huaxin_trade_api |
|---|
| | | from utils import tool, middle_api_protocol |
|---|
| | |
|---|
| | | @return: |
|---|
| | | """ |
|---|
| | | |
|---|
| | | def update_leading_limit_up_datas(): |
|---|
| | | """ |
|---|
| | | 更新领涨代码信息 |
|---|
| | | @return: |
|---|
| | | """ |
|---|
| | | |
|---|
| | | def update(): |
|---|
| | | plates = __DataLoader.get_limit_up_reasons_with_plate_code() |
|---|
| | | for p in plates: |
|---|
| | | print(p) |
|---|
| | | __DataLoader.load_plate_codes(p[0], p[1]) |
|---|
| | | |
|---|
| | | if tool.get_now_time_str() < '16:00:00': |
|---|
| | | # 如果在16:00之前采用当前日期 |
|---|
| | | day = tool.get_now_date_str() |
|---|
| | | else: |
|---|
| | | # 如果在16:00之后采用下一个交易日 |
|---|
| | | day = TradeDateManager().get_next_trade_day(tool.get_now_date_str()) |
|---|
| | | __DataLoader = DataLoader(day) |
|---|
| | | threading.Thread(target=lambda: update(), daemon=True).start() |
|---|
| | | return {"code": 0} |
|---|
| | | |
|---|
| | | # 定时更新代码精选板块 |
|---|
| | | def run_pending(): |
|---|
| | | # 更新今日代码精选板块 |
|---|
| | |
|---|
| | | codes |= set([x.decode() for x in codes_sz]) |
|---|
| | | day = tool.get_now_date_str() |
|---|
| | | schedule.every().day.at("08:05:00").do(lambda: KPLCodeJXBlocksManager(day, codes).start_download_blocks()) |
|---|
| | | schedule.every().day.at("08:10:00").do(lambda: update_leading_limit_up_datas()) |
|---|
| | | |
|---|
| | | while True: |
|---|
| | | try: |
|---|
| | | schedule.run_pending() |
|---|
