go_dreamfactory/modules/stonehenge/api_taskinfo.go
2023-08-15 15:09:49 +08:00

54 lines
1.4 KiB
Go

package stonehenge
import (
"go_dreamfactory/comm"
"go_dreamfactory/pb"
cfg "go_dreamfactory/sys/configure/structs"
)
//参数校验
func (this *apiComp) TaskInfoCheck(session comm.IUserSession, req *pb.StonehengeTaskInfoReq) (errdata *pb.ErrorData) {
return
}
func (this *apiComp) TaskInfo(session comm.IUserSession, req *pb.StonehengeTaskInfoReq) (errdata *pb.ErrorData) {
var (
info *pb.DBStonehenge
confs []*cfg.GameStoneTaskData
tasks []int32 = make([]int32, 0)
progress []*pb.ConIProgress
err error
)
if errdata = this.TaskInfoCheck(session, req); errdata != nil {
return
}
if info, err = this.module.modelStonehenge.GetStonehengeData(session.GetUserId()); err != nil {
errdata = &pb.ErrorData{
Code: pb.ErrorCode_DBError,
Title: pb.ErrorCode_DBError.String(),
Message: err.Error(),
}
return
}
if confs, err = this.module.configure.getGameStoneTaskDatas(); err != nil {
errdata = &pb.ErrorData{
Code: pb.ErrorCode_ConfigNoFound,
Title: pb.ErrorCode_ConfigNoFound.String(),
Message: err.Error(),
}
return
}
for _, v := range confs {
tasks = append(tasks, v.TaskId)
}
if progress, err = this.module.ModuleBuried.CheckCondition(session.GetUserId(), tasks...); err != nil {
return
}
session.SendMsg(string(this.module.GetType()), "taskinfo", &pb.StonehengeTaskInfoResp{Conlds: progress, Task: info.Task})
return
}