import http from '../api/httpRequest.js' import {TERMINAL_TYPE} from "../api/enums.js" export default { state: { friends: [], activeFriend: null, timer: null }, mutations: { setFriends(state, friends) { friends.forEach((f)=>{ f.online = false; f.onlineWeb = false; f.onlineApp = false; }) state.friends = friends; }, updateFriend(state,friend){ state.friends.forEach((f,index)=>{ if(f.id==friend.id){ // 拷贝属性 let online = state.friends[index].online; Object.assign(state.friends[index], friend); state.friends[index].online =online; } }) }, activeFriend(state, idx) { state.activeFriend = state.friends[idx]; }, removeFriend(state, idx) { if (state.friends[idx] == state.activeFriend) { state.activeFriend = null; } state.friends.splice(idx, 1); }, addFriend(state, friend) { state.friends.push(friend); }, refreshOnlineStatus(state){ let userIds = []; if(state.friends.length ==0){ return; } state.friends.forEach((f)=>{userIds.push(f.id)}); http({ url: '/user/terminal/online', method: 'get', params: {userIds: userIds.join(',')} }).then((onlineTerminals) => { this.commit("setOnlineStatus",onlineTerminals); }) // 30s后重新拉取 state.timer && clearTimeout(state.timer); state.timer = setTimeout(()=>{ this.commit("refreshOnlineStatus"); },30000) }, setOnlineStatus(state,onlineTerminals){ state.friends.forEach((f)=>{ let userTerminal = onlineTerminals.find((o)=> f.id==o.userId); if(userTerminal){ f.online = true; f.onlineWeb = userTerminal.terminals.indexOf(TERMINAL_TYPE.WEB)>=0 f.onlineApp = userTerminal.terminals.indexOf(TERMINAL_TYPE.APP)>=0 }else{ f.online = false; f.onlineWeb = false; f.onlineApp = false; } }); // 在线的在前面 state.friends.sort((f1,f2)=>{ if(f1.online&&!f2.online){ return -1; } if(f2.online&&!f1.online){ return 1; } return 0; }); }, clear(state) { state.timer && clearTimeout(state.timer); state.friends = []; state.timer = null; state.activeFriend = []; } }, actions: { loadFriend(context) { return new Promise((resolve, reject) => { http({ url: '/friend/list', method: 'GET' }).then((friends) => { context.commit("setFriends", friends); context.commit("refreshOnlineStatus"); resolve() }).catch((res) => { reject(); }) }); } } }