From c5894abdb8d222f7ff73e44e7e4df58ec9c4872c Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 23 一月 2025 17:03:14 +0800
Subject: [PATCH] 订阅修改
---
utils/kpl_data_db_util.py | 16 +++++++++++++++-
1 files changed, 15 insertions(+), 1 deletions(-)
diff --git a/utils/kpl_data_db_util.py b/utils/kpl_data_db_util.py
index e1fe2fe..a112386 100644
--- a/utils/kpl_data_db_util.py
+++ b/utils/kpl_data_db_util.py
@@ -1,4 +1,5 @@
from db.mysql_data_delegate import Mysqldb
+from third_data.history_k_data_util import HistoryKDatasUtils
from utils import tool
@@ -11,7 +12,7 @@
@param code: 浠ｇ爜
@return: 鏈�杩戠殑娑ㄥ仠鏉垮潡淇℃伅
"""
- sql = f"SELECT r.`_code`, r.`_day`, r.`_hot_block_name`, r.`_blocks` FROM `kpl_limit_up_record` r WHERE r.`_day`>'{min_day}' and r.`_day` <'{max_day}'"
+ sql = f"SELECT r.`_code`, r.`_day`, r.`_hot_block_name`, r.`_blocks`, r.`_open` FROM `kpl_limit_up_record` r WHERE r.`_day`>='{min_day}' and r.`_day` <'{max_day}'"
if code:
sql += f" AND _code='{code}'"
@@ -19,3 +20,16 @@
mysqldb = Mysqldb()
results = mysqldb.select_all(sql)
return results
+
+ @classmethod
+ def get_latest_block_infos_by_day(cls, day=tool.get_now_date_str()):
+ sql = f"SELECT * FROM `kpl_limit_up_record` r WHERE r.`_day`='{day}'"
+ mysqldb = Mysqldb()
+ results = mysqldb.select_all(sql)
+ return results
+
+
+if __name__ == '__main__':
+ # 鍒犻櫎涓嶆槸浜ゆ槗鏃ユ湡鐨勬暟鎹�
+ datas = KPLLimitUpDataUtil.get_latest_block_infos()
+ len(datas)
--
Gitblit v1.8.0