From 2f00a0565dcf8d652b8bb5c4caefbce1c2c92d62 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 23 六月 2025 09:58:15 +0800
Subject: [PATCH] bug修复/策略完善
---
main.py | 16 +++++++++++-----
1 files changed, 11 insertions(+), 5 deletions(-)
diff --git a/main.py b/main.py
index 1e5b704..059d0fb 100644
--- a/main.py
+++ b/main.py
@@ -1,5 +1,6 @@
import json
import multiprocessing
+import pickle
import threading
import time
@@ -11,7 +12,7 @@
from db.redis_manager_delegate import RedisUtils
from huaxin_client import l2_market_client, trade_client, l1_subscript_codes_manager
from log_module import async_log_util
-from log_module.log import logger_debug
+from log_module.log import logger_debug, logger_system
from server import data_server
from strategy import strategy_manager
from strategy.env_info import RealTimeEnvInfo
@@ -26,6 +27,7 @@
while True:
try:
data = queue_l1_w_strategy_r.get()
+ data = pickle.loads(data)
if data.get("type") == 'set_target_codes':
# [(浠ｇ爜, 鏃堕棿鎴�, 浠锋牸, 鎬讳氦鏄撻噺, 鎬讳氦鏄撻, 涔�5, 鍗�5)]
market_data_list = data["data"]["data"]
@@ -106,12 +108,16 @@
# ----鍒濆鍖�------------
__init()
-
# 鍒濆鍖栨暟鎹�
strategy_manager.low_suction_strtegy = strategy_manager.LowSuctionStrategy(tool.get_now_date_str())
-
-
+ logger_system.info("鍒濆鍖栫瓥鐣ュ璞℃垚鍔�")
+ try:
+ strategy_manager.low_suction_strtegy.load_data()
+ logger_system.info("鍔犺浇绛栫暐鏁版嵁鎴愬姛")
+ except Exception as e:
+ logger_system.error(f"鍔犺浇绛栫暐鏁版嵁澶辫触锛歿str(e)}")
+ logger_system.exception(e)
# -------鍚姩L2 market璁㈤槄------
__run_l2_market_subscript()
- print("鍚姩瀹屾垚")
+ logger_system.info("绯荤粺缁撴潫")
--
Gitblit v1.8.0