test/databoard-transform
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

fix(time): mongo query error

Browse Source
This commit is contained in:
eson 2020-12-09 18:18:09 +08:00
parent c4e6ac8fb4
commit 487ce31c4c
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
collect.go
View File

@ -16,20 +16,28 @@ import (
func collectCopyCountLiveAnchors(cxt *WorkerContext) {
defer cxt.Done()
var err error
var ok bool
for !ps.IsClose() {
liveanchor := &CountLiveAnchors{}
ok, err := db.T.CountLiveAnchors.OrderBy("create_at desc").Limit(1).Get(liveanchor)
ok, err = db.T.CountLiveAnchors.OrderBy("create_at desc").Limit(1).Get(liveanchor)
if ok || (ok == false && err == nil) {
var cur *mongo.Cursor
var last time.Time
if ok == false {
cur, err = mdb.C.CountLiveAnchors.Find(context.TODO(), bson.M{"create_at": bson.M{"$gt": "2020-05-30"}})
last, err = time.ParseInLocation("2006-01-02", "2020-05-30", time.Local)
if err != nil {
panic(err)
}
cur, err = mdb.C.CountLiveAnchors.Find(context.TODO(), bson.M{"create_at": bson.M{"$gt": last}})
} else {
last := liveanchor.CreateAt
last = liveanchor.CreateAt
log.Println("last: ", last)
cur, err = mdb.C.CountLiveAnchors.Find(context.TODO(), bson.M{"create_at": bson.M{"$gt": last}})
}
if err != nil {
log.Println(err)
ps.Wait(time.Second * 5)