XingQue/Wechat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修正了 pages 名为拼音的问题

Browse Source
This commit is contained in:
TermiNexus
2026-06-13 10:44:02 +08:00
parent 76cc4ac55e
commit 296e41a8a7
249 changed files with 29660 additions and 29505 deletions
Download Patch File Download Diff File Expand all files Collapse all files

800
utils/chat-core.js
View File

@@ -1,400 +1,400 @@
// utils/chat-core.js — 全局 IM 连接、监听、角标（稳定版）
import GoEasy from '../static/lib/goeasy-2.13.24.esm.min';
import { resolveAvatarUrl } from './avatar.js';
import { getLocalImUserId, getLocalImIdentity } from './im-user.js';
let _convListener = null;
let _privateListener = null;
let _groupListener = null;
let _notificationHandler = null;
let _heartbeatTimer = null;
let _listenersBoundForUser = null;
let _lastGroupSubscribeAt = 0;
const _notifiedMessageIds = new Map();
const NOTIFY_MAX_AGE_MS = 15000;
function shouldShowNotification(message) {
if (!message) return false;
const id = message.messageId || `${message.senderId}_${message.timestamp}`;
if (_notifiedMessageIds.has(id)) return false;
if (message.timestamp && Date.now() - message.timestamp > NOTIFY_MAX_AGE_MS) return false;
_notifiedMessageIds.set(id, Date.now());
if (_notifiedMessageIds.size > 400) {
const cutoff = Date.now() - 60000;
_notifiedMessageIds.forEach((t, k) => {
if (t < cutoff) _notifiedMessageIds.delete(k);
});
}
return true;
}
function bindGlobalListenersIfNeeded(app, userId) {
if (_listenersBoundForUser === userId && _convListener) return;
registerGlobalListeners(app);
registerNotification(app);
_listenersBoundForUser = userId;
}
function initGlobalMessageSystem(app) {
app.ensureConnection = () => ensureConnection(app);
app.connectForCurrentRole = () => ensureConnection(app);
app.loadConversations = () => loadConversations(app);
app.disconnectGoEasy = () => disconnectGoEasy(app);
app.switchRoleAndReconnect = (newRole) => switchRoleAndReconnect(app, newRole);
app.updateUnreadCount = (count) => updateTabBarBadge(app, count || 0);
app.reregisterNotification = () => registerNotification(app);
app.startImWhenReady = () => startImWhenReady(app);
if (!app.globalData.messageManager) {
app.globalData.messageManager = {};
}
try {
const muted = wx.getStorageSync('notificationMuted');
if (muted !== undefined) app.globalData.messageManager.notificationMuted = muted;
} catch (e) {}
initAppStateListener(app);
initNetworkListener(app);
startHeartbeat(app);
startImWhenReady(app);
}
/** GoEasy 未就绪时轮询，登录后尽早建立监听 */
function startImWhenReady(app, maxAttempts = 40) {
let attempts = 0;
const tick = () => {
if (!wx.getStorageSync('uid')) return;
attempts += 1;
if (!wx.goEasy) {
if (attempts < maxAttempts) setTimeout(tick, 250);
return;
}
ensureConnection(app);
};
tick();
}
function getCurrentUserId() {
return (wx.goEasy && wx.goEasy.im && wx.goEasy.im.userId) || null;
}
function getConnectionStatus() {
if (!wx.goEasy || !wx.goEasy.getConnectionStatus) return 'disconnected';
return wx.goEasy.getConnectionStatus();
}
function isConnected() {
const s = getConnectionStatus();
return s === 'connected' || s === 'reconnected';
}
/** 统一会话数据结构，避免不同回调格式导致列表空白 */
function normalizeConversationsPayload(result) {
if (!result) return { conversations: [], unreadTotal: 0 };
const content = result.content || result;
const conversations = content.conversations || result.conversations || [];
const unreadTotal = content.unreadTotal ?? result.unreadTotal ?? 0;
return { conversations, unreadTotal };
}
function emitConversationsUpdated(app, result) {
const payload = normalizeConversationsPayload(result);
updateTabBarBadge(app, payload.unreadTotal);
app.emitEvent('conversationsUpdated', {
content: payload,
unreadTotal: payload.unreadTotal,
raw: result,
});
}
async function ensureConnection(app) {
const uid = wx.getStorageSync('uid');
if (!uid || !wx.goEasy) return;
const targetUserId = getLocalImUserId(app);
const identityType = getLocalImIdentity(app);
if (!targetUserId) return;
if (isConnected()) {
const currentUserId = getCurrentUserId();
if (currentUserId === targetUserId) {
bindGlobalListenersIfNeeded(app, targetUserId);
loadConversations(app);
const now = Date.now();
if (now - _lastGroupSubscribeAt > 60000) {
_lastGroupSubscribeAt = now;
await subscribeAllGroups(app);
}
return;
}
try {
wx.goEasy.disconnect();
} catch (e) {}
}
connectGoEasy(app, targetUserId, identityType);
}
function connectGoEasy(app, userId, identityType) {
const defAvatar = resolveAvatarUrl('', app);
const tx = wx.getStorageSync('touxiang') || '';
const uid = wx.getStorageSync('uid') || '';
const nick = wx.getStorageSync('nicheng') || app.globalData.nicheng || app.globalData.dashouNicheng || '';
const name = nick || ('用户' + (uid || '').substring(0, 6));
const avatar = resolveAvatarUrl(tx, app) || defAvatar;
wx.goEasy.connect({
id: userId,
data: {
name,
avatar,
identityType: identityType === 'normal' ? 'boss' : identityType,
},
onSuccess: async () => {
try {
wx.setStorageSync('savedGoEasyConnection', JSON.stringify({
userId,
identityType,
lastConnectTime: Date.now(),
status: 'connected',
}));
} catch (e) {}
bindGlobalListenersIfNeeded(app, userId);
_lastGroupSubscribeAt = Date.now();
await subscribeAllGroups(app);
loadConversations(app);
},
onFailed: (error) => {
console.error('GoEasy连接失败', error);
if (error.code === 408) {
bindGlobalListenersIfNeeded(app, userId);
loadConversations(app);
} else {
wx.showToast({ title: '连接失败，请重试', icon: 'none' });
}
},
});
}
function subscribeAllGroups(app) {
return new Promise((resolve) => {
if (!wx.goEasy || !wx.goEasy.im) return resolve();
wx.goEasy.im.latestConversations({
onSuccess: (result) => {
const payload = normalizeConversationsPayload(result);
const groupIds = payload.conversations
.filter((c) => c.type === 'group' && c.groupId)
.map((c) => c.groupId);
if (groupIds.length && wx.goEasy.im.subscribeGroup) {
wx.goEasy.im.subscribeGroup({
groupIds,
onSuccess: () => resolve(),
onFailed: () => resolve(),
});
} else {
resolve();
}
},
onFailed: () => resolve(),
});
});
}
function registerGlobalListeners(app) {
if (!wx.goEasy || !wx.goEasy.im) return;
if (_convListener) {
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.CONVERSATIONS_UPDATED, _convListener);
}
if (_privateListener) {
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.PRIVATE_MESSAGE_RECEIVED, _privateListener);
}
if (_groupListener) {
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.GROUP_MESSAGE_RECEIVED, _groupListener);
}
_convListener = (result) => {
emitConversationsUpdated(app, result);
};
wx.goEasy.im.on(wx.GoEasy.IM_EVENT.CONVERSATIONS_UPDATED, _convListener);
_privateListener = () => {
loadConversations(app);
};
wx.goEasy.im.on(wx.GoEasy.IM_EVENT.PRIVATE_MESSAGE_RECEIVED, _privateListener);
_groupListener = () => {
loadConversations(app);
};
wx.goEasy.im.on(wx.GoEasy.IM_EVENT.GROUP_MESSAGE_RECEIVED, _groupListener);
}
function loadConversations(app) {
if (!wx.goEasy || !wx.goEasy.im) return;
if (!getCurrentUserId()) return;
wx.goEasy.im.latestConversations({
onSuccess: (result) => {
emitConversationsUpdated(app, result);
subscribeAllGroups(app);
},
onFailed: (err) => {
console.error('加载会话失败', err);
},
});
}
function updateTabBarBadge(app, unreadCount) {
const badgeText = unreadCount > 0 ? (unreadCount > 99 ? '99+' : String(unreadCount)) : '';
if (!app.globalData.messageManager) app.globalData.messageManager = {};
app.globalData.messageManager.unreadTotal = unreadCount;
app.globalData.messageManager.tabBarBadgeText = badgeText;
app.emitEvent('tabBarBadgeChanged', { badgeText, showRedDot: unreadCount > 0 });
try {
const pages = getCurrentPages();
if (pages.length) {
const page = pages[pages.length - 1];
const tabBar = page.selectComponent('#custom-tab-bar');
if (tabBar && tabBar.setData) tabBar.setData({ badgeText });
if (page.getTabBar) {
const tb = page.getTabBar();
if (tb && tb.setData) tb.setData({ badgeText });
}
}
} catch (e) {}
wx.setStorageSync('messageUnreadTotal', unreadCount);
}
function registerNotification(app) {
if (!wx.goEasy || !wx.goEasy.im) return;
if (_notificationHandler) {
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.PRIVATE_MESSAGE_RECEIVED, _notificationHandler);
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.GROUP_MESSAGE_RECEIVED, _notificationHandler);
}
_notificationHandler = (message) => {
if (app.globalData.messageManager && app.globalData.messageManager.notificationMuted) return;
if (!shouldShowNotification(message)) return;
const pages = getCurrentPages();
if (pages.length) {
const curPage = pages[pages.length - 1];
const route = curPage.route || '';
if (route === 'pages/liaotian/liaotian' || route === 'pages/qunliaotian/qunliaotian') return;
}
const senderName = message.senderData?.name || (message.senderId || '用户');
let content = '';
if (message.type === 'text') content = message.payload?.text || '[文本]';
else if (message.type === 'image') content = '[图片]';
else if (message.type === 'audio') content = '[语音]';
else content = '[新消息]';
const avatar = resolveAvatarUrl(message.senderData?.avatar, app);
if (app.globalData.globalNotification && app.globalData.globalNotification.show) {
app.globalData.globalNotification.show({
senderName,
content,
avatar,
message,
notificationType: message.groupId ? 'group' : 'private',
groupId: message.groupId,
orderId: message.orderId,
});
} else {
wx.showToast({ title: `${senderName}: ${content}`, icon: 'none', duration: 2000 });
}
};
wx.goEasy.im.on(wx.GoEasy.IM_EVENT.PRIVATE_MESSAGE_RECEIVED, _notificationHandler);
wx.goEasy.im.on(wx.GoEasy.IM_EVENT.GROUP_MESSAGE_RECEIVED, _notificationHandler);
}
function detachGlobalListeners() {
if (!wx.goEasy || !wx.goEasy.im) return;
if (_convListener) {
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.CONVERSATIONS_UPDATED, _convListener);
_convListener = null;
}
if (_privateListener) {
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.PRIVATE_MESSAGE_RECEIVED, _privateListener);
_privateListener = null;
}
if (_groupListener) {
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.GROUP_MESSAGE_RECEIVED, _groupListener);
_groupListener = null;
}
if (_notificationHandler) {
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.PRIVATE_MESSAGE_RECEIVED, _notificationHandler);
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.GROUP_MESSAGE_RECEIVED, _notificationHandler);
_notificationHandler = null;
}
_listenersBoundForUser = null;
}
function disconnectGoEasy(app) {
stopHeartbeat(app);
detachGlobalListeners();
if (wx.goEasy && wx.goEasy.disconnect) {
wx.goEasy.disconnect({ onSuccess: () => {}, onFailed: () => {} });
}
wx.removeStorageSync('savedGoEasyConnection');
}
async function switchRoleAndReconnect(app, newRole) {
disconnectGoEasy(app);
app.globalData.currentRole = newRole;
wx.setStorageSync('currentRole', newRole);
if (app.globalData.primaryRole !== newRole && ['normal', 'dashou', 'shangjia'].includes(newRole)) {
app.globalData.primaryRole = newRole;
wx.setStorageSync('primaryRole', newRole);
}
startHeartbeat(app);
await ensureConnection(app);
return true;
}
function startHeartbeat(app) {
stopHeartbeat(app);
_heartbeatTimer = setInterval(() => {
if (!wx.getStorageSync('uid')) return;
if (isConnected()) {
loadConversations(app);
} else {
ensureConnection(app);
}
}, 45000);
}
function stopHeartbeat(app) {
if (_heartbeatTimer) {
clearInterval(_heartbeatTimer);
_heartbeatTimer = null;
}
}
function initAppStateListener(app) {
wx.onAppShow(() => {
setTimeout(() => {
if (!wx.getStorageSync('uid')) return;
if (!isConnected()) {
ensureConnection(app);
} else {
loadConversations(app);
setTimeout(() => {
const unread = (app.globalData.messageManager && app.globalData.messageManager.unreadTotal) || 0;
updateTabBarBadge(app, unread);
}, 300);
}
}, 200);
});
}
function initNetworkListener(app) {
wx.onNetworkStatusChange((res) => {
if (res.isConnected) {
setTimeout(() => ensureConnection(app), 1000);
}
});
}
module.exports = { initGlobalMessageSystem };
// utils/chat-core.js — 全局 IM 连接、监听、角标（稳定版）
import GoEasy from '../static/lib/goeasy-2.13.24.esm.min';
import { resolveAvatarUrl } from './avatar.js';
import { getLocalImUserId, getLocalImIdentity } from './im-user.js';
let _convListener = null;
let _privateListener = null;
let _groupListener = null;
let _notificationHandler = null;
let _heartbeatTimer = null;
let _listenersBoundForUser = null;
let _lastGroupSubscribeAt = 0;
const _notifiedMessageIds = new Map();
const NOTIFY_MAX_AGE_MS = 15000;
function shouldShowNotification(message) {
if (!message) return false;
const id = message.messageId || `${message.senderId}_${message.timestamp}`;
if (_notifiedMessageIds.has(id)) return false;
if (message.timestamp && Date.now() - message.timestamp > NOTIFY_MAX_AGE_MS) return false;
_notifiedMessageIds.set(id, Date.now());
if (_notifiedMessageIds.size > 400) {
const cutoff = Date.now() - 60000;
_notifiedMessageIds.forEach((t, k) => {
if (t < cutoff) _notifiedMessageIds.delete(k);
});
}
return true;
}
function bindGlobalListenersIfNeeded(app, userId) {
if (_listenersBoundForUser === userId && _convListener) return;
registerGlobalListeners(app);
registerNotification(app);
_listenersBoundForUser = userId;
}
function initGlobalMessageSystem(app) {
app.ensureConnection = () => ensureConnection(app);
app.connectForCurrentRole = () => ensureConnection(app);
app.loadConversations = () => loadConversations(app);
app.disconnectGoEasy = () => disconnectGoEasy(app);
app.switchRoleAndReconnect = (newRole) => switchRoleAndReconnect(app, newRole);
app.updateUnreadCount = (count) => updateTabBarBadge(app, count || 0);
app.reregisterNotification = () => registerNotification(app);
app.startImWhenReady = () => startImWhenReady(app);
if (!app.globalData.messageManager) {
app.globalData.messageManager = {};
}
try {
const muted = wx.getStorageSync('notificationMuted');
if (muted !== undefined) app.globalData.messageManager.notificationMuted = muted;
} catch (e) {}
initAppStateListener(app);
initNetworkListener(app);
startHeartbeat(app);
startImWhenReady(app);
}
/** GoEasy 未就绪时轮询，登录后尽早建立监听 */
function startImWhenReady(app, maxAttempts = 40) {
let attempts = 0;
const tick = () => {
if (!wx.getStorageSync('uid')) return;
attempts += 1;
if (!wx.goEasy) {
if (attempts < maxAttempts) setTimeout(tick, 250);
return;
}
ensureConnection(app);
};
tick();
}
function getCurrentUserId() {
return (wx.goEasy && wx.goEasy.im && wx.goEasy.im.userId) || null;
}
function getConnectionStatus() {
if (!wx.goEasy || !wx.goEasy.getConnectionStatus) return 'disconnected';
return wx.goEasy.getConnectionStatus();
}
function isConnected() {
const s = getConnectionStatus();
return s === 'connected' || s === 'reconnected';
}
/** 统一会话数据结构，避免不同回调格式导致列表空白 */
function normalizeConversationsPayload(result) {
if (!result) return { conversations: [], unreadTotal: 0 };
const content = result.content || result;
const conversations = content.conversations || result.conversations || [];
const unreadTotal = content.unreadTotal ?? result.unreadTotal ?? 0;
return { conversations, unreadTotal };
}
function emitConversationsUpdated(app, result) {
const payload = normalizeConversationsPayload(result);
updateTabBarBadge(app, payload.unreadTotal);
app.emitEvent('conversationsUpdated', {
content: payload,
unreadTotal: payload.unreadTotal,
raw: result,
});
}
async function ensureConnection(app) {
const uid = wx.getStorageSync('uid');
if (!uid || !wx.goEasy) return;
const targetUserId = getLocalImUserId(app);
const identityType = getLocalImIdentity(app);
if (!targetUserId) return;
if (isConnected()) {
const currentUserId = getCurrentUserId();
if (currentUserId === targetUserId) {
bindGlobalListenersIfNeeded(app, targetUserId);
loadConversations(app);
const now = Date.now();
if (now - _lastGroupSubscribeAt > 60000) {
_lastGroupSubscribeAt = now;
await subscribeAllGroups(app);
}
return;
}
try {
wx.goEasy.disconnect();
} catch (e) {}
}
connectGoEasy(app, targetUserId, identityType);
}
function connectGoEasy(app, userId, identityType) {
const defAvatar = resolveAvatarUrl('', app);
const tx = wx.getStorageSync('touxiang') || '';
const uid = wx.getStorageSync('uid') || '';
const nick = wx.getStorageSync('nicheng') || app.globalData.nicheng || app.globalData.dashouNicheng || '';
const name = nick || ('用户' + (uid || '').substring(0, 6));
const avatar = resolveAvatarUrl(tx, app) || defAvatar;
wx.goEasy.connect({
id: userId,
data: {
name,
avatar,
identityType: identityType === 'normal' ? 'boss' : identityType,
},
onSuccess: async () => {
try {
wx.setStorageSync('savedGoEasyConnection', JSON.stringify({
userId,
identityType,
lastConnectTime: Date.now(),
status: 'connected',
}));
} catch (e) {}
bindGlobalListenersIfNeeded(app, userId);
_lastGroupSubscribeAt = Date.now();
await subscribeAllGroups(app);
loadConversations(app);
},
onFailed: (error) => {
console.error('GoEasy连接失败', error);
if (error.code === 408) {
bindGlobalListenersIfNeeded(app, userId);
loadConversations(app);
} else {
wx.showToast({ title: '连接失败，请重试', icon: 'none' });
}
},
});
}
function subscribeAllGroups(app) {
return new Promise((resolve) => {
if (!wx.goEasy || !wx.goEasy.im) return resolve();
wx.goEasy.im.latestConversations({
onSuccess: (result) => {
const payload = normalizeConversationsPayload(result);
const groupIds = payload.conversations
.filter((c) => c.type === 'group' && c.groupId)
.map((c) => c.groupId);
if (groupIds.length && wx.goEasy.im.subscribeGroup) {
wx.goEasy.im.subscribeGroup({
groupIds,
onSuccess: () => resolve(),
onFailed: () => resolve(),
});
} else {
resolve();
}
},
onFailed: () => resolve(),
});
});
}
function registerGlobalListeners(app) {
if (!wx.goEasy || !wx.goEasy.im) return;
if (_convListener) {
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.CONVERSATIONS_UPDATED, _convListener);
}
if (_privateListener) {
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.PRIVATE_MESSAGE_RECEIVED, _privateListener);
}
if (_groupListener) {
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.GROUP_MESSAGE_RECEIVED, _groupListener);
}
_convListener = (result) => {
emitConversationsUpdated(app, result);
};
wx.goEasy.im.on(wx.GoEasy.IM_EVENT.CONVERSATIONS_UPDATED, _convListener);
_privateListener = () => {
loadConversations(app);
};
wx.goEasy.im.on(wx.GoEasy.IM_EVENT.PRIVATE_MESSAGE_RECEIVED, _privateListener);
_groupListener = () => {
loadConversations(app);
};
wx.goEasy.im.on(wx.GoEasy.IM_EVENT.GROUP_MESSAGE_RECEIVED, _groupListener);
}
function loadConversations(app) {
if (!wx.goEasy || !wx.goEasy.im) return;
if (!getCurrentUserId()) return;
wx.goEasy.im.latestConversations({
onSuccess: (result) => {
emitConversationsUpdated(app, result);
subscribeAllGroups(app);
},
onFailed: (err) => {
console.error('加载会话失败', err);
},
});
}
function updateTabBarBadge(app, unreadCount) {
const badgeText = unreadCount > 0 ? (unreadCount > 99 ? '99+' : String(unreadCount)) : '';
if (!app.globalData.messageManager) app.globalData.messageManager = {};
app.globalData.messageManager.unreadTotal = unreadCount;
app.globalData.messageManager.tabBarBadgeText = badgeText;
app.emitEvent('tabBarBadgeChanged', { badgeText, showRedDot: unreadCount > 0 });
try {
const pages = getCurrentPages();
if (pages.length) {
const page = pages[pages.length - 1];
const tabBar = page.selectComponent('#custom-tab-bar');
if (tabBar && tabBar.setData) tabBar.setData({ badgeText });
if (page.getTabBar) {
const tb = page.getTabBar();
if (tb && tb.setData) tb.setData({ badgeText });
}
}
} catch (e) {}
wx.setStorageSync('messageUnreadTotal', unreadCount);
}
function registerNotification(app) {
if (!wx.goEasy || !wx.goEasy.im) return;
if (_notificationHandler) {
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.PRIVATE_MESSAGE_RECEIVED, _notificationHandler);
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.GROUP_MESSAGE_RECEIVED, _notificationHandler);
}
_notificationHandler = (message) => {
if (app.globalData.messageManager && app.globalData.messageManager.notificationMuted) return;
if (!shouldShowNotification(message)) return;
const pages = getCurrentPages();
if (pages.length) {
const curPage = pages[pages.length - 1];
const route = curPage.route || '';
if (route === 'pages/chat/chat' || route === 'pages/group-chat/group-chat') return;
}
const senderName = message.senderData?.name || (message.senderId || '用户');
let content = '';
if (message.type === 'text') content = message.payload?.text || '[文本]';
else if (message.type === 'image') content = '[图片]';
else if (message.type === 'audio') content = '[语音]';
else content = '[新消息]';
const avatar = resolveAvatarUrl(message.senderData?.avatar, app);
if (app.globalData.globalNotification && app.globalData.globalNotification.show) {
app.globalData.globalNotification.show({
senderName,
content,
avatar,
message,
notificationType: message.groupId ? 'group' : 'private',
groupId: message.groupId,
orderId: message.orderId,
});
} else {
wx.showToast({ title: `${senderName}: ${content}`, icon: 'none', duration: 2000 });
}
};
wx.goEasy.im.on(wx.GoEasy.IM_EVENT.PRIVATE_MESSAGE_RECEIVED, _notificationHandler);
wx.goEasy.im.on(wx.GoEasy.IM_EVENT.GROUP_MESSAGE_RECEIVED, _notificationHandler);
}
function detachGlobalListeners() {
if (!wx.goEasy || !wx.goEasy.im) return;
if (_convListener) {
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.CONVERSATIONS_UPDATED, _convListener);
_convListener = null;
}
if (_privateListener) {
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.PRIVATE_MESSAGE_RECEIVED, _privateListener);
_privateListener = null;
}
if (_groupListener) {
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.GROUP_MESSAGE_RECEIVED, _groupListener);
_groupListener = null;
}
if (_notificationHandler) {
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.PRIVATE_MESSAGE_RECEIVED, _notificationHandler);
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.GROUP_MESSAGE_RECEIVED, _notificationHandler);
_notificationHandler = null;
}
_listenersBoundForUser = null;
}
function disconnectGoEasy(app) {
stopHeartbeat(app);
detachGlobalListeners();
if (wx.goEasy && wx.goEasy.disconnect) {
wx.goEasy.disconnect({ onSuccess: () => {}, onFailed: () => {} });
}
wx.removeStorageSync('savedGoEasyConnection');
}
async function switchRoleAndReconnect(app, newRole) {
disconnectGoEasy(app);
app.globalData.currentRole = newRole;
wx.setStorageSync('currentRole', newRole);
if (app.globalData.primaryRole !== newRole && ['normal', 'dashou', 'shangjia'].includes(newRole)) {
app.globalData.primaryRole = newRole;
wx.setStorageSync('primaryRole', newRole);
}
startHeartbeat(app);
await ensureConnection(app);
return true;
}
function startHeartbeat(app) {
stopHeartbeat(app);
_heartbeatTimer = setInterval(() => {
if (!wx.getStorageSync('uid')) return;
if (isConnected()) {
loadConversations(app);
} else {
ensureConnection(app);
}
}, 45000);
}
function stopHeartbeat(app) {
if (_heartbeatTimer) {
clearInterval(_heartbeatTimer);
_heartbeatTimer = null;
}
}
function initAppStateListener(app) {
wx.onAppShow(() => {
setTimeout(() => {
if (!wx.getStorageSync('uid')) return;
if (!isConnected()) {
ensureConnection(app);
} else {
loadConversations(app);
setTimeout(() => {
const unread = (app.globalData.messageManager && app.globalData.messageManager.unreadTotal) || 0;
updateTabBarBadge(app, unread);
}, 300);
}
}, 200);
});
}
function initNetworkListener(app) {
wx.onNetworkStatusChange((res) => {
if (res.isConnected) {
setTimeout(() => ensureConnection(app), 1000);
}
});
}
module.exports = { initGlobalMessageSystem };