| | |
| | | from third_data.kpl_data_manager import KPLDataManager |
| | | from third_data.kpl_limit_up_data_manager import CodeLimitUpSequenceManager |
| | | from third_data.kpl_util import KPLDataType |
| | | from trade import trade_manager, l2_trade_util, trade_data_manager |
| | | from trade import trade_manager, l2_trade_util, trade_data_manager, trade_constant |
| | | import l2_data_util as l2_data_util_old |
| | | |
| | | from trade.huaxin import huaxin_trade_api, huaxin_trade_data_update, \ |
| | |
| | | accountID = data["accountID"] |
| | | orderSysID = data["orderSysID"] |
| | | sinfo = data["sinfo"] |
| | | async_log_util.info(logger_trade, f"API撤单: {data}") |
| | | if orderSysID: |
| | | result = huaxin_trade_api.cancel_order(direction, code, orderSysID, sinfo=sinfo, |
| | | blocking=True, request_id=request_id) |
| | |
| | | msg_list.append(f"撤卖单数量:{sell_count}") |
| | | except Exception as e: |
| | | logger_debug.exception(e) |
| | | can_cancel = l2_data_manager_new.L2TradeDataProcessor.cancel_buy(code, "手动撤单") |
| | | can_cancel = l2_data_manager_new.L2TradeDataProcessor.cancel_buy(code, "手动撤单", cancel_type=trade_constant.CANCEL_TYPE_HUMAN) |
| | | if not can_cancel: |
| | | msg_list.append(f"无法撤买单") |
| | | else: |
| | | msg_list.append(f"已撤买单") |
| | | async_log_util.info(logger_trade, f"API撤单结果: {msg_list}") |
| | | self.send_response({"code": 0, "data": {"code": 0, "msg": ";".join(msg_list)}}, client_id, |
| | | request_id) |
| | | except Exception as e: |
| | |
| | | if operate == outside_api_command_manager.OPERRATE_SET: |
| | | # 先手动撤单 |
| | | try: |
| | | l2_data_manager_new.L2TradeDataProcessor.cancel_buy(code, "手动拉黑") |
| | | l2_data_manager_new.L2TradeDataProcessor.cancel_buy(code, "手动拉黑", cancel_type=trade_constant.CANCEL_TYPE_HUMAN) |
| | | except Exception as e: |
| | | logger_debug.exception(e) |
| | | l2_trade_util.forbidden_trade(code, msg="手动加入 trade_server") |