获得隐藏积分

This commit is contained in:
meixiongfeng 2024-01-23 18:08:03 +08:00
parent 22bcc92e0d
commit 692d69d0ba
5 changed files with 43 additions and 2 deletions

View File

@ -221,6 +221,8 @@ type (
PsConvertExp(ps int32) (res *cfg.Gameatn)
CleanUserConsumeMoney(session IUserSession) (err error)
// 增加隐藏分
AddUserHidenum(session IUserSession, score int32) (err error)
}
//武器模块
IEquipment interface {

View File

@ -71,7 +71,7 @@ func (this *modelLand) createPlunderLandData(uid string) (land *pb.DBPlunderLand
}
uids = append(uids, uid) // 优先加入自己
uInfos = append(uInfos, comm.GetUserBaseInfo(user))
cur, err := this.DB.Find(core.SqlTable(comm.TableUser), bson.M{"gold": bson.M{"$gte": limtSocre}, "name": bson.M{"$ne": ""}}, options.Find().SetSkip(int64(0)).SetLimit(int64(30)))
cur, err := this.DB.Find(core.SqlTable(comm.TableUser), bson.M{"plunder": bson.M{"$gte": limtSocre}, "name": bson.M{"$ne": ""}}, options.Find().SetSkip(int64(0)).SetLimit(int64(30)))
for cur.Next(context.TODO()) {
tmp := &pb.DBUser{}
if err = cur.Decode(tmp); err == nil {

View File

@ -136,7 +136,7 @@ func (this *modelPlunder) queryPlunderInfos(uids []string, landid string) (data
results = make([]*pb.DBPlunder, 0)
mp = make(map[string]struct{})
if _, err = this.Gets(uids, &results); err != nil {
if _, err = this.GetByUids(uids, &results); err != nil {
this.module.Errorln(err)
return
}

View File

@ -45,6 +45,9 @@ func (this *ModelUser) Init(service core.IService, module core.IModule, comp cor
this.DB.CreateIndex(core.SqlTable(this.TableName), mongo.IndexModel{
Keys: bsonx.Doc{{Key: "merchantmoney", Value: bsonx.Int32(1)}},
})
this.DB.CreateIndex(core.SqlTable(this.TableName), mongo.IndexModel{
Keys: bsonx.Doc{{Key: "plunder", Value: bsonx.Int32(1)}},
})
return
}
@ -420,3 +423,36 @@ func (this *ModelUser) CleanUserConsumeMoney(session comm.IUserSession) (err err
}
return
}
func (this *ModelUser) AddUserHidenum(uid string, score int32) (err error) {
var (
user *pb.DBUser
)
user = &pb.DBUser{}
if this.module.IsCross() {
var model *db.DBModel
if model, err = this.module.GetDBModelByUid(uid, this.TableName); err != nil {
this.module.Errorln(err)
} else {
if err = model.Get(uid, user); err != nil {
this.module.Errorf("uid:%s err:%v", uid, err)
}
if err = model.Change(uid, map[string]interface{}{
"plunder": user.Plunder + score,
}); err != nil {
this.module.Errorf("uid:%s err:%v", uid, err)
}
}
} else {
if err = this.Get(uid, user); err != nil {
this.module.Errorf("uid:%s err:%v", uid, err)
}
if err = this.Change(uid, map[string]interface{}{
"plunder": user.Plunder + score,
}); err != nil {
this.module.Errorf("uid:%s err:%v", uid, err)
}
}
return
}

View File

@ -1476,3 +1476,6 @@ func (this *User) PsConvertExp(ps int32) (res *cfg.Gameatn) {
func (this *User) CleanUserConsumeMoney(session comm.IUserSession) (err error) {
return this.modelUser.CleanUserConsumeMoney(session)
}
func (this *User) AddUserHidenum(session comm.IUserSession, score int32) (err error) {
return this.modelUser.AddUserHidenum(session.GetUserId(), score)
}