华鑫适配

Administrator

2023-07-10 912f1c5976f070d8fff703e07bedb3531acf3fd0

华鑫适配

 server.py

@@ -37,8 +37,10 @@
from trade.huaxin import huaxin_trade_record_manager
from trade.trade_manager import TradeTargetCodeModeManager
from trade.trade_queue_manager import THSBuy1VolumnManager, thsl2tradequeuemanager

ths_util = import_util.import_lib("ths.ths_util")
trade_gui = import_util.import_lib("trade.trade_gui")


class MyTCPServer(socketserver.TCPServer):
    def __init__(self, server_address, RequestHandlerClass, bind_and_activate=True, pipe_juejin=None, pipe_ui=None):
@@ -102,6 +104,15 @@
                # print("结果：",_str)
                type = -1
                try:
                    # 如果带有头
                    if _str.startswith("##"):
                        total_length = int(_str[2:10])
                        _str = _str[10:]
                        # 防止socket数据发生粘连
                        while total_length > len(_str):
                            d = sk.recv(1024 * 100)
                            if d:
                                _str += d.decode(encoding='gbk')
                    type = data_process.parseType(_str)
                except Exception as e:
                    if str(e).find("Unterminated string starting") > -1:
@@ -1108,7 +1119,6 @@


if __name__ == "__main__":


    # 交易成功无法读取时备用
    while True:

 third_data/block_info.py

@@ -32,6 +32,7 @@
# (代码, 名称, 首次涨停时间, 最近涨停时间, 几板, 涨停原因, 板块, 实际流通, 主力净额)
def __get_blocks(code, limit_up_datas, filter=True):
    blocks = []
    if limit_up_datas:
    for data in limit_up_datas:
        if data[0] == code:
            block = data[5]

 trade/huaxin/trade_server.py

@@ -361,26 +361,7 @@


if __name__ == "__main__":
    code = "002251"
    datas = [['002251', 0.0, 138300, '1', '2', 112555120, 2011, 18281251, 18233797, 'D']]
    origin_start_time = 0
    try:
        # 转换数据格式
        _start_index = 0
        if local_today_datas.get(code) is not None and len(
                local_today_datas[code]) > 0:
            _start_index = local_today_datas[code][-1]["index"] + 1
        datas = l2_huaxin_util.get_format_l2_datas(code, datas,
                                                   gpcode_manager.get_limit_up_price(code), _start_index)
        __start_time = round(time.time() * 1000)
        # l2_data_manager_new.L2TradeDataProcessor().process_add_datas(code, datas, 0, __start_time)
    except Exception as e:
        logging.exception(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)

    # ClientSocketManager.add_client(ClientSocketManager.CLIENT_TYPE_TRADE, "1", None)