From 287c506725b2d970f721f80169f83c2418cb0991 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 04 六月 2025 18:39:02 +0800
Subject: [PATCH] 添加新版低吸中间服务器
---
middle_server.py | 62 ++++++++++++++++++++++++++++++-
1 files changed, 60 insertions(+), 2 deletions(-)
diff --git a/middle_server.py b/middle_server.py
index 018bfc5..c2606c5 100644
--- a/middle_server.py
+++ b/middle_server.py
@@ -18,7 +18,8 @@
from log_module.log import logger_debug
from middle_l1_data_server import L1DataManager
from output import push_msg_manager
-from utils import socket_util, kpl_api_util, hosting_api_util, kp_client_msg_manager, global_data_cache_util, tool
+from utils import socket_util, kpl_api_util, hosting_api_util, kp_client_msg_manager, global_data_cache_util, tool, \
+ block_web_api
from utils.juejin_util import JueJinHttpApi
trade_data_request_queue = queue.Queue()
@@ -155,9 +156,18 @@
try:
data = data_json["data"]
datas = data["data"]
- print("l2_subscript_codes", data_json)
+ # print("l2_subscript_codes", data_json)
global_data_cache_util.huaxin_subscript_codes = datas
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":
@@ -318,6 +328,54 @@
datas = data_json["data"]
L1DataManager().add_datas(datas)
break
+ elif data_json["type"] == 'get_l1_target_codes':
+ # 鑾峰彇鐩爣浠ｇ爜
+ codes = L1DataManager().get_target_codes()
+ result_str = json.dumps({"code": 0, "data": list(codes)})
+ sk.sendall(socket_util.load_header(result_str.encode(encoding='utf-8')))
+ break
+ # 鑾峰彇涓夋柟鏉垮潡
+ elif data_json["type"] == 'get_third_blocks':
+ data = data_json["data"]
+ data = data["data"]
+ source = data["source"]
+ code = data["code"]
+ result_str = json.dumps({"code": 1, "msg": "source涓嶅尮閰�"})
+ if source == 2:
+ # 閫氳揪淇�
+ try:
+ blocks = block_web_api.get_tdx_blocks(code)
+ result_str = json.dumps({"code": 0, "data": list(blocks)})
+ except Exception as e:
+ result_str = json.dumps({"code": 1, "msg": str(e)})
+ elif source == 3:
+ # 鍚岃姳椤�
+ try:
+ blocks = block_web_api.THSBlocksApi().get_ths_blocks(code)
+ result_str = json.dumps({"code": 0, "data": list(blocks)})
+ except Exception as e:
+ try:
+ block_web_api.THSBlocksApi.load_hexin_v()
+ blocks = block_web_api.THSBlocksApi().get_ths_blocks(code)
+ result_str = json.dumps({"code": 0, "data": list(blocks)})
+ except Exception as e1:
+ result_str = json.dumps({"code": 1, "msg": str(e1)})
+ elif source == 4:
+ # 涓滄柟璐㈠瘜
+ try:
+ blocks = block_web_api.get_eastmoney_block(code)
+ result_str = json.dumps({"code": 0, "data": list(blocks)})
+ except Exception as e:
+ 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