| | |
|---|
| | | ret = api.ReqOrderInsert(req_field, self.req_id) |
|---|
| | | if ret != 0: |
|---|
| | | raise Exception('ReqOrderInsert fail, ret[%d]' % ret) |
|---|
| | | # 常态化监听不需要单独设置 |
|---|
| | | # if queue_other_w_l2_r is not None: |
|---|
| | | # queue_other_w_l2_r.put_nowait( |
|---|
| | | # json.dumps({"type": "listen_volume", "data": {"code": code, |
|---|
| | | # "volume": count}}).encode( |
|---|
| | | # 'utf-8')) |
|---|
| | | async_log_util.info(logger_trade, f"{code}华鑫本地真实下单结束") |
|---|
| | | # --------------------------------影子订单-------------------------------- |
|---|
| | | if shadow_price: |
|---|
| | |
|---|
| | | logger_system.info("交易进程ID：{}", os.getpid()) |
|---|
| | | logger_system.info(f"trade 线程ID:{tool.get_thread_id()}") |
|---|
| | | __init_trade_data_server() |
|---|
| | | global queue_other_w_l2_r |
|---|
| | | queue_other_w_l2_r = queue_other_w_l2_r_ |
|---|
| | | |
|---|
| | | global queue_strategy_trade_write |
|---|
| | | queue_strategy_trade_write = queue_strategy_trade_write_ |
|---|
