| | |
|---|
| | | |
|---|
| | | def test(): |
|---|
| | | time.sleep(5) |
|---|
| | | while True: |
|---|
| | | print("获取持仓：", huaxin_trade_data_update.add_position_list()) |
|---|
| | | time.sleep(3) |
|---|
| | | # print("获取资金：", huaxin_trade_api.get_money()) |
|---|
| | | |
|---|
| | | print("获取资金：", huaxin_trade_api.get_money()) |
|---|
| | | # print("获取成交：", huaxin_trade_api.get_deal_list()) |
|---|
| | | # print("下单：", huaxin_trade_api.order(1, "127075", 10, 140.5, blocking=True)) |
|---|
| | | |
|---|
| | |
|---|
| | | command_callback, [("trade_cb", 50)]) |
|---|
| | | manager.run(blocking=False) |
|---|
| | | |
|---|
| | | # threading.Thread(target=test, daemon=True).start() |
|---|
| | | threading.Thread(target=test, daemon=True).start() |
|---|
| | | # ===========读取根据L2制定的买入策略========== |
|---|
| | | threading.Thread(target=read_l2_results, args=(trade_call_back_queue,), daemon=True).start() |
|---|
| | | # ===========异步日志持久化========== |
|---|
