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

更新好友推荐

Browse Source
This commit is contained in:
wh_zcy 2023-01-17 11:28:43 +08:00
parent b441c4b272
commit a6cd1233f6
2 changed files with 18 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
modules/sociaty/model_sociatyboss.go
View File

@ -455,10 +455,6 @@ func (s *ModelSociatyBoss) resetSportsData() error {
var record []*pb.DBSociatyBossRecord
_ = s.GetList(uid, &record)
for _, v := range record {
// update := map[string]interface{}{
// "status": 1, //归档
// "tasks": []*pb.ChallengeTask{},
// }
if err := s.DelByUId(uid); err != nil {
s.moduleSociaty.Error("清理玩家赛季记录", log.Field{Key: "uid", Value: v.Uid}, log.Field{Key: "err", Value: err.Error()})
}
@ -555,11 +551,10 @@ func (s *ModelSociatyBoss) settlement() error {
s.addSociatyRank(uid, total)
s.moduleSociaty.Debug("结算:", log.Field{Key: "uid", Value: uid})
//归档赛季记录
if err := s.AddList(comm.RDS_EMPTY, uid, cr); err != nil {
s.moduleSociaty.Error("归档玩家赛季数据", log.Field{Key: "err", Value: err.Error()})
}
}
//归档前10的玩家记录
return nil
}

19
modules/user/module.go
View File

@ -180,13 +180,24 @@ func (this *User) UserOnlineList() ([]*pb.CacheUser, error) {
// 跨服玩家列表
func (this *User) CrossUserOnlineList() ([]*pb.CacheUser, error) {
reply := &pb.UserOnlineResp{}
err := this.service.AcrossClusterRpcCall(context.Background(), this.GetCrossTag(),
comm.Service_Worker, Rpc_GetAllOnlineUser, nil, reply)
conn, err := db.Local()
if err != nil {
return nil, err
}
return reply.Users, err
model := db.NewDBModel(comm.TableSession, 0, conn)
var cache []*pb.CacheUser
if err := model.GetList(comm.RDS_EMPTY, &cache); err != nil {
return nil, err
}
return cache, nil
// reply := &pb.UserOnlineResp{}
// err := this.service.AcrossClusterRpcCall(context.Background(), this.GetCrossTag(),
// comm.Service_Worker, Rpc_GetAllOnlineUser, nil, reply)
// if err != nil {
// return nil, err
// }
// return reply.Users, err
}
// 跨服玩家会话