|
|
@@ -651,24 +651,24 @@ impl Platform for BitgetSwap {
|
|
|
// 撤销订单
|
|
|
let mut cancel_handlers = vec![];
|
|
|
for item in order_command.cancel.keys() {
|
|
|
- let gen_timestamp = order_command.cancel[item].get(2).unwrap().parse::<i64>().unwrap();
|
|
|
+ // let gen_timestamp = order_command.cancel[item].get(2).unwrap().parse::<i64>().unwrap();
|
|
|
let order_id = order_command.cancel[item].get(1).unwrap().clone();
|
|
|
let custom_id = order_command.cancel[item].get(0).unwrap().clone();
|
|
|
|
|
|
let mut self_clone = self.clone();
|
|
|
- let before_submit2 = Utc::now().timestamp_millis();
|
|
|
+ // let before_submit2 = Utc::now().timestamp_millis();
|
|
|
let handle = spawn(async move {
|
|
|
- let before_submit1 = Utc::now().timestamp_millis();
|
|
|
+ // let before_submit1 = Utc::now().timestamp_millis();
|
|
|
let result = self_clone.cancel_order(&order_id, &custom_id).await;
|
|
|
match result {
|
|
|
Ok(result) => {
|
|
|
- let canceled = Utc::now().timestamp_millis();
|
|
|
- info!("cid={}, 生成-撤销2: {}, 撤销2-撤销1: {}, 撤销1-撤销完成(服务器回报): {}",
|
|
|
- custom_id,
|
|
|
- before_submit2 - gen_timestamp,
|
|
|
- before_submit1 - before_submit2,
|
|
|
- canceled - before_submit1
|
|
|
- );
|
|
|
+ // let canceled = Utc::now().timestamp_millis();
|
|
|
+ // info!("cid={}, 生成-撤销2: {}, 撤销2-撤销1: {}, 撤销1-撤销完成(服务器回报): {}",
|
|
|
+ // custom_id,
|
|
|
+ // before_submit2 - gen_timestamp,
|
|
|
+ // before_submit1 - before_submit2,
|
|
|
+ // canceled - before_submit1
|
|
|
+ // );
|
|
|
|
|
|
self_clone.order_sender.send(result).await.unwrap();
|
|
|
}
|
|
|
@@ -679,8 +679,8 @@ impl Platform for BitgetSwap {
|
|
|
Ok(order) => {
|
|
|
self_clone.order_sender.send(order).await.unwrap();
|
|
|
}
|
|
|
- Err(err) => {
|
|
|
- error!("撤单失败,而且查单也失败了,bitget_swap,oid={}, cid={}, err={:?}。", order_id.clone(), custom_id.clone(), err);
|
|
|
+ Err(_err) => {
|
|
|
+ // error!("撤单失败,而且查单也失败了,bitget_swap,oid={}, cid={}, err={:?}。", order_id.clone(), custom_id.clone(), err);
|
|
|
}
|
|
|
}
|
|
|
self_clone.error_sender.send(error).await.unwrap();
|