if is_aggregate
    && let Some(interval) = res.histogram_interval
    && interval > 0
{
    let interval = interval * 1000 * 1000; // convert to microseconds
    // next interval of start_time
    if (accept_start_time % interval) != 0 {
        accept_start_time = accept_start_time - (accept_start_time % interval) + interval;
    }
    // previous interval of end_time
    if (accept_end_time % interval) != 0 {
        need_adjust_end_time = true;
        accept_end_time = accept_end_time - (accept_end_time % interval) - interval;
    }
}

// 2. get the data time range, check if need to remove records with discard_duration
let delay_ts = second_micros(get_config().limit.cache_delay_secs);
let mut accept_end_time =
    std::cmp::min(Utc::now().timestamp_micros() - delay_ts, accept_end_time);
let last_rec_ts = get_ts_value(ts_column, res.hits.last().unwrap());
let first_rec_ts = get_ts_value(ts_column, res.hits.first().unwrap());
let data_start_time = std::cmp::min(first_rec_ts, last_rec_ts);
let data_end_time = std::cmp::max(first_rec_ts, last_rec_ts);
if data_start_time < accept_start_time || data_end_time > accept_end_time {
    res.hits.retain(|hit| {
        if let Some(hit_ts) = hit.get(ts_column)
            && let Some(hit_ts_datetime) = convert_ts_value_to_datetime(hit_ts)
        {
            let item_ts = hit_ts_datetime.timestamp_micros();
            // only keep the records within the accept time range
            item_ts >= accept_start_time && item_ts <= accept_end_time
        } else {
            true
        }
    });
    res.total = res.hits.len();
    res.size = res.hits.len() as i64;
}

// 3. check if the hits is empty
if res.hits.is_empty() {
    log::info!("[trace_id {trace_id}] No hits found for caching, skipping caching");
    return;
}

// 4. check if the time range is less than discard_duration
if (accept_end_time - accept_start_time) < delay_ts {
    log::info!("[trace_id {trace_id}] Time range is too short for caching, skipping caching");
    return;
}

// 5. adjust the cache time range
if need_adjust_end_time
    && is_aggregate
    && let Some(interval) = res.histogram_interval
    && interval > 0
{
    accept_end_time += interval * 1000 * 1000;
}

    let interval = interval * 1000 * 1000; // convert to microseconds
    // next interval of start_time
    if (accept_start_time % interval) != 0 {
        accept_start_time = accept_start_time - (accept_start_time % interval) + interval;
    }
    // previous interval of end_time
    if (accept_end_time % interval) != 0 {
        need_adjust_end_time = true;
        accept_end_time = accept_end_time - (accept_end_time % interval) - interval;
    }
}

// 2. get the data time range, check if need to remove records with discard_duration
let delay_ts = second_micros(get_config().limit.cache_delay_secs);
let mut accept_end_time =
    std::cmp::min(Utc::now().timestamp_micros() - delay_ts, accept_end_time);
let last_rec_ts = get_ts_value(ts_column, res.hits.last().unwrap());
let first_rec_ts = get_ts_value(ts_column, res.hits.first().unwrap());
let data_start_time = std::cmp::min(first_rec_ts, last_rec_ts);
let data_end_time = std::cmp::max(first_rec_ts, last_rec_ts);
if data_start_time < accept_start_time || data_end_time > accept_end_time {
    res.hits.retain(|hit| {
        if let Some(hit_ts) = hit.get(ts_column)
            && let Some(hit_ts_datetime) = convert_ts_value_to_datetime(hit_ts)
        {
            let item_ts = hit_ts_datetime.timestamp_micros();
            // only keep the records within the accept time range
            item_ts >= accept_start_time && item_ts <= accept_end_time
        } else {
            true
        }
    });
    res.total = res.hits.len();
    res.size = res.hits.len() as i64;
}

// 3. check if the hits is empty
if res.hits.is_empty() {
    log::info!("[trace_id {trace_id}] No hits found for caching, skipping caching");
    return;
}

// 4. check if the time range is less than discard_duration
if (accept_end_time - accept_start_time) < delay_ts {
    log::info!("[trace_id {trace_id}] Time range is too short for caching, skipping caching");
    return;
}

// 5. adjust the cache time range
if need_adjust_end_time
    && is_aggregate
    && let Some(interval) = res.histogram_interval
    && interval > 0
{
    accept_end_time += interval * 1000 * 1000;
}