From 13e767c21d76d6f08f598e886e2013e5dfd33789 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期四, 21 八月 2025 15:49:50 +0800
Subject: [PATCH] 将积累好的过滤文件写入本地存储

---
 strategy/check_timer.py |   19 ++++++++++++++-----
 1 files changed, 14 insertions(+), 5 deletions(-)

diff --git a/strategy/check_timer.py b/strategy/check_timer.py
index 1e86d46..7f6a792 100644
--- a/strategy/check_timer.py
+++ b/strategy/check_timer.py
@@ -27,7 +27,15 @@
             # 澹版槑璧嬪�煎疄鏃舵椂闂�
             now_time = tool.get_now_time_str()
             # print(f"now_time==={now_time}")
-            if now_time > data_cache.AFTER_CLOSING_TIME and data_cache.execution is False:
+
+            # 鍗堢洏鍐崇瓥缁撴潫鏃堕棿 瀹氭椂鎵ц
+            if data_cache.NOON_MARKET_TIME < now_time and data_cache.moon_market_time_over is False:
+                plate_strength_analysis.write_filtered_file_local_storage()
+                logger.info(f"灏嗙Н绱ソ鐨勮繃婊ゆ枃浠跺啓鍏ユ湰鍦板瓨鍌� 宸茬粡杩愯瀹屾垚")
+                data_cache.moon_market_time_over = True
+
+            # 澶х洏鏀剁洏鏃堕棿 瀹氭椂鎵ц
+            if data_cache.AFTER_CLOSING_TIME < now_time and data_cache.after_closing_time_over is False:
                 # 鏁寸悊褰撴棩娑ㄥ仠淇℃伅骞跺啓鍏ユ湰鍦扮鐞嗗ソ鏈湴鏁版嵁
                 plate_strength_analysis.get_arrange_limit_up_info()
                 logger.info(f"鏁寸悊褰撴棩娑ㄥ仠淇℃伅 宸茬粡杩愯瀹屾垚")
@@ -41,14 +49,15 @@
                 plate_strength_analysis.check_intensity_missing_limit_up_stock()
                 logger.info(f"妫�鏌ュ洜寮哄害涓殑杩囨护鍥犵礌鑰岃閿欒繃鐨勬定鍋� 宸茬粡杩愯瀹屾垚")
                 # 瀹屾垚浜嗗悗灏嗘槸鍚︽墽琛岀殑寮�涓爣璁颁负鐪�
-                data_cache.execution = True
-            # 鏈湴鏁版嵁鏇存柊鏃堕棿
-            if data_cache.UPDATE_DATA_TIME < now_time and data_cache.index_K_line_write_execution is False:
+                data_cache.after_closing_time_over = True
+
+            # 鏈湴鏁版嵁鏇存柊鏃堕棿 瀹氭椂鎵ц
+            if data_cache.UPDATE_DATA_TIME < now_time and data_cache.update_data_time_over is False:
                 # 鍐欏叆鎵�鏈夋寚鏁癒绾�
                 market_sentiment_analysis.all_index_k_line_dict_write()
                 logger.info(f"鍐欏叆鎵�鏈夊甫灞炴�ф寚鏁癒绾� 宸茬粡杩愯瀹屾垚")
                 # 瀹屾垚浜嗗悗灏嗘槸鍚︽墽琛岀殑寮�涓爣璁颁负鐪�
-                data_cache.index_K_line_write_execution = True
+                data_cache.update_data_time_over = True
         except Exception as error:
             logger.error(f"瀹炴椂妫�娴嬪畾鏃跺櫒绾跨▼鎶ラ敊: {error}")
         finally:

--
Gitblit v1.8.0