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/kpl_data_manager.py | 24 +++++++++++++++++++++---
1 files changed, 21 insertions(+), 3 deletions(-)
diff --git a/third_data/kpl_data_manager.py b/third_data/kpl_data_manager.py
index 04d1513..27ea980 100644
--- a/third_data/kpl_data_manager.py
+++ b/third_data/kpl_data_manager.py
@@ -100,6 +100,13 @@
mysqldb = mysql_data.Mysqldb()
return mysqldb.select_one(sql)
+ # 鑾峰彇浠ｇ爜鏈�杩戠殑鏉垮潡锛岃繑鍥瀃(鏉垮潡,鏃ユ湡)]
+ @staticmethod
+ def get_latest_infos(code, count):
+ sql = f"SELECT GROUP_CONCAT(_hot_block_name),`_day` FROM (SELECT hb.`_hot_block_name`,hb.`_day` FROM `kpl_limit_up_record` hb WHERE hb.`_code`='{code}' ORDER BY hb.`_day` DESC LIMIT 10) a GROUP BY a._day ORDER BY a._day DESC LIMIT {count}"
+ mysqldb = mysql_data.Mysqldb()
+ return mysqldb.select_all(sql)
+
class KPLDataManager:
__latest_datas = {}
@@ -110,8 +117,19 @@
with open(path, 'w') as f:
f.write(json.dumps(datas))
- def __get_from_file(self, key):
- name = f"{tool.get_now_date_str()}_{key}.log"
+ def __get_from_file(self, key, day=tool.get_now_date_str()):
+ name = f"{day}_{key}.log"
+ path = f"{constant.CACHE_PATH}/{name}"
+ if not os.path.exists(path):
+ return None
+ with open(path, 'r') as f:
+ lines = f.readlines()
+ if lines:
+ return json.loads(lines[0])
+ return None
+
+ def get_from_file(self, type, day):
+ name = f"{day}_{type.value}.log"
path = f"{constant.CACHE_PATH}/{name}"
if not os.path.exists(path):
return None
@@ -151,4 +169,4 @@
if __name__ == "__main__":
- load_history_limit_up()
+ print(KPLLimitUpDataRecordManager.get_latest_infos("000950", 4))
--
Gitblit v1.8.0