actions.ts 6.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240
  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. members && rtcStore.setMemberList(members);
  123. if (user) {
  124. let name = user.Nickname;
  125. if (user.Role === 'leader') {
  126. const { socket } = useSocket();
  127. name = '主持人';
  128. Dialog.toast({ content: `主持人进入房间` });
  129. socket.emit('action', { type: 'user-init' });
  130. }
  131. const data: ChatContentType = {
  132. role: user?.Role,
  133. mode: rtcStore.mode,
  134. Nickname: name,
  135. UserId: user?.UserId,
  136. text: '进入房间',
  137. };
  138. if (rtcStore.isLeader) {
  139. rtcStore.addToChatList(data);
  140. }
  141. }
  142. }
  143. // 其他用户开起画笔通知
  144. async function handleUserPaint(open: boolean | undefined) {
  145. const app = await useApp();
  146. const rtcStore = useRtcStore();
  147. if (!rtcStore.isLeader) {
  148. if (open) {
  149. console.log(open);
  150. app.Connect.paint.show({
  151. role: rtcStore.role,
  152. paint: false,
  153. });
  154. Dialog.toast({ content: `主持人开启画笔` });
  155. } else {
  156. Dialog.toast({ content: `主持人关闭画笔` });
  157. app.Connect.paint.hide();
  158. }
  159. }
  160. }
  161. const handleChangeScene = (data: SceneItemType) => {
  162. const { changeScene } = useRoom();
  163. changeScene(data);
  164. };
  165. //
  166. const handleAskCurrentscene = (data) => {
  167. console.log('data', data);
  168. };
  169. const handleTagImageIndex = (data) => {
  170. console.log('data', data);
  171. };
  172. const handleUserSetWords = (UserId?: string, words?: boolean, members?: UserInfoType[]) => {
  173. console.log('members', members);
  174. const rtcStore = useRtcStore();
  175. console.log('handleUserSetWords', UserId, words);
  176. UserId &&
  177. rtcStore.updateMemberDatabyId(UserId, {
  178. IsWords: words,
  179. });
  180. if (UserId == rtcStore.userId) {
  181. Dialog.toast({
  182. content: !words ? `主持人设置了禁言` : `主持人已解除禁言`,
  183. });
  184. }
  185. };
  186. const handleUserMuted = (UserId?: string, muted?: boolean, members?: UserInfoType[]) => {
  187. const rtcStore = useRtcStore();
  188. console.log('members', members);
  189. console.log('handleUserSetWords', UserId, muted);
  190. UserId &&
  191. rtcStore.updateMemberDatabyId(UserId, {
  192. IsMuted: muted,
  193. });
  194. if (UserId == rtcStore.userId) {
  195. rtcStore.setMute(!!muted);
  196. }
  197. };
  198. //被动处理用离开
  199. const handleUserLeave = (user: UserInfoType, members: UserInfoType[]) => {
  200. console.log('有人离开了', user);
  201. const rtcStore = useRtcStore();
  202. let name = user.Nickname;
  203. if (user.Role == 'leader') {
  204. name = '';
  205. Dialog.toast({ content: `主持人离开了房间` });
  206. }
  207. const data = {
  208. role: user.Role,
  209. mode: '',
  210. Nickname: name,
  211. UserId: user.UserId,
  212. text: '离开房间',
  213. };
  214. console.log('members', user, members);
  215. rtcStore.addToChatList(data);
  216. members && rtcStore.setMemberList(members);
  217. };
  218. //被动处理用离开
  219. const handleLeaderDismiss = (user, members) => {
  220. const rtcStore = useRtcStore();
  221. console.log('members', user, members);
  222. rtcStore.clearMemberList();
  223. };