diff --git a/internal/logic/a/indicator.go b/internal/logic/a/indicator.go index ae99b5c..70c4a3f 100644 --- a/internal/logic/a/indicator.go +++ b/internal/logic/a/indicator.go @@ -3,23 +3,28 @@ package a import ( "log" "strings" + "time" "git.apinb.com/dataset/stock/internal/impl" "git.apinb.com/dataset/stock/internal/models" ) func GetStockIndicator() { - s, e := ReturnLastDay() + end := time.Now().Format("20060102") for _, code := range GetStockCodes() { + var start string = "20230101" + var last models.StockIndicator + err := impl.DBService.Where("ts_code=?", code).Order("trade_date DESC").First(&last).Error + if err == nil && last.TradeDate != "" { + start = last.TradeDate + } params := map[string]string{ "ts_code": code, - "start_date": s, - "end_date": e, + "start_date": start, + "end_date": end, } - var cnt int64 - impl.DBService.Model(&models.StockDaily{}).Where("ts_code=? and trade_date in (?,?)", code, s, e).Count(&cnt) - if cnt == 2 { + if start == end { continue }