移除部分警告

strategy/src/predictor.rs

@@ -1,7 +1,7 @@
 use std::collections::BTreeMap;
 use rust_decimal::prelude::*;
 use rust_decimal_macros::dec;
-use tracing::{info, instrument};
+use tracing::{instrument};
 use standard::Ticker;
 use global::public_params;
 
@@ -81,7 +81,6 @@ impl Predictor {
 
         for ref_index in 0..self.ref_exchange_length {
             let bias = last_ref_mid_price_per_exchange[ref_index] * self.alpha[ref_index] - mid_price_last;
-            info!(?bias);
 
             let mut gamma = self.gamma;
             // 如果程序刚刚启动，gamma值不能太大

strategy/src/quant.rs

@@ -228,11 +228,7 @@ impl Quant {
             let market_update_interval_key = tickers_key.clone();
             let max_buy_min_sell_cache_key = tickers_key.clone();
 
-            quant_obj.tickers.insert(tickers_key, SpecialTicker {
-                sell: Default::default(),
-                buy: Default::default(),
-                mid_price: Default::default(),
-            });
+            quant_obj.tickers.insert(tickers_key, SpecialTicker::new());
             quant_obj.ref_name.push(ref_name_element);
             quant_obj.depths.insert(depths_key, Default::default());
             quant_obj.market_update_time.insert(market_update_time_key, Default::default());
@@ -248,11 +244,7 @@ impl Quant {
         quant_obj.trade_name = name;
         quant_obj.market_update_time.insert(market_update_time_key, Default::default());
         quant_obj.market_update_interval.insert(market_update_interval_key, Default::default());
-        quant_obj.tickers.insert(tickers_key, SpecialTicker {
-            sell: Default::default(),
-            buy: Default::default(),
-            mid_price: Default::default(),
-        });
+        quant_obj.tickers.insert(tickers_key, SpecialTicker::new());
         quant_obj.depths.insert(depths_key, Default::default());
         quant_obj.max_buy_min_sell_cache.insert(max_buy_min_sell_cache_key, vec![Decimal::ZERO, Decimal::ZERO]);
         // broker.newWs
@@ -1535,7 +1527,7 @@ pub fn on_timer(quant_arc: Arc<Mutex<Quant>>) -> JoinHandle<()> {
                 // TODO quant没有rest
                 // info!("Rest报单平均延迟{}ms", quant.rest.avg_delay);
                 // info!("Rest报单最高延迟{}ms", quant.rest.max_delay);
-                for (name, interval) in &quant.market_update_interval {
+                for (_name, _interval) in &quant.market_update_interval {
                     // debug!("WS盘口{}行情平均更新间隔{}ms。", name, interval);
                 }
             }