初始化修复

This commit is contained in:
zhaocy 2022-06-15 17:46:13 +08:00
parent c7278719ba
commit f6ccb37e3b
5 changed files with 6 additions and 15 deletions

View File

@ -19,13 +19,13 @@ type DB_Comp struct {
} }
func (this *DB_Comp) Init(service core.IService, module core.IModule, comp core.IModuleComp, options core.IModuleOptions) (err error) { func (this *DB_Comp) Init(service core.IService, module core.IModule, comp core.IModuleComp, options core.IModuleOptions) (err error) {
this.ModuleCompBase.Init(service, module, comp, options) this.Model_Comp.Init(service, module, comp, options)
this.task = make(chan string, TaskMaxNum) this.task = make(chan string, TaskMaxNum)
return return
} }
func (this *DB_Comp) Start() (err error) { func (this *DB_Comp) Start() (err error) {
err = this.ModuleCompBase.Start() err = this.Model_Comp.Start()
go this.run() go this.run()
return return
} }

View File

@ -5,7 +5,7 @@ import (
"go_dreamfactory/pb" "go_dreamfactory/pb"
) )
func (this *Api_Comp) GetUserMailAttachmentReq_Check(session comm.IUserSession, req *pb.DelUserMailReq) (result map[string]interface{}, code pb.ErrorCode) { func (this *Api_Comp) GetUserMailAttachmentReq_Check(session comm.IUserSession, req *pb.GetUserMailAttachmentReq) (result map[string]interface{}, code pb.ErrorCode) {
return return
} }

View File

@ -6,7 +6,7 @@ import (
"go_dreamfactory/pb" "go_dreamfactory/pb"
) )
func (this *Api_Comp) QueryUserMailReq_Check(session comm.IUserSession, req *pb.DelUserMailReq) (result map[string]interface{}, code pb.ErrorCode) { func (this *Api_Comp) QueryUserMailReq_Check(session comm.IUserSession, req *pb.QueryUserMailReq) (result map[string]interface{}, code pb.ErrorCode) {
return return
} }

View File

@ -5,7 +5,7 @@ import (
"go_dreamfactory/pb" "go_dreamfactory/pb"
) )
func (this *Api_Comp) ReadUserMailReq_Check(session comm.IUserSession, req *pb.DelUserMailReq) (result map[string]interface{}, code pb.ErrorCode) { func (this *Api_Comp) ReadUserMailReq_Check(session comm.IUserSession, req *pb.ReadUserMailReq) (result map[string]interface{}, code pb.ErrorCode) {
return return
} }

View File

@ -1,7 +1,6 @@
package pack package pack
import ( import (
"go_dreamfactory/comm"
"go_dreamfactory/modules" "go_dreamfactory/modules"
"go_dreamfactory/lego/core" "go_dreamfactory/lego/core"
@ -20,25 +19,17 @@ type Api_Comp struct {
modules.MComp_GateComp modules.MComp_GateComp
service core.IService service core.IService
module *Pack module *Pack
mail comm.Imail
} }
//组件初始化接口 //组件初始化接口
func (this *Api_Comp) Init(service core.IService, module core.IModule, comp core.IModuleComp, options core.IModuleOptions) (err error) { func (this *Api_Comp) Init(service core.IService, module core.IModule, comp core.IModuleComp, options core.IModuleOptions) (err error) {
this.MComp_GateComp.Init(service, module, comp, options) this.MComp_GateComp.Init(service, module, comp, options)
this.module = module.(*Pack) this.module = module.(*Pack)
this.service = service
return return
} }
func (this *Api_Comp) Start() (err error) { func (this *Api_Comp) Start() (err error) {
err = this.MComp_GateComp.Start() err = this.MComp_GateComp.Start()
var module core.IModule
if module, err = this.service.GetModule(comm.SM_PackModule); err != nil {
return
}
this.mail = module.(comm.Imail)
return return
} }