内网gitea库

README.md

@@ -10,4 +10,4 @@ git submodule update --force --recursive --init --remote
 go mod tidy
 go mod vendor
 
-
+加入内网gitea库

candle.go

@@ -190,15 +190,17 @@ func (core *Core) SaveCandle(instId string, period string, rsp *CandleData, dura
 		cs := CandleSegment{}
 		sv, _ := json.Marshal(v)
 		json.Unmarshal(sv, &cs)
-		logrus.Warn("fetch segments2:", cs)
 		if !cs.Enabled {
 			continue
 		}
+		logrus.Warn("fetch segments2: cs.Seg: ", cs.Seg, ", period:", period, ", cs.Seg == period: ", (cs.Seg == period))
+
 		if cs.Seg == period {
 			curSegStartTime = cs.StartTime
+			break
 		}
-		break
 	}
+	logrus.Warn("curSegStartTime:", curSegStartTime)
 	curTm, _ := time.ParseInLocation("2006-01-02 15:04.000", curSegStartTime, time.Local)
 	curTmi := curTm.UnixMilli()
 
@@ -215,7 +217,8 @@ func (core *Core) SaveCandle(instId string, period string, rsp *CandleData, dura
 			continue
 		}
 		minutes, _ := core.PeriodToMinutes(period)
-		if (tmi-curTmi)/(minutes*1000000) != 0 {
+		logrus.Warn("tmi: ", tmi, " curTim:", curTmi, " minutes: ", minutes)
+		if (tmi-curTmi)%(minutes*60000) != 0 {
 			logrus.Warn("saveCandles error: 当前记录中的时间戳：", curSegStartTime, "，并非周期节点：", period, " 忽略")
 			continue
 		}