blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-04-26 19:46:57 +08:00
Code Issues Packages Projects Releases Wiki Activity

office

Browse Source
This commit is contained in:
wangchuxiao 2022-05-06 16:50:19 +08:00
parent 2cf070a26c
commit f0ed6973c8
1 changed files with 27 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
pkg/common/db/model.go
View File

@ -3,6 +3,8 @@ package db
import ( import (
"Open_IM/pkg/common/config" "Open_IM/pkg/common/config"
"go.mongodb.org/mongo-driver/bson" "go.mongodb.org/mongo-driver/bson"
"go.mongodb.org/mongo-driver/x/bsonx"
//"Open_IM/pkg/common/log" //"Open_IM/pkg/common/log"
"Open_IM/pkg/utils" "Open_IM/pkg/utils"
"fmt" "fmt"
@ -70,38 +72,33 @@ func init() {
opts := options.CreateIndexes().SetMaxTime(10 * time.Second) opts := options.CreateIndexes().SetMaxTime(10 * time.Second)
dataBase := mongoClient.Database(config.Config.Mongo.DBDatabase) dataBase := mongoClient.Database(config.Config.Mongo.DBDatabase)
//cSendLogModels := []mongo.IndexModel{ cSendLogModels := []mongo.IndexModel{
// { {
// Keys: bsonx.Doc{ Keys: bsonx.Doc{
// { {
// Key: "send_id", Key: "send_id",
// }, },
// }, {
// Options: options.Index().SetUnique(true), Key: "send_time",
// }, Value: bsonx.Int32(-1),
// { },
// Keys: bsonx.Doc{ },
// {
// Key: "send_time",
// Value: bsonx.Int32(-1),
// },
// },
// },
//}
//result, err := dataBase.Collection(cSendLog).Indexes().CreateMany(context.Background(), cSendLogModels, opts)
//if err != nil {
// fmt.Println("mongodb create cSendLogModels failed", result, err.Error())
//}
result, err := dataBase.Collection(cSendLog).Indexes().CreateOne(context.Background(), mongo.IndexModel{
Keys: bson.D{
{Key: "send_id"},
{Key: "send_time", Value: -1},
}, },
}, opts)
if err != nil {
fmt.Println("mongodb create cSendLog index failed", result, err.Error())
} }
result, err := dataBase.Collection(cSendLog).Indexes().CreateMany(context.Background(), cSendLogModels, opts)
if err != nil {
fmt.Println("mongodb create cSendLogModels failed", result, err.Error())
}
//result, err := dataBase.Collection(cSendLog).Indexes().CreateOne(context.Background(), mongo.IndexModel{
// Keys: bson.D{
// {Key: "send_id"},
// {Key: "send_time", Value: -1},
// },
//}, opts)
//if err != nil {
// fmt.Println("mongodb create cSendLog index failed", result, err.Error())
//}
cChatModels := []mongo.IndexModel{ cChatModels := []mongo.IndexModel{
{ {