更新测试

This commit is contained in:
zhaocy 2022-07-22 11:45:09 +08:00
parent 9989b8376f
commit 865df37ac3
6 changed files with 30 additions and 32 deletions

View File

@ -27,27 +27,22 @@ var (
// enabled: true, // enabled: true,
next: func(robot *Robot, rsp proto.Message) { next: func(robot *Robot, rsp proto.Message) {
tcs := []*TestCase{} tcs := []*TestCase{}
if r, ok := rsp.(*pb.HeroListResp); ok { if _, ok := rsp.(*pb.HeroListResp); ok {
for _, v := range r.List {
heroId := v.Id
tc := &TestCase{ tc := &TestCase{
desc: "英雄详情", desc: "英雄升级",
mainType: string(comm.ModuleHero), mainType: string(comm.ModuleHero),
subType: hero.HeroSubTypeInfo, subType: hero.StrengthenUplv,
req: &pb.HeroInfoReq{ req: &pb.HeroStrengthenUplvReq{
HeroId: heroId, HeroObjID: "62da0353ebe27f9446dd4a1d",
ExpCards: map[string]int32{
"62da19017944b60fd473df61": 1,
}, },
rsp: &pb.HeroInfoResp{}, },
rsp: &pb.HeroStrengthenUplvResp{},
// enabled: true, // enabled: true,
// print: func(rsp proto.Message) {
// r := rsp.(*pb.HeroInfoResp)
// fmt.Printf("%v\n", r)
// },
} }
tcs = append(tcs, tc) tcs = append(tcs, tc)
} }
}
robot.addBuilders(tcs) robot.addBuilders(tcs)
}, },
}, { }, {
@ -103,7 +98,7 @@ var (
req: &pb.HeroStrengthenUplvReq{ req: &pb.HeroStrengthenUplvReq{
HeroObjID: heroId, HeroObjID: heroId,
ExpCards: map[string]int32{ ExpCards: map[string]int32{
heroId: 1, "62da19017944b60fd473df61": 1,
}, },
}, },
rsp: &pb.HeroStrengthenUplvResp{}, rsp: &pb.HeroStrengthenUplvResp{},

View File

@ -29,7 +29,7 @@ var (
mainType: string(comm.ModuleMainline), mainType: string(comm.ModuleMainline),
subType: mainline.MainlineChallengeResp, subType: mainline.MainlineChallengeResp,
req: &pb.MainlineChallengeReq{ req: &pb.MainlineChallengeReq{
ChapterId: 1,
MainlineId: 1, MainlineId: 1,
}, },
rsp: &pb.MainlineChallengeResp{}, rsp: &pb.MainlineChallengeResp{},

View File

@ -29,7 +29,7 @@ var (
fmt.Printf("%v \n", v) fmt.Printf("%v \n", v)
} }
}, },
// enabled: true, enabled: true,
next: func(robot *Robot, rsp proto.Message) { next: func(robot *Robot, rsp proto.Message) {
tcs := []*TestCase{} tcs := []*TestCase{}
if v, ok := rsp.(*pb.TaskListResp); ok { if v, ok := rsp.(*pb.TaskListResp); ok {

View File

@ -41,7 +41,7 @@ var user_builders = []*TestCase{
req: &pb.UserAddResReq{ req: &pb.UserAddResReq{
Res: &pb.UserAssets{ Res: &pb.UserAssets{
A: "hero", A: "hero",
T: "43001", T: "42911",
N: 1, N: 1,
}, },
}, },

View File

@ -121,7 +121,6 @@ func (this *ModelTask) modifyUserTask(uid string, taskId string, data map[string
//任务处理 //任务处理
func (this *ModelTask) taskHandle(uid string, taskType comm.TaskType, taskParam *pb.TaskParam) (*pb.DBTask, error) { func (this *ModelTask) taskHandle(uid string, taskType comm.TaskType, taskParam *pb.TaskParam) (*pb.DBTask, error) {
//查询当前用户未完成的任务列表
data, err := this.moduleTask.configure.getTasks(int32(taskType)) data, err := this.moduleTask.configure.getTasks(int32(taskType))
if err != nil { if err != nil {
log.Errorf("taskHandle err %v", err) log.Errorf("taskHandle err %v", err)
@ -129,10 +128,13 @@ func (this *ModelTask) taskHandle(uid string, taskType comm.TaskType, taskParam
} }
for _, conf := range data { for _, conf := range data {
if conf.RestrictiveCondition != 0 {
//不满足限定条件 //不满足限定条件
if taskParam.First != conf.RestrictiveCondition { if taskParam.First < conf.RestrictiveCondition {
continue continue
} }
}
//检查进度,执行处理器 //检查进度,执行处理器
if v, ok := this.checkTaskProgress(uid, conf); ok { if v, ok := this.checkTaskProgress(uid, conf); ok {
if tt, err := this.finishHandle(v, conf); err != nil { if tt, err := this.finishHandle(v, conf); err != nil {
@ -140,7 +142,6 @@ func (this *ModelTask) taskHandle(uid string, taskType comm.TaskType, taskParam
} else { } else {
return tt, nil return tt, nil
} }
} }
} }
return nil, nil return nil, nil
@ -168,7 +169,7 @@ func (this *ModelTask) finishHandle(userTask *pb.DBTask, config *cfg.Game_taskRo
userTask.Progress = progress userTask.Progress = progress
userTask.Status = 1 userTask.Status = 1
return nil, nil return userTask, nil
} }
//清空任务 //清空任务

View File

@ -70,10 +70,12 @@ func (this *ModuleTask) SendToTask(session comm.IUserSession, taskType comm.Task
if task, err := this.modelTask.taskHandle(session.GetUserId(), taskType, taskPram); err != nil { if task, err := this.modelTask.taskHandle(session.GetUserId(), taskType, taskPram); err != nil {
code = pb.ErrorCode_TaskHandle code = pb.ErrorCode_TaskHandle
} else { } else {
if task != nil {
if err := session.SendMsg(string(comm.ModuleTask), TaskSubTypeFinishedPush, &pb.TaskFinishedPush{TaskId: task.TaskId}); err != nil { if err := session.SendMsg(string(comm.ModuleTask), TaskSubTypeFinishedPush, &pb.TaskFinishedPush{TaskId: task.TaskId}); err != nil {
this.modelTask.moduleTask.Errorf("SendToTask sendmsg err:%v", err) this.modelTask.moduleTask.Errorf("SendToTask sendmsg err:%v", err)
} }
} }
}
return return
} }