| | |
|---|
| | | from trade import huaxin_trade_api, huaxin_trade_data_update, huaxin_sell_util |
|---|
| | | from utils import middle_api_protocol, outside_api_command_manager, constant, tool, huaxin_util, socket_util, sell_util |
|---|
| | | |
|---|
| | | middle_api_protocol.SERVER_PORT = 10008 |
|---|
| | | middle_api_protocol.SERVER_HOST = "43.138.167.68" |
|---|
| | | |
|---|
| | | constant.LOG_DIR = "logs_cb" |
|---|
| | | from log_module.log import logger_debug, logger_trade, printlog |
|---|
| | | import concurrent.futures |
|---|
| | |
|---|
| | | |
|---|
| | | def test(): |
|---|
| | | time.sleep(5) |
|---|
| | | # print("获取持仓：", huaxin_trade_api.get_position_list()) |
|---|
| | | print("获取持仓：", huaxin_trade_api.get_position_list()) |
|---|
| | | # print("获取资金：", huaxin_trade_api.get_money()) |
|---|
| | | # print("获取成交：", huaxin_trade_api.get_deal_list()) |
|---|
| | | print("下单：", huaxin_trade_api.order(1, "110060", 10, 140.5, blocking=True)) |
|---|
| | | # print("下单：", huaxin_trade_api.order(1, "127075", 10, 140.5, blocking=True)) |
|---|
| | | |
|---|
| | | |
|---|
| | | def read_l2_results(trade_call_back_queue): |
|---|
| | |
|---|
| | | logger_debug.exception(e) |
|---|
| | | |
|---|
| | | trade_call_back_queue = multiprocessing.Queue() |
|---|
| | | middle_api_protocol.SERVER_PORT = 10008 |
|---|
| | | middle_api_protocol.SERVER_HOST = "43.138.167.68" |
|---|
| | | |
|---|
| | | # ===========运行交易外部API========== |
|---|
| | | # 策略与交易通信队列 |
|---|
| | | # 交易结果读取, 交易命令队列与交易查询队列设置为同一个 |
|---|
