新增兑换码

common/utils/redisUtil.lua

@@ -84,6 +84,14 @@ function root.hgetall(key)
         return ret
     end
 end
+-- 自增
+function root.hincrby(key, subKey, steps)
+    if is_nil(key) or is_nil(subKey) then
+        return
+    end
+    steps = steps or 1
+    return lib_game_redis:hincrby(key, subKey, steps)
+end
 
 function root.do_eval(evalkey, keyCount, ...)
     local data = lib_game_redis:eval(root.evalStr[evalkey], keyCount, ...)
@@ -91,11 +99,11 @@ function root.do_eval(evalkey, keyCount, ...)
 end
 
 -- redis 执行 lua 脚本.
-root.evalStr    = {
+root.evalStr = {
     ["aaa"] = [[redis.call('lpush', KEYS[1], ARGV[1]); redis.call('ltrim', KEYS[1], 0, ARGV[2]);]],
     ["bbb"] = [["redis.call('zincrby',KEYS[1], ARGV[1], ARGV[2]);
         local scores    = redis.call('zscore', KEYS[1], ARGV[2]);
-        local rank      = redis.call('zrevrank', KEYS[1], ARGV[2]); 
+        local rank      = redis.call('zrevrank', KEYS[1], ARGV[2]);
         return {rank, scores};]]
 }
 

dev/modules/exchangecode.lua

@@ -0,0 +1,62 @@
+--[[
+Descripttion:兑换码
+version:
+Author: Neo,Huang
+Date: 2023-11-19 21:28:04
+LastEditors: Neo,Huang
+LastEditTime: 2023-11-19 21:29:10
+--]]
+local code = require("code")
+local util_exchange_code = require("utils.util_exchange_code")
+
+local bagData = require("data.bag")
+
+local root = class("exchangecode", require("base.baseModule"))
+
+function root:ctor(uid)
+    root.super.ctor(self, uid, "exchangecode", "uid", true)
+    self.uid = uid
+end
+
+function root:mysql_get_init_columns()
+    return {
+        uid = "int(11) NOT NULL COMMENT '用户id'",
+        awardList = "JSON COMMENT '已领取兑换码列表'"
+    }
+end
+
+-- 兑换码
+function root:itf_exchange_code(role, msg)
+    local pCode = msg.pCode
+    if is_empty(pCode) then
+        return code.PARAMTER_ERROR
+    end
+    local awardList = self:redis_get_key_info("awardList")
+    if table.include(awardList, pCode) then
+        -- 已领取奖励
+        return code.EXCHANGE_CODE.AWARDED
+    end
+    -- 获取兑换码奖励权重物品列表
+    local errcode, weightItems = util_exchange_code:get_exchange_code_items(pCode)
+    if code.is_not_ok(errcode) then
+        return errcode
+    end
+    -- 增加领奖次数
+    errcode = util_exchange_code:add_award_times(pCode)
+    if code.is_not_ok(errcode) then
+        return errcode
+    end
+
+    table.insert(awardList, pCode)
+    self:redis_update_key_info("awardList", awardList)
+    -- 减少领奖次数
+
+    -- 随机物品
+    local index = random_list_by_weight(weightItems)
+    local items = {{id = weightItems[index].id, count = weightItems[index].count}}
+    local keyEvent = string.format("exchange-code-%s", tostring(pCode))
+    bagData:add_items(self.uid, items, keyEvent)
+    return code.OK, {items = items}
+end
+
+return root

dev/utils/util_exchange_code.lua

@@ -0,0 +1,92 @@
+--[[
+Descripttion:兑换码
+version:
+Author: Neo,Huang
+Date: 2023-11-19 21:20:05
+LastEditors: Neo,Huang
+LastEditTime: 2023-11-19 21:23:40
+--]]
+local code = require("code")
+local timeUtil = require("utils.timeUtil")
+local redisUtil = require("utils.redisUtil")
+local lib_game_redis = require("lib_game_redis")
+
+local MODULE_KEY = "exchange:code"
+
+local root = {}
+
+local function _get_exchange_code_key(pcode)
+    return string.format("%s:%s", tostring(MODULE_KEY), tostring(pcode))
+end
+-- 获取兑换码配置
+function root:get_exchange_code_items(pcode)
+    if is_empty(pcode) then
+        return code.PARAMTER_ERROR
+    end
+    local key = _get_exchange_code_key(pcode)
+    local isExist = lib_game_redis:exists(key)
+    if not isExist then
+        -- 兑换码已不存在
+        return code.EXCHANGE_CODE.NOT_FOUND
+    end
+
+    local awardTimes = redisUtil.hget_int(key, "awardTimes")
+    if is_empty(awardTimes) or awardTimes <= 0 then
+        -- 已领完
+        return code.EXCHANGE_CODE.AWARD_NOT_MORE
+    end
+    local currTime = timeUtil.now()
+    local expireTime = redisUtil.hget_int(key, "expireTime")
+    if is_empty(expireTime) or currTime > expireTime then
+        -- 活动结束
+        return code.EXCHANGE_CODE.TIME_OUT
+    end
+    return code.OK, redisUtil.hget_json(key, "items")
+end
+
+-- 增加领奖次数
+function root:add_award_times(pcode)
+    local key = _get_exchange_code_key(pcode)
+    local isExist = lib_game_redis:exists(key)
+    if not isExist then
+        -- 兑换码已不存在
+        return code.EXCHANGE_CODE.NOT_FOUND
+    end
+    local subKey = "awardTimes"
+    local awardTimes = redisUtil.hincrby(key, subKey, -1)
+    if awardTimes < 0 then
+        redisUtil.hset(key, subKey, 0)
+        -- 已领完
+        return code.EXCHANGE_CODE.AWARD_NOT_MORE
+    end
+    return code.OK
+end
+----------------------------------------
+-- 记录
+----------------------------------------
+local function _get_record_key()
+    return string.format("%s:record", tostring(MODULE_KEY))
+end
+-- 新增
+function root:add_record(uid, items)
+    if is_empty(uid) or is_empty(items) then
+        return false
+    end
+    local key = _get_record_key()
+    local subKey = "records"
+    local records = redisUtil.hget_json(key, subKey)
+    table.insert(records, {uid = uid, items = items})
+    if #records > 10 then
+        table.remove(records, 1)
+    end
+    redisUtil.hset(key, subKey, records)
+    return false
+end
+-- 获取记录列表
+function root:get_records()
+    local key = _get_record_key()
+    local subKey = "records"
+    return redisUtil.hget_json(key, subKey)
+end
+
+return root

nodes/game/interface/exchange.lua

@@ -0,0 +1,38 @@
+--[[
+Descripttion:兑换码
+version:
+Author: Neo,Huang
+Date: 2023-11-19 22:58:58
+LastEditors: Neo,Huang
+LastEditTime: 2023-11-19 22:59:25
+--]]
+local code = require "code"
+local util_exchange_code = require("utils.util_exchange_code")
+local util_player = require("utils.util_player")
+
+local root = {}
+
+-- 模块信息
+function root:exchange_get_info(role, msg)
+    local list = util_exchange_code:get_records()
+    local ret = {}
+    if not is_empty(list) then
+        for _, v in ipairs(list) do
+            local info = {
+                playerInfo = util_player:get_base_info(v.uid),
+                items = v.items
+            }
+            if is_empty(ret.records) then
+                ret.records = {}
+            end
+            table.insert(ret.records, info)
+        end
+    end
+    return code.OK, ret
+end
+-- 领取
+function root:exchange_get_award(role, msg)
+    return role.exchangecode:itf_exchange_code(role, msg)
+end
+
+return root