From 994079acd0ac30a32e2b0391881890be16b0afc0 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 17 六月 2025 11:01:13 +0800
Subject: [PATCH] ‘功能完善

---
 strategy/strategy_variable_factory.py |   40 +++++++++++++++++++++++++++++++++++++---
 1 files changed, 37 insertions(+), 3 deletions(-)

diff --git a/strategy/strategy_variable_factory.py b/strategy/strategy_variable_factory.py
index 97b9e28..c79673b 100644
--- a/strategy/strategy_variable_factory.py
+++ b/strategy/strategy_variable_factory.py
@@ -7,7 +7,7 @@
 import re
 
 import constant
-from code_attribute import global_data_loader
+from code_attribute import global_data_loader, gpcode_manager
 from db import mysql_data_delegate
 from strategy.data_analyzer import KTickLineAnalyzer, KPLLimitUpDataAnalyzer, K60SLineAnalyzer
 from strategy.strategy_variable import StockVariables
@@ -235,7 +235,7 @@
                 results = [x for x in results if
                            (tool.is_can_buy_code(x[0]) and x[0] in valid_codes and x[0] not in exclude_codes)]
                 # 鍙栧墠1/3涓旀定鍋滄暟鏄墠10
-                max_count = len(results) // 2 if len(results) % 2 == 0 else len(results) // 2 + 1
+                max_count = len(results) // 3 if len(results) % 3 == 0 else len(results) // 3 + 1
                 results = results[:max_count]
                 # 鍙栧墠10
                 results = results[:10]
@@ -636,7 +636,41 @@
             print(code, code_blocks[code])
 
 
+def __load_target_codes_v1():
+    """
+    50浜夸互涓嬬殑
+    @return:
+    """
+
+    def get_zylt(code):
+        zylt_volume_map = global_util.zylt_volume_map
+        last_trade_day = __DataLoader.trade_days[0]
+        volume = zylt_volume_map.get(code)
+        # 浠婃棩娑ㄥ仠浠疯绐佺牬鏄ㄦ棩鏈�楂樹环
+        k_bars = HistoryKDataManager().get_history_bars(code, last_trade_day)
+        return k_bars[0]["close"] * volume * tool.get_limit_up_rate(code)
+
+    __DataLoader = DataLoader('2025-06-13')
+    global_data_loader.load_zyltgb_volume_from_db()
+    results = __DataLoader.load_target_plate_and_codes()
+    # for k in results:
+    #     print(k, results[k])
+    plates = ["澶╃劧姘�", "鍐涘伐"]
+    print("==========鏂伴鏉�=======")
+    for p in plates:
+        codes = [x for x in results.get(p) ] # if get_zylt(x) < 31e8
+        print("======", p)
+        for code in codes:
+            print("\t\t", code, gpcode_manager.CodesNameManager().get_code_name(code))
+
+
+
+
+
 if __name__ == "__main__":
+
+    __load_target_codes_v1()
+
     __DataLoader = DataLoader("2025-06-12")
     # __test_jx_blocks(__DataLoader)
 
@@ -655,7 +689,7 @@
     results = __DataLoader.load_target_plate_and_codes()
     # for k in results:
     #     print(k, results[k])
-    plates = ["姹借溅闆堕儴浠�", "绋�鍦熸案纾�", "鍖栧伐", "鍖昏嵂", "鍏変紡"]
+    plates = ["姹借溅闆堕儴浠�", "鏂囧寲浼犲獟", "璋峰瓙缁忔祹"]
     print("==========鏂伴鏉�=======")
     for p in plates:
         print(p, results.get(p))

--
Gitblit v1.8.0