From ff7c0f76f666f92d13cb4911b0065e025903a2ee Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 15 八月 2023 15:24:23 +0800
Subject: [PATCH] ++++++++++++++++ bug修复-
---
trade/huaxin/trade_api_server.py | 13 ++++++++-----
1 files changed, 8 insertions(+), 5 deletions(-)
diff --git a/trade/huaxin/trade_api_server.py b/trade/huaxin/trade_api_server.py
index df4c171..27273e1 100644
--- a/trade/huaxin/trade_api_server.py
+++ b/trade/huaxin/trade_api_server.py
@@ -438,8 +438,8 @@
"data": datas,
"request_id": f"{ClientSocketManager.CLIENT_TYPE_CMD_L2}_{round(time.time() * 1000)}"}
# root_data = socket_util.encryp_client_params_sign(root_data)
- # pipe_l2.send(json.dumps(root_data))
- pipe_l2.send(f"{time.time()}")
+ pipe_l2.send(json.dumps(root_data))
+ # pipe_l2.send(f"{time.time()}")
print("鍚慙2鍙戦�佹暟鎹�")
except Exception as e:
@@ -524,12 +524,15 @@
print("create TradeApiServer")
# 鎷夊彇浜ゆ槗淇℃伅
huaxin_trade_data_update.run()
-
- t1 = threading.Thread(target=lambda: __set_target_codes(pipe_l2), daemon=True)
- t1.start()
+ #
+ # t1 = threading.Thread(target=lambda: __set_target_codes(pipe_l2), daemon=True)
+ # t1.start()
t1 = threading.Thread(target=lambda: __read_sync_task(pipe_server), daemon=True)
t1.start()
+
+ __set_target_codes(pipe_l2)
+
# 鎵樼鐜涓嬩笉寮�鍚帴鍙�
# laddr = "0.0.0.0", 10009
# tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle) # 娉ㄦ剰锛氬弬鏁版槸MyBaseRequestHandle
--
Gitblit v1.8.0