添加新版低吸中间服务器

admin

2025-06-04 287c506725b2d970f721f80169f83c2418cb0991

 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: