华鑫适配

Administrator

2023-07-07 7b4dbbfc406509f87b8e6e1842b7b4cb88f97a2d

 trade/huaxin/trade_server.py

@@ -7,8 +7,13 @@
import socketserver
import threading
import time
import l2

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 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

@@ -147,6 +152,19 @@
                        code = data["code"]
                        datas = data["data"]
                        logger_l2_orderdetail.info(f"{code}#{datas}")
                        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))
                            __start_time = round(time.time() * 1000)
                            l2_data_manager_new.L2TradeDataProcessor().process_add_datas(code, datas, 0, __start_time)
                        except Exception as e:
                            logger_l2_error.exception(e)
                        finally:
                            l2_data_log.l2_time(code, round(time.time() * 1000) - origin_start_time,
                                                "l2数据处理总耗时",
                                                True)
                            l2.l2_data_util.save_l2_data(code, None, datas)
                        sk.sendall(json.dumps({"code": 0}).encode(encoding='utf-8'))

                    elif data_json["type"] == "l2_trans":