From c8b740733f0f9fcf438fc4606eea317011ebd8bd Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 28 四月 2023 16:42:47 +0800
Subject: [PATCH] 看盘页面及相关接口修改
---
third_data/data_server.py | 21 +++++++++++++++++----
1 files changed, 17 insertions(+), 4 deletions(-)
diff --git a/third_data/data_server.py b/third_data/data_server.py
index 6e1d7f8..e8665f2 100644
--- a/third_data/data_server.py
+++ b/third_data/data_server.py
@@ -22,11 +22,24 @@
def do_GET(self):
path = self.path
+ url = urlparse.urlparse(path)
+ response_data = ""
+ if url.path == "/get_kpl_data":
+ best_feng_kou = self.__kplDataManager.get_data(kpl_util.KPLDataType.BEST_FENG_KOU)
+ best_feng_kou=best_feng_kou[:22]
+ feng_kou = self.__kplDataManager.get_data(kpl_util.KPLDataType.FENG_KOU)
+ feng_kou = feng_kou[:22]
+ industry_rank = self.__kplDataManager.get_data(kpl_util.KPLDataType.INDUSTRY_RANK)
+ industry_rank = industry_rank[:22]
+ feng_xiang = self.__kplDataManager.get_data(kpl_util.KPLDataType.FENG_XIANG)
+ feng_xiang = feng_xiang[:22]
+ response_data = json.dumps({"code": 0, "data": {"best_feng_kou": best_feng_kou, "feng_kou": feng_kou,
+ "industry_rank": industry_rank, "feng_xiang": feng_xiang}})
self.send_response(200)
# 鍙戠粰璇锋眰瀹㈡埛绔殑鍝嶅簲鏁版嵁
self.send_header('Content-type', 'application/json')
self.end_headers()
- self.wfile.write("".encode())
+ self.wfile.write(response_data.encode())
def do_POST(self):
path = self.path
@@ -39,7 +52,7 @@
def __process_kpl_data(self, data):
type_ = data["type"]
- print("寮�鐩樺暒type:",type_)
+ print("寮�鐩樺暒type:", type_)
if type_ == KPLDataType.BIDDING.value:
result_list = kpl_util.parseDaBanData(data["data"], kpl_util.DABAN_TYPE_LIMIT_UP)
# 绔炰环鍙栧墠20
@@ -49,7 +62,7 @@
result_list = result_list[:20]
bs = []
for d in result_list:
- bs.append((d[0], f"{d[2] // 10000 }涓�"))
+ bs.append((d[0], f"{d[2] // 10000}涓�"))
bidding_money_manager.set_bidding_money(bs[:10])
self.__kplDataManager.save_data(type_, result_list)
@@ -63,7 +76,7 @@
limit_up_time = time.strftime("%H:%M:%S", time.localtime(d[2]))
code_price_manager.Buy1PriceManager.set_limit_up_time(code, limit_up_time)
self.__kplDataManager.save_data(type_, result_list)
- kpl_data_manager.KPLLimitUpDataRecordManager.save_record(tool.get_now_date_str(),result_list)
+ kpl_data_manager.KPLLimitUpDataRecordManager.save_record(tool.get_now_date_str(), result_list)
elif type_ == KPLDataType.OPEN_LIMIT_UP.value:
result_list = kpl_util.parseDaBanData(data["data"], kpl_util.DABAN_TYPE_OPEN_LIMIT_UP)
if result_list:
--
Gitblit v1.8.0