上传开服任务和守护者任务

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 //开服任务
 )

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
+}

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
+}

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
+}

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()
+}

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
+}

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
+	}
+}

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
+}

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
+}

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
+}

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
+}

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
+}

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
+	}
+}

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
+}

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
+}

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
+}

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
+}

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(),
 	)
 }