| | |
|---|
| | | |
|---|
| | | |
|---|
| | | # 撤单 |
|---|
| | | def cancel_order(code): |
|---|
| | | def cancel_order(code, msg=''): |
|---|
| | | orders_info = __TradeOrderIdManager.list_order_ids_cache(code) |
|---|
| | | orders_info = copy.deepcopy(orders_info) |
|---|
| | | orders = [] |
|---|
| | |
|---|
| | | order_info = json.loads(order) |
|---|
| | | orders.append({'orderSysID': order_info[1], 'accountId': order_info[0]}) |
|---|
| | | if orders: |
|---|
| | | async_log_util.info(logger_trade, f"{code}：华鑫开始执行撤单") |
|---|
| | | async_log_util.info(logger_trade, f"{code}：华鑫开始执行撤单 {msg}") |
|---|
| | | for order in orders: |
|---|
| | | huaxin_trade_api.cancel_order(1, code, order["orderSysID"]) |
|---|
| | | __TradeOrderIdManager.remove_order_id(code, order["accountId"], order["orderSysID"]) |
|---|
| | |
|---|
| | | if local_orders_info: |
|---|
| | | local_orders_info = copy.deepcopy(local_orders_info) |
|---|
| | | for order_id in local_orders_info: |
|---|
| | | async_log_util.info(logger_trade, f"{code}：华鑫开始执行撤单") |
|---|
| | | async_log_util.info(logger_trade, f"{code}：华鑫开始执行撤单 {msg}") |
|---|
| | | huaxin_trade_api.cancel_order(1, code, '', localOrderID=order_id) |
|---|
| | | __TradeOrderIdManager.remove_local_order_id(code, order_id) |
|---|
| | | async_log_util.info(logger_trade, f"{code}：华鑫执行撤单结束") |
|---|
