From cf32945520de905d86f87c04cad426a7402d12d8 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 19 十一月 2024 17:12:20 +0800
Subject: [PATCH] 删除原有的资金净流入统计方式
---
main.py | 12 +++---------
1 files changed, 3 insertions(+), 9 deletions(-)
diff --git a/main.py b/main.py
index 34dbb35..386889f 100644
--- a/main.py
+++ b/main.py
@@ -29,7 +29,7 @@
queue_l1_w_strategy_r_: multiprocessing.Queue,
queue_strategy_w_trade_r_: multiprocessing.Queue,
queue_strategy_w_trade_r_for_read_: multiprocessing.Queue, queue_l1_trade_r_strategy_w_,
- queue_l1_trade_w_strategy_r_, trade_ipc_addr, queue_custom_block_in_money):
+ queue_l1_trade_w_strategy_r_, trade_ipc_addr):
"""
绛栫暐杩涚▼
@@ -41,7 +41,6 @@
@param queue_l1_trade_r_strategy_w_:
@param queue_l1_trade_w_strategy_r_:
@param trade_ipc_addr: 浜ゆ槗ipc鍦板潃(涓嬪崟鍦板潃, 鎾ゅ崟鍦板潃)
- @param queue_custom_block_in_money: 鎺ユ敹鏉垮潡娴佸叆娴佸嚭
@return:
"""
logger_system.info("绛栫暐杩涚▼ID锛歿}", os.getpid())
@@ -67,7 +66,7 @@
# 鍚姩鍗庨懌浜ゆ槗鏈嶅姟
huaxin_trade_server.run(queue_strategy_r_trade_w_, queue_l1_w_strategy_r_, queue_strategy_w_trade_r_,
queue_strategy_w_trade_r_for_read_,
- queue_l1_trade_w_strategy_r_, trade_ipc_addr, queue_custom_block_in_money)
+ queue_l1_trade_w_strategy_r_, trade_ipc_addr)
# 涓绘湇鍔�
@@ -100,7 +99,6 @@
# l1
queue_l1_w_strategy_r = multiprocessing.Queue()
queue_l1_r_strategy_w = multiprocessing.Queue()
- queue_custom_block_in_money = multiprocessing.Queue() # 鎺ユ敹鏉垮潡娴佸叆娴佸嚭
# l1浜ゆ槗
queue_l1_trade_w_strategy_r = multiprocessing.Queue()
queue_l1_trade_r_strategy_w = multiprocessing.Queue()
@@ -122,7 +120,6 @@
# L1璁㈤槄鏁版嵁
l1Process = multiprocessing.Process(target=huaxin_client.l1_client.run,
args=(queue_l1_w_strategy_r, queue_l1_r_strategy_w,
- queue_custom_block_in_money,
gpcode_manager.BuyOpenLimitUpCodeManager().get_codes(),))
l1Process.start()
@@ -154,10 +151,7 @@
# 涓昏繘绋�
createTradeServer(pss_strategy, queue_strategy_r_trade_w, queue_l1_w_strategy_r, queue_strategy_w_trade_r,
queue_strategy_w_trade_r_for_read, queue_l1_trade_r_strategy_w,
- queue_l1_trade_w_strategy_r, (order_ipc_addr, cancel_order_ipc_addr),
- queue_custom_block_in_money)
-
-
+ queue_l1_trade_w_strategy_r, (order_ipc_addr, cancel_order_ipc_addr))
# 灏唗radeServer浣滀负涓昏繘绋�
l1Process.join()
--
Gitblit v1.8.0