Base/assembly/base/repository/redis/init.go

package redis

import (
	"context"
	"sportfitness/base/assembly/base/repository"
	"sportfitness/base/errors"

	"git.beswell.com/gframe/application"

	"github.com/go-redis/redis/v8"
)

const prefix = "bsw:sport_fitness:base"

var ctx = context.Background()

func Init() {
	err := repository.Repository.InitRedisByConfigCenter(0)
	if err != nil {
		panic(err)
	}
}

func getClient() redis.UniversalClient {
	return repository.Repository.GetRedisClient()
}

func handleTokenErr(err error) {
	if err != nil {
		if err == redis.Nil {
			err = application.ErrorBusinessF(errors.ErrCodeToken, "token无效")
		}

		panic(err)
	}
}

func handleErr(err error) {
	if err != nil {
		if err == redis.Nil {
			err = application.ErrorBusinessF(errors.ErrCodeNoRecord, "记录不存在")
		}
		panic(err)
	}
}