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