1290 lines
36 KiB
JavaScript
1290 lines
36 KiB
JavaScript
// 消息页面逻辑 - 完全基于 NIM SDK
|
||
const app = getApp();
|
||
const apiClient = require('../../utils/api-client.js');
|
||
const nimConversationManager = require('../../utils/nim-conversation-manager.js');
|
||
const nimPresenceManager = require('../../utils/nim-presence-manager.js');
|
||
const { initPageSystemInfo } = require('../../utils/system-info-modern.js');
|
||
|
||
Page({
|
||
data: {
|
||
//模拟数据
|
||
store:[{
|
||
avatar:'../../images/group/testImg.jpg',
|
||
nickname:'Jianying Liu',
|
||
text:'Heyyy',
|
||
tiem:'16:30'
|
||
}],
|
||
searchKeyword: '',
|
||
refreshing: false,
|
||
loading: false,
|
||
longPressing: false, // 长按标记，防止长按后触发单击
|
||
|
||
|
||
// 会话数据
|
||
conversations: [],
|
||
pinnedConversations: [],
|
||
normalConversations: [],
|
||
totalUnreadCount: 0,
|
||
filteredConversations: [],
|
||
|
||
// NIM SDK 状态
|
||
nimReady: false,
|
||
|
||
// 系统适配信息
|
||
systemInfo: {},
|
||
statusBarHeight: 0,
|
||
menuButtonHeight: 0,
|
||
menuButtonTop: 0,
|
||
navBarHeight: 0,
|
||
windowHeight: 0,
|
||
safeAreaBottom: 0,
|
||
showSearch: false,
|
||
|
||
// 本地模糊搜索增强
|
||
searching: false,
|
||
conversationSamples: {},
|
||
sampleLoading: {},
|
||
lastSearchKeyword: ''
|
||
},
|
||
|
||
// 统一时间戳规范化
|
||
normalizeTimestamp(ts) {
|
||
if (!ts && ts !== 0) return 0;
|
||
if (typeof ts === 'number' && isFinite(ts)) return ts;
|
||
if (typeof ts === 'string') {
|
||
const s = ts.trim();
|
||
if (!s) return 0;
|
||
if (/^\d+$/.test(s)) {
|
||
const n = parseInt(s, 10);
|
||
return s.length === 10 ? n * 1000 : n;
|
||
}
|
||
const d = Date.parse(s);
|
||
return isNaN(d) ? 0 : d;
|
||
}
|
||
try {
|
||
const d = new Date(ts).getTime();
|
||
return isNaN(d) ? 0 : d;
|
||
} catch (_) {
|
||
return 0;
|
||
}
|
||
},
|
||
|
||
/**
|
||
* 从会话数据中提取真实的用户ID
|
||
* @param {Object} conv - 会话对象
|
||
* @returns {string} - 用户ID
|
||
*/
|
||
extractUserIdFromConversation(conv) {
|
||
let userId = conv.targetId || conv.userId || '';
|
||
|
||
// 如果 targetId 是 conversationId 格式（包含|符号），则解析
|
||
if (userId && typeof userId === 'string' && userId.includes('|')) {
|
||
const parts = userId.split('|');
|
||
if (parts.length === 3) {
|
||
userId = parts[2]; // 提取目标用户ID
|
||
}
|
||
}
|
||
|
||
// 如果还是没有，尝试从 conversationId 解析
|
||
if (!userId && conv.conversationId && typeof conv.conversationId === 'string') {
|
||
const parts = conv.conversationId.split('|');
|
||
if (parts.length === 3) {
|
||
userId = parts[2];
|
||
}
|
||
}
|
||
|
||
return userId || '';
|
||
},
|
||
|
||
// 页面加载
|
||
onLoad: function (options) {
|
||
const { store } = this.data;
|
||
// 生成10次重复的数组（fill+flat 一行实现）
|
||
const repeatedArr = Array(20).fill(store).flat();
|
||
// 响应式更新：必须用 setData，页面才会渲染新数组
|
||
this.setData({ repeatedArr });
|
||
|
||
|
||
this.initSystemInfo();
|
||
this.checkAuthAndInit();
|
||
|
||
wx.setNavigationBarTitle({ title: '消息' });
|
||
},
|
||
|
||
// 检查认证状态并初始化
|
||
async checkAuthAndInit() {
|
||
try {
|
||
const currentToken = apiClient.getToken();
|
||
const app = getApp();
|
||
const isLoggedIn = app?.globalData?.isLoggedIn || false;
|
||
|
||
console.log('检查认证状态:', { hasToken: !!currentToken, isLoggedIn });
|
||
|
||
if (!currentToken || !isLoggedIn) {
|
||
console.warn('⚠️ 用户未登录，跳转到登录页');
|
||
this.redirectToLogin('checkAuthAndInit');
|
||
return;
|
||
}
|
||
|
||
// 初始化 NIM 模式
|
||
await this.initNIMMode();
|
||
} catch (error) {
|
||
console.error('认证检查失败:', error);
|
||
wx.showToast({
|
||
title: `NIM初始化失败:${error}`,
|
||
icon: 'none'
|
||
});
|
||
}
|
||
},
|
||
|
||
// 统一的登录页跳转方法
|
||
redirectToLogin(source) {
|
||
if (this.redirecting) {
|
||
console.log('已在跳转中，跳过');
|
||
return;
|
||
}
|
||
|
||
this.redirecting = true;
|
||
console.log(`🔄 来自${source}的跳转请求，执行跳转...`);
|
||
|
||
setTimeout(() => {
|
||
wx.reLaunch({
|
||
url: '/pages/login/login',
|
||
success: () => {
|
||
console.log('✅ 跳转登录页成功');
|
||
this.redirecting = false;
|
||
},
|
||
fail: (err) => {
|
||
console.error('❌ 跳转登录页失败:', err);
|
||
this.redirecting = false;
|
||
}
|
||
});
|
||
}, 1000);
|
||
},
|
||
|
||
// 初始化系统信息
|
||
initSystemInfo() {
|
||
const pageSystemInfo = initPageSystemInfo();
|
||
|
||
this.setData({
|
||
systemInfo: pageSystemInfo.systemInfo,
|
||
statusBarHeight: pageSystemInfo.statusBarHeight,
|
||
menuButtonHeight: pageSystemInfo.menuButtonHeight,
|
||
menuButtonTop: pageSystemInfo.menuButtonTop,
|
||
navBarHeight: pageSystemInfo.navBarHeight,
|
||
windowHeight: pageSystemInfo.windowHeight,
|
||
safeAreaBottom: pageSystemInfo.safeAreaBottom
|
||
});
|
||
},
|
||
|
||
// 初始化 NIM 模式
|
||
initNIMMode() {
|
||
try {
|
||
console.log('📡 初始化 NIM 模式');
|
||
|
||
const app = getApp();
|
||
if (!app.globalData.nim) {
|
||
console.error('❌ NIM 实例未初始化');
|
||
wx.showToast({
|
||
title: 'NIM未初始化',
|
||
icon: 'none'
|
||
});
|
||
return;
|
||
}
|
||
|
||
// 注册 NIM 事件监听器
|
||
nimConversationManager.on('conversation_created', this.handleNIMConversationCreated.bind(this));
|
||
nimConversationManager.on('conversation_deleted', this.handleNIMConversationDeleted.bind(this));
|
||
nimConversationManager.on('conversation_changed', this.handleNIMConversationChanged.bind(this));
|
||
nimConversationManager.on('new_message', this.handleNIMNewMessages.bind(this));
|
||
nimConversationManager.on('message_revoked', this.handleNIMMessageRevoked.bind(this));
|
||
|
||
// 🔥 注册在线状态变化监听
|
||
nimPresenceManager.on('presence_changed', this.handlePresenceChanged.bind(this));
|
||
|
||
this.setData({ nimReady: true });
|
||
|
||
// 加载会话列表
|
||
this.loadConversations();
|
||
|
||
console.log('✅ NIM 模式初始化完成');
|
||
} catch (error) {
|
||
console.error('❌ 初始化 NIM 模式失败:', error);
|
||
wx.showToast({
|
||
title: '初始化 NIM 模式失败',
|
||
icon: 'none'
|
||
});
|
||
}
|
||
},
|
||
|
||
// 🔥 检查并重连 NIM（页面级别）
|
||
async checkAndReconnectNim() {
|
||
try {
|
||
const app = getApp();
|
||
|
||
// 如果 NIM 未就绪，尝试初始化
|
||
if (!this.data.nimReady) {
|
||
console.log('⚠️ 页面 NIM 未就绪，尝试初始化');
|
||
await this.checkAuthAndInit();
|
||
return;
|
||
}
|
||
|
||
// 触发全局 NIM 重连检查
|
||
if (app && typeof app.checkAndReconnectNim === 'function') {
|
||
await app.checkAndReconnectNim();
|
||
}
|
||
|
||
// 重新初始化会话管理器（确保事件监听器有效）
|
||
if (app.globalData.nim) {
|
||
const nim = app.globalData.nim;
|
||
|
||
// 检查会话管理器是否已初始化
|
||
if (!nimConversationManager.getInitStatus()) {
|
||
console.log('🔄 重新初始化会话管理器');
|
||
nimConversationManager.init(nim);
|
||
}
|
||
|
||
// 检查在线状态管理器是否已初始化
|
||
if (!nimPresenceManager.getInitStatus()) {
|
||
console.log('🔄 重新初始化在线状态管理器');
|
||
nimPresenceManager.init(nim);
|
||
}
|
||
}
|
||
} catch (error) {
|
||
console.error('❌ 页面级 NIM 重连检查失败:', error);
|
||
}
|
||
},
|
||
|
||
// ===== NIM 事件处理方法 =====
|
||
|
||
// 处理 NIM 会话新增
|
||
handleNIMConversationCreated(conversation) {
|
||
console.log('📝 处理NIM会话新增:', conversation);
|
||
const conversations = [conversation, ...this.data.conversations];
|
||
this.processConversations(conversations);
|
||
this.playMessageSound();
|
||
},
|
||
|
||
// 处理 NIM 会话删除
|
||
handleNIMConversationDeleted(conversationIds) {
|
||
console.log('🗑️ 处理NIM会话删除:', conversationIds);
|
||
const conversations = this.data.conversations.filter(
|
||
conv => !conversationIds.includes(conv.conversationId)
|
||
);
|
||
this.processConversations(conversations);
|
||
},
|
||
|
||
// 处理 NIM 会话更新
|
||
handleNIMConversationChanged(changedConversations) {
|
||
console.log('🔄 处理NIM会话更新，数量:', changedConversations?.length || 0);
|
||
|
||
if (!Array.isArray(changedConversations) || changedConversations.length === 0) {
|
||
return;
|
||
}
|
||
|
||
// 🔥 增量更新：只更新变化的会话，而不是替换整个列表
|
||
let conversations = [...this.data.conversations];
|
||
let hasChanges = false;
|
||
|
||
changedConversations.forEach(changedConv => {
|
||
const index = conversations.findIndex(
|
||
conv => conv.conversationId === changedConv.conversationId
|
||
);
|
||
|
||
if (index >= 0) {
|
||
// 检查是否真的有变化（避免不必要的更新）
|
||
const oldConv = conversations[index];
|
||
const hasRealChange =
|
||
oldConv.unreadCount !== changedConv.unreadCount ||
|
||
oldConv.lastMessage !== changedConv.lastMessage ||
|
||
oldConv.isPinned !== changedConv.isPinned ||
|
||
oldConv.isMuted !== changedConv.isMuted;
|
||
|
||
if (hasRealChange) {
|
||
// 🔥 特殊处理：如果旧会话有未读数，新会话未读数为0，但最后消息没变
|
||
// 说明这可能是标记已读导致的更新，不应该覆盖可能正在到来的新消息未读数
|
||
if (oldConv.unreadCount > 0 && changedConv.unreadCount === 0 &&
|
||
oldConv.lastMessage === changedConv.lastMessage) {
|
||
console.log('⚠️ 检测到可能的标记已读事件，保留当前未读数');
|
||
changedConv.unreadCount = oldConv.unreadCount;
|
||
}
|
||
conversations[index] = changedConv;
|
||
hasChanges = true;
|
||
}
|
||
} else {
|
||
// 新会话，添加到列表
|
||
conversations.unshift(changedConv);
|
||
hasChanges = true;
|
||
}
|
||
});
|
||
|
||
// 只有真正有变化时才更新 UI
|
||
if (hasChanges) {
|
||
this.processConversations(conversations);
|
||
} else {
|
||
console.log('⚠️ 会话数据无实质变化，跳过更新');
|
||
}
|
||
},
|
||
|
||
// 处理 NIM 新消息
|
||
async handleNIMNewMessages(messages) {
|
||
console.log('📨 处理NIM新消息:', messages);
|
||
|
||
if (!Array.isArray(messages)) return;
|
||
|
||
let conversations = [...this.data.conversations];
|
||
let hasChanges = false;
|
||
let needReloadConversations = false;
|
||
|
||
messages.forEach(message => {
|
||
const conversationId = message.conversationId;
|
||
if (!conversationId) return;
|
||
|
||
const index = conversations.findIndex(
|
||
conv => conv.conversationId === conversationId
|
||
);
|
||
|
||
if (index >= 0) {
|
||
// 更新现有会话
|
||
// 🔥 使用消息的 createTime，如果没有则保持原时间
|
||
const messageTime = message.createTime || conversations[index].lastMsgTime || 0;
|
||
conversations[index] = {
|
||
...conversations[index],
|
||
lastMessage: nimConversationManager.getMessagePreview(message),
|
||
lastMessageType: nimConversationManager.getMessageType(message),
|
||
lastMessageTime: nimConversationManager.formatMessageTime(messageTime),
|
||
lastMsgTime: messageTime,
|
||
unreadCount: (conversations[index].unreadCount || 0) + 1
|
||
};
|
||
hasChanges = true;
|
||
} else {
|
||
// 新会话，需要重新加载
|
||
console.log('⚠️ 收到新会话消息，需要重新加载会话列表');
|
||
needReloadConversations = true;
|
||
}
|
||
});
|
||
|
||
if (hasChanges) {
|
||
this.processConversations(conversations);
|
||
this.playMessageSound();
|
||
}
|
||
|
||
if (needReloadConversations) {
|
||
this.loadConversations();
|
||
}
|
||
},
|
||
|
||
// 处理 NIM 消息撤回
|
||
handleNIMMessageRevoked(revokeNotifications) {
|
||
console.log('↩️ 处理NIM消息撤回:', revokeNotifications);
|
||
|
||
if (!Array.isArray(revokeNotifications)) return;
|
||
|
||
let conversations = [...this.data.conversations];
|
||
let hasChanges = false;
|
||
|
||
revokeNotifications.forEach(notification => {
|
||
const conversationId = notification.conversationId;
|
||
if (!conversationId) return;
|
||
|
||
const index = conversations.findIndex(
|
||
conv => conv.conversationId === conversationId
|
||
);
|
||
|
||
if (index >= 0) {
|
||
conversations[index] = {
|
||
...conversations[index],
|
||
lastMessage: '已撤回'
|
||
};
|
||
hasChanges = true;
|
||
}
|
||
});
|
||
|
||
if (hasChanges) {
|
||
this.processConversations(conversations);
|
||
}
|
||
},
|
||
|
||
// 🔥 处理用户在线状态变化
|
||
handlePresenceChanged(data) {
|
||
const { userId, isOnline } = data;
|
||
|
||
// 更新会话列表中对应用户的在线状态
|
||
let conversations = [...this.data.conversations];
|
||
let hasChanges = false;
|
||
|
||
conversations.forEach(conv => {
|
||
// 判断是否为单聊会话
|
||
const isSingleChat = conv.type === 'single' || conv.type === 0 || conv.chatType === 0;
|
||
|
||
if (!isSingleChat) {
|
||
return;
|
||
}
|
||
|
||
// 提取真实的用户ID进行匹配
|
||
let targetId = conv.targetId;
|
||
|
||
// 如果 targetId 包含 | 符号，说明是 conversationId 格式，需要解析
|
||
if (targetId && typeof targetId === 'string' && targetId.includes('|')) {
|
||
const parts = targetId.split('|');
|
||
if (parts.length === 3) {
|
||
targetId = parts[2];
|
||
conv.targetId = targetId; // 更新为纯用户ID
|
||
}
|
||
}
|
||
|
||
if (targetId === userId) {
|
||
conv.isOnline = isOnline;
|
||
hasChanges = true;
|
||
}
|
||
});
|
||
|
||
if (hasChanges) {
|
||
this.processConversations(conversations);
|
||
}
|
||
},
|
||
|
||
// 加载会话列表
|
||
async loadConversations() {
|
||
if (this.data.loading) return;
|
||
|
||
const currentToken = apiClient.getToken();
|
||
if (!currentToken) {
|
||
console.warn('⚠️ Token 丢失，无法加载会话列表');
|
||
return;
|
||
}
|
||
|
||
try {
|
||
this.setData({ loading: true });
|
||
|
||
console.log('📋 从 NIM SDK 加载会话列表');
|
||
const conversations = await nimConversationManager.getConversationList(0, 100);
|
||
|
||
console.log('✅ 加载会话列表成功，数量:', conversations.length);
|
||
|
||
this.processConversations(conversations);
|
||
} catch (error) {
|
||
console.error('❌ 加载会话列表失败:', error);
|
||
wx.showToast({
|
||
title: `加载会话列表失败:${error}`,
|
||
icon: 'none'
|
||
});
|
||
} finally {
|
||
this.setData({ loading: false });
|
||
}
|
||
},
|
||
|
||
// 播放消息提示音
|
||
playMessageSound() {
|
||
try {
|
||
const innerAudioContext = wx.createInnerAudioContext();
|
||
innerAudioContext.src = '/images/message-sound.mp3';
|
||
innerAudioContext.play();
|
||
} catch (error) {
|
||
console.error('播放提示音失败:', error);
|
||
}
|
||
},
|
||
|
||
// 更新Tab角标
|
||
updateTabBadge() {
|
||
const totalUnread = this.data.totalUnreadCount;
|
||
if (totalUnread > 0) {
|
||
wx.setTabBarBadge({
|
||
index: 1,
|
||
text: totalUnread > 99 ? '99+' : totalUnread.toString()
|
||
});
|
||
} else {
|
||
wx.removeTabBarBadge({ index: 1 });
|
||
}
|
||
|
||
// 自定义TabBar同步
|
||
try {
|
||
if (typeof this.getTabBar === 'function' && this.getTabBar()) {
|
||
this.getTabBar().setMessagesBadge(totalUnread);
|
||
}
|
||
} catch (_) { }
|
||
},
|
||
|
||
// 处理会话数据
|
||
async processConversations(conversations) {
|
||
// 过滤已删除项，并统一关键字段
|
||
const validList = (conversations || [])
|
||
.filter(it => it && !it.deleted && !it._deleted)
|
||
.map(it => ({
|
||
...it,
|
||
isPinned: !!(it.isPinned || it.isTop),
|
||
_ts: this.normalizeTimestamp(it.lastMsgTime || it.lastMessageTimeTs || it.lastActiveAt || it.updatedAt)
|
||
}));
|
||
|
||
// 🔥 订阅会话中单聊用户的在线状态
|
||
try {
|
||
await nimPresenceManager.subscribeConversations(validList);
|
||
} catch (error) {
|
||
console.error('订阅在线状态失败:', error);
|
||
}
|
||
|
||
// 🔥 从缓存中更新在线状态
|
||
validList.forEach(conv => {
|
||
// 判断是否为单聊
|
||
const isSingleChat = conv.type === 'single' || conv.type === 0 || conv.chatType === 0;
|
||
|
||
if (isSingleChat) {
|
||
// 提取真实的用户ID（处理可能的 conversationId 格式）
|
||
let targetId = conv.targetId;
|
||
|
||
// 如果 targetId 包含 | 符号，说明是 conversationId 格式，需要解析
|
||
if (targetId && typeof targetId === 'string' && targetId.includes('|')) {
|
||
const parts = targetId.split('|');
|
||
if (parts.length === 3) {
|
||
targetId = parts[2];
|
||
conv.targetId = targetId; // 更新为纯用户ID
|
||
}
|
||
}
|
||
|
||
if (!targetId) {
|
||
return;
|
||
}
|
||
|
||
const presence = nimPresenceManager.getUserPresence(targetId);
|
||
|
||
if (presence) {
|
||
conv.isOnline = presence.online;
|
||
} else {
|
||
conv.isOnline = false; // 默认离线
|
||
}
|
||
}
|
||
});
|
||
|
||
// 置顶/非置顶分组并组内按时间降序
|
||
const pinnedConversations = validList
|
||
.filter(item => item.isPinned)
|
||
.sort((a, b) => b._ts - a._ts);
|
||
const normalConversations = validList
|
||
.filter(item => !item.isPinned)
|
||
.sort((a, b) => b._ts - a._ts);
|
||
|
||
let sortedAll = [...pinnedConversations, ...normalConversations];
|
||
|
||
// 应用来自聊天页的撤回提示
|
||
sortedAll = this.applyRecallHints(sortedAll);
|
||
|
||
// 基于隐藏集合过滤呈现列表
|
||
const hiddenSet = this._getHiddenConversationSet();
|
||
const filteredSorted = (sortedAll || []).filter(item =>
|
||
!hiddenSet.has(String(item.conversationId || item.id || ''))
|
||
);
|
||
|
||
const totalUnreadCount = filteredSorted.reduce((sum, item) => sum + (item.unreadCount || 0), 0);
|
||
|
||
this.setData({
|
||
conversations: sortedAll,
|
||
pinnedConversations: filteredSorted.filter(i => i.isPinned),
|
||
normalConversations: filteredSorted.filter(i => !i.isPinned),
|
||
totalUnreadCount,
|
||
filteredConversations: filteredSorted
|
||
});
|
||
|
||
// 更新角标
|
||
this.updateTabBadge();
|
||
},
|
||
|
||
// 应用撤回提示（来自 chat 页存储），TTL=2分钟
|
||
applyRecallHints(list) {
|
||
try {
|
||
const store = wx.getStorageSync('recallHints') || {};
|
||
const now = Date.now();
|
||
const TTL = 2 * 60 * 1000; // 2分钟
|
||
|
||
return list.map(conv => {
|
||
const cid = conv.conversationId || conv.id;
|
||
if (!cid) return conv;
|
||
|
||
const hint = store[cid];
|
||
if (hint && (now - hint.timestamp < TTL)) {
|
||
return {
|
||
...conv,
|
||
lastMessage: '已撤回',
|
||
lastMessageType: 'system'
|
||
};
|
||
}
|
||
return conv;
|
||
});
|
||
} catch (e) {
|
||
console.error('应用撤回提示失败:', e);
|
||
return list;
|
||
}
|
||
},
|
||
|
||
// 刷新会话列表
|
||
async refreshConversations() {
|
||
this.setData({ refreshing: true });
|
||
await this.loadConversations();
|
||
this.setData({ refreshing: false });
|
||
},
|
||
|
||
// 下拉刷新
|
||
onRefresh() {
|
||
this.refreshConversations();
|
||
},
|
||
|
||
// 搜索输入
|
||
onSearchInput(e) {
|
||
const keyword = (e.detail.value || '').trim();
|
||
this.setData({
|
||
searchKeyword: keyword,
|
||
lastSearchKeyword: keyword,
|
||
searching: !!keyword
|
||
});
|
||
|
||
if (!keyword) {
|
||
// 清空搜索结果
|
||
this.processConversations(this.data.conversations);
|
||
return;
|
||
}
|
||
|
||
// 🔥 本地会话列表过滤（快速响应）
|
||
this.fuzzyFilterConversations(keyword);
|
||
},
|
||
|
||
// 清除搜索
|
||
clearSearch() {
|
||
this.setData({
|
||
searchKeyword: '',
|
||
lastSearchKeyword: '',
|
||
searching: false
|
||
});
|
||
this.processConversations(this.data.conversations);
|
||
},
|
||
|
||
// 显示/隐藏搜索栏
|
||
showSearchBar() {
|
||
this.setData({ showSearch: true });
|
||
},
|
||
|
||
hideSearchBar() {
|
||
this.setData({
|
||
showSearch: false,
|
||
searchKeyword: '',
|
||
lastSearchKeyword: '',
|
||
searching: false
|
||
});
|
||
this.processConversations(this.data.conversations);
|
||
},
|
||
|
||
// 🔥 带搜索关键词打开聊天
|
||
openChatWithSearchKeyword(conversation, searchKeyword) {
|
||
if (!conversation.targetId) {
|
||
wx.showToast({
|
||
title: '会话信息不完整',
|
||
icon: 'none'
|
||
});
|
||
return;
|
||
}
|
||
|
||
const chatType = conversation.chatType !== undefined ? conversation.chatType : 0;
|
||
|
||
const params = {
|
||
conversationId: conversation.conversationId,
|
||
targetId: conversation.targetId,
|
||
name: encodeURIComponent(conversation.name),
|
||
chatType: chatType
|
||
};
|
||
|
||
const kw = (searchKeyword || '').trim();
|
||
if (kw) {
|
||
params.searchKeyword = encodeURIComponent(kw);
|
||
}
|
||
|
||
const queryString = Object.keys(params)
|
||
.map(key => `${key}=${params[key]}`)
|
||
.join('&');
|
||
|
||
wx.navigateTo({
|
||
url: `/pages/message/chat/chat?${queryString}`
|
||
});
|
||
},
|
||
|
||
// 本地模糊过滤
|
||
fuzzyFilterConversations(keyword) {
|
||
if (!keyword) {
|
||
this.processConversations(this.data.conversations);
|
||
return;
|
||
}
|
||
|
||
const q = (keyword || '').toLowerCase();
|
||
|
||
const subseqScore = (text, query) => {
|
||
if (!text || !query) return 0;
|
||
text = text.toLowerCase();
|
||
let ti = 0, qi = 0, matches = 0;
|
||
while (ti < text.length && qi < query.length) {
|
||
if (text[ti] === query[qi]) {
|
||
matches++;
|
||
qi++;
|
||
}
|
||
ti++;
|
||
}
|
||
return qi === query.length ? matches / text.length : 0;
|
||
};
|
||
|
||
const samples = this.data.conversationSamples || {};
|
||
const list = this.data.conversations || [];
|
||
|
||
const withScore = list.map(item => {
|
||
const nameScore = subseqScore(item.name || '', q) * 3;
|
||
const lastMsgScore = subseqScore(item.lastMessage || '', q) * 2;
|
||
const sampleTexts = samples[item.conversationId] || [];
|
||
const sampleScore = sampleTexts.reduce((acc, txt) => Math.max(acc, subseqScore(txt, q)), 0);
|
||
const totalScore = nameScore + lastMsgScore + sampleScore;
|
||
return { item, score: totalScore };
|
||
}).filter(x => x.score > 0);
|
||
|
||
withScore.sort((a, b) => {
|
||
if (Math.abs(a.score - b.score) < 0.01) {
|
||
return b.item._ts - a.item._ts;
|
||
}
|
||
return b.score - a.score;
|
||
});
|
||
|
||
let filtered = withScore.map(x => x.item);
|
||
if (filtered.length === 0) {
|
||
filtered = list.filter(item => {
|
||
const n = (item.name || '').toLowerCase();
|
||
const m = (item.lastMessage || '').toLowerCase();
|
||
return n.includes(q) || m.includes(q);
|
||
});
|
||
}
|
||
|
||
const pinnedFiltered = filtered.filter(i => i.isPinned);
|
||
const normalFiltered = filtered.filter(i => !i.isPinned);
|
||
|
||
this.setData({
|
||
pinnedConversations: pinnedFiltered,
|
||
normalConversations: normalFiltered,
|
||
filteredConversations: filtered
|
||
});
|
||
},
|
||
|
||
// 预取会话样本
|
||
async prefetchTopConversationSamples(keyword) {
|
||
const q = (keyword || '').toLowerCase();
|
||
const list = this.data.conversations || [];
|
||
|
||
const rough = list
|
||
.map(item => ({
|
||
item,
|
||
s: (String(item.name || '').toLowerCase().includes(q) ? 2 : 0) +
|
||
(String(item.lastMessage || '').toLowerCase().includes(q) ? 1 : 0)
|
||
}))
|
||
.sort((a, b) => b.s - a.s)
|
||
.slice(0, 8)
|
||
.map(x => x.item);
|
||
|
||
const tasks = [];
|
||
for (const conv of rough) {
|
||
const cid = conv.conversationId;
|
||
const loading = this.data.sampleLoading[cid];
|
||
const existing = this.data.conversationSamples[cid];
|
||
|
||
if (!loading && !existing) {
|
||
tasks.push(this.fetchConversationSample(conv));
|
||
}
|
||
}
|
||
|
||
if (tasks.length) {
|
||
await Promise.allSettled(tasks);
|
||
this.fuzzyFilterConversations(this.data.lastSearchKeyword);
|
||
}
|
||
},
|
||
|
||
async fetchConversationSample(conv) {
|
||
const cid = conv.conversationId;
|
||
try {
|
||
this.setData({
|
||
[`sampleLoading.${cid}`]: true
|
||
});
|
||
|
||
// 这里可以调用 NIM SDK 获取历史消息
|
||
// 暂时留空，等待实现
|
||
|
||
this.setData({
|
||
[`conversationSamples.${cid}`]: [],
|
||
[`sampleLoading.${cid}`]: false
|
||
});
|
||
} catch (e) {
|
||
console.error('抓取会话样本失败:', e);
|
||
this.setData({
|
||
[`sampleLoading.${cid}`]: false
|
||
});
|
||
}
|
||
},
|
||
|
||
// 打开聊天
|
||
openChat(e) {
|
||
// 如果正在长按，忽略单击事件
|
||
if (this.data.longPressing) {
|
||
console.log('长按中，忽略单击事件');
|
||
this.setData({ longPressing: false });
|
||
return;
|
||
}
|
||
|
||
const conversation = e.currentTarget.dataset.conversation;
|
||
|
||
if (!conversation.targetId) {
|
||
wx.showToast({
|
||
title: '会话信息不完整',
|
||
icon: 'none'
|
||
});
|
||
return;
|
||
}
|
||
|
||
const chatType = conversation.chatType !== undefined ? conversation.chatType : 0;
|
||
|
||
const params = {
|
||
conversationId: conversation.conversationId,
|
||
targetId: conversation.targetId,
|
||
name: encodeURIComponent(conversation.name),
|
||
chatType: chatType
|
||
};
|
||
|
||
const kw = (this.data.searchKeyword || '').trim();
|
||
if (kw) {
|
||
params.searchKeyword = encodeURIComponent(kw);
|
||
}
|
||
|
||
const queryString = Object.keys(params)
|
||
.map(key => `${key}=${params[key]}`)
|
||
.join('&');
|
||
|
||
wx.navigateTo({
|
||
url: `/pages/message/chat/chat?${queryString}`
|
||
});
|
||
},
|
||
|
||
// 显示会话选项
|
||
showConversationOptions(e) {
|
||
// 设置长按标记，防止长按后触发单击
|
||
this.setData({ longPressing: true });
|
||
|
||
const conversation = e.currentTarget.dataset.conversation;
|
||
|
||
const itemList = [
|
||
(conversation.isPinned || conversation.isTop) ? '取消置顶' : '置顶会话',
|
||
conversation.isMuted ? '取消免打扰' : '免打扰',
|
||
'不显示该聊天',
|
||
'删除会话'
|
||
];
|
||
|
||
wx.showActionSheet({
|
||
itemList: itemList,
|
||
success: (res) => {
|
||
switch (res.tapIndex) {
|
||
case 0:
|
||
this.toggleConversationTop(conversation.conversationId);
|
||
break;
|
||
case 1:
|
||
this.toggleConversationMute(conversation.conversationId);
|
||
break;
|
||
case 2:
|
||
this.hideConversation(conversation.conversationId);
|
||
break;
|
||
case 3:
|
||
this.deleteConversation(conversation.conversationId);
|
||
break;
|
||
}
|
||
}
|
||
});
|
||
},
|
||
|
||
// 标记会话已读
|
||
async markConversationRead(conversationId) {
|
||
try {
|
||
await nimConversationManager.markConversationRead(conversationId);
|
||
|
||
const conversations = [...this.data.conversations];
|
||
const index = conversations.findIndex(c => c.conversationId === conversationId);
|
||
|
||
if (index >= 0) {
|
||
conversations[index].unreadCount = 0;
|
||
this.processConversations(conversations);
|
||
}
|
||
} catch (error) {
|
||
console.error('标记已读失败:', error);
|
||
}
|
||
},
|
||
|
||
// 全部标记为已读
|
||
markAllRead() {
|
||
if (this._markingAll) return;
|
||
|
||
const unreadIds = (this.data.conversations || [])
|
||
.filter(c => (c.unreadCount || 0) > 0)
|
||
.map(c => c.conversationId)
|
||
.filter(Boolean);
|
||
|
||
if (!unreadIds.length) {
|
||
wx.showToast({ title: '没有未读消息', icon: 'none' });
|
||
return;
|
||
}
|
||
|
||
wx.showModal({
|
||
title: '确认操作',
|
||
content: '将所有会话标记为已读？',
|
||
success: async (res) => {
|
||
if (!res.confirm) return;
|
||
|
||
this._markingAll = true;
|
||
wx.showLoading({ title: '处理中...' });
|
||
|
||
try {
|
||
const tasks = unreadIds.map(id => this.markConversationRead(id));
|
||
await Promise.allSettled(tasks);
|
||
|
||
wx.hideLoading();
|
||
wx.showToast({ title: '已全部标记为已读', icon: 'success' });
|
||
} catch (err) {
|
||
console.error('批量标记已读失败:', err);
|
||
wx.hideLoading();
|
||
wx.showToast({ title: '操作失败', icon: 'none' });
|
||
} finally {
|
||
this._markingAll = false;
|
||
}
|
||
}
|
||
});
|
||
},
|
||
|
||
// 发起聊天入口
|
||
startNewChat() {
|
||
this.showMenu();
|
||
},
|
||
|
||
// ===== 隐藏会话 =====
|
||
_hiddenStorageKey: 'hiddenConversationIds',
|
||
|
||
_getHiddenConversationSet() {
|
||
try {
|
||
const arr = wx.getStorageSync(this._hiddenStorageKey) || [];
|
||
return new Set(arr);
|
||
} catch (_) {
|
||
return new Set();
|
||
}
|
||
},
|
||
|
||
_saveHiddenConversationSet(set) {
|
||
try {
|
||
wx.setStorageSync(this._hiddenStorageKey, Array.from(set));
|
||
} catch (_) { }
|
||
},
|
||
|
||
hideConversation(conversationId) {
|
||
const cid = String(conversationId || '');
|
||
if (!cid) return;
|
||
|
||
const set = this._getHiddenConversationSet();
|
||
if (!set.has(cid)) set.add(cid);
|
||
this._saveHiddenConversationSet(set);
|
||
|
||
this.processConversations(this.data.conversations || []);
|
||
wx.showToast({ title: '已隐藏该聊天', icon: 'none' });
|
||
},
|
||
|
||
_unhideConversationId(conversationId) {
|
||
const cid = String(conversationId || '');
|
||
if (!cid) return;
|
||
|
||
const set = this._getHiddenConversationSet();
|
||
if (set.has(cid)) {
|
||
set.delete(cid);
|
||
this._saveHiddenConversationSet(set);
|
||
}
|
||
},
|
||
|
||
// ===== 会话操作 =====
|
||
|
||
// 置顶/取消置顶会话
|
||
async toggleConversationTop(conversationId) {
|
||
const conversations = [...this.data.conversations];
|
||
const conv = conversations.find(c => c.conversationId === conversationId);
|
||
|
||
if (!conv) return;
|
||
|
||
const willPin = !conv.isPinned;
|
||
|
||
try {
|
||
wx.showLoading({ title: willPin ? '置顶中...' : '取消中...' });
|
||
|
||
await nimConversationManager.setConversationStickTop(conversationId, willPin);
|
||
|
||
conv.isPinned = willPin;
|
||
conv.isTop = willPin;
|
||
|
||
this.processConversations(conversations);
|
||
|
||
wx.hideLoading();
|
||
wx.showToast({
|
||
title: willPin ? '已置顶' : '已取消置顶',
|
||
icon: 'success'
|
||
});
|
||
} catch (error) {
|
||
console.error('置顶操作失败:', error);
|
||
wx.hideLoading();
|
||
wx.showToast({
|
||
title: '操作失败',
|
||
icon: 'none'
|
||
});
|
||
}
|
||
},
|
||
|
||
// 静音/取消静音会话
|
||
async toggleConversationMute(conversationId) {
|
||
const conversations = [...this.data.conversations];
|
||
const conv = conversations.find(c => c.conversationId === conversationId);
|
||
|
||
if (!conv) return;
|
||
|
||
const willMute = !conv.isMuted;
|
||
conv.isMuted = willMute;
|
||
|
||
this.processConversations(conversations);
|
||
|
||
wx.showToast({
|
||
title: willMute ? '已设置免打扰' : '已取消免打扰',
|
||
icon: 'success'
|
||
});
|
||
},
|
||
|
||
// 删除会话
|
||
async deleteConversation(conversationId) {
|
||
try {
|
||
wx.showLoading({ title: '删除中...' });
|
||
|
||
await nimConversationManager.deleteConversation(conversationId);
|
||
|
||
const conversations = this.data.conversations.filter(
|
||
c => c.conversationId !== conversationId
|
||
);
|
||
this.processConversations(conversations);
|
||
|
||
wx.hideLoading();
|
||
wx.showToast({ title: '已删除', icon: 'success' });
|
||
} catch (error) {
|
||
console.error('删除会话失败:', error);
|
||
wx.hideLoading();
|
||
wx.showToast({ title: '删除失败', icon: 'none' });
|
||
}
|
||
},
|
||
|
||
// 显示菜单
|
||
showMenu() {
|
||
wx.showActionSheet({
|
||
itemList: ['创建群聊', '添加好友', '扫一扫', '设置'],
|
||
success: (res) => {
|
||
switch (res.tapIndex) {
|
||
case 0: this.createGroup(); break;
|
||
case 1: this.addFriend(); break;
|
||
case 2: this.scanQRCode(); break;
|
||
case 3: this.openSettings(); break;
|
||
}
|
||
}
|
||
});
|
||
},
|
||
|
||
// 创建群聊
|
||
createGroup() {
|
||
wx.navigateTo({ url: '/subpackages/group/create-group/create-group' });
|
||
},
|
||
|
||
// 添加好友
|
||
addFriend() {
|
||
wx.navigateTo({ url: '/subpackages/social/search/search' });
|
||
},
|
||
|
||
// 扫一扫
|
||
scanQRCode() {
|
||
wx.scanCode({
|
||
success: (res) => {
|
||
this.handleScanResult(res.result);
|
||
},
|
||
fail: (err) => {
|
||
console.error('扫码失败:', err);
|
||
if (err.errMsg && err.errMsg.includes('cancel')) {
|
||
// 用户取消扫码，不显示错误提示
|
||
return;
|
||
}
|
||
wx.showToast({
|
||
title: '扫码失败',
|
||
icon: 'none'
|
||
});
|
||
}
|
||
});
|
||
},
|
||
|
||
// 处理扫码结果
|
||
handleScanResult(result) {
|
||
console.log('📱 扫码结果:', result);
|
||
|
||
try {
|
||
// 处理 FindMe 用户二维码格式: FINDME:{customId}
|
||
if (result && result.startsWith('FINDME:')) {
|
||
const customId = result.split(':')[1];
|
||
|
||
if (!customId) {
|
||
wx.showToast({
|
||
title: '无效的用户二维码',
|
||
icon: 'none'
|
||
});
|
||
return;
|
||
}
|
||
|
||
// 检查是否是自己
|
||
const app = getApp();
|
||
const currentUser = app.globalData.userInfo?.user;
|
||
|
||
if (currentUser && currentUser.customId === customId) {
|
||
wx.showToast({
|
||
title: '这是你自己的二维码',
|
||
icon: 'none'
|
||
});
|
||
return;
|
||
}
|
||
|
||
// 跳转到用户预览页（该页面会自动处理好友/非好友状态）
|
||
wx.navigateTo({
|
||
url: `/subpackages/social/user-preview/user-preview?customId=${customId}`,
|
||
fail: (err) => {
|
||
console.error('跳转用户预览页失败:', err);
|
||
wx.showToast({
|
||
title: '打开用户资料失败',
|
||
icon: 'none'
|
||
});
|
||
}
|
||
});
|
||
return;
|
||
}
|
||
|
||
// 尝试解析URL格式的二维码（兼容旧格式）
|
||
try {
|
||
const url = new URL(result);
|
||
const type = url.searchParams.get('type');
|
||
const id = url.searchParams.get('id');
|
||
|
||
if (type === 'user' && id) {
|
||
// 检查是否是自己
|
||
const app = getApp();
|
||
const currentUser = app.globalData.userInfo?.user;
|
||
|
||
if (currentUser && currentUser.customId === id) {
|
||
wx.showToast({
|
||
title: '这是你自己的二维码',
|
||
icon: 'none'
|
||
});
|
||
return;
|
||
}
|
||
|
||
wx.navigateTo({
|
||
url: `/subpackages/social/user-preview/user-preview?customId=${id}`
|
||
});
|
||
} else if (type === 'group' && id) {
|
||
this.joinGroupByQR(id);
|
||
} else {
|
||
wx.showToast({
|
||
title: '无效的二维码',
|
||
icon: 'none'
|
||
});
|
||
}
|
||
} catch (urlError) {
|
||
// 不是URL格式，显示无效二维码提示
|
||
wx.showToast({
|
||
title: '无法识别的二维码格式',
|
||
icon: 'none'
|
||
});
|
||
}
|
||
} catch (error) {
|
||
console.error('处理扫码结果失败:', error);
|
||
wx.showToast({
|
||
title: '处理二维码失败',
|
||
icon: 'none'
|
||
});
|
||
}
|
||
},
|
||
|
||
// 通过二维码加入群聊
|
||
async joinGroupByQR(groupId) {
|
||
try {
|
||
wx.showLoading({ title: '加入中...' });
|
||
|
||
// 调用加入群组API
|
||
// await groupAPI.joinGroup(groupId);
|
||
|
||
wx.hideLoading();
|
||
wx.showToast({ title: '已加入群聊', icon: 'success' });
|
||
|
||
setTimeout(() => {
|
||
wx.navigateTo({
|
||
url: `/subpackages/group/group-info/group-info?groupId=${groupId}`
|
||
});
|
||
}, 1500);
|
||
} catch (error) {
|
||
console.error('加入群聊失败:', error);
|
||
wx.hideLoading();
|
||
wx.showToast({
|
||
title: '加入失败',
|
||
icon: 'none'
|
||
});
|
||
}
|
||
},
|
||
|
||
// 打开设置
|
||
openSettings() {
|
||
wx.navigateTo({ url: '/subpackages/settings/settingss/settingss' });
|
||
},
|
||
|
||
// 页面显示
|
||
onShow: function () {
|
||
console.log('消息页面显示');
|
||
|
||
// 设置tabBar选中状态为"聊天"（索引2）
|
||
try {
|
||
if (typeof this.getTabBar === 'function' && this.getTabBar()) {
|
||
this.getTabBar().setData({ selected: 2 });
|
||
}
|
||
} catch (_) {}
|
||
|
||
const currentToken = apiClient.getToken();
|
||
const app = getApp();
|
||
const isLoggedIn = app?.globalData?.isLoggedIn || false;
|
||
|
||
if (!currentToken) {
|
||
console.warn('⚠️ onShow检测到用户未登录');
|
||
if (isLoggedIn) {
|
||
this.redirectToLogin('onShow');
|
||
}
|
||
return;
|
||
}
|
||
|
||
// 🔥 检查并重连 NIM（防止从后台恢复后 NIM 断开）
|
||
this.checkAndReconnectNim();
|
||
|
||
// 刷新会话列表
|
||
this.refreshConversations();
|
||
},
|
||
|
||
// 页面隐藏
|
||
onHide: function () {
|
||
console.log('消息页面隐藏');
|
||
},
|
||
|
||
// 页面卸载
|
||
onUnload: function () {
|
||
console.log('消息页面卸载');
|
||
|
||
// 移除 NIM 监听器
|
||
if (this.data.nimReady) {
|
||
nimConversationManager.off('conversation_created');
|
||
nimConversationManager.off('conversation_deleted');
|
||
nimConversationManager.off('conversation_changed');
|
||
nimConversationManager.off('new_message');
|
||
nimConversationManager.off('message_revoked');
|
||
}
|
||
}
|
||
});
|