From 512202f8f88a3e0c23919921163aa7bd2f7da04d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 24 八月 2023 13:30:26 +0800
Subject: [PATCH] 记录华鑫本地的买入订单号
---
huaxin_client/l2_data_manager.py | 25 ++++++++++++++++++++++++-
1 files changed, 24 insertions(+), 1 deletions(-)
diff --git a/huaxin_client/l2_data_manager.py b/huaxin_client/l2_data_manager.py
index 7257f10..01cb5c6 100644
--- a/huaxin_client/l2_data_manager.py
+++ b/huaxin_client/l2_data_manager.py
@@ -10,7 +10,8 @@
from huaxin_client.client_network import SendResponseSkManager
# 娲诲姩鏃堕棿
-from log_module.log import logger_local_huaxin_l2_error, logger_local_huaxin_l2_upload
+from log_module import log_export
+from log_module.log import logger_local_huaxin_l2_error, logger_local_huaxin_l2_upload, logger_local_huaxin_l2_buy_no
order_detail_upload_active_time_dict = {}
transaction_upload_active_time_dict = {}
@@ -20,6 +21,7 @@
target_codes = set()
common_queue = queue.Queue()
trading_canceled_queue = queue.Queue()
+log_buy_no_queue = queue.Queue()
# 涔板叆璁㈠崟鍙风殑瀛楀吀
buy_order_nos_dict = {}
# 鏈�杩戠殑澶у崟鎴愪氦鍗曞彿
@@ -57,6 +59,8 @@
if data['SecurityID'] not in buy_order_nos_dict:
buy_order_nos_dict[data['SecurityID']] = set()
buy_order_nos_dict[data['SecurityID']].add(data['OrderNO'])
+ # 涔板叆璁㈠崟鍙烽渶瑕佽褰曟棩蹇�
+ log_buy_no_queue.put_nowait((data['SecurityID'], data['OrderNO']))
tmep_order_detail_queue_dict[code].put(
(data['SecurityID'], data['Price'], data['Volume'], data['Side'], data['OrderType'], data['OrderTime'],
@@ -225,6 +229,17 @@
logger_local_huaxin_l2_error.error(f"涓婁紶鏅�氭暟鎹嚭閿欙細{str(e)}")
+def __run_log():
+ print("__run_log")
+ while True:
+ try:
+ temp = log_buy_no_queue.get()
+ if temp:
+ logger_local_huaxin_l2_buy_no.info(f"{temp[0]}#{temp[1]}")
+ except:
+ pass
+
+
# 杩愯涓婁紶浠诲姟
def run_upload_task(code):
# 濡傛灉浠ｇ爜娌℃湁鍦ㄧ洰鏍囦唬鐮佷腑灏变笉闇�瑕佽繍琛�
@@ -250,6 +265,14 @@
t.start()
+def run_log():
+ fdatas = log_export.load_huaxin_local_buy_no()
+ global buy_order_nos_dict
+ buy_order_nos_dict = fdatas
+ t = threading.Thread(target=lambda: __run_log(), daemon=True)
+ t.start()
+
+
if __name__ == "__main__":
code = "603809"
target_codes.add(code)
--
Gitblit v1.8.0