From 3d00fca1dbff0b6a318f4977cec010a919ee410c Mon Sep 17 00:00:00 2001
From: eson <eson.hsm@nonolive.com>
Date: Wed, 9 Dec 2020 10:41:55 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E6=9C=80=E6=96=B0=E6=95=B0?=
=?UTF-8?q?=E6=8D=AE.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
main.go | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
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)
}
}
}