129 lines
4.9 KiB
Dart
129 lines
4.9 KiB
Dart
import 'package:get/get.dart';
|
||
import 'package:loopin/IM/im_service.dart';
|
||
import 'package:loopin/models/conversation_type.dart' as myConversationType;
|
||
import 'package:loopin/models/conversation_view_model.dart';
|
||
import 'package:tencent_cloud_chat_sdk/models/v2_tim_conversation.dart';
|
||
import 'package:tencent_cloud_chat_sdk/models/v2_tim_conversation_filter.dart';
|
||
|
||
class ChatController extends GetxController {
|
||
RxInt count = 20.obs; // 每页条数
|
||
RxString nextSeq = '0'.obs; // 页码
|
||
RxBool isFinished = false.obs; // 是否拉取完？默认未拉取完
|
||
|
||
final chatList = <ConversationViewModel>[].obs;
|
||
|
||
void initChatData() {
|
||
// chatList.value = <ConversationViewModel>[];
|
||
chatList.clear();
|
||
nextSeq.value = '0';
|
||
isFinished.value = false;
|
||
}
|
||
|
||
// 获取所有会话列表
|
||
void getConversationList() async {
|
||
logger.e('开始获取会话列表数据');
|
||
if (isFinished.value) {
|
||
// 拉取完数据了，直接结束
|
||
logger.e('会话触底无数据');
|
||
return;
|
||
}
|
||
try {
|
||
final res = await ImService.instance.getConversationList(nextSeq.value, count.value);
|
||
|
||
if (!res.success || res.data == null) {
|
||
logger.e('获取会话失败::${res.desc}');
|
||
return;
|
||
}
|
||
|
||
final List<ConversationViewModel> convList = res.data;
|
||
for (var conv in convList) {
|
||
logger.w('基本会话: ${conv.conversation.toJson()}, 会话ID: ${conv.conversation.conversationID}');
|
||
}
|
||
|
||
chatList.addAll(convList);
|
||
// 不包含noFriend才执行加载数据逻辑,分页加载时候过滤
|
||
final hasNoFriend = chatList.any((item) => item.conversation.conversationGroupList?.contains(myConversationType.ConversationType.noFriend.name) ?? false);
|
||
if (!hasNoFriend) {
|
||
getNoFriendData();
|
||
}
|
||
} catch (e) {
|
||
logger.e('获取会话异常：:$e');
|
||
}
|
||
}
|
||
|
||
///构建陌生人消息菜单入口
|
||
void getNoFriendData({V2TimConversation? csion}) async {
|
||
// 检测会话列表是否已有陌生人消息菜单
|
||
final hasNoFriend = chatList.any((item) => item.conversation.conversationGroupList?.contains(myConversationType.ConversationType.noFriend.name) ?? false);
|
||
if (hasNoFriend) {
|
||
// 已经有了入口
|
||
final ConversationViewModel matchItem = chatList.firstWhere(
|
||
(item) => item.conversation.conversationGroupList?.contains(myConversationType.ConversationType.noFriend.name) ?? false,
|
||
);
|
||
// 获取陌生人未读总数
|
||
final unreadTotal = await ImService.instance.getUnreadMessageCountByFilter(
|
||
filter: V2TimConversationFilter(
|
||
conversationGroup: myConversationType.ConversationType.noFriend.name,
|
||
hasUnreadCount: true,
|
||
),
|
||
);
|
||
matchItem.conversation.lastMessage = csion!.lastMessage;
|
||
matchItem.conversation.unreadCount = unreadTotal.data;
|
||
chatList.refresh();
|
||
return;
|
||
}
|
||
// 没有则执行创建逻辑
|
||
final res = await ImService.instance.getConversationListByFilter(
|
||
filter: V2TimConversationFilter(conversationGroup: myConversationType.ConversationType.noFriend.name),
|
||
nextSeq: 0,
|
||
count: 1,
|
||
);
|
||
if (res.success && res.data != null) {
|
||
final convList = res.data!.conversationList ?? [];
|
||
if (convList.isNotEmpty) {
|
||
// logger.i(res.data!.toJson());
|
||
// 有陌生人消息，1.获取未读数，2.组装converstaionviewmodel
|
||
final unread = await ImService.instance.getUnreadMessageCountByFilter(
|
||
filter: V2TimConversationFilter(
|
||
conversationGroup: myConversationType.ConversationType.noFriend.name,
|
||
hasUnreadCount: true,
|
||
),
|
||
);
|
||
if (unread.success) {
|
||
final conv = convList.first;
|
||
final faceUrl = 'assets/images/notify/msr.png';
|
||
conv.showName = '陌生人消息';
|
||
conv.unreadCount = unread.data;
|
||
final createItem = ConversationViewModel(
|
||
conversation: conv,
|
||
faceUrl: faceUrl,
|
||
);
|
||
final newList = List<ConversationViewModel>.from(chatList);
|
||
newList.add(createItem);
|
||
newList.sort((a, b) {
|
||
final atime = a.conversation.lastMessage?.timestamp ?? 0;
|
||
final btime = b.conversation.lastMessage?.timestamp ?? 0;
|
||
return btime.compareTo(atime); // 降序
|
||
});
|
||
chatList.value = newList;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
/// 按会话分组查询 getConversationListByFilter
|
||
// void filterConversationList() async {
|
||
// final res = await ImService.instance.getConversationListByFilter(
|
||
// filter: V2TimConversationFilter(conversationGroup: null),
|
||
// nextSeq: nextSeq.value,
|
||
// );
|
||
// final convList = res.data!.conversationList;
|
||
// logger.i(res.data!.toJson());
|
||
// chatList.value = convList;
|
||
// // for (var element in convList ?? []) {
|
||
// // logger.i(element.toJson());
|
||
// // // 你可以在这里继续处理 element
|
||
// // }
|
||
// }
|
||
}
|