|
|
@@ -7,6 +7,7 @@ use rust_decimal_macros::dec;
|
|
|
use serde::{Deserialize, Serialize};
|
|
|
use serde_json::{Value};
|
|
|
use tokio::sync::MutexGuard;
|
|
|
+use tracing::info;
|
|
|
use crate::json_db_utils::get_symbols_by_exchange;
|
|
|
use crate::msv::Indicators;
|
|
|
|
|
|
@@ -58,8 +59,9 @@ pub fn generate_rank_by_indicator_map(indicator_map: &MutexGuard<HashMap<String,
|
|
|
// 0.175 0.225 0.275 0.325
|
|
|
|
|
|
for (_index, value) in indicators.indicator.iter().enumerate() {
|
|
|
- // 如果数据时间循环到超过限制时间,直接跳出循环
|
|
|
- if value.timestamp.to_i64().unwrap() < limit_time{
|
|
|
+ // 如果数据时间循环到超过限制时间
|
|
|
+ if value.timestamp.to_i64().unwrap() < limit_time {
|
|
|
+ info!("value.timestamp: {}, limit_time: {}", value.timestamp.to_i64().unwrap(), limit_time);
|
|
|
continue
|
|
|
}
|
|
|
let msv_abs_value = value.msv_vol.abs();
|