From f5b416d9cb5214ff0e46ca6305098085d2fe8742 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 27 九月 2023 18:02:11 +0800
Subject: [PATCH] L2与交易之间的通信采用队列方式/实现L撤单比例动态计算
---
huaxin_client/command_manager.py | 8 +-------
1 files changed, 1 insertions(+), 7 deletions(-)
diff --git a/huaxin_client/command_manager.py b/huaxin_client/command_manager.py
index df18406..1a5c29d 100644
--- a/huaxin_client/command_manager.py
+++ b/huaxin_client/command_manager.py
@@ -74,20 +74,14 @@
return cls._instance
@classmethod
- def init(cls, trade_action_callback: TradeActionCallback, pipe_l2, queue_strategy_trade_read: multiprocessing.Queue):
+ def init(cls, trade_action_callback: TradeActionCallback, queue_strategy_trade_read: multiprocessing.Queue):
cls.action_callback = trade_action_callback
- cls.pipe_l2 = pipe_l2
cls.queue_strategy_trade_read = queue_strategy_trade_read
@classmethod
def process_command(cls, _type, client_id, result_json, sk=None):
async_log_util.info(logger_local_huaxin_contact_debug, f"process_command锛� {result_json}")
# 鏌ョ湅鏄惁鏄缃甃2鐨勪唬鐮�
- if _type == CLIENT_TYPE_CMD_L2:
- cls.pipe_l2.send(
- json.dumps({"type": "set_l2_codes", "data": result_json["data"]}))
- return
-
try:
data = result_json["data"]
request_id = result_json.get('request_id')
--
Gitblit v1.8.0