|
|
@@ -1,4 +1,4 @@
|
|
|
-use tracing::{error};
|
|
|
+use tracing::{error, info};
|
|
|
use std::collections::BTreeMap;
|
|
|
use std::sync::Arc;
|
|
|
use std::sync::atomic::AtomicBool;
|
|
|
@@ -98,7 +98,7 @@ async fn on_data(core_arc_clone: Arc<Mutex<Core>>,
|
|
|
}
|
|
|
"order.update" => {
|
|
|
trace_stack.set_source("coinex_swap.orders".to_string());
|
|
|
- // info!("coinex_usdt_swap 订单推送:{:?}", response);
|
|
|
+ info!("coinex_usdt_swap 订单推送:{:?}", response);
|
|
|
let orders = standard::handle_info::HandleSwapInfo::handle_order(CoinexSwap, response.clone(), multiplier.clone());
|
|
|
let mut order_infos:Vec<OrderInfo> = Vec::new();
|
|
|
for mut order in orders.order {
|
|
|
@@ -112,6 +112,7 @@ async fn on_data(core_arc_clone: Arc<Mutex<Core>>,
|
|
|
}
|
|
|
|
|
|
if order_infos.is_empty() {
|
|
|
+ error!("coinex_usdt_swap 未识别的订单 格式化失败:{:?}", response);
|
|
|
return
|
|
|
}
|
|
|
let mut new_order = order_infos[0].clone();
|