From 7093bbad9379116c432e4da278a40cc86303c76f Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 02 十一月 2023 11:30:24 +0800
Subject: [PATCH] bug修复
---
middle_api_server.py | 25 ++++++++++++++++++++++---
1 files changed, 22 insertions(+), 3 deletions(-)
diff --git a/middle_api_server.py b/middle_api_server.py
index e86d280..2528835 100644
--- a/middle_api_server.py
+++ b/middle_api_server.py
@@ -12,6 +12,7 @@
from db.redis_manager import RedisUtils
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
class MyTCPServer(socketserver.TCPServer):
@@ -109,7 +110,8 @@
orderSysID = codes_data.get("orderSysID")
accountId = codes_data.get("accountId")
if code:
- result = hosting_api_util.trade_cancel_order(hosting_api_util.TRADE_DIRECTION_BUY, code,accountId,
+ result = hosting_api_util.trade_cancel_order(hosting_api_util.TRADE_DIRECTION_BUY, code,
+ accountId,
orderSysID, True)
print("---鎾ゅ崟缁撴灉----")
print(result)
@@ -147,6 +149,16 @@
raise Exception(result["msg"])
print("---鍗栧嚭缁撴灉----")
print(result)
+ break
+ elif type_ == 'get_cost_price':
+ # 鑾峰彇鎴愭湰浠�
+ codes_data = data_json["data"]
+ code = codes_data["code"]
+ try:
+ price = PositionManager.get_cost_price(code)
+ return_str = json.dumps({"code": 0, "data": {"price": price}})
+ except Exception as e:
+ return_str = json.dumps({"code": 1, "msg": str(e)})
break
elif type_ == 'delegate_list':
# 濮旀墭鍒楄〃
@@ -237,7 +249,7 @@
# 鑾峰彇鐜淇℃伅
start_index = data_json["data"]["start_index"]
count = data_json["data"]["count"]
- result = hosting_api_util.get_system_logs(start_index,count)
+ result = hosting_api_util.get_system_logs(start_index, count)
return_str = json.dumps(result)
elif type_ == 'test_redis':
redis = redis_manager.RedisManager(5).getRedisNoPool()
@@ -255,10 +267,17 @@
{"code": 0, "data": times, "msg": ""})
finally:
redis.close()
+ elif type_ == 'get_code_trade_info':
+ # 鑾峰彇鐜淇℃伅
+ code = data_json["data"]["code"]
+ result = hosting_api_util.get_code_trade_info(code)
+ return_str = json.dumps(result)
+ elif type_ == 'get_l2_listen_active_count':
+ result = hosting_api_util.get_l2_listen_active_count()
+ return_str = json.dumps(result)
elif type_ == "trade_server_channels":
channels = socket_manager.ClientSocketManager.list_client()
return_str = json.dumps({"code": 0, "data": channels})
-
break
# sk.close()
except Exception as e:
--
Gitblit v1.8.0