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