InnerHandler.lua 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447
  1. -----------------------------logic消息分发------------------------
  2. local MiddleHeartBeat = require("middle.MiddleHeartBeat")
  3. local MiddleLogic = require("middle.MiddleLogic")
  4. local MiddleConnect = require("middle.MiddleConnect")
  5. local MiddleManager = require("middle.MiddleManager")
  6. local ChatMiddleLogic = require("chat.ChatMiddleLogic")
  7. local JjcLadderLogic = require("jjcLadder.JjcLadderLogic")
  8. local JjcLadderMiddle = require("jjcLadder.JjcLadderMiddle")
  9. local ValleyLogic = require("valley.ValleyLogic")
  10. local ValleyMiddle = require("valley.ValleyMiddle")
  11. local ValleyMiddle = require("valley.ValleyMiddle")
  12. local WarReportMiddle = require("warReport.WarReportMiddle")
  13. local AbsActBillboardLogic = require("absAct.AbsActBillboardLogic")
  14. local AbsActBillboardMiddleLogic = require("absAct.AbsActBillboardMiddleLogic")
  15. local YunYingLogic = require("yunying.YunYingLogic")
  16. local MoZhuLogic = require("mozhu.MoZhuLogic")
  17. local MoZhuMiddleLogic = require("mozhu.MoZhuMiddleLogic")
  18. local ChatLogic = require("chat.ChatLogic")
  19. local HeroMiddleLogic = require("hero.HeroMiddleLogic")
  20. local MiddleCommonLogic = require("middle.MiddleCommonLogic")
  21. local CommerceMiddle = require("serverCommerce.ServerCommerceMiddle")
  22. local MiddleCommonRank = require("middle.MiddleCommonRank")
  23. local BanLogic = require("scene.BanLogic")
  24. local JjcNewLadderMidder = require("jjcnewladder.jjcNewLadderMiddle")
  25. local RebateLogic = require("platform.RebateLogic")
  26. function LW_HELLO(fd, msg)
  27. if _G.is_middle ~= true then return end
  28. -- print("[LW_HELLO] 收到LW_HELLO 消息")
  29. MiddleConnect.LW_HELLO(fd, msg)
  30. end
  31. function LW_DISCONNECT(fd, msg)
  32. if _G.is_middle ~= true then return end
  33. print("[LW_DISCONNECT] 收到 LW_DISCONNECT 消息")
  34. MiddleConnect.LW_DISCONNECT(fd, msg)
  35. end
  36. function LW_HEARTBEAT(fd, msg)
  37. if _G.is_middle ~= true then return end
  38. --print("[LW_HEARTBEAT] 收到 LW_HEARTBEAT 消息")
  39. MiddleHeartBeat.LW_HEARTBEAT(fd, msg)
  40. end
  41. function LW_MOZHU_QUERY(fd,msg)
  42. if _G.is_middle ~= true then return end
  43. --print("[LW_MOZHU_QUERY] 收到 LW_MOZHU_QUERY 消息")
  44. MoZhuMiddleLogic.LW_MOZHU_QUERY(fd,msg)
  45. end
  46. function WL_MOZHU_QUERY(fd,msg)
  47. if _G.is_middle ~= true then return end
  48. --print("[WL_MOZHU_QUERY] 收到 WL_MOZHU_QUERY 消息")
  49. MoZhuMiddleLogic.LW_MOZHU_QUERY(fd,msg)
  50. end
  51. function WL_HELLO(fd, msg)
  52. --if _G.is_middle ~= true then return end
  53. -- print("[WL_HELLO] 收到 WL_HELLO 消息 fd = "..fd)
  54. -- table.print_lua_table(msg)
  55. MiddleConnect.WL_HELLO(fd, msg)
  56. end
  57. function WL_HEARTBEAT(fd, msg)
  58. -- if _G.is_middle ~= true then return end
  59. --print("[WL_HEARTBEAT] 收到 WL_HEARTBEAT 消息")
  60. MiddleHeartBeat.WL_HEARTBEAT(fd, msg)
  61. end
  62. function LW_MIDDLE_CHAT(fd, msg)
  63. if _G.is_middle ~= true then return end
  64. print("[LW_MIDDLE_CHAT] 收到跨服聊天请求 fd = "..fd)
  65. MiddleConnect.LW_MIDDLE_CHAT(fd, msg)
  66. end
  67. function WL_MIDDLE_CHAT(fd, msg)
  68. ChatLogic.WL_MIDDLE_CHAT(fd, msg)
  69. end
  70. -- 聊天查看分享英雄数据(请求的服务器->中心)
  71. function LW_MIDDLE_CHAT_QUERY_HERO_DATA(fd, msg)
  72. if _G.is_middle ~= true then return end
  73. print("[LW_MIDDLE_CHAT_QUERY_HERO_DATA] 请求的服务器->中心 获取到消息")
  74. MiddleConnect.LW_MIDDLE_CHAT_QUERY_HERO_DATA(fd, msg)
  75. end
  76. -- 发送到对应服务器信息(中心->目标服务器)
  77. function WL_MIDDLE_CHAT_QUERY_HERO_DATA(fd, msg)
  78. print("[WL_MIDDLE_CHAT_QUERY_HERO_DATA] 中心->目标服务器 获取到消息")
  79. HeroMiddleLogic.HeroMiddleLogic_QueryHeroData_WL(fd, msg)
  80. end
  81. -- 英雄信息回复(目标->中心)
  82. function LW_MIDDLE_CHAT_GET_HERO_DATA(fd, msg)
  83. if _G.is_middle ~= true then return end
  84. print("[LW_MIDDLE_CHAT_GET_HERO_DATA] 目标->中心 获取到消息")
  85. MiddleConnect.LW_MIDDLE_CHAT_GET_HERO_DATA(fd, msg)
  86. end
  87. -- 英雄信息回复(中心->请求)
  88. function WL_MIDDLE_CHAT_GET_HERO_DATA(fd, msg)
  89. print("[WL_MIDDLE_CHAT_GET_HERO_DATA] 中心->请求 获取到消息")
  90. HeroMiddleLogic.HeroMiddleLogic_GetHeroData_WL(fd, msg)
  91. end
  92. function LW_WARREPORT_GET_COMBATINFO(fd, msg)
  93. if _G.is_middle ~= true then return end
  94. print("[LW_WARREPORT_GET_COMBATINFO] 目标->中心 获取到战报录像信息")
  95. MiddleConnect.LW_WARREPORT_GET_COMBATINFO(fd, msg)
  96. end
  97. function WL_WARREPORT_GET_COMBATINFO(fd, msg)
  98. print("[WL_WARREPORT_GET_COMBATINFO] 获取到中心消息 请求获取到战报录像信息")
  99. WarReportMiddle.WL_WARREPORT_GET_COMBATINFO_NEW(fd, msg)
  100. end
  101. function LW_WARREPORT_SEND_COMBATINFO(fd, msg)
  102. if _G.is_middle ~= true then return end
  103. print("[LW_WARREPORT_SEND_COMBATINFO] 回复中心服 获取到战报录像信息")
  104. MiddleConnect.LW_WARREPORT_SEND_COMBATINFO(fd, msg)
  105. end
  106. function WL_WARREPORT_SEND_COMBATINFO(fd, msg)
  107. print("[WL_WARREPORT_GET_COMBATINFO] 获取到其他服消息 获取到战报录像信息回包")
  108. WarReportMiddle.WL_WARREPORT_SEND_COMBATINFO(fd, msg)
  109. end
  110. -------------------- 跨服玩家头像数据开始 --------------------
  111. function LW_CHAT_PLAYER_INFO(fd, msg)
  112. if _G.is_middle ~= true then return end
  113. MiddleConnect.LW_CHAT_PLAYER_INFO(fd, msg)
  114. end
  115. function WL_CHAT_PLAYER_INFO(fd, msg)
  116. MiddleCommonLogic.MiddleCommonLogic_GetChatPlayInfo_WL(fd, msg)
  117. end
  118. function LW_CHAT_PLAYER_INFO_SEND(fd, msg)
  119. if _G.is_middle ~= true then return end
  120. MiddleConnect.LW_CHAT_PLAYER_INFO_SEND(fd, msg)
  121. end
  122. function WL_CHAT_PLAYER_INFO_SEND(fd, msg)
  123. MiddleCommonLogic.MiddleCommonLogic_SendChatPlayInfo_WL(fd, msg)
  124. end
  125. -------------------- 跨服玩家头像数据结束 --------------------
  126. -------------------- 跨服请求战斗数据开始 --------------------
  127. function LW_COMBAT_GETINFO(fd, msg)
  128. if _G.is_middle ~= true then return end
  129. MiddleConnect.LW_COMBAT_GETINFO(fd, msg)
  130. end
  131. function WL_COMBAT_GETINFO(fd, msg)
  132. MiddleCommonLogic.MiddleCommonLogic_CombatBegin_WL(fd, msg)
  133. end
  134. function LW_COMBAT_GETINFO_SEND(fd, msg)
  135. if _G.is_middle ~= true then return end
  136. MiddleConnect.LW_COMBAT_GETINFO_SEND(fd, msg)
  137. end
  138. function WL_COMBAT_GETINFO_SEND(fd, msg)
  139. MiddleCommonLogic.MiddleCommonLogic_CombatBegin_SendWL(fd, msg)
  140. end
  141. -------------------- 跨服请求战斗数据结束 --------------------
  142. -------------------- 跨服商业活动开始 ---------------------------
  143. -- 回复开服天数
  144. function LW_COMMERCE_SENDOPENDAY(fd, msg)
  145. if _G.is_middle ~= true then return end
  146. print("[LW_COMMERCE_SENDOPENDAY] 回复开服天数")
  147. CommerceMiddle.CommerceMiddle_SendOpenDay(fd, msg)
  148. end
  149. -- 请求开服天数
  150. function WL_COMMERCE_QUERYOPENDAY(fd, msg)
  151. print("[WL_COMMERCE_QUERYOPENDAY] 请求开服天数")
  152. CommerceMiddle.CommerceMiddle_QueryOpenDay(fd, msg)
  153. end
  154. -- 请求是否开启活动
  155. function LW_COMMERCE_ACTOPEN(fd, msg)
  156. if _G.is_middle ~= true then return end
  157. print("[LW_COMMERCE_ACTOPEN] 请求是否开启活动")
  158. CommerceMiddle.CommerceMiddle_QueryOpenAct(fd, msg)
  159. end
  160. function WL_COMMERCE_ACTOPEN(fd, msg)
  161. print("[WL_COMMERCE_ACTOPEN] 回复是否开启活动")
  162. CommerceMiddle.CommerceMiddle_SendOpenAct(fd, msg)
  163. end
  164. -- 更新排行榜数据
  165. function LW_COMMERCE_RANK_POINT_CHANGE(fd, msg)
  166. if _G.is_middle ~= true then return end
  167. print("[LW_COMMERCE_RANK_POINT_CHANGE] 更新排行榜数据")
  168. MiddleCommonRank.MiddleCommonRank_ReceiveRankData(msg)
  169. end
  170. -- 请求排行榜数据
  171. function LW_COMMERCE_QUERY_RANK_INFO(fd, msg)
  172. if _G.is_middle ~= true then return end
  173. print("[LW_COMMERCE_QUERY_RANK_INFO] 请求排行榜数据")
  174. MiddleCommonRank.MiddleCommonRank_QueryRankInfo(msg)
  175. end
  176. -- 请求排行榜数据回包
  177. function WL_COMMERCE_QUERY_RANK_INFO(fd, msg)
  178. print("[WL_COMMERCE_QUERY_RANK_INFO] 请求排行榜数据回包")
  179. CommerceMiddle.CommerveMiddle_GetRankInfo(msg)
  180. end
  181. -- 请求服务器排名
  182. function LW_COMMERCE_QUERY_SERVER_RANK(fd, msg)
  183. if _G.is_middle ~= true then return end
  184. print("[LW_COMMERCE_QUERY_SERVER_RANK] 请求服务器排名")
  185. MiddleCommonRank.MiddleCommonRank_QueryServerRank(msg)
  186. end
  187. -- 获取服务器排行榜服务器排名 回包
  188. function WL_COMMERCE_GET_SERVERRANK_PRIZE(fd, msg)
  189. print("[WL_COMMERCE_GET_SERVERRANK_PRIZE] 获取服务器排行榜服务器排名 回包")
  190. CommerceMiddle.CommerceMiddle_GetServerRank(msg)
  191. end
  192. -- 通知中心服全服邮件发送完成
  193. function LW_COMMERCE_TELL_SERVER_MAILOK(fd, msg)
  194. if _G.is_middle ~= true then return end
  195. print("[LW_COMMERCE_TELL_SERVER_MAILOK] 通知中心服全服邮件发送完成")
  196. MiddleCommonRank.MiddleCommonRank_ServerMailOk(msg)
  197. end
  198. -- 发送给对应的服务器 个人排行榜奖励
  199. function WL_COMMERCE_SEND_HUMAN_PRIZE(fd, msg)
  200. print("[WL_COMMERCE_SEND_HUMAN_PRIZE] 发送给对应的服务器 个人排行榜奖励")
  201. CommerceMiddle.CommerceMiddle_GetHumanRank(msg)
  202. end
  203. -- 清理排行榜命令
  204. function LW_COMMERCE_CLEAR_RANK(fd, msg)
  205. if _G.is_middle ~= true then return end
  206. print("[LW_COMMERCE_CLEAR_RANK] 清理排行榜命令")
  207. MiddleCommonRank.MiddleCommonRank_ClearRank(msg)
  208. end
  209. function LW_COMMERCE_GM_CLEAR_MAIL(fd, msg)
  210. if _G.is_middle ~= true then return end
  211. print("[LW_COMMERCE_GM_CLEAR_MAIL] GM清理排行榜邮件个人发送命令")
  212. MiddleCommonRank.MiddleCommonRank_GMClearMail(msg)
  213. end
  214. -- 中心服请求活动数据
  215. function WL_COMMERCE_GET_ACT_INFO(fd, msg)
  216. print("[WL_COMMERCE_GET_ACT_INFO] 收到中心服请求活动开放时间数据")
  217. CommerceMiddle.CommerceMiddle_GetActInfo_WL(msg)
  218. end
  219. -- 普通服发送活动时间数据
  220. function LW_COMMERCE_GET_ACT_INFO(fd, msg)
  221. if _G.is_middle ~= true then return end
  222. CommerceMiddle.CommerceMiddle_GetActInfo_LW(msg)
  223. end
  224. -- 普通服请求活动时间
  225. function LW_COMMERCE_ACT_GET_OPENTIME(fd, msg)
  226. if _G.is_middle ~= true then return end
  227. CommerceMiddle.CommerceMiddle_GetActOpenTime_LW(msg)
  228. end
  229. function WL_COMMERCE_ACT_GET_OPENTIME(fd, msg)
  230. CommerceMiddle.CommerceMiddle_GetActOpenTime_WL(msg)
  231. end
  232. -------------------- 跨服商业活动结束 ---------------------------
  233. ----------------------- 封禁功能开始 ---------------------------
  234. -- 向跨服查询
  235. function LW_QUERY_BAN_INFO(fd, msg)
  236. if _G.is_middle ~= true then return end
  237. BanLogic.CS_Get_BanData(msg)
  238. end
  239. -- 跨服回应查询
  240. function WL_QUERY_BAN_INFO(fd, msg)
  241. BanLogic.NS_Init_BanData(msg.banList)
  242. end
  243. -- 通知跨服更新
  244. function LW_UPDATE_BAN_INFO(fd, msg)
  245. if _G.is_middle ~= true then return end
  246. BanLogic.CS_Update_BanData(msg.banStr)
  247. end
  248. -- 跨服广播更新的封禁数据
  249. function WL_UPDATE_BAN_INFO(fd, msg)
  250. BanLogic.NS_Update_BanData(msg.banStr)
  251. end
  252. ----------------------- 封禁功能结束 ---------------------------
  253. -------------------- 天梯赛开始 ---------------------------
  254. -- 请求参加天梯赛(普通->中心)
  255. -- function LW_JJC_NEWLADDER_JOINLADDER_O2C(fd, msg)
  256. -- if _G.is_middle ~= true then return end
  257. -- MiddleConnect.LW_JJC_NEWLADDER_JOINLADDER_O2C(fd, msg)
  258. -- end
  259. -- -- 请求参加天梯赛(中心->战区数据服)
  260. -- function WL_JJC_NEWLADDER_JOINLADDER_C2D(fd, msg)
  261. -- JjcNewLadderMidder.WL_JJC_NEWLADDER_JOINLADDER_C2D(fd, msg)
  262. -- end
  263. -- -- 请求参加天梯赛(数据->中心)
  264. -- function LW_JJC_NEWLADDER_JOINLADDER_D2C(fd, msg)
  265. -- if _G.is_middle ~= true then return end
  266. -- MiddleConnect.LW_JJC_NEWLADDER_JOINLADDER_D2C(fd, msg)
  267. -- end
  268. -- -- 请求参加天梯赛(中心->普通)
  269. -- function WL_JJC_NEWLADDER_JOINLADDER_C2O(fd, msg)
  270. -- JjcNewLadderMidder.WL_JJC_NEWLADDER_JOINLADDER_C2O(fd, msg)
  271. -- end
  272. -- -- 请求天梯赛排行榜数据(普通->中心)
  273. -- function LW_JJC_NEWLADDER_QUERY_RANK_O2C(fd, msg)
  274. -- if _G.is_middle ~= true then return end
  275. -- end
  276. -- -- 请求天梯赛排行榜数据(中心->战区数据服)
  277. -- function WL_JJC_NEWLADDER_QUERY_RANK_C2D(fd, msg)
  278. -- end
  279. -- -- 请求天梯赛排行榜数据(数据服->中心)
  280. -- function LW_JJC_NEWLADDER_QUERY_RANK_D2C(fd, msg)
  281. -- if _G.is_middle ~= true then return end
  282. -- end
  283. -- -- 请求天梯赛排行榜数据(中心->普通)
  284. -- function WL_JJC_NEWLADDER_QUERY_RANK_C2O(fd, msg)
  285. -- end
  286. -- -- 查询是否能够战斗(普通->中心)
  287. -- function LW_JJC_NEWLADDER_QUERY_CAN_FIGHT_O2C(fd, msg)
  288. -- if _G.is_middle ~= true then return end
  289. -- end
  290. -- -- 查询是否能够战斗(中心->战区数据服)
  291. -- function WL_JJC_NEWLADDER_QUERY_CAN_FIGHT_C2D(fd, msg)
  292. -- end
  293. -- -- 查询是否能够战斗(数据服->中心)
  294. -- function LW_JJC_NEWLADDER_QUERY_CAN_FIGHT_D2C(fd, msg)
  295. -- if _G.is_middle ~= true then return end
  296. -- end
  297. -- -- 查询是否能够战斗(中心->普通)
  298. -- function WL_JJC_NEWLADDER_QUERY_CAN_FIGHT_C2O(fd, msg)
  299. -- end
  300. -- -- 战斗结束(普通->中心)
  301. -- function LW_JJC_NEWLADDER_CANCEL_FIGHT_END_O2C(fd, msg)
  302. -- if _G.is_middle ~= true then return end
  303. -- end
  304. -- -- 战斗结束(中心->战区数据服)
  305. -- function WL_JJC_NEWLADDER_CANCEL_FIGHT_END_C2D(fd, msg)
  306. -- end
  307. -- -- 战斗结束(数据服->中心)
  308. -- function LW_JJC_NEWLADDER_CANCEL_FIGHT_END_D2C(fd, msg)
  309. -- if _G.is_middle ~= true then return end
  310. -- end
  311. -- -- 战斗结束
  312. -- function WL_JJC_NEWLADDER_CANCEL_FIGHT_END_C2O(fd, msg)
  313. -- end
  314. -- -- 发送战败邮件(数据->中心)
  315. -- function LW_JJC_NEWLADDER_SEND_MAIL_D2C(fd, msg)
  316. -- if _G.is_middle ~= true then return end
  317. -- end
  318. -- -- 发送战败邮件(中心->目标)
  319. -- function WL_JJC_NEWLADDER_SEND_MAIL_C2O(fd, msg)
  320. -- end
  321. -- -- 请求刷新对战列表(普通->中心)
  322. -- function LW_JJC_NEWLADDER_REFRESH_O2C(fd, msg)
  323. -- if _G.is_middle ~= true then return end
  324. -- MiddleConnect.LW_JJC_NEWLADDER_REFRESH_O2C(msg)
  325. -- end
  326. -- -- 请求刷新对战列表(中心->数据)
  327. -- function WL_JJC_NEWLADDER_REFRESH_C2D(fd, msg)
  328. -- JjcNewLadderMidder.WL_JJC_NEWLADDER_REFRESH_C2D(fd, msg)
  329. -- end
  330. -- -- 请求刷新对战列表(数据->中心)
  331. -- function LW_JJC_NEWLADDER_REFRESH_D2C(fd, msg)
  332. -- if _G.is_middle ~= true then return end
  333. -- MiddleConnect.LW_JJC_NEWLADDER_REFRESH_D2C(msg)
  334. -- end
  335. -- -- 请求刷新对战列表(中心-普通)
  336. -- function WL_JJC_NEWLADDER_REFRESH_C2O(fd, msg)
  337. -- JjcNewLadderMidder.WL_JJC_NEWLADDER_REFRESH_C2O(fd, msg)
  338. -- end
  339. -------------------- 天梯赛结束 ---------------------------
  340. -------------------- 返利开始 ---------------------------
  341. -- 向跨服查询该角色能否返利
  342. function LW_REBATE_QUERY(fd, msg)
  343. if _G.is_middle ~= true then return end
  344. RebateLogic.CS_RebateQuery(msg)
  345. end
  346. function WL_REBATE_OK(fd, msg)
  347. RebateLogic.NS_Rebate_OK(msg.channelId, msg.serverId, msg.account)
  348. end
  349. ---------------------返利结束 ---------------------------