From 95e18d831b6e1e3509e24e1fe3eed9f1d0b70f6d Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 31 七月 2025 14:13:27 +0800
Subject: [PATCH] 添加推送日志
---
middle_cb_api_server.py | 16 ++++++++++++----
1 files changed, 12 insertions(+), 4 deletions(-)
diff --git a/middle_cb_api_server.py b/middle_cb_api_server.py
index 5d63c54..24578c4 100644
--- a/middle_cb_api_server.py
+++ b/middle_cb_api_server.py
@@ -3,8 +3,9 @@
import logging
import socket
import socketserver
-import log
-from log import logger_request_debug
+
+from log_module import request_log_util
+from log_module.log import logger_request_debug
from utils import socket_util, hosting_api_util
"""
@@ -60,7 +61,7 @@
data_json = json.loads(data_str)
type_ = data_json['type']
try:
- log.request_info("middle_cb_api_server", f"璇锋眰寮�濮嬶細{type_}")
+ request_log_util.request_info("middle_cb_api_server", f"璇锋眰寮�濮嬶細{type_}")
is_sign_right = socket_util.is_client_params_sign_right(data_json)
# ------瀹㈡埛绔姹傛帴鍙�-------
if type_ == 'buy':
@@ -145,6 +146,13 @@
result = hosting_api_util.get_account_money_for_cb()
return_str = json.dumps(result)
break
+ elif type_ == 'refresh_trade_data':
+ # 楠岃瘉绛惧悕
+ data = data_json["data"]
+ refresh_type = data["ctype"]
+ result = hosting_api_util.refresh_trade_data_for_cb(refresh_type)
+ return_str = json.dumps(result)
+ break
elif type_ == 'common':
params = data_json["data"]
@@ -152,7 +160,7 @@
return_str = json.dumps(result)
break
finally:
- log.request_info("middle_cb_api_server", f"璇锋眰缁撴潫锛歿type_}")
+ request_log_util.request_info("middle_cb_api_server", f"璇锋眰缁撴潫锛歿type_}")
break
# sk.close()
except Exception as e:
--
Gitblit v1.8.0