55 lines
1.6 KiB
Go
55 lines
1.6 KiB
Go
|
package jackpot
|
|||
|
|
|
|||
|
|
import (
|
|||
|
|
"context"
|
|||
|
|
"fmt"
|
|||
|
|
"github.com/go-redis/redis/v8"
|
|||
|
|
"strconv"
|
|||
|
|
)
|
|||
|
|
|
|||
|
|
func JackpotSet(rdb *redis.Client, gameId int, chips int64) {
|
|||
|
|
key := fmt.Sprintf("Jackpot:%d", gameId)
|
|||
|
|
_, _ = rdb.Set(context.Background(), key, chips, 0).Result()
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func JackpotAdd(rdb *redis.Client, gameId int, chips int64) int64 {
|
|||
|
|
key := fmt.Sprintf("Jackpot:%d", gameId)
|
|||
|
|
v, _ := rdb.IncrBy(context.Background(), key, chips).Result()
|
|||
|
|
return v
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func JackpotGet(rdb *redis.Client, gameId int) int64 {
|
|||
|
|
key := fmt.Sprintf("Jackpot:%d", gameId)
|
|||
|
|
jp := rdb.Get(context.Background(), key).Val()
|
|||
|
|
result, _ := strconv.ParseInt(jp, 10, 64)
|
|||
|
|
return result
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// jp系统池，玩家部分利润进入该池，重置jackpot池时，从这里扣除。系统池反映系统盈亏
|
|||
|
|
func JackpotSystemAdd(rdb *redis.Client, gameId int, chips int64) int64 {
|
|||
|
|
key := fmt.Sprintf("JackpotSystem:%d", gameId)
|
|||
|
|
value, _ := rdb.IncrBy(context.Background(), key, chips).Result()
|
|||
|
|
return value
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func JackpotSystemGet(rdb *redis.Client, gameId int) int64 {
|
|||
|
|
key := fmt.Sprintf("JackpotSystem:%d", gameId)
|
|||
|
|
jp := rdb.Get(context.Background(), key).Val()
|
|||
|
|
result, _ := strconv.ParseInt(jp, 10, 64)
|
|||
|
|
return result
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 玩家总赎回
|
|||
|
|
func JackpotUserRepaidAdd(rdb *redis.Client, gameId int, chips int64) int64 {
|
|||
|
|
key := fmt.Sprintf("JackpotUserRepaid:%d", gameId)
|
|||
|
|
value, _ := rdb.IncrBy(context.Background(), key, chips).Result()
|
|||
|
|
return value
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// jp池重置次数
|
|||
|
|
func JackpotInitCountAdd(rdb *redis.Client, gameId int) int64 {
|
|||
|
|
key := fmt.Sprintf("JackpotInitCount:%d", gameId)
|
|||
|
|
count, _ := rdb.IncrBy(context.Background(), key, 1).Result()
|
|||
|
|
return count
|
|||
|
|
}
|