| | |
|---|
| | | |
|---|
| | | |
|---|
| | | # 设置交易通信队列 |
|---|
| | | # 暂时不会使用该方法 |
|---|
| | | def run_pipe_trade(queue_strategy_r_trade_w_, queue_strategy_w_trade_r_): |
|---|
| | | global queue_strategy_w_trade_r |
|---|
| | | queue_strategy_w_trade_r = queue_strategy_w_trade_r_ |
|---|
| | |
|---|
| | | async_log_util.info(hx_logger_trade_loop, f"请求响应: request_id-{request_id} 内容-{response}") |
|---|
| | | # 主动触发 |
|---|
| | | __request_response_dict[request_id] = response |
|---|
| | | try: |
|---|
| | | # 设置替换本地订单号 |
|---|
| | | if response.get('code') == 0: |
|---|
| | | data = response['data'] |
|---|
| | | # 处理下单 |
|---|
| | | if data.get('orderStatus') == huaxin_util.TORA_TSTP_OST_Accepted: |
|---|
| | | orderRef = data.get('orderRef') |
|---|
| | | orderSysID = data.get('orderSysID') |
|---|
| | | accountID = data.get('accountID') |
|---|
| | | insertTime = data.get('insertTime') |
|---|
| | | code = data.get('securityId') |
|---|
| | | if orderRef and orderSysID: |
|---|
| | | # 移除本地单号，添加系统单号 |
|---|
| | | __TradeOrderIdManager.add_order_id(code, accountID, orderSysID) |
|---|
| | | __TradeOrderIdManager.remove_order_ref(code, orderRef) |
|---|
| | | except: |
|---|
| | | pass |
|---|
| | | else: |
|---|
| | | # 被动触发 |
|---|
| | | pass |
|---|
