This commit is contained in:
meixiongfeng 2022-07-15 13:42:08 +08:00
parent 0d9b59a4c3
commit 2d7405baea
4 changed files with 36 additions and 12 deletions

View File

@ -24,9 +24,23 @@ var user_builders = []*TestCase{
subType: "addres", subType: "addres",
req: &pb.UserAddResReq{ req: &pb.UserAddResReq{
Res: &pb.UserAssets{ Res: &pb.UserAssets{
A: "attr", A: "item",
T: "10011",
N: 13,
},
},
rsp: &pb.UserAddResResp{},
//enabled: true,
},
{
desc: "添加资源",
mainType: string(comm.ModuleUser),
subType: "addres",
req: &pb.UserAddResReq{
Res: &pb.UserAssets{
A: "item",
T: "10001", T: "10001",
N: 12, N: 1,
}, },
}, },
rsp: &pb.UserAddResResp{}, rsp: &pb.UserAddResResp{},

View File

@ -86,6 +86,17 @@ func (this *apiComp) Awaken(session comm.IUserSession, req *pb.HeroAwakenReq) (c
property[awakenData.Phasebonus[0]] += int32(value) property[awakenData.Phasebonus[0]] += int32(value)
} }
this.module.modelHero.mergeMainProperty(session.GetUserId(), _hero.Id, property) this.module.modelHero.mergeMainProperty(session.GetUserId(), _hero.Id, property)
_heroMap := map[string]interface{}{
"juexingLv": _hero.JuexingLv + 1,
}
// 保存数据
err1 = this.module.modelHero.modifyHeroData(session.GetUserId(), _hero.Id, _heroMap)
if err1 != nil {
code = pb.ErrorCode_DBError
this.module.Errorf("update hero skill failed:%v", err1)
return
}
} }
err1 = this.module.modelHero.PushHeroProperty(session, _hero.Id) // 推送属性变化 err1 = this.module.modelHero.PushHeroProperty(session, _hero.Id) // 推送属性变化

View File

@ -20,15 +20,6 @@ func (this *apiComp) AddRes(session comm.IUserSession, req *pb.UserAddResReq) (c
return return
} }
rsp := &pb.UserAddResResp{}
defer func() {
if err := session.SendMsg(string(this.module.GetType()), UserSubTypeAddRes, rsp); err != nil {
code = pb.ErrorCode_SystemError
return
}
}()
user := this.module.modelUser.GetUser(session.GetUserId()) user := this.module.modelUser.GetUser(session.GetUserId())
if user == nil { if user == nil {
code = pb.ErrorCode_UserSessionNobeing code = pb.ErrorCode_UserSessionNobeing
@ -42,6 +33,12 @@ func (this *apiComp) AddRes(session comm.IUserSession, req *pb.UserAddResReq) (c
} }
res = append(res, atn) res = append(res, atn)
code = this.module.DispenseRes(session.GetUserId(), res, true) code = this.module.DispenseRes(session.GetUserId(), res, true)
rsp.Res = req.Res if code == pb.ErrorCode_Success {
rsp := &pb.UserAddResResp{
Res: req.Res,
}
session.SendMsg(string(this.module.GetType()), UserSubTypeAddRes, rsp)
}
return return
} }

View File

@ -122,6 +122,8 @@ func (this *User) AddAttributeValue(uid string, attr string, add int32, bPush bo
} }
_change.Diamond += add _change.Diamond += add
update[comm.ResDiamond] = user.Diamond + add update[comm.ResDiamond] = user.Diamond + add
default:
code = pb.ErrorCode_Unknown
} }
if len(update) == 0 { if len(update) == 0 {