| | |
|---|
| | | BigDecimal currentValue = AdjustmentValueCache.getCurrentValue().get(symbol); |
|---|
| | | if (currentValue != null) { |
|---|
| | | data.forEach(kline -> { |
|---|
| | | /*logger.info("==currentValue==close:{}, low:{}, high:{}, open:{}, currentValue:{}", |
|---|
| | | kline.getClose(), kline.getLow(), kline.getHigh(), kline.getOpen(), currentValue);*/ |
|---|
| | | if (!kline.isAdjusted()){ |
|---|
| | | if (kline.getClose().compareTo(kline.getLow()) >= 0 && kline.getClose().compareTo(kline.getHigh()) <= 0) { |
|---|
| | | kline.setClose(kline.getClose().add(currentValue)); |
|---|
| | | } |
|---|
| | | kline.setOpen(kline.getOpen().add(currentValue)); |
|---|
| | | kline.setLow(kline.getLow().add(currentValue)); |
|---|
| | | kline.setHigh(kline.getHigh().add(currentValue)); |
|---|
| | | kline.setAdjusted(true); |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | } |
|---|
| | | return Result.succeed(this.build(data, line, symbol)); |
|---|
