| | |
|---|
| | | import constant |
|---|
| | | from code_attribute import gpcode_manager |
|---|
| | | from l2 import l2_data_manager_new, l2_data_log |
|---|
| | | from l2.huaxin import l2_huaxin_util |
|---|
| | | from l2.huaxin import l2_huaxin_util, huaxin_target_codes_manager |
|---|
| | | from logs_.log import logger_l2_error |
|---|
| | | from trade.huaxin.huaxin_log import logger_l2_orderdetail, logger_l2_transaction, logger_l2_upload, \ |
|---|
| | | logger_contact_debug, logger_trade_callback, logger_trade_debug |
|---|
| | |
|---|
| | | origin_start_time = round(time.time() * 1000) |
|---|
| | | try: |
|---|
| | | # 转换数据格式 |
|---|
| | | datas = l2_huaxin_util.get_format_l2_datas(code, datas, gpcode_manager.get_limit_up_price(code)) |
|---|
| | | datas = l2_huaxin_util.get_format_l2_datas(code, datas, |
|---|
| | | gpcode_manager.get_limit_up_price(code)) |
|---|
| | | __start_time = round(time.time() * 1000) |
|---|
| | | l2_data_manager_new.L2TradeDataProcessor().process_add_datas(code, datas, 0, __start_time) |
|---|
| | | except Exception as e: |
|---|
| | |
|---|
| | | time.sleep(1) |
|---|
| | | |
|---|
| | | |
|---|
| | | def __set_target_codes(): |
|---|
| | | while True: |
|---|
| | | try: |
|---|
| | | datas = huaxin_target_codes_manager.pop() |
|---|
| | | if datas: |
|---|
| | | result = huaxin_trade_api.set_l2_codes_data(datas) |
|---|
| | | print("设置L2代码结果：", result) |
|---|
| | | except Exception as e: |
|---|
| | | logging.exception(e) |
|---|
| | | finally: |
|---|
| | | time.sleep(1) |
|---|
| | | |
|---|
| | | |
|---|
| | | def run(): |
|---|
| | | t1 = threading.Thread(target=lambda: read_trade_data_queue()) |
|---|
| | | # 后台运行 |
|---|
| | | t1.setDaemon(True) |
|---|
| | | # 拉取交易信息 |
|---|
| | | t1 = threading.Thread(target=lambda: read_trade_data_queue(), daemon=True) |
|---|
| | | t1.start() |
|---|
| | | |
|---|
| | | t1 = threading.Thread(target=lambda: __set_target_codes(), daemon=True) |
|---|
| | | t1.start() |
|---|
| | | |
|---|
| | | laddr = "0.0.0.0", 10008 |
|---|
