handler.go 7.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192
  1. package message
  2. import (
  3. "bet24.com/log"
  4. "strings"
  5. )
  6. // 消息分发处理器
  7. func MessageHandler(userId int, msg, data string) string {
  8. switch msg {
  9. case "loginAudioRoomServer": // 登录服务器
  10. return loginAudioRoomServer(userId, data)
  11. case "logoutAudioRoomServer": // 退出服务器
  12. return logoutAudioRoomServer(userId, data)
  13. case "getAudioRoomConfig": // 获取房间配置
  14. return getAudioRoomConfig(userId, data)
  15. case "getAudioRoom": // 获取房间信息
  16. return getAudioRoom(userId, data)
  17. case "getAudioRoomHotInfo": // 获取房间热数据
  18. return getAudioRoomHotInfo(userId, data)
  19. case "isEnterAudioRoom": // 是否允许进入房间
  20. return isEnterAudioRoom(userId, data)
  21. case "enterAudioRoom": // 进入房间
  22. return enterAudioRoom(userId, data)
  23. case "exitAudioRoom": // 退出房间
  24. return exitAudioRoom(userId, data)
  25. case "createAudioRoom": // 创建房间
  26. return createAudioRoom(userId, data)
  27. case "updateAudioRoom": // 修改房间
  28. return updateAudioRoom(userId, data)
  29. case "getAudioRoomOnlineRoom": //获取用户在线房间
  30. return getAudioRoomOnlineRoom(userId, data)
  31. case "getAudioRoomExploreList": // 获取探索列表
  32. return getAudioRoomExploreList(userId, data)
  33. case "getAudioRoomJoinList": // 获取加入房间列表
  34. return getAudioRoomJoinList(userId, data)
  35. case "getAudioRoomAttentionList": // 获取关注房间列表
  36. return getAudioRoomAttentionList(userId, data)
  37. case "getAudioRoomBrowseList": // 获取浏览房间列表
  38. return getAudioRoomBrowseList(userId, data)
  39. case "addAudioRoomJoin": // 加入
  40. return addAudioRoomJoin(userId, data)
  41. case "delAudioRoomJoin": // 取消加入
  42. return delAudioRoomJoin(userId, data)
  43. case "addAudioRoomAttention": // 关注
  44. return addAudioRoomAttention(userId, data)
  45. case "delAudioRoomAttention": // 取消关注
  46. return delAudioRoomAttention(userId, data)
  47. case "AudioRoomInviteJoin": // 发出成员邀请
  48. return audioRoomInviteJoin(userId, data)
  49. case "AudioRoomAcceptJoin": // 接受成员邀请
  50. return audioRoomAcceptJoin(userId, data)
  51. case "getAudioRoomOnlineUsers": // 获取在线用户成员列表
  52. return getAudioRoomOnlineUsers(userId, data)
  53. case "AudioRoomSearchUser": // 查询房间在线用户信息
  54. return audioRoomSearchUser(userId, data)
  55. case "getAudioRoomMembers": // 获取成员列表
  56. return getAudioRoomMembers(userId, data)
  57. case "searchAudioRoom": // 搜索房间
  58. return searchAudioRoom(userId, data)
  59. case "recommendAudioRoomUser": // 推荐用户
  60. return recommendAudioRoomUser(userId, data)
  61. case "recommendAudioRoom": // 推荐房间
  62. return recommendAudioRoom(userId, data)
  63. case "AudioRoomListByTag": // 根据标签获取房间列表
  64. return audioRoomListByTag(userId, data)
  65. case "AudioRoomInviteOnTheMic": // 邀请上麦
  66. return audioRoomInviteOnTheMic(userId, data)
  67. case "AudioRoomKickMic": // 踢麦(强制下麦)
  68. return audioRoomKickMic(userId, data)
  69. case "AudioRoomSetMic": // 加解锁麦(status -1=上锁 0=解锁)
  70. return audioRoomSetMic(userId, data)
  71. case "getAudioRoomMicList": //获取麦列表
  72. return getAudioRoomMicList(userId, data)
  73. case "AudioRoomGetPermission": // 获取权限
  74. return audioRoomGetPermission(userId, data)
  75. case "AudioRoomSetPermission": // 设置权限
  76. return audioRoomSetPermission(userId, data)
  77. case "AudioRoomGetEnterCondition": // 获取进入房间条件
  78. return audioRoomGetEnterCondition(userId, data)
  79. case "AudioRoomSetEnterCondition": // 设置进入房间条件
  80. return audioRoomSetEnterCondition(userId, data)
  81. case "AudioRoomGetBlackList": // 获取黑名单用户列表
  82. return audioRoomGetBlackList(userId, data)
  83. case "AudioRoomAddBlack": // 设置黑名单
  84. return audioRoomAddBlack(userId, data)
  85. case "AudioRoomRemoveBlack": // 移除黑名单
  86. return audioRoomRemoveBlack(userId, data)
  87. case "AudioRoomGetOperateLog": // 操作记录
  88. return audioRoomGetOperateLog(userId, data)
  89. case "AudioRoomAddAdmin": // 添加管理员
  90. return audioRoomAddAdmin(userId, data)
  91. case "AudioRoomDelAdmin": // 取消管理员
  92. return audioRoomDelAdmin(userId, data)
  93. case "AudioRoomDelMember": // 删除会员
  94. return audioRoomDelMember(userId, data)
  95. case "AudioRoomIsAttention": // 是否关注过房间
  96. return audioRoomIsAttention(userId, data)
  97. case "AudioRoomGetRoomImg": //房间封面
  98. return getRoomImg(userId, data)
  99. case "getAudioRoomSysTask": // 获取系统任务
  100. return getAudioRoomSysTask(userId, data)
  101. case "getAudioRoomUpgradeConfig": // 获取升级配置
  102. return getAudioRoomUpgradeConfig(userId, data)
  103. case "getAudioRoomTaskList": // 获取房间任务列表
  104. return getAudioRoomTaskList(userId, data)
  105. case "getAudioRoomCollect": // 获取昨天收集信息
  106. return getAudioRoomCollect(userId, data)
  107. case "giftAudioRoomCollect": // 领取收集奖励
  108. return giftAudioRoomCollect(userId, data)
  109. case "getAudioRoomExtInfo": // 获取房间扩展信息
  110. return getAudioRoomExtInfo(userId, data)
  111. case "AudioRoomGetUserTaskList": // 获取用户房间任务列表
  112. return audioRoomGetUserTaskList(userId, data)
  113. case "AudioRoomShare": // 分享
  114. return audioRoomShare(userId, data)
  115. case "AudioRoomSendMessage": // 发送短信
  116. return audioRoomSendMessage(userId, data)
  117. case "AudioRoomGetUserRoomInfo": // 用户房间信息
  118. return audioRoomGetUserRoomInfo(userId, data)
  119. case "AudioRoomGetUserRoomTaskStat": // 获取用户任务统计
  120. return audioRoomGetUserRoomTaskStat(userId, data)
  121. case "AudioRoomStartGame": // 开始游戏
  122. return audioRoomStartGame(userId, data)
  123. case "AudioRoomSetScreenLock": // 设置屏幕锁
  124. return audioRoomSetScreenLock(userId, data)
  125. case "AudioRoomIsBannedSpeak": // 是否禁止发言
  126. return audioRoomIsBannedSpeak(userId, data)
  127. case "AudioRoomGetGameRoomInfo":
  128. return audioRoomGetGameRoomInfo(userId, data)
  129. case "AudioRoomCreateGameRoom": // 创建游戏房间
  130. return audioRoomCreateGameRoom(userId, data)
  131. case "AudioRoomCloseGameRoom": // 关闭游戏房间
  132. return audioRoomCloseGameRoom(userId, data)
  133. case "AudioRoomGetIncomeInfo": // 收益信息
  134. return audioRoomGetIncomeInfo(userId, data)
  135. case "NotifyRoom": // 通知房间
  136. return notifyRoom(userId, data)
  137. case "updateRoomImg": // 修改房间封面
  138. return updateRoomImg(userId, data)
  139. case "AudioRoomApplyOnMic": // 申请上麦
  140. return audioRoomApplyOnMic(userId, data)
  141. case "AudioRoomCancelApplyOnMic": // 取消申请上麦
  142. return audioRoomCancelApplyOnMic(userId, data)
  143. case "AudioRoomDealApplyOnMic": // 处理申请上麦(1=同意 2=拒绝)
  144. return audioRoomDealApplyOnMic(userId, data)
  145. default:
  146. // 上麦
  147. if strings.Contains(msg, "AudioRoomOnTheMic") {
  148. return audioRoomOnTheMic(userId, data)
  149. }
  150. // 发送礼物
  151. if strings.Contains(msg, "AudioRoomSendGiving") {
  152. return audioRoomSendGiving(userId, data)
  153. }
  154. // 游戏列表
  155. if strings.Contains(msg, "AudioRoomGetGameList") {
  156. return audioRoomGetGameList(userId, data)
  157. }
  158. // 游戏房间列表
  159. if strings.Contains(msg, "AudioRoomGetGameRoomList") {
  160. return audioRoomGetGameRoomList(userId, data)
  161. }
  162. // 上麦申请列表
  163. if strings.Contains(msg, "AudioRoomGetOnMicApplyList") {
  164. return audioRoomGetOnMicApplyList(userId, data)
  165. }
  166. // 收益记录
  167. if strings.Contains(msg, "AudioRoomGetIncomeLog") {
  168. return audioRoomGetIncomeLog(userId, data)
  169. }
  170. // 用户收益统计
  171. if strings.Contains(msg, "AudioRoomGetUserIncomeStat") {
  172. return audioRoomGetUserIncomeStat(userId, data)
  173. }
  174. // 游戏收益统计
  175. if strings.Contains(msg, "AudioRoomGetGameIncomeStat") {
  176. return audioRoomGetGameIncomeStat(userId, data)
  177. }
  178. }
  179. log.Error("message_main.MessageHandler unprocessed userId=%d msg=%s data=%s", userId, msg, data)
  180. return ""
  181. }