| | |
| | | import psutil |
| | | import requests |
| | | |
| | | from api import low_suction_data_pusher |
| | | from code_attribute import global_data_loader |
| | | from huaxin_client import l2_client_test, l1_subscript_codes_manager |
| | | from log_module.log import logger_local_huaxin_l2_transaction_big_order, logger_system, \ |
| | |
| | | def __save_accurate_big_order(big_accurate_order_queue): |
| | | while True: |
| | | try: |
| | | data = big_accurate_order_queue.get() |
| | | logger_local_huaxin_l2_transaction_accurate_big_order.info(f"{data}") |
| | | datas = [] |
| | | while not big_accurate_order_queue.empty(): |
| | | data = big_accurate_order_queue.get() |
| | | datas.append(data) |
| | | if datas: |
| | | low_suction_data_pusher.push_big_order(datas) |
| | | for data in datas: |
| | | logger_local_huaxin_l2_transaction_accurate_big_order.info(f"{data}") |
| | | except: |
| | | pass |
| | | |
| | |
| | | __upload_data("jingxuan_rank", json.dumps(fins)) |
| | | __upload_data("jingxuan_rank_out", json.dumps(fouts)) |
| | | __upload_codes_in_money() |
| | | try: |
| | | low_suction_data_pusher.push_block_in(in_list) |
| | | except: |
| | | pass |
| | | except Exception as e: |
| | | logging.exception(e) |
| | | finally: |