| | |
|---|
| | | blocking=True, request_id=request_id) |
|---|
| | | self.send_response({"code": 0, "data": result}, client_id, request_id) |
|---|
| | | elif code: |
|---|
| | | msg_list = [] |
|---|
| | | try: |
|---|
| | | sell_count = 0 |
|---|
| | | sell_orders = huaxin_trade_order_processor.TradeResultProcessor.get_huaxin_sell_order_by_code(code) |
|---|
| | | if sell_orders: |
|---|
| | | for sell_order in sell_orders: |
|---|
| | | if huaxin_util.is_can_cancel(sell_order.orderStatus): |
|---|
| | | sell_count+=1 |
|---|
| | | huaxin_trade_api.cancel_order(direction, code, sell_order.orderRef, blocking=False) |
|---|
| | | msg_list.append(f"撤卖单数量：{sell_count}") |
|---|
| | | except Exception as e: |
|---|
| | | logger_debug.exception(e) |
|---|
| | | l2_data_manager_new.L2TradeDataProcessor.cancel_buy(code, "手动撤单") |
|---|
| | | self.send_response({"code": 0, "data": {"code": 0}}, client_id, request_id) |
|---|
| | | can_cancel = l2_data_manager_new.L2TradeDataProcessor.cancel_buy(code, "手动撤单") |
|---|
| | | if not can_cancel: |
|---|
| | | msg_list.append(f"无法撤买单") |
|---|
| | | else: |
|---|
| | | msg_list.append(f"已撤买单") |
|---|
| | | self.send_response({"code": 0, "data": {"code": 0,"msg": "；".join(msg_list)}}, client_id, request_id) |
|---|
| | | except Exception as e: |
|---|
| | | logger_debug.exception(e) |
|---|
| | | self.send_response({"code": 1, "msg": str(e)}, client_id, request_id) |
|---|
