From a674a57120c3530151aa7b79d843a84ffb703e1d Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 11 一月 2024 15:05:08 +0800
Subject: [PATCH] bug修复/日志添加
---
middle_api_server.py | 31 +++++++++++++++++++++++++++----
1 files changed, 27 insertions(+), 4 deletions(-)
diff --git a/middle_api_server.py b/middle_api_server.py
index c39b498..504797a 100644
--- a/middle_api_server.py
+++ b/middle_api_server.py
@@ -14,6 +14,7 @@
from db import mysql_data, redis_manager
from db.redis_manager import RedisUtils
from log import logger_request_debug
+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
from utils.history_k_data_util import HistoryKDatasUtils, JueJinApi
from utils.huaxin_trade_record_manager import PositionManager
@@ -95,7 +96,8 @@
raise Exception("鐜颁环鑾峰彇澶辫触")
price = prices[0][1]
# 涓嬪崟
- result = hosting_api_util.trade_order(hosting_api_util.TRADE_DIRECTION_BUY, code, volume,
+ result = hosting_api_util.trade_order(hosting_api_util.TRADE_DIRECTION_BUY, code,
+ volume,
round(float(price), 2))
if result:
resultJSON = result
@@ -158,8 +160,8 @@
elif type_ == 'common':
# 楠岃瘉绛惧悕
- if not is_sign_right:
- raise Exception("绛惧悕閿欒")
+ # if not is_sign_right:
+ # raise Exception("绛惧悕閿欒")
params = data_json["data"]
result = hosting_api_util.common_request(params)
return_str = json.dumps(result)
@@ -221,7 +223,8 @@
if update_time is None:
update_time = ''
return_str = json.dumps(
- {"code": 0, "data": {"count": len(fresults), "list": fresults, "update_time": update_time},
+ {"code": 0,
+ "data": {"count": len(fresults), "list": fresults, "update_time": update_time},
"msg": ""})
pass
elif type_ == "export_l2_data":
@@ -335,6 +338,26 @@
params = data_json["data"]
result = hosting_api_util.common_request(params)
return_str = json.dumps(result)
+ elif type_ == "register_msg_receiver":
+ params = data_json["data"]
+ msg_types = params["types"]
+ try:
+ push_msg_manager.SocketManager.regirster_socket(sk, msg_types)
+ result = {"code": 0}
+ except Exception as e:
+ result = {"code": 1, "msg": str(e)}
+ return_str = json.dumps(result)
+ sk.sendall(socket_util.load_header(return_str.encode(encoding='utf-8')))
+ while True:
+ try:
+ sk.recv(1024)
+ time.sleep(1)
+ except:
+ print("鏁版嵁鏂紑")
+ break
+
+
+
finally:
log.request_info("middle_api_server", f"璇锋眰缁撴潫锛歿type_}")
break
--
Gitblit v1.8.0