From 5a28abc3f829eba092ebc87578a65d09f38fe262 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 15 八月 2023 14:48:22 +0800
Subject: [PATCH] ++++++++++++++++ bug修复-
---
huaxin_api/l2_client.py | 13 ++++++-------
1 files changed, 6 insertions(+), 7 deletions(-)
diff --git a/huaxin_api/l2_client.py b/huaxin_api/l2_client.py
index 7d6835c..82e8223 100644
--- a/huaxin_api/l2_client.py
+++ b/huaxin_api/l2_client.py
@@ -524,11 +524,10 @@
def __receive_from_pipe_strategy(pipe):
while True:
try:
- value = pipe.recv()
- if value:
- print("__receive_from_pipe_strategy:",value)
- value = value.decode("utf-8")
- data = json.loads(value)
+ val = pipe.recv()
+ if val:
+ print("L2瀹㈡埛绔帴鍙楀埌鏁版嵁锛�:", val)
+ data = json.loads(val)
if data["type"] == "set_l2_codes":
data = data["data"]
l2CommandManager.process_command(command_manager.CLIENT_TYPE_CMD_L2, None, data)
@@ -536,7 +535,7 @@
logging.exception(e)
-def run(pipe_trade=None, pipe_strategy=None):
+def run(pipe_trade, pipe_strategy):
__init_l2()
if pipe_trade is not None:
t1 = threading.Thread(target=lambda: __receive_from_pipe_trade(pipe_trade), daemon=True)
@@ -553,6 +552,6 @@
if __name__ == "__main__":
- run()
+ run(None,None)
# spi.set_codes_data([("000333", 12000)])
input()
--
Gitblit v1.8.0