瀏覽代碼

计算逻辑的一些调整

skyffire 9 月之前
父節點
當前提交
b2440650c4
共有 1 個文件被更改,包括 3 次插入1 次删除
  1. 3 1
      strategy/src/predictor.rs

+ 3 - 1
strategy/src/predictor.rs

@@ -172,7 +172,7 @@ impl Predictor {
             ask_delta: Default::default(),
             bid_delta: Default::default(),
 
-            force_order_time_vec: FixedTimeRangeDeque::new(60 * 1_000_000),
+            force_order_time_vec: FixedTimeRangeDeque::new(30 * 1_000_000),
             force_order_value: Default::default(),
 
             fair_price_time_vec: FixedTimeRangeDeque::new((params.second_observation_time.to_f64().unwrap() * 1_000_000f64).to_i64().unwrap()),
@@ -255,6 +255,8 @@ impl Predictor {
             return;
         }
         self.processor().await;
+
+        self.force_order_value = self.force_order_time_vec.deque.iter().map(|item| item.value).sum();
     }
 
     pub async fn on_trade(&mut self, trade: &Trade, _index: usize) {