【进阶实战】幂等消费：消息重复投递的防护封装

local dedup = {}
local TTL = 7 * 86400
local function isDuplicate(msgId)
    local e = dedup[msgId]
    if e == nil then
        return false
    end
    if os.time() - e.ts > TTL then
        dedup[msgId] = nil
        return false
    end
    return true
end
local function consume(msg)
    if isDuplicate(msg.id) then
        print("重复消息 " .. msg.id .. "，跳过")
        return true
    end
    deliverReward(msg)
    dedup[msg.id] = { ts = os.time() }
    return true
end
local function deliverReward(msg)
    giveitem(getplayerbyname(msg.to), msg.item, msg.num, 0, "活动奖励")
end

local function purgeDedup()
    local now = os.time()
    for k, e in pairs(dedup) do
        if now - e.ts > TTL then
            dedup[k] = nil
        end
    end
end