解决未读消息显示问题
This commit is contained in:
parent
03aac339d8
commit
b2f2526028
3
App.vue
3
App.vue
@ -1,6 +1,7 @@
|
||||
<script>
|
||||
import dbStore from "@/store/db";
|
||||
import accountStore from "@/store/account";
|
||||
import { globalUnreadListenerManager } from "@/utils/global-unread-listener.js";
|
||||
|
||||
export default {
|
||||
async onLaunch() {
|
||||
@ -38,6 +39,8 @@ export default {
|
||||
const success = await account.initIMAfterLogin();
|
||||
if (success) {
|
||||
console.log("IM 初始化成功");
|
||||
// IM 初始化成功后，设置全局未读消息监听
|
||||
globalUnreadListenerManager.setup();
|
||||
} else {
|
||||
console.warn("IM 初始化失败");
|
||||
}
|
||||
|
||||
@ -158,6 +158,7 @@ import { onLoad, onShow, onHide } from "@dcloudio/uni-app";
|
||||
import { storeToRefs } from "pinia";
|
||||
import useAccountStore from "@/store/account.js";
|
||||
import { globalTimChatManager } from "@/utils/tim-chat.js";
|
||||
import { globalUnreadListenerManager } from "@/utils/global-unread-listener.js";
|
||||
import {
|
||||
startIMMonitoring,
|
||||
stopIMMonitoring,
|
||||
@ -527,9 +528,10 @@ const initTIMCallbacks = async () => {
|
||||
.setMessageRead({
|
||||
conversationID: chatInfo.value.conversationID,
|
||||
})
|
||||
.then(() => {
|
||||
.then(async () => {
|
||||
console.log("✓ 收到新消息后已标记为已读");
|
||||
// 标记为已读后，刷新 tabBar 徽章
|
||||
// 标记为已读后，立即刷新 tabBar 徽章
|
||||
await globalUnreadListenerManager.refreshBadge();
|
||||
})
|
||||
.catch((error) => {
|
||||
console.error("✗ 标记已读失败:", error);
|
||||
@ -680,9 +682,10 @@ const loadMessageList = async () => {
|
||||
.setMessageRead({
|
||||
conversationID: chatInfo.value.conversationID,
|
||||
})
|
||||
.then(() => {
|
||||
.then(async () => {
|
||||
console.log("✓ 会话已标记为已读:", chatInfo.value.conversationID);
|
||||
// 标记为已读后，刷新 tabBar 徽章
|
||||
// 标记为已读后，立即刷新 tabBar 徽章
|
||||
await globalUnreadListenerManager.refreshBadge();
|
||||
})
|
||||
.catch((error) => {
|
||||
console.error("✗ 标记会话已读失败:", error);
|
||||
@ -845,6 +848,11 @@ onHide(() => {
|
||||
// 清空当前会话ID，避免离开页面后收到的消息被错误标记为已读
|
||||
timChatManager.currentConversationID = null;
|
||||
console.log("✓ 页面隐藏，已清空当前会话ID");
|
||||
|
||||
// 页面隐藏时刷新 tabBar 徽章，确保显示正确的未读数
|
||||
if (globalUnreadListenerManager.isInitialized) {
|
||||
globalUnreadListenerManager.refreshBadge();
|
||||
}
|
||||
});
|
||||
|
||||
// 处理取消申请
|
||||
|
||||
@ -76,12 +76,13 @@
|
||||
</template>
|
||||
|
||||
<script setup>
|
||||
import { ref, computed } from "vue";
|
||||
import { ref, computed, onUnmounted } from "vue";
|
||||
import { onLoad, onShow, onHide } from "@dcloudio/uni-app";
|
||||
import { storeToRefs } from "pinia";
|
||||
import useAccountStore from "@/store/account.js";
|
||||
import { globalTimChatManager } from "@/utils/tim-chat.js";
|
||||
import { mergeConversationWithGroupDetails } from "@/utils/conversation-merger.js";
|
||||
import { globalUnreadListenerManager } from "@/utils/global-unread-listener.js";
|
||||
import useGroupAvatars from "./hooks/use-group-avatars.js";
|
||||
import GroupAvatar from "@/components/group-avatar.vue";
|
||||
|
||||
@ -251,125 +252,143 @@ const loadConversationList = async () => {
|
||||
// 防抖更新定时器
|
||||
let updateTimer = null;
|
||||
|
||||
// 设置会话列表监听，实时更新列表
|
||||
const setupConversationListener = () => {
|
||||
if (!globalTimChatManager) return;
|
||||
// 监听会话列表更新事件
|
||||
globalTimChatManager.setCallback("onConversationListUpdated", (eventData) => {
|
||||
console.log("会话列表更新事件:", eventData);
|
||||
// 处理单个会话更新（标记已读的情况）
|
||||
if (eventData && !Array.isArray(eventData) && eventData.conversationID) {
|
||||
const conversationID = eventData.conversationID;
|
||||
// 会话列表更新处理函数
|
||||
const handleConversationListUpdate = async (eventData) => {
|
||||
console.log("【消息列表页】会话列表更新事件:", eventData);
|
||||
|
||||
// 处理单个会话更新（标记已读的情况）
|
||||
if (eventData && !Array.isArray(eventData) && eventData.conversationID) {
|
||||
const conversationID = eventData.conversationID;
|
||||
const existingIndex = conversationList.value.findIndex(
|
||||
(conv) => conv.conversationID === conversationID
|
||||
);
|
||||
|
||||
if (existingIndex !== -1) {
|
||||
// 直接更新未读数，避免触发整个对象的响应式更新
|
||||
if (eventData.unreadCount !== undefined) {
|
||||
conversationList.value[existingIndex].unreadCount =
|
||||
eventData.unreadCount;
|
||||
console.log(
|
||||
`【消息列表页】已更新会话未读数: ${conversationList.value[existingIndex].name}, unreadCount: ${eventData.unreadCount}`
|
||||
);
|
||||
}
|
||||
// 更新最后消息
|
||||
if (eventData.lastMessage) {
|
||||
conversationList.value[existingIndex].lastMessage = eventData.lastMessage.messageForShow || '';
|
||||
conversationList.value[existingIndex].lastMessageTime = eventData.lastMessage.lastTime || Date.now();
|
||||
// 重新排序
|
||||
conversationList.value.sort((a, b) => b.lastMessageTime - a.lastMessageTime);
|
||||
}
|
||||
}
|
||||
return;
|
||||
}
|
||||
|
||||
// eventData 是一个数组，包含所有更新的会话
|
||||
if (!eventData || !Array.isArray(eventData)) {
|
||||
console.warn("【消息列表页】会话列表更新事件数据格式错误");
|
||||
return;
|
||||
}
|
||||
|
||||
// 防抖处理：避免频繁更新导致闪动
|
||||
if (updateTimer) {
|
||||
clearTimeout(updateTimer);
|
||||
}
|
||||
|
||||
updateTimer = setTimeout(async () => {
|
||||
// 过滤出群聊会话
|
||||
const groupConversations = eventData.filter(
|
||||
(conv) => conv.conversationID && conv.conversationID.startsWith("GROUP")
|
||||
);
|
||||
|
||||
console.log(`【消息列表页】收到 ${groupConversations.length} 个群聊会话更新`);
|
||||
|
||||
// 使用 TimChatManager 的格式化方法转换为标准格式
|
||||
const formattedConversations = groupConversations.map((conv) =>
|
||||
globalTimChatManager.formatConversationData(conv)
|
||||
);
|
||||
|
||||
// 合并后端群组详细信息（已包含格式化和排序）
|
||||
const mergedConversations = await mergeConversationWithGroupDetails(
|
||||
formattedConversations
|
||||
);
|
||||
|
||||
if (!mergedConversations || mergedConversations.length === 0) {
|
||||
console.log("【消息列表页】合并后的会话数据为空，跳过更新");
|
||||
return;
|
||||
}
|
||||
|
||||
let needSort = false;
|
||||
|
||||
// 更新会话列表
|
||||
mergedConversations.forEach((conversationData) => {
|
||||
const conversationID = conversationData.conversationID;
|
||||
const existingIndex = conversationList.value.findIndex(
|
||||
(conv) => conv.conversationID === conversationID
|
||||
);
|
||||
|
||||
if (existingIndex !== -1) {
|
||||
// 直接更新未读数，避免触发整个对象的响应式更新
|
||||
if (eventData.unreadCount !== undefined) {
|
||||
conversationList.value[existingIndex].unreadCount =
|
||||
eventData.unreadCount;
|
||||
const existing = conversationList.value[existingIndex];
|
||||
// 只在关键字段变化时才更新，减少不必要的渲染
|
||||
if (
|
||||
existing.lastMessage !== conversationData.lastMessage ||
|
||||
existing.lastMessageTime !== conversationData.lastMessageTime ||
|
||||
existing.unreadCount !== conversationData.unreadCount
|
||||
) {
|
||||
// 只更新变化的字段，保持头像稳定
|
||||
conversationList.value[existingIndex] = {
|
||||
...conversationData,
|
||||
// 保持原有头像，避免闪动
|
||||
avatar: existing.avatar || conversationData.avatar,
|
||||
// 直接使用 TIM SDK 返回的未读数
|
||||
unreadCount: conversationData.unreadCount || 0
|
||||
};
|
||||
needSort = true;
|
||||
console.log(
|
||||
`已清空会话未读数: ${conversationList.value[existingIndex].name}, unreadCount: ${eventData.unreadCount}`
|
||||
`【消息列表页】已更新会话: ${conversationData.name}, unreadCount: ${conversationList.value[existingIndex].unreadCount}`
|
||||
);
|
||||
}
|
||||
} else {
|
||||
// 添加新会话
|
||||
conversationList.value.push(conversationData);
|
||||
needSort = true;
|
||||
console.log(`【消息列表页】已添加新会话: ${conversationData.name}`);
|
||||
}
|
||||
return;
|
||||
}
|
||||
});
|
||||
|
||||
// eventData 是一个数组，包含所有更新的会话
|
||||
if (!eventData || !Array.isArray(eventData)) {
|
||||
console.warn("会话列表更新事件数据格式错误");
|
||||
return;
|
||||
}
|
||||
|
||||
// 防抖处理：避免频繁更新导致闪动
|
||||
if (updateTimer) {
|
||||
clearTimeout(updateTimer);
|
||||
}
|
||||
|
||||
updateTimer = setTimeout(async () => {
|
||||
// 过滤出群聊会话
|
||||
const groupConversations = eventData.filter(
|
||||
(conv) => conv.conversationID && conv.conversationID.startsWith("GROUP")
|
||||
// 只在需要时才排序
|
||||
if (needSort) {
|
||||
conversationList.value.sort(
|
||||
(a, b) => b.lastMessageTime - a.lastMessageTime
|
||||
);
|
||||
}
|
||||
}, 100); // 100ms 防抖延迟
|
||||
};
|
||||
|
||||
console.log(`收到 ${groupConversations.length} 个群聊会话更新`);
|
||||
// 消息接收处理函数
|
||||
const handleMessageReceived = (message) => {
|
||||
console.log("【消息列表页】收到新消息:", message);
|
||||
// TIM SDK 会在收到新消息时自动更新会话的未读数，并触发 onConversationListUpdated 事件
|
||||
// 因此这里不需要手动处理，只记录日志
|
||||
};
|
||||
|
||||
// 使用 TimChatManager 的格式化方法转换为标准格式
|
||||
const formattedConversations = groupConversations.map((conv) =>
|
||||
globalTimChatManager.formatConversationData(conv)
|
||||
);
|
||||
|
||||
// 合并后端群组详细信息（已包含格式化和排序）
|
||||
const mergedConversations = await mergeConversationWithGroupDetails(
|
||||
formattedConversations
|
||||
);
|
||||
|
||||
if (!mergedConversations || mergedConversations.length === 0) {
|
||||
console.log("合并后的会话数据为空，跳过更新");
|
||||
return;
|
||||
}
|
||||
|
||||
let needSort = false;
|
||||
|
||||
// 更新会话列表
|
||||
mergedConversations.forEach((conversationData) => {
|
||||
const conversationID = conversationData.conversationID;
|
||||
const existingIndex = conversationList.value.findIndex(
|
||||
(conv) => conv.conversationID === conversationID
|
||||
);
|
||||
|
||||
if (existingIndex !== -1) {
|
||||
const existing = conversationList.value[existingIndex];
|
||||
// 只在关键字段变化时才更新，减少不必要的渲染
|
||||
if (
|
||||
existing.lastMessage !== conversationData.lastMessage ||
|
||||
existing.lastMessageTime !== conversationData.lastMessageTime ||
|
||||
existing.unreadCount !== conversationData.unreadCount
|
||||
) {
|
||||
// 只更新变化的字段，保持头像稳定
|
||||
conversationList.value[existingIndex] = {
|
||||
...conversationData,
|
||||
// 保持原有头像，避免闪动
|
||||
avatar: existing.avatar || conversationData.avatar,
|
||||
// 【修复】直接使用 TIM SDK 返回的未读数，不使用 Math.max
|
||||
// 这样才能正确处理标记已读的情况（unreadCount 从 N 变为 0）
|
||||
unreadCount: conversationData.unreadCount || 0
|
||||
};
|
||||
needSort = true;
|
||||
console.log(
|
||||
`已更新会话: ${conversationData.name}, unreadCount: ${conversationList.value[existingIndex].unreadCount}`
|
||||
);
|
||||
}
|
||||
} else {
|
||||
// 添加新会话
|
||||
conversationList.value.push(conversationData);
|
||||
needSort = true;
|
||||
console.log(`已添加新会话: ${conversationData.name}`);
|
||||
}
|
||||
});
|
||||
|
||||
// 只在需要时才排序
|
||||
if (needSort) {
|
||||
conversationList.value.sort(
|
||||
(a, b) => b.lastMessageTime - a.lastMessageTime
|
||||
);
|
||||
}
|
||||
}, 100); // 100ms 防抖延迟
|
||||
});
|
||||
|
||||
// 监听消息接收事件（用于更新未读数）
|
||||
globalTimChatManager.setCallback("onMessageReceived", (message) => {
|
||||
console.log("消息列表页面收到新消息:", message);
|
||||
|
||||
// 【修复】不再手动更新未读数
|
||||
// TIM SDK 会在收到新消息时自动更新会话的未读数，并触发 onConversationListUpdated 事件
|
||||
// 手动 +1 可能导致未读数不准确（重复计数）
|
||||
//
|
||||
// 注意：onConversationListUpdated 事件会在消息接收后自动触发，
|
||||
// 其中包含了正确的未读数，因此这里不需要手动处理
|
||||
});
|
||||
// 设置会话列表监听，实时更新列表
|
||||
const setupConversationListener = () => {
|
||||
if (!globalTimChatManager) return;
|
||||
|
||||
console.log("【消息列表页】设置会话监听器");
|
||||
|
||||
// 将回调添加到全局未读监听器的回调链中
|
||||
// 这样不会覆盖全局未读监听器，而是与之共存
|
||||
if (globalUnreadListenerManager.isInitialized) {
|
||||
globalUnreadListenerManager.addCallback("onConversationListUpdated", handleConversationListUpdate);
|
||||
globalUnreadListenerManager.addCallback("onMessageReceived", handleMessageReceived);
|
||||
console.log("【消息列表页】已添加回调到全局监听器回调链");
|
||||
} else {
|
||||
console.warn("【消息列表页】全局未读监听器未初始化，使用直接回调方式");
|
||||
// 如果全局监听器未初始化，直接设置回调（兼容处理）
|
||||
globalTimChatManager.setCallback("onConversationListUpdated", handleConversationListUpdate);
|
||||
globalTimChatManager.setCallback("onMessageReceived", handleMessageReceived);
|
||||
}
|
||||
};
|
||||
|
||||
// 格式化消息时间
|
||||
@ -417,6 +436,8 @@ const formatMessageTime = (timestamp) => {
|
||||
// 点击会话
|
||||
const handleClickConversation = async (conversation) => {
|
||||
console.log("点击会话:", conversation);
|
||||
|
||||
// 立即清除本地未读数显示
|
||||
const conversationIndex = conversationList.value.findIndex(
|
||||
(conv) => conv.conversationID === conversation.conversationID
|
||||
);
|
||||
@ -424,6 +445,21 @@ const handleClickConversation = async (conversation) => {
|
||||
conversationList.value[conversationIndex].unreadCount = 0;
|
||||
}
|
||||
|
||||
// 标记会话为已读
|
||||
if (globalTimChatManager && globalTimChatManager.tim) {
|
||||
try {
|
||||
await globalTimChatManager.tim.setMessageRead({
|
||||
conversationID: conversation.conversationID,
|
||||
});
|
||||
console.log("✓ 已标记会话为已读:", conversation.conversationID);
|
||||
|
||||
// 立即刷新 tabBar 徽章
|
||||
await globalUnreadListenerManager.refreshBadge();
|
||||
} catch (error) {
|
||||
console.error("✗ 标记会话已读失败:", error);
|
||||
}
|
||||
}
|
||||
|
||||
// 跳转到聊天页面
|
||||
uni.navigateTo({
|
||||
url: `/pages/message/index?conversationID=${conversation.conversationID}&groupID=${conversation.groupID}`,
|
||||
@ -477,19 +513,42 @@ const cleanMessageText = (text) => {
|
||||
|
||||
// 页面显示
|
||||
onShow(async () => {
|
||||
|
||||
// 页面显示时刷新 tabBar 徽章
|
||||
if (globalUnreadListenerManager.isInitialized) {
|
||||
await globalUnreadListenerManager.refreshBadge();
|
||||
}
|
||||
});
|
||||
|
||||
// 页面隐藏
|
||||
onHide(() => {
|
||||
console.log("【消息列表页】页面隐藏");
|
||||
|
||||
// 清除防抖定时器
|
||||
if (updateTimer) {
|
||||
clearTimeout(updateTimer);
|
||||
updateTimer = null;
|
||||
}
|
||||
if (globalTimChatManager) {
|
||||
globalTimChatManager.setCallback("onConversationListUpdated", null);
|
||||
globalTimChatManager.setCallback("onMessageReceived", null);
|
||||
|
||||
// 注意：不要清除 globalTimChatManager 的回调
|
||||
// 因为全局未读监听器需要持续工作
|
||||
// 回调链会在页面销毁时自动清理
|
||||
});
|
||||
|
||||
// 页面卸载
|
||||
onUnmounted(() => {
|
||||
console.log("【消息列表页】页面卸载，清理回调");
|
||||
|
||||
// 清除防抖定时器
|
||||
if (updateTimer) {
|
||||
clearTimeout(updateTimer);
|
||||
updateTimer = null;
|
||||
}
|
||||
|
||||
// 从全局未读监听器的回调链中移除本页面的回调
|
||||
if (globalUnreadListenerManager.isInitialized) {
|
||||
globalUnreadListenerManager.removeCallback("onConversationListUpdated", handleConversationListUpdate);
|
||||
globalUnreadListenerManager.removeCallback("onMessageReceived", handleMessageReceived);
|
||||
console.log("【消息列表页】已从回调链移除回调");
|
||||
}
|
||||
});
|
||||
</script>
|
||||
|
||||
@ -3,6 +3,7 @@ import { defineStore } from "pinia";
|
||||
import api from '@/utils/api';
|
||||
import { toast } from '@/utils/widget';
|
||||
import { initGlobalTIM, globalTimChatManager } from "@/utils/tim-chat.js";
|
||||
import { globalUnreadListenerManager } from "@/utils/global-unread-listener.js";
|
||||
const env = __VITE_ENV__;
|
||||
|
||||
export default defineStore("accountStore", () => {
|
||||
@ -76,6 +77,10 @@ export default defineStore("accountStore", () => {
|
||||
|
||||
isIMInitialized.value = true;
|
||||
console.log('IM 初始化成功');
|
||||
|
||||
// IM 初始化成功后，设置全局未读消息监听
|
||||
globalUnreadListenerManager.setup();
|
||||
|
||||
return true;
|
||||
} catch (error) {
|
||||
console.log('IM初始化异常，跳过 IM 初始化:', error.message);
|
||||
@ -91,6 +96,11 @@ export default defineStore("accountStore", () => {
|
||||
await globalTimChatManager.destroy();
|
||||
console.log('腾讯IM退出成功');
|
||||
}
|
||||
|
||||
// 清除全局未读监听
|
||||
if (globalUnreadListenerManager.isInitialized) {
|
||||
globalUnreadListenerManager.destroy();
|
||||
}
|
||||
} catch (error) {
|
||||
console.error('退出腾讯IM失败:', error);
|
||||
}
|
||||
@ -103,6 +113,11 @@ export default defineStore("accountStore", () => {
|
||||
// 清除本地存储
|
||||
uni.removeStorageSync('account');
|
||||
uni.removeStorageSync('openid');
|
||||
|
||||
// 清除 tabBar 徽章
|
||||
uni.removeTabBarBadge({
|
||||
index: 1
|
||||
});
|
||||
}
|
||||
|
||||
async function getExternalUserId(corpId) {
|
||||
|
||||
@ -7,8 +7,11 @@ import { globalTimChatManager } from './tim-chat.js';
|
||||
class GlobalUnreadListenerManager {
|
||||
constructor() {
|
||||
this.isInitialized = false;
|
||||
this.originalConversationListCallback = null;
|
||||
this.originalMessageReceivedCallback = null;
|
||||
this.callbackChain = {
|
||||
onConversationListUpdated: [],
|
||||
onMessageReceived: []
|
||||
};
|
||||
this.updateTimer = null; // 防抖定时器
|
||||
}
|
||||
|
||||
/**
|
||||
@ -25,39 +28,76 @@ class GlobalUnreadListenerManager {
|
||||
return;
|
||||
}
|
||||
|
||||
// 保存原始回调（在覆盖前保存）
|
||||
this.originalConversationListCallback = globalTimChatManager.callbacks.onConversationListUpdated;
|
||||
this.originalMessageReceivedCallback = globalTimChatManager.callbacks.onMessageReceived;
|
||||
// 保存原始回调到回调链
|
||||
const originalConversationListCallback = globalTimChatManager.callbacks.onConversationListUpdated;
|
||||
const originalMessageReceivedCallback = globalTimChatManager.callbacks.onMessageReceived;
|
||||
|
||||
console.log('保存原始回调:', {
|
||||
hasConversationListCallback: !!this.originalConversationListCallback,
|
||||
hasMessageReceivedCallback: !!this.originalMessageReceivedCallback
|
||||
if (originalConversationListCallback && typeof originalConversationListCallback === 'function') {
|
||||
this.callbackChain.onConversationListUpdated.push(originalConversationListCallback);
|
||||
}
|
||||
if (originalMessageReceivedCallback && typeof originalMessageReceivedCallback === 'function') {
|
||||
this.callbackChain.onMessageReceived.push(originalMessageReceivedCallback);
|
||||
}
|
||||
|
||||
console.log('全局未读监听初始化，回调链长度:', {
|
||||
onConversationListUpdated: this.callbackChain.onConversationListUpdated.length,
|
||||
onMessageReceived: this.callbackChain.onMessageReceived.length
|
||||
});
|
||||
|
||||
// 监听会话列表更新事件（包括消息接收和已读状态变化）
|
||||
globalTimChatManager.setCallback('onConversationListUpdated', (eventData) => {
|
||||
console.log('onConversationListUpdated 触发，调用原始回调');
|
||||
// 调用原始回调（如果存在）
|
||||
if (this.originalConversationListCallback && typeof this.originalConversationListCallback === 'function') {
|
||||
this.originalConversationListCallback(eventData);
|
||||
}
|
||||
// 更新 tabBar 徽章
|
||||
this.updateTabBarBadge();
|
||||
console.log('【全局未读监听】onConversationListUpdated 触发，回调链长度:', this.callbackChain.onConversationListUpdated.length);
|
||||
|
||||
// 执行回调链中的所有回调
|
||||
this.callbackChain.onConversationListUpdated.forEach((callback, index) => {
|
||||
try {
|
||||
console.log(`【全局未读监听】执行回调链 #${index + 1}`);
|
||||
callback(eventData);
|
||||
} catch (error) {
|
||||
console.error(`【全局未读监听】执行 onConversationListUpdated 回调 #${index + 1} 失败:`, error);
|
||||
}
|
||||
});
|
||||
|
||||
// 防抖更新 tabBar 徽章
|
||||
this.debouncedUpdateTabBarBadge();
|
||||
});
|
||||
|
||||
// 监听消息接收事件
|
||||
globalTimChatManager.setCallback('onMessageReceived', (message) => {
|
||||
console.log('onMessageReceived 触发，调用原始回调');
|
||||
// 调用原始回调（如果存在）
|
||||
if (this.originalMessageReceivedCallback && typeof this.originalMessageReceivedCallback === 'function') {
|
||||
this.originalMessageReceivedCallback(message);
|
||||
}
|
||||
// 更新 tabBar 徽章
|
||||
this.updateTabBarBadge();
|
||||
console.log('【全局未读监听】onMessageReceived 触发，回调链长度:', this.callbackChain.onMessageReceived.length);
|
||||
|
||||
// 执行回调链中的所有回调
|
||||
this.callbackChain.onMessageReceived.forEach((callback, index) => {
|
||||
try {
|
||||
console.log(`【全局未读监听】执行回调链 #${index + 1}`);
|
||||
callback(message);
|
||||
} catch (error) {
|
||||
console.error(`【全局未读监听】执行 onMessageReceived 回调 #${index + 1} 失败:`, error);
|
||||
}
|
||||
});
|
||||
|
||||
// 防抖更新 tabBar 徽章
|
||||
this.debouncedUpdateTabBarBadge();
|
||||
});
|
||||
|
||||
this.isInitialized = true;
|
||||
console.log('全局未读消息监听已设置');
|
||||
|
||||
// 初始化时立即更新一次徽章
|
||||
this.updateTabBarBadge();
|
||||
}
|
||||
|
||||
/**
|
||||
* 防抖更新 tabBar 徽章
|
||||
* 避免频繁更新导致性能问题
|
||||
*/
|
||||
debouncedUpdateTabBarBadge() {
|
||||
if (this.updateTimer) {
|
||||
clearTimeout(this.updateTimer);
|
||||
}
|
||||
this.updateTimer = setTimeout(() => {
|
||||
this.updateTabBarBadge();
|
||||
}, 200); // 减少到 200ms 防抖延迟，提高响应速度
|
||||
}
|
||||
|
||||
/**
|
||||
@ -67,21 +107,22 @@ class GlobalUnreadListenerManager {
|
||||
async updateTabBarBadge() {
|
||||
try {
|
||||
if (!globalTimChatManager || !globalTimChatManager.tim) {
|
||||
console.warn('globalTimChatManager 或 tim 未初始化');
|
||||
console.warn('【全局未读监听】globalTimChatManager 或 tim 未初始化');
|
||||
return;
|
||||
}
|
||||
|
||||
const response = await globalTimChatManager.tim.getConversationList();
|
||||
|
||||
if (!response || !response.data || !response.data.conversationList) {
|
||||
console.warn('获取会话列表返回数据异常');
|
||||
console.warn('【全局未读监听】获取会话列表返回数据异常');
|
||||
return;
|
||||
}
|
||||
|
||||
const totalUnreadCount = this.calculateGroupUnreadCount(response.data.conversationList);
|
||||
console.log('【全局未读监听】计算总未读数:', totalUnreadCount);
|
||||
this.setTabBarBadge(totalUnreadCount);
|
||||
} catch (error) {
|
||||
console.error('更新 tabBar 徽章失败:', error);
|
||||
console.error('【全局未读监听】更新 tabBar 徽章失败:', error);
|
||||
}
|
||||
}
|
||||
|
||||
@ -107,25 +148,68 @@ class GlobalUnreadListenerManager {
|
||||
index: tabIndex,
|
||||
text: count > 99 ? '99+' : String(count)
|
||||
});
|
||||
console.log(`已更新 tabBar 徽章（索引 ${tabIndex}）:`, count);
|
||||
console.log(`✓ 已更新 tabBar 徽章（索引 ${tabIndex}）:`, count);
|
||||
} else {
|
||||
// uni.removeTabBarBadge({
|
||||
// index: tabIndex
|
||||
// });
|
||||
console.log(`已移除 tabBar 徽章（索引 ${tabIndex}）`);
|
||||
uni.removeTabBarBadge({
|
||||
index: tabIndex
|
||||
});
|
||||
console.log(`✓ 已移除 tabBar 徽章（索引 ${tabIndex}）`);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 手动刷新徽章
|
||||
* 用于页面显示时强制刷新
|
||||
*/
|
||||
async refreshBadge() {
|
||||
console.log('手动刷新 tabBar 徽章');
|
||||
await this.updateTabBarBadge();
|
||||
}
|
||||
|
||||
/**
|
||||
* 添加回调到回调链
|
||||
* @param {string} eventName - 事件名称
|
||||
* @param {Function} callback - 回调函数
|
||||
*/
|
||||
addCallback(eventName, callback) {
|
||||
if (this.callbackChain[eventName] && typeof callback === 'function') {
|
||||
// 避免重复添加同一个回调
|
||||
if (!this.callbackChain[eventName].includes(callback)) {
|
||||
this.callbackChain[eventName].push(callback);
|
||||
console.log(`✓ 已添加回调到 ${eventName} 回调链，当前链长度:`, this.callbackChain[eventName].length);
|
||||
} else {
|
||||
console.log(`⚠️ 回调已存在于 ${eventName} 回调链中，跳过添加`);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 从回调链中移除回调
|
||||
* @param {string} eventName - 事件名称
|
||||
* @param {Function} callback - 回调函数
|
||||
*/
|
||||
removeCallback(eventName, callback) {
|
||||
if (this.callbackChain[eventName]) {
|
||||
const index = this.callbackChain[eventName].indexOf(callback);
|
||||
if (index > -1) {
|
||||
this.callbackChain[eventName].splice(index, 1);
|
||||
console.log(`✓ 已从 ${eventName} 回调链移除回调，当前链长度:`, this.callbackChain[eventName].length);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 清除监听（可选）
|
||||
*/
|
||||
destroy() {
|
||||
if (this.updateTimer) {
|
||||
clearTimeout(this.updateTimer);
|
||||
this.updateTimer = null;
|
||||
}
|
||||
this.callbackChain = {
|
||||
onConversationListUpdated: [],
|
||||
onMessageReceived: []
|
||||
};
|
||||
this.isInitialized = false;
|
||||
console.log('全局未读消息监听已清除');
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user