108 lines
3.4 KiB
TypeScript
108 lines
3.4 KiB
TypeScript
import { defineStore } from "pinia";
|
|
import refreshToken from "~/utils/RefreshToken";
|
|
import { getUserInfo } from "~/api/common/index";
|
|
import type { AppMemberUserInfoRespVO } from "~/api/common/types";
|
|
import MQTTClient from "~/utils/mqttClient";
|
|
import { socialLoginByCode } from "~/api/pay";
|
|
|
|
export default defineStore("useUserStore", {
|
|
|
|
state: () => ({
|
|
token: refreshToken.getToken().token || "",
|
|
refreshToken: refreshToken.getToken().refreshToken || "",
|
|
userId: refreshToken.getToken().userId || "",
|
|
userName: refreshToken.getToken().userName || "",
|
|
userInfoRes: (refreshToken.getToken().userInfo ||
|
|
{}) as AppMemberUserInfoRespVO,
|
|
mqttClient: null as MQTTClient | null,
|
|
}),
|
|
actions: {
|
|
setToken(token: string) {
|
|
this.token = token;
|
|
},
|
|
setRefreshToken(refreshToken: string) {
|
|
this.refreshToken = refreshToken;
|
|
},
|
|
setUserId(userId: string) {
|
|
this.userId = userId;
|
|
},
|
|
setUserName(userName: string) {
|
|
this.userName = userName;
|
|
},
|
|
logout() {
|
|
refreshToken.removeToken();
|
|
if (self === top) {
|
|
navigateTo("/");
|
|
} else {
|
|
window.top?.postMessage({ event: "logout" }, "*");
|
|
}
|
|
},
|
|
async getUserInfo() {
|
|
const res = await getUserInfo();
|
|
if (res.code === 0) {
|
|
this.userInfoRes = res.data;
|
|
refreshToken.setUserInfo(res.data);
|
|
// 建立连接mqtt
|
|
this.connectMqtt();
|
|
}
|
|
},
|
|
// 建立连接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}`
|
|
);
|
|
}
|
|
},
|
|
async getToken(row: any) {
|
|
const app = useNuxtApp();
|
|
try {
|
|
// 验证state
|
|
if (
|
|
localStorage.getItem("wechat_login_state") !== row.state &&
|
|
localStorage.getItem("qq_login_state") !== row.state
|
|
) {
|
|
ElMessage.error("验证失败,请重新登录");
|
|
return;
|
|
}
|
|
|
|
const res = await socialLoginByCode({
|
|
code: row.code,
|
|
state: row.state,
|
|
type: Number(row.type), // type: 32-微信开放平台 35-腾讯QQ
|
|
});
|
|
|
|
const { code, data } = res;
|
|
if (code === 0 && data.openid) {
|
|
// 打开登录界面
|
|
if (!data.accessToken) {
|
|
ElMessage.error("因你未绑定手机号，请先绑定手机号");
|
|
app.$openLogin("verify", row.code, row.type, row.state);
|
|
} else {
|
|
refreshToken.setToken(data.accessToken, data.refreshToken);
|
|
refreshToken.setUserId(data.userId.toString());
|
|
// refreshToken.setUserName(loginForm.mobile)
|
|
this.setToken(data.accessToken);
|
|
this.setUserId(data.userId.toString());
|
|
// userStore.setUserName(loginForm.mobile)
|
|
this.setRefreshToken(data.refreshToken);
|
|
// 获取信息
|
|
await this.getUserInfo();
|
|
}
|
|
} else {
|
|
console.error("获取token失败:", res.msg);
|
|
}
|
|
} catch (error) {
|
|
console.error("getToken error:", error);
|
|
}
|
|
},
|
|
},
|
|
});
|