| | |
|---|
| | | data = data_json["data"] |
|---|
| | | code = data["code"] |
|---|
| | | order_no = data["data"] |
|---|
| | | TradeServerProcessor.trading_order_canceled(code,order_no) |
|---|
| | | TradeServerProcessor.trading_order_canceled(code, order_no) |
|---|
| | | finally: |
|---|
| | | sk.sendall(socket_util.load_header(json.dumps({"code": 0}).encode(encoding='utf-8'))) |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | try: |
|---|
| | | need_cancel, msg = cls.__GCancelBigNumComputer.start_cancel(code, f"{order_no}", |
|---|
| | | l2_data_util.local_today_datas.get( |
|---|
| | | code), |
|---|
| | | l2_data_util.local_today_buyno_map.get( |
|---|
| | | code), |
|---|
| | | l2_data_util.local_today_num_operate_map.get( |
|---|
| | | code), m_val_num) |
|---|
| | | l2_data_util.local_today_datas.get( |
|---|
| | | code), |
|---|
| | | l2_data_util.local_today_buyno_map.get( |
|---|
| | | code), |
|---|
| | | l2_data_util.local_today_num_operate_map.get( |
|---|
| | | code), m_val_num) |
|---|
| | | if need_cancel: |
|---|
| | | # 需要撤单 |
|---|
| | | l2_data_manager_new.L2TradeDataProcessor.cancel_buy(code, "G撤撤单", "G撤") |
|---|
| | |
|---|
| | | logger_l2_g_cancel.info(f"{code}-不需要撤单：{msg}") |
|---|
| | | except Exception as e: |
|---|
| | | logger_l2_g_cancel.error(f"{code}-撤单异常：{str(e)}") |
|---|
| | | |
|---|
| | | |
|---|
| | | def clear_invalid_client(): |
|---|
| | | while True: |
|---|
| | |
|---|
| | | |
|---|
| | | def OnTradingOrderCancel(self, code, buy_no): |
|---|
| | | TradeServerProcessor.trading_order_canceled(code, buy_no) |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | class MyTradeResponse(TradeResponse): |
|---|
