diff --git a/comm/const.go b/comm/const.go index 539b97465..952aa436e 100644 --- a/comm/const.go +++ b/comm/const.go @@ -95,7 +95,9 @@ const ( ModuleDailytask core.M_Modules = "dailytask" //每日任务 ModuleQuestionnaire core.M_Modules = "questionnaire" //问卷调查 ModuleMainline core.M_Modules = "mainline" //主线模块 - ModuleStone core.M_Modules = "stonehenge" + ModuleStone core.M_Modules = "stonehenge" //巨石秘境 + ModuleKFTask core.M_Modules = "kftask" //开服任务 + ModuleHeroTask core.M_Modules = "herotask" //守护者任务 ) // 数据表名定义处 @@ -320,6 +322,12 @@ const ( //新主线数据表 TableMainline = "mainline" + + //开服任务 + Tablekftask = "kftask" + + //守护者任务 + TableHerotask = "herotask" ) // RPC服务接口定义处 @@ -980,4 +988,5 @@ const ( HdTypeWarorder = 1 // 圣桃战令类型 HdTypePay = 2 // 圣桃充值礼包 + KFSevenTask = 3 //开服任务 ) diff --git a/modules/herotask/api.go b/modules/herotask/api.go new file mode 100644 index 000000000..5b846c382 --- /dev/null +++ b/modules/herotask/api.go @@ -0,0 +1,20 @@ +package herotask + +import ( + "go_dreamfactory/lego/base" + "go_dreamfactory/lego/core" + "go_dreamfactory/modules" +) + +type apiComp struct { + modules.MCompGate + service base.IRPCXService + module *HeroTask +} + +func (this *apiComp) Init(service core.IService, module core.IModule, comp core.IModuleComp, options core.IModuleOptions) (err error) { + _ = this.MCompGate.Init(service, module, comp, options) + this.service = service.(base.IRPCXService) + this.module = module.(*HeroTask) + return +} diff --git a/modules/herotask/api_Info.go b/modules/herotask/api_Info.go new file mode 100644 index 000000000..a14b1d902 --- /dev/null +++ b/modules/herotask/api_Info.go @@ -0,0 +1,47 @@ +package herotask + +import ( + "go_dreamfactory/comm" + "go_dreamfactory/pb" +) + +// 参数校验 +func (this *apiComp) InfoCheck(session comm.IUserSession, req *pb.HeroTaskInfoReq) (errdata *pb.ErrorData) { + + return +} + +// /获取自己的排行榜信息 +func (this *apiComp) Info(session comm.IUserSession, req *pb.HeroTaskInfoReq) (errdata *pb.ErrorData) { + var ( + dtask *pb.DBHeroTask + tasks map[int32]struct{} + condiIds []int32 + progress []*pb.ConIProgress + err error + ) + if errdata = this.InfoCheck(session, req); errdata != nil { + return + } + + if dtask, err = this.module.modeltask.getUserDTasks(session.GetUserId()); err != nil { + errdata = &pb.ErrorData{ + Code: pb.ErrorCode_DBError, + Title: pb.ErrorCode_DBError.ToString(), + Message: err.Error(), + } + return + } + tasks = this.module.configure.gettasks() + condiIds = make([]int32, 0, len(tasks)) + for k, _ := range tasks { + condiIds = append(condiIds, k) + } + + if progress, err = this.module.ModuleBuried.CheckCondition(session.GetUserId(), condiIds...); err != nil { + return + } + + session.SendMsg(string(this.module.GetType()), "info", &pb.HeroTaskInfoResp{Conlds: progress, Heros: dtask.Heros}) + return +} diff --git a/modules/herotask/api_receive.go b/modules/herotask/api_receive.go new file mode 100644 index 000000000..c13c46ef9 --- /dev/null +++ b/modules/herotask/api_receive.go @@ -0,0 +1,104 @@ +package herotask + +import ( + "fmt" + "go_dreamfactory/comm" + "go_dreamfactory/pb" + cfg "go_dreamfactory/sys/configure/structs" +) + +// 参数校验 +func (this *apiComp) ReceiveCheck(session comm.IUserSession, req *pb.HeroTaskReceiveReq) (errdata *pb.ErrorData) { + + return +} + +// /获取自己的排行榜信息 +func (this *apiComp) Receive(session comm.IUserSession, req *pb.HeroTaskReceiveReq) (errdata *pb.ErrorData) { + var ( + dtask *pb.DBHeroTask + tasks []int32 + conf *cfg.GameFategiftrewardData + progress []*pb.ConIProgress + award []*pb.UserAssets + ok bool + err error + ) + if errdata = this.ReceiveCheck(session, req); errdata != nil { + return + } + + if tasks, err = this.module.configure.getgrouptask(req.Hero, req.Stage); err != nil { + errdata = &pb.ErrorData{ + Code: pb.ErrorCode_DBError, + Title: pb.ErrorCode_DBError.ToString(), + Message: err.Error(), + } + return + } + if conf, err = this.module.configure.getgroupreward(req.Hero, req.Stage); err != nil { + errdata = &pb.ErrorData{ + Code: pb.ErrorCode_DBError, + Title: pb.ErrorCode_DBError.ToString(), + Message: err.Error(), + } + return + } + if dtask, err = this.module.modeltask.getUserDTasks(session.GetUserId()); err != nil { + errdata = &pb.ErrorData{ + Code: pb.ErrorCode_DBError, + Title: pb.ErrorCode_DBError.ToString(), + Message: err.Error(), + } + return + } + if _, ok = dtask.Heros[req.Hero]; ok { + if dtask.Heros[req.Hero].Stage[req.Stage] == 1 { + errdata = &pb.ErrorData{ + Code: pb.ErrorCode_ReqParameterError, + Title: pb.ErrorCode_ReqParameterError.ToString(), + Message: fmt.Sprintf("hero:%d stage%d received", req.Hero, req.Stage), + } + return + } + + } else { + dtask.Heros[req.Hero] = &pb.DBHeroItem{ + Heroid: req.Hero, + Stage: make(map[int32]int32), + } + } + + if progress, err = this.module.ModuleBuried.CheckCondition(session.GetUserId(), tasks...); err != nil { + return + } + + for _, v := range progress { + if v.State == pb.BuriedItemFinishState_buried_unfinish { + errdata = &pb.ErrorData{ + Code: pb.ErrorCode_ReqParameterError, + Title: pb.ErrorCode_ReqParameterError.ToString(), + Message: "task no finish", + } + return + } + } + + if errdata = this.module.DispenseRes(session, []*cfg.Gameatn{conf.Stagereward}, true); errdata != nil { + return + } + award = make([]*pb.UserAssets, 0) + for _, v := range []*cfg.Gameatn{conf.Stagereward} { + award = append(award, &pb.UserAssets{ + A: v.A, + T: v.T, + N: v.N, + }) + } + dtask.Heros[req.Hero].Stage[req.Stage] = 1 + this.module.modeltask.Change(session.GetUserId(), map[string]interface{}{ + "heros": dtask.Heros, + }) + session.SendMsg(string(this.module.GetType()), "receive", &pb.HeroTaskReceiveResp{Hero: req.Hero, Stage: req.Stage, Award: award}) + return +} diff --git a/modules/herotask/configure.go b/modules/herotask/configure.go new file mode 100644 index 000000000..bf7c9e0f8 --- /dev/null +++ b/modules/herotask/configure.go @@ -0,0 +1,135 @@ +package herotask + +import ( + "go_dreamfactory/comm" + "go_dreamfactory/lego/core" + "go_dreamfactory/modules" + "go_dreamfactory/sys/configure" + cfg "go_dreamfactory/sys/configure/structs" + "sync" +) + +const ( + game_fategiftfate = "game_fategiftfate.json" + game_fategiftreward = "game_fategiftreward.json" +) + +type configureComp struct { + modules.MCompConfigure + module *HeroTask + lock sync.RWMutex + tasks map[int32]struct{} + grouptask map[int32]map[int32][]int32 + groupreward map[int32]map[int32]*cfg.GameFategiftrewardData +} + +func (this *configureComp) Init(service core.IService, module core.IModule, comp core.IModuleComp, options core.IModuleOptions) (err error) { + err = this.MCompConfigure.Init(service, module, comp, options) + this.module = module.(*HeroTask) + configure.RegisterConfigure(game_fategiftfate, cfg.NewGameFategiftFate, this.updateconfigure) + configure.RegisterConfigure(game_fategiftreward, cfg.NewGameFategiftreward, this.updateconfigurereward) + return +} + +func (this *configureComp) gettasks() map[int32]struct{} { + this.lock.RLock() + defer this.lock.RUnlock() + return this.tasks +} +func (this *configureComp) getgrouptask(hero, stage int32) (conf []int32, err error) { + this.lock.RLock() + heros, ok := this.grouptask[hero] + this.lock.RUnlock() + if !ok { + err = comm.NewNotFoundConfErr(string(this.module.GetType()), game_fategiftfate, hero) + return + } + tasks, ok := heros[stage] + if !ok { + err = comm.NewNotFoundConfErr(string(this.module.GetType()), game_fategiftfate, hero) + return + } + conf = tasks + return +} +func (this *configureComp) getgroupreward(hero, stage int32) (conf *cfg.GameFategiftrewardData, err error) { + this.lock.RLock() + heros, ok := this.groupreward[hero] + this.lock.RUnlock() + if !ok { + err = comm.NewNotFoundConfErr(string(this.module.GetType()), game_fategiftfate, hero) + return + } + tasks, ok := heros[stage] + if !ok { + err = comm.NewNotFoundConfErr(string(this.module.GetType()), game_fategiftfate, hero) + return + } + conf = tasks + return +} + +// 更新任务配置表 +func (this *configureComp) updateconfigure() { + var ( + v interface{} + conf *cfg.GameFategiftFate + ok bool + err error + ) + if v, err = this.GetConfigure(game_fategiftfate); err != nil { + return + } + if conf, ok = v.(*cfg.GameFategiftFate); !ok { + this.module.Error("日常任务配置异常!") + return + } + tasks := make(map[int32]struct{}) + grouptask := make(map[int32]map[int32][]int32) + + for _, v := range conf.GetDataList() { + + if _, ok := grouptask[v.Heroid]; !ok { + grouptask[v.Heroid] = make(map[int32][]int32) + } + if _, ok := grouptask[v.Heroid][v.Herostage]; !ok { + grouptask[v.Heroid][v.Herostage] = make([]int32, 0) + } + grouptask[v.Heroid][v.Herostage] = append(grouptask[v.Heroid][v.Herostage], v.Stagetask) + tasks[v.Stagetask] = struct{}{} + } + + this.lock.Lock() + this.grouptask = grouptask + this.tasks = tasks + this.lock.Unlock() +} + +// 更新任务配置表 +func (this *configureComp) updateconfigurereward() { + var ( + v interface{} + conf *cfg.GameFategiftreward + ok bool + err error + ) + if v, err = this.GetConfigure(game_fategiftreward); err != nil { + return + } + if conf, ok = v.(*cfg.GameFategiftreward); !ok { + this.module.Error("日常任务配置异常!") + return + } + groupTasksConf := make(map[int32]map[int32]*cfg.GameFategiftrewardData) + + for _, v := range conf.GetDataList() { + if _, ok := groupTasksConf[v.Heroid]; !ok { + groupTasksConf[v.Heroid] = make(map[int32]*cfg.GameFategiftrewardData) + } + groupTasksConf[v.Heroid][v.Stageid] = v + } + + this.lock.Lock() + this.groupreward = groupTasksConf + this.lock.Unlock() +} diff --git a/modules/herotask/modeltask.go b/modules/herotask/modeltask.go new file mode 100644 index 000000000..7444fe7aa --- /dev/null +++ b/modules/herotask/modeltask.go @@ -0,0 +1,46 @@ +package herotask + +import ( + "go_dreamfactory/comm" + "go_dreamfactory/lego/core" + "go_dreamfactory/lego/sys/mgo" + "go_dreamfactory/modules" + "go_dreamfactory/pb" + + "go.mongodb.org/mongo-driver/bson/primitive" + "go.mongodb.org/mongo-driver/mongo" + "go.mongodb.org/mongo-driver/x/bsonx" +) + +type Modeltask struct { + modules.MCompModel + module *HeroTask +} + +func (this *Modeltask) Init(service core.IService, module core.IModule, comp core.IModuleComp, options core.IModuleOptions) (err error) { + err = this.MCompModel.Init(service, module, comp, options) + this.TableName = comm.TableHerotask + this.module = module.(*HeroTask) + this.DB.CreateIndex(core.SqlTable(this.TableName), mongo.IndexModel{ + Keys: bsonx.Doc{{Key: "uid", Value: bsonx.Int32(1)}}, + }) + return +} + +// 获取用户全部的埋点数据 +func (this *Modeltask) getUserDTasks(uid string) (results *pb.DBHeroTask, err error) { + results = &pb.DBHeroTask{} + if err = this.Get(uid, results); err != nil && err != mgo.MongodbNil { + this.module.Errorln(err) + return + } + if err == mgo.MongodbNil { + results = &pb.DBHeroTask{ + Id: primitive.NewObjectID().Hex(), + Uid: uid, + Heros: make(map[int32]*pb.DBHeroItem), + } + err = this.Add(uid, results) + } + return +} diff --git a/modules/herotask/module.go b/modules/herotask/module.go new file mode 100644 index 000000000..c57d633ca --- /dev/null +++ b/modules/herotask/module.go @@ -0,0 +1,53 @@ +package herotask + +import ( + "go_dreamfactory/comm" + "go_dreamfactory/lego/core" + "go_dreamfactory/modules" + "go_dreamfactory/pb" +) + +type HeroTask struct { + modules.ModuleBase + service core.IService + api *apiComp + configure *configureComp + modeltask *Modeltask + open bool +} + +func NewModule() core.IModule { + return &HeroTask{} +} + +func (this *HeroTask) GetType() core.M_Modules { + return comm.ModuleHeroTask +} + +func (this *HeroTask) Init(service core.IService, module core.IModule, options core.IModuleOptions) (err error) { + err = this.ModuleBase.Init(service, module, options) + this.service = service + return +} + +func (this *HeroTask) Start() (err error) { + err = this.ModuleBase.Start() + + return +} + +func (this *HeroTask) OnInstallComp() { + this.ModuleBase.OnInstallComp() + this.api = this.RegisterComp(new(apiComp)).(*apiComp) + this.modeltask = this.RegisterComp(new(Modeltask)).(*Modeltask) + this.configure = this.RegisterComp(new(configureComp)).(*configureComp) +} + +// 活动开启 +func (this *HeroTask) ActivityNotice(hdlist *pb.DBHuodong) { + switch hdlist.Itype { + case comm.KFSevenTask: + this.open = true + break + } +} diff --git a/modules/kftask/api.go b/modules/kftask/api.go new file mode 100644 index 000000000..ba4e6098f --- /dev/null +++ b/modules/kftask/api.go @@ -0,0 +1,20 @@ +package kftask + +import ( + "go_dreamfactory/lego/base" + "go_dreamfactory/lego/core" + "go_dreamfactory/modules" +) + +type apiComp struct { + modules.MCompGate + service base.IRPCXService + module *KFTask +} + +func (this *apiComp) Init(service core.IService, module core.IModule, comp core.IModuleComp, options core.IModuleOptions) (err error) { + _ = this.MCompGate.Init(service, module, comp, options) + this.service = service.(base.IRPCXService) + this.module = module.(*KFTask) + return +} diff --git a/modules/kftask/api_Info.go b/modules/kftask/api_Info.go new file mode 100644 index 000000000..eab063056 --- /dev/null +++ b/modules/kftask/api_Info.go @@ -0,0 +1,47 @@ +package kftask + +import ( + "go_dreamfactory/comm" + "go_dreamfactory/pb" +) + +// 参数校验 +func (this *apiComp) InfoCheck(session comm.IUserSession, req *pb.KFTaskInfoReq) (errdata *pb.ErrorData) { + + return +} + +// /获取自己的排行榜信息 +func (this *apiComp) Info(session comm.IUserSession, req *pb.KFTaskInfoReq) (errdata *pb.ErrorData) { + var ( + dtask *pb.DBKFTask + tasks map[int32]struct{} + condiIds []int32 + progress []*pb.ConIProgress + err error + ) + if errdata = this.InfoCheck(session, req); errdata != nil { + return + } + + if dtask, err = this.module.modeltask.getUserDTasks(session.GetUserId()); err != nil { + errdata = &pb.ErrorData{ + Code: pb.ErrorCode_DBError, + Title: pb.ErrorCode_DBError.ToString(), + Message: err.Error(), + } + return + } + tasks = this.module.configure.gettasks() + condiIds = make([]int32, 0, len(tasks)) + for k, _ := range tasks { + condiIds = append(condiIds, k) + } + + if progress, err = this.module.ModuleBuried.CheckCondition(session.GetUserId(), condiIds...); err != nil { + return + } + + session.SendMsg(string(this.module.GetType()), "info", &pb.KFTaskInfoResp{Conlds: progress, Tasks: dtask.Tasks}) + return +} diff --git a/modules/kftask/api_receive.go b/modules/kftask/api_receive.go new file mode 100644 index 000000000..49d493428 --- /dev/null +++ b/modules/kftask/api_receive.go @@ -0,0 +1,107 @@ +package kftask + +import ( + "fmt" + "go_dreamfactory/comm" + "go_dreamfactory/pb" + "go_dreamfactory/sys/configure" + cfg "go_dreamfactory/sys/configure/structs" + "go_dreamfactory/utils" +) + +// 参数校验 +func (this *apiComp) ReceiveCheck(session comm.IUserSession, req *pb.KFTaskReceiveReq) (errdata *pb.ErrorData) { + + return +} + +// /获取自己的排行榜信息 +func (this *apiComp) Receive(session comm.IUserSession, req *pb.KFTaskReceiveReq) (errdata *pb.ErrorData) { + var ( + dtask *pb.DBKFTask + conf *cfg.GameVenturegiftsTaskData + user *pb.DBUser + progress []*pb.ConIProgress + award []*pb.UserAssets + err error + ) + if errdata = this.ReceiveCheck(session, req); errdata != nil { + return + } + + if conf, err = this.module.configure.getGameVenturegiftsTask(req.Id); err != nil { + errdata = &pb.ErrorData{ + Code: pb.ErrorCode_DBError, + Title: pb.ErrorCode_DBError.ToString(), + Message: err.Error(), + } + return + } + if dtask, err = this.module.modeltask.getUserDTasks(session.GetUserId()); err != nil { + errdata = &pb.ErrorData{ + Code: pb.ErrorCode_DBError, + Title: pb.ErrorCode_DBError.ToString(), + Message: err.Error(), + } + return + } + + if dtask.Tasks[req.Id] == 1 { + errdata = &pb.ErrorData{ + Code: pb.ErrorCode_ReqParameterError, + Title: pb.ErrorCode_ReqParameterError.ToString(), + Message: fmt.Sprintf("%d received", req.Id), + } + return + } + if user = this.module.ModuleUser.GetUser(session.GetUserId()); user == nil { + errdata = &pb.ErrorData{ + Code: pb.ErrorCode_DBError, + Title: pb.ErrorCode_DBError.ToString(), + Message: "no found user!", + } + return + } + days := utils.DiffDays(user.Ctime, configure.Now().Unix()) + if days < int(conf.Openday) { + errdata = &pb.ErrorData{ + Code: pb.ErrorCode_DBError, + Title: pb.ErrorCode_DBError.ToString(), + Message: "no open", + } + return + } + + if progress, err = this.module.ModuleBuried.CheckCondition(session.GetUserId(), conf.Venturetask); err != nil { + return + } + + for _, v := range progress { + if v.State == pb.BuriedItemFinishState_buried_unfinish { + errdata = &pb.ErrorData{ + Code: pb.ErrorCode_ReqParameterError, + Title: pb.ErrorCode_ReqParameterError.ToString(), + Message: "task no finish", + } + return + } + } + + if errdata = this.module.DispenseRes(session, conf.Venturereward, true); errdata != nil { + return + } + award = make([]*pb.UserAssets, 0) + for _, v := range conf.Venturereward { + award = append(award, &pb.UserAssets{ + A: v.A, + T: v.T, + N: v.N, + }) + } + dtask.Tasks[req.Id] = 1 + this.module.modeltask.Change(session.GetUserId(), map[string]interface{}{ + "tasks": dtask.Tasks, + }) + session.SendMsg(string(this.module.GetType()), "receive", &pb.KFTaskReceiveResp{Id: req.Id, Award: award}) + return +} diff --git a/modules/kftask/configure.go b/modules/kftask/configure.go new file mode 100644 index 000000000..c91ade629 --- /dev/null +++ b/modules/kftask/configure.go @@ -0,0 +1,84 @@ +package kftask + +import ( + "go_dreamfactory/comm" + "go_dreamfactory/lego/core" + "go_dreamfactory/modules" + "go_dreamfactory/sys/configure" + cfg "go_dreamfactory/sys/configure/structs" + "sync" +) + +const ( + game_venturegiftstask = "game_venturegiftstask.json" +) + +type configureComp struct { + modules.MCompConfigure + module *KFTask + lock sync.RWMutex + tasks map[int32]struct{} + groupTasks map[int32][]*cfg.GameVenturegiftsTaskData //key 条件ID +} + +func (this *configureComp) Init(service core.IService, module core.IModule, comp core.IModuleComp, options core.IModuleOptions) (err error) { + err = this.MCompConfigure.Init(service, module, comp, options) + this.module = module.(*KFTask) + configure.RegisterConfigure(game_venturegiftstask, cfg.NewGameVenturegiftsTask, this.updateconfigure) + return +} + +func (this *configureComp) gettasks() map[int32]struct{} { + this.lock.RLock() + defer this.lock.RUnlock() + return this.tasks +} + +// 更新任务配置表 +func (this *configureComp) updateconfigure() { + var ( + v interface{} + conf *cfg.GameVenturegiftsTask + ok bool + err error + ) + if v, err = this.GetConfigure(game_venturegiftstask); err != nil { + return + } + if conf, ok = v.(*cfg.GameVenturegiftsTask); !ok { + this.module.Error("日常任务配置异常!") + return + } + tasks := make(map[int32]struct{}) + groupTasksConf := make(map[int32][]*cfg.GameVenturegiftsTaskData) + + for _, v := range conf.GetDataList() { + + if _, ok := groupTasksConf[v.Openday]; !ok { + groupTasksConf[v.Openday] = make([]*cfg.GameVenturegiftsTaskData, 0) + } + groupTasksConf[v.Openday] = append(groupTasksConf[v.Openday], v) + tasks[v.Venturetask] = struct{}{} + } + + this.lock.Lock() + this.groupTasks = groupTasksConf + this.tasks = tasks + this.lock.Unlock() +} + +func (this *configureComp) getGameVenturegiftsTask(id int32) (conf *cfg.GameVenturegiftsTaskData, err error) { + var ( + v interface{} + ok bool + ) + if v, err = this.GetConfigure(game_venturegiftstask); err != nil { + return + } + if conf, ok = v.(*cfg.GameVenturegiftsTask).GetDataMap()[id]; !ok { + err = comm.NewNotFoundConfErr(string(this.module.GetType()), game_venturegiftstask, id) + this.module.Errorln(err) + return + } + return +} diff --git a/modules/kftask/modeltask.go b/modules/kftask/modeltask.go new file mode 100644 index 000000000..c7056b5a1 --- /dev/null +++ b/modules/kftask/modeltask.go @@ -0,0 +1,46 @@ +package kftask + +import ( + "go_dreamfactory/comm" + "go_dreamfactory/lego/core" + "go_dreamfactory/lego/sys/mgo" + "go_dreamfactory/modules" + "go_dreamfactory/pb" + + "go.mongodb.org/mongo-driver/bson/primitive" + "go.mongodb.org/mongo-driver/mongo" + "go.mongodb.org/mongo-driver/x/bsonx" +) + +type Modeltask struct { + modules.MCompModel + module *KFTask +} + +func (this *Modeltask) Init(service core.IService, module core.IModule, comp core.IModuleComp, options core.IModuleOptions) (err error) { + err = this.MCompModel.Init(service, module, comp, options) + this.TableName = comm.Tablekftask + this.module = module.(*KFTask) + this.DB.CreateIndex(core.SqlTable(this.TableName), mongo.IndexModel{ + Keys: bsonx.Doc{{Key: "uid", Value: bsonx.Int32(1)}}, + }) + return +} + +// 获取用户全部的埋点数据 +func (this *Modeltask) getUserDTasks(uid string) (results *pb.DBKFTask, err error) { + results = &pb.DBKFTask{} + if err = this.Get(uid, results); err != nil && err != mgo.MongodbNil { + this.module.Errorln(err) + return + } + if err == mgo.MongodbNil { + results = &pb.DBKFTask{ + Id: primitive.NewObjectID().Hex(), + Uid: uid, + Tasks: make(map[int32]int32), + } + err = this.Add(uid, results) + } + return +} diff --git a/modules/kftask/module.go b/modules/kftask/module.go new file mode 100644 index 000000000..9e246e249 --- /dev/null +++ b/modules/kftask/module.go @@ -0,0 +1,53 @@ +package kftask + +import ( + "go_dreamfactory/comm" + "go_dreamfactory/lego/core" + "go_dreamfactory/modules" + "go_dreamfactory/pb" +) + +type KFTask struct { + modules.ModuleBase + service core.IService + api *apiComp + configure *configureComp + modeltask *Modeltask + open bool +} + +func NewModule() core.IModule { + return &KFTask{} +} + +func (this *KFTask) GetType() core.M_Modules { + return comm.ModuleKFTask +} + +func (this *KFTask) Init(service core.IService, module core.IModule, options core.IModuleOptions) (err error) { + err = this.ModuleBase.Init(service, module, options) + this.service = service + return +} + +func (this *KFTask) Start() (err error) { + err = this.ModuleBase.Start() + + return +} + +func (this *KFTask) OnInstallComp() { + this.ModuleBase.OnInstallComp() + this.api = this.RegisterComp(new(apiComp)).(*apiComp) + this.modeltask = this.RegisterComp(new(Modeltask)).(*Modeltask) + this.configure = this.RegisterComp(new(configureComp)).(*configureComp) +} + +// 活动开启 +func (this *KFTask) ActivityNotice(hdlist *pb.DBHuodong) { + switch hdlist.Itype { + case comm.KFSevenTask: + this.open = true + break + } +} diff --git a/pb/herotask_db.pb.go b/pb/herotask_db.pb.go new file mode 100644 index 000000000..a6f8834e8 --- /dev/null +++ b/pb/herotask_db.pb.go @@ -0,0 +1,249 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.28.0 +// protoc v3.20.0 +// source: herotask/herotask_db.proto + +package pb + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +//开服任务数据 +type DBHeroTask struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id"` + Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid"` + Heros map[int32]*DBHeroItem `protobuf:"bytes,3,rep,name=heros,proto3" json:"heros" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` +} + +func (x *DBHeroTask) Reset() { + *x = DBHeroTask{} + if protoimpl.UnsafeEnabled { + mi := &file_herotask_herotask_db_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *DBHeroTask) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DBHeroTask) ProtoMessage() {} + +func (x *DBHeroTask) ProtoReflect() protoreflect.Message { + mi := &file_herotask_herotask_db_proto_msgTypes[0] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use DBHeroTask.ProtoReflect.Descriptor instead. +func (*DBHeroTask) Descriptor() ([]byte, []int) { + return file_herotask_herotask_db_proto_rawDescGZIP(), []int{0} +} + +func (x *DBHeroTask) GetId() string { + if x != nil { + return x.Id + } + return "" +} + +func (x *DBHeroTask) GetUid() string { + if x != nil { + return x.Uid + } + return "" +} + +func (x *DBHeroTask) GetHeros() map[int32]*DBHeroItem { + if x != nil { + return x.Heros + } + return nil +} + +type DBHeroItem struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Heroid int32 `protobuf:"varint,1,opt,name=heroid,proto3" json:"heroid"` + Stage map[int32]int32 `protobuf:"bytes,2,rep,name=stage,proto3" json:"stage" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"` +} + +func (x *DBHeroItem) Reset() { + *x = DBHeroItem{} + if protoimpl.UnsafeEnabled { + mi := &file_herotask_herotask_db_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *DBHeroItem) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DBHeroItem) ProtoMessage() {} + +func (x *DBHeroItem) ProtoReflect() protoreflect.Message { + mi := &file_herotask_herotask_db_proto_msgTypes[1] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use DBHeroItem.ProtoReflect.Descriptor instead. +func (*DBHeroItem) Descriptor() ([]byte, []int) { + return file_herotask_herotask_db_proto_rawDescGZIP(), []int{1} +} + +func (x *DBHeroItem) GetHeroid() int32 { + if x != nil { + return x.Heroid + } + return 0 +} + +func (x *DBHeroItem) GetStage() map[int32]int32 { + if x != nil { + return x.Stage + } + return nil +} + +var File_herotask_herotask_db_proto protoreflect.FileDescriptor + +var file_herotask_herotask_db_proto_rawDesc = []byte{ + 0x0a, 0x1a, 0x68, 0x65, 0x72, 0x6f, 0x74, 0x61, 0x73, 0x6b, 0x2f, 0x68, 0x65, 0x72, 0x6f, 0x74, + 0x61, 0x73, 0x6b, 0x5f, 0x64, 0x62, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xa3, 0x01, 0x0a, + 0x0a, 0x44, 0x42, 0x48, 0x65, 0x72, 0x6f, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x0e, 0x0a, 0x02, 0x69, + 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64, 0x12, 0x10, 0x0a, 0x03, 0x75, + 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x75, 0x69, 0x64, 0x12, 0x2c, 0x0a, + 0x05, 0x68, 0x65, 0x72, 0x6f, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x44, + 0x42, 0x48, 0x65, 0x72, 0x6f, 0x54, 0x61, 0x73, 0x6b, 0x2e, 0x48, 0x65, 0x72, 0x6f, 0x73, 0x45, + 0x6e, 0x74, 0x72, 0x79, 0x52, 0x05, 0x68, 0x65, 0x72, 0x6f, 0x73, 0x1a, 0x45, 0x0a, 0x0a, 0x48, + 0x65, 0x72, 0x6f, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, + 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x21, 0x0a, 0x05, 0x76, + 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0b, 0x2e, 0x44, 0x42, 0x48, + 0x65, 0x72, 0x6f, 0x49, 0x74, 0x65, 0x6d, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, + 0x38, 0x01, 0x22, 0x8c, 0x01, 0x0a, 0x0a, 0x44, 0x42, 0x48, 0x65, 0x72, 0x6f, 0x49, 0x74, 0x65, + 0x6d, 0x12, 0x16, 0x0a, 0x06, 0x68, 0x65, 0x72, 0x6f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, + 0x05, 0x52, 0x06, 0x68, 0x65, 0x72, 0x6f, 0x69, 0x64, 0x12, 0x2c, 0x0a, 0x05, 0x73, 0x74, 0x61, + 0x67, 0x65, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x44, 0x42, 0x48, 0x65, 0x72, + 0x6f, 0x49, 0x74, 0x65, 0x6d, 0x2e, 0x53, 0x74, 0x61, 0x67, 0x65, 0x45, 0x6e, 0x74, 0x72, 0x79, + 0x52, 0x05, 0x73, 0x74, 0x61, 0x67, 0x65, 0x1a, 0x38, 0x0a, 0x0a, 0x53, 0x74, 0x61, 0x67, 0x65, + 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, + 0x28, 0x05, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, + 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, + 0x01, 0x42, 0x06, 0x5a, 0x04, 0x2e, 0x3b, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, + 0x33, +} + +var ( + file_herotask_herotask_db_proto_rawDescOnce sync.Once + file_herotask_herotask_db_proto_rawDescData = file_herotask_herotask_db_proto_rawDesc +) + +func file_herotask_herotask_db_proto_rawDescGZIP() []byte { + file_herotask_herotask_db_proto_rawDescOnce.Do(func() { + file_herotask_herotask_db_proto_rawDescData = protoimpl.X.CompressGZIP(file_herotask_herotask_db_proto_rawDescData) + }) + return file_herotask_herotask_db_proto_rawDescData +} + +var file_herotask_herotask_db_proto_msgTypes = make([]protoimpl.MessageInfo, 4) +var file_herotask_herotask_db_proto_goTypes = []interface{}{ + (*DBHeroTask)(nil), // 0: DBHeroTask + (*DBHeroItem)(nil), // 1: DBHeroItem + nil, // 2: DBHeroTask.HerosEntry + nil, // 3: DBHeroItem.StageEntry +} +var file_herotask_herotask_db_proto_depIdxs = []int32{ + 2, // 0: DBHeroTask.heros:type_name -> DBHeroTask.HerosEntry + 3, // 1: DBHeroItem.stage:type_name -> DBHeroItem.StageEntry + 1, // 2: DBHeroTask.HerosEntry.value:type_name -> DBHeroItem + 3, // [3:3] is the sub-list for method output_type + 3, // [3:3] is the sub-list for method input_type + 3, // [3:3] is the sub-list for extension type_name + 3, // [3:3] is the sub-list for extension extendee + 0, // [0:3] is the sub-list for field type_name +} + +func init() { file_herotask_herotask_db_proto_init() } +func file_herotask_herotask_db_proto_init() { + if File_herotask_herotask_db_proto != nil { + return + } + if !protoimpl.UnsafeEnabled { + file_herotask_herotask_db_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*DBHeroTask); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_herotask_herotask_db_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*DBHeroItem); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + } + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: file_herotask_herotask_db_proto_rawDesc, + NumEnums: 0, + NumMessages: 4, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_herotask_herotask_db_proto_goTypes, + DependencyIndexes: file_herotask_herotask_db_proto_depIdxs, + MessageInfos: file_herotask_herotask_db_proto_msgTypes, + }.Build() + File_herotask_herotask_db_proto = out.File + file_herotask_herotask_db_proto_rawDesc = nil + file_herotask_herotask_db_proto_goTypes = nil + file_herotask_herotask_db_proto_depIdxs = nil +} diff --git a/pb/herotask_msg.pb.go b/pb/herotask_msg.pb.go new file mode 100644 index 000000000..2bc3948e9 --- /dev/null +++ b/pb/herotask_msg.pb.go @@ -0,0 +1,384 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.28.0 +// protoc v3.20.0 +// source: herotask/herotask_msg.proto + +package pb + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +//开服任务数据 +type HeroTaskInfoReq struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *HeroTaskInfoReq) Reset() { + *x = HeroTaskInfoReq{} + if protoimpl.UnsafeEnabled { + mi := &file_herotask_herotask_msg_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *HeroTaskInfoReq) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*HeroTaskInfoReq) ProtoMessage() {} + +func (x *HeroTaskInfoReq) ProtoReflect() protoreflect.Message { + mi := &file_herotask_herotask_msg_proto_msgTypes[0] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use HeroTaskInfoReq.ProtoReflect.Descriptor instead. +func (*HeroTaskInfoReq) Descriptor() ([]byte, []int) { + return file_herotask_herotask_msg_proto_rawDescGZIP(), []int{0} +} + +//开服任务数据 +type HeroTaskInfoResp struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Conlds []*ConIProgress `protobuf:"bytes,1,rep,name=conlds,proto3" json:"conlds"` //子任务进度数据 + Heros map[int32]*DBHeroItem `protobuf:"bytes,2,rep,name=heros,proto3" json:"heros" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` +} + +func (x *HeroTaskInfoResp) Reset() { + *x = HeroTaskInfoResp{} + if protoimpl.UnsafeEnabled { + mi := &file_herotask_herotask_msg_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *HeroTaskInfoResp) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*HeroTaskInfoResp) ProtoMessage() {} + +func (x *HeroTaskInfoResp) ProtoReflect() protoreflect.Message { + mi := &file_herotask_herotask_msg_proto_msgTypes[1] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use HeroTaskInfoResp.ProtoReflect.Descriptor instead. +func (*HeroTaskInfoResp) Descriptor() ([]byte, []int) { + return file_herotask_herotask_msg_proto_rawDescGZIP(), []int{1} +} + +func (x *HeroTaskInfoResp) GetConlds() []*ConIProgress { + if x != nil { + return x.Conlds + } + return nil +} + +func (x *HeroTaskInfoResp) GetHeros() map[int32]*DBHeroItem { + if x != nil { + return x.Heros + } + return nil +} + +//领奖 请求 +type HeroTaskReceiveReq struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Hero int32 `protobuf:"varint,1,opt,name=hero,proto3" json:"hero"` + Stage int32 `protobuf:"varint,2,opt,name=stage,proto3" json:"stage"` +} + +func (x *HeroTaskReceiveReq) Reset() { + *x = HeroTaskReceiveReq{} + if protoimpl.UnsafeEnabled { + mi := &file_herotask_herotask_msg_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *HeroTaskReceiveReq) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*HeroTaskReceiveReq) ProtoMessage() {} + +func (x *HeroTaskReceiveReq) ProtoReflect() protoreflect.Message { + mi := &file_herotask_herotask_msg_proto_msgTypes[2] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use HeroTaskReceiveReq.ProtoReflect.Descriptor instead. +func (*HeroTaskReceiveReq) Descriptor() ([]byte, []int) { + return file_herotask_herotask_msg_proto_rawDescGZIP(), []int{2} +} + +func (x *HeroTaskReceiveReq) GetHero() int32 { + if x != nil { + return x.Hero + } + return 0 +} + +func (x *HeroTaskReceiveReq) GetStage() int32 { + if x != nil { + return x.Stage + } + return 0 +} + +//领奖 请求回应 +type HeroTaskReceiveResp struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Hero int32 `protobuf:"varint,1,opt,name=hero,proto3" json:"hero"` + Stage int32 `protobuf:"varint,2,opt,name=stage,proto3" json:"stage"` + Award []*UserAssets `protobuf:"bytes,3,rep,name=award,proto3" json:"award"` //奖励 +} + +func (x *HeroTaskReceiveResp) Reset() { + *x = HeroTaskReceiveResp{} + if protoimpl.UnsafeEnabled { + mi := &file_herotask_herotask_msg_proto_msgTypes[3] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *HeroTaskReceiveResp) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*HeroTaskReceiveResp) ProtoMessage() {} + +func (x *HeroTaskReceiveResp) ProtoReflect() protoreflect.Message { + mi := &file_herotask_herotask_msg_proto_msgTypes[3] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use HeroTaskReceiveResp.ProtoReflect.Descriptor instead. +func (*HeroTaskReceiveResp) Descriptor() ([]byte, []int) { + return file_herotask_herotask_msg_proto_rawDescGZIP(), []int{3} +} + +func (x *HeroTaskReceiveResp) GetHero() int32 { + if x != nil { + return x.Hero + } + return 0 +} + +func (x *HeroTaskReceiveResp) GetStage() int32 { + if x != nil { + return x.Stage + } + return 0 +} + +func (x *HeroTaskReceiveResp) GetAward() []*UserAssets { + if x != nil { + return x.Award + } + return nil +} + +var File_herotask_herotask_msg_proto protoreflect.FileDescriptor + +var file_herotask_herotask_msg_proto_rawDesc = []byte{ + 0x0a, 0x1b, 0x68, 0x65, 0x72, 0x6f, 0x74, 0x61, 0x73, 0x6b, 0x2f, 0x68, 0x65, 0x72, 0x6f, 0x74, + 0x61, 0x73, 0x6b, 0x5f, 0x6d, 0x73, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1a, 0x68, + 0x65, 0x72, 0x6f, 0x74, 0x61, 0x73, 0x6b, 0x2f, 0x68, 0x65, 0x72, 0x6f, 0x74, 0x61, 0x73, 0x6b, + 0x5f, 0x64, 0x62, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x16, 0x62, 0x75, 0x72, 0x69, 0x65, + 0x64, 0x2f, 0x62, 0x75, 0x72, 0x69, 0x65, 0x64, 0x5f, 0x64, 0x62, 0x2e, 0x70, 0x72, 0x6f, 0x74, + 0x6f, 0x1a, 0x0a, 0x63, 0x6f, 0x6d, 0x6d, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x11, 0x0a, + 0x0f, 0x48, 0x65, 0x72, 0x6f, 0x54, 0x61, 0x73, 0x6b, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x65, 0x71, + 0x22, 0xb4, 0x01, 0x0a, 0x10, 0x48, 0x65, 0x72, 0x6f, 0x54, 0x61, 0x73, 0x6b, 0x49, 0x6e, 0x66, + 0x6f, 0x52, 0x65, 0x73, 0x70, 0x12, 0x25, 0x0a, 0x06, 0x63, 0x6f, 0x6e, 0x6c, 0x64, 0x73, 0x18, + 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0d, 0x2e, 0x43, 0x6f, 0x6e, 0x49, 0x50, 0x72, 0x6f, 0x67, + 0x72, 0x65, 0x73, 0x73, 0x52, 0x06, 0x63, 0x6f, 0x6e, 0x6c, 0x64, 0x73, 0x12, 0x32, 0x0a, 0x05, + 0x68, 0x65, 0x72, 0x6f, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x48, 0x65, + 0x72, 0x6f, 0x54, 0x61, 0x73, 0x6b, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x65, 0x73, 0x70, 0x2e, 0x48, + 0x65, 0x72, 0x6f, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x05, 0x68, 0x65, 0x72, 0x6f, 0x73, + 0x1a, 0x45, 0x0a, 0x0a, 0x48, 0x65, 0x72, 0x6f, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, + 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x03, 0x6b, 0x65, 0x79, + 0x12, 0x21, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, + 0x0b, 0x2e, 0x44, 0x42, 0x48, 0x65, 0x72, 0x6f, 0x49, 0x74, 0x65, 0x6d, 0x52, 0x05, 0x76, 0x61, + 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x3e, 0x0a, 0x12, 0x48, 0x65, 0x72, 0x6f, 0x54, + 0x61, 0x73, 0x6b, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x52, 0x65, 0x71, 0x12, 0x12, 0x0a, + 0x04, 0x68, 0x65, 0x72, 0x6f, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x04, 0x68, 0x65, 0x72, + 0x6f, 0x12, 0x14, 0x0a, 0x05, 0x73, 0x74, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, + 0x52, 0x05, 0x73, 0x74, 0x61, 0x67, 0x65, 0x22, 0x62, 0x0a, 0x13, 0x48, 0x65, 0x72, 0x6f, 0x54, + 0x61, 0x73, 0x6b, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x52, 0x65, 0x73, 0x70, 0x12, 0x12, + 0x0a, 0x04, 0x68, 0x65, 0x72, 0x6f, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x04, 0x68, 0x65, + 0x72, 0x6f, 0x12, 0x14, 0x0a, 0x05, 0x73, 0x74, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, + 0x05, 0x52, 0x05, 0x73, 0x74, 0x61, 0x67, 0x65, 0x12, 0x21, 0x0a, 0x05, 0x61, 0x77, 0x61, 0x72, + 0x64, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0b, 0x2e, 0x55, 0x73, 0x65, 0x72, 0x41, 0x73, + 0x73, 0x65, 0x74, 0x73, 0x52, 0x05, 0x61, 0x77, 0x61, 0x72, 0x64, 0x42, 0x06, 0x5a, 0x04, 0x2e, + 0x3b, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, +} + +var ( + file_herotask_herotask_msg_proto_rawDescOnce sync.Once + file_herotask_herotask_msg_proto_rawDescData = file_herotask_herotask_msg_proto_rawDesc +) + +func file_herotask_herotask_msg_proto_rawDescGZIP() []byte { + file_herotask_herotask_msg_proto_rawDescOnce.Do(func() { + file_herotask_herotask_msg_proto_rawDescData = protoimpl.X.CompressGZIP(file_herotask_herotask_msg_proto_rawDescData) + }) + return file_herotask_herotask_msg_proto_rawDescData +} + +var file_herotask_herotask_msg_proto_msgTypes = make([]protoimpl.MessageInfo, 5) +var file_herotask_herotask_msg_proto_goTypes = []interface{}{ + (*HeroTaskInfoReq)(nil), // 0: HeroTaskInfoReq + (*HeroTaskInfoResp)(nil), // 1: HeroTaskInfoResp + (*HeroTaskReceiveReq)(nil), // 2: HeroTaskReceiveReq + (*HeroTaskReceiveResp)(nil), // 3: HeroTaskReceiveResp + nil, // 4: HeroTaskInfoResp.HerosEntry + (*ConIProgress)(nil), // 5: ConIProgress + (*UserAssets)(nil), // 6: UserAssets + (*DBHeroItem)(nil), // 7: DBHeroItem +} +var file_herotask_herotask_msg_proto_depIdxs = []int32{ + 5, // 0: HeroTaskInfoResp.conlds:type_name -> ConIProgress + 4, // 1: HeroTaskInfoResp.heros:type_name -> HeroTaskInfoResp.HerosEntry + 6, // 2: HeroTaskReceiveResp.award:type_name -> UserAssets + 7, // 3: HeroTaskInfoResp.HerosEntry.value:type_name -> DBHeroItem + 4, // [4:4] is the sub-list for method output_type + 4, // [4:4] is the sub-list for method input_type + 4, // [4:4] is the sub-list for extension type_name + 4, // [4:4] is the sub-list for extension extendee + 0, // [0:4] is the sub-list for field type_name +} + +func init() { file_herotask_herotask_msg_proto_init() } +func file_herotask_herotask_msg_proto_init() { + if File_herotask_herotask_msg_proto != nil { + return + } + file_herotask_herotask_db_proto_init() + file_buried_buried_db_proto_init() + file_comm_proto_init() + if !protoimpl.UnsafeEnabled { + file_herotask_herotask_msg_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*HeroTaskInfoReq); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_herotask_herotask_msg_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*HeroTaskInfoResp); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_herotask_herotask_msg_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*HeroTaskReceiveReq); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_herotask_herotask_msg_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*HeroTaskReceiveResp); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + } + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: file_herotask_herotask_msg_proto_rawDesc, + NumEnums: 0, + NumMessages: 5, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_herotask_herotask_msg_proto_goTypes, + DependencyIndexes: file_herotask_herotask_msg_proto_depIdxs, + MessageInfos: file_herotask_herotask_msg_proto_msgTypes, + }.Build() + File_herotask_herotask_msg_proto = out.File + file_herotask_herotask_msg_proto_rawDesc = nil + file_herotask_herotask_msg_proto_goTypes = nil + file_herotask_herotask_msg_proto_depIdxs = nil +} diff --git a/pb/kftask_db.pb.go b/pb/kftask_db.pb.go new file mode 100644 index 000000000..2f0852ab5 --- /dev/null +++ b/pb/kftask_db.pb.go @@ -0,0 +1,167 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.28.0 +// protoc v3.20.0 +// source: kftask/kftask_db.proto + +package pb + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +//开服任务数据 +type DBKFTask struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id"` + Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid"` + Tasks map[int32]int32 `protobuf:"bytes,3,rep,name=tasks,proto3" json:"tasks" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"` +} + +func (x *DBKFTask) Reset() { + *x = DBKFTask{} + if protoimpl.UnsafeEnabled { + mi := &file_kftask_kftask_db_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *DBKFTask) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DBKFTask) ProtoMessage() {} + +func (x *DBKFTask) ProtoReflect() protoreflect.Message { + mi := &file_kftask_kftask_db_proto_msgTypes[0] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use DBKFTask.ProtoReflect.Descriptor instead. +func (*DBKFTask) Descriptor() ([]byte, []int) { + return file_kftask_kftask_db_proto_rawDescGZIP(), []int{0} +} + +func (x *DBKFTask) GetId() string { + if x != nil { + return x.Id + } + return "" +} + +func (x *DBKFTask) GetUid() string { + if x != nil { + return x.Uid + } + return "" +} + +func (x *DBKFTask) GetTasks() map[int32]int32 { + if x != nil { + return x.Tasks + } + return nil +} + +var File_kftask_kftask_db_proto protoreflect.FileDescriptor + +var file_kftask_kftask_db_proto_rawDesc = []byte{ + 0x0a, 0x16, 0x6b, 0x66, 0x74, 0x61, 0x73, 0x6b, 0x2f, 0x6b, 0x66, 0x74, 0x61, 0x73, 0x6b, 0x5f, + 0x64, 0x62, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x92, 0x01, 0x0a, 0x08, 0x44, 0x42, 0x4b, + 0x46, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, + 0x09, 0x52, 0x02, 0x69, 0x64, 0x12, 0x10, 0x0a, 0x03, 0x75, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, + 0x28, 0x09, 0x52, 0x03, 0x75, 0x69, 0x64, 0x12, 0x2a, 0x0a, 0x05, 0x74, 0x61, 0x73, 0x6b, 0x73, + 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x14, 0x2e, 0x44, 0x42, 0x4b, 0x46, 0x54, 0x61, 0x73, + 0x6b, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x05, 0x74, 0x61, + 0x73, 0x6b, 0x73, 0x1a, 0x38, 0x0a, 0x0a, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x45, 0x6e, 0x74, 0x72, + 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x03, + 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, + 0x28, 0x05, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x42, 0x06, 0x5a, + 0x04, 0x2e, 0x3b, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, +} + +var ( + file_kftask_kftask_db_proto_rawDescOnce sync.Once + file_kftask_kftask_db_proto_rawDescData = file_kftask_kftask_db_proto_rawDesc +) + +func file_kftask_kftask_db_proto_rawDescGZIP() []byte { + file_kftask_kftask_db_proto_rawDescOnce.Do(func() { + file_kftask_kftask_db_proto_rawDescData = protoimpl.X.CompressGZIP(file_kftask_kftask_db_proto_rawDescData) + }) + return file_kftask_kftask_db_proto_rawDescData +} + +var file_kftask_kftask_db_proto_msgTypes = make([]protoimpl.MessageInfo, 2) +var file_kftask_kftask_db_proto_goTypes = []interface{}{ + (*DBKFTask)(nil), // 0: DBKFTask + nil, // 1: DBKFTask.TasksEntry +} +var file_kftask_kftask_db_proto_depIdxs = []int32{ + 1, // 0: DBKFTask.tasks:type_name -> DBKFTask.TasksEntry + 1, // [1:1] is the sub-list for method output_type + 1, // [1:1] is the sub-list for method input_type + 1, // [1:1] is the sub-list for extension type_name + 1, // [1:1] is the sub-list for extension extendee + 0, // [0:1] is the sub-list for field type_name +} + +func init() { file_kftask_kftask_db_proto_init() } +func file_kftask_kftask_db_proto_init() { + if File_kftask_kftask_db_proto != nil { + return + } + if !protoimpl.UnsafeEnabled { + file_kftask_kftask_db_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*DBKFTask); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + } + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: file_kftask_kftask_db_proto_rawDesc, + NumEnums: 0, + NumMessages: 2, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_kftask_kftask_db_proto_goTypes, + DependencyIndexes: file_kftask_kftask_db_proto_depIdxs, + MessageInfos: file_kftask_kftask_db_proto_msgTypes, + }.Build() + File_kftask_kftask_db_proto = out.File + file_kftask_kftask_db_proto_rawDesc = nil + file_kftask_kftask_db_proto_goTypes = nil + file_kftask_kftask_db_proto_depIdxs = nil +} diff --git a/pb/kftask_msg.pb.go b/pb/kftask_msg.pb.go new file mode 100644 index 000000000..130866206 --- /dev/null +++ b/pb/kftask_msg.pb.go @@ -0,0 +1,358 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.28.0 +// protoc v3.20.0 +// source: kftask/kftask_msg.proto + +package pb + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +//开服任务数据 +type KFTaskInfoReq struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *KFTaskInfoReq) Reset() { + *x = KFTaskInfoReq{} + if protoimpl.UnsafeEnabled { + mi := &file_kftask_kftask_msg_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *KFTaskInfoReq) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*KFTaskInfoReq) ProtoMessage() {} + +func (x *KFTaskInfoReq) ProtoReflect() protoreflect.Message { + mi := &file_kftask_kftask_msg_proto_msgTypes[0] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use KFTaskInfoReq.ProtoReflect.Descriptor instead. +func (*KFTaskInfoReq) Descriptor() ([]byte, []int) { + return file_kftask_kftask_msg_proto_rawDescGZIP(), []int{0} +} + +//开服任务数据 +type KFTaskInfoResp struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Conlds []*ConIProgress `protobuf:"bytes,1,rep,name=conlds,proto3" json:"conlds"` //子任务进度数据 + Tasks map[int32]int32 `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"` +} + +func (x *KFTaskInfoResp) Reset() { + *x = KFTaskInfoResp{} + if protoimpl.UnsafeEnabled { + mi := &file_kftask_kftask_msg_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *KFTaskInfoResp) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*KFTaskInfoResp) ProtoMessage() {} + +func (x *KFTaskInfoResp) ProtoReflect() protoreflect.Message { + mi := &file_kftask_kftask_msg_proto_msgTypes[1] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use KFTaskInfoResp.ProtoReflect.Descriptor instead. +func (*KFTaskInfoResp) Descriptor() ([]byte, []int) { + return file_kftask_kftask_msg_proto_rawDescGZIP(), []int{1} +} + +func (x *KFTaskInfoResp) GetConlds() []*ConIProgress { + if x != nil { + return x.Conlds + } + return nil +} + +func (x *KFTaskInfoResp) GetTasks() map[int32]int32 { + if x != nil { + return x.Tasks + } + return nil +} + +//领奖 请求 +type KFTaskReceiveReq struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id"` +} + +func (x *KFTaskReceiveReq) Reset() { + *x = KFTaskReceiveReq{} + if protoimpl.UnsafeEnabled { + mi := &file_kftask_kftask_msg_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *KFTaskReceiveReq) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*KFTaskReceiveReq) ProtoMessage() {} + +func (x *KFTaskReceiveReq) ProtoReflect() protoreflect.Message { + mi := &file_kftask_kftask_msg_proto_msgTypes[2] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use KFTaskReceiveReq.ProtoReflect.Descriptor instead. +func (*KFTaskReceiveReq) Descriptor() ([]byte, []int) { + return file_kftask_kftask_msg_proto_rawDescGZIP(), []int{2} +} + +func (x *KFTaskReceiveReq) GetId() int32 { + if x != nil { + return x.Id + } + return 0 +} + +//领奖 请求回应 +type KFTaskReceiveResp struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id"` + Award []*UserAssets `protobuf:"bytes,2,rep,name=award,proto3" json:"award"` //奖励 +} + +func (x *KFTaskReceiveResp) Reset() { + *x = KFTaskReceiveResp{} + if protoimpl.UnsafeEnabled { + mi := &file_kftask_kftask_msg_proto_msgTypes[3] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *KFTaskReceiveResp) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*KFTaskReceiveResp) ProtoMessage() {} + +func (x *KFTaskReceiveResp) ProtoReflect() protoreflect.Message { + mi := &file_kftask_kftask_msg_proto_msgTypes[3] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use KFTaskReceiveResp.ProtoReflect.Descriptor instead. +func (*KFTaskReceiveResp) Descriptor() ([]byte, []int) { + return file_kftask_kftask_msg_proto_rawDescGZIP(), []int{3} +} + +func (x *KFTaskReceiveResp) GetId() int32 { + if x != nil { + return x.Id + } + return 0 +} + +func (x *KFTaskReceiveResp) GetAward() []*UserAssets { + if x != nil { + return x.Award + } + return nil +} + +var File_kftask_kftask_msg_proto protoreflect.FileDescriptor + +var file_kftask_kftask_msg_proto_rawDesc = []byte{ + 0x0a, 0x17, 0x6b, 0x66, 0x74, 0x61, 0x73, 0x6b, 0x2f, 0x6b, 0x66, 0x74, 0x61, 0x73, 0x6b, 0x5f, + 0x6d, 0x73, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x16, 0x62, 0x75, 0x72, 0x69, 0x65, + 0x64, 0x2f, 0x62, 0x75, 0x72, 0x69, 0x65, 0x64, 0x5f, 0x64, 0x62, 0x2e, 0x70, 0x72, 0x6f, 0x74, + 0x6f, 0x1a, 0x0a, 0x63, 0x6f, 0x6d, 0x6d, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x0f, 0x0a, + 0x0d, 0x4b, 0x46, 0x54, 0x61, 0x73, 0x6b, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x65, 0x71, 0x22, 0xa3, + 0x01, 0x0a, 0x0e, 0x4b, 0x46, 0x54, 0x61, 0x73, 0x6b, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x65, 0x73, + 0x70, 0x12, 0x25, 0x0a, 0x06, 0x63, 0x6f, 0x6e, 0x6c, 0x64, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, + 0x0b, 0x32, 0x0d, 0x2e, 0x43, 0x6f, 0x6e, 0x49, 0x50, 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, + 0x52, 0x06, 0x63, 0x6f, 0x6e, 0x6c, 0x64, 0x73, 0x12, 0x30, 0x0a, 0x05, 0x74, 0x61, 0x73, 0x6b, + 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x4b, 0x46, 0x54, 0x61, 0x73, 0x6b, + 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x65, 0x73, 0x70, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x45, 0x6e, + 0x74, 0x72, 0x79, 0x52, 0x05, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x1a, 0x38, 0x0a, 0x0a, 0x54, 0x61, + 0x73, 0x6b, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, + 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, + 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, + 0x3a, 0x02, 0x38, 0x01, 0x22, 0x22, 0x0a, 0x10, 0x4b, 0x46, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x65, + 0x63, 0x65, 0x69, 0x76, 0x65, 0x52, 0x65, 0x71, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, + 0x20, 0x01, 0x28, 0x05, 0x52, 0x02, 0x69, 0x64, 0x22, 0x46, 0x0a, 0x11, 0x4b, 0x46, 0x54, 0x61, + 0x73, 0x6b, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x52, 0x65, 0x73, 0x70, 0x12, 0x0e, 0x0a, + 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x02, 0x69, 0x64, 0x12, 0x21, 0x0a, + 0x05, 0x61, 0x77, 0x61, 0x72, 0x64, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0b, 0x2e, 0x55, + 0x73, 0x65, 0x72, 0x41, 0x73, 0x73, 0x65, 0x74, 0x73, 0x52, 0x05, 0x61, 0x77, 0x61, 0x72, 0x64, + 0x42, 0x06, 0x5a, 0x04, 0x2e, 0x3b, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, +} + +var ( + file_kftask_kftask_msg_proto_rawDescOnce sync.Once + file_kftask_kftask_msg_proto_rawDescData = file_kftask_kftask_msg_proto_rawDesc +) + +func file_kftask_kftask_msg_proto_rawDescGZIP() []byte { + file_kftask_kftask_msg_proto_rawDescOnce.Do(func() { + file_kftask_kftask_msg_proto_rawDescData = protoimpl.X.CompressGZIP(file_kftask_kftask_msg_proto_rawDescData) + }) + return file_kftask_kftask_msg_proto_rawDescData +} + +var file_kftask_kftask_msg_proto_msgTypes = make([]protoimpl.MessageInfo, 5) +var file_kftask_kftask_msg_proto_goTypes = []interface{}{ + (*KFTaskInfoReq)(nil), // 0: KFTaskInfoReq + (*KFTaskInfoResp)(nil), // 1: KFTaskInfoResp + (*KFTaskReceiveReq)(nil), // 2: KFTaskReceiveReq + (*KFTaskReceiveResp)(nil), // 3: KFTaskReceiveResp + nil, // 4: KFTaskInfoResp.TasksEntry + (*ConIProgress)(nil), // 5: ConIProgress + (*UserAssets)(nil), // 6: UserAssets +} +var file_kftask_kftask_msg_proto_depIdxs = []int32{ + 5, // 0: KFTaskInfoResp.conlds:type_name -> ConIProgress + 4, // 1: KFTaskInfoResp.tasks:type_name -> KFTaskInfoResp.TasksEntry + 6, // 2: KFTaskReceiveResp.award:type_name -> UserAssets + 3, // [3:3] is the sub-list for method output_type + 3, // [3:3] is the sub-list for method input_type + 3, // [3:3] is the sub-list for extension type_name + 3, // [3:3] is the sub-list for extension extendee + 0, // [0:3] is the sub-list for field type_name +} + +func init() { file_kftask_kftask_msg_proto_init() } +func file_kftask_kftask_msg_proto_init() { + if File_kftask_kftask_msg_proto != nil { + return + } + file_buried_buried_db_proto_init() + file_comm_proto_init() + if !protoimpl.UnsafeEnabled { + file_kftask_kftask_msg_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*KFTaskInfoReq); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_kftask_kftask_msg_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*KFTaskInfoResp); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_kftask_kftask_msg_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*KFTaskReceiveReq); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_kftask_kftask_msg_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*KFTaskReceiveResp); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + } + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: file_kftask_kftask_msg_proto_rawDesc, + NumEnums: 0, + NumMessages: 5, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_kftask_kftask_msg_proto_goTypes, + DependencyIndexes: file_kftask_kftask_msg_proto_depIdxs, + MessageInfos: file_kftask_kftask_msg_proto_msgTypes, + }.Build() + File_kftask_kftask_msg_proto = out.File + file_kftask_kftask_msg_proto_rawDesc = nil + file_kftask_kftask_msg_proto_goTypes = nil + file_kftask_kftask_msg_proto_depIdxs = nil +} diff --git a/services/worker/main.go b/services/worker/main.go index 0ed15695a..4625997d3 100644 --- a/services/worker/main.go +++ b/services/worker/main.go @@ -24,9 +24,11 @@ import ( "go_dreamfactory/modules/guidance" "go_dreamfactory/modules/guildgve" "go_dreamfactory/modules/hero" + "go_dreamfactory/modules/herotask" "go_dreamfactory/modules/horoscope" "go_dreamfactory/modules/hunting" "go_dreamfactory/modules/items" + "go_dreamfactory/modules/kftask" "go_dreamfactory/modules/library" "go_dreamfactory/modules/linestory" "go_dreamfactory/modules/mail" @@ -142,6 +144,8 @@ func main() { dailytask.NewModule(), questionnaire.NewModule(), mainline.NewModule(), + kftask.NewModule(), + herotask.NewModule(), ) }