bug修复

Administrator

2023-07-19 c28579640b39ea22329f901f726ec49dbffd767c

bug修复

 constant.py

@@ -111,7 +111,7 @@
L_CANCEL_MIN_MONEY = 98

# 华鑫L2的卡位数量
HUAXIN_L2_MAX_CODES_COUNT = 30
HUAXIN_L2_MAX_CODES_COUNT = 40

TRADE_WAY_HUAXIN = "huaxin"
TRADE_WAY_JUEJIN = "juejin"

 trade/huaxin/huaxin_trade_api.py

@@ -7,6 +7,7 @@
import threading
import time

from log_module.log import hx_logger_trade_debug
from utils import socket_util


@@ -53,13 +54,15 @@
                client_list = sorted(cls.socket_client_dict[_type], key=lambda x: cls.active_client_dict.get(x[0]) if x[
                                                                                                                          0] in cls.active_client_dict else 0,
                                     reverse=True)
                hx_logger_trade_debug.info(f"acquire_client client_list数量：{len(client_list)}")
                hx_logger_trade_debug.info(f"acquire_client socket_client_lock_dict数量：{len(cls.socket_client_lock_dict.keys())}")
                for d in client_list:
                    if d[0] in cls.socket_client_lock_dict:
                        try:
                            if cls.socket_client_lock_dict[d[0]].acquire(blocking=False):
                                return d
                        except threading.TimeoutError:
                            pass
                            hx_logger_trade_debug.error("acquire_client TimeoutError")
        else:
            if _type in cls.socket_client_dict:
                try: