From 9d9323c582bea82196b6813fa7331bea8494b5ea Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期四, 16 一月 2025 17:23:42 +0800
Subject: [PATCH] 功能完善
---
strategy/order_methods.py | 15 ++++++++++++++-
1 files changed, 14 insertions(+), 1 deletions(-)
diff --git a/strategy/order_methods.py b/strategy/order_methods.py
index ade2313..e21ef19 100644
--- a/strategy/order_methods.py
+++ b/strategy/order_methods.py
@@ -12,7 +12,8 @@
# import account_management
# 寮曞叆鏃ュ織妯″潡
from strategy.logging_config import get_logger
-from trade import huaxin_trade_api
+from trade import huaxin_trade_api, huaxin_trade_data_update, middle_api_protocol
+from utils import huaxin_util
# 鑾峰彇logger瀹炰緥
logger = get_logger()
@@ -215,7 +216,19 @@
:param order_info: {'sinfo': 'b_603682_1736312765623', 'securityID': '603682', 'orderLocalID': '8100043081', 'direction': '0', 'orderSysID': '110018100043081', 'insertTime': '13:06:04', 'insertDate': '20250108', 'acceptTime': '13:05:46', 'cancelTime': '', 'limitPrice': 6.45, 'accountID': '00032047', 'orderRef': 130608, 'turnover': 6410.0, 'volume': 1000, 'volumeTraded': 1000, 'orderStatus': '4', 'orderSubmitStatus': '1', 'statusMsg': ''}
:return:
"""
+ print(f"鏀跺埌璁㈠崟鍥炶皟锛歿order_info}")
logger_debug.info(f"鏀跺埌璁㈠崟鍥炶皟锛歿order_info}")
+ if huaxin_util.is_deal(order_info['orderStatus']):
+ # 鎴愪氦锛岄渶瑕佹洿鏂版寔浠�/濮旀墭/鎴愪氦
+ huaxin_trade_data_update.add_position_list()
+ huaxin_trade_data_update.add_delegate_list("鎴愪氦")
+ huaxin_trade_data_update.add_deal_list()
+ else:
+ huaxin_trade_data_update.add_money_list()
+ huaxin_trade_data_update.add_delegate_list("璁㈠崟鐘舵�佸彉鍖�")
+ # 鎺ㄩ�佽鍗曟暟鎹�
+ threading.Thread(target=lambda: middle_api_protocol.push(
+ middle_api_protocol.load_push_msg({"type": "order", "data": order_info})), daemon=True).start()
queue = multiprocessing.Queue()
huaxin_trade_api.run_trade(queue, MyTradeCallback())
--
Gitblit v1.8.0