package task import ( "go_dreamfactory/comm" "go_dreamfactory/lego/core" "go_dreamfactory/modules" "time" ) type TaskModule struct { modules.ModuleBase modelTask *ModelTask api *apiComp } func NewModule() core.IModule { return &TaskModule{} } func (this *TaskModule) GetType() core.M_Modules { return comm.ModuleTask } func (this *TaskModule) Init(service core.IService, module core.IModule, options core.IModuleOptions) (err error) { err = this.ModuleBase.Init(service, module, options) go func() { tickC := time.NewTicker(time.Second * 1) for { select { case tc := <-tickC.C: this.update(tc) } } }() return } func (this *TaskModule) OnInstallComp() { this.ModuleBase.OnInstallComp() this.api = this.RegisterComp(new(apiComp)).(*apiComp) this.modelTask = this.RegisterComp(new(ModelTask)).(*ModelTask) } func (this *TaskModule) update(t time.Time) { }