actions.ts 6.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241
  1. import { useRtcStore } from '/@/store/modules/rtc';
  2. import type { ChatContentType, UserInfoType } from '/@/store/modules/rtc';
  3. import Dialog from '/@/components/basic/dialog';
  4. import { useApp } from '/@/hooks/userApp';
  5. import consola from 'consola';
  6. import { useSocket } from '/@/hooks/userSocket';
  7. import { useRoom, SceneItemType } from '/@/hooks/useRoom';
  8. interface ActionDataType {
  9. type: string;
  10. data: any;
  11. members?: UserInfoType[];
  12. open?: boolean;
  13. user?: UserInfoType;
  14. userId?: string;
  15. words?: boolean;
  16. muted?: boolean;
  17. }
  18. export function handleActions({
  19. data,
  20. type,
  21. members,
  22. open,
  23. user,
  24. userId,
  25. words,
  26. muted,
  27. }: ActionDataType) {
  28. switch (type) {
  29. case 'user-init':
  30. handleUserInit();
  31. break;
  32. case 'danmumsg':
  33. handleDanMumSg(data);
  34. break;
  35. case 'changeScene':
  36. handleChangeScene(data);
  37. break;
  38. case 'user-join':
  39. handleUserJoin(members, user);
  40. break;
  41. case 'user-leave':
  42. handleUserLeave(user, members);
  43. break;
  44. case 'users-muted':
  45. handleUserMuted(userId, muted, members);
  46. break;
  47. case 'users-words':
  48. handleUserSetWords(userId, words, members);
  49. break;
  50. case 'leader-dismiss':
  51. handleLeaderDismiss(user, members);
  52. break;
  53. case 'user-paint':
  54. handleUserPaint(open);
  55. break;
  56. case 'tagclick':
  57. break;
  58. case 'tagclose':
  59. break;
  60. case 'tag-image-index':
  61. handleTagImageIndex(data);
  62. break;
  63. case 'ask-currentscene':
  64. handleAskCurrentscene(data);
  65. break;
  66. case 'error':
  67. Dialog.toast({ content: `房间未找到`, type: 'error' });
  68. default:
  69. break;
  70. }
  71. if (members?.length) {
  72. console.log('发烧的', members);
  73. }
  74. }
  75. //被动处理初始化
  76. async function handleUserInit() {
  77. const rtcStore = useRtcStore();
  78. if (rtcStore.role === 'leader') {
  79. const app = await useApp();
  80. app.Connect.follow.sync();
  81. // setTimeout(() => {
  82. // socket.value.emit("action", {
  83. // type: "leader-avatar",
  84. // data: { avatar: leaderAvatar.value },
  85. // });
  86. // if (tagclick.value && tagclick.value.type == "goodlist") {
  87. // socket.value.emit("action", {
  88. // type: "tagclick",
  89. // data: {
  90. // sid: tagclick.value.data.sid,
  91. // },
  92. // });
  93. // if (tagImageIndex.value != null) {
  94. // setTimeout(() => {
  95. // socket.value.emit("action", {
  96. // type: "tag-image-index",
  97. // data: {
  98. // index: tagImageIndex.value,
  99. // },
  100. // });
  101. // }, 200);
  102. // }
  103. // }
  104. // }, 200);
  105. }
  106. }
  107. // 被动处理弹幕
  108. function handleDanMumSg(data: ChatContentType) {
  109. const rtcStore = useRtcStore();
  110. if (data.role == 'leader') {
  111. data.Nickname = '主持人';
  112. }
  113. rtcStore.addToChatList(data);
  114. }
  115. // 其他用户进入
  116. function handleUserJoin(members?: UserInfoType[], user?: UserInfoType) {
  117. consola.info({
  118. tag: 'socket',
  119. message: '有人进来了',
  120. });
  121. const rtcStore = useRtcStore();
  122. // const { closeSocket } = useSocket();
  123. members && rtcStore.setMemberList(members);
  124. if (user) {
  125. let name = user.Nickname;
  126. if (user.Role === 'leader') {
  127. const { socket } = useSocket();
  128. name = '主持人';
  129. Dialog.toast({ content: `主持人进入房间` });
  130. socket.emit('action', { type: 'user-init' });
  131. }
  132. const data: ChatContentType = {
  133. role: user?.Role,
  134. mode: rtcStore.mode,
  135. Nickname: name,
  136. UserId: user?.UserId,
  137. text: '进入房间',
  138. };
  139. if (rtcStore.isLeader) {
  140. rtcStore.addToChatList(data);
  141. }
  142. }
  143. }
  144. // 其他用户开起画笔通知
  145. async function handleUserPaint(open: boolean | undefined) {
  146. const app = await useApp();
  147. const rtcStore = useRtcStore();
  148. if (!rtcStore.isLeader) {
  149. if (open) {
  150. console.log(open);
  151. app.Connect.paint.show({
  152. role: rtcStore.role,
  153. paint: false,
  154. });
  155. Dialog.toast({ content: `主持人开启画笔` });
  156. } else {
  157. Dialog.toast({ content: `主持人关闭画笔` });
  158. app.Connect.paint.hide();
  159. }
  160. }
  161. }
  162. const handleChangeScene = (data: SceneItemType) => {
  163. const { changeScene } = useRoom();
  164. changeScene(data);
  165. };
  166. //
  167. const handleAskCurrentscene = (data) => {
  168. console.log('data', data);
  169. };
  170. const handleTagImageIndex = (data) => {
  171. console.log('data', data);
  172. };
  173. const handleUserSetWords = (UserId?: string, words?: boolean, members?: UserInfoType[]) => {
  174. console.log('members', members);
  175. const rtcStore = useRtcStore();
  176. console.log('handleUserSetWords', UserId, words);
  177. UserId &&
  178. rtcStore.updateMemberDatabyId(UserId, {
  179. IsWords: words,
  180. });
  181. if (UserId == rtcStore.userId) {
  182. Dialog.toast({
  183. content: !words ? `主持人设置了禁言` : `主持人已解除禁言`,
  184. });
  185. }
  186. };
  187. const handleUserMuted = (UserId?: string, muted?: boolean, members?: UserInfoType[]) => {
  188. const rtcStore = useRtcStore();
  189. console.log('members', members);
  190. console.log('handleUserSetWords', UserId, muted);
  191. UserId &&
  192. rtcStore.updateMemberDatabyId(UserId, {
  193. IsMuted: muted,
  194. });
  195. if (UserId == rtcStore.userId) {
  196. rtcStore.setMute(!!muted);
  197. }
  198. };
  199. //被动处理用离开
  200. const handleUserLeave = (user: UserInfoType, members: UserInfoType[]) => {
  201. console.log('有人离开了', user.UserId);
  202. const rtcStore = useRtcStore();
  203. let name = user.Nickname;
  204. if (user.Role == 'leader') {
  205. name = '';
  206. Dialog.toast({ content: `主持人离开了房间` });
  207. }
  208. const data = {
  209. role: user.Role,
  210. mode: '',
  211. Nickname: name,
  212. UserId: user.UserId,
  213. text: '离开房间',
  214. };
  215. console.log('members', user, members);
  216. rtcStore.addToChatList(data);
  217. members && rtcStore.setMemberList(members);
  218. };
  219. //被动处理用离开
  220. const handleLeaderDismiss = (user, members) => {
  221. const rtcStore = useRtcStore();
  222. console.log('members', user, members);
  223. rtcStore.clearMemberList();
  224. };