liwei_3d/go_dreamfactory
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Merge branch 'dev' of http://git.legu.cc/liwei_3d/go_dreamfactory into dev

Browse Source
This commit is contained in:
liwei1dao 2023-01-31 10:44:33 +08:00
commit ebbb0c9e5d
2 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
modules/gateway/agent.go
View File

@ -89,7 +89,8 @@ locp:
SubType: "heartbeat", SubType: "heartbeat",
Data: data, Data: data,
}) })
//this.wsConn.SetReadDeadline(time.Now().Add(time.Second * 30))
//this.wsConn.SetReadDeadline(configure.Now().Add(time.Second * 30))
continue continue
} }
if err := this.messageDistribution(msg); err != nil { if err := this.messageDistribution(msg); err != nil {

7
modules/pagoda/model_rank.go
View File

@ -16,6 +16,8 @@ import (
"github.com/go-redis/redis/v8" "github.com/go-redis/redis/v8"
"go.mongodb.org/mongo-driver/bson/primitive" "go.mongodb.org/mongo-driver/bson/primitive"
"go.mongodb.org/mongo-driver/mongo"
"go.mongodb.org/mongo-driver/x/bsonx"
) )
var floorRankKey = "pagoda:floor" var floorRankKey = "pagoda:floor"
@ -29,6 +31,11 @@ func (this *ModelRank) Init(service core.IService, module core.IModule, comp cor
this.TableName = comm.TablePagodaRecord this.TableName = comm.TablePagodaRecord
err = this.MCompModel.Init(service, module, comp, options) err = this.MCompModel.Init(service, module, comp, options)
this.modulePagoda = module.(*Pagoda) this.modulePagoda = module.(*Pagoda)
//创建uid索引
this.DB.CreateIndex(core.SqlTable(comm.TableMail), mongo.IndexModel{
Keys: bsonx.Doc{{Key: "uid", Value: bsonx.Int32(1)}},
})
return return
} }