fix bug

cmd/test/main.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"fmt"
 	"log"
 	"time"
 
@@ -23,7 +24,7 @@ func main() {
 	impl.NewImpl()
 
 	a.NewApiClient()
-	code := "002463.SZ"
+	code := "300541.SZ"
 	end := time.Now().Format("20060102")
 
 	var start string = "20230101"
@@ -38,6 +39,7 @@ func main() {
 		"end_date":   end,
 	}
 
+	log.Println("GetStockDaily", code, start, end)
 	fields := []string{}
 	reply, err := a.TushareClient.Daily(params, fields)
 	if err != nil {
@@ -72,6 +74,7 @@ func main() {
 	}
 
 	if len(records) > 0 {
-		impl.DBService.CreateInBatches(records, 100)
+		fmt.Println("Created", len(records))
+		//impl.DBService.CreateInBatches(records, 100)
 	}
 }

internal/cron/boot.go

@@ -14,6 +14,8 @@ func Boot() {
 		os.MkdirAll("./markdata/", 0755)
 	}
 
+	UpdateTask()
+
 	scheduler := cron.New()
 	// 每天运行3次来更新数据
 	scheduler.AddFunc("0 18 * * *", func() {

internal/logic/a/daily.go

@@ -1,6 +1,7 @@
 package a
 
 import (
+	"encoding/json"
 	"log"
 	"time"
 
@@ -32,7 +33,13 @@ func GetStockDaily() {
 		reply, err := TushareClient.Daily(params, fields)
 		if err != nil {
 			log.Println("ERROR", "GetStockDaily", err)
-			return
+			continue
+		}
+
+		if len(reply.Data.Items) == 0 {
+			json, _ := json.Marshal(reply)
+			log.Println("ERROR", "GetStockDailyReply", string(json))
+			continue
 		}
 
 		records := make([]*models.StockDaily, 0)
@@ -65,7 +72,7 @@ func GetStockDaily() {
 			impl.DBService.CreateInBatches(records, 50)
 		}
 
-		time.Sleep(200 * time.Microsecond)
+		time.Sleep(200 * time.Millisecond)
 
 	}
 

internal/logic/a/fina_indicator.go

@@ -95,7 +95,7 @@ func GetFinaIndicator() {
 			}
 		}
 
-		time.Sleep(200 * time.Microsecond)
+		time.Sleep(200 * time.Millisecond)
 	}
 }
 

internal/logic/a/indicator.go

@@ -73,6 +73,6 @@ func GetStockIndicator() {
 			impl.DBService.CreateInBatches(records, 100)
 		}
 
-		time.Sleep(200 * time.Microsecond)
+		time.Sleep(200 * time.Millisecond)
 	}
 }