diff --git a/main.go b/main.go index 631ed05..a5d7488 100644 --- a/main.go +++ b/main.go @@ -3,6 +3,7 @@ package main import ( "context" "encoding/json" + "log" "time" _ "github.com/go-sql-driver/mysql" @@ -30,7 +31,11 @@ func main() { cla := engine.Table("count_live_anchors") - cur, err := mdb.C.CountLiveAnchors.Find(context.TODO(), bson.M{}) + start, err := time.ParseInLocation("2006-01-02 15:04:03", "2020-11-30 16:29:17", time.Local) + if err != nil { + panic(err) + } + cur, err := mdb.C.CountLiveAnchors.Find(context.TODO(), bson.M{"create_at": bson.M{"$gte": start}}) if err != nil { panic(err) } @@ -52,7 +57,7 @@ func main() { c.CountMap = string(data) _, err = cla.Insert(c) if err != nil { - panic(err) + log.Println(err) } } }