From 122def357140a4a504710a57fe2bc1a8020aa7b1 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 27 二月 2024 17:57:39 +0800
Subject: [PATCH] 新版L2数据传输协议测试
---
third_data/data_server.py | 12 ++++++++++--
1 files changed, 10 insertions(+), 2 deletions(-)
diff --git a/third_data/data_server.py b/third_data/data_server.py
index d9a5de6..dec747d 100644
--- a/third_data/data_server.py
+++ b/third_data/data_server.py
@@ -320,7 +320,13 @@
logging.exception(e)
# 鑾峰彇璇勫垎淇℃伅
- pass
+ elif url.path == "/get_l2_cant_buy_reasons":
+ # 鑾峰彇L2娌′拱鐨勫師鍥�
+ ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
+ code = ps_dict['code']
+ fdatas = log_export.get_l2_cant_buy_reasons(code)
+ response_data = json.dumps({"code": 0, "data": fdatas})
+
elif url.path == "/get_kpl_block_info":
start_time = time.time()
ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
@@ -338,7 +344,7 @@
# 鑾峰彇L2鐨勬暟鎹�
ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
code = ps_dict['code']
- datas = data_export_util.get_l2_datas(code)
+ datas = data_export_util.get_l2_datas(code, l2_data_util.local_today_datas.get(code))
code_name = gpcode_manager.get_code_name(code)
response_data = json.dumps({"code": 0, "data": {"code": code, "code_name": code_name, "data": datas}})
except Exception as e:
@@ -528,6 +534,7 @@
response_data = json.dumps({"code": 1, "msg": "璇蜂笂浼燾ode"})
elif url.path == "/get_last_trade_day_reasons":
+
# 璁＄畻骞冲潎娑ㄥ箙
def get_limit_rate_list(codes):
if not codes:
@@ -549,6 +556,7 @@
return [(c_, self.__code_limit_rate_dict[c_][0]) for c_ in codes]
try:
+ raise Exception("鎺ュ彛鏆傚仠浣跨敤")
# 鑾峰彇涓婁釜浜ゆ槗鏃ョ殑鐩稿悓娑ㄥ仠鍘熷洜鐨勪唬鐮佷俊鎭�
ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
code = ps_dict["code"]
--
Gitblit v1.8.0