diff --git a/components/kl-nav-tab/index.vue b/components/kl-nav-tab/index.vue index fabd8c5..5a6960e 100644 --- a/components/kl-nav-tab/index.vue +++ b/components/kl-nav-tab/index.vue @@ -67,6 +67,7 @@ import { top } from '~/api/home/index' import type { ProjectDrawStatisticAppRespVO } from '~/api/home/type' import { Search } from '@element-plus/icons-vue' + import refreshToken from "~/utils/RefreshToken"; import useUserStore from '~/store/user' const userStore = useUserStore() const app = useNuxtApp() @@ -88,6 +89,8 @@ // 是否登录 const isLogin = computed(() => { + console.log('userStore.token', userStore); + return !!userStore.token }) diff --git a/store/user.ts b/store/user.ts index e017c46..5d68e8e 100644 --- a/store/user.ts +++ b/store/user.ts @@ -4,9 +4,9 @@ import { getUserInfo } from "~/api/common/index"; import type { AppMemberUserInfoRespVO } from "~/api/common/types"; import MQTTClient from "~/utils/mqttClient"; import { socialLoginByCode } from "~/api/pay"; -const app = useNuxtApp(); export default defineStore("useUserStore", { + state: () => ({ token: refreshToken.getToken().token || "", refreshToken: refreshToken.getToken().refreshToken || "", @@ -18,7 +18,7 @@ export default defineStore("useUserStore", { }), actions: { setToken(token: string) { - this.token = token; + this.token = token; }, setRefreshToken(refreshToken: string) { this.refreshToken = refreshToken; @@ -32,7 +32,7 @@ export default defineStore("useUserStore", { logout() { refreshToken.removeToken(); if (self === top) { - navigateTo("/index"); + navigateTo("/"); } else { window.top?.postMessage({ event: "logout" }, "*"); } @@ -49,19 +49,20 @@ export default defineStore("useUserStore", { // 建立连接mqtt async connectMqtt() { if (process.client) { - // this.mqttClient = new MQTTClient("wss://www.tuxixi.net/mqtt", { - // clientId: this.userInfoRes.id, - // }); - // await this.mqttClient.connect(); - // await this.mqttClient?.subscribe( - // `zbjk_message_single/${this.userInfoRes.id}` - // ); - // await this.mqttClient?.subscribe( - // `zbjk_message_kefu/${this.userInfoRes.id}` - // ); + this.mqttClient = new MQTTClient("wss://www.tuxixi.net/mqtt", { + clientId: this.userInfoRes.id, + }); + await this.mqttClient.connect(); + await this.mqttClient?.subscribe( + `zbjk_message_single/${this.userInfoRes.id}` + ); + await this.mqttClient?.subscribe( + `zbjk_message_kefu/${this.userInfoRes.id}` + ); } }, async getToken(row: any) { + const app = useNuxtApp(); try { // 验证state if (