From c001539dc2c831546e429da36f0236296646c79e Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 17 六月 2024 13:59:33 +0800
Subject: [PATCH] 添加测试日志

---
 third_data/data_server.py |    7 +++++--
 1 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/third_data/data_server.py b/third_data/data_server.py
index 1fba80d..2080c10 100644
--- a/third_data/data_server.py
+++ b/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()])

--
Gitblit v1.8.0