初始化

peter

2025-06-25 252184b1fff1b75e24032973996bfdc5b6126cb0

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
package com.yami.trading.huobi.data.internal;
 
import com.yami.trading.bean.data.domain.Kline;
 
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.List;
 
public class KLineConverter {
 
 
    /**
     * 假设只取了一个区间的数据，直接对数据进行转
     * @param sKlineList
     * @return
     */
    public static List<Kline> convertTo5MinKline(List<Kline> sKlineList) {
        List<Kline> fiveMinKlineList = new ArrayList<>();
 
        int currentIndex = 0;
        int dataSize = sKlineList.size();
 
        while (currentIndex < dataSize) {
            Kline currentKline = sKlineList.get(currentIndex);
            long currentTimestamp = currentKline.getTs();
            BigDecimal open = currentKline.getOpen();
            BigDecimal high = currentKline.getHigh();
            BigDecimal low = currentKline.getLow();
            BigDecimal close = currentKline.getClose();
            BigDecimal volume = currentKline.getVolume();
            BigDecimal amount = currentKline.getAmount();
 
            long nextTimestamp = currentTimestamp + (5 * 60 * 1000); // 5 minutes in milliseconds
 
            // Find the index of the next Kline that satisfies the 5-minute condition
            int nextIndex = currentIndex + 1;
            while (nextIndex < dataSize && sKlineList.get(nextIndex).getTs() < nextTimestamp) {
                Kline nextKline = sKlineList.get(nextIndex);
                high = high.max(nextKline.getHigh());
                low = low.min(nextKline.getLow());
                volume = volume.add(nextKline.getVolume());
                amount = amount.add(nextKline.getAmount());
                close = nextKline.getClose();
                nextIndex++;
            }
 
            // Create the 5-minute Kline and add it to the list
            Kline fiveMinKline = new Kline();
            fiveMinKline.setSymbol(currentKline.getSymbol());
            fiveMinKline.setTs(currentTimestamp);
            fiveMinKline.setOpen(open);
            fiveMinKline.setHigh(high);
            fiveMinKline.setLow(low);
            fiveMinKline.setClose(close);
            fiveMinKline.setVolume(volume);
            fiveMinKline.setAmount(amount);
            fiveMinKlineList.add(fiveMinKline);
 
            currentIndex = nextIndex;
        }
 
        return fiveMinKlineList;
    }
 
}