package moonlv import ( "errors" "go_dreamfactory/comm" "go_dreamfactory/pb" ) // 任务奖励领取 func (this *apiComp) TaskAwardCheck(session comm.IUserSession, req *pb.MoonlvTaskAwardReq) (errdata *pb.ErrorData) { if req.TaskId == 0 { errdata = &pb.ErrorData{ Code: pb.ErrorCode_ReqParameterError, Title: pb.ErrorCode_ReqParameterError.ToString(), } } return } func (this *apiComp) TaskAward(session comm.IUserSession, req *pb.MoonlvTaskAwardReq) (errdata *pb.ErrorData) { var ( atno []*pb.UserAtno list *pb.DBMoonLv err error ) if errdata = this.TaskAwardCheck(session, req); errdata != nil { return } list, err = this.module.modelMoonlv.getMoonlvList(session.GetUserId()) if err != nil { errdata = &pb.ErrorData{ Code: pb.ErrorCode_DBError, Title: pb.ErrorCode_DBError.ToString(), Message: err.Error(), } return } if err := this.module.modelMoonlv.updateTaskRecord(session.GetUserId(), req.TaskId, list); err != nil { var errCustom = new(comm.CustomError) if errors.As(err, &errCustom) { errdata = &pb.ErrorData{ Code: errCustom.Code, Title: errCustom.Code.ToString(), Message: err.Error(), } } else { errdata = &pb.ErrorData{ Code: pb.ErrorCode_DBError, Title: pb.ErrorCode_DBError.ToString(), Message: err.Error(), } } return } if c, err := this.module.configure.GetMoonLvConf(list.Lv); err == nil { if conf, err := this.module.configure.GetMoonLvTaskConfByTaskId(c.TaskGroupId, req.TaskId); err != nil { errdata = &pb.ErrorData{ Code: pb.ErrorCode_ConfigNoFound, Title: pb.ErrorCode_ConfigNoFound.ToString(), Message: err.Error(), } return } else { if errdata, atno = this.module.DispenseAtno(session, conf.TaskReward, true); errdata != nil { return } } } session.SendMsg(string(this.module.GetType()), "taskaward", &pb.MoonlvTaskAwardResp{ TaskId: req.TaskId, Reward: atno, Data: list, }) go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) { this.module.WriteUserLog(session.GetUserId(), comm.GMResAddType, "MoonlvTaskAwardReq", atno) }) return }