Переглянути джерело

self.prev_flush_state_time = now;

不然一直请求……
skyffire 9 місяців тому
батько
коміт
09d8f3c2c2
1 змінених файлів з 3 додано та 0 видалено
  1. 3 0
      strategy/src/predictor.rs

+ 3 - 0
strategy/src/predictor.rs

@@ -464,6 +464,7 @@ impl Predictor {
             // 这个是后面加了动态平仓时间再使用的
             // self.params.holding_time = Decimal::from(profit_min_index);
             let _ = Decimal::from(profit_min_index);
+            self.prev_flush_state_time = now;
         }
 
         self.bid_delta = dec!(-2);
@@ -661,6 +662,8 @@ impl Predictor {
             let response_text = response.text().await.unwrap();
             let parsed: Value = serde_json::from_str(response_text.as_str()).unwrap();
 
+            info!("state_matrix={}", parsed["state_matrix"].to_string());
+
             self.state_matrix = parsed["state_matrix"]
                 .as_array()
                 .unwrap()