修复波动计算bug。

src/export_analyze.rs

@@ -2,7 +2,7 @@ use crate::export_ticker::{get_binance_ticker_info, get_bitget_ticker_info, get_
 use std::cmp::max;
 use std::collections::{BTreeMap};
 use std::str::FromStr;
-use chrono::{Utc};
+use chrono::Utc;
 use rust_decimal::Decimal;
 use rust_decimal_macros::dec;
 use tracing::{info};
@@ -73,7 +73,7 @@ pub fn calc_gate_ticker_amplitude(tickers: Vec<Ticker>, limit_range: Decimal) ->
     let mut amplitude_map: BTreeMap<Decimal, Decimal> = BTreeMap::new();
 
     // 每一个元素都遍历一遍
-    info!("精确幅度计算执行中……");
+    info!("精确幅度计算执行中({}条数据)……", tickers.len());
     for (index, ticker) in tickers.iter().enumerate() {
         // 该元素向前遍历range毫秒
         let mut range_index = if index == 0 {
@@ -115,7 +115,7 @@ pub fn calc_gate_ticker_amplitude(tickers: Vec<Ticker>, limit_range: Decimal) ->
         let last_price = ticker.price;
 
         // 不是初始值，以及不是0波动
-        if index != 0 && (max_price != last_price || min_price != last_price) {
+        if index != 0 {
             let mut up_rate = (last_price - min_price) / min_price;
             let mut dn_rate = (last_price - max_price) / max_price;
 
@@ -123,11 +123,10 @@ pub fn calc_gate_ticker_amplitude(tickers: Vec<Ticker>, limit_range: Decimal) ->
             dn_rate.rescale(4);
 
             // 去除小数位之后，可以忽略一些太小的波动，减少图表生成压力
-            if up_rate.eq(&Decimal::ZERO) || dn_rate.eq(&Decimal::ZERO) {
+            if up_rate.eq(&Decimal::ZERO) && dn_rate.eq(&Decimal::ZERO) {
                 continue
             }
 
-            // info!("up={}, dn={}, ra={}", up_rate, dn_rate, max(up_rate, dn_rate));
             // 如果已经生成了一个波动，则也要和已生成的波动进行比较
             let insert_value = if amplitude_map.contains_key(&ticker.create_time) {
                 let origin_rate = amplitude_map.get(&ticker.create_time).unwrap();