package main

import (
	"fmt"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/os/gtime"
)

// Redis接口定义
type RedisStorage interface {
	Set(key, value string) error
	Get(key string) (string, error)
	Del(key string) error
}

// Redis实现结构体
type RedisStorageImpl struct {
	client *g.Redis
}

// NewRedisStorageImpl 创建Redis实现对象
func NewRedisStorageImpl(client *g.Redis) RedisStorage {
	return &RedisStorageImpl{client: client}
}

// Set 实现Redis接口的Set方法
func (r *RedisStorageImpl) Set(key, value string) error {
	return r.client.Set(key, value, 0).Err()
}

// Get 实现Redis接口的Get方法
func (r *RedisStorageImpl) Get(key string) (string, error) {
	return r.client.Get(key).Result()
}

// Del 实现Redis接口的Del方法
func (r *RedisStorageImpl) Del(key string) error {
	return r.client.Del(key).Err()
}

func main() {
	// 连接Redis，默认使用配置文件中的配置
	redis := g.Redis()

	// 创建Redis接口实现对象
	redisStorage := NewRedisStorageImpl(redis)

	// 使用Redis接口进行操作
	key := "exampleKey"
	value := "exampleValue"

	err := redisStorage.Set(key, value)
	if err != nil {
		fmt.Println("Error setting value:", err)
		return
	}

	result, err := redisStorage.Get(key)
	if err != nil {
		fmt.Println("Error getting value:", err)
		return
	}
	fmt.Println("Value:", result)

	err = redisStorage.Del(key)
	if err != nil {
		fmt.Println("Error deleting value:", err)
		return
	}

	// 再次获取值
	resultAgain, err := redisStorage.Get(key)
	if err == g.RedisNil {
		fmt.Println("Value not found")
	} else if err != nil {
		fmt.Println("Error getting value:", err)
		return
	} else {
		fmt.Println("Value:", resultAgain)
	}
}