diff --git a/internal/rpc/group/group.go b/internal/rpc/group/group.go index a87db4e9c..108652b86 100644 --- a/internal/rpc/group/group.go +++ b/internal/rpc/group/group.go @@ -53,17 +53,12 @@ func NewGroupServer(port int) *groupServer { //mysql init var mysql relation.Mysql var mongo unrelation.Mongo - var groupModel relation.GroupModel + var groupModel relationTb.GroupModel var redis cache.RedisClient - err = mysql.InitConn().AutoMigrateModel(&groupModel) + err := mysql.InitConn().AutoMigrateModel(&groupModel) if err != nil { panic("db init err:" + err.Error()) } - if mysql.GormConn() != nil { - groupModel.DB = mysql.GormConn() - } else { - panic("db init err:" + "conn is nil") - } mongo.InitMongo() redis.InitRedis() mongo.CreateSuperGroupIndex() @@ -77,7 +72,7 @@ func NewGroupServer(port int) *groupServer { panic(err.Error()) } g.registerCenter = zkClient - conns, err := g.registerCenter.GetConns(config.Config.RpcRegisterName.OpenImConversationName) + //conns, err := g.registerCenter.GetConns(config.Config.RpcRegisterName.OpenImConversationName) g.GroupInterface = controller.NewGroupInterface(controller.NewGroupDatabase(mysql.GormConn(), redis.GetClient(), mongo.GetClient())) return &g