修复时间限制逻辑

src/rank.rs

@@ -62,7 +62,7 @@ pub fn generate_rank_by_indicator_map(indicator_map: &MutexGuard<HashMap<String,
             // 如果数据时间循环到超过限制时间
             if value.timestamp.to_i64().unwrap() < limit_time {
                 info!("value.timestamp: {}, limit_time: {}", value.timestamp.to_i64().unwrap(), limit_time);
-                continue
+                continue;
             }
             let msv_abs_value = value.msv_vol.abs();
 
@@ -105,6 +105,10 @@ pub fn generate_rank_by_indicator_map(indicator_map: &MutexGuard<HashMap<String,
         // ============== liq相关数据的计算 =================
         let mut liquidity_total = Decimal::ZERO;
         for liq_value in indicators.indicator.iter() {
+            // 如果数据时间循环到超过限制时间
+            if liq_value.timestamp.to_i64().unwrap() < limit_time {
+                continue;
+            }
             liquidity_total += liq_value.liq_liquidity_amount * Decimal::ONE_THOUSAND;
         }
         let mut liquidity_avg = if msv_count == Decimal::ZERO {