// Package redis /** * @ File: hr_verify_r1.go * @ Date: 2021/6/8 18:03 * @ Author: JYQ * @ Description: */ package redis import ( "encoding/json" "fmt" "sportfitness/base/assembly/heartRate/model" "github.com/go-redis/redis/v8" "github.com/sirupsen/logrus" ) const hrVerifyR1Key = prefix + ":hr_verify_r1" func HrVerifyR1(list []model.HrVerifyDetail) { cmder, err := getClient().TxPipelined(ctx, func(pipeliner redis.Pipeliner) error { for _, one := range list { data, err2 := json.Marshal(one.HrVerify) if err2 != nil { panic(err2) } pipeliner.Set(ctx, fmt.Sprintf("%s:%s", hrVerifyR1Key, one.Sn), data, 0) } return nil }) if err != nil { logrus.Errorf("HrVerufyR1 保存失败:%s", err) return } for _, r := range cmder { if r.Err() != nil { logrus.Errorf("HrVerufyR1 保存失败:%s", r.Err()) } } }