kucoin ticker信息可以使用。

strategy/src/kucoin_swap.rs

@@ -9,7 +9,6 @@ use tokio_tungstenite::tungstenite::Message;
 use tokio::spawn;
 use tokio::sync::Mutex;
 use tokio::time::sleep;
-use tracing::info;
 
 use exchanges::kucoin_swap_ws::{KucoinSwapLogin, KucoinSwapSubscribeType, KucoinSwapWs, KucoinSwapWsType};
 use exchanges::response_base::ResponseData;
@@ -59,7 +58,6 @@ pub async fn kucoin_swap_run(bool_v1 :Arc<AtomicBool>, type_num: i8, quant_arc:
             // 交易
             if type_num == 1 {
                 let login_params = parse_btree_map_to_kucoin_swap_login(exchange_params);
-                info!(?login_params);
                 kucoin_exc = KucoinSwapWs::new_label(name.clone(), false, Option::from(login_params), KucoinSwapWsType::Private).await;
                 kucoin_exc.set_subscribe(vec![
                     KucoinSwapSubscribeType::PuContractMarketLevel2Depth50,
@@ -126,11 +124,9 @@ async fn on_data(bot_arc_clone: Arc<Mutex<Quant>>,
 
         on_special_depth(bot_arc_clone, update_flag_u, data.label, trace_stack, depth).await
     } else if data.channel == "tickerV2" {
-        let ticker = standard::handle_info::HandleSwapInfo::handle_special_ticker(KucoinSwap, data);
-        {
-            let mut quant = bot_arc_clone.lock().await;
-            quant._update_ticker(ticker.ticker, ticker.name);
-        }
+        let depth = standard::handle_info::HandleSwapInfo::handle_special_ticker(KucoinSwap, data.clone());
+
+        on_special_depth(bot_arc_clone, update_flag_u, data.label, trace_stack, depth).await
     } else if data.channel == "availableBalance.change" {
         // 取消原有推送解析，因为推送的信息不准确
         // let account = standard::handle_info::HandleSwapInfo::handle_account_info(KucoinSwap, data, run_symbol.clone());