flutter/lib/IM/global_badge.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/tab_type.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;

  @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.i("新会话创建:${conv.conversationGroupList}");
          handleCoverstion(conv);
        }
      },
      onConversationChanged: (List<V2TimConversation> conversationList) async {
        logger.w('会话变更:会话分组：${conversationList.first.conversationGroupList}，会话内容${conversationList.first.toLogString()}');
        final ctl = Get.find<ChatController>();
        final updatedIds = conversationList.map((e) => e.conversationID).toSet();
        logger.w('要变更的会话id：$updatedIds');
        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)) {
            final updatedConv = conversationList.firstWhere(
              (c) => c.conversationID == chatItem.conversation.conversationID,
              orElse: () => V2TimConversation(conversationID: ''),
            );

            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; // 获取陌生人未读总数
            } else {
              // 其他类型统一更新处理
              chatItem.conversation = updatedConv;
            }
          }
        }
        //重新排序
        ctl.chatList.sort((a, b) {
          final atime = a.conversation.lastMessage?.timestamp ?? 0;
          final btime = b.conversation.lastMessage?.timestamp ?? 0;
          return btime.compareTo(atime); // 降序
        });
        ctl.chatList.refresh();
      },
    );
    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');
    }
  }

  /// 添加会话未读数监听器
  void _addListener() {
    TencentImSDKPlugin.v2TIMManager.getConversationManager().addConversationListener(listener: _listener);
    logger.i('未读数监听器注册成功');
  }

  /// 手动更新total
  Future<void> refreshUnreadCount() async {
    _initUnreadCount();
  }

  /// 移除监听器，防止重复注册
  @override
  void onClose() {
    TencentImSDKPlugin.v2TIMManager.getConversationManager().removeConversationListener(listener: _listener);
    super.onClose();
  }
}