소스 검색

取消计算时间限制

JiahengHe 1 년 전
부모
커밋
c24fa7586d
1개의 변경된 파일4개의 추가작업 그리고 4개의 파일을 삭제
  1. 4 4
      src/rank.rs

+ 4 - 4
src/rank.rs

@@ -38,7 +38,7 @@ const TWO_HUNDRED: Decimal = dec!(200);
 // 根据最终的msv计算排行榜
 pub fn generate_rank_by_indicator_map(indicator_map: &MutexGuard<HashMap<String, Indicators>>, hour_num: i64) -> Value {
     let now = Utc::now().timestamp_millis();
-    let limit_time = now - 60 * 1000 * 60 * hour_num;
+    // let limit_time = now - 60 * 1000 * 60 * hour_num;
     let mut rank_list: Vec<Rank> = vec![];
     let binance_symbols = get_symbols_by_exchange("binance_usdt_swap").as_array().unwrap_or(&vec![]).clone();
     for (key, indicators) in indicator_map.iter() {
@@ -59,9 +59,9 @@ pub fn generate_rank_by_indicator_map(indicator_map: &MutexGuard<HashMap<String,
 
         for (_index, value) in indicators.indicator.iter().enumerate() {
             // 如果数据时间循环到超过限制时间,直接跳出循环
-            if value.timestamp.to_i64().unwrap() < limit_time{
-                break
-            }
+            // if value.timestamp.to_i64().unwrap() < limit_time{
+            //     break
+            // }
             let msv_abs_value = value.msv_vol.abs();
 
             if msv_abs_value <= Decimal::ZERO {