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"

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