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.
163 lines
3.1 KiB
163 lines
3.1 KiB
package cache
|
|
|
|
import (
|
|
"fmt"
|
|
"recook/internal/dbc"
|
|
"time"
|
|
|
|
"github.com/go-redis/redis"
|
|
)
|
|
|
|
// SetUserSMSCode 缓存登录验证码
|
|
func SetUserSMSCode(mobile string, code string) {
|
|
k := fmt.Sprintf("login_sms_%v", mobile)
|
|
e := dbc.Rds.Set(k, code, time.Minute*10).Err()
|
|
if e != nil {
|
|
panic(e)
|
|
}
|
|
}
|
|
|
|
func GetUserSMSCode(mobile string) string {
|
|
k := fmt.Sprintf("login_sms_%v", mobile)
|
|
v, err := dbc.Rds.Get(k).Result()
|
|
if err == redis.Nil {
|
|
return ""
|
|
} else if err != nil {
|
|
panic(err)
|
|
}
|
|
return v
|
|
}
|
|
|
|
func SetVerifyMobileSMSCode(mobile string, code string) {
|
|
k := fmt.Sprintf("wallet_sms_%v", mobile)
|
|
e := dbc.Rds.Set(k, code, time.Minute*10).Err()
|
|
if e != nil {
|
|
panic(e)
|
|
}
|
|
}
|
|
|
|
func GetVerifyMobileSMSCode(mobile string) string {
|
|
k := fmt.Sprintf("wallet_sms_%v", mobile)
|
|
v, err := dbc.Rds.Get(k).Result()
|
|
if err == redis.Nil {
|
|
return ""
|
|
} else if err != nil {
|
|
panic(err)
|
|
}
|
|
return v
|
|
}
|
|
|
|
func SetUserDestroySMSCode(user uint, code string) {
|
|
k := fmt.Sprintf("sms:destroy:%v", user)
|
|
e := dbc.Rds.Set(k, code, time.Minute*10).Err()
|
|
if e != nil {
|
|
panic(e)
|
|
}
|
|
}
|
|
|
|
func GetUserDestroySMSCode(user uint) string {
|
|
k := fmt.Sprintf("sms:destroy:%v", user)
|
|
v, err := dbc.Rds.Get(k).Result()
|
|
if err == redis.Nil {
|
|
return ""
|
|
|
|
} else if err != nil {
|
|
panic(err)
|
|
}
|
|
return v
|
|
}
|
|
|
|
func SetUpgradeSMSCode(user uint, mobile, code string) {
|
|
k := fmt.Sprintf("sms:upgrade:%s:%v", mobile, user)
|
|
e := dbc.Rds.Set(k, code, time.Minute*10).Err()
|
|
if e != nil {
|
|
panic(e)
|
|
}
|
|
}
|
|
|
|
func GetUpgradeSMSCode(user uint, mobile string) string {
|
|
k := fmt.Sprintf("sms:upgrade:%s:%v", mobile, user)
|
|
v, err := dbc.Rds.Get(k).Result()
|
|
if err == redis.Nil {
|
|
return ""
|
|
|
|
} else if err != nil {
|
|
panic(err)
|
|
}
|
|
return v
|
|
}
|
|
|
|
func GetUserOrderSMSCode(user uint) string {
|
|
k := fmt.Sprintf("mbs:codes:%v", user)
|
|
v, err := dbc.Rds.Get(k).Result()
|
|
if err == redis.Nil {
|
|
return ""
|
|
|
|
} else if err != nil {
|
|
panic(err)
|
|
}
|
|
return v
|
|
}
|
|
func SetUserOrderSMSCode(user uint, code string) {
|
|
k := fmt.Sprintf("mbs:codes:%v", user)
|
|
e := dbc.Rds.Set(k, code, time.Minute*10).Err()
|
|
if e != nil {
|
|
panic(e)
|
|
}
|
|
}
|
|
func SetGysRetreat(id uint, sms string) {
|
|
k := fmt.Sprintf("gysid:sms:%v", id)
|
|
e := dbc.Rds.Set(k, sms, time.Minute*10).Err()
|
|
if e != nil {
|
|
panic(e)
|
|
}
|
|
}
|
|
func GetGysRetreat(id uint) string {
|
|
k := fmt.Sprintf("gysid:sms:%v", id)
|
|
v, err := dbc.Rds.Get(k).Result()
|
|
if err == redis.Nil {
|
|
return ""
|
|
|
|
} else if err != nil {
|
|
panic(err)
|
|
}
|
|
return v
|
|
}
|
|
func SetActiveNum(date uint, uid uint) {
|
|
k := fmt.Sprintf("activedate:users:%v", date)
|
|
e := dbc.Rds.SAdd(k, uid).Err()
|
|
if e != nil {
|
|
panic(e)
|
|
}
|
|
}
|
|
func GetActiveNum(date uint) []string {
|
|
k := fmt.Sprintf("activedate:users:%v", date)
|
|
v, err := dbc.Rds.SMembers(k).Result()
|
|
if err == redis.Nil {
|
|
return nil
|
|
|
|
} else if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
return v
|
|
}
|
|
func SetSecKillPeople(date uint, uid uint) {
|
|
k := fmt.Sprintf("seckill:num:%v", date)
|
|
e := dbc.Rds.Set(k, uid, time.Minute*10).Err()
|
|
if e != nil {
|
|
panic(e)
|
|
}
|
|
}
|
|
func GetSecKillPeople(date uint) string {
|
|
k := fmt.Sprintf("seckill:num:%v", date)
|
|
v, err := dbc.Rds.Get(k).Result()
|
|
if err == redis.Nil {
|
|
return ""
|
|
|
|
} else if err != nil {
|
|
panic(err)
|
|
}
|
|
return v
|
|
}
|