|
@@ -56,7 +56,12 @@ func (l *NewestBiddingLogic) NewestBidding(in *bxbase.NewestBiddingReq) (*bxbase
|
|
|
} else {
|
|
|
rks = MC.If(in.UserId != "", in.UserId, in.City).(string)
|
|
|
}
|
|
|
- redisByte, err := redis.GetBytes("other", "p1_indexMessage_new_"+rks)
|
|
|
+ redisKey := "p1_indexMessage_new_" + rks
|
|
|
+ if in.UserId == "" {
|
|
|
+ redisKey = fmt.Sprintf("%s_%d_%d_%d", redisKey, time.Now().Year(), time.Now().Minute(), time.Now().Day())
|
|
|
+ }
|
|
|
+
|
|
|
+ redisByte, err := redis.GetBytes("other", redisKey)
|
|
|
if err == nil && redisByte != nil && len(*redisByte) > 0 {
|
|
|
err = json.Unmarshal(*redisByte, res.Data)
|
|
|
if err != nil {
|
|
@@ -196,11 +201,13 @@ func (l *NewestBiddingLogic) NewestBidding(in *bxbase.NewestBiddingReq) (*bxbase
|
|
|
r.ErrCode = -1
|
|
|
r.ErrMsg = fmt.Sprintf("保存缓存 序列化异常,err:%s", err.Error())
|
|
|
} else {
|
|
|
+ redisKey := "p1_indexMessage_new_" + rks
|
|
|
timeOut := 2 * 60 * 60
|
|
|
if in.UserId == "" {
|
|
|
timeOut = 24 * 60 * 60
|
|
|
+ redisKey = fmt.Sprintf("%s_%d_%d_%d", redisKey, time.Now().Year(), time.Now().Minute(), time.Now().Day())
|
|
|
}
|
|
|
- if err = redis.PutBytes("other", "p1_indexMessage_new_"+rks, &b, timeOut); err != nil {
|
|
|
+ if err = redis.PutBytes("other", redisKey, &b, timeOut); err != nil {
|
|
|
r.ErrCode = -1
|
|
|
r.ErrMsg = fmt.Sprintf("保存缓存 redis 异常,err:%s", err.Error())
|
|
|
}
|