追梦

dev/const/gameConst.lua

@@ -24,7 +24,8 @@ root.EVENT_ID = {
 -- 常用资源物品ID
 root.ITEM_ID = {
     GOLD = 101, -- 金币
-    DIAMOND = 102 -- 宝石
+    DIAMOND = 102, -- 宝石
+    N1 = 103 -- N1纪念布章
 }
 
 -- 战斗类型

dev/modules/dream.lua

@@ -0,0 +1,30 @@
+--[[
+Descripttion:追梦记录
+version:
+Author: Neo,Huang
+Date: 2022-08-17 16:04:20
+LastEditors: Neo,Huang
+LastEditTime: 2022-08-19 20:12:34
+--]]
+local root = class("dream", require("base.baseModule"))
+
+function root:ctor(id)
+	root.super.ctor(self, id, "dream", "id", true, false)
+	self.id = id
+end
+
+function root:mysql_get_init_columns()
+	return {
+		id = "bigint(20) NOT NULL COMMENT '邮件ID'",
+		uid = "bigint(20) DEFAULT 0 COMMENT '抽奖玩家ID'",
+		itemId = "int(11) DEFAULT 0 COMMENT '掉落时价格'",
+		dropItem = "json COMMENT '掉落物品'",
+		price = "int(11) DEFAULT 0 COMMENT '掉落时价格'",
+		odds = "int(11) DEFAULT 0 COMMENT '使用概率'",
+		isWin = "int(11) DEFAULT 0 COMMENT '是否中奖 0:不中奖 1:中奖'",
+		dropTime = "int(11) DEFAULT 1 COMMENT '掉落时间戳'",
+		expireTime = "int(11) DEFAULT 0 COMMENT '过期时间'"
+	}
+end
+
+return root

dev/modules/order.lua

@@ -10,6 +10,7 @@ local root = class("order", require("base.baseModule"))
 
 function root:ctor(id)
     root.super.ctor(self, id, "order", "id", true, false)
+    self.id = id
 end
 
 function root:mysql_get_init_columns()

dev/utils/util_box.lua

@@ -9,6 +9,8 @@ LastEditTime: 2023-11-15 22:41:18
 local timeUtil = require("utils.timeUtil")
 local redisUtil = require("utils.redisUtil")
 local util_player = require("utils.util_player")
+local mysqlUtil = require("utils.mysqlUtil")
+local lib_game_redis = require("lib_game_redis")
 
 local baseAdapt = require("base.baseAdapt")
 local boxAdapt = require("adapt.boxAdapt")
@@ -18,6 +20,9 @@ local MODULE_NAME = "box"
 
 local root = {}
 
+----------------------------------------
+-- 盲盒
+----------------------------------------
 local function _get_box_key(boxId)
     return string.format("%s:%s", MODULE_NAME, tostring(boxId))
 end
@@ -92,5 +97,149 @@ function root:pack_box_info_list(boxId)
     end
     return boxInfoList
 end
+----------------------------------------
+-- 追梦
+----------------------------------------
+local function _get_dream_key()
+    return "box:dream"
+end
+local function _get_dream_odds_tims_key(ti)
+    return string.format("box:dream:odds-times:%s", timeUtil.toDate(ti))
+end
+-- 新增记录
+function root:dream_add_record(uid, itemId, odds, dropItem, isWin)
+    if is_empty(uid) or is_empty(itemId) or is_empty(odds) or is_empty(dropItem) then
+        return false
+    end
+    local price = resAdapt:get_item_price(itemId)
+    if is_empty(price) then
+        return false
+    end
+
+    local dropTime = timeUtil.now()
+    local expireTime = dropItem + timeUtil.SEC_PER_DAY * 365
+    local sql =
+        string.format(
+        "INSERT INTO `mdl_dream` (`uid`,`itemId`,`dropItem`,`price`,`odds`,`isWin`,`dropTime`,`expireTime`)" ..
+            " VALUES (%s,%s,'%s',%s,%s,%s,%s,%s); ",
+        tostring(uid),
+        tostring(itemId),
+        cjson_encode(dropItem),
+        tostring(price),
+        tostring(odds),
+        tostring(isWin and 1 or 0),
+        tostring(dropTime),
+        tostring(expireTime)
+    )
+
+    return mysqlUtil:insert(sql)
+end
+-- 新增概率次数
+function root:dream_add_odds_times(odds, isWin)
+    if is_empty(odds) then
+        return false
+    end
+    local key = _get_dream_odds_tims_key()
+    local subKey = string.format("odds:%s:%s", tostring(odds), tostring(isWin and 1 or 0))
+    local times = redisUtil.hget_int(key, subKey)
+    times = times + 1
+    redisUtil.hset(key, subKey, times)
+end
+
+-- 获取精彩瞬间记录
+function root:dream_get_brilliants()
+    local minPrice = 100000
+    local count = 20
+    local sql =
+        string.format(
+        "SELECT * FROM `mdl_dream` WHERE `price`>=%s AND `isWin`=1 ORDER BY dropTime DESC limit %s",
+        tostring(minPrice),
+        tostring(count)
+    )
+    local ok, ret = mysqlUtil:select(sql)
+    if not ok or is_empty(ret) then
+        return
+    end
+    local list = {}
+    for _, v in ipairs(ret) do
+        local uid = tonumber(v.uid)
+        local info = {
+            playerInfo = util_player:get_base_info(uid),
+            itemId = tonumber(v.itemId),
+            dropItem = cjson_decode(v.dropItem),
+            price = tonumber(v.price),
+            odds = tonumber(v.odds),
+            dropTime = tonumber(v.dropTime)
+        }
+        table.insert(list, info)
+    end
+    return list
+end
+
+-- 掉落记录
+function root:dream_get_records()
+    local count = 20
+    local sql = string.format("SELECT * FROM `mdl_dream` ORDER BY dropTime DESC limit %s", tostring(count))
+    local ok, ret = mysqlUtil:select(sql)
+    if not ok or is_empty(ret) then
+        return
+    end
+    local list = {}
+    for _, v in ipairs(ret) do
+        local uid = tonumber(v.uid)
+        local info = {
+            playerInfo = util_player:get_base_info(uid),
+            itemId = tonumber(v.itemId),
+            dropItem = cjson_decode(v.dropItem),
+            price = tonumber(v.price),
+            odds = tonumber(v.odds),
+            dropTime = tonumber(v.dropTime)
+        }
+        table.insert(list, info)
+    end
+    return list
+end
+
+-- 次数统计
+function root:dream_get_statement()
+    local days = 3
+    local mapOddsWinTims = {}
+    local mapOddsLoseTims = {}
+    local currTime = timeUtil.now()
+    for i = 0, days - 2 do
+        local ti = currTime - timeUtil.SEC_PER_DAY * i
+        local key = _get_dream_odds_tims_key(ti)
+        for odds = 5, 85 do
+            -- 中奖
+            local subKey = string.format("odds:%s:1", tostring(odds))
+            local times = redisUtil.hget_int(key, subKey)
+            mapOddsWinTims[odds] = (mapOddsWinTims[odds] or 0) + times
+            -- 不中奖
+            subKey = string.format("odds:%s:0", tostring(odds))
+            times = redisUtil.hget_int(key, subKey)
+            mapOddsLoseTims[odds] = (mapOddsLoseTims[odds] or 0) + times
+        end
+    end
+    local oddsTimesList = {}
+    for odds = 5, 85 do
+        if not is_empty(mapOddsWinTims[odds]) or not is_empty(mapOddsLoseTims[odds]) then
+            local info = {
+                odds = odds,
+                winTimes = mapOddsWinTims[odds] or 0,
+                loseTimes = mapOddsLoseTims[odds] or 0
+            }
+            table.insert(oddsTimesList, info)
+        end
+    end
+    return oddsTimesList
+end
+-- 删除天统计
+function root:dream_del_day_statement(ti)
+    if is_empty(ti) then
+        return
+    end
+    local key = _get_dream_odds_tims_key(ti)
+    lib_game_redis:del(key)
+end
 
 return root

nodes/game/interface/box.lua

@@ -17,7 +17,10 @@ local bagData = require("data.bag")
 
 local root = {}
 
+----------------------------------------
+-- 盲盒
+----------------------------------------
+-- 模块信息
 function root:box_blind_get_info(role, msg)
     local id = msg.id
     local ret = {
@@ -26,7 +29,7 @@ function root:box_blind_get_info(role, msg)
     return code.OK, ret
 end
 
+-- 开盲盒
 function root:box_blind_open(role, msg)
     local id = msg.id
     local count = msg.count or 1
@@ -45,11 +48,11 @@ function root:box_blind_open(role, msg)
                 break
             end
             -- 消耗
-            local eventId = string.format("box-blind-%s", tostring(id))
-            bagData:consume_items(uid, costItems, eventId)
+            local keyEvent = string.format("box-blind-%s", tostring(id))
+            bagData:consume_items(uid, costItems, keyEvent)
             -- 获取物品
             local _items = {{id = itemId, count = itemCount}}
-            bagData:add_items(uid, _items, eventId)
+            bagData:add_items(uid, _items, keyEvent)
 
             items = itemUtil.items_merge(items, _items)
         end
@@ -64,4 +67,64 @@ function root:box_blind_open(role, msg)
     return code.OK, ret
 end
 
+----------------------------------------
+-- 追梦
+----------------------------------------
+-- 开奖
+function root:box_dream_open(role, msg)
+    local itemId = msg.itemId
+    local odds = msg.odds
+    if is_empty(itemId) or is_empty(odds) or odds < 5 or odds > 85 then
+        return code.PARAMTER_ERROR
+    end
+    local confItem = resAdapt:get_item_conf(itemId)
+    if is_empty(confItem) then
+        return code.BAG.ITEM_NOT_EXIST
+    end
+    local uid = role.uid
+    -- 消耗
+    local costItems = {
+        {id = gameConst.ITEM_ID.DIAMOND, count = math.floor(confItem.price / confItem.priceConst * odds)}
+    }
+    local ok, _costItems = bagData:is_enough(uid, costItems)
+    if not ok then
+        return code.BAG.ITEM_NOT_ENOUGH
+    end
+    -- 消耗
+    local keyEvent = string.format("box-dream-%s", tostring(itemId))
+    bagData:consume_items(uid, _costItems, keyEvent)
+    -- 随机道具
+    local awardList = {
+        {id = itemId, count = 1, weight = adds},
+        {id = gameConst.ITEM_ID.N1, count = 1, weight = 100 - odds}
+    }
+    local index = random_list_by_weight(awardList)
+    local dropItem = {id = awardList[index].id, count = awardList[index].count}
+    bagData:add_items(uid, {dropItem}, keyEvent)
+    -- 记录/统计
+    local isWin = dropItem.id == itemId
+    util_box:dream_add_record(uid, itemId, odds, dropItem, isWin)
+    util_box:dream_add_odds_times(odds, isWin)
+
+    return code.OK, {dropItem = dropItem}
+end
+
+-- 精彩瞬间
+function root:box_dream_brilliant(role, msg)
+    local list = util_box:dream_get_brilliants()
+    return code.OK, {list = list}
+end
+
+-- 掉落记录
+function root:box_dream_records(role, msg)
+    local list = util_box:dream_get_records()
+    return code.OK, {list = list}
+end
+
+-- 全局统计
+function root:box_dream_statement(role, msg)
+    local oddsTimesList = util_box:dream_get_statement()
+    return code.OK, {oddsTimesList = oddsTimesList}
+end
+
 return root

nodes/global/main.lua

@@ -24,6 +24,8 @@ skynet.start(
         init_nodes:init_config()
 
         skynet.uniqueservice("backupSrv")
+        skynet.uniqueservice("mailSrv")
+        skynet.uniqueservice("dreamSrv")
 
         -- 集群
         init_nodes:init_cluster()

nodes/global/service/dreamSrv.lua

@@ -0,0 +1,38 @@
+--[[
+Descripttion:追梦
+version:
+Author: Neo,Huang
+Date: 2022-08-17 16:04:20
+LastEditors: Neo,Huang
+LastEditTime: 2022-08-20 15:18:25
+--]]
+local timer = require("timer")
+local baseService = require("baseService")
+local lib_game_mysql = require("lib_game_mysql")
+local util_box = require("utils.util_box")
+
+local timerDelExpireMail = nil
+
+local CMD = {}
+
+-- 清理过期追梦记录
+local function l_del_expire_record()
+	local currTime = skynet_time()
+	local sql = string.format("delete from mdl_dream where expireTime >0 and expireTime < %s;", tostring(currTime))
+	local ret = lib_game_mysql:query(sql)
+	log.info("l_del_expire_record sql[%s] ret[%s]", tostring(sql), tostring(ret))
+	-- 统计 - 保留30
+	local ti = currTime - 86400 * 30
+	util_box:dream_del_day_statement(ti)
+end
+
+function CMD.onStart()
+	timerDelExpireMail = timer.timeOut(60, l_del_expire_mail)
+end
+
+function CMD.onStop()
+	-- 取消定时器
+	timerDelExpireMail.func = nil
+end
+
+baseService.start(CMD, ".dreamCenter", true)