看看格式化bookTicker的平均速度

strategy/src/binance_usdt_swap.rs

@@ -81,13 +81,18 @@ async fn on_data(core_arc_clone: Arc<Mutex<Core>>,
         // core.max_buy_min_sell_cache.insert(data.label, vec![*_max_buy, *_min_sell]);
     } else if data.channel == "bookTicker" {
         // 将ticker数据转换为模拟深度
+        let label = data.label.clone();
+        let ins = data.ins;
         let special_depth = standard::handle_info::HandleSwapInfo::handle_special_ticker(BinanceSwap, data.clone());
 
-        on_special_depth(core_arc_clone, update_flag_u, data.label.clone(), trace_stack, special_depth).await;
+        TraceStack::show_delay(ins);
+
+        on_special_depth(core_arc_clone, update_flag_u, label, trace_stack, special_depth).await;
     } else if data.channel == "depth" {
         // 将depth数据转换为模拟深度
-        let special_depth = standard::handle_info::HandleSwapInfo::handle_special_depth(BinanceSwap, data.clone());
+        let label = data.label.clone();
+        let special_depth = standard::handle_info::HandleSwapInfo::handle_special_depth(BinanceSwap, data);
 
-        on_special_depth(core_arc_clone, update_flag_u, data.label.clone(), trace_stack, special_depth).await;
+        on_special_depth(core_arc_clone, update_flag_u, label, trace_stack, special_depth).await;
     }
 }

strategy/src/exchange_disguise.rs

@@ -3,7 +3,6 @@ use std::sync::Arc;
 use std::sync::atomic::AtomicBool;
 use rust_decimal::Decimal;
 use tokio::sync::Mutex;
-use tracing::info;
 use global::trace_stack::TraceStack;
 use standard::SpecialDepth;
 
@@ -93,12 +92,9 @@ pub async fn on_special_depth(core_arc: Arc<Mutex<Core>>,
                               label: String,
                               trace_stack: TraceStack,
                               special_depth: SpecialDepth) {
-    
     if special_depth.t > *update_flag_u {
         let mut core = core_arc.lock().await;
 
-        TraceStack::show_delay(trace_stack.after_network_instant);
-
         core._update_ticker(special_depth.ticker, label.clone());
         core._update_depth(special_depth.depth.clone(), label.clone(), trace_stack).await;
         core.local_depths.insert(special_depth.name, special_depth.depth);