From 287c506725b2d970f721f80169f83c2418cb0991 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 04 六月 2025 18:39:02 +0800
Subject: [PATCH] 添加新版低吸中间服务器

---
 middle_server.py |   16 ++++++++++++++++
 1 files changed, 16 insertions(+), 0 deletions(-)

diff --git a/middle_server.py b/middle_server.py
index b7228df..c2606c5 100644
--- a/middle_server.py
+++ b/middle_server.py
@@ -161,6 +161,15 @@
                                 global_data_cache_util.huaxin_subscript_codes_update_time = tool.get_now_time_str()
                             finally:
                                 sk.sendall(socket_util.load_header(json.dumps({"code": 0}).encode(encoding='utf-8')))
+                        elif data_json["type"] == "l2_subscript_codes_rate":
+                            # 璁剧疆璁㈤槄鐨勪唬鐮佺殑娑ㄥ箙
+                            try:
+                                data = data_json["data"]
+                                datas = data["data"]
+                                # print("l2_subscript_codes", data_json)
+                                global_data_cache_util.huaxin_subscript_codes_rate = datas
+                            finally:
+                                sk.sendall(socket_util.load_header(json.dumps({"code": 0}).encode(encoding='utf-8')))
                         elif data_json["type"] == "l2_position_subscript_codes":
                             # 璁剧疆璁㈤槄鐨勪唬鐮�
                             try:
@@ -360,6 +369,13 @@
                                     result_str = json.dumps({"code": 1, "msg": str(e)})
                             sk.sendall(socket_util.load_header(result_str.encode(encoding='utf-8')))
                             break
+                        elif data_json["type"] == 'low_suction':
+                            # TODO 浣庡惛閫氶亾
+                            datas = data_json["data"]
+                            pass
+
+
+
                     except Exception as e:
                         log.logger_tuoguan_request_debug.exception(e)
                     finally:

--
Gitblit v1.8.0