992 lines
33 KiB
JavaScript
992 lines
33 KiB
JavaScript
// utils/chat-core.js — 全局 IM 连接、监听、重连、角标
|
||
import GoEasy from '../static/lib/goeasy-2.13.24.esm.min';
|
||
import { jianquanxian } from './imAuth/jianquanxian';
|
||
import { parseOrderCardText } from './group-chat.js';
|
||
import { persistGroupMeta, getFreshImUser, getImUserIdForRole, getLocalImUserId, getLocalImIdentity } from './im-user.js';
|
||
|
||
let _globalPrivateHandler = null;
|
||
let _globalGroupHandler = null;
|
||
let _globalConvHandler = null;
|
||
let _imLockDepth = 0;
|
||
let _loadConvTimer = null;
|
||
let _loadConvInFlight = false;
|
||
|
||
async function withImLock(fn) {
|
||
if (_imLockDepth > 0) {
|
||
return await fn();
|
||
}
|
||
_imLockDepth += 1;
|
||
try {
|
||
return await fn();
|
||
} finally {
|
||
_imLockDepth -= 1;
|
||
}
|
||
}
|
||
|
||
function initGlobalMessageSystem(app) {
|
||
app.updateUnreadCount = (count) => updateUnreadCount(app, count);
|
||
app.disconnectGoEasy = () => disconnectGoEasy(app);
|
||
app.ensureConnection = () => ensureConnection(app);
|
||
app.connectWithIdentity = (identityType, userId, isAutoRestore) =>
|
||
connectWithIdentity(app, identityType, userId, isAutoRestore);
|
||
app.connectForCurrentRole = () => connectForCurrentRole(app);
|
||
app.switchRoleAndReconnect = (newRole) => switchRoleAndReconnect(app, newRole);
|
||
app.toggleDoNotDisturb = (enabled) => toggleDoNotDisturb(app, enabled);
|
||
app.toggleNotificationMute = (enabled) => toggleNotificationMute(app, enabled);
|
||
app.closeNotification = () => closeNotification(app);
|
||
app.loadConversations = () => loadConversations(app);
|
||
app.updateCurrentPageState = () => updateCurrentPageState(app);
|
||
app.getSavedConnection = () => getSavedConnection(app);
|
||
app.clearSavedConnection = () => clearSavedConnection(app);
|
||
app.saveConnectionState = () => saveConnectionState(app);
|
||
app.handleNewMessage = (message) => handleNewMessage(app, message);
|
||
app.ensureImForRole = (role) => ensureImForRole(app, role);
|
||
app.syncConnectionStatus = () => syncConnectionStatus(app);
|
||
app.restoreTabBarBadge = () => restoreCachedBadge(app);
|
||
app.startImWhenReady = () => startImWhenReady(app);
|
||
|
||
loadUserSettings(app);
|
||
initNetworkListener(app);
|
||
initAppStateListener(app);
|
||
bindGoEasyLifecycle(app);
|
||
setupEventSystem(app);
|
||
checkAndRestoreConnection(app);
|
||
}
|
||
|
||
function bindGoEasyLifecycle(app) {
|
||
if (!wx.goEasy || app._goEasyLifecycleBound) return;
|
||
app._goEasyLifecycleBound = true;
|
||
try {
|
||
wx.goEasy.on('connected', () => {
|
||
app.globalData.goEasyConnection.status = 'connected';
|
||
app.globalData.goEasyConnection.autoReconnect = true;
|
||
setupMessageListeners(app);
|
||
loadConversations(app);
|
||
startHeartbeat(app);
|
||
syncConnectionStatus(app);
|
||
});
|
||
wx.goEasy.on('disconnected', () => {
|
||
app.globalData.goEasyConnection.status = 'disconnected';
|
||
if (!app._imSuppressDisconnectEvent) {
|
||
app.emitEvent('connectionChanged', { status: 'disconnected' });
|
||
}
|
||
if (app.globalData.goEasyConnection.autoReconnect) {
|
||
setTimeout(() => ensureConnection(app), app.globalData.goEasyConnection.config.reconnectDelay);
|
||
}
|
||
});
|
||
} catch (e) {
|
||
console.warn('绑定 GoEasy 生命周期失败:', e);
|
||
}
|
||
}
|
||
|
||
function getCurrentGoEasyUserId() {
|
||
return (wx.goEasy && wx.goEasy.im && wx.goEasy.im.userId) || null;
|
||
}
|
||
|
||
function getExpectedImUserId(app) {
|
||
const fromLocal = getLocalImUserId(app);
|
||
if (fromLocal) return fromLocal;
|
||
const uid = wx.getStorageSync('uid');
|
||
if (!uid) return '';
|
||
const role = app.globalData.currentRole || getLocalImIdentity(app) || 'normal';
|
||
return getImUserIdForRole(role, uid);
|
||
}
|
||
|
||
function loadUserSettings(app) {
|
||
try {
|
||
const messageSettings = wx.getStorageSync(app.globalData.messageManager.cacheKeys.messageSettings);
|
||
if (messageSettings) {
|
||
app.globalData.messageManager = { ...app.globalData.messageManager, ...messageSettings };
|
||
}
|
||
const notificationMuted = wx.getStorageSync(app.globalData.messageManager.cacheKeys.notificationMuted);
|
||
if (notificationMuted !== '') {
|
||
app.globalData.messageManager.notificationMuted = notificationMuted;
|
||
}
|
||
const savedUnread = wx.getStorageSync(app.globalData.messageManager.cacheKeys.unreadTotal);
|
||
if (savedUnread !== '' && savedUnread !== undefined) {
|
||
app.globalData.messageManager.unreadTotal = savedUnread;
|
||
updateTabBarBadge(app, savedUnread);
|
||
}
|
||
const savedMessages = wx.getStorageSync(app.globalData.messageManager.cacheKeys.latestMessages);
|
||
if (savedMessages) {
|
||
app.globalData.messageManager.latestMessages = savedMessages;
|
||
}
|
||
} catch (error) {
|
||
console.warn('加载用户设置失败:', error);
|
||
}
|
||
}
|
||
|
||
function initNetworkListener(app) {
|
||
wx.onNetworkStatusChange((res) => {
|
||
if (res.isConnected) {
|
||
app.globalData.goEasyConnection.autoReconnect = true;
|
||
app.globalData.goEasyConnection.reconnectAttempts = 0;
|
||
app.emitEvent('connectionChanged', { status: 'reconnecting', reason: 'network' });
|
||
ensureConnection(app);
|
||
} else {
|
||
app.globalData.goEasyConnection.status = 'disconnected';
|
||
app.emitEvent('connectionChanged', { status: 'disconnected', reason: 'network' });
|
||
}
|
||
});
|
||
}
|
||
|
||
function initAppStateListener(app) {
|
||
wx.onAppShow(() => {
|
||
updateCurrentPageState(app);
|
||
app.globalData.goEasyConnection.autoReconnect = true;
|
||
restoreCachedBadge(app);
|
||
ensureConnection(app);
|
||
setTimeout(() => loadConversations(app), 400);
|
||
});
|
||
wx.onAppHide(() => {
|
||
pauseHeartbeat(app);
|
||
saveConnectionState(app);
|
||
});
|
||
}
|
||
|
||
function checkAndRestoreConnection(app) {
|
||
try {
|
||
const savedConnection = wx.getStorageSync(app.globalData.goEasyConnection.cacheKeys.savedConnection);
|
||
if (savedConnection && savedConnection.userId && savedConnection.identityType) {
|
||
const now = Date.now();
|
||
const lastTime = savedConnection.lastConnectTime || 0;
|
||
const hoursDiff = (now - lastTime) / (1000 * 60 * 60);
|
||
const validityHours = app.globalData.goEasyConnection.config.cacheValidityHours || 12;
|
||
if (hoursDiff > validityHours) {
|
||
clearSavedConnection(app);
|
||
}
|
||
}
|
||
ensureConnection(app);
|
||
} catch (error) {
|
||
console.warn('检查保存的连接信息失败:', error);
|
||
}
|
||
}
|
||
|
||
function setupEventSystem(app) {
|
||
if (!app.globalData.eventListeners) {
|
||
app.globalData.eventListeners = {};
|
||
}
|
||
}
|
||
|
||
function isSdkConnected() {
|
||
if (!wx.goEasy?.getConnectionStatus) return false;
|
||
const s = wx.goEasy.getConnectionStatus();
|
||
return s === 'connected' || s === 'reconnected';
|
||
}
|
||
|
||
function isImConnected() {
|
||
return isSdkConnected();
|
||
}
|
||
|
||
/** 已连接且身份正确则直接恢复监听，避免重复 connect 触发 408 */
|
||
function adoptExistingConnection(app, identityType, userId) {
|
||
app.globalData.goEasyConnection.status = 'connected';
|
||
app.globalData.goEasyConnection.userId = userId;
|
||
app.globalData.goEasyConnection.identityType = identityType;
|
||
app.globalData.goEasyConnection.autoReconnect = true;
|
||
app.globalData.goEasyConnection.reconnectAttempts = 0;
|
||
saveConnectionState(app);
|
||
startHeartbeat(app);
|
||
setupMessageListeners(app);
|
||
loadConversations(app);
|
||
syncConnectionStatus(app);
|
||
}
|
||
|
||
/** 根据 SDK 真实状态同步 UI（避免已连接仍显示未连接） */
|
||
function syncConnectionStatus(app) {
|
||
if (app.globalData.chatEnabled === false) {
|
||
app.emitEvent('connectionChanged', { status: 'disabled', reason: 'chat_disabled' });
|
||
return;
|
||
}
|
||
const expectedId = getExpectedImUserId(app);
|
||
if (!expectedId) {
|
||
app.emitEvent('connectionChanged', { status: 'disconnected', reason: 'no_uid' });
|
||
return;
|
||
}
|
||
const cur = getCurrentGoEasyUserId();
|
||
if (isSdkConnected() && (!cur || cur === expectedId)) {
|
||
app.globalData.goEasyConnection.status = 'connected';
|
||
app.globalData.goEasyConnection.userId = cur || expectedId;
|
||
app.globalData.goEasyConnection.autoReconnect = true;
|
||
setupMessageListeners(app);
|
||
loadConversations(app);
|
||
restoreCachedBadge(app);
|
||
app.emitEvent('connectionChanged', { status: 'connected' });
|
||
return;
|
||
}
|
||
const st = app.globalData.goEasyConnection.status;
|
||
if (st === 'connecting' || st === 'reconnecting') {
|
||
app.emitEvent('connectionChanged', { status: st });
|
||
} else {
|
||
app.emitEvent('connectionChanged', { status: 'disconnected' });
|
||
}
|
||
}
|
||
|
||
function ensureConnection(app) {
|
||
if (!wx.goEasy?.connect) return;
|
||
if (app.globalData.chatEnabled === false) {
|
||
syncConnectionStatus(app);
|
||
return;
|
||
}
|
||
|
||
const expectedId = getExpectedImUserId(app);
|
||
if (!expectedId) return;
|
||
|
||
const role = app.globalData.currentRole || 'normal';
|
||
|
||
if (isImConnected()) {
|
||
const cur = getCurrentGoEasyUserId();
|
||
if (cur === expectedId) {
|
||
setupMessageListeners(app);
|
||
startHeartbeat(app);
|
||
loadConversations(app);
|
||
syncConnectionStatus(app);
|
||
return;
|
||
}
|
||
connectForCurrentRole(app);
|
||
return;
|
||
}
|
||
|
||
app.globalData.goEasyConnection.autoReconnect = true;
|
||
app.emitEvent('connectionChanged', { status: 'connecting' });
|
||
|
||
const saved = getSavedConnection(app);
|
||
if (saved && saved.userId === expectedId && saved.identityType === role) {
|
||
connectWithIdentity(app, saved.identityType, saved.userId, true);
|
||
return;
|
||
}
|
||
|
||
connectForCurrentRole(app);
|
||
}
|
||
|
||
async function ensureImForRole(app, role) {
|
||
const uid = wx.getStorageSync('uid');
|
||
if (!uid) throw new Error('未登录');
|
||
const targetUserId = getImUserIdForRole(role, uid);
|
||
if (!targetUserId) throw new Error('无效身份');
|
||
|
||
if (isImConnected() && getCurrentGoEasyUserId() === targetUserId) {
|
||
setupMessageListeners(app);
|
||
loadConversations(app);
|
||
syncConnectionStatus(app);
|
||
return;
|
||
}
|
||
|
||
if (app.globalData.currentRole !== role) {
|
||
app.globalData.currentRole = role;
|
||
wx.setStorageSync('currentRole', role);
|
||
}
|
||
|
||
await connectWithIdentity(app, role, targetUserId, true);
|
||
}
|
||
|
||
function getSavedConnection(app) {
|
||
try {
|
||
const saved = wx.getStorageSync(app.globalData.goEasyConnection.cacheKeys.savedConnection);
|
||
if (!saved) return null;
|
||
if (typeof saved === 'string') return JSON.parse(saved);
|
||
return saved;
|
||
} catch (error) {
|
||
console.error('获取保存的连接信息失败:', error);
|
||
return null;
|
||
}
|
||
}
|
||
|
||
function saveConnectionState(app) {
|
||
try {
|
||
const { goEasyConnection } = app.globalData;
|
||
const connectionState = {
|
||
userId: goEasyConnection.userId,
|
||
identityType: goEasyConnection.identityType,
|
||
lastConnectTime: Date.now(),
|
||
autoReconnect: goEasyConnection.autoReconnect,
|
||
status: goEasyConnection.status,
|
||
};
|
||
wx.setStorageSync(goEasyConnection.cacheKeys.savedConnection, JSON.stringify(connectionState));
|
||
} catch (error) {
|
||
console.warn('保存连接状态失败:', error);
|
||
}
|
||
}
|
||
|
||
function clearSavedConnection(app) {
|
||
const { cacheKeys } = app.globalData.goEasyConnection;
|
||
wx.removeStorageSync(cacheKeys.savedConnection);
|
||
wx.removeStorageSync(cacheKeys.userId);
|
||
wx.removeStorageSync(cacheKeys.identityType);
|
||
app.globalData.goEasyConnection.userId = '';
|
||
app.globalData.goEasyConnection.identityType = '';
|
||
app.globalData.goEasyConnection.lastConnectTime = 0;
|
||
}
|
||
|
||
function disconnectGoEasy(app, options = {}) {
|
||
const silent = options.silent === true;
|
||
const keepAutoReconnect = options.keepAutoReconnect === true;
|
||
|
||
return withImLock(() => new Promise((resolve) => {
|
||
if (silent) app._imSuppressDisconnectEvent = true;
|
||
app.globalData.goEasyConnection.status = 'disconnected';
|
||
if (!keepAutoReconnect) {
|
||
app.globalData.goEasyConnection.autoReconnect = false;
|
||
}
|
||
stopHeartbeat(app);
|
||
removeGlobalMessageListeners();
|
||
|
||
const finish = () => {
|
||
clearSavedConnection(app);
|
||
if (!keepAutoReconnect) {
|
||
app.globalData.messageManager.unreadTotal = 0;
|
||
updateTabBarBadge(app, 0);
|
||
}
|
||
if (!silent) {
|
||
app.emitEvent('connectionChanged', { status: 'disconnected', manual: true });
|
||
}
|
||
app._imSuppressDisconnectEvent = false;
|
||
resolve();
|
||
};
|
||
|
||
if (wx.goEasy && wx.goEasy.disconnect) {
|
||
wx.goEasy.disconnect({
|
||
onSuccess: finish,
|
||
onFailed: finish,
|
||
});
|
||
} else {
|
||
finish();
|
||
}
|
||
}));
|
||
}
|
||
|
||
async function connectWithIdentity(app, identityType, userId, isAutoRestore = false) {
|
||
if (!wx.goEasy?.connect) {
|
||
return Promise.reject(new Error('聊天服务未就绪'));
|
||
}
|
||
|
||
return withImLock(async () => {
|
||
if (!isAutoRestore) {
|
||
const quanxian = await jianquanxian(app);
|
||
if (!quanxian.allowed) {
|
||
throw new Error(quanxian.reason || '无聊天权限');
|
||
}
|
||
} else {
|
||
const uid = wx.getStorageSync('uid');
|
||
if (!uid) throw new Error('未登录');
|
||
}
|
||
|
||
const currentId = getCurrentGoEasyUserId();
|
||
if (isSdkConnected()) {
|
||
if (!currentId || currentId === userId) {
|
||
adoptExistingConnection(app, identityType, userId);
|
||
return;
|
||
}
|
||
await disconnectGoEasy(app, { silent: true, keepAutoReconnect: true });
|
||
app.globalData.goEasyConnection.autoReconnect = true;
|
||
await new Promise((r) => setTimeout(r, 400));
|
||
}
|
||
|
||
if (currentId && currentId !== userId && !isSdkConnected()) {
|
||
await disconnectGoEasy(app, { silent: true, keepAutoReconnect: true });
|
||
app.globalData.goEasyConnection.autoReconnect = true;
|
||
await new Promise((r) => setTimeout(r, 400));
|
||
}
|
||
|
||
app.globalData.goEasyConnection.autoReconnect = true;
|
||
app.globalData.goEasyConnection.status = 'connecting';
|
||
app.globalData.goEasyConnection.userId = userId;
|
||
app.globalData.goEasyConnection.identityType = identityType;
|
||
if (!isAutoRestore) app.globalData.goEasyConnection.reconnectAttempts = 0;
|
||
saveConnectionState(app);
|
||
app.emitEvent('connectionChanged', { status: 'connecting', identityType, userId });
|
||
|
||
const uid = wx.getStorageSync('uid');
|
||
const role = identityType || app.globalData.currentRole || 'normal';
|
||
const freshUser = getFreshImUser(app, role, uid);
|
||
const currentUser = app.globalData.currentUser || {
|
||
id: uid,
|
||
name: freshUser.name,
|
||
avatar: freshUser.avatar,
|
||
};
|
||
|
||
return new Promise((resolve, reject) => {
|
||
wx.goEasy.connect({
|
||
id: userId,
|
||
data: {
|
||
name: freshUser.name || currentUser.name,
|
||
avatar: freshUser.avatar || currentUser.avatar || (app.globalData.ossImageUrl + app.globalData.morentouxiang),
|
||
identityType,
|
||
},
|
||
onSuccess: () => {
|
||
app.globalData.goEasyConnection.status = 'connected';
|
||
app.globalData.goEasyConnection.lastConnectTime = Date.now();
|
||
app.globalData.goEasyConnection.reconnectAttempts = 0;
|
||
saveConnectionState(app);
|
||
startHeartbeat(app);
|
||
setupMessageListeners(app);
|
||
loadConversations(app);
|
||
app.emitEvent('connectionChanged', { status: 'connected', identityType, userId });
|
||
resolve();
|
||
},
|
||
onFailed: (error) => {
|
||
console.error('GoEasy连接失败:', error);
|
||
// 408 = 已连接，勿再 connect，直接复用当前连接
|
||
if (error.code === 408) {
|
||
adoptExistingConnection(app, identityType, userId);
|
||
resolve();
|
||
return;
|
||
}
|
||
if (error.code === 900) {
|
||
app.globalData.goEasyConnection.autoReconnect = false;
|
||
app.globalData.goEasyConnection.status = 'disconnected';
|
||
clearSavedConnection(app);
|
||
stopHeartbeat(app);
|
||
wx.showModal({
|
||
title: '消息功能暂不可用',
|
||
content: '当前使用人数爆满，消息功能暂时无法使用。请联系管理员升级套餐后重试。',
|
||
showCancel: false,
|
||
confirmText: '我知道了',
|
||
});
|
||
app.emitEvent('connectionChanged', { status: 'disconnected', error, reason: 'overcapacity' });
|
||
reject(error);
|
||
return;
|
||
}
|
||
app.globalData.goEasyConnection.status = 'reconnecting';
|
||
app.emitEvent('connectionChanged', { status: 'reconnecting', error, isAutoRestore });
|
||
const { autoReconnect, reconnectAttempts, maxReconnectAttempts } = app.globalData.goEasyConnection;
|
||
if (autoReconnect && reconnectAttempts < maxReconnectAttempts && !isSdkConnected()) {
|
||
app.globalData.goEasyConnection.reconnectAttempts++;
|
||
const delay = app.globalData.goEasyConnection.config.reconnectDelay * reconnectAttempts;
|
||
setTimeout(() => {
|
||
if (app.globalData.goEasyConnection.autoReconnect) {
|
||
connectWithIdentity(app, identityType, userId, true).then(resolve).catch(reject);
|
||
}
|
||
}, delay);
|
||
} else {
|
||
reject(error);
|
||
}
|
||
},
|
||
});
|
||
});
|
||
});
|
||
}
|
||
|
||
async function connectForCurrentRole(app) {
|
||
const uid = wx.getStorageSync('uid');
|
||
if (!uid) return;
|
||
const role = app.globalData.currentRole || 'normal';
|
||
const targetUserId = getImUserIdForRole(role, uid);
|
||
|
||
const currentUserId = getCurrentGoEasyUserId();
|
||
if (currentUserId === targetUserId && isImConnected()) {
|
||
setupMessageListeners(app);
|
||
startHeartbeat(app);
|
||
loadConversations(app);
|
||
syncConnectionStatus(app);
|
||
return;
|
||
}
|
||
if (currentUserId && currentUserId !== targetUserId) {
|
||
await disconnectGoEasy(app, { silent: true, keepAutoReconnect: true });
|
||
app.globalData.goEasyConnection.autoReconnect = true;
|
||
}
|
||
await connectWithIdentity(app, role, targetUserId, true);
|
||
}
|
||
|
||
async function switchRoleAndReconnect(app, newRole) {
|
||
try {
|
||
await withImLock(async () => {
|
||
await disconnectGoEasy(app, { silent: true, keepAutoReconnect: true });
|
||
app.globalData.currentRole = newRole;
|
||
wx.setStorageSync('currentRole', newRole);
|
||
app.globalData.goEasyConnection.autoReconnect = true;
|
||
app.globalData.goEasyConnection.reconnectAttempts = 0;
|
||
const uid = wx.getStorageSync('uid');
|
||
const targetUserId = getImUserIdForRole(newRole, uid);
|
||
// 切换身份用轻量连接，避免鉴权接口失败把 IM 永久断开
|
||
await connectWithIdentity(app, newRole, targetUserId, true);
|
||
});
|
||
return true;
|
||
} catch (error) {
|
||
console.warn('切换身份 IM 重连失败', error);
|
||
syncConnectionStatus(app);
|
||
throw error;
|
||
}
|
||
}
|
||
|
||
function startHeartbeat(app) {
|
||
const { goEasyConnection } = app.globalData;
|
||
stopHeartbeat(app);
|
||
let convTick = 0;
|
||
goEasyConnection.heartbeatInterval = setInterval(() => {
|
||
if (goEasyConnection.status === 'connected' && wx.goEasy?.im) {
|
||
if (isSdkConnected()) {
|
||
convTick += 1;
|
||
if (convTick % 3 === 0) {
|
||
loadConversations(app);
|
||
}
|
||
} else {
|
||
goEasyConnection.status = 'reconnecting';
|
||
app.emitEvent('connectionChanged', { status: 'reconnecting' });
|
||
attemptReconnect(app);
|
||
}
|
||
} else if (goEasyConnection.autoReconnect && !isSdkConnected()) {
|
||
ensureConnection(app);
|
||
}
|
||
}, goEasyConnection.config.heartbeatInterval);
|
||
}
|
||
|
||
function stopHeartbeat(app) {
|
||
if (app.globalData.goEasyConnection.heartbeatInterval) {
|
||
clearInterval(app.globalData.goEasyConnection.heartbeatInterval);
|
||
app.globalData.goEasyConnection.heartbeatInterval = null;
|
||
}
|
||
}
|
||
|
||
function pauseHeartbeat(app) { stopHeartbeat(app); }
|
||
|
||
function attemptReconnect(app) {
|
||
const { goEasyConnection } = app.globalData;
|
||
if (!goEasyConnection.autoReconnect || isSdkConnected()) return;
|
||
if (goEasyConnection.reconnectAttempts >= goEasyConnection.maxReconnectAttempts) {
|
||
goEasyConnection.reconnectAttempts = 0;
|
||
}
|
||
if (goEasyConnection.userId && goEasyConnection.identityType) {
|
||
connectWithIdentity(app, goEasyConnection.identityType, goEasyConnection.userId, true);
|
||
} else {
|
||
connectForCurrentRole(app);
|
||
}
|
||
}
|
||
|
||
function removeGlobalMessageListeners() {
|
||
if (!wx.goEasy?.im) return;
|
||
if (_globalPrivateHandler) {
|
||
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.PRIVATE_MESSAGE_RECEIVED, _globalPrivateHandler);
|
||
_globalPrivateHandler = null;
|
||
}
|
||
if (_globalGroupHandler) {
|
||
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.GROUP_MESSAGE_RECEIVED, _globalGroupHandler);
|
||
_globalGroupHandler = null;
|
||
}
|
||
if (_globalConvHandler) {
|
||
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.CONVERSATIONS_UPDATED, _globalConvHandler);
|
||
_globalConvHandler = null;
|
||
}
|
||
}
|
||
|
||
function setupMessageListeners(app) {
|
||
if (!wx.goEasy?.im || typeof wx.goEasy.im.on !== 'function') {
|
||
return;
|
||
}
|
||
removeGlobalMessageListeners();
|
||
|
||
_globalPrivateHandler = (message) => {
|
||
app.handleNewMessage(message);
|
||
};
|
||
_globalGroupHandler = (message) => {
|
||
app.handleNewMessage(message);
|
||
};
|
||
_globalConvHandler = (conversations) => {
|
||
const normalized = normalizeConversationPayload(conversations);
|
||
const unreadTotal = normalized?.unreadTotal ?? conversations?.unreadTotal ?? 0;
|
||
applyUnreadTotal(app, unreadTotal);
|
||
if (normalized && typeof app.emitEvent === 'function') {
|
||
app.emitEvent('conversationsUpdated', normalized);
|
||
}
|
||
};
|
||
|
||
wx.goEasy.im.on(wx.GoEasy.IM_EVENT.PRIVATE_MESSAGE_RECEIVED, _globalPrivateHandler);
|
||
wx.goEasy.im.on(wx.GoEasy.IM_EVENT.GROUP_MESSAGE_RECEIVED, _globalGroupHandler);
|
||
wx.goEasy.im.on(wx.GoEasy.IM_EVENT.CONVERSATIONS_UPDATED, _globalConvHandler);
|
||
}
|
||
|
||
function handleNewMessage(app, message) {
|
||
const messageId = message.messageId || message.id;
|
||
const fingerprint = `${message.senderId}_${message.timestamp}_${message.type}`;
|
||
const msgKey = messageId || fingerprint;
|
||
|
||
if (!app._processedMessages) app._processedMessages = new Set();
|
||
if (app._processedMessages.has(msgKey)) return;
|
||
app._processedMessages.add(msgKey);
|
||
if (app._processedMessages.size > 300) {
|
||
app._processedMessages.delete(app._processedMessages.values().next().value);
|
||
}
|
||
|
||
cacheMessage(app, message);
|
||
loadConversations(app);
|
||
|
||
if (shouldShowNotification(app, message)) {
|
||
let notificationType = 'private';
|
||
let extraData = {};
|
||
if (message.groupId) {
|
||
notificationType = 'group';
|
||
extraData = {
|
||
groupId: message.groupId,
|
||
orderId: message.orderId || '',
|
||
groupName: '',
|
||
groupAvatar: '',
|
||
isCross: message.isCross || 0,
|
||
};
|
||
const groupInfo = app.globalData.groupInfoMap?.[message.groupId];
|
||
if (groupInfo) {
|
||
extraData.groupName = groupInfo.name || '';
|
||
extraData.groupAvatar = groupInfo.avatar || '';
|
||
}
|
||
} else if (message.teamId) {
|
||
notificationType = 'cs';
|
||
extraData = { teamId: message.teamId };
|
||
}
|
||
showNotificationDirect(app, {
|
||
senderId: message.senderId,
|
||
senderName: message.senderData?.name || '用户',
|
||
avatar: message.senderData?.avatar || (app.globalData.ossImageUrl + app.globalData.morentouxiang),
|
||
content: formatMessageForNotification(message),
|
||
message,
|
||
notificationType,
|
||
...extraData,
|
||
});
|
||
}
|
||
}
|
||
|
||
function shouldShowNotification(app, message) {
|
||
if (app.globalData.messageManager.notificationMuted) return false;
|
||
if (isDoNotDisturbTime(app)) return false;
|
||
if (isMessageFromCurrentChat(app, message)) return false;
|
||
return true;
|
||
}
|
||
|
||
function isDoNotDisturbTime(app) {
|
||
const { doNotDisturb, doNotDisturbStart, doNotDisturbEnd } = app.globalData.messageManager;
|
||
if (!doNotDisturb) return false;
|
||
const now = new Date();
|
||
const currentTime = now.getHours() * 60 + now.getMinutes();
|
||
const [sH, sM] = doNotDisturbStart.split(':').map(Number);
|
||
const [eH, eM] = doNotDisturbEnd.split(':').map(Number);
|
||
const startTime = sH * 60 + sM;
|
||
const endTime = eH * 60 + eM;
|
||
if (startTime < endTime) {
|
||
return currentTime >= startTime && currentTime < endTime;
|
||
}
|
||
return currentTime >= startTime || currentTime < endTime;
|
||
}
|
||
|
||
function isMessageFromCurrentChat(app, message) {
|
||
const pageState = app.globalData.pageState || {};
|
||
if (!pageState.isInChatPage || !pageState.currentChatId) return false;
|
||
if (message.groupId) {
|
||
return message.groupId === pageState.currentChatId;
|
||
}
|
||
const myId = app.globalData.goEasyConnection?.userId || getCurrentGoEasyUserId();
|
||
if (!myId) return false;
|
||
const peerId = message.senderId === myId ? message.receiverId : message.senderId;
|
||
return peerId === pageState.currentChatId || message.senderId === pageState.currentChatId;
|
||
}
|
||
|
||
function showNotificationDirect(app, data) {
|
||
if (app.globalData.globalNotification?.show) {
|
||
try {
|
||
app.globalData.globalNotification.show(data);
|
||
return;
|
||
} catch (error) {
|
||
console.warn('全局通知显示失败:', error);
|
||
}
|
||
}
|
||
app.emitEvent('showNotification', data);
|
||
}
|
||
|
||
function startImWhenReady(app) {
|
||
if (!wx.getStorageSync('uid')) return;
|
||
app.globalData.goEasyConnection.autoReconnect = true;
|
||
restoreCachedBadge(app);
|
||
ensureConnection(app);
|
||
setTimeout(() => {
|
||
if (isSdkConnected()) {
|
||
setupMessageListeners(app);
|
||
loadConversations(app);
|
||
}
|
||
restoreCachedBadge(app);
|
||
}, 450);
|
||
}
|
||
|
||
function restoreCachedBadge(app) {
|
||
const { messageManager } = app.globalData;
|
||
let unread = messageManager.unreadTotal;
|
||
if (unread == null || unread === '') {
|
||
try {
|
||
const saved = wx.getStorageSync(messageManager.cacheKeys.unreadTotal);
|
||
if (saved !== '' && saved != null) unread = Number(saved) || 0;
|
||
} catch (e) {}
|
||
}
|
||
if (!unread) {
|
||
try {
|
||
const badgeStr = wx.getStorageSync('tabBarMessageBadge');
|
||
if (badgeStr && badgeStr !== '0') {
|
||
unread = badgeStr === '99+' ? 100 : (parseInt(badgeStr, 10) || 0);
|
||
}
|
||
} catch (e) {}
|
||
}
|
||
if (unread > 0) {
|
||
updateTabBarBadge(app, unread);
|
||
} else if (messageManager.tabBarBadgeText) {
|
||
app.emitEvent('tabBarBadgeChanged', {
|
||
index: messageManager.tabBarIndex,
|
||
badgeText: messageManager.tabBarBadgeText,
|
||
showRedDot: true,
|
||
forceUpdate: true,
|
||
});
|
||
updateTabBarDirectly(app, messageManager.tabBarBadgeText);
|
||
}
|
||
}
|
||
|
||
function applyUnreadTotal(app, unreadTotal) {
|
||
const prev = app.globalData.messageManager.unreadTotal;
|
||
const connected = isSdkConnected();
|
||
if (unreadTotal === 0 && !connected && prev > 0) {
|
||
restoreCachedBadge(app);
|
||
return;
|
||
}
|
||
app.globalData.messageManager.unreadTotal = unreadTotal;
|
||
updateTabBarBadge(app, unreadTotal);
|
||
wx.setStorageSync(app.globalData.messageManager.cacheKeys.unreadTotal, unreadTotal);
|
||
if (prev !== unreadTotal) {
|
||
app.emitEvent('unreadCountChanged', { unreadTotal });
|
||
}
|
||
}
|
||
|
||
async function updateUnreadCount(app, customCount) {
|
||
let unreadTotal = customCount;
|
||
if (unreadTotal === undefined) {
|
||
try {
|
||
const result = await getUnreadCount(app);
|
||
unreadTotal = result.unreadTotal || 0;
|
||
} catch (error) {
|
||
console.error('获取未读数失败:', error);
|
||
return;
|
||
}
|
||
}
|
||
applyUnreadTotal(app, unreadTotal);
|
||
}
|
||
|
||
function getUnreadCount(app) {
|
||
return new Promise((resolve, reject) => {
|
||
if (!getCurrentGoEasyUserId()) {
|
||
resolve({ unreadTotal: 0 });
|
||
return;
|
||
}
|
||
wx.goEasy.im.latestConversations({
|
||
onSuccess: (result) => resolve({
|
||
unreadTotal: result.unreadTotal || 0,
|
||
conversations: result.content?.conversations || [],
|
||
}),
|
||
onFailed: reject,
|
||
});
|
||
});
|
||
}
|
||
|
||
function formatMessageForNotification(message) {
|
||
switch (message.type) {
|
||
case 'text': return message.payload.text || '[文本]';
|
||
case 'image': return '[图片]';
|
||
case 'audio': return '[语音]';
|
||
case 'video': return '[视频]';
|
||
case 'file': return '[文件]';
|
||
case 'order': return '[订单]';
|
||
default: return '[新消息]';
|
||
}
|
||
}
|
||
|
||
function cacheMessage(app, message) {
|
||
if (message.groupId && message.type === 'text' && message.payload?.text) {
|
||
const card = parseOrderCardText(message.payload.text);
|
||
if (card && card.zhuangtai != null) {
|
||
if (!app.globalData.groupInfoMap) app.globalData.groupInfoMap = {};
|
||
const meta = {
|
||
...(app.globalData.groupInfoMap[message.groupId] || {}),
|
||
orderId: card.orderId,
|
||
orderZhuangtai: card.zhuangtai,
|
||
orderDesc: card.jieshao,
|
||
};
|
||
app.globalData.groupInfoMap[message.groupId] = meta;
|
||
persistGroupMeta(app, message.groupId, meta);
|
||
}
|
||
}
|
||
const { latestMessages } = app.globalData.messageManager;
|
||
latestMessages.unshift({
|
||
id: message.messageId,
|
||
type: message.type,
|
||
senderId: message.senderId,
|
||
senderName: message.senderData?.name,
|
||
content: formatMessageForNotification(message),
|
||
timestamp: message.timestamp || Date.now(),
|
||
conversationId: message.conversationId,
|
||
});
|
||
if (latestMessages.length > 50) latestMessages.length = 50;
|
||
wx.setStorageSync(app.globalData.messageManager.cacheKeys.latestMessages, latestMessages);
|
||
}
|
||
|
||
function normalizeConversationPayload(result) {
|
||
if (!result) return null;
|
||
const content = result.content || result;
|
||
const list = content.conversations || result.conversations;
|
||
if (!list || !Array.isArray(list)) return null;
|
||
return {
|
||
conversations: list,
|
||
unreadTotal: content.unreadTotal ?? result.unreadTotal ?? 0,
|
||
};
|
||
}
|
||
|
||
function loadConversations(app) {
|
||
if (_loadConvTimer) clearTimeout(_loadConvTimer);
|
||
_loadConvTimer = setTimeout(() => {
|
||
_loadConvTimer = null;
|
||
loadConversationsNow(app);
|
||
}, 280);
|
||
}
|
||
|
||
function loadConversationsNow(app) {
|
||
if (_loadConvInFlight) return;
|
||
if (!isSdkConnected() || !wx.goEasy?.im?.latestConversations) {
|
||
restoreCachedBadge(app);
|
||
if (app.globalData.goEasyConnection.autoReconnect) {
|
||
ensureConnection(app);
|
||
}
|
||
return;
|
||
}
|
||
_loadConvInFlight = true;
|
||
wx.goEasy.im.latestConversations({
|
||
onSuccess: (result) => {
|
||
_loadConvInFlight = false;
|
||
const normalized = normalizeConversationPayload(result);
|
||
if (result.unreadTotal !== undefined) {
|
||
applyUnreadTotal(app, result.unreadTotal);
|
||
} else if (normalized) {
|
||
applyUnreadTotal(app, normalized.unreadTotal);
|
||
}
|
||
if (normalized && typeof app.emitEvent === 'function') {
|
||
app.emitEvent('conversationsUpdated', normalized);
|
||
}
|
||
const conversations = normalized?.conversations || [];
|
||
if (!app.globalData.groupInfoMap) app.globalData.groupInfoMap = {};
|
||
conversations.forEach((c) => {
|
||
if (c.type === 'group' && c.groupId) {
|
||
app.globalData.groupInfoMap[c.groupId] = c.data || {};
|
||
}
|
||
});
|
||
_ensureGroupSubscriptions(app, conversations);
|
||
},
|
||
onFailed: (error) => {
|
||
_loadConvInFlight = false;
|
||
console.error('加载会话列表失败:', error);
|
||
restoreCachedBadge(app);
|
||
if (!isSdkConnected() && app.globalData.goEasyConnection.autoReconnect) {
|
||
attemptReconnect(app);
|
||
}
|
||
},
|
||
});
|
||
}
|
||
|
||
function _ensureGroupSubscriptions(app, conversations) {
|
||
const groupIds = conversations
|
||
.filter((c) => c.type === 'group' && c.groupId)
|
||
.map((c) => c.groupId);
|
||
|
||
if (groupIds.length === 0) return;
|
||
if (!wx.goEasy?.im || typeof wx.goEasy.im.subscribeGroup !== 'function') return;
|
||
|
||
wx.goEasy.im.subscribeGroup({
|
||
groupIds,
|
||
onSuccess: () => {},
|
||
onFailed: (error) => console.error('全局订阅群组失败:', error),
|
||
});
|
||
}
|
||
|
||
function updateCurrentPageState(app) {
|
||
try {
|
||
const pages = getCurrentPages();
|
||
if (pages.length > 0) {
|
||
const currentPage = pages[pages.length - 1];
|
||
const chatPages = [
|
||
'pages/chat/chat',
|
||
'pages/group-chat/group-chat',
|
||
'pages/cs-chat/cs-chat',
|
||
'pages/liaotian/liaotian',
|
||
'pages/qunliaotian/qunliaotian',
|
||
'pages/kefuliaotian/kefuliaotian',
|
||
];
|
||
app.globalData.pageState.currentPage = currentPage.route;
|
||
app.globalData.pageState.isInChatPage = chatPages.indexOf(currentPage.route) >= 0;
|
||
app.globalData.pageState.lastPageUpdate = Date.now();
|
||
}
|
||
} catch (error) {
|
||
console.warn('更新页面状态失败:', error);
|
||
}
|
||
}
|
||
|
||
function saveUserSettings(app) {
|
||
try {
|
||
wx.setStorageSync(app.globalData.messageManager.cacheKeys.messageSettings, {
|
||
soundEnabled: app.globalData.messageManager.soundEnabled,
|
||
vibrationEnabled: app.globalData.messageManager.vibrationEnabled,
|
||
doNotDisturb: app.globalData.messageManager.doNotDisturb,
|
||
doNotDisturbStart: app.globalData.messageManager.doNotDisturbStart,
|
||
doNotDisturbEnd: app.globalData.messageManager.doNotDisturbEnd,
|
||
notificationMuted: app.globalData.messageManager.notificationMuted,
|
||
notificationStyle: app.globalData.messageManager.notificationStyle,
|
||
});
|
||
} catch (error) {
|
||
console.warn('保存用户设置失败:', error);
|
||
}
|
||
}
|
||
|
||
function toggleDoNotDisturb(app, enabled) {
|
||
app.globalData.messageManager.doNotDisturb = enabled;
|
||
saveUserSettings(app);
|
||
wx.showToast({ title: `免打扰${enabled ? '开启' : '关闭'}`, icon: 'success', duration: 2000 });
|
||
}
|
||
|
||
function toggleNotificationMute(app, enabled) {
|
||
app.globalData.messageManager.notificationMuted = enabled;
|
||
wx.setStorageSync(app.globalData.messageManager.cacheKeys.notificationMuted, enabled);
|
||
saveUserSettings(app);
|
||
wx.showToast({ title: `通知${enabled ? '静音' : '开启'}`, icon: 'success', duration: 2000 });
|
||
}
|
||
|
||
function closeNotification(app) {
|
||
app.emitEvent('hideNotification');
|
||
}
|
||
|
||
function updateTabBarBadge(app, unreadCount) {
|
||
const { messageManager } = app.globalData;
|
||
if (!messageManager.showTabBarBadge) return;
|
||
let badgeText = '';
|
||
if (unreadCount > 0) {
|
||
badgeText = unreadCount > 99 ? '99+' : unreadCount.toString();
|
||
}
|
||
messageManager.tabBarBadgeText = badgeText;
|
||
app.emitEvent('tabBarBadgeChanged', {
|
||
index: messageManager.tabBarIndex,
|
||
badgeText,
|
||
showRedDot: unreadCount > 0,
|
||
forceUpdate: true,
|
||
});
|
||
updateTabBarDirectly(app, badgeText);
|
||
saveTabBarBadgeToStorage(app, badgeText);
|
||
}
|
||
|
||
function updateTabBarDirectly(app, badgeText) {
|
||
try {
|
||
const pages = getCurrentPages();
|
||
for (let i = pages.length - 1; i >= 0; i--) {
|
||
const tabBar = pages[i].selectComponent('#custom-tab-bar')
|
||
|| pages[i].selectComponent('tab-bar');
|
||
if (tabBar && tabBar.setData) {
|
||
tabBar.setData({ badgeText });
|
||
break;
|
||
}
|
||
}
|
||
} catch (error) { console.warn('直接更新TabBar失败:', error); }
|
||
}
|
||
|
||
function saveTabBarBadgeToStorage(app, badgeText) {
|
||
try {
|
||
wx.setStorageSync('tabBarMessageBadge', badgeText);
|
||
} catch (error) { console.warn('保存TabBar徽章失败:', error); }
|
||
}
|
||
|
||
module.exports = { initGlobalMessageSystem };
|