From b05f9e21526ff2257a987fd386010ce863c6af45 Mon Sep 17 00:00:00 2001 From: meixiongfeng <766881921@qq.com> Date: Sun, 31 Dec 2023 20:58:30 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=80=E4=B8=AA=E5=BE=88=E5=9D=91=E7=9A=84bu?= =?UTF-8?q?g?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- modules/user/model_user.go | 14 +++----------- modules/user/module.go | 13 ++++++++++++- 2 files changed, 15 insertions(+), 12 deletions(-) diff --git a/modules/user/model_user.go b/modules/user/model_user.go index 2d94c0d80..1f64a9f36 100644 --- a/modules/user/model_user.go +++ b/modules/user/model_user.go @@ -287,12 +287,10 @@ func (this *ModelUser) computeLevel(change *pb.UserResChangedPush) (lvchange boo return } -func (this *ModelUser) changelv(session comm.IUserSession, lv int32, exp int64, name string, rewards []*cfg.Gameatn) { +func (this *ModelUser) changelv(session comm.IUserSession, lv int32, exp int64, name string) { go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { var ( - atno []*pb.UserAtno - errdata *pb.ErrorData - tasks []*pb.BuriedParam = make([]*pb.BuriedParam, 0) + tasks []*pb.BuriedParam = make([]*pb.BuriedParam, 0) ) if err := session.SendMsg(string(this.module.GetType()), UserSubTypeLvChangedPush, &pb.UserLvChangedPush{Uid: session.GetUserId(), Exp: exp, Lv: lv}); err != nil { @@ -302,17 +300,11 @@ func (this *ModelUser) changelv(session comm.IUserSession, lv int32, exp int64, log.Field{Key: "lv", Value: lv}, ) } - if errdata, atno = this.module.DispenseAtno(session, rewards, true); errdata != nil { - this.module.Error("资源发放", - log.Field{Key: "uid", Value: session.GetUserId()}, - log.Field{Key: "rewards", Value: rewards}, - ) - } + this.module.chat.SendSysChatToUser(session, comm.ChatSystem12, lv, 0, name) this.module.ModuleSys.CheckOpenCond(session.Clone(), comm.OpencondTypePlatlv, lv) tasks = append(tasks, comm.GetBuriedParam(comm.Rtype20, lv)) this.module.ModuleBuried.TriggerBuried(session, tasks...) - this.module.WriteUserLog(session.GetUserId(), fmt.Sprintf(" lv :%d, exp %d, name %s", lv, exp, name), comm.GMResAddType, "changelv", atno) }) } diff --git a/modules/user/module.go b/modules/user/module.go index 503d060c3..9be69ec32 100644 --- a/modules/user/module.go +++ b/modules/user/module.go @@ -574,7 +574,18 @@ func (this *User) change(session comm.IUserSession, attrs map[string]int32) (atn } change.Exp += int64(add) if lvchange, loseexp, rewards = this.modelUser.computeLevel(change); lvchange { - this.modelUser.changelv(session, change.Lv, change.Exp, user.Name, rewards) + this.modelUser.changelv(session, change.Lv, change.Exp, user.Name) + defer func() { + go func() { + if err, res := this.DispenseAtno(session, rewards, true); err == nil { + this.WriteUserLog(session.GetUserId(), fmt.Sprintf("userlv change"), comm.GMResAddType, "changelv", res) + } else { + this.Errorf("err:%v", err) + } + + }() + }() + } temp.N = temp.N - loseexp case comm.VipExp: