| | |
| | | } |
| | | } |
| | | |
| | | BigDecimal currentValue = AdjustmentValueCache.getCurrentValue().get(symbol); |
| | | /*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);*/ |
| | | *//*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.setAdjusted(true); |
| | | } |
| | | }); |
| | | } |
| | | }*/ |
| | | return Result.succeed(this.build(data, line, symbol)); |
| | | } catch (Exception e) { |
| | | logger.error("getKline error", e); |