|
|
@@ -71,8 +71,8 @@ func loadAllUser() map[int64]bool {
|
|
|
_id := primitive.NewObjectIDFromTimestamp(time.Now().AddDate(-1, 0, 0))
|
|
|
log.Println("开始加载最近一年活跃用户。。。", _id)
|
|
|
allUser := map[int64]bool{}
|
|
|
- sess := Mgo.GetMgoConn()
|
|
|
- defer Mgo.DestoryMongoConn(sess)
|
|
|
+ sess := Mgo_Log.GetMgoConn()
|
|
|
+ defer Mgo_Log.DestoryMongoConn(sess)
|
|
|
it := sess.DB("qfw").C("jy_gateway_logs").Find(map[string]interface{}{
|
|
|
"_id": map[string]interface{}{
|
|
|
"$gt": _id,
|
