From ab662be5c523b75c1bd28fc6bfcab2872b9623b3 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 12 六月 2025 15:22:06 +0800
Subject: [PATCH] bug修复
---
main.py | 23 ++++++++++++++++++++---
1 files changed, 20 insertions(+), 3 deletions(-)
diff --git a/main.py b/main.py
index ea2e387..2e20643 100644
--- a/main.py
+++ b/main.py
@@ -7,9 +7,12 @@
from api import outside_api_callback
from api.outside_api_command_manager import ApiCommandManager
+from db.redis_manager_delegate import RedisUtils
from huaxin_client import l2_market_client, trade_client
+from log_module import async_log_util
from log_module.log import logger_debug
from server import data_server
+from strategy import strategy_manager
from strategy.env_info import RealTimeEnvInfo
from third_data import hx_qc_value_util
from trade.huaxin import huaxin_trade_api
@@ -24,8 +27,11 @@
if data.get("type") == 'set_target_codes':
# [(浠ｇ爜, 鏃堕棿鎴�, 浠锋牸, 鎬讳氦鏄撻噺, 鎬讳氦鏄撻, 涔�5, 鍗�5)]
market_data_list = data["data"]["data"]
+ if strategy_manager.low_suction_strtegy:
+ strategy_manager.low_suction_strtegy.add_ticks(market_data_list)
RealTimeEnvInfo().ticks = (tool.get_now_time_str(), len(market_data_list))
- except:
+ except Exception as e:
+ logger_debug.exception(e)
time.sleep(0.1)
queue_l1_w_strategy_r: multiprocessing.Queue = multiprocessing.Queue()
@@ -47,21 +53,32 @@
if __name__ == "__main__":
+ # -------鍚姩鍗庨懌澧炲�兼湇鍔pi------
+ threading.Thread(target=hx_qc_value_util.run, daemon=True).start()
+ time.sleep(10)
# -----鍚姩data_server-----
threading.Thread(target=lambda: data_server.run("127.0.0.1", 9008), daemon=True).start()
+
+ # 鍚姩鏈湴鏃ュ織
+ threading.Thread(target=lambda: async_log_util.run_sync(), daemon=True).start()
+
+ # 鍚姩redis鍚屾
+ threading.Thread(target=lambda: RedisUtils.run_loop(), daemon=True).start()
# --------鍚姩鏈湴API鎺ュ彛----------
manager = ApiCommandManager(middle_api_protocol.SERVER_HOST, middle_api_protocol.SERVER_PORT, outside_api_callback.MyAPICallback())
manager.run(blocking=False)
- # -------鍚姩鍗庨懌澧炲�兼湇鍔pi------
- threading.Thread(target=hx_qc_value_util.run, daemon=True).start()
+
# --------鍚姩浜ゆ槗----------
huaxin_trade_api.run()
threading.Thread(target=test, daemon=True).start()
# test()
+ # 鍒濆鍖栨暟鎹�
+ strategy_manager.low_suction_strtegy = strategy_manager.LowSuctionStrategy(tool.get_now_date_str())
+
# -------鍚姩L2 market璁㈤槄------
__run_l2_market_subscript()
print("鍚姩瀹屾垚")
--
Gitblit v1.8.0