package com.xcong.excoin.modules.okxNewPrice.indicator;
|
|
import lombok.Getter;
|
import lombok.Setter;
|
import lombok.extern.slf4j.Slf4j;
|
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.util.List;
|
|
/**
|
* BOLL (Bollinger Bands) 指标实现
|
* 计算逻辑：
|
* 1. 中轨（MB）= N日移动平均线
|
* 2. 上轨（UP）= 中轨 + K倍标准差
|
* 3. 下轨（DN）= 中轨 - K倍标准差
|
*/
|
@Slf4j
|
@Getter
|
@Setter
|
public class BOLL extends IndicatorBase {
|
|
private static final int DEFAULT_PERIOD = 20;
|
private static final double DEFAULT_K = 2.0;
|
|
private int period = DEFAULT_PERIOD;
|
private BigDecimal k = new BigDecimal(DEFAULT_K);
|
private BigDecimal mid = BigDecimal.ZERO;
|
private BigDecimal upper = BigDecimal.ZERO;
|
private BigDecimal lower = BigDecimal.ZERO;
|
|
public BOLL() {}
|
|
public BOLL(int period, double k) {
|
this.period = period;
|
this.k = new BigDecimal(k);
|
}
|
|
/**
|
* 计算BOLL指标
|
* @param prices 价格列表
|
*/
|
public void calculate(List<BigDecimal> prices) {
|
if (prices == null || prices.size() < period) {
|
return;
|
}
|
|
// 计算中轨（MB）= N日移动平均线
|
mid = calculateMA(prices, period);
|
|
// 计算标准差
|
BigDecimal stdDev = calculateStdDev(prices, period);
|
|
// 计算上轨（UP）和下轨（DN）
|
BigDecimal bandWidth = k.multiply(stdDev);
|
upper = mid.add(bandWidth).setScale(8, RoundingMode.HALF_UP);
|
lower = mid.subtract(bandWidth).setScale(8, RoundingMode.HALF_UP);
|
|
log.debug("BOLL计算结果 - 中轨: {}, 上轨: {}, 下轨: {}", mid, upper, lower);
|
}
|
|
/**
|
* 判断价格是否突破上轨
|
* @param price 当前价格
|
* @return 是否突破上轨
|
*/
|
public boolean isBreakUpper(BigDecimal price) {
|
return price.compareTo(upper) > 0;
|
}
|
|
/**
|
* 判断价格是否跌破下轨
|
* @param price 当前价格
|
* @return 是否跌破下轨
|
*/
|
public boolean isBreakLower(BigDecimal price) {
|
return price.compareTo(lower) < 0;
|
}
|
|
/**
|
* 判断价格是否回归上轨下方
|
* @param price 当前价格
|
* @param prevPrice 前一期价格
|
* @return 是否回归上轨下方
|
*/
|
public boolean isReturnFromUpper(BigDecimal price, BigDecimal prevPrice) {
|
return prevPrice.compareTo(upper) > 0 && price.compareTo(upper) <= 0;
|
}
|
|
/**
|
* 判断价格是否回归下轨上方
|
* @param price 当前价格
|
* @param prevPrice 前一期价格
|
* @return 是否回归下轨上方
|
*/
|
public boolean isReturnFromLower(BigDecimal price, BigDecimal prevPrice) {
|
return prevPrice.compareTo(lower) < 0 && price.compareTo(lower) >= 0;
|
}
|
|
/**
|
* 判断价格是否在中轨上方
|
* @param price 当前价格
|
* @return 是否在中轨上方
|
*/
|
public boolean isAboveMid(BigDecimal price) {
|
return price.compareTo(mid) > 0;
|
}
|
|
/**
|
* 判断价格是否在中轨下方
|
* @param price 当前价格
|
* @return 是否在中轨下方
|
*/
|
public boolean isBelowMid(BigDecimal price) {
|
return price.compareTo(mid) < 0;
|
}
|
|
/**
|
* 计算布林带宽度
|
* @return 布林带宽度
|
*/
|
public BigDecimal calculateBandWidth() {
|
if (mid.compareTo(BigDecimal.ZERO) == 0) {
|
return BigDecimal.ZERO;
|
}
|
return upper.subtract(lower).divide(mid, 8, RoundingMode.HALF_UP);
|
}
|
|
/**
|
* 计算价格相对于布林带的位置
|
* @param price 当前价格
|
* @return 价格位置指标 (-1: 下轨外, 0: 轨道内, 1: 上轨外)
|
*/
|
public int getPricePosition(BigDecimal price) {
|
if (price.compareTo(upper) > 0) {
|
return 1;
|
} else if (price.compareTo(lower) < 0) {
|
return -1;
|
} else {
|
return 0;
|
}
|
}
|
}
|
