| | |
|---|
| | | |
|---|
| | | def test(): |
|---|
| | | time.sleep(5) |
|---|
| | | print("获取持仓：", huaxin_trade_api.get_position_list()) |
|---|
| | | print("获取持仓：", huaxin_trade_data_update.add_position_list()) |
|---|
| | | # 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)) |
|---|
| | |
|---|
| | | if limit_up_price: |
|---|
| | | async_log_util.info(logger_trade, f"准备下单：{cb_code}-{limit_up_price}") |
|---|
| | | # 买入20股 |
|---|
| | | huaxin_trade_api.order(1, cb_code, 20, round(float(limit_up_price), 3), blocking=False) |
|---|
| | | result = huaxin_trade_api.order(1, cb_code, 20, round(float(limit_up_price), 3), blocking=True) |
|---|
| | | async_log_util.info(logger_trade, f"可转债下单结果：{result}") |
|---|
| | | except Exception as e: |
|---|
| | | logger_debug.exception(e) |
|---|
| | | time.sleep(1) |
|---|
| | |
|---|
| | | command_callback, [("trade_cb", 20)]) |
|---|
| | | 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() |
|---|
| | | # ===========异步日志持久化========== |
|---|
