添加测试日志

Administrator

2024-06-17 c001539dc2c831546e429da36f0236296646c79e

 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()])