108 lines
2.8 KiB
JavaScript
108 lines
2.8 KiB
JavaScript
// app.js
|
|
import config from './config';
|
|
import createBus from './utils/eventBus';
|
|
const API = require('./utils/api.js');
|
|
|
|
App({
|
|
onLaunch() {
|
|
const updateManager = wx.getUpdateManager();
|
|
|
|
updateManager.onCheckForUpdate((res) => {
|
|
// console.log(res.hasUpdate)
|
|
});
|
|
|
|
updateManager.onUpdateReady(() => {
|
|
wx.showModal({
|
|
title: '更新提示',
|
|
content: '新版本已经准备好，是否重启应用？',
|
|
success(res) {
|
|
if (res.confirm) {
|
|
updateManager.applyUpdate();
|
|
}
|
|
},
|
|
});
|
|
});
|
|
|
|
this.getUnreadNum();
|
|
this.connect();
|
|
},
|
|
|
|
onShow(options) {
|
|
// 每次回前台重新登录刷新用户信息；进行中的页面请求会复用同一次登录
|
|
this.signin();
|
|
},
|
|
|
|
/** 执行登录，返回可复用的 Promise（避免页面请求早于登录完成的竞态） */
|
|
signin() {
|
|
if (this._loginPromise) return this._loginPromise;
|
|
|
|
this._loginPromise = new Promise((resolve, reject) => {
|
|
wx.login({
|
|
success: (res) => {
|
|
if (!res.code) {
|
|
this._loginPromise = null;
|
|
return reject(new Error('wx.login 未返回 code'));
|
|
}
|
|
API.user.wxSignin({ code: res.code })
|
|
.then((data) => {
|
|
if (data.code == 0) {
|
|
this.globalData.user = data.data.user;
|
|
this.eventBus.emit('user-login', data.data.user);
|
|
resolve(data.data.user);
|
|
} else {
|
|
this._loginPromise = null;
|
|
reject(new Error(data.msg || '登录失败'));
|
|
}
|
|
})
|
|
.catch((err) => {
|
|
this._loginPromise = null;
|
|
reject(err);
|
|
});
|
|
},
|
|
fail: (err) => {
|
|
this._loginPromise = null;
|
|
reject(err);
|
|
}
|
|
});
|
|
});
|
|
|
|
return this._loginPromise;
|
|
},
|
|
|
|
/** 保证已登录：已有用户信息立即返回，否则等待登录完成 */
|
|
ensureLogin() {
|
|
if (this.globalData.user) return Promise.resolve(this.globalData.user);
|
|
return this.signin();
|
|
},
|
|
|
|
/** 全局事件总线 */
|
|
eventBus: createBus(),
|
|
|
|
/** 初始化WebSocket */
|
|
connect() {
|
|
const socket = null //connectSocket();
|
|
/*socket.onMessage((data) => {
|
|
data = JSON.parse(data);
|
|
if (data.type === 'message' && !data.data.message.read) this.setUnreadNum(this.globalData.unreadNum + 1);
|
|
});*/
|
|
this.globalData.socket = socket;
|
|
},
|
|
|
|
/** 获取未读消息数量 */
|
|
getUnreadNum() {
|
|
},
|
|
|
|
/** 设置未读消息数量 */
|
|
setUnreadNum(unreadNum) {
|
|
this.globalData.unreadNum = unreadNum;
|
|
this.eventBus.emit('unread-num-change', unreadNum);
|
|
},
|
|
|
|
|
|
globalData: {
|
|
user: null,
|
|
unreadNum: 0, // 未读消息数量
|
|
socket: null, // SocketTask 对象
|
|
},
|
|
});
|