|
@@ -2,8 +2,7 @@ package scene
|
|
|
|
|
|
import (
|
|
|
"context"
|
|
|
- "fmt"
|
|
|
- "github.com/gogf/gf/v2/database/gredis"
|
|
|
+ "github.com/gogf/gf/database/gredis"
|
|
|
)
|
|
|
|
|
|
const (
|
|
@@ -42,8 +41,9 @@ type Manager struct {
|
|
|
}
|
|
|
|
|
|
func NewSceneManager(host string, port int) *Manager {
|
|
|
- red, _ := gredis.New(&gredis.Config{
|
|
|
- Address: fmt.Sprintf("%s:%d", host, port),
|
|
|
+ red := gredis.New(&gredis.Config{
|
|
|
+ Host: host,
|
|
|
+ Port: port,
|
|
|
Db: 2,
|
|
|
MaxActive: 100,
|
|
|
})
|
|
@@ -56,11 +56,11 @@ func NewSceneManager(host string, port int) *Manager {
|
|
|
}
|
|
|
|
|
|
func (a *Manager) SaveScene(info *Info) error {
|
|
|
- _, err := a.redisClient.Do(a.ctx, "SET", info.Key, info.Config)
|
|
|
+ _, err := a.redisClient.Do("SET", info.Key, info.Config)
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
|
- _, err = a.redisClient.Do(a.ctx, info.Key, dataExpires)
|
|
|
+ _, err = a.redisClient.Do(info.Key, dataExpires)
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
@@ -69,7 +69,7 @@ func (a *Manager) SaveScene(info *Info) error {
|
|
|
|
|
|
func (a *Manager) GetScene(key string) (string, error) {
|
|
|
// get status from redis
|
|
|
- result, err := a.redisClient.Do(a.ctx, "GET", key)
|
|
|
+ result, err := a.redisClient.DoVar("GET", key)
|
|
|
if err != nil {
|
|
|
return "", err
|
|
|
}
|
|
@@ -78,7 +78,7 @@ func (a *Manager) GetScene(key string) (string, error) {
|
|
|
|
|
|
func (a *Manager) DeleteScene(key string) error {
|
|
|
// get status from redis
|
|
|
- _, err := a.redisClient.Do(a.ctx, "DEL", key)
|
|
|
+ _, err := a.redisClient.Do("DEL", key)
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|