融入交易

admin

2024-05-22 4ee1bd5de9ca76a69adac6e17a11bd686c742ef3

 middle_api_server.py

@@ -8,12 +8,12 @@
import time

import constant
import log
import socket_manager
import trade_manager
from db import mysql_data, redis_manager
from db.redis_manager import RedisUtils
from log import logger_request_debug
from log_module import log, request_log_util
from log_module.log import logger_request_debug
from middle_l1_data_server import L1DataManager
from output import push_msg_manager
from utils import socket_util, hosting_api_util, huaxin_trade_record_manager, huaxin_util, tool, global_data_cache_util
@@ -69,7 +69,7 @@
                    data_json = json.loads(data_str)
                    type_ = data_json['type']
                    try:
                        log.request_info("middle_api_server", f"请求开始：{type_}")
                        request_log_util.request_info("middle_api_server", f"请求开始：{type_}")
                        if type(type_) == int:
                            # 处理数字型TYPE
                            return_str = self.process_num_type(sk, type_, data_str)
@@ -397,7 +397,7 @@
                            results = L1DataManager.get_current_l1_data()
                            return_str = json.dumps({"code": 0, "data": results})
                    finally:
                        log.request_info("middle_api_server", f"请求结束：{type_}")
                        request_log_util.request_info("middle_api_server", f"请求结束：{type_}")
                break
                # sk.close()
            except Exception as e: