From 2aba12b6801112dd7ec3d4f6867a8897a2da74dc Mon Sep 17 00:00:00 2001 From: meixiongfeng <766881921@qq.com> Date: Tue, 14 Nov 2023 14:30:58 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8A=A4=E6=9C=88=E7=AD=89=E7=BA=A7=20?= =?UTF-8?q?=E6=A8=A1=E5=9D=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- comm/const.go | 3 + modules/moonlv/api.go | 25 ++ modules/moonlv/api_atlasactivate.go | 26 ++ modules/moonlv/api_atlasaward.go | 20 ++ modules/moonlv/api_getlist.go | 29 ++ modules/moonlv/comp_configure.go | 64 ++++ modules/moonlv/model_moonlv.go | 47 +++ modules/moonlv/module.go | 38 +++ modules/user/api_login.go | 1 + pb/moonlv_db.pb.go | 273 ++++++++++++++++ pb/moonlv_msg.pb.go | 491 ++++++++++++++++++++++++++++ 11 files changed, 1017 insertions(+) create mode 100644 modules/moonlv/api.go create mode 100644 modules/moonlv/api_atlasactivate.go create mode 100644 modules/moonlv/api_atlasaward.go create mode 100644 modules/moonlv/api_getlist.go create mode 100644 modules/moonlv/comp_configure.go create mode 100644 modules/moonlv/model_moonlv.go create mode 100644 modules/moonlv/module.go create mode 100644 pb/moonlv_db.pb.go create mode 100644 pb/moonlv_msg.pb.go diff --git a/comm/const.go b/comm/const.go index 030c100a4..2f5affed6 100644 --- a/comm/const.go +++ b/comm/const.go @@ -123,6 +123,7 @@ const ( ModuleIsLand core.M_Modules = "island" //海岛探险 ModuleEgghunt core.M_Modules = "egghunt" //彩蛋 ModuleCatchbugs core.M_Modules = "catchbugs" //捉虫子 + ModuleMoonlv core.M_Modules = "monnlv" //护月等级 ) // 数据表名定义处 @@ -419,6 +420,8 @@ const ( //用户日志 TableUserLog = "userlog" + + TableMoonlv = "moonlv" ) // RPC服务接口定义处 diff --git a/modules/moonlv/api.go b/modules/moonlv/api.go new file mode 100644 index 000000000..68d49565c --- /dev/null +++ b/modules/moonlv/api.go @@ -0,0 +1,25 @@ +package moonlv + +import ( + "go_dreamfactory/lego/core" + "go_dreamfactory/modules" +) + +type apiComp struct { + modules.MCompGate + service core.IService + module *Moonlv +} + +//组件初始化接口 +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.module = module.(*Moonlv) + this.service = service + return +} + +func (this *apiComp) Start() (err error) { + err = this.MCompGate.Start() + return +} diff --git a/modules/moonlv/api_atlasactivate.go b/modules/moonlv/api_atlasactivate.go new file mode 100644 index 000000000..089630cad --- /dev/null +++ b/modules/moonlv/api_atlasactivate.go @@ -0,0 +1,26 @@ +package moonlv + +import ( + "go_dreamfactory/comm" + "go_dreamfactory/pb" +) + +//参数校验 +func (this *apiComp) ActivateCheck(session comm.IUserSession, req *pb.AtlasActivateReq) (errdata *pb.ErrorData) { + if req.Id == "" { + errdata = &pb.ErrorData{ + Code: pb.ErrorCode_ReqParameterError, + Title: pb.ErrorCode_ReqParameterError.ToString(), + } + } + return +} + +// 激活图鉴信息 +func (this *apiComp) Activate(session comm.IUserSession, req *pb.AtlasActivateReq) (errdata *pb.ErrorData) { + if errdata = this.ActivateCheck(session, req); errdata != nil { + return + } + + return +} diff --git a/modules/moonlv/api_atlasaward.go b/modules/moonlv/api_atlasaward.go new file mode 100644 index 000000000..46eff30cd --- /dev/null +++ b/modules/moonlv/api_atlasaward.go @@ -0,0 +1,20 @@ +package moonlv + +import ( + "go_dreamfactory/comm" + "go_dreamfactory/pb" +) + +//参数校验 +func (this *apiComp) AwardCheck(session comm.IUserSession, req *pb.AtlasAwardReq) (errdata *pb.ErrorData) { + + return +} + +// 一键领取所有可以领取的奖励 +func (this *apiComp) Award(session comm.IUserSession, req *pb.AtlasAwardReq) (errdata *pb.ErrorData) { + + session.SendMsg(string(this.module.GetType()), "award", &pb.AtlasAwardResp{}) + + return +} diff --git a/modules/moonlv/api_getlist.go b/modules/moonlv/api_getlist.go new file mode 100644 index 000000000..4dd10afd4 --- /dev/null +++ b/modules/moonlv/api_getlist.go @@ -0,0 +1,29 @@ +package moonlv + +import ( + "go_dreamfactory/comm" + "go_dreamfactory/pb" +) + +//参数校验 +func (this *apiComp) GetListCheck(session comm.IUserSession, req *pb.MoonlvGetListReq) (errdata *pb.ErrorData) { + + return +} + +// 获取护月等级基本信息 +func (this *apiComp) GetList(session comm.IUserSession, req *pb.MoonlvGetListReq) (errdata *pb.ErrorData) { + + list, err := this.module.modelMoonlv.getMoonlvList(session.GetUserId()) + if err != nil { + errdata = &pb.ErrorData{ + Code: pb.ErrorCode_DBError, + Title: pb.ErrorCode_DBError.ToString(), + } + return + } + session.SendMsg(string(this.module.GetType()), "getlist", &pb.MoonlvGetListResp{ + Data: list, + }) + return +} diff --git a/modules/moonlv/comp_configure.go b/modules/moonlv/comp_configure.go new file mode 100644 index 000000000..c06db5184 --- /dev/null +++ b/modules/moonlv/comp_configure.go @@ -0,0 +1,64 @@ +package moonlv + +import ( + "go_dreamfactory/comm" + "go_dreamfactory/lego/core" + "go_dreamfactory/lego/sys/log" + "go_dreamfactory/modules" + "go_dreamfactory/sys/configure" + cfg "go_dreamfactory/sys/configure/structs" +) + +const ( + pandaJx = "game_pandamasjx.json" // 武馆教习 + +) + +// /配置管理基础组件 +type configureComp struct { + modules.MCompConfigure + module *Moonlv +} + +// 组件初始化接口 +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.(*Moonlv) + err = this.LoadMultiConfigure(map[string]interface{}{ + pandaJx: cfg.NewGamePandamasJx, + }) + + return +} + +// 加载多个配置文件 +func (this *configureComp) LoadMultiConfigure(confs map[string]interface{}) (err error) { + for k, v := range confs { + err = configure.RegisterConfigure(k, v, nil) + if err != nil { + log.Errorf("配置文件:%s解析失败!", k) + break + } + } + return +} + +// 读取配置数据 +func (this *configureComp) GetConfigure(name string) (v interface{}, err error) { + return configure.GetConfigure(name) +} + +// 获取教习数据 +func (this *configureComp) GetPandoJxConf(id string) (conf *cfg.GamePandamasJxData, err error) { + + if v, err := this.GetConfigure(pandaJx); err == nil { + if configure, ok := v.(*cfg.GamePandamasJx); ok { + if conf = configure.Get(id); conf == nil { + err = comm.NewNotFoundConfErr("atlas", pandaJx, id) + this.module.Errorln(err) + } + } + } + err = comm.NewNotFoundConfErr("atlas", pandaJx, id) + return +} diff --git a/modules/moonlv/model_moonlv.go b/modules/moonlv/model_moonlv.go new file mode 100644 index 000000000..8a441c036 --- /dev/null +++ b/modules/moonlv/model_moonlv.go @@ -0,0 +1,47 @@ +package moonlv + +import ( + "go_dreamfactory/comm" + "go_dreamfactory/lego/core" + "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 modelMoonlv struct { + modules.MCompModel + module *Moonlv +} + +func (this *modelMoonlv) Init(service core.IService, module core.IModule, comp core.IModuleComp, options core.IModuleOptions) (err error) { + this.TableName = string(comm.TableMoonlv) + err = this.MCompModel.Init(service, module, comp, options) + this.module = module.(*Moonlv) + // uid 创建索引 + this.DB.CreateIndex(core.SqlTable(this.TableName), mongo.IndexModel{ + Keys: bsonx.Doc{{Key: "uid", Value: bsonx.Int32(1)}}, + }) + return +} + +func (this *modelMoonlv) getMoonlvList(uid string) (result *pb.DBMoonLv, err error) { + result = &pb.DBMoonLv{} + if err = this.Get(uid, result); err != nil { + if mongo.ErrNoDocuments == err { + result.Id = primitive.NewObjectID().Hex() + result.Uid = uid + result.Reward = make(map[int32]bool) + this.Add(uid, result) + err = nil + } + return + } + return +} + +func (this *modelMoonlv) modifyMoonlvList(uid string, data map[string]interface{}) error { + return this.Change(uid, data) +} diff --git a/modules/moonlv/module.go b/modules/moonlv/module.go new file mode 100644 index 000000000..89ec171a2 --- /dev/null +++ b/modules/moonlv/module.go @@ -0,0 +1,38 @@ +package moonlv + +import ( + "go_dreamfactory/comm" + "go_dreamfactory/lego/core" + "go_dreamfactory/modules" +) + +type Moonlv struct { + modules.ModuleBase + api *apiComp + configure *configureComp + modelMoonlv *modelMoonlv + service core.IService +} + +func NewModule() core.IModule { + return &Moonlv{} +} + +func (this *Moonlv) GetType() core.M_Modules { + return comm.ModuleMoonlv +} + +func (this *Moonlv) Init(service core.IService, module core.IModule, options core.IModuleOptions) (err error) { + if err = this.ModuleBase.Init(service, module, options); err != nil { + return + } + this.service = service + return +} + +func (this *Moonlv) OnInstallComp() { + this.ModuleBase.OnInstallComp() + this.api = this.RegisterComp(new(apiComp)).(*apiComp) + this.configure = this.RegisterComp(new(configureComp)).(*configureComp) + this.modelMoonlv = this.RegisterComp(new(modelMoonlv)).(*modelMoonlv) +} diff --git a/modules/user/api_login.go b/modules/user/api_login.go index 96f49be07..38423be76 100644 --- a/modules/user/api_login.go +++ b/modules/user/api_login.go @@ -73,6 +73,7 @@ func (this *apiComp) Login(session comm.IUserSession, req *pb.UserLoginReq) (err expand = &pb.DBUserExpand{} user.CurSkin = this.module.ModuleTools.GetGlobalConf().Initper.T + user.Skins = []string{user.CurSkin} } // 玩家是否封号 if user.Ban { diff --git a/pb/moonlv_db.pb.go b/pb/moonlv_db.pb.go new file mode 100644 index 000000000..f374b7452 --- /dev/null +++ b/pb/moonlv_db.pb.go @@ -0,0 +1,273 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.28.0 +// protoc v3.20.0 +// source: moonlv/moonlv_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 DBMoonLv struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id" bson:"_id"` //ID + Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid" bson:"uid"` //用户ID + Tasks []*MoonTask `protobuf:"bytes,3,rep,name=tasks,proto3" json:"tasks" bson:"tasks"` // 任务列表 + Lv int32 `protobuf:"varint,4,opt,name=lv,proto3" json:"lv"` // 月明度等级 + Reward map[int32]bool `protobuf:"bytes,5,rep,name=reward,proto3" json:"reward" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"` // 等级奖励 +} + +func (x *DBMoonLv) Reset() { + *x = DBMoonLv{} + if protoimpl.UnsafeEnabled { + mi := &file_moonlv_moonlv_db_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *DBMoonLv) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DBMoonLv) ProtoMessage() {} + +func (x *DBMoonLv) ProtoReflect() protoreflect.Message { + mi := &file_moonlv_moonlv_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 DBMoonLv.ProtoReflect.Descriptor instead. +func (*DBMoonLv) Descriptor() ([]byte, []int) { + return file_moonlv_moonlv_db_proto_rawDescGZIP(), []int{0} +} + +func (x *DBMoonLv) GetId() string { + if x != nil { + return x.Id + } + return "" +} + +func (x *DBMoonLv) GetUid() string { + if x != nil { + return x.Uid + } + return "" +} + +func (x *DBMoonLv) GetTasks() []*MoonTask { + if x != nil { + return x.Tasks + } + return nil +} + +func (x *DBMoonLv) GetLv() int32 { + if x != nil { + return x.Lv + } + return 0 +} + +func (x *DBMoonLv) GetReward() map[int32]bool { + if x != nil { + return x.Reward + } + return nil +} + +type MoonTask struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + TaskId int32 `protobuf:"varint,1,opt,name=taskId,proto3" json:"taskId" bson:"taskId"` // 任务ID + Received int32 `protobuf:"varint,2,opt,name=received,proto3" json:"received" bson:"received"` //领取状态 0未领取 1待领取 2已领取 + Cond *ConIProgress `protobuf:"bytes,3,opt,name=cond,proto3" json:"cond" bson:"cond"` //任务进度 +} + +func (x *MoonTask) Reset() { + *x = MoonTask{} + if protoimpl.UnsafeEnabled { + mi := &file_moonlv_moonlv_db_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *MoonTask) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*MoonTask) ProtoMessage() {} + +func (x *MoonTask) ProtoReflect() protoreflect.Message { + mi := &file_moonlv_moonlv_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 MoonTask.ProtoReflect.Descriptor instead. +func (*MoonTask) Descriptor() ([]byte, []int) { + return file_moonlv_moonlv_db_proto_rawDescGZIP(), []int{1} +} + +func (x *MoonTask) GetTaskId() int32 { + if x != nil { + return x.TaskId + } + return 0 +} + +func (x *MoonTask) GetReceived() int32 { + if x != nil { + return x.Received + } + return 0 +} + +func (x *MoonTask) GetCond() *ConIProgress { + if x != nil { + return x.Cond + } + return nil +} + +var File_moonlv_moonlv_db_proto protoreflect.FileDescriptor + +var file_moonlv_moonlv_db_proto_rawDesc = []byte{ + 0x0a, 0x16, 0x6d, 0x6f, 0x6f, 0x6e, 0x6c, 0x76, 0x2f, 0x6d, 0x6f, 0x6f, 0x6e, 0x6c, 0x76, 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, + 0x22, 0xc7, 0x01, 0x0a, 0x08, 0x44, 0x42, 0x4d, 0x6f, 0x6f, 0x6e, 0x4c, 0x76, 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, + 0x1f, 0x0a, 0x05, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x09, + 0x2e, 0x4d, 0x6f, 0x6f, 0x6e, 0x54, 0x61, 0x73, 0x6b, 0x52, 0x05, 0x74, 0x61, 0x73, 0x6b, 0x73, + 0x12, 0x0e, 0x0a, 0x02, 0x6c, 0x76, 0x18, 0x04, 0x20, 0x01, 0x28, 0x05, 0x52, 0x02, 0x6c, 0x76, + 0x12, 0x2d, 0x0a, 0x06, 0x72, 0x65, 0x77, 0x61, 0x72, 0x64, 0x18, 0x05, 0x20, 0x03, 0x28, 0x0b, + 0x32, 0x15, 0x2e, 0x44, 0x42, 0x4d, 0x6f, 0x6f, 0x6e, 0x4c, 0x76, 0x2e, 0x52, 0x65, 0x77, 0x61, + 0x72, 0x64, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x06, 0x72, 0x65, 0x77, 0x61, 0x72, 0x64, 0x1a, + 0x39, 0x0a, 0x0b, 0x52, 0x65, 0x77, 0x61, 0x72, 0x64, 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, 0x08, 0x52, + 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x61, 0x0a, 0x08, 0x4d, 0x6f, + 0x6f, 0x6e, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x16, 0x0a, 0x06, 0x74, 0x61, 0x73, 0x6b, 0x49, 0x64, + 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x06, 0x74, 0x61, 0x73, 0x6b, 0x49, 0x64, 0x12, 0x1a, + 0x0a, 0x08, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, + 0x52, 0x08, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x64, 0x12, 0x21, 0x0a, 0x04, 0x63, 0x6f, + 0x6e, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0d, 0x2e, 0x43, 0x6f, 0x6e, 0x49, 0x50, + 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, 0x52, 0x04, 0x63, 0x6f, 0x6e, 0x64, 0x42, 0x06, 0x5a, + 0x04, 0x2e, 0x3b, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, +} + +var ( + file_moonlv_moonlv_db_proto_rawDescOnce sync.Once + file_moonlv_moonlv_db_proto_rawDescData = file_moonlv_moonlv_db_proto_rawDesc +) + +func file_moonlv_moonlv_db_proto_rawDescGZIP() []byte { + file_moonlv_moonlv_db_proto_rawDescOnce.Do(func() { + file_moonlv_moonlv_db_proto_rawDescData = protoimpl.X.CompressGZIP(file_moonlv_moonlv_db_proto_rawDescData) + }) + return file_moonlv_moonlv_db_proto_rawDescData +} + +var file_moonlv_moonlv_db_proto_msgTypes = make([]protoimpl.MessageInfo, 3) +var file_moonlv_moonlv_db_proto_goTypes = []interface{}{ + (*DBMoonLv)(nil), // 0: DBMoonLv + (*MoonTask)(nil), // 1: MoonTask + nil, // 2: DBMoonLv.RewardEntry + (*ConIProgress)(nil), // 3: ConIProgress +} +var file_moonlv_moonlv_db_proto_depIdxs = []int32{ + 1, // 0: DBMoonLv.tasks:type_name -> MoonTask + 2, // 1: DBMoonLv.reward:type_name -> DBMoonLv.RewardEntry + 3, // 2: MoonTask.cond:type_name -> ConIProgress + 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_moonlv_moonlv_db_proto_init() } +func file_moonlv_moonlv_db_proto_init() { + if File_moonlv_moonlv_db_proto != nil { + return + } + file_buried_buried_db_proto_init() + if !protoimpl.UnsafeEnabled { + file_moonlv_moonlv_db_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*DBMoonLv); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_moonlv_moonlv_db_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*MoonTask); 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_moonlv_moonlv_db_proto_rawDesc, + NumEnums: 0, + NumMessages: 3, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_moonlv_moonlv_db_proto_goTypes, + DependencyIndexes: file_moonlv_moonlv_db_proto_depIdxs, + MessageInfos: file_moonlv_moonlv_db_proto_msgTypes, + }.Build() + File_moonlv_moonlv_db_proto = out.File + file_moonlv_moonlv_db_proto_rawDesc = nil + file_moonlv_moonlv_db_proto_goTypes = nil + file_moonlv_moonlv_db_proto_depIdxs = nil +} diff --git a/pb/moonlv_msg.pb.go b/pb/moonlv_msg.pb.go new file mode 100644 index 000000000..62e175bd2 --- /dev/null +++ b/pb/moonlv_msg.pb.go @@ -0,0 +1,491 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.28.0 +// protoc v3.20.0 +// source: moonlv/moonlv_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 MoonlvGetListReq struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *MoonlvGetListReq) Reset() { + *x = MoonlvGetListReq{} + if protoimpl.UnsafeEnabled { + mi := &file_moonlv_moonlv_msg_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *MoonlvGetListReq) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*MoonlvGetListReq) ProtoMessage() {} + +func (x *MoonlvGetListReq) ProtoReflect() protoreflect.Message { + mi := &file_moonlv_moonlv_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 MoonlvGetListReq.ProtoReflect.Descriptor instead. +func (*MoonlvGetListReq) Descriptor() ([]byte, []int) { + return file_moonlv_moonlv_msg_proto_rawDescGZIP(), []int{0} +} + +type MoonlvGetListResp struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Data *DBMoonLv `protobuf:"bytes,1,opt,name=data,proto3" json:"data"` +} + +func (x *MoonlvGetListResp) Reset() { + *x = MoonlvGetListResp{} + if protoimpl.UnsafeEnabled { + mi := &file_moonlv_moonlv_msg_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *MoonlvGetListResp) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*MoonlvGetListResp) ProtoMessage() {} + +func (x *MoonlvGetListResp) ProtoReflect() protoreflect.Message { + mi := &file_moonlv_moonlv_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 MoonlvGetListResp.ProtoReflect.Descriptor instead. +func (*MoonlvGetListResp) Descriptor() ([]byte, []int) { + return file_moonlv_moonlv_msg_proto_rawDescGZIP(), []int{1} +} + +func (x *MoonlvGetListResp) GetData() *DBMoonLv { + if x != nil { + return x.Data + } + return nil +} + +// 等级奖励领取 +type MoonlvAwardReq struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Lv int32 `protobuf:"varint,1,opt,name=lv,proto3" json:"lv"` +} + +func (x *MoonlvAwardReq) Reset() { + *x = MoonlvAwardReq{} + if protoimpl.UnsafeEnabled { + mi := &file_moonlv_moonlv_msg_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *MoonlvAwardReq) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*MoonlvAwardReq) ProtoMessage() {} + +func (x *MoonlvAwardReq) ProtoReflect() protoreflect.Message { + mi := &file_moonlv_moonlv_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 MoonlvAwardReq.ProtoReflect.Descriptor instead. +func (*MoonlvAwardReq) Descriptor() ([]byte, []int) { + return file_moonlv_moonlv_msg_proto_rawDescGZIP(), []int{2} +} + +func (x *MoonlvAwardReq) GetLv() int32 { + if x != nil { + return x.Lv + } + return 0 +} + +type MoonlvAwardResp struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Data *DBMoonLv `protobuf:"bytes,1,opt,name=data,proto3" json:"data"` // 奖励信息 + Res []*UserAssets `protobuf:"bytes,2,rep,name=res,proto3" json:"res"` // 获得的奖励 +} + +func (x *MoonlvAwardResp) Reset() { + *x = MoonlvAwardResp{} + if protoimpl.UnsafeEnabled { + mi := &file_moonlv_moonlv_msg_proto_msgTypes[3] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *MoonlvAwardResp) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*MoonlvAwardResp) ProtoMessage() {} + +func (x *MoonlvAwardResp) ProtoReflect() protoreflect.Message { + mi := &file_moonlv_moonlv_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 MoonlvAwardResp.ProtoReflect.Descriptor instead. +func (*MoonlvAwardResp) Descriptor() ([]byte, []int) { + return file_moonlv_moonlv_msg_proto_rawDescGZIP(), []int{3} +} + +func (x *MoonlvAwardResp) GetData() *DBMoonLv { + if x != nil { + return x.Data + } + return nil +} + +func (x *MoonlvAwardResp) GetRes() []*UserAssets { + if x != nil { + return x.Res + } + return nil +} + +// 任务奖励领取 +type MoonlvTaskAwardReq struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + TaskId int32 `protobuf:"varint,1,opt,name=taskId,proto3" json:"taskId"` +} + +func (x *MoonlvTaskAwardReq) Reset() { + *x = MoonlvTaskAwardReq{} + if protoimpl.UnsafeEnabled { + mi := &file_moonlv_moonlv_msg_proto_msgTypes[4] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *MoonlvTaskAwardReq) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*MoonlvTaskAwardReq) ProtoMessage() {} + +func (x *MoonlvTaskAwardReq) ProtoReflect() protoreflect.Message { + mi := &file_moonlv_moonlv_msg_proto_msgTypes[4] + 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 MoonlvTaskAwardReq.ProtoReflect.Descriptor instead. +func (*MoonlvTaskAwardReq) Descriptor() ([]byte, []int) { + return file_moonlv_moonlv_msg_proto_rawDescGZIP(), []int{4} +} + +func (x *MoonlvTaskAwardReq) GetTaskId() int32 { + if x != nil { + return x.TaskId + } + return 0 +} + +type MoonlvTaskAwardResp struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + TaskId int32 `protobuf:"varint,1,opt,name=taskId,proto3" json:"taskId"` + Reward []*UserAtno `protobuf:"bytes,2,rep,name=reward,proto3" json:"reward"` // 获得的奖励 + Data *DBMoonLv `protobuf:"bytes,3,opt,name=data,proto3" json:"data"` +} + +func (x *MoonlvTaskAwardResp) Reset() { + *x = MoonlvTaskAwardResp{} + if protoimpl.UnsafeEnabled { + mi := &file_moonlv_moonlv_msg_proto_msgTypes[5] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *MoonlvTaskAwardResp) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*MoonlvTaskAwardResp) ProtoMessage() {} + +func (x *MoonlvTaskAwardResp) ProtoReflect() protoreflect.Message { + mi := &file_moonlv_moonlv_msg_proto_msgTypes[5] + 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 MoonlvTaskAwardResp.ProtoReflect.Descriptor instead. +func (*MoonlvTaskAwardResp) Descriptor() ([]byte, []int) { + return file_moonlv_moonlv_msg_proto_rawDescGZIP(), []int{5} +} + +func (x *MoonlvTaskAwardResp) GetTaskId() int32 { + if x != nil { + return x.TaskId + } + return 0 +} + +func (x *MoonlvTaskAwardResp) GetReward() []*UserAtno { + if x != nil { + return x.Reward + } + return nil +} + +func (x *MoonlvTaskAwardResp) GetData() *DBMoonLv { + if x != nil { + return x.Data + } + return nil +} + +var File_moonlv_moonlv_msg_proto protoreflect.FileDescriptor + +var file_moonlv_moonlv_msg_proto_rawDesc = []byte{ + 0x0a, 0x17, 0x6d, 0x6f, 0x6f, 0x6e, 0x6c, 0x76, 0x2f, 0x6d, 0x6f, 0x6f, 0x6e, 0x6c, 0x76, 0x5f, + 0x6d, 0x73, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x16, 0x6d, 0x6f, 0x6f, 0x6e, 0x6c, + 0x76, 0x2f, 0x6d, 0x6f, 0x6f, 0x6e, 0x6c, 0x76, 0x5f, 0x64, 0x62, 0x2e, 0x70, 0x72, 0x6f, 0x74, + 0x6f, 0x1a, 0x0a, 0x63, 0x6f, 0x6d, 0x6d, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x12, 0x0a, + 0x10, 0x4d, 0x6f, 0x6f, 0x6e, 0x6c, 0x76, 0x47, 0x65, 0x74, 0x4c, 0x69, 0x73, 0x74, 0x52, 0x65, + 0x71, 0x22, 0x32, 0x0a, 0x11, 0x4d, 0x6f, 0x6f, 0x6e, 0x6c, 0x76, 0x47, 0x65, 0x74, 0x4c, 0x69, + 0x73, 0x74, 0x52, 0x65, 0x73, 0x70, 0x12, 0x1d, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, + 0x20, 0x01, 0x28, 0x0b, 0x32, 0x09, 0x2e, 0x44, 0x42, 0x4d, 0x6f, 0x6f, 0x6e, 0x4c, 0x76, 0x52, + 0x04, 0x64, 0x61, 0x74, 0x61, 0x22, 0x20, 0x0a, 0x0e, 0x4d, 0x6f, 0x6f, 0x6e, 0x6c, 0x76, 0x41, + 0x77, 0x61, 0x72, 0x64, 0x52, 0x65, 0x71, 0x12, 0x0e, 0x0a, 0x02, 0x6c, 0x76, 0x18, 0x01, 0x20, + 0x01, 0x28, 0x05, 0x52, 0x02, 0x6c, 0x76, 0x22, 0x4f, 0x0a, 0x0f, 0x4d, 0x6f, 0x6f, 0x6e, 0x6c, + 0x76, 0x41, 0x77, 0x61, 0x72, 0x64, 0x52, 0x65, 0x73, 0x70, 0x12, 0x1d, 0x0a, 0x04, 0x64, 0x61, + 0x74, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x09, 0x2e, 0x44, 0x42, 0x4d, 0x6f, 0x6f, + 0x6e, 0x4c, 0x76, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x12, 0x1d, 0x0a, 0x03, 0x72, 0x65, 0x73, + 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0b, 0x2e, 0x55, 0x73, 0x65, 0x72, 0x41, 0x73, 0x73, + 0x65, 0x74, 0x73, 0x52, 0x03, 0x72, 0x65, 0x73, 0x22, 0x2c, 0x0a, 0x12, 0x4d, 0x6f, 0x6f, 0x6e, + 0x6c, 0x76, 0x54, 0x61, 0x73, 0x6b, 0x41, 0x77, 0x61, 0x72, 0x64, 0x52, 0x65, 0x71, 0x12, 0x16, + 0x0a, 0x06, 0x74, 0x61, 0x73, 0x6b, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x06, + 0x74, 0x61, 0x73, 0x6b, 0x49, 0x64, 0x22, 0x6f, 0x0a, 0x13, 0x4d, 0x6f, 0x6f, 0x6e, 0x6c, 0x76, + 0x54, 0x61, 0x73, 0x6b, 0x41, 0x77, 0x61, 0x72, 0x64, 0x52, 0x65, 0x73, 0x70, 0x12, 0x16, 0x0a, + 0x06, 0x74, 0x61, 0x73, 0x6b, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x06, 0x74, + 0x61, 0x73, 0x6b, 0x49, 0x64, 0x12, 0x21, 0x0a, 0x06, 0x72, 0x65, 0x77, 0x61, 0x72, 0x64, 0x18, + 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x09, 0x2e, 0x55, 0x73, 0x65, 0x72, 0x41, 0x74, 0x6e, 0x6f, + 0x52, 0x06, 0x72, 0x65, 0x77, 0x61, 0x72, 0x64, 0x12, 0x1d, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, + 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x09, 0x2e, 0x44, 0x42, 0x4d, 0x6f, 0x6f, 0x6e, 0x4c, + 0x76, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x42, 0x06, 0x5a, 0x04, 0x2e, 0x3b, 0x70, 0x62, 0x62, + 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, +} + +var ( + file_moonlv_moonlv_msg_proto_rawDescOnce sync.Once + file_moonlv_moonlv_msg_proto_rawDescData = file_moonlv_moonlv_msg_proto_rawDesc +) + +func file_moonlv_moonlv_msg_proto_rawDescGZIP() []byte { + file_moonlv_moonlv_msg_proto_rawDescOnce.Do(func() { + file_moonlv_moonlv_msg_proto_rawDescData = protoimpl.X.CompressGZIP(file_moonlv_moonlv_msg_proto_rawDescData) + }) + return file_moonlv_moonlv_msg_proto_rawDescData +} + +var file_moonlv_moonlv_msg_proto_msgTypes = make([]protoimpl.MessageInfo, 6) +var file_moonlv_moonlv_msg_proto_goTypes = []interface{}{ + (*MoonlvGetListReq)(nil), // 0: MoonlvGetListReq + (*MoonlvGetListResp)(nil), // 1: MoonlvGetListResp + (*MoonlvAwardReq)(nil), // 2: MoonlvAwardReq + (*MoonlvAwardResp)(nil), // 3: MoonlvAwardResp + (*MoonlvTaskAwardReq)(nil), // 4: MoonlvTaskAwardReq + (*MoonlvTaskAwardResp)(nil), // 5: MoonlvTaskAwardResp + (*DBMoonLv)(nil), // 6: DBMoonLv + (*UserAssets)(nil), // 7: UserAssets + (*UserAtno)(nil), // 8: UserAtno +} +var file_moonlv_moonlv_msg_proto_depIdxs = []int32{ + 6, // 0: MoonlvGetListResp.data:type_name -> DBMoonLv + 6, // 1: MoonlvAwardResp.data:type_name -> DBMoonLv + 7, // 2: MoonlvAwardResp.res:type_name -> UserAssets + 8, // 3: MoonlvTaskAwardResp.reward:type_name -> UserAtno + 6, // 4: MoonlvTaskAwardResp.data:type_name -> DBMoonLv + 5, // [5:5] is the sub-list for method output_type + 5, // [5:5] is the sub-list for method input_type + 5, // [5:5] is the sub-list for extension type_name + 5, // [5:5] is the sub-list for extension extendee + 0, // [0:5] is the sub-list for field type_name +} + +func init() { file_moonlv_moonlv_msg_proto_init() } +func file_moonlv_moonlv_msg_proto_init() { + if File_moonlv_moonlv_msg_proto != nil { + return + } + file_moonlv_moonlv_db_proto_init() + file_comm_proto_init() + if !protoimpl.UnsafeEnabled { + file_moonlv_moonlv_msg_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*MoonlvGetListReq); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_moonlv_moonlv_msg_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*MoonlvGetListResp); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_moonlv_moonlv_msg_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*MoonlvAwardReq); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_moonlv_moonlv_msg_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*MoonlvAwardResp); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_moonlv_moonlv_msg_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*MoonlvTaskAwardReq); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_moonlv_moonlv_msg_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*MoonlvTaskAwardResp); 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_moonlv_moonlv_msg_proto_rawDesc, + NumEnums: 0, + NumMessages: 6, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_moonlv_moonlv_msg_proto_goTypes, + DependencyIndexes: file_moonlv_moonlv_msg_proto_depIdxs, + MessageInfos: file_moonlv_moonlv_msg_proto_msgTypes, + }.Build() + File_moonlv_moonlv_msg_proto = out.File + file_moonlv_moonlv_msg_proto_rawDesc = nil + file_moonlv_moonlv_msg_proto_goTypes = nil + file_moonlv_moonlv_msg_proto_depIdxs = nil +}