Files
im-uniapp/App.vue
2025-07-12 12:42:01 +08:00

731 lines
24 KiB
Vue
Raw Blame History

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

<script>
import { mapGetters, mapActions } from "vuex";
import IMSDK, {
IMMethods,
MessageType,
SessionType,
} from "openim-uniapp-polyfill";
import config from "./common/config";
import { getDbDir, toastWithCallback } from "@/util/common.js";
import { conversationSort } from "@/util/imCommon";
import { PageEvents, UpdateMessageTypes } from "@/constant";
const openSdk = uni.requireNativePlugin('Tuoyun-OpenIMSDK');
const globalEvent = uni.requireNativePlugin('globalEvent');
export default {
onLaunch: function () {
console.log("App Launch");
console.log(openSdk);
this.setGlobalIMlistener();
this.tryLogin();
// #ifdef APP-PLUS
checkUpdate(); // 直接调用独立函数避免this问题
// #endif
// #ifdef H5
console.error(
`暂时不支持运行到 Web如果需要移动端的 Web 项目,参考 [H5 demo](https://github.com/openimsdk/openim-h5-demo)`
);
// #endif
// #ifdef MP-WEIXIN
console.error(`暂时不支持运行到小程序端`);
// #endif
// 集成cid全局获取和存储
// uni.getPushClientId({
// success: (res) => {
// console.log(res, 'app-Push-ID');
// if (res && res.cid) {
// uni.setStorageSync('cid', res.cid);
// }
// },
// fail: (err) => {
// console.log(err)
// }
// })
},
onShow: function () {
console.log("App Show");
IMSDK.asyncApi(IMSDK.IMMethods.SetAppBackgroundStatus, IMSDK.uuid(), false);
//#ifdef APP-PLUS
// var info = plus.push.getClientInfo()
// plus.push.addEventListener("click", function(msg) {
// console.log("click:" + JSON.stringify(msg));
// console.log(msg.payload);
// console.log(JSON.stringify(msg));
// }, false);
// // 监听在线消息事件
// plus.push.addEventListener("receive", function(msg) {
// //业务代码
// console.log("recevice:" + JSON.stringify(msg))
// }, false);
//#endif
},
onHide: function () {
console.log("App Hide");
IMSDK.asyncApi(IMSDK.IMMethods.SetAppBackgroundStatus, IMSDK.uuid(), true);
},
computed: {
...mapGetters([
"storeConversationList",
"storeCurrentConversation",
"storeCurrentUserID",
"storeSelfInfo",
"storeRecvFriendApplications",
"storeRecvGroupApplications",
"storeHistoryMessageList",
"storeIsSyncing",
"storeGroupList",
]),
},
methods: {
...mapActions("message", ["pushNewMessage", "updateOneMessage"]),
...mapActions("conversation", ["updateCurrentMemberInGroup"]),
...mapActions("contact", [
"updateFriendInfo",
"pushNewFriend",
"updateBlackInfo",
"pushNewBlack",
"pushNewGroup",
"updateGroupInfo",
"pushNewRecvFriendApplition",
"updateRecvFriendApplition",
"pushNewSentFriendApplition",
"updateSentFriendApplition",
"pushNewRecvGroupApplition",
"updateRecvGroupApplition",
"pushNewSentGroupApplition",
"updateSentGroupApplition",
]),
setGlobalIMlistener() {
console.log("setGlobalIMlistener");
// init
const kickHander = (message) => {
toastWithCallback(message, () => {
uni.removeStorage({
key: "IMToken",
});
uni.removeStorage({
key: "BusinessToken",
});
uni.$u.route("/pages/login/index");
});
};
IMSDK.subscribe(IMSDK.IMEvents.OnKickedOffline, (data) => {
kickHander("您的账号在其他设备登录,请重新登陆!");
});
IMSDK.subscribe(IMSDK.IMEvents.OnUserTokenExpired, (data) => {
kickHander("您的登录已过期,请重新登陆!");
});
IMSDK.subscribe(IMSDK.IMEvents.OnUserTokenInvalid, (data) => {
kickHander("您的登录已无效,请重新登陆!");
});
// sync
const syncStartHandler = ({ data }) => {
this.$store.commit("user/SET_IS_SYNCING", true);
this.$store.commit("user/SET_REINSTALL", data);
};
const syncProgressHandler = ({ data }) => {
this.$store.commit("user/SET_PROGRESS", data);
};
const syncFinishHandler = () => {
uni.hideLoading();
this.$store.dispatch("conversation/getConversationList");
this.$store.dispatch("contact/getFriendList");
this.$store.dispatch("contact/getGrouplist");
this.$store.dispatch("conversation/getUnReadCount");
this.$store.commit("user/SET_IS_SYNCING", false);
};
const syncFailedHandler = () => {
uni.hideLoading();
uni.$u.toast("同步消息失败");
this.$store.dispatch("conversation/getConversationList");
this.$store.dispatch("conversation/getUnReadCount");
this.$store.commit("user/SET_IS_SYNCING", false);
};
IMSDK.subscribe(IMSDK.IMEvents.OnSyncServerStart, syncStartHandler);
IMSDK.subscribe(IMSDK.IMEvents.OnSyncServerFinish, syncFinishHandler);
IMSDK.subscribe(IMSDK.IMEvents.OnSyncServerFailed, syncFailedHandler);
IMSDK.subscribe(IMSDK.IMEvents.OnSyncServerProgress, syncProgressHandler);
// self
const selfInfoUpdateHandler = ({ data }) => {
this.$store.commit("user/SET_SELF_INFO", {
...this.storeSelfInfo,
...data,
});
};
IMSDK.subscribe(IMSDK.IMEvents.OnSelfInfoUpdated, selfInfoUpdateHandler);
// message
const newMessagesHandler = ({ data }) => {
if (this.storeIsSyncing) {
return;
}
data.forEach(this.handleNewMessage);
};
IMSDK.subscribe(IMSDK.IMEvents.OnRecvNewMessages, newMessagesHandler);
// friend
const friendInfoChangeHandler = ({ data }) => {
uni.$emit(IMSDK.IMEvents.OnFriendInfoChanged, { data });
this.updateFriendInfo({
friendInfo: data,
});
};
const friendAddedHandler = ({ data }) => {
this.pushNewFriend(data);
};
const friendDeletedHander = ({ data }) => {
this.updateFriendInfo({
friendInfo: data,
isRemove: true,
});
};
IMSDK.subscribe(
IMSDK.IMEvents.OnFriendInfoChanged,
friendInfoChangeHandler
);
IMSDK.subscribe(IMSDK.IMEvents.OnFriendAdded, friendAddedHandler);
IMSDK.subscribe(IMSDK.IMEvents.OnFriendDeleted, friendDeletedHander);
// blacklist
const blackAddedHandler = ({ data }) => {
this.pushNewBlack(data);
};
const blackDeletedHandler = ({ data }) => {
this.updateBlackInfo({
blackInfo: data,
isRemove: true,
});
};
IMSDK.subscribe(IMSDK.IMEvents.OnBlackAdded, blackAddedHandler);
IMSDK.subscribe(IMSDK.IMEvents.OnBlackDeleted, blackDeletedHandler);
// group
const joinedGroupAddedHandler = ({ data }) => {
this.pushNewGroup(data);
};
const joinedGroupDeletedHandler = ({ data }) => {
this.updateGroupInfo({
groupInfo: data,
isRemove: true,
});
};
const groupInfoChangedHandler = ({ data }) => {
this.updateGroupInfo({
groupInfo: data,
});
};
const groupMemberInfoChangedHandler = ({ data }) => {
uni.$emit(IMSDK.IMEvents.OnGroupMemberInfoChanged, { data });
if (data.groupID === this.storeCurrentConversation?.groupID) {
this.updateCurrentMemberInGroup(data);
}
};
IMSDK.subscribe(
IMSDK.IMEvents.OnJoinedGroupAdded,
joinedGroupAddedHandler
);
IMSDK.subscribe(
IMSDK.IMEvents.OnJoinedGroupDeleted,
joinedGroupDeletedHandler
);
IMSDK.subscribe(
IMSDK.IMEvents.OnGroupInfoChanged,
groupInfoChangedHandler
);
IMSDK.subscribe(
IMSDK.IMEvents.OnGroupMemberInfoChanged,
groupMemberInfoChangedHandler
);
// application
const friendApplicationNumHandler = ({ data }) => {
const isRecv = data.toUserID === this.storeCurrentUserID;
if (isRecv) {
this.pushNewRecvFriendApplition(data);
} else {
this.pushNewSentFriendApplition(data);
}
};
const friendApplicationAccessHandler = ({ data }) => {
const isRecv = data.toUserID === this.storeCurrentUserID;
if (isRecv) {
this.updateRecvFriendApplition({
application: data,
});
} else {
this.updateSentFriendApplition({
application: data,
});
}
};
const groupApplicationNumHandler = ({ data }) => {
const isRecv = data.userID !== this.storeCurrentUserID;
if (isRecv) {
this.pushNewRecvGroupApplition(data);
} else {
this.pushNewSentGroupApplition(data);
}
};
const groupApplicationAccessHandler = ({ data }) => {
const isRecv = data.userID !== this.storeCurrentUserID;
if (isRecv) {
this.updateRecvGroupApplition({
application: data,
});
} else {
this.updateSentGroupApplition({
application: data,
});
}
};
IMSDK.subscribe(
IMSDK.IMEvents.OnFriendApplicationAdded,
friendApplicationNumHandler
);
IMSDK.subscribe(
IMSDK.IMEvents.OnFriendApplicationAccepted,
friendApplicationAccessHandler
);
IMSDK.subscribe(
IMSDK.IMEvents.OnFriendApplicationRejected,
friendApplicationAccessHandler
);
IMSDK.subscribe(
IMSDK.IMEvents.OnGroupApplicationAdded,
groupApplicationNumHandler
);
IMSDK.subscribe(
IMSDK.IMEvents.OnGroupApplicationAccepted,
groupApplicationAccessHandler
);
IMSDK.subscribe(
IMSDK.IMEvents.OnGroupApplicationRejected,
groupApplicationAccessHandler
);
// conversation
const totalUnreadCountChangedHandler = ({ data }) => {
if (this.storeIsSyncing) {
return;
}
this.$store.commit("conversation/SET_UNREAD_COUNT", data);
};
const newConversationHandler = ({ data }) => {
if (this.storeIsSyncing) {
return;
}
const result = [...data, ...this.storeConversationList];
this.$store.commit(
"conversation/SET_CONVERSATION_LIST",
conversationSort(result)
);
};
const conversationChangedHandler = ({ data }) => {
if (this.storeIsSyncing) {
return;
}
let filterArr = [];
console.log(data);
const chids = data.map((ch) => ch.conversationID);
filterArr = this.storeConversationList.filter(
(tc) => !chids.includes(tc.conversationID)
);
const idx = data.findIndex(
(c) =>
c.conversationID === this.storeCurrentConversation.conversationID
);
if (idx !== -1)
this.$store.commit(
"conversation/SET_CURRENT_CONVERSATION",
data[idx]
);
const result = [...data, ...filterArr];
this.$store.commit(
"conversation/SET_CONVERSATION_LIST",
conversationSort(result)
);
};
IMSDK.subscribe(
IMSDK.IMEvents.OnTotalUnreadMessageCountChanged,
totalUnreadCountChangedHandler
);
IMSDK.subscribe(IMSDK.IMEvents.OnNewConversation, newConversationHandler);
IMSDK.subscribe(
IMSDK.IMEvents.OnConversationChanged,
conversationChangedHandler
);
},
tryLogin() {
const initStore = () => {
this.$store.dispatch("user/getSelfInfo");
this.$store.dispatch("conversation/getConversationList");
this.$store.dispatch("conversation/getUnReadCount");
this.$store.dispatch("contact/getFriendList");
this.$store.dispatch("contact/getGrouplist");
this.$store.dispatch("contact/getBlacklist");
this.$store.dispatch("contact/getRecvFriendApplications");
this.$store.dispatch("contact/getSentFriendApplications");
this.$store.dispatch("contact/getRecvGroupApplications");
this.$store.dispatch("contact/getSentGroupApplications");
uni.switchTab({
url: "/pages/conversation/conversationList/index?isRedirect=true",
});
};
getDbDir()
.then(async (path) => {
const flag = await IMSDK.asyncApi(IMMethods.InitSDK, IMSDK.uuid(), {
systemType: "uni-app",
apiAddr: config.getApiUrl(), // SDK的API接口地址。如http://xxx:10002
wsAddr: config.getWsUrl(), // SDK的websocket地址。如 ws://xxx:10001
dataDir: path, // 数据存储路径
logLevel: 6,
logFilePath: path,
isLogStandardOutput: true,
isExternalExtensions: false,
});
if (!flag) {
plus.navigator.closeSplashscreen();
uni.$u.toast("初始化IMSDK失败");
return;
}
const status = await IMSDK.asyncApi(
IMSDK.IMMethods.GetLoginStatus,
IMSDK.uuid()
);
if (status === 3) {
initStore();
return;
}
const IMToken = uni.getStorageSync("IMToken");
const IMUserID = uni.getStorageSync("IMUserID");
if (IMToken && IMUserID) {
IMSDK.asyncApi(IMSDK.IMMethods.Login, IMSDK.uuid(), {
userID: IMUserID,
token: IMToken,
})
.then(initStore)
.catch((err) => {
console.log(err);
uni.removeStorage({
key: "IMToken",
});
uni.removeStorage({
key: "BusinessToken",
});
plus.navigator.closeSplashscreen();
});
} else {
plus.navigator.closeSplashscreen();
}
})
},
handleNewMessage(newServerMsg) {
if (this.inCurrentConversation(newServerMsg)) {
if (
newServerMsg.contentType !== MessageType.TypingMessage &&
newServerMsg.contentType !== MessageType.RevokeMessage
) {
newServerMsg.isAppend = true;
this.pushNewMessage(newServerMsg);
setTimeout(() => uni.$emit(PageEvents.ScrollToBottom, true));
uni.$u.debounce(this.markConversationAsRead, 2000);
}
}
},
inCurrentConversation(newServerMsg) {
switch (newServerMsg.sessionType) {
case SessionType.Single:
return (
newServerMsg.sendID === this.storeCurrentConversation.userID ||
(newServerMsg.sendID === this.storeCurrentUserID &&
newServerMsg.recvID === this.storeCurrentConversation.userID)
);
case SessionType.WorkingGroup:
return newServerMsg.groupID === this.storeCurrentConversation.groupID;
case SessionType.Notification:
return newServerMsg.sendID === this.storeCurrentConversation.userID;
default:
return false;
}
},
markConversationAsRead() {
IMSDK.asyncApi(
IMSDK.IMMethods.MarkConversationMessageAsRead,
IMSDK.uuid(),
this.storeCurrentConversation.conversationID
);
},
},
};
function checkUpdate(forceCheck = false) {
const localVersion = plus.runtime.version;
const localWgtVersion = uni.getStorageSync('wgtVersion') || localVersion;
uni.request({
url: 'http://47.117.71.33:11295/fadapp-update/version.json?t=' + Date.now(),
success: (res) => {
const remoteVersion = res.data.version;
const wgtUrl = res.data.wgtUrl;
// 取本地基座和本地wgt的最大版本
const currentVersion = compareVersion(localWgtVersion, localVersion) > 0 ? localWgtVersion : localVersion;
console.log('本地基座版本:', localVersion, '本地wgt版本:', localWgtVersion, '当前对比版本:', currentVersion, '远程版本:', remoteVersion);
if (compareVersion(remoteVersion, currentVersion) > 0) {
// 检查版本兼容性
if (!checkVersionCompatibility(remoteVersion, localVersion)) {
console.warn('版本不兼容,跳过更新');
uni.showModal({
title: '版本不兼容',
content: `新版本 ${remoteVersion} 与当前基座版本 ${localVersion} 不兼容,请通过应用商店更新完整版本。`,
showCancel: false,
confirmText: '确定'
});
return;
}
// 检查是否已忽略当前版本(除非强制检查)
const ignoredVersion = uni.getStorageSync('ignoredVersion');
if (!forceCheck && ignoredVersion === remoteVersion) {
console.log('用户已选择忽略此版本:', remoteVersion);
return;
}
uni.showModal({
title: '发现新版本',
content: `检测到新版本(${remoteVersion}),是否立即下载并更新?`,
confirmText: '立即更新',
cancelText: '暂不更新',
showCancel: true,
success: (modalRes) => {
if (modalRes.confirm) {
// 检查存储空间
checkStorageSpace().then(() => {
uni.showLoading({title: '正在下载更新包...'});
console.log('开始下载wgt包:', wgtUrl);
uni.downloadFile({
url: wgtUrl,
success: (downloadResult) => {
uni.hideLoading();
console.log('下载结果:', downloadResult);
if (downloadResult.statusCode === 200) {
console.log('开始安装wgt包:', downloadResult.tempFilePath);
// 检查文件是否存在
plus.io.resolveLocalFileSystemURL(downloadResult.tempFilePath, (entry) => {
console.log('文件存在,开始安装');
plus.runtime.install(downloadResult.tempFilePath, {force: true}, function() {
console.log('wgt包安装成功');
// 更新本地wgt版本号
uni.setStorageSync('wgtVersion', remoteVersion);
uni.showModal({
title: '更新完成',
content: '应用需要重启才能生效,是否立即重启?',
success: function (res) {
if (res.confirm) {
plus.runtime.restart();
}
}
});
}, function(e) {
console.error('wgt包安装失败:', e);
let errorMsg = '安装失败';
if (e && e.message) {
errorMsg += ': ' + e.message;
}
if (e && e.code) {
errorMsg += ' (错误代码: ' + e.code + ')';
}
uni.showModal({
title: '安装失败',
content: errorMsg + '\n\n可能的原因\n1. 版本不兼容\n2. 文件损坏\n3. 权限不足\n4. 存储空间不足',
showCancel: false,
confirmText: '确定'
});
});
}, (error) => {
console.error('文件不存在:', error);
uni.showModal({
title: '安装失败',
content: '下载的文件不存在或已损坏',
showCancel: false,
confirmText: '确定'
});
});
} else {
console.error('下载失败,状态码:', downloadResult.statusCode);
uni.showModal({
title: '下载失败',
content: `服务器返回错误,状态码: ${downloadResult.statusCode}`,
showCancel: false,
confirmText: '确定'
});
}
},
fail: (error) => {
uni.hideLoading();
console.error('下载失败:', error);
uni.showModal({
title: '下载失败',
content: '网络连接异常,请检查网络后重试',
showCancel: false,
confirmText: '确定'
});
}
});
}).catch((error) => {
console.error('存储空间检查失败:', error);
uni.showModal({
title: '存储空间不足',
content: '设备存储空间不足,无法下载更新包',
showCancel: false,
confirmText: '确定'
});
});
} else {
// 用户选择暂不更新,询问是否忽略此版本
uni.showModal({
title: '忽略更新',
content: `是否忽略版本 ${remoteVersion}?忽略后下次启动时将不再提示此版本更新。`,
confirmText: '忽略此版本',
cancelText: '下次提醒',
success: (ignoreRes) => {
if (ignoreRes.confirm) {
uni.setStorageSync('ignoredVersion', remoteVersion);
uni.showToast({title: '已忽略此版本更新'});
}
}
});
}
}
});
} else {
// uni.showToast({title: '当前已是最新版本'});
console.log('当前已是最新版本');
}
},
fail: (error) => {
console.error('检查更新失败:', error);
uni.showToast({title: '网络异常,请稍后重试'});
}
});
}
function extractVersionNum(str) {
// 匹配第一个出现的数字版本号
const match = str.match(/(\d+\.\d+(?:\.\d+)?)/);
return match ? match[1] : '0.0.0';
}
function compareVersion(v1, v2) {
v1 = extractVersionNum(v1).split('.').map(Number);
v2 = extractVersionNum(v2).split('.').map(Number);
for (let i = 0; i < Math.max(v1.length, v2.length); i++) {
const n1 = v1[i] || 0;
const n2 = v2[i] || 0;
if (n1 > n2) return 1;
if (n1 < n2) return -1;
}
return 0;
}
// 更新管理工具函数
function clearIgnoredVersion() {
uni.removeStorageSync('ignoredVersion');
console.log('已清除忽略的版本设置');
}
function getIgnoredVersion() {
return uni.getStorageSync('ignoredVersion');
}
function setIgnoredVersion(version) {
uni.setStorageSync('ignoredVersion', version);
console.log('已设置忽略版本:', version);
}
// 检查版本兼容性
function checkVersionCompatibility(wgtVersion, baseVersion) {
console.log('检查版本兼容性:', { wgtVersion, baseVersion });
// 提取主版本号进行比较
const wgtMajor = extractVersionNum(wgtVersion).split('.')[0];
const baseMajor = extractVersionNum(baseVersion).split('.')[0];
// 主版本号必须匹配
if (wgtMajor !== baseMajor) {
console.warn('主版本号不匹配:', { wgtMajor, baseMajor });
return false;
}
// 检查wgt版本是否高于基座版本
if (compareVersion(wgtVersion, baseVersion) <= 0) {
console.warn('wgt版本不高于基座版本');
return false;
}
return true;
}
// 检查存储空间
function checkStorageSpace() {
return new Promise((resolve, reject) => {
// #ifdef APP-PLUS
if (typeof plus !== 'undefined' && plus.io) {
plus.io.requestFileSystem(plus.io.PRIVATE_DOC, (fs) => {
fs.root.getDirectory('temp', { create: true }, (dir) => {
// 简单检查,实际项目中可能需要更复杂的空间检查
resolve(true);
}, (error) => {
console.error('检查存储空间失败:', error);
reject(error);
});
});
} else {
resolve(true);
}
// #endif
// #ifndef APP-PLUS
resolve(true);
// #endif
});
}
// 导出更新管理函数供其他页面使用
uni.$updateManager = {
checkUpdate: (forceCheck = false) => checkUpdate(forceCheck),
clearIgnoredVersion,
getIgnoredVersion,
setIgnoredVersion,
checkVersionCompatibility,
checkStorageSpace
};
</script>
<style lang="scss">
/*每个页面公共css */
@import "@/uni_modules/uview-ui/index.scss";
@import "@/styles/login.scss";
@import "@/styles/global.scss";
uni-page-body {
height: 100vh;
overflow: hidden;
}
.uni-tabbar .uni-tabbar__icon {
width: 28px !important;
height: 28px !important;
}
</style>