深度、ticker推送打印

strategy/src/binance_usdt_swap.rs

@@ -4,7 +4,7 @@ use std::sync::atomic::AtomicBool;
 use rust_decimal::Decimal;
 use tokio::sync::Mutex;
 use tokio_tungstenite::tungstenite::Message;
-use tracing::error;
+use tracing::{error, info};
 use exchanges::response_base::ResponseData;
 use global::trace_stack::{TraceStack};
 use standard::exchange::ExchangeEnum::BinanceSwap;
@@ -89,7 +89,7 @@ async fn on_data(core_arc_clone: Arc<Mutex<Core>>,
             // 将ticker数据转换为模拟深度
             let special_depth = standard::handle_info::HandleSwapInfo::handle_book_ticker(BinanceSwap, &response, symbol_multiplier);
             trace_stack.on_after_format();
-
+            info!("binance depth1推送： {:?}", special_depth);
             on_special_depth(core_arc_clone, update_flag_u, &response.label, &mut trace_stack, &special_depth).await;
         }
         "depth" => {

strategy/src/coinex_usdt_swap.rs

@@ -1,4 +1,4 @@
-use tracing::{error};
+use tracing::{error, info};
 use std::collections::BTreeMap;
 use std::sync::Arc;
 use std::sync::atomic::AtomicBool;
@@ -90,7 +90,7 @@ async fn on_data(core_arc_clone: Arc<Mutex<Core>>,
             trace_stack.set_source("coinex_usdt_swap.order_book".to_string());
             let special_depth = standard::handle_info::HandleSwapInfo::handle_special_depth(CoinexSwap, &response, symbol_multiplier);
             trace_stack.on_after_format();
-
+            info!("gate depth推送： {:?}", special_depth);
             on_special_depth(core_arc_clone, update_flag_u, &response.label, &mut trace_stack, &special_depth).await;
         }
         "balance.update" => {

strategy/src/gate_swap.rs

@@ -107,7 +107,7 @@ async fn on_data(core_arc_clone: Arc<Mutex<Core>>,
             trace_stack.set_source("gate_usdt_swap.order_book".to_string());
             let special_depth = standard::handle_info::HandleSwapInfo::handle_special_depth(GateSwap, &response, symbol_multiplier);
             trace_stack.on_after_format();
-
+            info!("gate depth推送： {:?}", special_depth);
             on_special_depth(core_arc_clone, update_flag_u, &response.label, &mut trace_stack, &special_depth).await;
         }
         "futures.book_ticker" => {
@@ -115,7 +115,7 @@ async fn on_data(core_arc_clone: Arc<Mutex<Core>>,
             // 将ticker数据转换为模拟深度
             let special_depth = standard::handle_info::HandleSwapInfo::handle_book_ticker(GateSwap, &response, symbol_multiplier);
             trace_stack.on_after_format();
-
+            info!("gate ticker推送： {:?}", special_depth);
             on_special_depth(core_arc_clone, update_flag_u, &response.label, &mut trace_stack, &special_depth).await;
         }
         "futures.balances" => {