移除一些不用的变量

global/src/log_utils.rs

@@ -1,23 +1,23 @@
-use std::fmt::Debug;
+// use std::fmt::Debug;
 use std::io;
 use tracing_appender_timezone::non_blocking::WorkerGuard;
 use tracing_subscriber::{fmt};
 use tracing_subscriber::layer::{SubscriberExt};
-use tracing::field::{Field, Visit};
+// use tracing::field::{Field, Visit};
 use tracing_appender_timezone::rolling::{RollingFileAppender, Rotation};
 
 
-struct ErrorMessageVisitor {
-    message: String
-}
-
-impl Visit for ErrorMessageVisitor {
-    fn record_debug(&mut self, field: &Field, value: &dyn Debug) {
-        if field.name() == "message" {
-            self.message = format!("{:?}", value);
-        }
-    }
-}
+// struct ErrorMessageVisitor {
+//     message: String
+// }
+//
+// impl Visit for ErrorMessageVisitor {
+//     fn record_debug(&mut self, field: &Field, value: &dyn Debug) {
+//         if field.name() == "message" {
+//             self.message = format!("{:?}", value);
+//         }
+//     }
+// }
 
 
 // 错误报告发送到指定服务器

global/src/params.rs

@@ -32,8 +32,6 @@ pub struct Params {
     pub close_activate: Decimal,
     // 平仓
     pub close: Decimal,
-    // 秒级观测时间
-    pub second_observation_time: Decimal,
     // 杠杆大小
     pub lever_rate: Decimal,
     // 现货底仓
@@ -96,7 +94,6 @@ impl Params {
             open_activate: Decimal::try_from(json_value["open_activate"].as_f64().unwrap_or_default()).unwrap(),
             min_spread: Decimal::try_from(json_value["min_spread"].as_f64().unwrap_or_default()).unwrap(),
             close: Decimal::try_from(json_value["close"].as_f64().unwrap_or_default()).unwrap(),
-            second_observation_time: Decimal::try_from(json_value["second_observation_time"].as_f64().unwrap()).unwrap(),
             lever_rate: Decimal::try_from(json_value["lever_rate"].as_f64().unwrap_or_default()).unwrap(),
             ref_exchange: vec![json_value["ref_exchange"].as_str().unwrap().to_string()],                   // 兼容新版本与老版本
             ref_pair: vec![json_value["ref_pair"].as_str().unwrap().to_string()],                           // 兼容新版本与老版本

strategy/src/predictor.rs

@@ -51,8 +51,6 @@ pub struct Predictor {
     pub bid_delta: Decimal,                                                     // δb
 
     pub mid_price_time_vec: FixedTimeRangeDeque<Decimal>,                       // 中间价格队列，
-    pub fair_price_time_vec: FixedTimeRangeDeque<Decimal>,                      // 公平价格队列，
-    pub fair_price_long_time_vec: FixedTimeRangeDeque<Decimal>,                 //
     pub fair_price_vec: Vec<Decimal>,                                           // 公平价格列表，0表示做市所，1表示参考所
     pub fair_price: Decimal,                                                    // 公平价格
     pub fair_price_ema_short: Decimal,                                          // 公平价格_ema
@@ -121,7 +119,7 @@ impl Predictor {
                 }
 
                 let now = Decimal::from(Utc::now().timestamp_millis());
-                if now - prev_save_time < dec!(60000) {
+                if now - prev_save_time < dec!(30000) {
                     continue;
                 }
 
@@ -165,8 +163,6 @@ impl Predictor {
             ask_delta: Default::default(),
             bid_delta: Default::default(),
 
-            fair_price_time_vec: FixedTimeRangeDeque::new((params.second_observation_time.to_f64().unwrap() * 1_000_000f64).to_i64().unwrap()),
-            fair_price_long_time_vec: FixedTimeRangeDeque::new(5 * 60_000_000),
             mid_price_time_vec: FixedTimeRangeDeque::new(100_000),
             fair_price: Default::default(),
             fair_price_ema_short: Default::default(),
@@ -301,11 +297,6 @@ impl Predictor {
             self.prev_trade_time = Utc::now().timestamp_micros();
         }
 
-        // 重置fair数据，用于重新计算幅度
-        if prev_inventory != self.inventory {
-            self.fair_price_time_vec.deque.clear();
-        }
-
         // 重置资金流计算
         if prev_inventory != self.inventory && self.inventory.is_zero() {
             self.trade_fixed_vec.clear();
@@ -513,12 +504,7 @@ impl Predictor {
 
         let inventory = self.inventory;
 
-        let sigma_square = if self.fair_price_time_vec.len() > 1 {
-            Self::get_real_rate(&self.fair_price_time_vec)
-        } else {
-            Decimal::ZERO
-        };
-        // let sigma_square = self.error_rate;
+        let sigma_square = self.fair_price - self.mid_price;
 
         let gamma = self.fair_rate_focus_open;
         let kappa = self.fair_rate_focus_close;