255 lines
11 KiB
Dart
255 lines
11 KiB
Dart
import 'package:get/get.dart';
|
||
import 'package:loopin/IM/controller/chat_controller.dart';
|
||
import 'package:loopin/IM/controller/tab_bar_controller.dart';
|
||
import 'package:loopin/IM/im_service.dart';
|
||
import 'package:loopin/models/conversation_type.dart';
|
||
import 'package:loopin/models/conversation_view_model.dart';
|
||
import 'package:loopin/models/tab_type.dart';
|
||
import 'package:loopin/pages/chat/notify_controller/notify_no_friend_controller.dart';
|
||
import 'package:tencent_cloud_chat_sdk/enum/V2TimConversationListener.dart';
|
||
import 'package:tencent_cloud_chat_sdk/models/v2_tim_conversation.dart';
|
||
import 'package:tencent_cloud_chat_sdk/models/v2_tim_conversation_filter.dart';
|
||
import 'package:tencent_cloud_chat_sdk/tencent_im_sdk_plugin.dart';
|
||
|
||
class GlobalBadge extends GetxController {
|
||
/// 全局未读消息总数
|
||
RxInt totalUnread = 0.obs;
|
||
|
||
/// 监听器对象（用于 add/remove）
|
||
late final V2TimConversationListener _listener;
|
||
|
||
void rest() {
|
||
totalUnread.value = 0;
|
||
}
|
||
|
||
@override
|
||
void onInit() {
|
||
super.onInit();
|
||
_listener = V2TimConversationListener(
|
||
onTotalUnreadMessageCountChanged: (int count) {
|
||
logger.i('未读数发生变化$count');
|
||
totalUnread.value = count;
|
||
Get.find<TabBarController>().setBadge(TabType.chat, totalUnread.value);
|
||
},
|
||
onNewConversation: (List<V2TimConversation> conversationList) {
|
||
for (var conv in conversationList) {
|
||
logger.e('新创建会话：${conv.toLogString()}');
|
||
logger.i("新会话分组类型:${conv.conversationGroupList}");
|
||
handleCoverstion(conv);
|
||
}
|
||
},
|
||
onConversationChanged: (List<V2TimConversation> conversationList) async {
|
||
logger.w('会话变更:会话分组：${conversationList.first.conversationGroupList}，会话内容${conversationList.first.toLogString()}');
|
||
final ctl = Get.find<ChatController>();
|
||
logger.w('当前会话列表内容：${ctl.chatList.length}');
|
||
|
||
final updatedIds = conversationList.map((e) => e.conversationID).toSet();
|
||
logger.w('要变更的会话id：$updatedIds');
|
||
// 收集可能存在后续分页的会话
|
||
final List<V2TimConversation> willInsert = <V2TimConversation>[];
|
||
for (int i = 0; i < ctl.chatList.length; i++) {
|
||
final chatItem = ctl.chatList[i];
|
||
logger.w('需要更新的ID:${chatItem.conversation.conversationID}');
|
||
if (updatedIds.contains(chatItem.conversation.conversationID)) {
|
||
logger.w('chatList中包含:${chatItem.conversation.conversationID}');
|
||
|
||
// 从onchange中找到原始数据
|
||
final updatedConv = conversationList.firstWhere(
|
||
(c) => c.conversationID == chatItem.conversation.conversationID,
|
||
orElse: () => V2TimConversation(conversationID: ''),
|
||
);
|
||
// 同步更新
|
||
ctl.getNoFriendData(csion: chatItem.conversation);
|
||
|
||
if (updatedConv.conversationID != '' && (updatedConv.conversationGroupList?.contains(ConversationType.noFriend.name) ?? false)) {
|
||
// 单独处理陌生人会话
|
||
final unread = await ImService.instance.getUnreadMessageCountByFilter(
|
||
filter: V2TimConversationFilter(
|
||
conversationGroup: ConversationType.noFriend.name,
|
||
hasUnreadCount: true,
|
||
),
|
||
);
|
||
chatItem.conversation.lastMessage = updatedConv.lastMessage;
|
||
chatItem.conversation.unreadCount = unread.data; // 获取陌生人未读总数
|
||
update();
|
||
} else if (updatedConv.conversationID != '') {
|
||
// 其他类型统一更新处理
|
||
logger.w('非陌生人消息的会话，正常更新');
|
||
chatItem.conversation = updatedConv;
|
||
update();
|
||
}
|
||
} else {
|
||
logger.e('本地会话列表中不包含的会话：$updatedIds'); // 情况1：nofriend分组会话，情况2:会话分页未拉取到或者分组变更
|
||
// 检测这条会话数据远端是否存在
|
||
for (var cvID in updatedIds) {
|
||
// 检测这条会话数据是否存在，如果存在说明在后面的分页中，不存在则是被删除不处理
|
||
final isReal = await ImService.instance.getConversation(conversationID: cvID);
|
||
if (isReal.success) {
|
||
final V2TimConversation realConv = isReal.data;
|
||
|
||
if (realConv.lastMessage != null) {
|
||
// 陌生人会话列表单独处理
|
||
if (Get.isRegistered<NotifyNoFriendController>()) {
|
||
logger.w('在陌生人会话列表');
|
||
final notifyCtl = Get.find<NotifyNoFriendController>();
|
||
// 有分组更新，没分组删除
|
||
if (realConv.conversationGroupList?.contains(ConversationType.noFriend.name) ?? false) {
|
||
notifyCtl.updateLastMsg(conversation: realConv);
|
||
} else {
|
||
notifyCtl.del(conversation: realConv);
|
||
}
|
||
}
|
||
// 同步更新nofriend会话菜单入口的未读数量
|
||
if (chatItem.isCustomAdmin?.contains(ConversationType.noFriend.name) ?? false) {
|
||
await ctl.updateNoFriendMenu();
|
||
}
|
||
if (realConv.conversationGroupList?.contains(ConversationType.noFriend.name) ?? false) {
|
||
// 这个方法执行的逻辑：已有则刷新菜单入口数据，没有则创建菜单入口
|
||
await ctl.getNoFriendData(csion: realConv);
|
||
} else {
|
||
// 非陌生人会话，收集要插入的数据 （情况2）这条会话数据
|
||
willInsert.add(realConv);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
}
|
||
// 添加收集的数据，别忘了分页获取的去重
|
||
if (willInsert.isNotEmpty) {
|
||
logger.w('收集到要插入的数据为：${willInsert.first.toLogString()}');
|
||
// willInsert 去重
|
||
final deduped = {for (var c in willInsert) c.conversationID.trim(): c}.values.toList();
|
||
// 已有会话ID集合
|
||
final existingIds = ctl.chatList.map((e) => e.conversation.conversationID.trim()).where((id) => id.isNotEmpty).toSet();
|
||
// 过滤掉已存在的会话
|
||
final filtered = deduped.where((c) => !existingIds.contains(c.conversationID.trim())).toList();
|
||
logger.w('最终需要插入的会话数量: ${filtered.length}, ids: ${filtered.map((c) => '"${(c.conversationID).trim()}"').toList()}');
|
||
|
||
final viewModelList = await ConversationViewModel.createConversationViewModel(convList: filtered);
|
||
|
||
ctl.chatList.insertAll(0, viewModelList);
|
||
}
|
||
// 如果没当前会话列表为空
|
||
if (ctl.chatList.isEmpty) {
|
||
// 重新获取一次
|
||
logger.w('重新获取会话');
|
||
ctl.initChatData();
|
||
ctl.getConversationList();
|
||
}
|
||
|
||
//重新排序
|
||
ctl.chatList.sort((a, b) {
|
||
final atime = a.conversation.lastMessage?.timestamp ?? 0;
|
||
final btime = b.conversation.lastMessage?.timestamp ?? 0;
|
||
return btime.compareTo(atime); // 降序
|
||
});
|
||
//去重
|
||
final seen = <String>{};
|
||
ctl.chatList.retainWhere((item) {
|
||
final id = item.conversation.conversationID.trim();
|
||
if (seen.contains(id)) {
|
||
return false;
|
||
} else {
|
||
seen.add(id);
|
||
return true;
|
||
}
|
||
});
|
||
ctl.chatList.refresh();
|
||
}, //changeEnd;
|
||
);
|
||
// final ctl = Get.find<ChatController>();
|
||
// ctl.getConversationList();
|
||
initUnreadCount();
|
||
_addListener();
|
||
}
|
||
|
||
// final rr = await ImService.instance.deleteConversationsFromGroup(
|
||
// conversationIDList: [cov.conversationID],
|
||
// groupName: 'noFriend',
|
||
// );
|
||
// logger.w(rr.desc);
|
||
|
||
/// 新建会话时候,根据消息的自定义属性给会话分组
|
||
void handleCoverstion(V2TimConversation cov) async {
|
||
final message = cov.lastMessage;
|
||
final isSelfSend = message!.isSelf; // 是否本人发送的消息
|
||
final typeEnum = conversationTypeFromString(message.cloudCustomData); // 会话类型
|
||
final needAdd = cov.conversationGroupList!.isEmpty == true; // 当前会话是否已加入了分组中
|
||
if (typeEnum != null && needAdd && isSelfSend == false) {
|
||
logger.i('当前会话的类型要加入的组是:$typeEnum');
|
||
// 当前会话需要进行分组，检测 组 是否存在
|
||
final hasGroupRes = await ImService.instance.getConversationGroupList();
|
||
if (hasGroupRes.success) {
|
||
final exists = hasGroupRes.data?.any((item) => item == typeEnum) ?? false;
|
||
if (!exists) {
|
||
// 组不存在，创建组并把会话加入group中
|
||
await ImService.instance.createConversationGroup(
|
||
groupName: typeEnum,
|
||
conversationIDList: ['c2c_${message.sender}'],
|
||
);
|
||
logger.i('首次创建会话分组$typeEnum');
|
||
} else {
|
||
// 分组存在直接添加
|
||
await ImService.instance.addConversationsToGroup(
|
||
groupName: typeEnum,
|
||
conversationIDList: ['c2c_${message.sender}'],
|
||
);
|
||
logger.i('添加会话分组$typeEnum成功');
|
||
}
|
||
if (typeEnum == ConversationType.noFriend.name) {
|
||
//陌生人分组特殊处理 满足分组条件且已经有分组,
|
||
final ctl = Get.find<ChatController>();
|
||
// 这个方法执行的逻辑：已有则刷新菜单入口数据，没有则创建菜单入口
|
||
ctl.getNoFriendData(csion: cov);
|
||
}
|
||
}
|
||
} else {
|
||
logger.w('新会话不需分组');
|
||
}
|
||
}
|
||
|
||
/// 初始化时获取一次未读总数
|
||
void initUnreadCount() async {
|
||
final res = await TencentImSDKPlugin.v2TIMManager.getConversationManager().getTotalUnreadMessageCount();
|
||
if (res.code == 0) {
|
||
totalUnread.value = res.data ?? 0;
|
||
Get.find<TabBarController>().setBadge(TabType.chat, totalUnread.value);
|
||
final to = res.data;
|
||
logger.i('初始化未读消息数$to');
|
||
} else {
|
||
//处理安卓端重新登录后获取未读数量失败的问题
|
||
logger.e('获取初始化未读数失败:${res.desc},重新补偿获取');
|
||
Future.delayed(Duration(seconds: 1), handAndroid);
|
||
}
|
||
}
|
||
|
||
/// 处理安卓端异常的问题
|
||
handAndroid() {
|
||
initUnreadCount();
|
||
final ctl = Get.find<ChatController>();
|
||
ctl.initChatData();
|
||
ctl.getConversationList();
|
||
}
|
||
|
||
/// 添加会话未读数监听器
|
||
void _addListener() {
|
||
TencentImSDKPlugin.v2TIMManager.getConversationManager().addConversationListener(listener: _listener);
|
||
logger.i('未读数监听器注册成功');
|
||
}
|
||
|
||
/// 手动更新total
|
||
Future<void> refreshUnreadCount() async {
|
||
initUnreadCount();
|
||
}
|
||
|
||
/// 移除监听器，防止重复注册
|
||
@override
|
||
void onClose() {
|
||
logger.i(_listener);
|
||
logger.i('移除global未读监听器');
|
||
TencentImSDKPlugin.v2TIMManager.getConversationManager().removeConversationListener(listener: _listener);
|
||
super.onClose();
|
||
}
|
||
}
|