From 9d2b0ab3967761b2d4b4e1c92034c3c0ea6705f5 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 16 一月 2025 16:29:56 +0800
Subject: [PATCH] 添加低吸中间服务器
---
middle_server.py | 46 ++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 44 insertions(+), 2 deletions(-)
diff --git a/middle_server.py b/middle_server.py
index 018bfc5..b7228df 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,7 +156,7 @@
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:
@@ -318,6 +319,47 @@
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
except Exception as e:
log.logger_tuoguan_request_debug.exception(e)
finally:
--
Gitblit v1.8.0