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

//Package redis
/**
 * @ File:
 * @ Date: 2021/6/10 13:57
 * @ Author: JYQ
 * @ Description:
 */
package redis

import (
	"encoding/json"
	"fmt"
	"sportfitness/base/assembly/heartRate/model"
)

const OnClassKey = prefix + ":on_class"

func OnClassRedis(classInfo []model.ClassStartDetail) {
	for _, v := range classInfo {
		crIdList, err2 := json.Marshal(v.CrIdLIst)
		if err2 != nil {
			panic(err2)
		}
		stdInfo, err2 := json.Marshal(v.StdInfo)
		if err2 != nil {
			panic(err2)
		}
		getClient().HSet(ctx, fmt.Sprintf("%s:%s", OnClassKey, v.EqSn),
			"crIdList", crIdList,
			"stdInfo", stdInfo)
	}
}

//func OnClassRedis(list []model.CrIdList) {
//	cmders, err := getClient().TxPipelined(ctx, func(pipeliner redis.Pipeliner) error {
//		for _, v := range list {
//			data, err2 := json.Marshal(v.CrIdLIst)
//			if err2 != nil {
//				panic(err2)
//			}
//			//HSet(ctx, hashKey, fmt.Sprintf("K%02d", i), "x")
//			i := pipeliner.HSet(ctx, fmt.Sprintf("%s:%s", OnClassKey, v.EqSn), "crid_list", data)
//			println(i)
//		}
//		return nil
//	})
//	if err != nil {
//		logrus.Errorf("OnClass 保存失败：%s", err)
//		return
//	}
//
//	for _, r := range cmders {
//		if r.Err() != nil {
//			logrus.Errorf("OnClass 保存失败：%s", r.Err())
//		}
//	}
//}