friendStore.js 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091
  1. import http from '../common/request'
  2. import {TERMINAL_TYPE} from '../common/enums.js'
  3. export default {
  4. state: {
  5. friends: [],
  6. timer: null
  7. },
  8. mutations: {
  9. setFriends(state, friends) {
  10. state.friends = friends;
  11. },
  12. updateFriend(state, friend) {
  13. state.friends.forEach((f, index) => {
  14. if (!f.delete && f.id == friend.id) {
  15. // 拷贝属性
  16. let online = state.friends[index].online;
  17. Object.assign(state.friends[index], friend);
  18. state.friends[index].online = online;
  19. }
  20. })
  21. },
  22. removeFriend(state, id) {
  23. let friend = this.getters.findFriend(id);
  24. if(friend){
  25. friend.delete = true;
  26. }
  27. },
  28. addFriend(state, friend) {
  29. let f = this.getters.findFriend(friend.id);
  30. if(f){
  31. Object.assign(f, friend);
  32. f.delete = false;
  33. }else{
  34. state.friends.push(friend);
  35. }
  36. },
  37. setOnlineStatus(state, onlineUsers) {
  38. state.friends.forEach((f) => {
  39. let onlineUser = onlineUsers.find((o) => f.id == o.userId);
  40. f.online = !!onlineUser
  41. });
  42. },
  43. refreshOnlineStatus(state) {
  44. if (state.friends.length > 0) {
  45. let userIds = [];
  46. state.friends.forEach((f) => {
  47. userIds.push(f.id)
  48. });
  49. http({
  50. url: '/user/terminal/online?userIds=' + userIds.join(','),
  51. method: 'GET'
  52. }).then((onlineUsers) => {
  53. this.commit("setOnlineStatus", onlineUsers);
  54. })
  55. }
  56. // 30s后重新拉取
  57. clearTimeout(state.timer);
  58. state.timer = setTimeout(() => {
  59. this.commit("refreshOnlineStatus");
  60. }, 30000)
  61. },
  62. clear(state) {
  63. clearTimeout(state.timer);
  64. state.friends = [];
  65. state.timer = null;
  66. }
  67. },
  68. actions: {
  69. loadFriend(context) {
  70. return new Promise((resolve, reject) => {
  71. http({
  72. url: '/friend/list',
  73. method: 'GET'
  74. }).then((friends) => {
  75. context.commit("setFriends", friends);
  76. context.commit("refreshOnlineStatus");
  77. resolve()
  78. }).catch((res) => {
  79. reject();
  80. })
  81. });
  82. }
  83. },
  84. getters:{
  85. findFriend: (state) => (id) => {
  86. return state.friends.find((f)=>f.id==id);
  87. }
  88. }
  89. }