Blame view

src/actions/HangAction.lua 20.2 KB
384bb077   zhouahaihai   挂机
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
  local ipairs = ipairs
  local table = table
  local math = math
  local next = next
  local string = string
  local redisproxy = redisproxy
  local MsgPack = MsgPack
  local getRandomName = getRandomName
  local mcast_util = mcast_util
  local string_format = string.format
  local tonumber = tonumber
  local require = require
  local table_insert = table.insert
  local tconcat = table.concat
  local table_unpack = table.unpack
  
  local _M = {}
  
  local function checkReward(role)
  	local hangInfo = role:getProperty("hangInfo")
  	if not hangInfo.carbonId or not hangInfo.coinTime or not hangInfo.itemTime then
024370be   liuzujun   双倍掉掉落bug
22
  		return false
384bb077   zhouahaihai   挂机
23
24
  	end
  	local carbonData = csvdb["idle_battleCsv"][hangInfo.carbonId]
bcf5bfbb   zhouahaihai   挂机new
25
26
  	local nowCoinTime = math.min(skynet.timex(), hangInfo.endCoinTime or 0)
  	local nowItemTime = math.min(skynet.timex(), hangInfo.endItemTime or 0)
384bb077   zhouahaihai   挂机
27
  
706b517e   liuzujun   翻倍掉落活动,商城免费宝箱
28
29
30
  	-- 此次挂机,其中翻倍时长占多少
  	local doubleTime = role.activity:getActHangDoubleTime(hangInfo.coinTime, nowCoinTime)
  	local normalTime = nowCoinTime - hangInfo.coinTime - doubleTime
384bb077   zhouahaihai   挂机
31
  
706b517e   liuzujun   翻倍掉落活动,商城免费宝箱
32
33
34
35
  	local coinCount = math.max(0, math.floor((normalTime) / globalCsv.idle_money_produce_cd))
  	local coinDoubleCount = math.max(0, math.floor((doubleTime) / globalCsv.idle_money_produce_cd)) * 2
  	hangInfo.coinTime = nowCoinTime
  
024370be   liuzujun   双倍掉掉落bug
36
  	normalTime = nowItemTime - hangInfo.itemTime
706b517e   liuzujun   翻倍掉落活动,商城免费宝箱
37
  	local itemCount = math.max(0, math.floor((normalTime) / globalCsv.idle_item_produce_cd))
706b517e   liuzujun   翻倍掉落活动,商城免费宝箱
38
  	hangInfo.itemTime = nowItemTime
384bb077   zhouahaihai   挂机
39
40
  
  	local items = role:getProperty("hangBag")
706b517e   liuzujun   翻倍掉落活动,商城免费宝箱
41
  	coinCount = coinCount + coinDoubleCount
9e1a93c2   liuzujun   快速挂机掉落浮点数取整
42
43
44
  	items[ItemId.Gold] = math.floor((items[ItemId.Gold] or 0) + coinCount * carbonData.money)
  	items[ItemId.Exp] = math.floor((items[ItemId.Exp] or 0) + coinCount * carbonData.exp)
  	items[ItemId.PlayerExp] = math.floor((items[ItemId.PlayerExp] or 0) + coinCount * carbonData.playerExp)
384bb077   zhouahaihai   挂机
45
46
47
48
49
  
  	local pool = {}
  	for _, temp in pairs(carbonData.item:toArray()) do
  		table.insert(pool, temp:toArray(true, "="))
  	end
64e63ad0   wangyujie   完成需求:挂机栏位物品数量上限和钻...
50
51
52
  	local curFC = 0
  	local curIC = 0
  	for id, count in pairs(items) do
bcf5bfbb   zhouahaihai   挂机new
53
  		if id ~= ItemId.Gold and id ~= ItemId.Exp and id ~= ItemId.PlayerExp then
64e63ad0   wangyujie   完成需求:挂机栏位物品数量上限和钻...
54
55
  			curFC = curFC + math.ceil(count / globalCsv.idle_field_limit)
  			curIC = curIC + count
9962b061   zhouahaihai   补充 挂机
56
57
  		end
  	end
317a46a9   liuzujun   添加特权卡
58
59
60
61
  
  	-- 特权卡挂机额外栏位
  	local privExtraCnt = role.storeData:getHangSlotExtraCount()
  	local selfFC = role:getProperty("hangBagLimit") + privExtraCnt
64e63ad0   wangyujie   完成需求:挂机栏位物品数量上限和钻...
62
63
64
65
66
67
68
69
70
  	local selfIC = selfFC * globalCsv.idle_field_limit
  
  	local function randomItem()
  		if curIC >= selfIC then
  			return
  		end
  		local tempPool = clone(pool)
  		while #tempPool > 0 do
  			local idx = math.randWeight(tempPool, 3)
024370be   liuzujun   双倍掉掉落bug
71
  			local cur = clone(pool[idx])
93f6e69b   liuzujun   拾荒选择时间,抽卡增加sr保底
72
  			if cur[1] ~= 0 then  -- 轮空 id
024370be   liuzujun   双倍掉掉落bug
73
74
  				if cur[1] == ItemId.BreakCost and doubleTime > 0 then
  					cur[2] = cur[2] * 2
64e63ad0   wangyujie   完成需求:挂机栏位物品数量上限和钻...
75
  				end
024370be   liuzujun   双倍掉掉落bug
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
  				if (items[cur[1]] and math.ceil((items[cur[1]] + cur[2]) / globalCsv.idle_field_limit) > math.ceil(items[cur[1]] / globalCsv.idle_field_limit))
  						or not items[cur[1]] then	--要占用新栏位的情况
  					local addFC
  					if not items[cur[1]] then
  						addFC = math.ceil(cur[2] / globalCsv.idle_field_limit)
  					else
  						local frontC = items[cur[1]] % globalCsv.idle_field_limit
  						if frontC == 0 then
  							frontC = globalCsv.idle_field_limit
  						end
  						addFC = math.ceil((cur[2] - (globalCsv.idle_field_limit - frontC)) / globalCsv.idle_field_limit)
  					end
  					if curFC + addFC <= selfFC then
  						curFC = curFC + addFC
  						items[cur[1]] = (items[cur[1]] or 0) + cur[2]
  						break
  					else
  						--加不了,换别的东西
  						table.remove(tempPool, idx)
  					end
64e63ad0   wangyujie   完成需求:挂机栏位物品数量上限和钻...
96
  				else
024370be   liuzujun   双倍掉掉落bug
97
98
  					items[cur[1]] = items[cur[1]] + cur[2]
  					break
64e63ad0   wangyujie   完成需求:挂机栏位物品数量上限和钻...
99
100
  				end
  			else
64e63ad0   wangyujie   完成需求:挂机栏位物品数量上限和钻...
101
  				break
9962b061   zhouahaihai   补充 挂机
102
  			end
9962b061   zhouahaihai   补充 挂机
103
  		end
64e63ad0   wangyujie   完成需求:挂机栏位物品数量上限和钻...
104
105
  		curIC = curIC + 1
  	end
024370be   liuzujun   双倍掉掉落bug
106
  
64e63ad0   wangyujie   完成需求:挂机栏位物品数量上限和钻...
107
108
  	for i = 1, itemCount do
  		randomItem()
384bb077   zhouahaihai   挂机
109
110
111
  	end
  
  	if coinCount > 0 or itemCount > 0 then
5af8b4aa   zhouahaihai   挂机down
112
  		return true
384bb077   zhouahaihai   挂机
113
  	end
024370be   liuzujun   双倍掉掉落bug
114
115
  
  	return false
384bb077   zhouahaihai   挂机
116
117
  end
  
384bb077   zhouahaihai   挂机
118
119
120
121
122
123
  --开始一个新的关卡
  function _M.startRpc( agent, data )
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local carbonId = msg.carbonId
  	local carbonData = csvdb["idle_battleCsv"][carbonId]
f60b89b1   zhouhaihai   奖励副本
124
  	if not carbonData then return 1 end
384bb077   zhouahaihai   挂机
125
  
d232676a   zhouhaihai   功能解锁 冒险返回
126
127
128
129
  	if math.floor(carbonId / 10000) ~= 1 then
  		if not role:isFuncUnlock(FuncUnlock.DifficultHang) then return end
  	end
  
5d80aca6   zhouahaihai   挂机优化
130
131
  
  	for _, preCarbonId in ipairs(carbonData.prepose:toArray(true, "=")) do
33be3111   zhouhaihai   修改hangPass 结构
132
  		if not role:checkHangPass(preCarbonId) then return 2 end
5d80aca6   zhouahaihai   挂机优化
133
  	end
384bb077   zhouahaihai   挂机
134
  
5af8b4aa   zhouahaihai   挂机down
135
136
137
  	if checkReward(role) then
  		role:updateProperty({field = "hangBag", value = role:getProperty("hangBag")})
  	end
384bb077   zhouahaihai   挂机
138
139
  
  	local hangInfo = role:getProperty("hangInfo")
5af8b4aa   zhouahaihai   挂机down
140
  	local isNew = not hangInfo.carbonId
384bb077   zhouahaihai   挂机
141
142
  	hangInfo.carbonId = carbonId
  	local nowTime = skynet.timex()
5af8b4aa   zhouahaihai   挂机down
143
  	if isNew then
1103490d   zhouhaihai   设置 国家时间错误
144
145
  		hangInfo.coinTime = nowTime
  		hangInfo.itemTime = nowTime
bcf5bfbb   zhouahaihai   挂机new
146
147
  		hangInfo.endCoinTime = nowTime + globalCsv.idle_producetime_max
  		hangInfo.endItemTime = nowTime + globalCsv.idle_producetime_max
1103490d   zhouhaihai   设置 国家时间错误
148
149
150
  	else
  		hangInfo.coinTime = math.min(nowTime, hangInfo.endCoinTime)
  		hangInfo.itemTime = math.min(nowTime, hangInfo.endItemTime)
5af8b4aa   zhouahaihai   挂机down
151
  	end
33be3111   zhouhaihai   修改hangPass 结构
152
  	if not role:checkHangPass(carbonId) then
5af8b4aa   zhouahaihai   挂机down
153
154
155
  		hangInfo.bossTime = nowTime + carbonData.idle_time
  	else
  		hangInfo.bossTime = nil
384bb077   zhouahaihai   挂机
156
157
158
  	end
  	role:updateProperty({field = "hangInfo", value = hangInfo})
  
5132bac1   chenyueqi   挂机选定关卡时,指定新手引导步骤
159
160
161
162
163
164
165
166
167
168
  	-- 指定当前引导的步骤
  	if carbonId == 10101 then
  		role:saveGuide(5,11)
  	elseif carbonId == 10102 then
  		role:saveGuide(8,2)
  	elseif carbonId == 10103 then
  		role:saveGuide(9,2)
  	elseif carbonId == 10220 then
  		role:saveGuide(22,1)
  	end
d02f7904   zhouhaihai   遗失的log
169
  	role:mylog("hang_action", {desc = "startHang", int1 = carbonId})
384bb077   zhouahaihai   挂机
170
171
172
173
174
175
176
177
  	SendPacket(actionCodes.Hang_startRpc, '')
  	return true
  end
  
  -- 每隔1分钟检查一次
  function _M.checkRpc(agent, data)
  	local role = agent.role
  	-- local msg = MsgPack.unpack(data)
5af8b4aa   zhouahaihai   挂机down
178
179
180
181
  	if checkReward(role) then
  		role:updateProperty({field = "hangBag", value = role:getProperty("hangBag")})
  		role:updateProperty({field = "hangInfo", value = role:getProperty("hangInfo")})
  	end
384bb077   zhouahaihai   挂机
182
183
184
185
  	SendPacket(actionCodes.Hang_checkRpc, MsgPack.pack({}))
  	return true
  end
  
cc5ca7f3   zhouhaihai   缓存battleKey
186
  local _BattleKey = nil
384bb077   zhouahaihai   挂机
187
188
189
  function _M.startBattleRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
bcf5bfbb   zhouahaihai   挂机new
190
191
  	local carbonId = msg.carbonId
  	local curData = csvdb["idle_battleCsv"][carbonId]
a1e08c9c   zhengshouren   宝箱关战斗异常
192
193
194
  	if not curData then 
  		return 1
  	end
bcf5bfbb   zhouahaihai   挂机new
195
  
384bb077   zhouahaihai   挂机
196
  	local hangInfo = role:getProperty("hangInfo")
bcf5bfbb   zhouahaihai   挂机new
197
  	if curData.main ~= 1 then
a1e08c9c   zhengshouren   宝箱关战斗异常
198
199
200
  		if carbonId ~= hangInfo.carbonId then 
  			return 2
  		end
bcf5bfbb   zhouahaihai   挂机new
201
202
  	end
  
33be3111   zhouhaihai   修改hangPass 结构
203
  	if role:checkHangPass(carbonId) then 
a1e08c9c   zhengshouren   宝箱关战斗异常
204
205
  		return 3
  	end
bcf5bfbb   zhouahaihai   挂机new
206
  
cc5ca7f3   zhouhaihai   缓存battleKey
207
208
  	_BattleKey = tostring(math.random())
  
53e8037e   zhouhaihai   任务
209
  	role:checkTaskEnter("HangBattle", {id = carbonId})
52c87300   zhouhaihai   bug
210
  	SendPacket(actionCodes.Hang_startBattleRpc, MsgPack.pack({key = _BattleKey}))
384bb077   zhouahaihai   挂机
211
212
213
214
215
216
217
  	return true
  end
  
  function _M.endBattleRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local hangInfo = role:getProperty("hangInfo")
cc5ca7f3   zhouhaihai   缓存battleKey
218
  	if not msg.key or msg.key ~= _BattleKey then 
d6a66c74   zhouhaihai   校验失败也返回
219
220
  		SendPacket(actionCodes.Hang_endBattleRpc, MsgPack.pack({errorCode = 1}))
  		return true
4906ebd2   zhengshouren   宝箱关副本结算异常
221
  	end
bcf5bfbb   zhouahaihai   挂机new
222
  	local carbonId = msg.carbonId
d4e9b817   zhouhaihai   战斗 日志
223
  	local isWin = msg.starNum and msg.starNum > 0
bcf5bfbb   zhouahaihai   挂机new
224
  	local carbonData = csvdb["idle_battleCsv"][carbonId]
4906ebd2   zhengshouren   宝箱关副本结算异常
225
226
227
  	if not carbonData then
  		return 2
  	end
bcf5bfbb   zhouahaihai   挂机new
228
  	if carbonData.main ~= 1 then
4906ebd2   zhengshouren   宝箱关副本结算异常
229
230
231
  		if carbonId ~= hangInfo.carbonId then 
  			return 3
  		end
bcf5bfbb   zhouahaihai   挂机new
232
  	end
33be3111   zhouhaihai   修改hangPass 结构
233
234
  
  	if role:checkHangPass(carbonId) then 
4906ebd2   zhengshouren   宝箱关副本结算异常
235
236
  		return 4
  	end
d4e9b817   zhouhaihai   战斗 日志
237
  
7bb30dca   zhouhaihai   修改发奖
238
  	local reward, change
d4e9b817   zhouhaihai   战斗 日志
239
  	if isWin then --win
33be3111   zhouhaihai   修改hangPass 结构
240
  		role:hangFinish(carbonId)
bcf5bfbb   zhouahaihai   挂机new
241
242
243
  		if carbonData.main ~= 1 then
  			hangInfo.bossTime = nil
  		end
384bb077   zhouahaihai   挂机
244
245
  		-- reward
  		reward = {}
384bb077   zhouahaihai   挂机
246
247
  		reward[ItemId.Gold] = carbonData.money_clear
  		reward[ItemId.Exp] = carbonData.exp_clear
00115a7a   zhouahaihai   奖励发放
248
  		reward[ItemId.PlayerExp] = carbonData.playerExp_clear
384bb077   zhouahaihai   挂机
249
  		for itemId, count in pairs(carbonData.item_clear:toNumMap()) do
384bb077   zhouahaihai   挂机
250
251
  			reward[itemId] = count
  		end
7bb30dca   zhouhaihai   修改发奖
252
  		reward, change = role:award(reward, {log = {desc = "hangBattle", int1 = carbonId}})
00e663bd   zhouhaihai   剧情相关
253
  
03a6166a   zhouhaihai   餐厅优化
254
  		role:checkTaskEnter("HangPass", {id = carbonId})
286c980a   chenyueqi   挂机战斗胜利才触发对应的引导
255
256
257
258
259
260
  		
  		-- 引导
  		if carbonId == 10101 then
  			role:finishGuide(5)
  		elseif carbonId == 10102 then
  			role:finishGuide(8)
e0290d8e   liuzujun   修改引导, 抽卡阶段奖励修改
261
  			role:saveGuide(9, 2)
286c980a   chenyueqi   挂机战斗胜利才触发对应的引导
262
263
  		elseif carbonId == 10103 then
  			role:finishGuide(9)
be0c7a19   chenyueqi   挂机打完困难20101才设定完成引导22
264
  		elseif carbonId == 20101 then
286c980a   chenyueqi   挂机战斗胜利才触发对应的引导
265
266
267
268
269
270
271
272
  			role:finishGuide(22)
  		end
  		for _, guideData in pairs(csvdb["guide_unlockCsv"]) do
  			if guideData.type == 3 and guideData.carbonId == carbonId then
  				role:saveGuide(guideData.guideId,1,true)
  				break
  			end
  		end
384bb077   zhouahaihai   挂机
273
  	end
53b4b8bd   liuzujun   自动挂机下一关
274
275
  	local nextCarbonId = role:getNextCarbonId(carbonId)
  	-- 设置挂机关卡
e0290d8e   liuzujun   修改引导, 抽卡阶段奖励修改
276
  	if isWin and hangInfo.carbonId < nextCarbonId then
53b4b8bd   liuzujun   自动挂机下一关
277
  		hangInfo.carbonId = nextCarbonId
e0290d8e   liuzujun   修改引导, 抽卡阶段奖励修改
278
279
280
  		local cfg = csvdb["idle_battleCsv"][nextCarbonId]
  		if cfg then
  			hangInfo.bossTime = skynet.timex() + cfg.idle_time
e0290d8e   liuzujun   修改引导, 抽卡阶段奖励修改
281
  		end
93f6e69b   liuzujun   拾荒选择时间,抽卡增加sr保底
282
  	end
384bb077   zhouahaihai   挂机
283
  	role:updateProperty({field = "hangInfo", value = hangInfo})
33be3111   zhouhaihai   修改hangPass 结构
284
  	
d4e9b817   zhouhaihai   战斗 日志
285
286
287
288
289
290
  	role:checkBattle("hang", {
  		id = carbonId,
  		isWin = isWin,
  		info = msg.info,
  		reward = reward,
  	})
1e9cb217   chenyueqi   服务器记录控制引导过程
291
  
d02f7904   zhouhaihai   遗失的log
292
293
294
  	local team = role:getProperty("pvpTC")
  	role:mylog("hang_action", {desc = "hangBattle", short1 = msg.starNum > 0 and 1 or 0, int1 = carbonId, int2 = role:getProperty("hangTBV"), cint1 = role:getHerosCamp(team.heros)})
  
384bb077   zhouahaihai   挂机
295
296
297
  	SendPacket(actionCodes.Hang_endBattleRpc, MsgPack.pack({
  		starNum = msg.starNum, 
  		reward = reward,
7bb30dca   zhouhaihai   修改发奖
298
  		change = change,
384bb077   zhouahaihai   挂机
299
300
301
302
  		}))
  	return true
  end
  
7efe5275   zhouhaihai   检查leader
303
304
305
306
307
308
309
  local function checkLeader(heros, leader)
  	if not leader then return end
  	for slot, heroId in pairs(heros) do
  		if heroId == leader then return true end
  	end
  end
  
384bb077   zhouahaihai   挂机
310
311
312
  function _M.roleFormatRpc(agent , data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
384bb077   zhouahaihai   挂机
313
314
315
  	local hangTeam = role:getProperty("hangTeam")
  	for slot, heroId in pairs(msg.heros) do
  		if not role.heros[heroId] then
e6ebee44   zhouhaihai   编队bug
316
  			return 1
384bb077   zhouahaihai   挂机
317
318
  		end
  	end
f603a60f   zhouhaihai   支援技实装
319
320
321
  
  	local supports = {}
  	for slot, support in pairs(msg.supports or {}) do
e6ebee44   zhouhaihai   编队bug
322
  		if slot ~= 1 and slot ~= 2 then return 2 end
f603a60f   zhouhaihai   支援技实装
323
  		local level = role.dinerData:getProperty("dishTree"):getv(support, 0)
e6ebee44   zhouhaihai   编队bug
324
  		if level <= 0 then return 3 end
f603a60f   zhouhaihai   支援技实装
325
326
  		supports[slot] = support
  	end
e6ebee44   zhouhaihai   编队bug
327
  	if not checkLeader(msg.heros, msg.leader) then return 4 end
f603a60f   zhouhaihai   支援技实装
328
  
384bb077   zhouahaihai   挂机
329
330
331
332
333
334
  	table.clear(hangTeam)
  	hangTeam.heros = {}
  	for slot, heroId in pairs(msg.heros) do
  		hangTeam.heros[slot] = heroId
  	end
  	hangTeam.leader = msg.leader
f603a60f   zhouhaihai   支援技实装
335
  	hangTeam.supports = supports
fa565e0c   zhouhaihai   优化结构
336
  	role:saveHangTeam(hangTeam)
826a2c9e   chenyueqi   挂机编队完成的时候服务器主动保存下...
337
  	role:saveGuide(5,8)
384bb077   zhouahaihai   挂机
338
339
340
341
  	SendPacket(actionCodes.Hang_roleFormatRpc, '')
  	return true
  end
  
5af8b4aa   zhouahaihai   挂机down
342
343
344
345
346
  function _M.getRewardRpc(agent , data)
  	local role = agent.role
  	checkReward(role)
  	local items = role:getProperty("hangBag")
  	if not next(items) then return end
7bb30dca   zhouhaihai   修改发奖
347
  	local reward, change = role:award(items, {log = {desc = "hangReward"}})
5af8b4aa   zhouahaihai   挂机down
348
349
350
  	table.clear(items)
  	local hangInfo = role:getProperty("hangInfo")
  	local nowTime = skynet.timex()
bcf5bfbb   zhouahaihai   挂机new
351
352
  	hangInfo.endItemTime = nowTime + globalCsv.idle_producetime_max
  	hangInfo.endCoinTime = nowTime + globalCsv.idle_producetime_max
5af8b4aa   zhouahaihai   挂机down
353
354
355
356
  	hangInfo.coinTime = nowTime
  	hangInfo.itemTime = nowTime
  	role:updateProperty({field = "hangBag", value = items})
  	role:updateProperty({field = "hangInfo", value = hangInfo})
03a6166a   zhouhaihai   餐厅优化
357
  	role:checkTaskEnter("HangGet")
53e8037e   zhouhaihai   任务
358
359
  	if reward[ItemId.Gold] then
  		role:checkTaskEnter("HangGetGold", {count = reward[ItemId.Gold]})
bcf5bfbb   zhouahaihai   挂机new
360
  	end
d43246b0   zhouhaihai   log 增加
361
362
363
364
365
366
367
368
369
370
371
  
  	role:log("residence_reward", {
  		mission_threadid = math.floor(hangInfo.carbonId / 10000), --大关卡ID
  		mission_id = hangInfo.carbonId, --关卡ID
  		mission_type = 100, --关卡类型,见关卡类型枚举表
  		residence_reward_type = 0, --领取奖励方式,快速(超前领取)记录为1,正常领取记录为0
  		residence_time = 0, --挂机或排名时长
  		residence_reward = reward, --获得奖励,建议使用json格式记录。示例:{ "XX": "1", "XXX": "3"}
  	})
  	
  
53e8037e   zhouhaihai   任务
372
  	SendPacket(actionCodes.Hang_getRewardRpc, MsgPack.pack({
7bb30dca   zhouhaihai   修改发奖
373
374
  		reward = reward,
  		change = change
bcf5bfbb   zhouahaihai   挂机new
375
376
377
378
  	}))
  	return true
  end
  
9962b061   zhouahaihai   补充 挂机
379
380
381
382
383
384
385
386
387
388
389
390
  function _M.quickRpc(agent , data)
  	local role = agent.role
  
  	local hangInfo = role:getProperty("hangInfo")
  	if not hangInfo.carbonId then return end
  	local carbonData = csvdb["idle_battleCsv"][hangInfo.carbonId]
  
  	local curCount = role.dailyData:getProperty("hangQC") + 1
  	local costs = globalCsv.idle_quickproduce_cost:toArray(true, "=")
  	if not costs[curCount] then return end
  	if costs[curCount] > 0 then
  		if not role:checkItemEnough({[ItemId.Diamond] = costs[curCount]}) then return end
3133cb76   zhouhaihai   日志
391
  		role:costItems({[ItemId.Diamond] = costs[curCount]}, {log = {desc = "quickHang", int1 = hangInfo.carbonId}})
9962b061   zhouahaihai   补充 挂机
392
393
394
395
396
397
398
399
400
  	end
  
  	role.dailyData:updateProperty({field = "hangQC", value = curCount})
  
  	local time = globalCsv.idle_quickproduce_time
  	local reward = {}
  
  	local coinCount = math.floor(time / globalCsv.idle_money_produce_cd)
  	local itemCount = math.floor(time / globalCsv.idle_item_produce_cd)
9e1a93c2   liuzujun   快速挂机掉落浮点数取整
401
402
403
  	reward[ItemId.Gold] = math.floor((reward[ItemId.Gold] or 0) + coinCount * carbonData.money)
  	reward[ItemId.Exp] = math.floor((reward[ItemId.Exp] or 0) + coinCount * carbonData.exp)
  	reward[ItemId.PlayerExp] = math.floor((reward[ItemId.PlayerExp] or 0) + coinCount * carbonData.playerExp)
9962b061   zhouahaihai   补充 挂机
404
405
406
407
408
409
410
411
412
  
  	local pool = {}
  	for _, temp in pairs(carbonData.item:toArray()) do
  		table.insert(pool, temp:toArray(true, "="))
  	end
  	for i = 1, itemCount do
  		local cur = pool[math.randWeight(pool, 3)]
  		reward[cur[1]] = (reward[cur[1]] or 0) + cur[2]
  	end
317a46a9   liuzujun   添加特权卡
413
  
9e1a93c2   liuzujun   快速挂机掉落浮点数取整
414
  	local doubleCoef = role.activity:isOpen("DoubleDrop") and 2 or 1
317a46a9   liuzujun   添加特权卡
415
416
  	-- 特权卡获取加速获得额外道具
  	local coef = role.storeData:getProduceItemSpeedCoef()
accf94c4   liuzujun   活动以类型标识,修改双倍活动bug
417
  	if coef > 1 or doubleCoef > 1 then
317a46a9   liuzujun   添加特权卡
418
  		for k, cnt in pairs(reward) do
9e1a93c2   liuzujun   快速挂机掉落浮点数取整
419
  			reward[k] = math.floor(cnt * coef * doubleCoef)
317a46a9   liuzujun   添加特权卡
420
421
422
  		end
  	end
  
7bb30dca   zhouhaihai   修改发奖
423
424
  	local change
  	reward, change = role:award(reward, {log = {desc = "quickHang", int1 = hangInfo.carbonId}})
f60b89b1   zhouhaihai   奖励副本
425
426
427
  	if reward[ItemId.Gold] then
  		role:checkTaskEnter("HangGetGold", {count = reward[ItemId.Gold]})
  	end
53e8037e   zhouhaihai   任务
428
  	role:checkTaskEnter("HangQuick")
d43246b0   zhouhaihai   log 增加
429
430
431
432
433
434
435
436
437
  
  	role:log("residence_reward", {
  		mission_threadid = math.floor(hangInfo.carbonId / 10000), --大关卡ID
  		mission_id = hangInfo.carbonId, --关卡ID
  		mission_type = 100, --关卡类型,见关卡类型枚举表
  		residence_reward_type = 1, --领取奖励方式,快速(超前领取)记录为1,正常领取记录为0
  		residence_time = time, --挂机或排名时长
  		residence_reward = reward, --获得奖励,建议使用json格式记录。示例:{ "XX": "1", "XXX": "3"}
  	})
9962b061   zhouahaihai   补充 挂机
438
  	SendPacket(actionCodes.Hang_quickRpc, MsgPack.pack({
7bb30dca   zhouhaihai   修改发奖
439
440
  		reward = reward,
  		change = change
9962b061   zhouahaihai   补充 挂机
441
442
443
444
  	}))
  	return true
  end
  
f60b89b1   zhouhaihai   奖励副本
445
446
447
448
449
450
451
452
453
  function _M.bonusFormatRpc(agent , data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local bTeam = role:getProperty("bTeam")
  	for slot, heroId in pairs(msg.heros) do
  		if not role.heros[heroId] then
  			return
  		end
  	end
f603a60f   zhouhaihai   支援技实装
454
455
456
457
458
459
460
  	local supports = {}
  	for slot, support in pairs(msg.supports) do
  		if slot ~= 1 and slot ~= 2 then return end
  		local level = role.dinerData:getProperty("dishTree"):getv(support, 0)
  		if level <= 0 then return end
  		supports[slot] = support
  	end
7efe5275   zhouhaihai   检查leader
461
462
  	if not checkLeader(msg.heros, msg.leader) then return end
  	
f60b89b1   zhouhaihai   奖励副本
463
464
465
466
467
468
  	table.clear(bTeam)
  	bTeam.heros = {}
  	for slot, heroId in pairs(msg.heros) do
  		bTeam.heros[slot] = heroId
  	end
  	bTeam.leader = msg.leader
f603a60f   zhouhaihai   支援技实装
469
  	bTeam.supports = supports
f60b89b1   zhouhaihai   奖励副本
470
471
472
473
474
475
476
477
478
479
480
481
482
  
  	role:updateProperty({field = "bTeam", value = bTeam}) 
  	SendPacket(actionCodes.Hang_bonusFormatRpc, '')
  	return true
  end
  
  function _M.buyBonusCountRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  
  	local count = msg.count
  	local btype = msg.type
  
3133cb76   zhouhaihai   日志
483
  	if not TimeReset["DailyBattle" .. btype] then return end
accf94c4   liuzujun   活动以类型标识,修改双倍活动bug
484
485
486
487
488
  	local open, actId = role.activity:isOpen("BonusDouble")
  	local actData = csvdb["activity_ctrlCsv"][actId]
  	if not actData then return end
  
  	local coef = open and tonumber(actData.condition2) or 1
f60b89b1   zhouhaihai   奖励副本
489
490
491
  
  	local bonusC = role.dailyData:getProperty("bonusC")
  	bonusC[btype] = bonusC[btype] or {c = 0, b = 0}
accf94c4   liuzujun   活动以类型标识,修改双倍活动bug
492
  	local lastCount = globalCsv.bonus_daily_buy_count * coef - bonusC[btype]["b"]
f60b89b1   zhouhaihai   奖励副本
493
494
  	if math.illegalNum(count, 1, lastCount)  then return 1 end
  
3133cb76   zhouhaihai   日志
495
  	if not role:checkItemEnough({[ItemId.Diamond] = globalCsv.bonus_buy_cost * count}) then return 2 end
f60b89b1   zhouhaihai   奖励副本
496
  
887c1843   zhouhaihai   日志新一批
497
  	role:costItems({[ItemId.Diamond] = globalCsv.bonus_buy_cost * count}, {log = {desc = "buyBonusCount", int1 = btype, int2 = count}})
d481965d   zhouhaihai   购买次数bug
498
499
  	bonusC[btype]["b"] = bonusC[btype]["b"] + count
  	bonusC[btype]["c"] = bonusC[btype]["c"] - count
f60b89b1   zhouhaihai   奖励副本
500
501
502
503
504
505
506
507
508
509
510
511
  
  	role.dailyData:updateProperty({field = "bonusC", value = bonusC})
  
  	SendPacket(actionCodes.Hang_buyBonusCountRpc, '')
  	return true
  end
  
  function _M.startBonusBattleRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  
accf94c4   liuzujun   活动以类型标识,修改双倍活动bug
512
513
514
  	local open, actId = role.activity:isOpen("BonusDouble")
  
  	if not role:isFuncUnlock(FuncUnlock.BonusBattle) then return 1 end
d232676a   zhouhaihai   功能解锁 冒险返回
515
  
f60b89b1   zhouhaihai   奖励副本
516
  	local bonusData = csvdb["bonus_battleCsv"][id]
bc902e2d   zhouhaihai   增加开放判断
517
  
accf94c4   liuzujun   活动以类型标识,修改双倍活动bug
518
519
520
  	if not open then
  		if not role:isTimeResetOpen(TimeReset["DailyBattle" .. bonusData.type]) then return 2 end
  	end
bc902e2d   zhouhaihai   增加开放判断
521
  
accf94c4   liuzujun   活动以类型标识,修改双倍活动bug
522
523
  	if not bonusData then return 3 end
  	if not role:checkHangPass(bonusData.unlock) then return 4 end
f60b89b1   zhouhaihai   奖励副本
524
  
accf94c4   liuzujun   活动以类型标识,修改双倍活动bug
525
  	if not next(role:getProperty("bTeam")) then return 5 end
f60b89b1   zhouhaihai   奖励副本
526
527
528
  
  	local bonusC = role.dailyData:getProperty("bonusC")
  	bonusC[bonusData.type] = bonusC[bonusData.type] or {c = 0, b = 0}
accf94c4   liuzujun   活动以类型标识,修改双倍活动bug
529
530
531
532
533
534
535
  
  	local actData = csvdb["activity_ctrlCsv"][actId]
  	if not actData then return 6 end
  
  	local coef = open and tonumber(actData.condition2) or 1
  
  	if globalCsv.bonus_daily_count * coef - bonusC[bonusData.type]["c"] <= 0 then return 7 end
f60b89b1   zhouhaihai   奖励副本
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
  
  
  	role.__bonusBattleCache = {
  		key = tostring(math.random()),
  		id = id,
  	}
  	SendPacket(actionCodes.Hang_startBonusBattleRpc, MsgPack.pack({key = role.__bonusBattleCache.key}))
  	return true
  end
  
  function _M.endBonusBattleRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local key = msg.key
  	local starNum = msg.starNum
  	if not role.__bonusBattleCache then return 1 end
accf94c4   liuzujun   活动以类型标识,修改双倍活动bug
553
554
555
556
557
  	local open, actId = role.activity:isOpen("BonusDouble")
  	local actData = csvdb["activity_ctrlCsv"][actId]
  	if not actData then return end
  
  	local coef = open and tonumber(actData.condition2) or 1
f60b89b1   zhouhaihai   奖励副本
558
  
d6a66c74   zhouhaihai   校验失败也返回
559
560
561
562
  	if role.__bonusBattleCache.id ~= id or role.__bonusBattleCache.key ~= key then 
  		SendPacket(actionCodes.Hang_endBonusBattleRpc, MsgPack.pack({errorCode = 1}))
  		return true
  	end
f60b89b1   zhouhaihai   奖励副本
563
564
  	local bonusData = csvdb["bonus_battleCsv"][id]
  
7bb30dca   zhouhaihai   修改发奖
565
  	local reward, change
f60b89b1   zhouhaihai   奖励副本
566
   	if starNum and starNum > 0 then
74a8fdc9   zhouhaihai   奖励副本 胜利扣除次数
567
568
569
   		-- 胜利扣除次数
   		local bonusC = role.dailyData:getProperty("bonusC")
  		bonusC[bonusData.type] = bonusC[bonusData.type] or {c = 0, b = 0}
accf94c4   liuzujun   活动以类型标识,修改双倍活动bug
570
  		if globalCsv.bonus_daily_count * coef - bonusC[bonusData.type]["c"] <= 0 then return 3 end
74a8fdc9   zhouhaihai   奖励副本 胜利扣除次数
571
572
573
  		bonusC[bonusData.type]["c"] = bonusC[bonusData.type]["c"] + 1
  		role.dailyData:updateProperty({field = "bonusC", value = bonusC})
  
b2747fbc   zhouhaihai   挂机
574
575
576
577
578
  		reward = bonusData.reward:toNumMap()
  		local chance = bonusData.chance:randWeight(true)
  		if chance[1] ~= 0 then
  			reward[chance[1]] = (reward[chance[1]] or 0) + chance[2]
  		end
accf94c4   liuzujun   活动以类型标识,修改双倍活动bug
579
580
581
  		for k, v  in pairs(reward) do
  			reward[k] = v * (coef > 1 and actData.condition or 1)
  		end
7bb30dca   zhouhaihai   修改发奖
582
   		reward, change = role:award(reward, {log = {desc = "bonusBattle", int1 = id}})
f60b89b1   zhouhaihai   奖励副本
583
584
585
   		role:checkTaskEnter("BonusPass", {id = id})
   	end
  
d4e9b817   zhouhaihai   战斗 日志
586
587
588
589
590
591
   	role:checkBattle("bonus", {
  		id = id,
  		isWin = starNum and starNum > 0,
  		info = msg.info,
  		reward = reward,
  	})
d02f7904   zhouhaihai   遗失的log
592
593
  	role:mylog("hang_action", {desc = "bonusBattle", short1 = msg.starNum > 0 and 1 or 0, int1 = id})
  
f60b89b1   zhouhaihai   奖励副本
594
595
  	SendPacket(actionCodes.Hang_endBonusBattleRpc, MsgPack.pack({
  		starNum = starNum, 
7bb30dca   zhouhaihai   修改发奖
596
597
598
  		reward = reward,
  		change = change
  	}))
f60b89b1   zhouhaihai   奖励副本
599
600
601
  	return true
  end
  
a6508219   zhouhaihai   挂机奖励
602
603
604
605
606
607
608
609
610
611
612
  function _M.hangGiftRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  
  	local id = msg.id
  	local carbonData = csvdb["idle_battleCsv"][id]
  	if not carbonData or carbonData.item_clear_special == "" then return 1 end
  
  	local hangGift = role:getProperty("hangGift")
  	if hangGift[id] then return 2 end
  
7bb30dca   zhouhaihai   修改发奖
613
  	local reward, change = role:award(carbonData.item_clear_special, {log = {desc = "hangGift", int1 = id}})
a6508219   zhouhaihai   挂机奖励
614
615
  
  	role:changeUpdates({{type = "hangGift", field = id, value = 1}})
d02f7904   zhouhaihai   遗失的log
616
  	role:mylog("hang_action", {desc = "hangGift",  int1 = id})
a6508219   zhouhaihai   挂机奖励
617
  
7bb30dca   zhouhaihai   修改发奖
618
  	SendPacket(actionCodes.Hang_hangGiftRpc, MsgPack.pack({reward = reward, change = change}))
a6508219   zhouhaihai   挂机奖励
619
620
  	return true
  end
f60b89b1   zhouhaihai   奖励副本
621
  
64e63ad0   wangyujie   完成需求:挂机栏位物品数量上限和钻...
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
  function _M.bagFieldRpc(agent, data)
  	local role = agent.role
  	local curBL = role:getProperty("hangBagLimit")
  	local costD = globalCsv.idle_field_cost[curBL - globalCsv.idle_field_origin]
  	if not costD then
  		return 1
  	end
  	if costD ~= 0 and not role:checkItemEnough({[ItemId.Diamond] = costD}) then
  		return 2
  	end
  	role:updateProperty({field = "hangBagLimit", value = curBL + 1})
  	role:costItems({[ItemId.Diamond] = costD}, {log = {desc = "bagField"}})
  	SendPacket(actionCodes.Hang_bagFieldRpc, '')
  	return true
  end
f60b89b1   zhouhaihai   奖励副本
637
  
ed20f277   zhouhaihai   chatline 奖励
638
639
640
  function _M.chatLineRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
ed20f277   zhouhaihai   chatline 奖励
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
  	local id = msg.id
  
  	local idleData = csvdb["idle_battleCsv"][id]
  	if not idleData or idleData.chatline == 0 then
  		return
  	end
  
  	local chatline = role:getProperty("chatline")
  	if chatline[id] then return end
  
  	if not role:checkHangPass(id) then return end
  
  	chatline[id] = skynet.timex()
  	role:updateProperty({field = "chatline", value = chatline})
  
7bb30dca   zhouhaihai   修改发奖
656
  	local reward, change = role:award(idleData.chatline_reward, {log = {desc = "chatline", int1 = id}})
ed20f277   zhouhaihai   chatline 奖励
657
  	
7bb30dca   zhouhaihai   修改发奖
658
  	SendPacket(actionCodes.Hang_chatLineRpc, MsgPack.pack({reward = reward, change = change}))
ed20f277   zhouhaihai   chatline 奖励
659
660
661
  	return true
  end
  
384bb077   zhouahaihai   挂机
662
  return _M