| | |
|---|
| | | 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("程序结束") |
|---|
