youtu_grpc/app/user/internal/svc/service_context.go
xiabin 53a7d70bc9
All checks were successful
/ build-services (app/auth/Dockerfile, auth, auth) (push) Successful in 39s
/ build-services (app/ecpm/Dockerfile, ecpm, ecpm) (push) Successful in 34s
/ build-services (app/ranking/Dockerfile, ranking, ranking) (push) Successful in 39s
/ build-services (app/user/Dockerfile, user_manager, user) (push) Successful in 39s
/ start-services (push) Successful in 5s
update
2025-02-14 10:56:23 +08:00

40 lines
877 B
Go

package svc
import (
"gitea.youtukeji.com.cn/youtu/youtu_grpc/app/user/internal/gen/dao/query"
"gitea.youtukeji.com.cn/youtu/youtu_grpc/pkg/config"
"gitea.youtukeji.com.cn/youtu/youtu_grpc/pkg/id_gen"
"gitea.youtukeji.com.cn/youtu/youtu_grpc/pkg/my_gorm"
"github.com/sony/sonyflake"
"github.com/redis/go-redis/v9"
"gorm.io/driver/mysql"
"gorm.io/gorm"
)
type ServiceContext struct {
Config config.Config
Query *query.Query
IDGen *sonyflake.Sonyflake
}
func NewServiceContext(c config.Config) *ServiceContext {
svc := &ServiceContext{
Config: c,
IDGen: id_gen.New(),
}
//初始化redis client
redisClient := redis.NewClient(&redis.Options{
Addr: c.Redis[0].Host,
})
//初始化数据库
db, err := my_gorm.NewDBWithCache(mysql.Open(c.Mysql), &gorm.Config{}, redisClient)
if err != nil {
panic(err)
}
svc.Query = query.Use(db)
return svc
}