From 05c1607c84af32a9cf77a9f47710db76ccbc61ec Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 20 二月 2025 18:40:08 +0800
Subject: [PATCH] 排1准备

---
 code_attribute/first_target_code_data_processor.py |   14 +++++---------
 1 files changed, 5 insertions(+), 9 deletions(-)

diff --git a/code_attribute/first_target_code_data_processor.py b/code_attribute/first_target_code_data_processor.py
index 07a773a..ac34fd9 100644
--- a/code_attribute/first_target_code_data_processor.py
+++ b/code_attribute/first_target_code_data_processor.py
@@ -42,7 +42,7 @@
 
 
 def process_first_codes_datas(dataList, request_id=None):
-    logger_l2_codes_subscript.info(f"{request_id}鍔犺浇l2浠g爜鐩稿叧鏁版嵁")
+    async_log_util.info(logger_l2_codes_subscript, f"{request_id}鍔犺浇l2浠g爜鐩稿叧鏁版嵁")
     # 鑾峰彇鏈�杩�5澶╃殑浜ゆ槗鏃ユ湡锛屼负鍚庨潰鐨勬暟鎹绠楀仛鍑嗗
     dates = HistoryKDatasUtils.get_latest_trading_date_cache(5)
     latest_trading_date = None
@@ -110,14 +110,7 @@
                     async_log_util.info(logger_l2_codes_subscript, f"{request_id}浠庣綉缁滃姞杞終绾挎暟鎹細{code}")
                 if not volumes_data:
                     continue
-                volumes = init_data_util.parse_max_volume(code, volumes_data[:90],
-                                                          code_nature_analyse.is_new_top(code,
-                                                                                         limit_up_price,
-                                                                                         volumes_data[
-                                                                                         :90]) or code_nature_analyse.is_near_top(
-                                                              code,
-                                                              limit_up_price,
-                                                              volumes_data[:90]))
+                volumes = init_data_util.parse_max_volume_new(code, volumes_data[:60])
                 max_volume_in_5_days = init_data_util.parse_max_volume_in_days(volumes_data, 5)
 
                 async_log_util.info(logger_first_code_record, f"{code} 鑾峰彇鍒伴鏉�60澶╂渶澶ч噺锛歿volumes}")
@@ -150,6 +143,9 @@
                         l2_trade_util.forbidden_trade(code, "6澶╁唴鑲′环闀垮緱澶珮")
                         continue
 
+                    if tool.is_ge_code(code) and float(limit_up_price) < 10:
+                        l2_trade_util.forbidden_trade(code, "鍒涗笟鏉胯偂浠�10鍧楀唴")
+
                     if len(k_format) > 14 and k_format[14]:
                         l2_trade_util.forbidden_trade(code, "鏄ㄦ棩鐐告澘")
                         continue

--
Gitblit v1.8.0