From 6df8d9ac75a041377c01c80e6e970e5c75ce7662 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 06 六月 2025 17:33:41 +0800
Subject: [PATCH] 初始化导入
---
main.py | 59 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 59 insertions(+), 0 deletions(-)
diff --git a/main.py b/main.py
index e69de29..84a48d7 100644
--- a/main.py
+++ b/main.py
@@ -0,0 +1,59 @@
+import multiprocessing
+import threading
+import time
+
+import requests
+
+from huaxin_client import l2_market_client, trade_client
+from log_module.log import logger_debug
+from server import data_server
+from strategy.env_info import RealTimeEnvInfo
+from third_data import hx_qc_value_util
+from trade.huaxin import huaxin_trade_api
+from utils import tool
+
+
+def __run_l2_market_subscript():
+ def read_results():
+ while True:
+ try:
+ data = queue_l1_w_strategy_r.get()
+ if data.get("type") == 'set_target_codes':
+ # [(浠ｇ爜, 鏃堕棿鎴�, 浠锋牸, 鎬讳氦鏄撻噺, 鎬讳氦鏄撻, 涔�5, 鍗�5)]
+ market_data_list = data["data"]["data"]
+ RealTimeEnvInfo().ticks = (tool.get_now_time_str(), len(market_data_list))
+ except:
+ time.sleep(0.1)
+
+ queue_l1_w_strategy_r: multiprocessing.Queue = multiprocessing.Queue()
+ l2MarketProcess = multiprocessing.Process(target=l2_market_client.run,
+ args=(queue_l1_w_strategy_r,))
+ l2MarketProcess.start()
+ read_results()
+
+
+def test():
+ time.sleep(10)
+ result = huaxin_trade_api.get_money(blocking=True)
+ logger_debug.info(f"娴嬭瘯浜ゆ槗璐︽埛鑾峰彇锛歿result}")
+ # 鍙戦�佷俊鎭�
+ requests.post("http://127.0.0.1:9008/upload_big_order_datas", [(1, 2, 3, 4, 5)])
+ # 鑾峰彇澧炲�兼湇鍔PI
+ result = hx_qc_value_util.get_next_trading_date("2025-06-06")
+ logger_debug.info(f"娴嬭瘯鑾峰彇涓嬩竴涓氦鏄撴棩锛歿result}")
+
+
+if __name__ == "__main__":
+ # -----鍚姩data_server-----
+ threading.Thread(target=lambda: data_server.run("127.0.0.1", 9008), daemon=True).start()
+ # -------鍚姩鍗庨懌澧炲�兼湇鍔pi------
+ threading.Thread(target=hx_qc_value_util.run, daemon=True).start()
+ # --------鍚姩浜ゆ槗----------
+ huaxin_trade_api.run()
+
+ threading.Thread(target=test, daemon=True).start()
+ test()
+
+ # -------鍚姩L2 market璁㈤槄------
+ __run_l2_market_subscript()
+ print("鍚姩瀹屾垚")
--
Gitblit v1.8.0