From 806e1c7b2296bf615faeddb5a78512ef61b52389 Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期五, 22 八月 2025 18:20:21 +0800 Subject: [PATCH] 测试资金明细 --- main.py | 15 +++++++++++++-- 1 files changed, 13 insertions(+), 2 deletions(-) diff --git a/main.py b/main.py index e3bac57..fe2d118 100644 --- a/main.py +++ b/main.py @@ -2,6 +2,7 @@ GUI绠$悊 """ import math +import time import psutil @@ -18,6 +19,7 @@ from task import task_manager from third_data import hx_qc_value_util from third_data.code_plate_key_manager import KPLPlateForbiddenManager +from trade.huaxin import huaxin_trade_api from utils import shared_memery_util logger_system.info("绋嬪簭鍚姩Pre锛歿}", os.getpid()) @@ -117,10 +119,11 @@ sub_single_queue_list.append(sub_single_queue) data_callback_queue_list.append(data_callback_queue) l2_process = multiprocessing.Process(target=l2_client_v2.run, - args=(sub_single_queue, data_callback_queue, channels, i, )) + args=(sub_single_queue, data_callback_queue, channels, i,)) l2_process.start() - l2_subscript_manager.process_manager = l2_subscript_manager.TargetCodeProcessManager(sub_single_queue_list, channel_count_list) + l2_subscript_manager.process_manager = l2_subscript_manager.TargetCodeProcessManager(sub_single_queue_list, + channel_count_list) # 鐩戝惉L2甯傚満琛屾儏鏁版嵁 huaxin_trade_server.run_l2_market_info_reciever(data_callback_queue_list) # 鍚姩ZMQserver锛岄拡瀵瑰鎵橀槦鍒椾笌鎴愪氦闃熷垪杩涜鐩戝惉 @@ -189,6 +192,14 @@ # 杩愯鍗庨懌澧炲�兼湇鍔¤繘绋� threading.Thread(target=hx_qc_value_util.run, daemon=True).start() + + def test(): + time.sleep(180) + huaxin_trade_api.query_order_found_detail("603716", "110010190007896") + + + threading.Thread(target=test, daemon=True).start() + # 缁戞牳杩愯 # psutil.Process(l1Process.pid).cpu_affinity([20]) # psutil.Process(tradeProcess.pid).cpu_affinity([21, 22]) -- Gitblit v1.8.0