debug

src/gate_usdt_swap_data_listener.rs

@@ -93,13 +93,13 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
                         indicators.result_size = old_msv.result_size + msv.result_size;
                         indicators.total_size = old_msv.total_size + msv.total_size;
                         indicators.last_calc_time = msv.last_calc_time;
-                        info!("删除前： result_size：{}， total_size： {}", indicators.result_size, indicators.total_size);
+                        info!("删除前： result_size：{}", indicators.result_size);
 
                         // 删除掉指定小时前的数据
                         delete_expire_data(indicators, 4)
                     }
                 };
-                info!("删除后： result_size：{}， total_size： {}", new_msv.result_size, new_msv.total_size);
+                info!("删除后： result_size：{}", new_msv.result_size);
                 indicator_map.insert(symbol, new_msv);
             }
             // 更新结束时间

src/msv.rs

@@ -7,7 +7,7 @@ use rust_decimal_macros::dec;
 use serde::{Deserialize, Serialize};
 use serde_json::{Value};
 use standard::{SimpleDepth, Trade};
-
+use tracing::info;
 
 /// 技术指标结构体
 /// - `msv(Vec<Vec<Decimal>>)`: msv
@@ -299,7 +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;
+    info!("删除前数据：{:?}", msv.indicator);
     msv.indicator.retain(|info| info.timestamp.to_i64().unwrap() < limit_time);
+    info!("删除后数据：{:?}", msv.indicator);
     // 更新有效条数
     msv.result_size = msv.indicator.len().to_i64().unwrap();
     msv