Compare commits
4 Commits
34698ddc60
...
af1fe8d3bc
Author | SHA1 | Date | |
---|---|---|---|
af1fe8d3bc | |||
a649050155 | |||
d446065b0e | |||
1fe4cd65a8 |
@ -16,7 +16,7 @@ func (e *CustomError) Error() string {
|
||||
return e.Code.String()
|
||||
}
|
||||
|
||||
func NewCustomError(errdata *pb.ErrorData) error {
|
||||
func NewCustomError(code pb.ErrorCode) error {
|
||||
// 初次调用得用Wrap方法,进行实例化
|
||||
return errors.Wrap(&CustomError{
|
||||
Code: code,
|
||||
|
@ -19,50 +19,60 @@ func (a *apiComp) AcceptCheck(session comm.IUserSession, req *pb.WorldtaskAccept
|
||||
}
|
||||
|
||||
func (a *apiComp) Accept(session comm.IUserSession, req *pb.WorldtaskAcceptReq) (errdata *pb.ErrorData) {
|
||||
if code = a.AcceptCheck(session, req); errdata != nil {
|
||||
if errdata = a.AcceptCheck(session, req); errdata != nil {
|
||||
return
|
||||
}
|
||||
data = &pb.ErrorData{}
|
||||
|
||||
uid := session.GetUserId()
|
||||
user := a.module.ModuleUser.GetUser(uid)
|
||||
if user == nil {
|
||||
code = pb.ErrorCode_UserSessionNobeing
|
||||
data.Title = code.ToString()
|
||||
data.Datastring = uid
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_UserSessionNobeing,
|
||||
Title: pb.ErrorCode_UserSessionNobeing.ToString(),
|
||||
Datastring: uid,
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
rsp := &pb.WorldtaskAcceptResp{}
|
||||
myWorldtask, err := a.module.modelWorldtask.getWorldtask(uid)
|
||||
if err != nil {
|
||||
code = pb.ErrorCode_DBError
|
||||
data.Title = code.ToString()
|
||||
data.Datastring = uid
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_DBError,
|
||||
Title: pb.ErrorCode_DBError.ToString(),
|
||||
Datastring: uid,
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// 当前任务配置
|
||||
curTaskConf, err := a.module.configure.getWorldtaskById(req.TaskId)
|
||||
if err != nil || curTaskConf == nil {
|
||||
code = pb.ErrorCode_ConfigNoFound
|
||||
data.Title = code.ToString()
|
||||
data.Message = err.Error()
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_ConfigNoFound,
|
||||
Title: pb.ErrorCode_ConfigNoFound.ToString(),
|
||||
Message: err.Error(),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// 判断玩家等级要求
|
||||
if user.Lv < curTaskConf.Lock {
|
||||
code = pb.ErrorCode_WorldtaskLvNotEnough
|
||||
data.Title = code.ToString()
|
||||
data.Message = fmt.Sprintf("实际等级:%d 期望等级:%d", user.Lv, curTaskConf.Lock)
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_WorldtaskLvNotEnough,
|
||||
Title: pb.ErrorCode_WorldtaskLvNotEnough.ToString(),
|
||||
Message: fmt.Sprintf("实际等级:%d 期望等级:%d", user.Lv, curTaskConf.Lock),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// 前置任务ID 只有世界任务才校验前置
|
||||
if !a.module.modelWorldtask.IsPreFinished(req.GroupId, myWorldtask, curTaskConf) {
|
||||
code = pb.ErrorCode_WorldtaskLastUnFinished
|
||||
data.Title = code.ToString()
|
||||
data.Message = fmt.Sprintf("%v前置任务%v未完成", curTaskConf.Key, curTaskConf.Ontxe)
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_WorldtaskLastUnFinished,
|
||||
Title: pb.ErrorCode_WorldtaskLastUnFinished.ToString(),
|
||||
Message: fmt.Sprintf("%v前置任务%v未完成", curTaskConf.Key, curTaskConf.Ontxe),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
@ -80,7 +90,10 @@ func (a *apiComp) Accept(session comm.IUserSession, req *pb.WorldtaskAcceptReq)
|
||||
}
|
||||
|
||||
if err := a.module.modelWorldtask.Change(uid, update); err != nil {
|
||||
code = pb.ErrorCode_DBError
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_DBError,
|
||||
Title: pb.ErrorCode_DBError.ToString(),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
|
@ -25,23 +25,29 @@ func (this *apiComp) BattlefinishCheck(session comm.IUserSession, req *pb.Worldt
|
||||
}
|
||||
|
||||
func (this *apiComp) Battlefinish(session comm.IUserSession, req *pb.WorldtaskBattleFinishReq) (errdata *pb.ErrorData) {
|
||||
if code = this.BattlefinishCheck(session, req); errdata != nil {
|
||||
if errdata = this.BattlefinishCheck(session, req); errdata != nil {
|
||||
return
|
||||
}
|
||||
data = &pb.ErrorData{}
|
||||
|
||||
uid := session.GetUserId()
|
||||
taskConf, err := this.module.configure.getWorldtaskById(req.TaskId)
|
||||
if err != nil || taskConf == nil {
|
||||
code = pb.ErrorCode_ConfigNoFound
|
||||
data.Title = code.ToString()
|
||||
data.Message = err.Error()
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_ConfigNoFound,
|
||||
Title: pb.ErrorCode_ConfigNoFound.ToString(),
|
||||
Message: err.Error(),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// 当前玩家世界任务
|
||||
userTask, err := this.module.modelWorldtask.getWorldtask(uid)
|
||||
if err != nil {
|
||||
code = pb.ErrorCode_DBError
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_DBError,
|
||||
Title: pb.ErrorCode_DBError.ToString(),
|
||||
Message: err.Error(),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
@ -49,9 +55,11 @@ func (this *apiComp) Battlefinish(session comm.IUserSession, req *pb.WorldtaskBa
|
||||
|
||||
if len(taskConf.Completetask) == 0 {
|
||||
if err := this.module.modelWorldtask.finishTask(taskConf.Group, req.TaskId, userTask); err != nil {
|
||||
code = pb.ErrorCode_DBError
|
||||
data.Title = code.ToString()
|
||||
data.Message = err.Error()
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_DBError,
|
||||
Title: pb.ErrorCode_DBError.ToString(),
|
||||
Message: err.Error(),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
@ -61,16 +69,20 @@ func (this *apiComp) Battlefinish(session comm.IUserSession, req *pb.WorldtaskBa
|
||||
|
||||
battleModule, err := this.module.service.GetModule(comm.ModuleBattle)
|
||||
if err != nil {
|
||||
code = pb.ErrorCode_SystemError
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_SystemError,
|
||||
Title: pb.ErrorCode_SystemError.ToString(),
|
||||
Message: err.Error(),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
if ibattle, ok := battleModule.(comm.IBattle); ok {
|
||||
var isWin bool
|
||||
if code, isWin = ibattle.CheckBattleReport(session, req.Report); code == pb.ErrorCode_Success {
|
||||
if errdata, isWin = ibattle.CheckBattleReport(session, req.Report); errdata == nil {
|
||||
if isWin {
|
||||
if battleConf, ok := this.module.worldBattleConf.GetDataMap()[req.BattleConfId]; ok {
|
||||
if code = this.module.DispenseRes(session, []*cfg.Gameatn{battleConf.Playexp}, true); errdata != nil {
|
||||
if errdata = this.module.DispenseRes(session, []*cfg.Gameatn{battleConf.Playexp}, true); errdata != nil {
|
||||
this.module.Error("世界任务战斗玩家经验结算",
|
||||
log.Field{Key: "uid", Value: uid},
|
||||
log.Field{Key: "playerExp", Value: battleConf.Playexp},
|
||||
@ -91,7 +103,11 @@ func (this *apiComp) Battlefinish(session comm.IUserSession, req *pb.WorldtaskBa
|
||||
"currentTask": userTask.CurrentTask,
|
||||
}
|
||||
if err := this.module.modelWorldtask.Change(uid, update); err != nil {
|
||||
code = pb.ErrorCode_DBError
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_DBError,
|
||||
Title: pb.ErrorCode_DBError.ToString(),
|
||||
Message: err.Error(),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
@ -100,20 +116,23 @@ func (this *apiComp) Battlefinish(session comm.IUserSession, req *pb.WorldtaskBa
|
||||
}
|
||||
|
||||
} else {
|
||||
data.Title = code.ToString()
|
||||
data.Message = "战报校验错误"
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_ExternalModule,
|
||||
Title: pb.ErrorCode_ExternalModule.ToString(),
|
||||
Message: "战报校验错误",
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
//判断是否配置了通知module
|
||||
if len(taskConf.Module) == 0 {
|
||||
// 发奖
|
||||
if code = this.module.DispenseRes(session, taskConf.Reword, true); errdata != nil {
|
||||
if errdata = this.module.DispenseRes(session, taskConf.Reword, true); errdata != nil {
|
||||
this.module.Error("资源发放",
|
||||
log.Field{Key: "uid", Value: uid},
|
||||
log.Field{Key: "taskId", Value: req.TaskId},
|
||||
log.Field{Key: "reword", Value: taskConf.Reword},
|
||||
log.Field{Key: "code", Value: code},
|
||||
log.Field{Key: "errdata", Value: errdata},
|
||||
)
|
||||
return
|
||||
}
|
||||
|
@ -23,23 +23,28 @@ func (this *apiComp) BattlestartCheck(session comm.IUserSession, req *pb.Worldta
|
||||
}
|
||||
|
||||
func (this *apiComp) Battlestart(session comm.IUserSession, req *pb.WorldtaskBattleStartReq) (errdata *pb.ErrorData) {
|
||||
if code = this.BattlestartCheck(session, req); errdata != nil {
|
||||
if errdata = this.BattlestartCheck(session, req); errdata != nil {
|
||||
return
|
||||
}
|
||||
data = &pb.ErrorData{}
|
||||
resp := &pb.WorldtaskBattleStartResp{}
|
||||
|
||||
battleConf, err := this.module.configure.getWorldtaskBattleById(req.BattleConfId)
|
||||
if err != nil || battleConf == nil {
|
||||
code = pb.ErrorCode_ConfigNoFound
|
||||
data.Title = code.String()
|
||||
data.Message = fmt.Sprintf("战斗配置未找到 %v", req.BattleConfId)
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_ConfigNoFound,
|
||||
Title: pb.ErrorCode_ConfigNoFound.ToString(),
|
||||
Message: fmt.Sprintf("战斗配置未找到 %v", req.BattleConfId),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
iBattle, err := this.module.service.GetModule(comm.ModuleBattle)
|
||||
if err != nil {
|
||||
code = pb.ErrorCode_SystemError
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_SystemError,
|
||||
Title: pb.ErrorCode_SystemError.ToString(),
|
||||
Message: err.Error(),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
@ -47,14 +52,18 @@ func (this *apiComp) Battlestart(session comm.IUserSession, req *pb.WorldtaskBat
|
||||
var (
|
||||
record *pb.DBBattleRecord
|
||||
)
|
||||
code, record = b.CreateEveBattle(session, &pb.BattleEVEReq{
|
||||
errdata, record = b.CreateEveBattle(session, &pb.BattleEVEReq{
|
||||
Ptype: pb.PlayType_rtask,
|
||||
Format: req.Battle,
|
||||
Buleformat: battleConf.FormatList,
|
||||
})
|
||||
|
||||
if errdata != nil {
|
||||
data.Title = code.String()
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_ExternalModule,
|
||||
Title: pb.ErrorCode_ExternalModule.ToString(),
|
||||
Message: "创建Eve战斗失败",
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
@ -73,8 +82,11 @@ func (this *apiComp) Battlestart(session comm.IUserSession, req *pb.WorldtaskBat
|
||||
},
|
||||
}
|
||||
} else {
|
||||
code = pb.ErrorCode_WorldtaskBattleCreate
|
||||
data.Title = code.String()
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_WorldtaskBattleCreate,
|
||||
Title: pb.ErrorCode_WorldtaskBattleCreate.ToString(),
|
||||
Message: "战斗记录是空",
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
|
@ -1,6 +1,7 @@
|
||||
package worldtask
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"go_dreamfactory/comm"
|
||||
"go_dreamfactory/pb"
|
||||
)
|
||||
@ -16,43 +17,57 @@ func (this *apiComp) ChapterrewardCheck(session comm.IUserSession, req *pb.World
|
||||
}
|
||||
|
||||
func (this *apiComp) Chapterreward(session comm.IUserSession, req *pb.WorldtaskChapterrewardReq) (errdata *pb.ErrorData) {
|
||||
if code = this.ChapterrewardCheck(session, req); errdata != nil {
|
||||
if errdata = this.ChapterrewardCheck(session, req); errdata != nil {
|
||||
return
|
||||
}
|
||||
data = &pb.ErrorData{}
|
||||
|
||||
uid := session.GetUserId()
|
||||
rsp := &pb.WorldtaskChapterrewardResp{}
|
||||
myWorldtask, err := this.module.modelWorldtask.getWorldtask(uid)
|
||||
if err != nil {
|
||||
code = pb.ErrorCode_DBError
|
||||
data.Title = code.String()
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_DBError,
|
||||
Title: pb.ErrorCode_DBError.ToString(),
|
||||
Message: err.Error(),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
if stats, ok := myWorldtask.Chapters[req.GroupId]; !ok {
|
||||
code = pb.ErrorCode_WorldtaskChapterUnFinished
|
||||
data.Title = code.String()
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_WorldtaskChapterUnFinished,
|
||||
Title: pb.ErrorCode_WorldtaskChapterUnFinished.ToString(),
|
||||
Message: err.Error(),
|
||||
}
|
||||
return
|
||||
} else {
|
||||
if stats == 2 {
|
||||
code = pb.ErrorCode_WorldtaskChapterReceived
|
||||
data.Title = code.String()
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_WorldtaskChapterReceived,
|
||||
Title: pb.ErrorCode_WorldtaskChapterReceived.ToString(),
|
||||
Message: err.Error(),
|
||||
}
|
||||
return
|
||||
}
|
||||
}
|
||||
|
||||
gwa, err := this.module.configure.getWorldAllCfg()
|
||||
if err != nil || gwa == nil {
|
||||
code = pb.ErrorCode_ConfigNoFound
|
||||
data.Title = code.String()
|
||||
data.Message = err.Error()
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_ConfigNoFound,
|
||||
Title: pb.ErrorCode_ConfigNoFound.ToString(),
|
||||
Message: err.Error(),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
rewardCnf := gwa.GetDataMap()[req.GroupId]
|
||||
if rewardCnf == nil {
|
||||
code = pb.ErrorCode_ConfigNoFound
|
||||
data.Title = code.String()
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_ConfigNoFound,
|
||||
Title: pb.ErrorCode_ConfigNoFound.ToString(),
|
||||
Message: fmt.Sprintf("未找到组%v配置", req.GroupId),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
|
@ -8,48 +8,61 @@ import (
|
||||
// 任务完成条件
|
||||
func (this *apiComp) CompleteCondiCheck(session comm.IUserSession, req *pb.WorldtaskCompleteCondiReq) (errdata *pb.ErrorData) {
|
||||
if req.GroupId <= 0 || req.TaskId <= 0 || req.CondiId <= 0 {
|
||||
code = *pb.ErrorCode_ReqParameterError.Enum()
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_ReqParameterError,
|
||||
Title: pb.ErrorCode_ReqParameterError.ToString(),
|
||||
}
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
func (this *apiComp) CompleteCondi(session comm.IUserSession, req *pb.WorldtaskCompleteCondiReq) (errdata *pb.ErrorData) {
|
||||
if code = this.CompleteCondiCheck(session, req); errdata != nil {
|
||||
if errdata = this.CompleteCondiCheck(session, req); errdata != nil {
|
||||
return
|
||||
}
|
||||
data = &pb.ErrorData{}
|
||||
|
||||
rsp := &pb.WorldtaskCompleteCondiResp{}
|
||||
uid := session.GetUserId()
|
||||
|
||||
// 当前任务配置
|
||||
curTaskConf, err := this.module.configure.getWorldtaskById(req.TaskId)
|
||||
if err != nil || curTaskConf == nil {
|
||||
code = pb.ErrorCode_ConfigNoFound
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_ConfigNoFound,
|
||||
Title: pb.ErrorCode_ConfigNoFound.ToString(),
|
||||
Message: err.Error(),
|
||||
}
|
||||
return
|
||||
}
|
||||
if (len(curTaskConf.Completetask) == 1 && curTaskConf.Completetask[0] == 0) ||
|
||||
len(curTaskConf.Completetask) == 0 {
|
||||
code = pb.ErrorCode_WorldtaskNoProcess
|
||||
data.Title = code.ToString()
|
||||
data.Message = "无完成条件"
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_WorldtaskNoProcess,
|
||||
Title: pb.ErrorCode_WorldtaskNoProcess.ToString(),
|
||||
Message: "无完成条件",
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
myWorldtask, err := this.module.modelWorldtask.getWorldtask(uid)
|
||||
if err != nil {
|
||||
code = pb.ErrorCode_DBError
|
||||
data.Title = code.ToString()
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_DBError,
|
||||
Title: pb.ErrorCode_DBError.ToString(),
|
||||
Message: err.Error(),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
myWorldtask.Uid = uid
|
||||
wt := myWorldtask.CurrentTask[req.GroupId]
|
||||
|
||||
conds, err := this.module.ModuleBuried.CheckCondition(uid, req.CondiId)
|
||||
if err != nil {
|
||||
code = pb.ErrorCode_ExternalModule
|
||||
data.Title = code.ToString()
|
||||
data.Message = comm.NewExternalModuleErr("buried", "CheckCondition", uid, req.CondiId).Error()
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_ExternalModule,
|
||||
Title: pb.ErrorCode_ExternalModule.ToString(),
|
||||
Message: comm.NewExternalModuleErr("buried", "CheckCondition", uid, req.CondiId).Error(),
|
||||
}
|
||||
}
|
||||
for _, cond := range conds {
|
||||
if cond.State == pb.BuriedItemFinishState_buried_finish {
|
||||
@ -63,7 +76,11 @@ func (this *apiComp) CompleteCondi(session comm.IUserSession, req *pb.WorldtaskC
|
||||
"currentTask": myWorldtask.CurrentTask,
|
||||
}
|
||||
if err := this.module.modelWorldtask.Change(uid, update); err != nil {
|
||||
code = pb.ErrorCode_DBError
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_DBError,
|
||||
Title: pb.ErrorCode_DBError.ToString(),
|
||||
Message: err.Error(),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
|
@ -23,10 +23,9 @@ func (this *apiComp) FinishCheck(session comm.IUserSession, req *pb.WorldtaskFin
|
||||
}
|
||||
|
||||
func (this *apiComp) Finish(session comm.IUserSession, req *pb.WorldtaskFinishReq) (errdata *pb.ErrorData) {
|
||||
if code = this.FinishCheck(session, req); errdata != nil {
|
||||
if errdata = this.FinishCheck(session, req); errdata != nil {
|
||||
return
|
||||
}
|
||||
data = &pb.ErrorData{}
|
||||
uid := session.GetUserId()
|
||||
|
||||
rsp := &pb.WorldtaskFinishResp{}
|
||||
@ -34,47 +33,61 @@ func (this *apiComp) Finish(session comm.IUserSession, req *pb.WorldtaskFinishRe
|
||||
// 获取用户信息
|
||||
user := this.module.ModuleUser.GetUser(uid)
|
||||
if user == nil {
|
||||
code = pb.ErrorCode_UserSessionNobeing
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_UserSessionNobeing,
|
||||
Title: pb.ErrorCode_UserSessionNobeing.ToString(),
|
||||
Datastring: uid,
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// 当前任务配置
|
||||
curTaskConf, err := this.module.configure.getWorldtaskById(req.TaskId)
|
||||
if err != nil || curTaskConf == nil {
|
||||
code = pb.ErrorCode_ConfigNoFound
|
||||
data.Title = code.ToString()
|
||||
data.Message = err.Error()
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_ConfigNoFound,
|
||||
Title: pb.ErrorCode_ConfigNoFound.ToString(),
|
||||
Message: err.Error(),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
if curTaskConf.Group != req.GroupId {
|
||||
code = pb.ErrorCode_WorldtaskGroupIdNosame
|
||||
data.Title = code.ToString()
|
||||
data.Message = fmt.Sprintf("组ID一致,实际:%d 期望:%d", curTaskConf.Group, req.GroupId)
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_WorldtaskGroupIdNosame,
|
||||
Title: pb.ErrorCode_WorldtaskGroupIdNosame.ToString(),
|
||||
Message: fmt.Sprintf("组ID一致,实际:%d 期望:%d", curTaskConf.Group, req.GroupId),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
if curTaskConf.DeliverNpc == 0 {
|
||||
code = pb.ErrorCode_WorldtaskNoProcess
|
||||
data.Title = code.ToString()
|
||||
data.Message = "配置DeliverNpc字段是0"
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_WorldtaskNoProcess,
|
||||
Title: pb.ErrorCode_WorldtaskNoProcess.ToString(),
|
||||
Message: "配置DeliverNpc字段是0",
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// 判断玩家等级要求
|
||||
if user.Lv < curTaskConf.Lock {
|
||||
code = pb.ErrorCode_WorldtaskLvNotEnough
|
||||
data.Title = code.ToString()
|
||||
data.Message = fmt.Sprintf("实际等级:%d 期望等级:%d", user.Lv, curTaskConf.Lock)
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_WorldtaskLvNotEnough,
|
||||
Title: pb.ErrorCode_WorldtaskLvNotEnough.ToString(),
|
||||
Message: fmt.Sprintf("实际等级:%d 期望等级:%d", user.Lv, curTaskConf.Lock),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// 当前玩家世界任务
|
||||
userTask, err := this.module.modelWorldtask.getWorldtask(uid)
|
||||
if err != nil {
|
||||
code = pb.ErrorCode_DBError
|
||||
data.Title = code.ToString()
|
||||
data.Message = err.Error()
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_DBError,
|
||||
Title: pb.ErrorCode_DBError.ToString(),
|
||||
Message: err.Error(),
|
||||
}
|
||||
return
|
||||
}
|
||||
if userTask.Uid == "" {
|
||||
@ -83,9 +96,11 @@ func (this *apiComp) Finish(session comm.IUserSession, req *pb.WorldtaskFinishRe
|
||||
|
||||
// 前置任务ID 只有世界任务才校验前置
|
||||
if !this.module.modelWorldtask.IsPreFinished(req.GroupId, userTask, curTaskConf) {
|
||||
code = pb.ErrorCode_WorldtaskLastUnFinished
|
||||
data.Title = code.ToString()
|
||||
data.Message = fmt.Sprintf("任务[%v]的前置任务 [%v] 未完成", curTaskConf.Key, curTaskConf.Ontxe)
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_WorldtaskLastUnFinished,
|
||||
Title: pb.ErrorCode_WorldtaskLastUnFinished.ToString(),
|
||||
Message: fmt.Sprintf("任务[%v]的前置任务 [%v] 未完成", curTaskConf.Key, curTaskConf.Ontxe),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
@ -109,9 +124,9 @@ func (this *apiComp) Finish(session comm.IUserSession, req *pb.WorldtaskFinishRe
|
||||
if _, ok := utils.Findx(v.CondiIds, condId); !ok {
|
||||
conds, err := this.module.ModuleBuried.CheckCondition(uid, condId)
|
||||
if err != nil {
|
||||
code = pb.ErrorCode_ExternalModule
|
||||
data = &pb.ErrorData{
|
||||
Title: code.ToString(),
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_ExternalModule,
|
||||
Title: pb.ErrorCode_ExternalModule.ToString(),
|
||||
Message: comm.NewExternalModuleErr("Buried", "CheckCondition", uid, condId).Error(),
|
||||
}
|
||||
return
|
||||
@ -128,26 +143,30 @@ func (this *apiComp) Finish(session comm.IUserSession, req *pb.WorldtaskFinishRe
|
||||
}
|
||||
|
||||
if !condiFlag {
|
||||
code = pb.ErrorCode_RtaskCondiNoReach
|
||||
data.Title = code.ToString()
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_RtaskCondiNoReach,
|
||||
Title: pb.ErrorCode_RtaskCondiNoReach.ToString(),
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// 完成任务
|
||||
if err := this.module.modelWorldtask.finishTask(req.GroupId, req.TaskId, userTask); err != nil {
|
||||
code = pb.ErrorCode_WorldtaskFinish
|
||||
data.Title = code.ToString()
|
||||
data.Message = err.Error()
|
||||
errdata = &pb.ErrorData{
|
||||
Code: pb.ErrorCode_WorldtaskFinish,
|
||||
Title: pb.ErrorCode_WorldtaskFinish.ToString(),
|
||||
Message: err.Error(),
|
||||
}
|
||||
return
|
||||
}
|
||||
// 发奖
|
||||
if code = this.module.DispenseRes(session, curTaskConf.Reword, true); errdata != nil {
|
||||
if errdata = this.module.DispenseRes(session, curTaskConf.Reword, true); errdata != nil {
|
||||
this.module.Error("资源发放",
|
||||
log.Field{Key: "uid", Value: uid},
|
||||
log.Field{Key: "groupId", Value: req.GroupId},
|
||||
log.Field{Key: "taskId", Value: req.TaskId},
|
||||
log.Field{Key: "reword", Value: curTaskConf.Reword},
|
||||
log.Field{Key: "code", Value: code},
|
||||
log.Field{Key: "errdata", Value: errdata},
|
||||
)
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user