Преглед на файлове

今天改了太多,回滾一下。

skyfffire преди 1 година
родител
ревизия
e15a4bfcf9
променени са 1 файла, в които са добавени 7 реда и са изтрити 20 реда
  1. 7 20
      strategy/src/avellaneda_stoikov.rs

+ 7 - 20
strategy/src/avellaneda_stoikov.rs

@@ -245,17 +245,11 @@ impl AvellanedaStoikov {
     }
 
     pub fn update_delta(&mut self) {
-        if self.flow_ratio_vec.len() == 0 {
-            return;
-        }
-
-        let max_flow_ratio_abs = self.flow_ratio_vec.deque.iter().map(|&x| x.abs()).max().unwrap();
-        self.flow_ratio_diff = max_flow_ratio_abs;
-        if !self.gamma.is_zero() && !max_flow_ratio_abs.is_zero() {
+        if self.gamma != Decimal::ZERO {
             let pos_edge = self.gamma * self.sigma_square * self.inventory.abs().powd(dec!(2.5)) * self.t_diff / Decimal::TWO;
 
             self.base_delta = self.gamma * self.sigma_square * self.t_diff / Decimal::TWO + (Decimal::ONE / self.gamma) * (Decimal::ONE + self.gamma / self.kappa).ln();
-            self.ratio_edge = dec!(5) * (self.flow_ratio / max_flow_ratio_abs.abs()) * self.sigma_square;
+            self.ratio_edge = self.flow_ratio * self.sigma_square;
 
             self.bid_delta = self.base_delta;
             self.ask_delta = self.base_delta;
@@ -268,9 +262,9 @@ impl AvellanedaStoikov {
 
             if self.ratio_edge > Decimal::ZERO {
                 self.ask_delta = self.ask_delta - self.ratio_edge.abs() * (dec!(1.618) - self.t_diff);
-                self.bid_delta = self.bid_delta + self.ratio_edge.abs() * Decimal::PI;
+                self.bid_delta = self.bid_delta + self.ratio_edge.abs() * dec!(25);
             } else if self.ratio_edge < Decimal::ZERO {
-                self.ask_delta = self.ask_delta + self.ratio_edge.abs() * Decimal::PI;
+                self.ask_delta = self.ask_delta + self.ratio_edge.abs() * dec!(25);
                 self.bid_delta = self.bid_delta - self.ratio_edge.abs() * (dec!(1.618) - self.t_diff);
             }
 
@@ -295,16 +289,9 @@ impl AvellanedaStoikov {
     }
 
     pub fn update_flow_ratio(&mut self) {
-        if self.flow_out_value + self.flow_in_value > Decimal::ZERO && self.trade_vec.len() > 100 {
+        if self.trade_vec.len() > 200 {
             // let prev_flow_ratio = self.flow_ratio;
             self.flow_ratio = (self.flow_in_value - self.flow_out_value) / (self.flow_out_value + self.flow_in_value);
-            if self.flow_ratio.abs() < dec!(0.1) {
-                self.flow_ratio = if self.flow_ratio.is_sign_negative() {
-                    dec!(-0.1)
-                } else {
-                    dec!(0.1)
-                }
-            }
             self.flow_ratio_vec.push_back(self.flow_ratio);
 
             // self.flow_ratio_diff = if !prev_flow_ratio.is_zero() {
@@ -327,7 +314,7 @@ impl AvellanedaStoikov {
         }
 
         if self.mid_price == Decimal::ZERO {
-           return;
+            return;
         }
 
         if self.ask_price == Decimal::ZERO {
@@ -399,7 +386,7 @@ impl AvellanedaStoikov {
             inventory: self.inventory,
             sigma_square: self.flow_ratio,
             gamma: self.ratio_edge,
-            kappa: self.flow_ratio_diff,
+            kappa: self.t_diff,
 
             flow_ratio: self.flow_ratio,
             ref_price: self.ref_price,