华鑫适配

Administrator

2023-07-07 7b4dbbfc406509f87b8e6e1842b7b4cb88f97a2d

 trade/current_price_process_manager.py

@@ -8,6 +8,7 @@
from ths import client_manager
import constant
from code_attribute import gpcode_manager
from trade.huaxin import huaxin_trade_api
from utils import tool, import_util
from ths.l2_code_operate import L2CodeOperate
from trade import trade_manager, l2_trade_util
@@ -67,6 +68,7 @@
        # -------------------------------处理交易位置分配---------------------------------
        # 排序
        new_code_list = sorted(_code_list, key=lambda e: (e.__getitem__(2), e.__getitem__(0)), reverse=True)
        if constant.L2_SOURCE_TYPE == constant.L2_SOURCE_TYPE_THS:
        # 预填充下单代码
        _buy_win_codes = []
        for d in new_code_list:
@@ -81,12 +83,15 @@
            pass

        # -------------------------------处理L2监听---------------------------------

        max_count = 0
        if constant.L2_SOURCE_TYPE == constant.L2_SOURCE_TYPE_THS:
        client_ids = client_manager.getValidL2Clients()
        # 最多填充的代码数量
        max_count = len(client_ids) * constant.L2_CODE_COUNT_PER_DEVICE
        if max_count == 0:
            max_count = constant.L2_CODE_COUNT_PER_DEVICE
        else:
            max_count = constant.HUAXIN_L2_MAX_CODES_COUNT

        _delete_list = []
        for item in new_code_list:
@@ -108,6 +113,18 @@
        for d in _delete_list:
            del_code_list.append(d[1])

        if constant.L2_SOURCE_TYPE == constant.L2_SOURCE_TYPE_HUAXIN:
            # 华鑫L2,获取加入代码的涨停价
            add_datas = []
            for d in add_code_list:
                limit_up_price = gpcode_manager.get_limit_up_price(d)
                min_volume = 50 * 10000 // limit_up_price
                add_datas.append((d, min_volume, limit_up_price))
                try:
                    huaxin_trade_api.set_l2_codes_data(add_datas)
                except Exception as e:
                    logging.exception(e)
        else:
        # 后面的代码数量
        # 先删除应该删除的代码
        for code in del_code_list: