From d163fc446359d66afa10e2ab63e860887aa8732c Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 19 八月 2025 01:33:11 +0800
Subject: [PATCH] 连续涨停时间记录/新增大单概览接口
---
servers/data_server.py | 10 +++++++++-
1 files changed, 9 insertions(+), 1 deletions(-)
diff --git a/servers/data_server.py b/servers/data_server.py
index cb8e7c5..acc73ef 100644
--- a/servers/data_server.py
+++ b/servers/data_server.py
@@ -36,7 +36,7 @@
from log_module import log_analyse, log_export, async_log_util
from l2 import code_price_manager, l2_data_util, transaction_progress
from cancel_strategy.s_l_h_cancel_strategy import HourCancelBigNumComputer, LCancelRateManager, \
- CancelRateHumanSettingManager
+ CancelRateHumanSettingManager, LCancelBigNumComputer
from output.limit_up_data_filter import IgnoreCodeManager
from third_data import kpl_util, kpl_data_manager, kpl_api, block_info
from third_data.code_plate_key_manager import RealTimeKplMarketData, KPLPlateForbiddenManager
@@ -1197,6 +1197,14 @@
response_data = json.dumps({"code": 0, "data": fdatas})
except Exception as e:
logger_debug.exception(e)
+ elif url.path == "/get_l2_down_watch_index_overview":
+ ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
+ code = ps_dict.get('code')
+ # 澶у崟姒傝
+ l2_down_data = LCancelBigNumComputer().statistic_l_down_watch_indexes_of_big_order_info(code)
+ total_big_order_info = LCancelBigNumComputer().statistic_total_big_order_info(code)
+ response_data = json.dumps({"code": 0, "data": {"l_down":l2_down_data,"total":total_big_order_info}})
+
async_log_util.info(logger_request_api, f"缁撴潫璇锋眰{tool.get_thread_id()}-{url}")
self.send_response(200)
# 鍙戠粰璇锋眰瀹㈡埛绔殑鍝嶅簲鏁版嵁
--
Gitblit v1.8.0