You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
95 lines
2.3 KiB
95 lines
2.3 KiB
package common
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"github.com/go-redis/redis/v8"
|
|
"log"
|
|
"os"
|
|
"time"
|
|
|
|
"github.com/spf13/viper"
|
|
_ "github.com/spf13/viper/remote"
|
|
"gorm.io/driver/mysql"
|
|
"gorm.io/gorm"
|
|
"gorm.io/gorm/logger"
|
|
)
|
|
|
|
func GetConsulConfig(url string, fileKey string) (*viper.Viper, error) {
|
|
conf := viper.New()
|
|
conf.AddRemoteProvider("consul", url, fileKey)
|
|
conf.SetConfigType("json")
|
|
err := conf.ReadRemoteConfig()
|
|
if err != nil {
|
|
log.Println("viper conf err :", err)
|
|
//}else {
|
|
//log.Println("viper conf :", conf)
|
|
}
|
|
return conf, nil
|
|
}
|
|
|
|
// 获取 MySQL配置
|
|
func GetMysqlFromConsul(vip *viper.Viper) (db *gorm.DB, err error) {
|
|
newLogger := logger.New(
|
|
log.New(os.Stdout, "\r\n", log.LstdFlags),
|
|
logger.Config{
|
|
SlowThreshold: time.Second,
|
|
LogLevel: logger.Info,
|
|
Colorful: true,
|
|
},
|
|
)
|
|
str := vip.GetString("user") + ":" + vip.GetString("pwd") + "@tcp(" + vip.GetString("host") + ":" + vip.GetString("port") + ")/" + vip.GetString("database") + "?charset=utf8mb4&parseTime=True&loc=Local"
|
|
db, errr := gorm.Open(mysql.Open(str), &gorm.Config{Logger: newLogger})
|
|
if errr != nil {
|
|
log.Println("db err :", errr)
|
|
}
|
|
|
|
return db, nil
|
|
}
|
|
|
|
/**
|
|
{
|
|
"addr": "192.168.100.131",
|
|
"password": "",
|
|
"DB": "0",
|
|
"poolSize": "30",
|
|
"minIdleConn": "30"
|
|
}
|
|
*/
|
|
// 获取redis 配置
|
|
func GetRedisFromConsul(vip *viper.Viper) (red *redis.Client, err error) {
|
|
red = redis.NewClient(&redis.Options{
|
|
Addr: vip.GetString("addr"),
|
|
Password: vip.GetString("password"),
|
|
DB: vip.GetInt("DB"),
|
|
PoolSize: vip.GetInt("poolSize"),
|
|
MinIdleConns: vip.GetInt("minIdleConn"),
|
|
})
|
|
//集群
|
|
clusterClients := redis.NewClusterClient(
|
|
&redis.ClusterOptions{
|
|
Addrs: []string{},
|
|
})
|
|
fmt.Println(clusterClients)
|
|
return red, nil
|
|
}
|
|
|
|
// 设置用户登录信息
|
|
func SetUserToken(red *redis.Client, key string, val []byte, timeTTL time.Duration) {
|
|
red.Set(context.Background(), key, val, timeTTL)
|
|
}
|
|
|
|
// 订单Token
|
|
func SetOrderToken(red *redis.Client, key string, val string, timeTTL time.Duration) {
|
|
red.Set(context.Background(), key, val, timeTTL)
|
|
}
|
|
|
|
// 获取用户登录信息
|
|
func GetUserToken(red *redis.Client, key string) string {
|
|
res, err := red.Get(context.Background(), key).Result()
|
|
if err != nil {
|
|
log.Print("GetUserToken err ", err)
|
|
}
|
|
return res
|
|
}
|