liucaijun
/
voucher
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ctx

This commit is contained in:
ziming 2025-03-26 14:29:23 +08:00
parent 5243d6b063
commit 87c22cad47
2 changed files with 1 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
internal/data/gorm.go
View File

@ -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")
// }
//
// }
//}

2
internal/data/repoimpl/product.go
View File

@ -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))