|
|
@@ -299,13 +299,9 @@ pub fn generate_msv_by_trades(mut trades: Vec<Trade>, mills_back: Decimal, simpl
|
|
|
pub fn delete_expire_data(mut msv: Indicators, hour_num: i64) -> Indicators {
|
|
|
let now = Utc::now().timestamp_millis();
|
|
|
let limit_time = now - 60 * 1000 * 60 * hour_num;
|
|
|
- let old_size = msv.indicator.len();
|
|
|
msv.indicator.retain(|info| info.timestamp.to_i64().unwrap() < limit_time);
|
|
|
- let delete_num = old_size - msv.indicator.len();
|
|
|
// 更新有效条数
|
|
|
msv.result_size = msv.indicator.len().to_i64().unwrap();
|
|
|
- // 更新总条数
|
|
|
- msv.total_size -= delete_num.to_i64().unwrap();
|
|
|
msv
|
|
|
}
|
|
|
|