ice_gametopM2R.go

package sdkmr

import (
	"client/sdkdb"
	"client/sdkredis"
	"log"
)

/**
 *  数据库所有数据导入redis
 */
func IceGametopM2R() {
	// 查询数据库中所有数据
	iceGameTops, err := sdkdb.IceGameTopMysqlQueryTotal()
	if err != nil {
		log.Printf("IceGameTopQueryTotal err[%v]\n", err)
		return
	}

	// 连接redis
	redisConn := sdkredis.RedisClient.GetConn()
	defer sdkredis.RedisClose(redisConn)

	// set key value
	for _, igt := range iceGameTops {
		reply, err := sdkredis.RedisSetKV(redisConn, "ice_gametop:uid:"+igt.UID+":gtid:"+igt.GTID+":gid:"+igt.GID+":toptype:"+igt.TopType+":mykey", igt.MyKey)
		if err != nil {
			sdkredis.RedisClose(redisConn)
			log.Printf("RedisCommand replay[%v] err[%v]\n", reply, err)
			return
		}
	}
}