feat:未登录用户首页推送信息逻辑需改

jyBXBase/rpc/internal/logic/newestbiddinglogic.go

@@ -46,27 +46,28 @@ func (l *NewestBiddingLogic) NewestBidding(in *bxbase.NewestBiddingReq) (*bxbase
 		}
 		if in.UserId == "" {
 			var result []*bxbase.NewestList
-			userTime := fmt.Sprintf("p1_indexMessage_new_%d_%d_%d", time.Now().Year(), time.Now().Minute(), time.Now().Day())
-			redisByte, err := redis.GetBytes("other", userTime)
+			res.Data.IsVip = false
+			res.Data.HasSubKeys = false
+			notLoggedPush := fmt.Sprintf("p1_indexMessage_new_%d_%d_%d", time.Now().Year(), time.Now().Minute(), time.Now().Day())
+			redisByte, err := redis.GetBytes("other", notLoggedPush)
 			if err == nil && redisByte != nil && len(*redisByte) > 0 {
 				err = json.Unmarshal(*redisByte, &result)
-				if err != nil {
-					res.ErrCode = -1
-					res.ErrMsg = fmt.Sprintf("读取缓存 序列化异常,err:%s", err.Error())
+				if err == nil {
+					res.Data.Count = int64(len(result))
+					res.Data.List = result
+					return res
 				}
-			} else {
-				query := model.NewestQuery("", "")
-				result = model.NewestES(query)
-				b, err1 := json.Marshal(result)
-				if err1 == nil {
-					err = redis.PutBytes("other", userTime, &b, 60*60*24)
-					if err != nil {
-						log.Println(fmt.Sprintf("未登录用户每日数据存入缓存 序列化异常,err:%s", err.Error()))
-					}
+				log.Println(fmt.Sprintf("未登录用户每日数据获取缓存 序列化异常,err:%s", err.Error()))
+			}
+			query := model.NewestQuery("", "")
+			result = model.NewestES(query)
+			b, err1 := json.Marshal(result)
+			if err1 == nil {
+				err = redis.PutBytes("other", notLoggedPush, &b, 60*60*24)
+				if err != nil {
+					log.Println(fmt.Sprintf("未登录用户每日数据存入缓存 序列化异常,err:%s", err.Error()))
 				}
 			}
-			res.Data.IsVip = false
-			res.Data.HasSubKeys = false
 			res.Data.Count = int64(len(result))
 			res.Data.List = result
 			return res