|
@@ -573,6 +573,36 @@ func Zrank(code, key, member string) int64 {
|
|
|
return -1
|
|
|
}
|
|
|
|
|
|
+func Zscore(code, key, member string) string {
|
|
|
+ defer catch()
|
|
|
+ conn := RedisPool[code].Get()
|
|
|
+ defer conn.Close()
|
|
|
+ ret, err := conn.Do("ZSCORE", key, member)
|
|
|
+ if nil != err {
|
|
|
+ log.Println("redisutil-ZSCORE error", err)
|
|
|
+ return ""
|
|
|
+ }
|
|
|
+ if res, ok := ret.([]uint8); ok {
|
|
|
+ return string(res)
|
|
|
+ }
|
|
|
+ return ""
|
|
|
+}
|
|
|
+
|
|
|
+func Zincrby(code, key string, increment float64, member string) int64 {
|
|
|
+ defer catch()
|
|
|
+ conn := RedisPool[code].Get()
|
|
|
+ defer conn.Close()
|
|
|
+ ret, err := conn.Do("ZINCRBY", key, increment, member)
|
|
|
+ if nil != err {
|
|
|
+ log.Println("redisutil-ZINCRBY error", err)
|
|
|
+ return -1
|
|
|
+ }
|
|
|
+ if res, ok := ret.(int64); ok {
|
|
|
+ return res
|
|
|
+ }
|
|
|
+ return -1
|
|
|
+}
|
|
|
+
|
|
|
func catch() {
|
|
|
if r := recover(); r != nil {
|
|
|
log.Println(r)
|