diff --git a/modules/gateway/agent.go b/modules/gateway/agent.go index b0de4c975..09d3cbceb 100644 --- a/modules/gateway/agent.go +++ b/modules/gateway/agent.go @@ -89,7 +89,8 @@ locp: SubType: "heartbeat", Data: data, }) - //this.wsConn.SetReadDeadline(time.Now().Add(time.Second * 30)) + + //this.wsConn.SetReadDeadline(configure.Now().Add(time.Second * 30)) continue } if err := this.messageDistribution(msg); err != nil { diff --git a/modules/pagoda/model_rank.go b/modules/pagoda/model_rank.go index d05160f54..55a66a5d3 100644 --- a/modules/pagoda/model_rank.go +++ b/modules/pagoda/model_rank.go @@ -16,6 +16,8 @@ import ( "github.com/go-redis/redis/v8" "go.mongodb.org/mongo-driver/bson/primitive" + "go.mongodb.org/mongo-driver/mongo" + "go.mongodb.org/mongo-driver/x/bsonx" ) var floorRankKey = "pagoda:floor" @@ -29,6 +31,11 @@ func (this *ModelRank) Init(service core.IService, module core.IModule, comp cor this.TableName = comm.TablePagodaRecord err = this.MCompModel.Init(service, module, comp, options) this.modulePagoda = module.(*Pagoda) + + //创建uid索引 + this.DB.CreateIndex(core.SqlTable(comm.TableMail), mongo.IndexModel{ + Keys: bsonx.Doc{{Key: "uid", Value: bsonx.Int32(1)}}, + }) return }