45 lines
1.2 KiB
Go
45 lines
1.2 KiB
Go
package homeser
|
|
|
|
import (
|
|
"encoding/json"
|
|
"time"
|
|
"videoweb/app/api/proto"
|
|
"videoweb/pub/common/log"
|
|
"videoweb/pub/redis"
|
|
)
|
|
|
|
const (
|
|
appHomeCacheKey = "app:home:data"
|
|
appHomeCacheTTL = time.Minute * 5
|
|
)
|
|
|
|
// getHomeDataCache 读取 APP 首页 Redis 缓存，缓存异常时降级查库
|
|
func getHomeDataCache() *proto.DataResp {
|
|
cacheData, err1 := redis.Get(appHomeCacheKey)
|
|
if err1 != nil {
|
|
log.Warn("读取APP首页缓存失败", log.Any("cacheKey", appHomeCacheKey), log.E(err1))
|
|
return nil
|
|
}
|
|
if cacheData == nil || *cacheData == "" {
|
|
return nil
|
|
}
|
|
resp := &proto.DataResp{}
|
|
if err1 := json.Unmarshal([]byte(*cacheData), resp); err1 != nil {
|
|
log.Warn("解析APP首页缓存失败", log.Any("cacheKey", appHomeCacheKey), log.E(err1))
|
|
return nil
|
|
}
|
|
return resp
|
|
}
|
|
|
|
// setHomeDataCache 写入 APP 首页 Redis 缓存，缓存异常不影响主流程
|
|
func setHomeDataCache(resp proto.DataResp) {
|
|
bytes, err1 := json.Marshal(resp)
|
|
if err1 != nil {
|
|
log.Warn("序列化APP首页缓存失败", log.Any("cacheKey", appHomeCacheKey), log.E(err1))
|
|
return
|
|
}
|
|
if err1 := redis.Set(appHomeCacheKey, string(bytes), appHomeCacheTTL); err1 != nil {
|
|
log.Warn("写入APP首页缓存失败", log.Any("cacheKey", appHomeCacheKey), log.E(err1))
|
|
}
|
|
}
|