From 4905b98d221044f08c8ac8db49e86a769e574bae Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 05 六月 2024 12:42:07 +0800
Subject: [PATCH] P撤修改/买入2000以下,买所有

---
 code_attribute/first_target_code_data_processor.py |   24 +++++++++++++++++++++++-
 1 files changed, 23 insertions(+), 1 deletions(-)

diff --git a/code_attribute/first_target_code_data_processor.py b/code_attribute/first_target_code_data_processor.py
index a624b54..1d9d439 100644
--- a/code_attribute/first_target_code_data_processor.py
+++ b/code_attribute/first_target_code_data_processor.py
@@ -12,13 +12,31 @@
 from code_attribute.gpcode_manager import WantBuyCodesManager
 from log_module.log import logger_first_code_record, logger_l2_codes_subscript
 from third_data.code_plate_key_manager import CodesHisReasonAndBlocksManager
-from third_data.history_k_data_util import HistoryKDatasUtils
+from third_data.history_k_data_util import HistoryKDatasUtils, JueJinApi
 from ths import l2_code_operate
 from trade import trade_data_manager, l2_trade_util
 from settings.trade_setting import MarketSituationManager
 from utils import global_util, tool, init_data_util, buy_condition_util
 
 __CodesPlateKeysManager = CodesHisReasonAndBlocksManager()
+
+
+def __is_normal_in_5d(code):
+    """
+    鏈�杩�5澶╂槸鍚﹀浜庢甯哥姸鎬�
+    @param code:
+    @return:
+    """
+    now_day = tool.get_now_date_str()
+    results = JueJinApi.get_history_instruments(JueJinApi.get_juejin_code_list_with_prefix([code]),
+                                                tool.date_sub(now_day, 30), tool.date_sub(now_day, 1))
+    results = results[-5:]
+    normal = True
+    for r in results:
+        if r["sec_level"] != 1:
+            normal = False
+            break
+    return normal
 
 
 def process_first_codes_datas(dataList, request_id=None):
@@ -156,6 +174,10 @@
                         l2_trade_util.forbidden_trade(code, "鍥炶俯涓嶅")
                         continue
 
+                    if not __is_normal_in_5d(code):
+                        l2_trade_util.forbidden_trade(code, "鏈�杩�5澶╂湁ST/闈炴甯哥姸鎬�")
+                        continue
+
                 if code_nature_analyse.is_up_too_high_in_10d_with_limit_up(volumes_data):
                     # 鍒ゆ柇鏄惁澶珮
                     HighIncreaseCodeManager().add_code(code)

--
Gitblit v1.8.0