From 12ed2a63a601854075886b6673bf03d1b4de75c8 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 01 十一月 2023 14:23:03 +0800
Subject: [PATCH] L撤H撤数据外部接口添加/涨幅过高代码记录
---
third_data/data_server.py | 37 +++++++++++++++++++++++++++++++++++--
1 files changed, 35 insertions(+), 2 deletions(-)
diff --git a/third_data/data_server.py b/third_data/data_server.py
index 34edcdc..3a6b5a3 100644
--- a/third_data/data_server.py
+++ b/third_data/data_server.py
@@ -24,7 +24,7 @@
from urllib.parse import parse_qs
from output import code_info_output, limit_up_data_filter, output_util, kp_client_msg_manager
-from trade import bidding_money_manager, trade_manager, l2_trade_util
+from trade import bidding_money_manager, trade_manager, l2_trade_util, trade_record_log_util
from trade.l2_trade_util import BlackListCodeManager
import concurrent.futures
@@ -326,9 +326,42 @@
ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
code = ps_dict['code']
trade_progress, is_default = transaction_progress.TradeBuyQueue().get_traded_index(code)
- datas = data_export_util.get_l2_datas(code)
response_data = json.dumps(
{"code": 0, "data": {"trade_progress": trade_progress, "is_default": is_default}})
+ elif url.path == "/get_l_cancel_datas":
+ # 鏈�鏂扮殑l鎾ゆ暟鎹�
+ ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
+ code = ps_dict['code']
+ records = code_info_output.load_trade_record_cancel_watch_indexes(code)
+ # 鑾峰彇鏈�鏂扮殑L涓婁笌L涓�
+ records.reverse()
+ up_indexes = []
+ down_indexes = []
+ for r in records:
+ if r[0] == trade_record_log_util.CancelWatchIndexesInfo.CANCEL_TYPE_L_UP:
+ up_indexes = r[2]
+ break
+ for r in records:
+ if r[0] == trade_record_log_util.CancelWatchIndexesInfo.CANCEL_TYPE_L_DOWN:
+ down_indexes = r[2]
+ break
+
+ response_data = json.dumps(
+ {"code": 0, "data": {"up": up_indexes, "down": down_indexes}})
+ elif url.path == "/get_h_cancel_datas":
+ # 鏈�鏂扮殑H鎾ゆ暟鎹�
+ ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
+ code = ps_dict['code']
+ records = code_info_output.load_trade_record_cancel_watch_indexes(code,
+ trade_record_log_util.CancelWatchIndexesInfo.CANCEL_TYPE_H)
+ # 鑾峰彇鏈�鏂扮殑L涓婁笌L涓�
+ records.reverse()
+ indexes = []
+ for r in records:
+ indexes = r[2]
+ break
+ response_data = json.dumps(
+ {"code": 0, "data":indexes})
elif url.path == "/kpl/get_limit_up_list":
response_data = self.__get_limit_up_list()
--
Gitblit v1.8.0