From e0b77a03d87eb9bafd08e35492f918b5b8b0fbb5 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 28 六月 2024 15:34:18 +0800
Subject: [PATCH] '持仓矫正'
---
local_api/juejin.py | 27 +++++++++++++++++++++++++++
1 files changed, 27 insertions(+), 0 deletions(-)
diff --git a/local_api/juejin.py b/local_api/juejin.py
index 52f228e..acba275 100644
--- a/local_api/juejin.py
+++ b/local_api/juejin.py
@@ -59,6 +59,16 @@
except:
return []
+ def queryPositionBySymbol(self, symbol):
+ """
+ 鎸佷粨鏌ヨ
+ :return:
+ """
+ try:
+ return self.context.account().position(symbol, PositionSide_Long)
+ except:
+ return []
+
def queryUnfinishOrders(self):
"""
鏌ヨ鏈畬鎴愬鎵�
@@ -78,6 +88,13 @@
"""
async_log_util.info(logger_trade, f"鎾ゅ崟锛歿local_id}-{account_id}")
return order_cancel([{"cl_ord_id": local_id, "account_id": account_id}])
+
+ def getExecutionReports(self):
+ """
+ 鑾峰彇鎵ц鍥炴姤
+ :return:
+ """
+ return get_execution_reports()
__JueJinTradeManager = JueJinTradeManager()
@@ -122,12 +139,22 @@
elif type == 'position':
results = __JueJinTradeManager.queryPosition()
__send_request_response(request_id, results)
+ elif type == 'get_position_by_symbol':
+ results = __JueJinTradeManager.queryPositionBySymbol(data["symbol"])
+ __send_request_response(request_id, results)
elif type == 'get_unfinish_orders':
results = __JueJinTradeManager.queryUnfinishOrders()
__send_request_response(request_id, results)
elif type == 'cancel_order':
__JueJinTradeManager.cancelOrders(data["local_order_id"], data["account_id"])
__send_request_response(request_id, {})
+ elif type == 'get_execution_reports':
+ __JueJinTradeManager.getExecutionReports()
+ __send_request_response(request_id, {})
+
+
+
+
except Exception as e:
logger_print.exception(e)
--
Gitblit v1.8.0