From 273428fe5a4fe4c0e5200dff007c7684153d331b Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期五, 10 五月 2024 18:46:22 +0800 Subject: [PATCH] 可转债仿真交易 --- test/test.py | 31 ++++++++++++++++++++++++++----- 1 files changed, 26 insertions(+), 5 deletions(-) diff --git a/test/test.py b/test/test.py index 1ee1e85..efddf35 100644 --- a/test/test.py +++ b/test/test.py @@ -1,8 +1,29 @@ -from code_atrribute.history_k_data_util import JueJinHttpApi -from huaxin_client import l2_client_for_cb -from utils import tool +import logging +import multiprocessing +import time + +from huaxin_client.cb import trade_client_for_cb +from log_module.log import logger_info +from trade import huaxin_trade_api if __name__ == "__main__": - ffresults = l2_client_for_cb.get_subscript_codes() + try: + q_s_w_t_r, q_s_r_t_w = multiprocessing.Queue(), multiprocessing.Queue() + huaxin_trade_api.run_pipe_trade(q_s_r_t_w, q_s_w_t_r) + tradeProcess = multiprocessing.Process( + target= trade_client_for_cb.run, + args=(q_s_w_t_r, q_s_r_t_w)) + tradeProcess.start() + time.sleep(3) + print("鑾峰彇濮旀墭缁撴灉", huaxin_trade_api.get_delegate_list()) - print("鏈�缁堢殑鏁伴噺", len(ffresults)) + time.sleep(2) + print("鑾峰彇鎸佷粨缁撴灉", huaxin_trade_api.get_position_list(True)) + + + + + except Exception as e: + logging.exception(e) + finally: + logger_info.debug("绋嬪簭缁撴潫") -- Gitblit v1.8.0