From 258d64ba21cc0c65a13a1458e713b00f30655968 Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期一, 23 十二月 2024 14:44:17 +0800 Subject: [PATCH] 代码的板块不包含历史炸板过的数据/更新开盘啦前一天的实时涨停数据 --- third_data/kpl_data_manager.py | 14 ++++++++++++-- 1 files changed, 12 insertions(+), 2 deletions(-) diff --git a/third_data/kpl_data_manager.py b/third_data/kpl_data_manager.py index 71b91c3..09b95c7 100644 --- a/third_data/kpl_data_manager.py +++ b/third_data/kpl_data_manager.py @@ -72,7 +72,13 @@ pass @classmethod - def save_record(cls, day, records): + def save_record(cls, day, records, set_not_open=False): + """ + @param day: + @param records: + @param set_not_open: 鏄惁闇�瑕佽缃偢鏉夸笌鍚� + @return: + """ # 缁熻鐐告澘 try: last_codes = set() @@ -149,6 +155,10 @@ mysqldb.execute( f"update kpl_limit_up_record set _latest_limit_up_time='{d[3]}',_limit_up_time='{d[2]}',_hot_block_code_count={d[10]},_limit_up_high_info='{d[4]}' ,_update_time=now() where _id='{_id}'") cls.latest_datas[_id] = d + if set_not_open: + # 闇�瑕佽缃笉鐐告澘 + mysqldb.execute(f"update kpl_limit_up_record set _open = 0, _update_time = now() where _id='{_id}'") + cls.latest_datas[_id] = d # 鑾峰彇鍘熸潵鐨勪唬鐮佹墍灞炴澘鍧�,鍒犻櫎涔嬪墠閿欒鐨勬澘鍧� @@ -367,7 +377,7 @@ if lines: if int(file[0].replace("-", "")) <= int(max_day.replace("-", "")): fresults.append((file[0], json.loads(lines[0]))) - if len(fresults) >=count: + if len(fresults) >= count: break return fresults -- Gitblit v1.8.0