import Vue from "vue"; import Vuex from "vuex"; Vue.use(Vuex); let lifeData = {}; try { // 尝试获取本地是否存在lifeData变量,第一次启动APP时是不存在的 lifeData = uni.getStorageSync("lifeData"); } catch (e) {} // 需要永久存储,且下次APP启动需要取出的,在state中的变量名 let saveStateKeys = [ "vuex_user", "vuex_token", "vuex_userType", "vuex_msgUser", ]; // 保存变量到本地存储中 const saveLifeData = function (key, value) { // 判断变量名是否在需要存储的数组中 if (saveStateKeys.indexOf(key) != -1) { // 获取本地存储的lifeData对象,将变量添加到对象中 let tmp = uni.getStorageSync("lifeData"); // 第一次打开APP,不存在lifeData变量,故放一个{}空对象 tmp = tmp ? tmp : {}; tmp[key] = value; // 执行这一步后,所有需要存储的变量,都挂载在本地的lifeData对象中 uni.setStorageSync("lifeData", tmp); } }; const store = new Vuex.Store({ state: { vuex_teacherInfo: lifeData.vuex_teacherInfo ? lifeData.vuex_teacherInfo : "", // 如果上面从本地获取的lifeData对象下有对应的属性,就赋值给state中对应的变量 // 加上vuex_前缀,是防止变量名冲突,也让人一目了然 vuex_userType: lifeData.vuex_userType ? lifeData.vuex_userType : 0, // 0:学生 1:教师 vuex_user: lifeData.vuex_user ? lifeData.vuex_user : "", vuex_token: lifeData.vuex_token ? lifeData.vuex_token : "", // 如果vuex_version无需保存到本地永久存储,无需lifeData.vuex_version方式 vuex_version: "1.0.0", // 当前聊天窗口消息列表(数组 vuex_msgList: [], // 最近联系人/会话列表 vuex_userMsgList: [], // 当前聊天用户对象 vuex_msgUser: lifeData.vuex_msgUser ? lifeData.vuex_msgUser : {}, // 消息窗口滚动位置 vuex_msgScrollTop: 0, // 自定义tabbar数据 vuex_iPhone: lifeData.vuex_iPhone ? lifeData.vuex_iPhone : false, // tabbar相关配置 vuex_tabbar_config: { activeColor: "#3CB5FB", inactiveColor: "#666666", }, vuex_tabbar: [ { pagePath: "pages/home/index/index", iconPath: "/static/common/tabbar/index.png", selectedIconPath: "/static/common/tabbar/selectindex.png", text: "首页", }, { pagePath: "pages/message/msgList/msgList", iconPath: "/static/common/tabbar/message.png", selectedIconPath: "/static/common/tabbar/selectmessage.png", // count: 2, //提示数量 // 初始化红点:基于未读计数 isDot: lifeData.vuex_msgList ? true : false, // 显示红色小点 text: "消息", }, // { // pagePath: "/pages/main/index/index", // iconPath: "/static/common/tabbar/findFriends.png", // selectedIconPath: "/static/common/tabbar/selectFindFridend.png", // text: "找校友" // }, // { // pagePath: "/pages/AlumniCircle/alumnus/alumnus", // iconPath: "/static/common/tabbar/AlumniCircle.png", // selectedIconPath: "/static/common/tabbar/selectAlumniCircle.png", // text: "校友圈" // }, // { // pagePath: "/pages/my/my/my", // iconPath: "/static/common/tabbar/my.png", // selectedIconPath: "/static/common/tabbar/selectmy.png", // text: "我的" // } ], vuex_education: [], vuex_schoolName: "", }, mutations: { $uStore(state, payload) { // 判断是否多层级调用,state中为对象存在的情况,诸如user.info.score = 1 let nameArr = payload.name.split("."); let saveKey = ""; let len = nameArr.length; if (len >= 2) { let obj = state[nameArr[0]]; for (let i = 1; i < len - 1; i++) { obj = obj[nameArr[i]]; } obj[nameArr[len - 1]] = payload.value; saveKey = nameArr[0]; } else { // 单层级变量,在state就是一个普通变量的情况 state[payload.name] = payload.value; saveKey = payload.name; } // 保存变量到本地,见顶部函数定义 saveLifeData(saveKey, state[saveKey]); }, // ===== 消息中心:列表、当前聊天、消息推送等 ===== // 设置会话列表(服务端返回) set_UserMsgList(state, list) { state.vuex_userMsgList = Array.isArray(list) ? list.slice() : []; if (state.vuex_msgUser && state.vuex_msgUser.friendId) { state.vuex_userMsgList = state.vuex_userMsgList.map((item) => { if (item && item.friendId === state.vuex_msgUser.friendId) { return { ...item, unReadCount: 0 }; } return item; }); } }, // 设置当前聊天用户 set_MsgUser(state, user) { state.vuex_msgUser = user || null; if (state.vuex_msgUser && state.vuex_msgUser.friendId) { state.vuex_userMsgList = (state.vuex_userMsgList || []).map((item) => { if (item && item.friendId === state.vuex_msgUser.friendId) { return { ...item, unReadCount: 0 }; } return item; }); } }, // 现在没有id,先覆盖整个list push_MsgList(state, list) { state.vuex_msgList = list || []; }, // 推送一条新消息(去重) push_Msg(state, msg) { // 注:现在的消息没有id,无法去重,暂时用push_MsgList if (!msg || !msg.id) return; const exists = (state.vuex_msgList || []).some( (item) => item && item.id === msg.id ); if (!exists) { state.vuex_msgList.push(msg); } }, // 插入历史消息到头部 unshift_Msg(state, msg) { if (!msg) return; state.vuex_msgList.unshift(msg); }, // 更新置顶状态(本地) update_TopState(state, { friendId, isTop }) { state.vuex_userMsgList = (state.vuex_userMsgList || []).map((item) => { if (item && item.friendId === friendId) { return { ...item, isTop: !!isTop }; } return item; }); }, // 更新消息窗口滚动位置 set_MsgScrollTop(state, top) { state.vuex_msgScrollTop = Number(top) || 0; }, // 清空消息相关状态(登出/切换账号) clear_MessageState(state) { state.vuex_msgList = []; state.vuex_userMsgList = []; state.vuex_msgUser = null; state.vuex_msgScrollTop = 0; }, // 统一登出清理:清除 token 与用户数据,并同步到本地存储 // 注意:仅清理与登录态相关的关键字段,避免影响其他持久化数据 logout(state) { // 清除登录令牌 state.vuex_token = ""; state.vuex_teacherInfo = ""; state.vuex_user = ""; // 清理消息相关状态 state.vuex_msgList = []; state.vuex_userMsgList = []; state.vuex_msgUser = null; state.vuex_msgScrollTop = 0; // 同步更新本地持久化 saveLifeData("vuex_token", state.vuex_token); saveLifeData("vuex_teacherInfo", state.vuex_teacherInfo); saveLifeData("vuex_user", state.vuex_user); }, }, actions: { // 获取聊天列表(最近联系人) async getUserlist({ commit, state }) { // 在 Vuex action 中没有组件 this,上下文不包含 $u // 通过 Vue.prototype.$u 使用 uView 的 http 实例 return Vue.prototype.$u.api.GetDialogueListApi().then((res) => { const list = (res && res.data.item1 ? res.data.item1 : []).map( (item) => { const unReadCount = state.vuex_msgUser && state.vuex_msgUser.friendId === item.friendId ? 0 : item.unReadCount || 0; return { ...item, // avatar: item.avatar, unReadCount, }; } ); commit("set_UserMsgList", list); return list; }); }, // 设置当前聊天用户 setMsgUser({ commit, dispatch }, user) { console.log("setMsgUser执行了", user); commit("set_MsgUser", user); // 刷新列表,清零未读 dispatch("getUserlist"); }, // 获取聊天记录(私聊) async fetchChatRecord( { commit, state }, { userId, friendId, chatType = 0, PageIndex = 1, PageSize = 20 } ) { const params = { userId, friendId, PageIndex, PageSize }; Vue.prototype.$u.api.GetChatHistoryDataApi(params).then((res) => { const list = res && res.data ? res.data : []; // 将最新消息插入到消息列表尾部(或头部) list.forEach((msg) => commit("push_Msg", msg)); }); }, // 设置消息置顶(服务端 + 本地) async setTopMsgUser({ commit, dispatch }, user) { if (!user || !user.friendId) return; if (user.isTop) { return; } else { Vue.prototype.$u.api .OverheadOneDialogueApi({ dialogueManagementId: user.friendId }) .then((res) => { commit("update_TopState", { friendId: user.friendId, isTop: true }); dispatch("getUserlist"); }); } }, // 统一入口:打开或创建会话 // 使用位置:所有需要进入聊天的入口调用该方法,避免各页面重复逻辑 // 1) 获取最新会话列表 // 2) 查找是否存在 friendId 对应的会话 // 3) 有则设置当前会话并(可选)跳转;无则创建,成功后递归重试 async openOrCreateDialogue({ commit, state, dispatch }, user) { const { friendId, friendName, avatar, chatType = 0 } = user || {}; const attempt = user && typeof user.attempt === "number" ? user.attempt : 1; if (!friendId) return Promise.reject(new Error("缺少 friendId")); // 第一步:获取列表(复用现有 action,保证 state 同步更新) const list = await dispatch("getUserlist"); // 第二步:查找是否存在该会话(兼容后端字段 friendId/receiverId) const target = (list || []).find( (i) => i && (i.receiverId === friendId || i.friendId === friendId) ); if (target) { commit("set_MsgUser", target); // 跳转到对话页,参数按需调整 uni.navigateTo({ url: `/pages/chat/index`, }); return target; } // 第二次调用时,无论成功与否均在第三步(创建)之前结束 if (attempt >= 2) { return false; } // 第三步:不存在则创建,成功后重试本流程 const res = await Vue.prototype.$u.api.AddDialogueApi({ receiverId: friendId, onlineConsultationType: 0, // 0:招生在线;1:迎新在线(可按业务传入) }); if (res && res.succeed === true) { // 创建成功后,重新执行流程(再次获取列表并进入会话) return dispatch("openOrCreateDialogue", { friendId, friendName, avatar, chatType, attempt: attempt + 1, }); } return Promise.reject(new Error(res?.error || "创建会话失败")); }, }, }); export default store;