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_manager.py |   14 ++++++++++----
 1 files changed, 10 insertions(+), 4 deletions(-)

diff --git a/strategy/strategy_manager.py b/strategy/strategy_manager.py
index c2c8ca5..5aed98f 100644
--- a/strategy/strategy_manager.py
+++ b/strategy/strategy_manager.py
@@ -7,6 +7,8 @@
 from db import redis_manager_delegate as redis_manager
 from db.mysql_data_delegate import Mysqldb
 from db.redis_manager_delegate import RedisUtils
+from log_module import async_log_util
+from log_module.log import logger_trade
 from strategy.data_analyzer import KPLLimitUpDataAnalyzer
 from strategy.low_suction_strategy import LowSuctionOriginDataExportManager
 from strategy.strategy_params_settings import StrategyParamsSettingsManager
@@ -101,7 +103,9 @@
     """
     浣庡惛绛栫暐
     """
-    def __init__(self, day, script_name="strategy_script_v6.py", settings=StrategyParamsSettingsManager().get_settings()):
+
+    def __init__(self, day, script_name="strategy_script_v6.py",
+                 settings=StrategyParamsSettingsManager().get_settings()):
         self.now_day = day
         # 涔板ぇ鍗曪細{浠g爜:[澶у崟鏁版嵁]}
         self.big_order_buy = {}
@@ -135,7 +139,8 @@
         self.current_block_in_datas = []
 
         # 鍔犺浇绛栫暐鑴氭湰鏂囦欢
-        with open(script_name if constant.is_windows() else f'{constant.get_path_prefix()}/{script_name}', mode='r', encoding='utf-8') as f:
+        with open(script_name if constant.is_windows() else f'{constant.get_path_prefix()}/{script_name}', mode='r',
+                  encoding='utf-8') as f:
             lines = f.readlines()
             scripts = "\n".join(lines)
             # 娉ㄩ噴鎺夐噷闈㈢殑import涓庡彉閲�
@@ -225,7 +230,6 @@
         """
         if code_ in self.stock_variables_dict:
             return
-
         stock_variables = StrategyVariableFactory.create_from_history_data(
             self.kline_data.get(code_), None,
             self.limit_up_record_data.get(code_), self.data_loader.trade_days)
@@ -382,6 +386,8 @@
             # 鍒ゆ柇鏄惁鍙互涔�
             for b in compute_result[3]:
                 DealCodesManager().place_order(b, code)
+                async_log_util.info(logger_trade, f"{code}涓嬪崟锛屾澘鍧楋細{compute_result[3]}")
+
 
 # 褰撳墠鐨勪綆鍚哥瓥鐣ュ璞�
-low_suction_strtegy = None
\ No newline at end of file
+low_suction_strtegy = None

--
Gitblit v1.8.0