From 258d64ba21cc0c65a13a1458e713b00f30655968 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 23 十二月 2024 14:44:17 +0800
Subject: [PATCH] 代码的板块不包含历史炸板过的数据/更新开盘啦前一天的实时涨停数据
---
utils/kpl_data_db_util.py | 21 +++------------------
1 files changed, 3 insertions(+), 18 deletions(-)
diff --git a/utils/kpl_data_db_util.py b/utils/kpl_data_db_util.py
index 8508219..a112386 100644
--- a/utils/kpl_data_db_util.py
+++ b/utils/kpl_data_db_util.py
@@ -12,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}'"
@@ -29,22 +29,7 @@
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
+ datas = KPLLimitUpDataUtil.get_latest_block_infos()
+ len(datas)
--
Gitblit v1.8.0