diff --git a/modules/mainline/api_levelpass.go b/modules/mainline/api_levelpass.go index c93ac65c0..6f93202b1 100644 --- a/modules/mainline/api_levelpass.go +++ b/modules/mainline/api_levelpass.go @@ -122,6 +122,15 @@ func (this *apiComp) LevelPass(session comm.IUserSession, req *pb.MainlineLevelP UserExp: userExp, }) // 数据推送 + if err = this.module.modelMline.updateMainlineData(session.GetUserId(), info); err != nil { + errdata = &pb.ErrorData{ + Code: pb.ErrorCode_DBError, + Title: pb.ErrorCode_DBError.ToString(), + Message: err.Error(), + } + return + } + tasks = append(tasks, comm.GetBuriedParam(comm.Rtype60, 1)) tasks = append(tasks, comm.GetBuriedParam(comm.Rtype61, 1, int32(req.Level))) go this.module.ModuleBuried.TriggerBuried(session.Clone(), tasks...) diff --git a/modules/wtask/api_accept.go b/modules/wtask/api_accept.go index 707a4dd6e..5e11c76e9 100644 --- a/modules/wtask/api_accept.go +++ b/modules/wtask/api_accept.go @@ -94,6 +94,12 @@ func (this *apiComp) Accept(session comm.IUserSession, req *pb.WTaskAcceptReq) ( session.SendMsg(string(this.module.GetType()), "boxchange", &pb.WTaskBoxChangePush{Boxs: wtask.Boxs}) } + if len(conf.GetItem) > 0 { //接取 获得物品 + if errdata = this.module.DispenseRes(session, conf.GetItem, true); errdata != nil { + return + } + } + if progress, errdata = this.module.pushtaskprogress(session, wtask, false); errdata != nil { return }