|
@@ -508,18 +508,11 @@ impl Platform for HtxSwap {
|
|
|
self_clone.order_sender.send(order).await.unwrap();
|
|
self_clone.order_sender.send(order).await.unwrap();
|
|
|
}
|
|
}
|
|
|
Err(err) => {
|
|
Err(err) => {
|
|
|
- // 不存在的订单直接移除
|
|
|
|
|
- if !err.to_string().contains("Order doesnt exist") {
|
|
|
|
|
- self_clone.error_sender.send(error).await.unwrap();
|
|
|
|
|
- error!("撤单失败,而且查单也失败了,htx_swap,oid={}, cid={}, err={:?}。", order_id.clone(), custom_id.clone(), err);
|
|
|
|
|
- }
|
|
|
|
|
- let mut err_order = Order::new();
|
|
|
|
|
- err_order.custom_id = custom_id.clone();
|
|
|
|
|
- err_order.status = "REMOVE".to_string();
|
|
|
|
|
-
|
|
|
|
|
- self_clone.order_sender.send(err_order).await.unwrap();
|
|
|
|
|
|
|
+ error!("撤单失败,而且查单也失败了,htx_swap,oid={}, cid={}, err={:?}。", order_id.clone(), custom_id.clone(), err);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
+ error!("撤单失败,异常:{}", error);
|
|
|
|
|
+ self_clone.error_sender.send(error).await.unwrap();
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|