From a21e9145d05b98645c523a41d02cfa79655f3bbe Mon Sep 17 00:00:00 2001 From: richboo111 Date: Tue, 25 Apr 2023 17:06:15 +0800 Subject: [PATCH] 1 --- business/jxutils/cache/redis/redis.go | 86 +++++++++++++-------------- globals/api/api.go | 3 +- 2 files changed, 44 insertions(+), 45 deletions(-) diff --git a/business/jxutils/cache/redis/redis.go b/business/jxutils/cache/redis/redis.go index 38dfd5d59..bf4ef4377 100644 --- a/business/jxutils/cache/redis/redis.go +++ b/business/jxutils/cache/redis/redis.go @@ -74,46 +74,46 @@ func (c *Cacher) Keys(prefix string) ([]string, error) { return c.client.Keys(prefix + "*").Result() } -func (c *Cacher) RPush(key string, value interface{}) error { - return c.client.RPush(key, value).Err() -} - -func (c *Cacher) FlushDB() error { - return c.client.FlushDB().Err() -} - -func (c *Cacher) Expire(key string, expiration time.Duration) error { - return c.client.Expire(key, expiration).Err() -} - -func (c *Cacher) ExpireResult(key string, expiration time.Duration) (bool, error) { - ok, err := c.client.Expire(key, expiration).Result() - if err != nil { - return false, err - } - return ok, nil -} - -func (c *Cacher) Exists(keys ...string) (int64, error) { - ret := c.client.Exists(keys...) - return ret.Val(), ret.Err() -} - -func (c *Cacher) Incr(key string) error { - return c.client.Incr(key).Err() -} - -func (c *Cacher) LRange(key string) (retVal []string) { - if c.client.LLen(key).Val() > 0 { - retVal = c.client.LRange(key, 0, -1).Val() - } - return retVal -} - -func (c *Cacher) LSet(key string, index int, value interface{}) error { - return c.client.LSet(key, int64(index), value).Err() -} - -func (c *Cacher) LRem(key string, count int, value interface{}) error { - return c.client.LRem(key, int64(count), value).Err() -} +//func (c *Cacher) RPush(key string, value interface{}) error { +// return c.client.RPush(key, value).Err() +//} +// +//func (c *Cacher) FlushDB() error { +// return c.client.FlushDB().Err() +//} +// +//func (c *Cacher) Expire(key string, expiration time.Duration) error { +// return c.client.Expire(key, expiration).Err() +//} +// +//func (c *Cacher) ExpireResult(key string, expiration time.Duration) (bool, error) { +// ok, err := c.client.Expire(key, expiration).Result() +// if err != nil { +// return false, err +// } +// return ok, nil +//} +// +//func (c *Cacher) Exists(keys ...string) (int64, error) { +// ret := c.client.Exists(keys...) +// return ret.Val(), ret.Err() +//} +// +//func (c *Cacher) Incr(key string) error { +// return c.client.Incr(key).Err() +//} +// +//func (c *Cacher) LRange(key string) (retVal []string) { +// if c.client.LLen(key).Val() > 0 { +// retVal = c.client.LRange(key, 0, -1).Val() +// } +// return retVal +//} +// +//func (c *Cacher) LSet(key string, index int, value interface{}) error { +// return c.client.LSet(key, int64(index), value).Err() +//} +// +//func (c *Cacher) LRem(key string, count int, value interface{}) error { +// return c.client.LRem(key, int64(count), value).Err() +//} diff --git a/globals/api/api.go b/globals/api/api.go index 6cb943829..c64cd1900 100644 --- a/globals/api/api.go +++ b/globals/api/api.go @@ -46,7 +46,6 @@ import ( "git.rosy.net.cn/baseapi/platformapi/yilianyunapi" "git.rosy.net.cn/baseapi/platformapi/zhongwuapi" "git.rosy.net.cn/jx-callback/business/jxutils/cache" - "git.rosy.net.cn/jx-callback/business/jxutils/cache/redis" "git.rosy.net.cn/jx-callback/globals" aliyunsmsclient "github.com/KenmyZhang/aliyun-communicate" @@ -296,7 +295,7 @@ func Init() { //Cacher = redis.New(beego.AppConfig.DefaultString("redisHost", ""), beego.AppConfig.DefaultInt("redisPort", ""), beego.AppConfig.DefaultString("redisPassword", "")) //Todo 本地测试用 - Cacher = redis.New(beego.AppConfig.DefaultString("redisHost", "127.0.0.1"), beego.AppConfig.DefaultInt("redisPort", 6379), beego.AppConfig.DefaultString("redisPassword", "123456")) + //Cacher = redis.New(beego.AppConfig.DefaultString("redisHost", "127.0.0.1"), beego.AppConfig.DefaultInt("redisPort", 6379), beego.AppConfig.DefaultString("redisPassword", "123456")) AliUpcAPI = aliupcapi.New(beego.AppConfig.DefaultString("aliUpcAppCode", ""))