From 7a2e1ecbc31db9b91c8e502d5c0bec3240a298dd Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 07 十一月 2023 14:38:55 +0800
Subject: [PATCH] L撤/H撤接口根据买入信号位置拉取
---
third_data/data_server.py | 10 +++++++++-
1 files changed, 9 insertions(+), 1 deletions(-)
diff --git a/third_data/data_server.py b/third_data/data_server.py
index 3a6b5a3..9b08772 100644
--- a/third_data/data_server.py
+++ b/third_data/data_server.py
@@ -332,16 +332,21 @@
# 鏈�鏂扮殑l鎾ゆ暟鎹�
ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
code = ps_dict['code']
+ buy_single_index = ps_dict.get('buy_single_index')
records = code_info_output.load_trade_record_cancel_watch_indexes(code)
# 鑾峰彇鏈�鏂扮殑L涓婁笌L涓�
records.reverse()
up_indexes = []
down_indexes = []
for r in records:
+ if buy_single_index and buy_single_index != r[1]:
+ continue
if r[0] == trade_record_log_util.CancelWatchIndexesInfo.CANCEL_TYPE_L_UP:
up_indexes = r[2]
break
for r in records:
+ if buy_single_index and buy_single_index != r[1]:
+ continue
if r[0] == trade_record_log_util.CancelWatchIndexesInfo.CANCEL_TYPE_L_DOWN:
down_indexes = r[2]
break
@@ -352,16 +357,19 @@
# 鏈�鏂扮殑H鎾ゆ暟鎹�
ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
code = ps_dict['code']
+ buy_single_index = ps_dict.get('buy_single_index')
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:
+ if buy_single_index and buy_single_index != r[1]:
+ continue
indexes = r[2]
break
response_data = json.dumps(
- {"code": 0, "data":indexes})
+ {"code": 0, "data": indexes})
elif url.path == "/kpl/get_limit_up_list":
response_data = self.__get_limit_up_list()
--
Gitblit v1.8.0