From 87c22cad47acde69cc17f6ffedafd8b708383767 Mon Sep 17 00:00:00 2001 From: ziming Date: Wed, 26 Mar 2025 14:29:23 +0800 Subject: [PATCH] ctx --- internal/data/gorm.go | 35 ------------------------------- internal/data/repoimpl/product.go | 2 +- 2 files changed, 1 insertion(+), 36 deletions(-) diff --git a/internal/data/gorm.go b/internal/data/gorm.go index 7be8837..64d9cb4 100644 --- a/internal/data/gorm.go +++ b/internal/data/gorm.go @@ -41,38 +41,3 @@ func db(data *conf.Data_Database) *gorm.DB { return gormDB } - -//func db(data *conf.Data_Database) (*gorm.DB, func()) { -// //mysqlConn, err := sql.Open(data.Driver, data.Source) -// -// gormDB, err := gorm.Open( -// mysql.Open(data.Source), -// //&gorm.Config{ -// // Logger: logger.Default.LogMode(logger.Info), -// //}, -// ) -// -// if err != nil { -// panic("failed to connect database " + err.Error()) -// } -// -// sqlDB, err := gormDB.DB() -// if err != nil { -// panic("failed to gormDB " + err.Error()) -// } -// -// //sqlDB.SetMaxIdleConns(int(data.MaxIdle)) -// sqlDB.SetMaxIdleConns(1000) -// //sqlDB.SetMaxOpenConns(int(data.MaxOpen)) -// sqlDB.SetMaxOpenConns(1000) -// //sqlDB.SetConnMaxLifetime(1 * time.Hour) -// //sqlDB.SetConnMaxIdleTime(15 * time.Minute) -// -// return gormDB, func() { -// -// if gormDB != nil { -// fmt.Println("关闭 db") -// } -// -// } -//} diff --git a/internal/data/repoimpl/product.go b/internal/data/repoimpl/product.go index 540bc5d..613ebac 100644 --- a/internal/data/repoimpl/product.go +++ b/internal/data/repoimpl/product.go @@ -33,7 +33,7 @@ func (r *ProductRepoImpl) GetByProductNo(ctx context.Context, productNo string) c := vo.ProductQueryKey.BuildCache([]string{productNo}) - cacheValue, err := r.rdb.Rdb.Get(ctx, c.Key).Result() + cacheValue, err := r.rdb.Rdb.Get(context.Background(), c.Key).Result() if err != nil && err != redis.Nil { return nil, fmt.Errorf(fmt.Sprintf("获取商品缓存异常,%s:%v", c.Key, err))