下单/撤单通信方式修改/G撤修改

Administrator

2024-04-26 c4861d2429c2bf3a3f11309ad879b549e62e722d

 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"
@@ -41,6 +41,7 @@
CODE_LIST_BLACK = "black"
CODE_LIST_WANT = "want"
CODE_LIST_PAUSE_BUY = "pause_buy"
CODE_LIST_MUST_BUY = "must_buy"

# 类型
API_TYPE_TRADE = "trade"  # 交易
@@ -187,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)
@@ -205,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)
@@ -247,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: