Base/assembly/heartRate/repository/redis/hr_verify_r1.go

// 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"
)

const hrVerifyR1Key = prefix + ":hr_verify_r1"

func HrVerifyR1(list []model.HrVerifyDetail) {
	for _, one := range list {
		data, err2 := json.Marshal(one.HrVerify)
		if err2 != nil {
			panic(err2)
		}
		getClient().Set(ctx, fmt.Sprintf("%s:%s", hrVerifyR1Key, one.Sn), data, 0)
	}
}

//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())
//		}
//	}
//}