征途抽奖脚本

bfdz49

1. // CmdDrawActivity.h
   
2. #ifndef CMD_DRAW_ACTIVITY_H
   
3. #define CMD_DRAW_ACTIVITY_H
   
4. 
   
5. #include "zType.h"
   
6. 
   
7. namespace Cmd {
   
8. namespace Draw {
   
9. 
   
10. // 协议主ID: 0x3000-0x30FF
    
11. const WORD CMD_DRAW_ACTIVITY = 0x3000;
    
12. 
    
13. // 子协议
    
14. enum {
    
15.     PARA_DRAW_CHECK_REQ     = 1,    // 检查抽奖资格
    
16.     PARA_DRAW_CHECK_RET     = 2,    // 检查结果
    
17.     PARA_DRAW_DO_REQ        = 3,    // 执行抽奖
    
18.     PARA_DRAW_DO_RET        = 4,    // 抽奖结果
    
19.     PARA_DRAW_INFO_REQ      = 5,    // 请求活动信息
    
20.     PARA_DRAW_INFO_RET      = 6,    // 活动信息
    
21.     PARA_DRAW_LOG_REQ       = 7,    // 请求抽奖记录
    
22.     PARA_DRAW_LOG_RET       = 8,    // 记录返回
    
23.     PARA_DRAW_GLOBAL_NOTIFY = 9,    // 全服广播
    
24.     PARA_DRAW_GM_CMD        = 10,   // GM命令
    
25. };
    
26. 
    
27. // 奖品类型
    
28. enum PrizeType {
    
29.     PRIZE_TYPE_ITEM     = 1,    // 道具
    
30.     PRIZE_TYPE_MONEY    = 2,    // 金币
    
31.     PRIZE_TYPE_EXP      = 3,    // 经验
    
32.     PRIZE_TYPE_WING     = 4,    // 翅膀
    
33.     PRIZE_TYPE_PET      = 5,    // 宠物
    
34.     PRIZE_TYPE_TITLE    = 6,    // 称号
    
35.     PRIZE_TYPE_NONE     = 99,   // 未中奖
    
36. };
    
37. 
    
38. // 检查请求
    
39. struct stDrawCheckReq {
    
40.     WORD cmd;           // 0x3000
    
41.     WORD para;          // 1
    
42.     DWORD activityId;   // 活动ID
    
43.     DWORD drawTimes;    // 抽几次（1或10）
    
44. };
    
45. 
    
46. // 检查返回
    
47. struct stDrawCheckRet {
    
48.     WORD cmd;
    
49.     WORD para;          // 2
    
50.     DWORD activityId;
    
51.     BYTE ret;           // 0成功，1活动未开启，2次数不足，3道具不足，4包裹满
    
52.     DWORD remainTimes;  // 剩余次数
    
53.     DWORD needItemId;   // 需要道具ID
    
54.     DWORD needItemNum;  // 需要数量
    
55. };
    
56. 
    
57. // 执行抽奖请求
    
58. struct stDrawDoReq {
    
59.     WORD cmd;
    
60.     WORD para;          // 3
    
61.     DWORD activityId;
    
62.     DWORD drawTimes;    // 1或10
    
63.     BYTE useMoney;      // 是否使用元宝代替道具（0否1是）
    
64. };
    
65. 
    
66. // 单次奖品信息
    
67. struct PrizeInfo {
    
68.     DWORD prizeId;      // 奖品配置ID
    
69.     DWORD type;         // PrizeType
    
70.     DWORD itemId;       // 物品ID（如果是物品）
    
71.     DWORD count;        // 数量
    
72.     DWORD level;        // 等级/品质
    
73.     DWORD broadcast;    // 是否广播（0/1）
    
74.     char name[64];      // 奖品名称
    
75. };
    
76. 
    
77. // 执行抽奖返回
    
78. struct stDrawDoRet {
    
79.     WORD cmd;
    
80.     WORD para;          // 4
    
81.     DWORD activityId;
    
82.     BYTE ret;           // 0成功，1失败，2包裹满
    
83.     DWORD drawTimes;    // 实际抽了几次
    
84.     DWORD prizeCount;   // 奖品数量（用于变长数组）
    
85.     // PrizeInfo prizes[prizeCount];  // 奖品列表
    
86. };
    
87. 
    
88. // 活动信息请求
    
89. struct stDrawInfoReq {
    
90.     WORD cmd;
    
91.     WORD para;          // 5
    
92.     DWORD activityId;   // 0表示请求所有活动
    
93. };
    
94. 
    
95. // 活动基本信息
    
96. struct ActivityInfo {
    
97.     DWORD id;
    
98.     char name[64];
    
99.     char desc[256];
    
100.     BYTE enabled;       // 是否开启
     
101.     DWORD startTime;    // 开始时间
     
102.     DWORD endTime;      // 结束时间
     
103.     DWORD dailyLimit;   // 每日限制
     
104.     DWORD costItemId;   // 消耗道具
     
105.     DWORD costItemNum;  // 消耗数量
     
106.     DWORD costMoney;    // 替代元宝
     
107.     BYTE hasGuarantee;  // 是否有保底
     
108.     DWORD guaranteeTimes; // 保底次数
     
109. };
     
110. 
     
111. // 活动信息返回
     
112. struct stDrawInfoRet {
     
113.     WORD cmd;
     
114.     WORD para;          // 6
     
115.     DWORD count;
     
116.     // ActivityInfo activities[count];
     
117. };
     
118. 
     
119. // 抽奖记录
     
120. struct DrawLog {
     
121.     DWORD logId;
     
122.     DWORD activityId;
     
123.     DWORD prizeType;
     
124.     DWORD itemId;
     
125.     DWORD count;
     
126.     DWORD time;
     
127.     char prizeName[64];
     
128. };
     
129. 
     
130. // 记录请求
     
131. struct stDrawLogReq {
     
132.     WORD cmd;
     
133.     WORD para;          // 7
     
134.     DWORD activityId;   // 0表示所有
     
135.     DWORD startTime;
     
136.     DWORD endTime;
     
137. };
     
138. 
     
139. // 记录返回
     
140. struct stDrawLogRet {
     
141.     WORD cmd;
     
142.     WORD para;          // 8
     
143.     DWORD count;
     
144.     // DrawLog logs[count];
     
145. };
     
146. 
     
147. // 全服广播（服务器推送给所有客户端）
     
148. struct stDrawGlobalNotify {
     
149.     WORD cmd;
     
150.     WORD para;          // 9
     
151.     DWORD activityId;
     
152.     char playerName[64];
     
153.     char prizeName[64];
     
154.     DWORD prizeLevel;   // 奖品等级（用于显示不同颜色）
     
155.     char msg[256];      // 完整消息
     
156. };
     
157. 
     
158. // GM命令
     
159. enum GMCmd {
     
160.     GM_CMD_RELOAD_CONFIG = 1,   // 重载配置
     
161.     GM_CMD_RESET_PLAYER = 2,    // 重置玩家数据
     
162.     GM_CMD_SET_STOCK = 3,       // 设置库存
     
163.     GM_CMD_SET_STATUS = 4,      // 开启/关闭活动
     
164.     GM_CMD_ADD_TIMES = 5,       // 增加玩家次数
     
165.     GM_CMD_QUERY_INFO = 6,      // 查询信息
     
166. };
     
167. 
     
168. struct stDrawGMCmd {
     
169.     WORD cmd;
     
170.     WORD para;          // 10
     
171.     DWORD gmCmd;
     
172.     DWORD targetId;     // 玩家ID或活动ID
     
173.     DWORD param1;
     
174.     DWORD param2;
     
175.     char paramStr[256];
     
176. };
     
177. 
     
178. #pragma pack()
     
179. }
     
180. }
     
181. #endif
     

复制代码

1. // DrawActivityClient.h
   
2. #ifndef DRAW_ACTIVITY_CLIENT_H
   
3. #define DRAW_ACTIVITY_CLIENT_H
   
4. 
   
5. #include "zTCPClient.h"
   
6. #include "zSingleton.h"
   
7. #include "CmdDrawActivity.h"
   
8. 
   
9. using namespace Cmd::Draw;
   
10. 
    
11. class DrawActivityClient : public zTCPBufferClient, public zSingleton<DrawActivityClient>
    
12. {
    
13. public:
    
14.     DrawActivityClient(const std::string& ip, WORD port);
    
15.     virtual ~DrawActivityClient();
    
16.    
    
17.     bool connectToServer();
    
18.     virtual void run();
    
19.     virtual bool msgParse(const BYTE* data, const DWORD len);
    
20.    
    
21.     // 发送给抽奖服务器
    
22.     bool sendToDrawServer(const void* data, DWORD len);
    
23.    
    
24.     // 转发给客户端
    
25.     void sendToClient(DWORD userId, const void* data, DWORD len);
    
26.    
    
27. private:
    
28.     std::string serverIp;
    
29.     WORD serverPort;
    
30.     bool reconnect();
    
31. };
    
32. 
    
33. #define DRAW_CLIENT DrawActivityClient::getInstance()
    
34. 
    
35. #endif
    

复制代码

1. // DrawActivityClient.cpp
   
2. #include "DrawActivityClient.h"
   
3. #include "SceneUserManager.h"
   
4. #include "SceneUser.h"
   
5. #include "ScenesServer.h"
   
6. #include "LuaEngine.h"
   
7. 
   
8. DrawActivityClient::DrawActivityClient(const std::string& ip, WORD port)
   
9.     : serverIp(ip), serverPort(port)
   
10. {
    
11. }
    
12. 
    
13. DrawActivityClient::~DrawActivityClient()
    
14. {
    
15. }
    
16. 
    
17. bool DrawActivityClient::connectToServer()
    
18. {
    
19.     if(!connect(serverIp.c_str(), serverPort))
    
20.     {
    
21.         Zebra::logger->error("连接抽奖服务器失败 %s:%d", serverIp.c_str(), serverPort);
    
22.         return false;
    
23.     }
    
24.    
    
25.     // 发送注册包
    
26.     struct {
    
27.         WORD cmd;
    
28.         WORD para;
    
29.         DWORD serverId;
    
30.         DWORD serverType;
    
31.     } regCmd = {0x3000, 0, ScenesService::getInstance().getServerID(), 1};
    
32.    
    
33.     return sendCmd(&regCmd, sizeof(regCmd));
    
34. }
    
35. 
    
36. void DrawActivityClient::run()
    
37. {
    
38.     while(!ScenesService::getInstance().isTerminate())
    
39.     {
    
40.         if(!isConnected())
    
41.         {
    
42.             if(!reconnect())
    
43.             {
    
44.                 zThread::msleep(5000);
    
45.                 continue;
    
46.             }
    
47.         }
    
48.         
    
49.         zTCPBufferClient::run();
    
50.     }
    
51. }
    
52. 
    
53. bool DrawActivityClient::reconnect()
    
54. {
    
55.     close();
    
56.     return connectToServer();
    
57. }
    
58. 
    
59. bool DrawActivityClient::msgParse(const BYTE* data, const DWORD len)
    
60. {
    
61.     if(len < sizeof(NullCmd))
    
62.         return false;
    
63.    
    
64.     NullCmd* cmd = (NullCmd*)data;
    
65.    
    
66.     if(cmd->cmd != CMD_DRAW_ACTIVITY)
    
67.         return false;
    
68.    
    
69.     // 转发给Lua处理
    
70.     lua_State* L = LuaEngine::getInstance()->getLuaState();
    
71.     if(!L) return false;
    
72.    
    
73.     lua_getglobal(L, "DrawActivityManager");
    
74.     if(!lua_istable(L, -1))
    
75.     {
    
76.         lua_pop(L, 1);
    
77.         return false;
    
78.     }
    
79.    
    
80.     lua_getfield(L, -1, "onServerMessage");
    
81.     if(!lua_isfunction(L, -1))
    
82.     {
    
83.         lua_pop(L, 2);
    
84.         return false;
    
85.     }
    
86.    
    
87.     // 压入参数：协议号，数据指针，长度
    
88.     lua_pushinteger(L, ((WORD*)data)[1]); // para
    
89.     lua_pushlightuserdata(L, (void*)data);
    
90.     lua_pushinteger(L, len);
    
91.    
    
92.     if(lua_pcall(L, 3, 1, 0) != 0)
    
93.     {
    
94.         Zebra::logger->error("DrawActivity Lua error: %s", lua_tostring(L, -1));
    
95.         lua_pop(L, 1);
    
96.         return false;
    
97.     }
    
98.    
    
99.     bool ret = lua_toboolean(L, -1);
    
100.     lua_pop(L, 1);
     
101.     return ret;
     
102. }
     
103. 
     
104. bool DrawActivityClient::sendToDrawServer(const void* data, DWORD len)
     
105. {
     
106.     return sendCmd(data, len);
     
107. }
     
108. 
     
109. void DrawActivityClient::sendToClient(DWORD userId, const void* data, DWORD len)
     
110. {
     
111.     SceneUser* user = SceneUserManager::getMe().getUserByID(userId);
     
112.     if(user)
     
113.     {
     
114.         user->sendCmdToMe(data, len);
     
115.     }
     
116. }
     

复制代码

1. <!-- config/draw_activities.xml -->
   
2. <activities>
   
3.     <!-- 幸运大转盘 -->
   
4.     <activity id="1001" name="幸运大转盘" enabled="true"
   
5.               start_time="2024-01-01 00:00:00" end_time="2024-12-31 23:59:59"
   
6.               daily_limit="50" cost_type="item" cost_item="584" cost_num="1"
   
7.               cost_money="100" draw_mode="single">
   
8.         
   
9.         <guarantee enabled="true" times="50" pool="rare" reset="true"/>
   
10.         
    
11.         <broadcast min_level="4">恭喜【{player}】鸿运当头，获得【{prize}】！</broadcast>
    
12.         
    
13.         <prizes>
    
14.             <!-- 传说级（5星） -->
    
15.             <prize id="10001" type="wing" item_id="1001" name="炽天使之翼"
    
16.                    level="5" weight="10" broadcast="true" server_limit="3"/>
    
17.             
    
18.             <!-- 史诗级（4星） -->
    
19.             <prize id="10002" type="item" item_id="585" count="10" name="史诗强化石"
    
20.                    level="4" weight="100" broadcast="true"/>
    
21.             
    
22.             <!-- 稀有级（3星） -->
    
23.             <prize id="10003" type="item" item_id="584" count="5" name="进阶石礼包"
    
24.                    level="3" weight="500"/>
    
25.             
    
26.             <prize id="10004" type="money" count="50000" name="金币"
    
27.                    level="3" weight="1000"/>
    
28.             
    
29.             <!-- 普通级（1-2星） -->
    
30.             <prize id="10005" type="item" item_id="583" count="3" name="强化石"
    
31.                    level="2" weight="3000"/>
    
32.             
    
33.             <prize id="10006" type="exp" count="10000" name="经验"
    
34.                    level="1" weight="5390"/>
    
35.         </prizes>
    
36.     </activity>
    
37.    
    
38.     <!-- 十连抽宝箱 -->
    
39.     <activity id="1002" name="神秘宝箱" enabled="true"
    
40.               daily_limit="999" cost_type="item" cost_item="587" cost_num="10"
    
41.               draw_mode="multi">
    
42.         
    
43.         <guarantee enabled="true" times="10" pool="purple" reset="false"/>
    
44.         
    
45.         <prizes>
    
46.             <prize id="20001" type="pet" item_id="2001" name="神兽·青龙"
    
47.                    level="5" weight="5" broadcast="true" server_limit="1" daily_limit="1"/>
    
48.             
    
49.             <prize id="20002" type="item" item_id="588" count="1" name="紫色装备箱"
    
50.                    level="4" weight="50" broadcast="true"/>
    
51.             
    
52.             <!-- 保底奖品 -->
    
53.             <prize id="20003" type="item" item_id="589" count="5" name="紫色碎片"
    
54.                    level="4" weight="100"/>
    
55.         </prizes>
    
56.     </activity>
    
57. </activities>
    

复制代码

这些是我做个翅膀随便写下 自己去修改

1. -- scripts/jackpot/jackpot_manager.lua
   
2. -- 全服奖池分红系统
   
3. 
   
4. local JackpotManager = {}
   
5. local FLDB = require("database.flserver_db")  -- 账号数据库连接
   
6. local GameDB = require("database.game_db")    -- 游戏数据库连接
   
7. local Timer = require("Timer")
   
8. 
   
9. -- 配置
   
10. JackpotManager.CONFIG = {
    
11.     JACKPOT_LIMIT = 1000000000,  -- 10亿触发
    
12.     CHECK_INTERVAL = 60000,      -- 每分钟检查一次
    
13.     DISTRIBUTE_BATCH = 1000,     -- 每批处理1000人
    
14.     MIN_ONLINE_TIME = 3600,      -- 最小在线时长（秒）才有资格
    
15. }
    
16. 
    
17. -- 当前状态
    
18. JackpotManager.state = {
    
19.     currentAmount = 0,
    
20.     isDistributing = false,
    
21.     lastCheckTime = 0,
    
22.     currentBatch = nil
    
23. }
    
24. 
    
25. -- 初始化
    
26. function JackpotManager.init()
    
27.     -- 加载当前奖池金额
    
28.     local row = GameDB.queryOne("SELECT current_amount, status FROM global_jackpot WHERE id=1")
    
29.     if row then
    
30.         JackpotManager.state.currentAmount = tonumber(row.current_amount) or 0
    
31.         if tonumber(row.status) == 1 then  -- 待发放状态，继续发放
    
32.             JackpotManager.resumeDistribute()
    
33.         end
    
34.     else
    
35.         -- 初始化奖池
    
36.         GameDB.execute("INSERT INTO global_jackpot (id, current_amount) VALUES (1, 0)")
    
37.     end
    
38.    
    
39.     -- 启动定时检查
    
40.     Timer.scheduleRepeat(JackpotManager.CONFIG.CHECK_INTERVAL, JackpotManager.checkAndDistribute)
    
41.    
    
42.     Log.info("JackpotManager initialized, current jackpot: " .. JackpotManager.state.currentAmount)
    
43. end
    
44. 
    
45. -- 奖池流入（每次抽奖抽税时调用）
    
46. function JackpotManager.addToJackpot(activityId, userId, amount)
    
47.     if amount <= 0 then return end
    
48.    
    
49.     -- 更新数据库（原子操作）
    
50.     local sql = string.format(
    
51.         "UPDATE global_jackpot SET current_amount = current_amount + %d, total_in = total_in + %d WHERE id=1",
    
52.         amount, amount
    
53.     )
    
54.     local ok = GameDB.execute(sql)
    
55.    
    
56.     if ok then
    
57.         -- 记录流入
    
58.         GameDB.execute(string.format(
    
59.             "INSERT INTO jackpot_inflow (activity_id, user_id, amount, inflow_time) VALUES (%d, %d, %d, %d)",
    
60.             activityId, userId, amount, os.time()
    
61.         ))
    
62.         
    
63.         -- 更新内存
    
64.         JackpotManager.state.currentAmount = JackpotManager.state.currentAmount + amount
    
65.         
    
66.         -- 检查是否达到阈值
    
67.         if JackpotManager.state.currentAmount >= JackpotManager.CONFIG.JACKPOT_LIMIT
    
68.            and not JackpotManager.state.isDistributing then
    
69.             Log.info("Jackpot reached limit: " .. JackpotManager.state.currentAmount)
    
70.             -- 异步触发发放（避免阻塞）
    
71.             Timer.once(1000, JackpotManager.startDistribute)
    
72.         end
    
73.     end
    
74. end
    
75. 
    
76. -- 检查并发放（定时器调用）
    
77. function JackpotManager.checkAndDistribute()
    
78.     if JackpotManager.state.isDistributing then return end
    
79.    
    
80.     -- 从数据库获取最新金额（防止多服竞争）
    
81.     local row = GameDB.queryOne("SELECT current_amount, status FROM global_jackpot WHERE id=1 FOR UPDATE")
    
82.     if not row then return end
    
83.    
    
84.     local amount = tonumber(row.current_amount) or 0
    
85.     local status = tonumber(row.status) or 0
    
86.    
    
87.     JackpotManager.state.currentAmount = amount
    
88.    
    
89.     if amount >= JackpotManager.CONFIG.JACKPOT_LIMIT and status == 0 then
    
90.         JackpotManager.startDistribute()
    
91.     end
    
92. end
    
93. 
    
94. -- 开始发放流程
    
95. function JackpotManager.startDistribute()
    
96.     if JackpotManager.state.isDistributing then return false end
    
97.    
    
98.     JackpotManager.state.isDistributing = true
    
99.     Log.info("Starting jackpot distribution, amount: " .. JackpotManager.state.currentAmount)
    
100.    
     
101.     -- 1. 锁定奖池状态
     
102.     local ok = GameDB.execute("UPDATE global_jackpot SET status=2 WHERE id=1 AND status=0")
     
103.     if not ok then
     
104.         Log.error("Failed to lock jackpot, maybe another server is processing")
     
105.         JackpotManager.state.isDistributing = false
     
106.         return false
     
107.     end
     
108.    
     
109.     -- 2. 查询FLServerDB获取所有有效账号
     
110.     local accounts = FLDB.query([[
     
111.         SELECT DISTINCT a.id as account_id,
     
112.                (SELECT MAX(id) FROM game_user.user_active
     
113.                 WHERE account_id=a.id AND last_login_time > UNIX_TIMESTAMP() - 2592000) as user_id
     
114.         FROM account a
     
115.         WHERE a.status = 1
     
116.         AND a.create_time < UNIX_TIMESTAMP() - 86400  -- 注册超过1天
     
117.         AND (SELECT COUNT(*) FROM account_ban ab WHERE ab.account_id=a.id AND ab.end_time > UNIX_TIMESTAMP()) = 0
     
118.     ]])
     
119.    
     
120.     if not accounts or #accounts == 0 then
     
121.         Log.error("No valid accounts found for jackpot distribution")
     
122.         JackpotManager.resetJackpot()
     
123.         return false
     
124.     end
     
125.    
     
126.     -- 3. 计算每人分得
     
127.     local totalAmount = JackpotManager.state.currentAmount
     
128.     local playerCount = #accounts
     
129.     local perAmount = math.floor(totalAmount / playerCount)
     
130.     local remainder = totalAmount - (perAmount * playerCount)  -- 余数给前N个玩家
     
131.    
     
132.     if perAmount < 1 then
     
133.         Log.warn("Jackpot amount too small for distribution")
     
134.         JackpotManager.resetJackpot()
     
135.         return false
     
136.     end
     
137.    
     
138.     -- 4. 生成分红批次
     
139.     local batchNo = "JP" .. os.time() .. "_" .. math.random(1000,9999)
     
140.     GameDB.execute(string.format(
     
141.         "INSERT INTO jackpot_dividend (jackpot_id, batch_no, total_amount, player_count, per_amount, distribute_time, status) "..
     
142.         "VALUES (1, '%s', %d, %d, %d, %d, 1)",
     
143.         batchNo, totalAmount, playerCount, perAmount, os.time()
     
144.     ))
     
145.    
     
146.     JackpotManager.state.currentBatch = {
     
147.         batchNo = batchNo,
     
148.         accounts = accounts,
     
149.         perAmount = perAmount,
     
150.         remainder = remainder,
     
151.         total = playerCount,
     
152.         processed = 0,
     
153.         success = 0,
     
154.         failed = 0
     
155.     }
     
156.    
     
157.     -- 5. 写入明细表（分批插入）
     
158.     local batchInsert = {}
     
159.     for i, acc in ipairs(accounts) do
     
160.         local amount = perAmount
     
161.         if i <= remainder then amount = amount + 1 end  -- 余数分配
     
162.         
     
163.         table.insert(batchInsert, string.format("('%s', %d, %d, %d, 0)",
     
164.             batchNo, acc.account_id, acc.user_id or 0, amount))
     
165.         
     
166.         if #batchInsert >= 500 then
     
167.             local sql = "INSERT INTO jackpot_player_dividend (batch_no, account_id, user_id, amount, status) VALUES " ..
     
168.                        table.concat(batchInsert, ",")
     
169.             GameDB.execute(sql)
     
170.             batchInsert = {}
     
171.         end
     
172.     end
     
173.     if #batchInsert > 0 then
     
174.         local sql = "INSERT INTO jackpot_player_dividend (batch_no, account_id, user_id, amount, status) VALUES " ..
     
175.                    table.concat(batchInsert, ",")
     
176.         GameDB.execute(sql)
     
177.     end
     
178.    
     
179.     -- 6. 开始分批发放
     
180.     Timer.once(100, function() JackpotManager.processBatch(1) end)
     
181.    
     
182.     -- 全服广播预告
     
183.     WorldBroadcast(string.format("【全服福利】奖池累计已达10亿金币，正在为%d位玩家发放分红，每人约%d金币！",
     
184.         playerCount, perAmount))
     
185.    
     
186.     return true
     
187. end
     
188. 
     
189. -- 分批处理发放
     
190. function JackpotManager.processBatch(startIdx)
     
191.     local batch = JackpotManager.state.currentBatch
     
192.     if not batch then return end
     
193.    
     
194.     local endIdx = math.min(startIdx + JackpotManager.CONFIG.DISTRIBUTE_BATCH - 1, batch.total)
     
195.    
     
196.     for i = startIdx, endIdx do
     
197.         local acc = batch.accounts[i]
     
198.         if acc then
     
199.             local amount = batch.perAmount
     
200.             if i <= batch.remainder then amount = amount + 1 end
     
201.             
     
202.             local ok, err = JackpotManager.sendToPlayer(acc, amount, batch.batchNo)
     
203.             
     
204.             if ok then
     
205.                 batch.success = batch.success + 1
     
206.                 GameDB.execute(string.format(
     
207.                     "UPDATE jackpot_player_dividend SET status=1, send_time=%d WHERE batch_no='%s' AND account_id=%d",
     
208.                     os.time(), batch.batchNo, acc.account_id
     
209.                 ))
     
210.             else
     
211.                 batch.failed = batch.failed + 1
     
212.                 GameDB.execute(string.format(
     
213.                     "UPDATE jackpot_player_dividend SET status=2, error_msg='%s' WHERE batch_no='%s' AND account_id=%d",
     
214.                     tostring(err):sub(1, 250), batch.batchNo, acc.account_id
     
215.                 ))
     
216.                
     
217.                 -- 失败时放入邮件队列稍后重发
     
218.                 JackpotManager.queueMailReward(acc.account_id, acc.user_id, amount, batch.batchNo)
     
219.             end
     
220.         end
     
221.         
     
222.         batch.processed = batch.processed + 1
     
223.     end
     
224.    
     
225.     -- 更新进度
     
226.     GameDB.execute(string.format(
     
227.         "UPDATE jackpot_dividend SET status=1 WHERE batch_no='%s'",
     
228.         batch.batchNo
     
229.     ))
     
230.    
     
231.     Log.info(string.format("Jackpot distribution progress: %d/%d (success:%d, failed:%d)",
     
232.         batch.processed, batch.total, batch.success, batch.failed))
     
233.    
     
234.     -- 继续下一批或完成
     
235.     if endIdx < batch.total then
     
236.         Timer.once(100, function() JackpotManager.processBatch(endIdx + 1) end)
     
237.     else
     
238.         JackpotManager.finishDistribute()
     
239.     end
     
240. end
     
241. 
     
242. -- 发放给单个玩家
     
243. function JackpotManager.sendToPlayer(accountInfo, amount, batchNo)
     
244.     local accountId = accountInfo.account_id
     
245.     local userId = accountInfo.user_id
     
246.    
     
247.     -- 方式1：玩家在线，直接加金币
     
248.     if userId and userId > 0 then
     
249.         local user = SceneUserManager.getUserByID(userId)
     
250.         if user and user:isOnline() then
     
251.             -- 直接加金币
     
252.             local ok = user:addMoney(amount, "jackpot_dividend_" .. batchNo)
     
253.             if ok then
     
254.                 -- 发送通知
     
255.                 user:sendSysMsg(string.format("恭喜您获得全服奖池分红 %d 金币！", amount))
     
256.                
     
257.                 -- 播放特效
     
258.                 user:playEffect("jackpot_win")
     
259.                
     
260.                 -- 记录日志
     
261.                 Log.info(string.format("Jackpot sent to online user %d (account %d), amount: %d",
     
262.                     userId, accountId, amount))
     
263.                 return true
     
264.             end
     
265.         end
     
266.     end
     
267.    
     
268.     -- 方式2：玩家离线，写入待领取表（登录时发放）
     
269.     -- 或者发送邮件
     
270.     return JackpotManager.sendMailReward(accountId, userId, amount, batchNo)
     
271. end
     
272. 
     
273. -- 发送邮件奖励（离线玩家）
     
274. function JackpotManager.sendMailReward(accountId, userId, amount, batchNo)
     
275.     local mailSql = string.format([[
     
276.         INSERT INTO mail_system (receiver_id, title, content, attachment, send_time, expire_time, status)
     
277.         VALUES (%d, '全服奖池分红', '恭喜！全服奖池累计10亿金币，您分得%d金币（批次：%s）',
     
278.                 '{"money":%d}', %d, %d, 0)
     
279.     ]], userId or accountId, amount, batchNo, amount, os.time(), os.time() + 2592000)  -- 30天过期
     
280.    
     
281.     local ok = GameDB.execute(mailSql)
     
282.     if ok then
     
283.         Log.info(string.format("Jackpot mail sent to account %d, amount: %d", accountId, amount))
     
284.         return true, "mail_sent"
     
285.     else
     
286.         return false, "mail_failed"
     
287.     end
     
288. end
     
289. 
     
290. -- 队列化邮件奖励（用于失败重试）
     
291. function JackpotManager.queueMailReward(accountId, userId, amount, batchNo)
     
292.     -- 写入重试队列
     
293.     GameDB.execute(string.format(
     
294.         "INSERT INTO jackpot_retry_queue (batch_no, account_id, user_id, amount, create_time) VALUES ('%s', %d, %d, %d, %d)",
     
295.         batchNo, accountId, userId or 0, amount, os.time()
     
296.     ))
     
297. end
     
298. 
     
299. -- 完成发放
     
300. function JackpotManager.finishDistribute()
     
301.     local batch = JackpotManager.state.currentBatch
     
302.     if not batch then return end
     
303.    
     
304.     -- 更新总表状态
     
305.     GameDB.execute(string.format(
     
306.         "UPDATE jackpot_dividend SET status=2 WHERE batch_no='%s'",
     
307.         batch.batchNo
     
308.     ))
     
309.    
     
310.     -- 清空奖池
     
311.     GameDB.execute("UPDATE global_jackpot SET current_amount=0, status=0, last_winner_time=" .. os.time() .. " WHERE id=1")
     
312.    
     
313.     JackpotManager.state.currentAmount = 0
     
314.     JackpotManager.state.isDistributing = false
     
315.     JackpotManager.state.currentBatch = nil
     
316.    
     
317.     -- 全服广播完成
     
318.     WorldBroadcast(string.format("【全服福利】奖池分红发放完成！共%d位玩家分享10亿金币！", batch.total))
     
319.    
     
320.     Log.info(string.format("Jackpot distribution completed. Total: %d, Success: %d, Failed: %d",
     
321.         batch.total, batch.success, batch.failed))
     
322. end
     
323. 
     
324. -- 重置奖池（出错时）
     
325. function JackpotManager.resetJackpot()
     
326.     GameDB.execute("UPDATE global_jackpot SET status=0 WHERE id=1")
     
327.     JackpotManager.state.isDistributing = false
     
328.     JackpotManager.state.currentBatch = nil
     
329. end
     
330. 
     
331. -- 恢复发放（服务器重启后继续）
     
332. function JackpotManager.resumeDistribute()
     
333.     Log.info("Resuming jackpot distribution...")
     
334.    
     
335.     local row = GameDB.queryOne("SELECT batch_no FROM jackpot_dividend WHERE status=1 ORDER BY id DESC LIMIT 1")
     
336.     if row then
     
337.         local batchNo = row.batch_no
     
338.         
     
339.         -- 加载未完成的明细
     
340.         local list = GameDB.query(string.format(
     
341.             "SELECT account_id, user_id, amount FROM jackpot_player_dividend WHERE batch_no='%s' AND status=0",
     
342.             batchNo
     
343.         ))
     
344.         
     
345.         if list and #list > 0 then
     
346.             JackpotManager.state.currentBatch = {
     
347.                 batchNo = batchNo,
     
348.                 accounts = list,
     
349.                 perAmount = 0,  -- 不需要重新计算
     
350.                 total = #list,
     
351.                 processed = 0,
     
352.                 success = 0,
     
353.                 failed = 0
     
354.             }
     
355.             
     
356.             -- 继续发放
     
357.             Timer.once(1000, function() JackpotManager.processBatch(1) end)
     
358.             Log.info("Resumed batch " .. batchNo .. " with " .. #list .. " remaining players")
     
359.         else
     
360.             -- 没有待发放的，标记完成
     
361.             GameDB.execute(string.format("UPDATE jackpot_dividend SET status=2 WHERE batch_no='%s'", batchNo))
     
362.             GameDB.execute("UPDATE global_jackpot SET current_amount=0, status=0 WHERE id=1")
     
363.             JackpotManager.state.isDistributing = false
     
364.         end
     
365.     else
     
366.         JackpotManager.resetJackpot()
     
367.     end
     
368. end
     
369. 
     
370. -- GM命令：手动触发
     
371. function JackpotManager.gmForceDistribute()
     
372.     if JackpotManager.state.isDistributing then
     
373.         return false, "正在发放中"
     
374.     end
     
375.    
     
376.     -- 检查当前金额
     
377.     local row = GameDB.queryOne("SELECT current_amount FROM global_jackpot WHERE id=1")
     
378.     if not row or tonumber(row.current_amount) < 1000000 then  -- 至少100万才允许手动触发
     
379.         return false, "奖池金额不足（至少100万）"
     
380.     end
     
381.    
     
382.     JackpotManager.startDistribute()
     
383.     return true, "已开始发放"
     
384. end
     
385. 
     
386. -- GM命令：查看奖池状态
     
387. function JackpotManager.gmStatus()
     
388.     local row = GameDB.queryOne("SELECT * FROM global_jackpot WHERE id=1")
     
389.     if row then
     
390.         return {
     
391.             current = tonumber(row.current_amount),
     
392.             total_in = tonumber(row.total_in),
     
393.             total_out = tonumber(row.total_out),
     
394.             status = tonumber(row.status),
     
395.             is_distributing = JackpotManager.state.isDistributing
     
396.         }
     
397.     end
     
398.     return nil
     
399. end
     
400. 
     
401. -- 注册到全局
     
402. _G.JackpotManager = JackpotManager
     
403. return JackpotManager
     

复制代码

1. -- 玩家抽奖数据
   
2. CREATE TABLE draw_player_data (
   
3.     user_id BIGINT NOT NULL,
   
4.     activity_id INT NOT NULL,
   
5.     total_count INT DEFAULT 0 COMMENT '总抽奖次数',
   
6.     today_count INT DEFAULT 0 COMMENT '今日次数',
   
7.     last_draw_time INT DEFAULT 0 COMMENT '最后抽奖时间',
   
8.     guarantee_count INT DEFAULT 0 COMMENT '保底计数',
   
9.     update_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
   
10.     PRIMARY KEY (user_id, activity_id),
    
11.     INDEX idx_activity (activity_id)
    
12. ) ENGINE=InnoDB;
    
13. 
    
14. -- 抽奖日志（分表或按月分区）
    
15. CREATE TABLE draw_logs (
    
16.     id BIGINT AUTO_INCREMENT,
    
17.     user_id BIGINT NOT NULL,
    
18.     activity_id INT NOT NULL,
    
19.     prize_type VARCHAR(16),
    
20.     item_id INT,
    
21.     count INT,
    
22.     prize_level INT COMMENT '奖品等级',
    
23.     draw_time INT,
    
24.     PRIMARY KEY (id),
    
25.     INDEX idx_user_time (user_id, draw_time),
    
26.     INDEX idx_activity_time (activity_id, draw_time)
    
27. ) ENGINE=InnoDB PARTITION BY RANGE (draw_time) (
    
28.     PARTITION p202401 VALUES LESS THAN (1706745600),
    
29.     PARTITION p202402 VALUES LESS THAN (1709251200),
    
30.     PARTITION p202403 VALUES LESS THAN (1711929600)
    
31. );
    
32. 
    
33. -- 全服库存
    
34. CREATE TABLE draw_stock (
    
35.     activity_id INT NOT NULL,
    
36.     prize_id INT NOT NULL,
    
37.     remain_count INT DEFAULT 0,
    
38.     total_count INT DEFAULT 0,
    
39.     update_time TIMESTAMP,
    
40.     PRIMARY KEY (activity_id, prize_id)
    
41. ) ENGINE=InnoDB;
    
42. 
    
43. -- 活动配置（用于热重载备份）
    
44. CREATE TABLE draw_config (
    
45.     activity_id INT PRIMARY KEY,
    
46.     config_json TEXT,
    
47.     update_time TIMESTAMP,
    
48.     operator VARCHAR(64)
    
49. ) ENGINE=InnoDB;
    

复制代码

大大胖墩

虽不懂但谢谢

绝对疯子

感觉好高级·！！！

绝恋″℃

感觉好高级 谢谢大佬的分享

liyicheng556

虽然不会，感谢分享

176034095

谢谢分享