| | |
|---|
| | | 更新领涨代码信息 |
|---|
| | | @return: |
|---|
| | | """ |
|---|
| | | print("*******更新领涨信息********") |
|---|
| | | |
|---|
| | | 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': |
|---|
| | |
|---|
| | | 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() |
|---|
| | |
|---|
| | | outside_api_callback.MyAPICallback()) |
|---|
| | | manager.run(blocking=False) |
|---|
| | | |
|---|
| | | # --------启动交易---------- |
|---|
| | | huaxin_trade_api.run() |
|---|
| | | |
|---|
| | | threading.Thread(target=test, daemon=True).start() |
|---|
| | | # test() |
|---|
| | | try: |
|---|
| | | # --------启动交易---------- |
|---|
| | | huaxin_trade_api.run() |
|---|
| | | except: |
|---|
| | | pass |
|---|
| | | |
|---|
| | | # ----初始化------------ |
|---|
| | | __init() |
|---|
| | |
|---|
| | | logger_system.exception(e) |
|---|
| | | |
|---|
| | | # -------启动L2 market订阅------ |
|---|
| | | __run_l2_market_subscript() |
|---|
| | | logger_system.info("系统结束") |
|---|
| | | try: |
|---|
| | | __run_l2_market_subscript() |
|---|
| | | logger_system.info("系统结束") |
|---|
| | | except: |
|---|
| | | pass |
|---|
