From bf0c5badfe9c0efe7340af7d0a6356461d9ea961 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期一, 14 四月 2025 15:31:50 +0800
Subject: [PATCH] 真实交易环境准备
---
main.py | 20 +++++++++++++++++---
1 files changed, 17 insertions(+), 3 deletions(-)
diff --git a/main.py b/main.py
index 9cf3c57..4543a16 100644
--- a/main.py
+++ b/main.py
@@ -1,6 +1,7 @@
# coding=utf-8
from __future__ import print_function, absolute_import, unicode_literals
import logging
+import multiprocessing
import threading
import time
@@ -19,7 +20,7 @@
from strategy import kpl_api, data_cache, check_timer, all_K_line, instant_time_market, account_management, \
order_methods, local_data_management, kpl_data_manager, market_sentiment_analysis, plate_strength_analysis, \
selling_strategy
-from huaxin_client import l2_market_client, l2_client
+from huaxin_client import l2_market_client, l2_client, trade_client
from log_module import async_log_util, log
from trade import huaxin_trade_data_update, huaxin_trade_api
from utils import hx_qc_value_util, huaxin_util, juejin_api, tool
@@ -111,7 +112,8 @@
# 寮�鍚紑鐩樺暒 娑ㄥ仠鍒楄〃 鍜� 鍏ㄧ洏涓偂姒傚康鏉垮潡 鎺ュ彛绾跨▼
# 娑ㄥ仠姒傚康绾跨▼
# threading.Thread(target=plate_strength_analysis.kpl_limit_up_process, daemon=True).start() #璇ヨ浠ｇ爜涓哄彧杩愯鍗曚竴绾跨▼涓嶅洖璋冩暟鎹殑鏂瑰紡
- threading.Thread(target=plate_strength_analysis.kpl_limit_up_process, args=(kpl_limit_up_process,), daemon=True).start()
+ threading.Thread(target=plate_strength_analysis.kpl_limit_up_process, args=(kpl_limit_up_process,),
+ daemon=True).start()
# # 寮�鐩樺暒鐨勬澘鍧楀己搴︿笅鐨勪釜鑲″己搴﹀洖璋冨嚱鏁�
def get_market_sift_plate_its_stock_power_process(market_sift_plate_stock_dict):
@@ -201,6 +203,7 @@
l2_data_callbacks = []
+
# 璁㈤槄鎸佷粨L2鏁版嵁
def __subscript_position_l2():
"""
@@ -227,6 +230,8 @@
# 绗笁姝ワ細鎵ц绛栫暐鐨勫垵濮嬭缃�
if __name__ == '__main__':
log.close_print()
+
+
class MyMarketDataCallback(l2_market_client.L2MarketDataCallback):
def on_markets(self, datas):
"""
@@ -250,8 +255,17 @@
# redis 鏁版嵁鍚屾
threading.Thread(target=RedisUtils.run_loop, daemon=True).start()
+ # 绛栫暐涓庝氦鏄撻�氫俊闃熷垪
+ queue_strategy_r_trade_w, queue_strategy_w_trade_r, queue_strategy_w_trade_for_query_r = multiprocessing.Queue(), multiprocessing.Queue(), multiprocessing.Queue()
+
+ # 涓嶆槸妯℃嫙鐩樼殑鏃跺�欏惎鍔ㄤ氦鏄�
+ if not constant.IS_SIMULATED_TRADE:
+ multiprocessing.Process(target=trade_client.run, args=(
+ queue_strategy_r_trade_w, queue_strategy_w_trade_r, queue_strategy_w_trade_for_query_r,),
+ daemon=True).start()
+
# 鍚姩浜ゆ槗
- order_methods.run()
+ order_methods.run(queue_strategy_r_trade_w, queue_strategy_w_trade_r, queue_strategy_w_trade_for_query_r)
# 杩愯鍗庨懌澧炲�兼湇鍔¤繘绋�,鐢ㄤ簬鑾峰彇K绾夸笌浜ゆ槗鏃ュ巻
threading.Thread(target=hx_qc_value_util.run, daemon=True).start()
--
Gitblit v1.8.0