improved indicators

22388o · Apr 14, 2022 · f866787 · f866787
1 parent 88e1384
commit f866787
Show file tree

Hide file tree

Showing 6 changed files with 6 additions and 6 deletions.
diff --git a/pkg/indicator/ad.go b/pkg/indicator/ad.go
@@ -62,7 +62,7 @@ var _ types.Series = &AD{}
 
 func (inc *AD) calculateAndUpdate(kLines []types.KLine) {
 	for _, k := range kLines {
-		if inc.EndTime != zeroTime && k.EndTime.Before(inc.EndTime) {
+		if inc.EndTime != zeroTime && !k.EndTime.After(inc.EndTime) {
 			continue
 		}
 		inc.Update(k)

diff --git a/pkg/indicator/macd.go b/pkg/indicator/macd.go
@@ -68,7 +68,7 @@ func (inc *MACD) calculateAndUpdate(kLines []types.KLine) {
 	var priceF = KLineClosePriceMapper
 
 	for _, k := range kLines {
-		if inc.EndTime != zeroTime && k.EndTime.Before(inc.EndTime) {
+		if inc.EndTime != zeroTime && !k.EndTime.After(inc.EndTime) {
 			continue
 		}
 		inc.Update(k, priceF)

diff --git a/pkg/indicator/obv.go b/pkg/indicator/obv.go
@@ -50,7 +50,7 @@ func (inc *OBV) calculateAndUpdate(kLines []types.KLine) {
 	var priceF = KLineClosePriceMapper
 
 	for _, k := range kLines {
-		if inc.EndTime != zeroTime && k.EndTime.Before(inc.EndTime) {
+		if inc.EndTime != zeroTime && !k.EndTime.After(inc.EndTime) {
 			continue
 		}
 		inc.Update(k, priceF)

diff --git a/pkg/indicator/rsi.go b/pkg/indicator/rsi.go
@@ -81,7 +81,7 @@ func (inc *RSI) calculateAndUpdate(kLines []types.KLine) {
 	var priceF = KLineClosePriceMapper
 
 	for _, k := range kLines {
-		if inc.EndTime != zeroTime && k.EndTime.Before(inc.EndTime) {
+		if inc.EndTime != zeroTime && !k.EndTime.After(inc.EndTime) {
 			continue
 		}
 		inc.Update(k, priceF)

diff --git a/pkg/indicator/stoch.go b/pkg/indicator/stoch.go
@@ -61,7 +61,7 @@ func (inc *STOCH) calculateAndUpdate(kLines []types.KLine) {
 	}
 
 	for _, k := range kLines {
-		if inc.EndTime != zeroTime && k.EndTime.Before(inc.EndTime) {
+		if inc.EndTime != zeroTime && !k.EndTime.After(inc.EndTime) {
 			continue
 		}
 		inc.update(k)

diff --git a/pkg/indicator/vwap.go b/pkg/indicator/vwap.go
@@ -74,7 +74,7 @@ func (inc *VWAP) calculateAndUpdate(kLines []types.KLine) {
 	var priceF = KLineTypicalPriceMapper
 
 	for _, k := range kLines {
-		if inc.EndTime != zeroTime && k.EndTime.Before(inc.EndTime) {
+		if inc.EndTime != zeroTime && !k.EndTime.After(inc.EndTime) {
 			continue
 		}
 		inc.Update(k, priceF)