From 1dea3d72da9d3d2d55f2e41b611913b0901d8074 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期二, 17 六月 2025 19:15:19 +0800
Subject: [PATCH] 增加测试/记录精选流入板块
---
strategy/buying_strategy.py | 38 ++++++++++++++++++++++++++++++++------
1 files changed, 32 insertions(+), 6 deletions(-)
diff --git a/strategy/buying_strategy.py b/strategy/buying_strategy.py
index 991e972..08d6fe2 100644
--- a/strategy/buying_strategy.py
+++ b/strategy/buying_strategy.py
@@ -8,6 +8,8 @@
# from datetime import time
# from datetime import timedelta
import time
+
+import constant
import utils.tool
from log_module import async_log_util
from log_module.log import logger_kpl_jingxuan_in, logger_common
@@ -18,6 +20,7 @@
from strategy import basic_methods
from strategy import account_management
from strategy import order_methods
+from strategy.forbidden_plates_manager import ForbiddenPlatesManager
from strategy.order_methods import TodayBuyCodeManager
from utils import tool, huaxin_util
@@ -218,10 +221,8 @@
# print(f"娌℃湁鍦ㄦ蹇电紦瀛樺垪琛ㄤ腑鎵惧埌:{symbol_to_search}銆�")
# 澹版槑瑕佹鏌ヨ繃婊や笉鍙敤鐨勬蹇垫澘鍧楀悕绉板父閲� 銆愪唬琛ㄧ潃 鏄惁鏈夋棤姒傚康鍙婅窡闅忔蹇电殑鍙兘鎬�(鏈夋槑鏄句釜鑲＄嫭鐗瑰闀跨壒鎬х殑涓嶅彲璺熼殢锛屽洜涓烘蹇垫湰韬槸瀹芥硾鐨勶紝璁稿涓嶅悓姒傚康鐨勪釜鑲￠兘鏈夎繖涓蹇�)銆�
- check_plate_list = {'鏃�', 'ST鎽樺附', 'ST鏉垮潡', '瓒呰穼', '娆℃柊鑲�', '鍖椾氦鎵�', '绉戝垱鏉�',
- '骞存姤澧為暱', '骞存姤棰勫', '骞惰喘閲嶇粍', '鑲℃潈杞', '閫佽浆濉潈', '楂橀�佽浆', '澹宠祫婧�',
- '璧勪骇绠＄悊', '涓剧墝',
- '涓撶敤璁惧', '鍒涙姇'}
+ # check_plate_list = constant.check_plate_list | set(ForbiddenPlatesManager().list_plates())
+ check_plate_list = constant.check_plate_list
# 鏌ヨ褰撳墠涓偂鐨勪唬鐮佹槸鍚﹀湪鏉垮潡寮哄害涓偂鍒楄〃涓紙浣庡惛浼橀�夌洰鏍囷級
strength_list_have_it = False # 鏄惁鏈夊己搴﹁祴鍒濆��
@@ -429,6 +430,7 @@
data_cache.bought_plate.extend(limit_up_plate_included_list)
logger_info(
f"銆恵k_line_data[0]['sec_name']}銆戜氦鏄撴垚鍔燂紒鎸佷粨闆嗗悎锛歿data_cache.position_symbols_set}")
+ # 浼犵粰GUI鏄剧ず
purchased_stock_details = {
"name": k_line_data[0]['sec_name'],
"policy_name": "鏈夋蹇垫湁寮哄害绛栫暐鍒嗘敮",
@@ -548,11 +550,23 @@
data_cache.bought_plate.extend(limit_up_plate_included_list)
logger_info(
f"銆恵k_line_data[0]['sec_name']}銆戜氦鏄撴垚鍔燂紒鎸佷粨闆嗗悎锛歿data_cache.position_symbols_set}")
+ # 浼犵粰GUI鏄剧ず
+ purchased_stock_details = {
+ "name": k_line_data[0]['sec_name'],
+ "policy_name": "鏈夋蹇垫棤寮哄害绛栫暐鍒嗘敮",
+ "plate_name": limit_up_plate_included,
+ "buy_time_trading_volume_ratio": (
+ current_volume / k_line_data[0]['volume']),
+ }
+ data_cache.purchased_stocks_details_list.append(purchased_stock_details)
+ logger_info(
+ f"宸叉垚浜よ偂绁ㄨ鎯呭垪琛細{data_cache.purchased_stocks_details_list} ")
'''
鏃犳蹇� 鏈夊己搴﹁鐣�
'''
- if len(limit_up_plate_included) == 0:
- # logger_info(f"銆愭棤姒傚康銆�")
+ if len(limit_up_plate_included) == 0 or limit_up_plate_included.issubset(
+ check_plate_list) is True:
+ # logger_info(f"銆愭棤姒傚康 鎴� 姒傚康鍦ㄥ睆钄芥蹇电粍涓��")
if strength_list_have_it is True:
logger_info(
f"銆恵k_line_data[0]['sec_name']}銆�--------------------------------------------------------------------------------------------------------[鏈夊己搴﹁鐣宂")
@@ -661,6 +675,18 @@
data_cache.bought_plate.extend(strength_plate)
logger_info(
f"銆恵k_line_data[0]['sec_name']}銆戜氦鏄撴垚鍔燂紒鎸佷粨闆嗗悎锛歿data_cache.position_symbols_set}")
+ # 浼犵粰GUI鏄剧ず
+ purchased_stock_details = {
+ "name": k_line_data[0]['sec_name'],
+ "policy_name": "鏃犳蹇垫湁寮哄害绛栫暐鍒嗘敮",
+ "plate_name": strength_plate,
+ "buy_time_trading_volume_ratio": (
+ current_volume / k_line_data[0]['volume']),
+ }
+ data_cache.purchased_stocks_details_list.append(
+ purchased_stock_details)
+ logger_info(
+ f"宸叉垚浜よ偂绁ㄨ鎯呭垪琛細{data_cache.purchased_stocks_details_list} ")
'''
鏃犳蹇垫棤寮哄害 鏈夊皬閲忔崲澶ф定骞呭害瑙嗙晫
'''
--
Gitblit v1.8.0