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