| | |
|---|
| | | 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')) |
|---|
| | | # 常态化监听不需要单独设置 |
|---|
| | | # 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: |
|---|
