上传接口调整代码

modules/model/dbservice_comp.go

@@ -27,9 +27,9 @@ func (this *DBService_Comp) run() {
 	for {
 		select {
 		case v := <-this.task:
-			this.module.DB().(*DB_Comp).Model_UpdateUserDataByUid(v)
+			this.module.db_comp.Model_UpdateUserDataByUid(v)
 		case <-time.After(time.Second):
-			this.module.DB().(*DB_Comp).Model_UpdateDBByLog()
+			this.module.db_comp.Model_UpdateDBByLog()
 		}
 	}
 }

modules/model/mail_test.go

@@ -1,4 +1,4 @@
-package modules
+package model
 
 import (
 	"go_dreamfactory/lego/sys/log"
@@ -7,10 +7,6 @@ import (
 	"time"
 )
 
-var (
-	obj MComp_DBComp
-)
-
 func TestCreatemoudles(t *testing.T) {
 	_mail := &pb.DB_MailData{
 
@@ -23,7 +19,7 @@ func TestCreatemoudles(t *testing.T) {
 		Check:      false,
 		Reward:     false,
 	}
-	obj.InsertModelLogs("mail", "uid123", _mail)
+	// obj.InsertModelLogs("mail", "uid123", _mail)
 
 	log.Debugf("insert : %v", _mail)
 }

modules/model/module.go

@@ -15,6 +15,7 @@ func NewModule() core.IModule {
 type Model struct {
 	modules.ModuleBase
 	api_comp       *Api_Comp
+	db_comp        *DB_Comp
 	configure_comp *Configure_Comp
 }
 
@@ -37,6 +38,7 @@ func (this *Model) GetType() core.M_Modules {
 func (this *Model) OnInstallComp() {
 	this.ModuleBase.OnInstallComp()
 	this.api_comp = this.RegisterComp(new(Api_Comp)).(*Api_Comp)
+	this.db_comp = this.RegisterComp(new(DB_Comp)).(*DB_Comp)
 	this.configure_comp = this.RegisterComp(new(Configure_Comp)).(*Configure_Comp)
 }
 

sys/cache/cache.go

@@ -21,7 +21,7 @@ type Cache struct {
 func (this *Cache) init() (err error) {
 	this.redis, err = redis.NewSys(
 		redis.SetRedisType(redis.Redis_Cluster),
-		redis.Redis_Cluster_Addr(this.options.Redis_Addr),
+		redis.SetRedis_Cluster_Addr(this.options.Redis_Addr),
 		redis.SetRedis_Cluster_Password(this.options.Redis_Password))
 	return
 }