Parcourir la source

余额刷新问题尝试修复。

skyffire il y a 8 mois
Parent
commit
ca9d0bd1f9
1 fichiers modifiés avec 8 ajouts et 0 suppressions
  1. 8 0
      strategy/src/core.rs

+ 8 - 0
strategy/src/core.rs

@@ -588,6 +588,9 @@ impl Core {
             now_balance.rescale(4);
 
             self.predictor.on_balance(now_balance).await;
+
+            let mut cci = self.cci_arc.lock().await;
+            cci.now_balance = now_balance;
         }
     }
 
@@ -920,6 +923,11 @@ impl Core {
             return;
         }
         self.local_cash = data.balance * self.used_pct;
+
+        self.predictor.on_balance(self.local_cash).await;
+
+        let mut cci = self.cci_arc.lock().await;
+        cci.now_balance = self.local_cash;
     }
 
     // #[instrument(skip(self), level="TRACE")]