|
|
|
|
package main
|
|
|
|
|
|
|
|
|
|
import (
|
|
|
|
|
"Open_IM/pkg/common/constant"
|
|
|
|
|
"Open_IM/pkg/common/log"
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
func main() {
|
|
|
|
|
log.NewPrivateLog(constant.LogFileName)
|
|
|
|
|
//for {
|
|
|
|
|
// fmt.Println("start delete mongodb expired record")
|
|
|
|
|
// timeUnixBegin := time.Now().Unix()
|
|
|
|
|
// count, _ := db.DB.MgoUserCount()
|
|
|
|
|
// fmt.Println("mongodb record count: ", count)
|
|
|
|
|
// for i := 0; i < count; i++ {
|
|
|
|
|
// time.Sleep(1 * time.Millisecond)
|
|
|
|
|
// uid, _ := db.DB.MgoSkipUID(i)
|
|
|
|
|
// fmt.Println("operate uid: ", uid)
|
|
|
|
|
// err := db.DB.DelUserChat(uid)
|
|
|
|
|
// if err != nil {
|
|
|
|
|
// fmt.Println("operate uid failed: ", uid, err.Error())
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
//
|
|
|
|
|
// timeUnixEnd := time.Now().Unix()
|
|
|
|
|
// costTime := timeUnixEnd - timeUnixBegin
|
|
|
|
|
// if costTime > int64(config.Config.Mongo.DBRetainChatRecords*24*3600) {
|
|
|
|
|
// continue
|
|
|
|
|
// } else {
|
|
|
|
|
// sleepTime := 0
|
|
|
|
|
// if int64(config.Config.Mongo.DBRetainChatRecords*24*3600)-costTime > 24*3600 {
|
|
|
|
|
// sleepTime = 24 * 3600
|
|
|
|
|
// } else {
|
|
|
|
|
// sleepTime = config.Config.Mongo.DBRetainChatRecords*24*3600 - int(costTime)
|
|
|
|
|
// }
|
|
|
|
|
// fmt.Println("sleep: ", sleepTime)
|
|
|
|
|
// time.Sleep(time.Duration(sleepTime) * time.Second)
|
|
|
|
|
// }
|
|
|
|
|
//}
|
|
|
|
|
//for {
|
|
|
|
|
// uidList, err := im_mysql_model.SelectAllUserID()
|
|
|
|
|
// if err != nil {
|
|
|
|
|
// //log.NewError("999999", err.Error())
|
|
|
|
|
// } else {
|
|
|
|
|
// for _, v := range uidList {
|
|
|
|
|
// minSeq, err := commonDB.DB.GetMinSeqFromMongo(v)
|
|
|
|
|
// if err != nil {
|
|
|
|
|
// //log.NewError("999999", "get user minSeq err", err.Error(), v)
|
|
|
|
|
// continue
|
|
|
|
|
// } else {
|
|
|
|
|
// err := commonDB.DB.SetUserMinSeq(v, minSeq)
|
|
|
|
|
// if err != nil {
|
|
|
|
|
// //log.NewError("999999", "set user minSeq err", err.Error(), v)
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
// time.Sleep(time.Duration(100) * time.Millisecond)
|
|
|
|
|
// }
|
|
|
|
|
//
|
|
|
|
|
// }
|
|
|
|
|
//
|
|
|
|
|
//}
|
|
|
|
|
|
|
|
|
|
}
|
