From b8eff41fef7b4ee2c20a4d268ac83a4f420f34b0 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 21 十一月 2024 14:26:13 +0800
Subject: [PATCH] 测试日志
---
utils/kpl_data_db_util.py | 27 +++++++++++++++++++++++++--
1 files changed, 25 insertions(+), 2 deletions(-)
diff --git a/utils/kpl_data_db_util.py b/utils/kpl_data_db_util.py
index 5107280..4b7f077 100644
--- a/utils/kpl_data_db_util.py
+++ b/utils/kpl_data_db_util.py
@@ -1,19 +1,42 @@
from db.mysql_data_delegate import Mysqldb
+from third_data.history_k_data_util import HistoryKDatasUtils
from utils import tool
class KPLLimitUpDataUtil:
@classmethod
- def get_latest_block_infos(cls, min_day=tool.date_sub(tool.get_now_date_str(), 180), code=None):
+ def get_latest_block_infos(cls, min_day=tool.date_sub(tool.get_now_date_str(), 180), code=None,
+ max_day=tool.get_now_date_str()):
"""
@param min_day: 榛樿鑾峰彇180澶╀箣鍓嶇殑
@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}'"
+ 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}'"
+
if code:
sql += f" AND _code='{code}'"
sql += " order by _create_time"
mysqldb = Mysqldb()
results = mysqldb.select_all(sql)
return results
+
+
+if __name__ == '__main__':
+ # 鍒犻櫎涓嶆槸浜ゆ槗鏃ユ湡鐨勬暟鎹�
+ days = HistoryKDatasUtils.get_latest_trading_date(300)
+ for day in days:
+ pass
+ print(days)
+ mysqldb = Mysqldb()
+ results = mysqldb.select_all(f"SELECT _id, _day from kpl_limit_up_record r where r._day>='{days[-1]}'")
+ ids = []
+ for result in results:
+ if result[1] not in days:
+ ids.append(result[0])
+ # print("鍒犻櫎锛�", result)
+ if len(ids) > 10:
+ sql = f"delete from kpl_limit_up_record where " + ' or '.join([f"_id='{x}'" for x in ids])
+ mysqldb.execute(sql)
+ ids.clear()
+ pass
--
Gitblit v1.8.0