From 3da5d1ef00cf7665c2d37f837e6845c92d22e31c Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 15 十二月 2023 16:02:08 +0800
Subject: [PATCH] 前日炸板策略修改

---
 third_data/kpl_data_manager.py |   15 ++++++++++-----
 1 files changed, 10 insertions(+), 5 deletions(-)

diff --git a/third_data/kpl_data_manager.py b/third_data/kpl_data_manager.py
index 7f24b2f..1d5e713 100644
--- a/third_data/kpl_data_manager.py
+++ b/third_data/kpl_data_manager.py
@@ -342,9 +342,14 @@
 
 
 def get_yesterday_limit_up_codes():
-    yesterday_limit_up_data_records = get_current_limit_up_data_records(1)[0][1]
+    yesterday_limit_up_data_records = get_yesterday_current_limit_up_records()
     yesterday_codes = set([x[0] for x in yesterday_limit_up_data_records])
     return yesterday_codes
+
+
+def get_yesterday_current_limit_up_records():
+    yesterday_limit_up_data_records = get_current_limit_up_data_records(1)[0][1]
+    return yesterday_limit_up_data_records
 
 
 # 杩愯鎷夊彇浠诲姟
@@ -364,11 +369,11 @@
                     results = kpl_api.getLimitUpInfo()
                     result = json.loads(results)
                     start_time = time.time()
-                    if start_time - last_time >= 60:
-                        last_time = start_time
-                        # 璁板綍娑ㄥ仠鏁版嵁
-                        async_log_util.info(logger_kpl_limit_up, result)
                     __upload_data("limit_up", result)
+                    if start_time - last_time >= 60:
+                        last_time = time.time()
+                        # 璁板綍娑ㄥ仠鏁版嵁
+                        logger_kpl_limit_up.info(result)
                     # logger_kpl_limit_up_reason_change.info("涓婁紶鑰楁椂锛歿}", time.time() - start_time)
                 except Exception as e:
                     logging.exception(e)

--
Gitblit v1.8.0