添加测试日志

Administrator

2024-06-17 c001539dc2c831546e429da36f0236296646c79e

添加测试日志

 huaxin_client/code_queue_distribute_manager.py

@@ -3,6 +3,8 @@
"""
import copy

from log_module.log import logger_local_huaxin_l2_error


class CodeQueueDistributeManager:
    # queue_list
@@ -58,6 +60,7 @@

    # 获取可用的队列
    def get_available_callback(self):
        # 已经分配的回调ID
        distibuted_callbacks_ids = set()
        for code in self.distibuted_code_callback_dict:
            distibuted_callbacks_ids.add(self.distibuted_code_callback_dict[code][0])
@@ -72,6 +75,11 @@
            return self.distibuted_code_callback_dict.get(code)
        callback_info = self.get_available_callback()
        if not callback_info:
            distibuted_callbacks_ids = set()
            for code in self.distibuted_code_callback_dict:
                distibuted_callbacks_ids.add(self.distibuted_code_callback_dict[code][0])
            logger_local_huaxin_l2_error.info(f"已经分配的代码：{self.distibuted_code_callback_dict.keys()}")
            logger_local_huaxin_l2_error.info(f"已经分配的callbackid：{distibuted_callbacks_ids}")
            raise Exception("无可用的回调对象")
        self.distibuted_code_callback_dict[code] = callback_info
        return callback_info

 third_data/data_server.py

@@ -9,10 +9,10 @@

from code_attribute.gpcode_manager import BlackListCodeManager, CodePrePriceManager
from l2.l2_transaction_data_manager import HuaXinBuyOrderManager
from log_module.log import logger_system, logger_debug, logger_kpl_limit_up
from log_module.log import logger_system, logger_debug, logger_kpl_limit_up, logger_request_api
from utils import global_util, tool, data_export_util, init_data_util
from code_attribute import gpcode_manager
from log_module import log, log_analyse, log_export
from log_module import log, log_analyse, log_export, async_log_util
from l2 import code_price_manager, l2_data_util, l2_data_manager_new, cancel_buy_strategy, transaction_progress
from cancel_strategy.s_l_h_cancel_strategy import HourCancelBigNumComputer, LCancelRateManager
from output.limit_up_data_filter import IgnoreCodeManager
@@ -351,6 +351,7 @@
                logging.exception(e)

        elif url.path == "/get_l2_datas":
            async_log_util.info(logger_request_api, f"开始请求{tool.get_thread_id()}-{url}")
            try:
                # 获取L2的数据
                ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
@@ -370,6 +371,8 @@
                                                                         "transactions": transaction_datas}}})
            except Exception as e:
                logger_debug.exception(e)
            finally:
                async_log_util.info(logger_request_api, f"结束请求{tool.get_thread_id()}-{url}")
        elif url.path == "/get_trade_progress":
            # 获取交易进度
            ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])