From a20361d464f997e2d1af049316fdd47687f5e10b Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 09 一月 2024 10:35:29 +0800
Subject: [PATCH] 添加请求日志

---
 outside_api_command_manager.py |   10 ++++++----
 1 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/outside_api_command_manager.py b/outside_api_command_manager.py
index abe3b69..86d9be6 100644
--- a/outside_api_command_manager.py
+++ b/outside_api_command_manager.py
@@ -11,7 +11,7 @@
 # 蹇冭烦淇℃伅
 from huaxin_client import socket_util
 from huaxin_client.client_network import SendResponseSkManager
-from log_module.log import logger_system
+from log_module.log import logger_system, logger_request_api
 from utils import middle_api_protocol, tool
 
 MSG_TYPE_HEART = "heart"
@@ -63,7 +63,6 @@
 API_TYPE_SAVE_RUNNING_DATA = "save_running_data"  # 淇濆瓨杩愯鏃舵暟鎹�
 API_TYPE_GET_CODE_POSITION_INFO = "get_code_position_info"  # 鑾峰彇浠g爜鎸佷粨淇℃伅
 API_TYPE_COMMON_REQUEST = "common_request"  # 閫氱敤璇锋眰
-
 
 
 class ActionCallback(object):
@@ -189,6 +188,7 @@
             try:
                 result = socket_util.recv_data(sk)[0]
                 if result:
+                    start_time = time.time()
                     try:
                         print("鎺ユ敹鏁版嵁", _type, result)
                         result_json = json.loads(result)
@@ -207,7 +207,6 @@
                             SendResponseSkManager.send_error_response(_type, request_id, client_id,
                                                                       {"code": -1, "msg": "绛惧悕閿欒"})
                             continue
-
                         if content_type == API_TYPE_TRADE:
                             # 浜ゆ槗
                             cls.action_callback.OnTrade(client_id, request_id, data)
@@ -249,8 +248,11 @@
                             cls.action_callback.OnCommonRequest(client_id, request_id, data)
                     except Exception as e:
                         logging.exception(e)
-                        pass
                     finally:
+                        use_time = int(time.time() - start_time)
+                        if use_time > 5:
+                            result_json = json.loads(result)
+                            logger_request_api.info(f"瓒呮椂5s浠ヤ笂锛歿result_json['data']['type']}")
                         # 鍙戦�佸搷搴�
                         sk.send(json.dumps({"type": "cmd_recieve"}).encode('utf-8'))
                 else:

--
Gitblit v1.8.0