| | |
|---|
| | | import time |
|---|
| | | |
|---|
| | | import constant |
|---|
| | | import log |
|---|
| | | import socket_manager |
|---|
| | | import trade_manager |
|---|
| | | from db import mysql_data, redis_manager |
|---|
| | |
|---|
| | | # print("收到数据------", f"{data_str[:20]}......{data_str[-20:]}") |
|---|
| | | data_json = json.loads(data_str) |
|---|
| | | type_ = data_json['type'] |
|---|
| | | thread_id = random.randint(0, 1000000) |
|---|
| | | try: |
|---|
| | | logger_request_debug.info(f"middle_api_server 请求开始({thread_id})：{type_}") |
|---|
| | | log.request_info("middle_api_server", f"请求开始：{type_}") |
|---|
| | | if type(type_) == int: |
|---|
| | | # 处理数字型TYPE |
|---|
| | | return_str = self.process_num_type(sk, type_, data_str) |
|---|
| | |
|---|
| | | result = hosting_api_util.common_request(params) |
|---|
| | | return_str = json.dumps(result) |
|---|
| | | finally: |
|---|
| | | logger_request_debug.info(f"middle_api_server 请求结束({thread_id})：{type}") |
|---|
| | | log.request_info("middle_api_server", f"请求结束：{type_}") |
|---|
| | | break |
|---|
| | | # sk.close() |
|---|
| | | except Exception as e: |
|---|
