redis

_const/rediskey/key.go

@@ -40,6 +40,7 @@ const (
 	// 开斋节活动
 	OpenRamadanSendGiftLeftDiamond = "act:openRamadan:diamond:%d:%d" // 开斋节活动，剩余还没转换成积分的送礼钻石，活动id:用户id
 	ResCountry                     = "res:country"                   // 国家列表
+	// 开斋节活动
 
 	// 定时任务的互斥锁
 	cronLock = "cronLock:{subKey}"

_const/rediskey/key_func.go

@@ -99,3 +99,7 @@ func GetActImeiAwardTimesKey(actId uint64, awardType, level int, device string)
 func GetExchangePinkCostDiamond(userId uint64) string {
 	return fmt.Sprintf(ExchangePinkCostDiamond, time.Now().Format(utils.DATE_FORMAT), userId)
 }
+
+func GetOpenRamadanSendGiftLeftDiamond(actId, userId uint64) string {
+	return fmt.Sprintf(OpenRamadanSendGiftLeftDiamond, actId, userId)
+}

resource/redisCli/util.go

@@ -2,6 +2,7 @@ package redisCli
 
 import (
 	"context"
+	"git.hilo.cn/hilo-common/myerr"
 	"git.hilo.cn/hilo-common/mylogrus"
 	"github.com/go-redis/redis/v8"
 	"time"
@@ -97,3 +98,11 @@ func DecrNumExpire(key string, num int64, expiration time.Duration) (int64, erro
 	}
 	return times, nil
 }
+
+func DecrNum(key string, num int64) (int64, error) {
+	resNum, err := RedisClient.DecrBy(context.Background(), key, num).Result()
+	if err != nil {
+		return 0, myerr.WrapErr(err)
+	}
+	return resNum, nil
+}