基础页面
This commit is contained in:
379
lib/services/tim/conversation_service.dart
Normal file
379
lib/services/tim/conversation_service.dart
Normal file
@@ -0,0 +1,379 @@
|
||||
import 'package:chat/models/im/custom_message_model.dart';
|
||||
import 'package:chat/models/im/location_model.dart';
|
||||
import 'package:chat/services/tim_service.dart';
|
||||
import 'package:chat/utils/ui_tools.dart';
|
||||
import 'package:get/get.dart';
|
||||
import 'package:tencent_im_sdk_plugin/enum/V2TimConversationListener.dart';
|
||||
import 'package:tencent_im_sdk_plugin/enum/conversation_type.dart';
|
||||
import 'package:tencent_im_sdk_plugin/enum/receive_message_opt_enum.dart';
|
||||
import 'package:tencent_im_sdk_plugin/manager/v2_tim_conversation_manager.dart';
|
||||
import 'package:tencent_im_sdk_plugin/manager/v2_tim_message_manager.dart';
|
||||
import 'package:tencent_im_sdk_plugin/models/v2_tim_callback.dart';
|
||||
import 'package:tencent_im_sdk_plugin/models/v2_tim_conversation.dart';
|
||||
import 'package:tencent_im_sdk_plugin/models/v2_tim_msg_create_info_result.dart';
|
||||
import 'package:wechat_assets_picker/wechat_assets_picker.dart';
|
||||
|
||||
class TimConversationService extends GetxService {
|
||||
static TimConversationService get to => Get.find<TimConversationService>();
|
||||
|
||||
/// 消息管理实例
|
||||
V2TIMMessageManager get messageManager =>
|
||||
TimService.to.instance.v2TIMMessageManager;
|
||||
|
||||
/// 会话管理
|
||||
V2TIMConversationManager get conversationManager =>
|
||||
TimService.to.instance.v2ConversationManager;
|
||||
|
||||
@override
|
||||
void onInit() async {
|
||||
super.onInit();
|
||||
await fetchList();
|
||||
_addListener();
|
||||
}
|
||||
|
||||
_addListener() {
|
||||
conversationManager.addConversationListener(
|
||||
listener: V2TimConversationListener(
|
||||
|
||||
/// 未读消息总数监听
|
||||
onTotalUnreadMessageCountChanged: (_) {
|
||||
unreadCount.value = _;
|
||||
}));
|
||||
}
|
||||
|
||||
/// 会话列表
|
||||
RxList<V2TimConversation?> conversationList =
|
||||
List<V2TimConversation?>.empty(growable: true).obs;
|
||||
|
||||
/// 未读消息总数
|
||||
var unreadCount = 0.obs;
|
||||
|
||||
Future<void> fetchList() async {
|
||||
var data = await conversationManager.getConversationList(
|
||||
count: 100,
|
||||
nextSeq: '0',
|
||||
);
|
||||
|
||||
if (data.code == 0) {
|
||||
conversationList.value = data.data!.conversationList!;
|
||||
}
|
||||
}
|
||||
|
||||
/// 获取未读消息数
|
||||
Future<void> getUnreadCount() async {
|
||||
var result = await conversationManager.getTotalUnreadMessageCount();
|
||||
unreadCount.value = result.data ?? 0;
|
||||
}
|
||||
|
||||
/// 获取会话信息
|
||||
Future<V2TimConversation> getById(
|
||||
String conversationID,
|
||||
) async {
|
||||
var result = await conversationManager.getConversation(
|
||||
conversationID: conversationID,
|
||||
);
|
||||
return result.data!;
|
||||
}
|
||||
|
||||
/// 标记会话已读
|
||||
Future<void> markAsRead(V2TimConversation conversation) async {
|
||||
/// 标记会话内消息已读
|
||||
if (conversation.type == ConversationType.V2TIM_GROUP) {
|
||||
await messageManager.markGroupMessageAsRead(
|
||||
groupID: conversation.groupID!,
|
||||
);
|
||||
} else {
|
||||
await messageManager.markC2CMessageAsRead(
|
||||
userID: conversation.userID!,
|
||||
);
|
||||
}
|
||||
fetchList();
|
||||
}
|
||||
|
||||
/// 从会话列表移除会话
|
||||
Future<void> delete(V2TimConversation conversation) async {
|
||||
await deleteById(conversation.conversationID);
|
||||
fetchList();
|
||||
}
|
||||
|
||||
Future<void> deleteById(String conversationID) async {
|
||||
await conversationManager.deleteConversation(
|
||||
conversationID: conversationID,
|
||||
);
|
||||
fetchList();
|
||||
}
|
||||
|
||||
/// 清空会话历史消息
|
||||
Future<void> clearHistoryMessage(V2TimConversation conversation) async {
|
||||
if (conversation.type == ConversationType.V2TIM_GROUP) {
|
||||
await messageManager.clearGroupHistoryMessage(
|
||||
groupID: conversation.groupID!,
|
||||
);
|
||||
} else {
|
||||
await messageManager.clearC2CHistoryMessage(
|
||||
userID: conversation.userID!,
|
||||
);
|
||||
}
|
||||
fetchList();
|
||||
}
|
||||
|
||||
/// 设置会话置顶/取消置顶
|
||||
Future<bool> setOnTop(V2TimConversation conversation) async {
|
||||
var result = await conversationManager.pinConversation(
|
||||
conversationID: conversation.conversationID,
|
||||
isPinned: !conversation.isPinned!,
|
||||
);
|
||||
fetchList();
|
||||
|
||||
if (result.code != 0) {
|
||||
UiTools.toast(result.desc);
|
||||
}
|
||||
|
||||
return result.code == 0;
|
||||
}
|
||||
|
||||
/// 开启/关闭消息免打扰
|
||||
Future<bool> setReceiveOpt(
|
||||
V2TimConversation conversation,
|
||||
) async {
|
||||
V2TimCallback result;
|
||||
|
||||
if (conversation.type == ConversationType.V2TIM_GROUP) {
|
||||
result = await messageManager.setGroupReceiveMessageOpt(
|
||||
groupID: conversation.groupID!,
|
||||
opt: (conversation.recvOpt == 0)
|
||||
? ReceiveMsgOptEnum.V2TIM_NOT_RECEIVE_MESSAGE
|
||||
: ReceiveMsgOptEnum.V2TIM_RECEIVE_MESSAGE,
|
||||
);
|
||||
} else {
|
||||
result = await messageManager.setC2CReceiveMessageOpt(
|
||||
userIDList: [
|
||||
conversation.userID!,
|
||||
],
|
||||
opt: (conversation.recvOpt == 0)
|
||||
? ReceiveMsgOptEnum.V2TIM_NOT_RECEIVE_MESSAGE
|
||||
: ReceiveMsgOptEnum.V2TIM_RECEIVE_MESSAGE,
|
||||
);
|
||||
}
|
||||
|
||||
fetchList();
|
||||
|
||||
return result.code == 0;
|
||||
}
|
||||
|
||||
/// 发送消息
|
||||
Future<bool> sendTextMessage(
|
||||
V2TimConversation conversation,
|
||||
String text,
|
||||
) async {
|
||||
var msg = await messageManager.createTextAtMessage(
|
||||
text: text,
|
||||
atUserList: [],
|
||||
);
|
||||
if (msg.code == 0) {
|
||||
return await _sendMessage(conversation, msg.data!);
|
||||
} else {
|
||||
UiTools.toast(msg.desc);
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/// 发送图片消息
|
||||
Future<bool> sendImageMessage(
|
||||
V2TimConversation conversation,
|
||||
AssetEntity asset,
|
||||
) async {
|
||||
var msg = await messageManager.createImageMessage(
|
||||
imagePath: (await asset.file)!.path,
|
||||
);
|
||||
if (msg.code == 0) {
|
||||
return await _sendMessage(conversation, msg.data!);
|
||||
} else {
|
||||
UiTools.toast(msg.desc);
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/// 发送语音消息
|
||||
Future<bool> sendSoundMessage(
|
||||
V2TimConversation conversation,
|
||||
String soundPath,
|
||||
int duration,
|
||||
) async {
|
||||
var msg = await messageManager.createSoundMessage(
|
||||
soundPath: soundPath, duration: duration);
|
||||
if (msg.code == 0) {
|
||||
return await _sendMessage(conversation, msg.data!);
|
||||
} else {
|
||||
UiTools.toast(msg.desc);
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/// 发送视频消息
|
||||
Future<bool> sendVideoMessage(
|
||||
V2TimConversation conversation,
|
||||
AssetEntity asset,
|
||||
) async {
|
||||
return false;
|
||||
// final originFile = await asset.originFile;
|
||||
// var size = await originFile!.length();
|
||||
|
||||
// if (size >= 104857600) {
|
||||
// UiTools.toast('视频文件不能超过100M');
|
||||
// return false;
|
||||
// }
|
||||
|
||||
// final duration = asset.videoDuration.inSeconds;
|
||||
|
||||
// String tempPath = (await getTemporaryDirectory()).path;
|
||||
// String? thumbnail = await VideoThumbnail.thumbnailFile(
|
||||
// video: originFile.path,
|
||||
// thumbnailPath: tempPath,
|
||||
// imageFormat: ImageFormat.JPEG,
|
||||
// maxWidth: 256,
|
||||
// quality: 25,
|
||||
// );
|
||||
|
||||
// var msg = await messageManager.createVideoMessage(
|
||||
// videoFilePath: originFile.path,
|
||||
// type: asset.mimeType!.replaceFirst('video/', ''),
|
||||
// duration: duration,
|
||||
// snapshotPath: thumbnail ?? '',
|
||||
// );
|
||||
// if (msg.code == 0) {
|
||||
// return await _sendMessage(conversation, msg.data!);
|
||||
// } else {
|
||||
// UiTools.toast(msg.desc);
|
||||
// return false;
|
||||
// }
|
||||
}
|
||||
|
||||
/// 发送文件消息
|
||||
Future<bool> sendFileMessage(
|
||||
V2TimConversation conversation,
|
||||
String fileName,
|
||||
String filePath,
|
||||
) async {
|
||||
var msg = await messageManager.createFileMessage(
|
||||
fileName: fileName,
|
||||
filePath: filePath,
|
||||
);
|
||||
if (msg.code == 0) {
|
||||
return await _sendMessage(conversation, msg.data!);
|
||||
} else {
|
||||
UiTools.toast(msg.desc);
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/// 发送位置消息
|
||||
Future<bool> sendLocationMessage(
|
||||
V2TimConversation conversation,
|
||||
LocationModel messageModel,
|
||||
) async {
|
||||
var msg = await messageManager.createLocationMessage(
|
||||
desc: messageModel.name,
|
||||
latitude: messageModel.latitude,
|
||||
longitude: messageModel.longitude,
|
||||
);
|
||||
if (msg.code == 0) {
|
||||
return await _sendMessage(conversation, msg.data!);
|
||||
} else {
|
||||
UiTools.toast(msg.desc);
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/// 发送表情消息
|
||||
Future<bool> sendFaceMessage(
|
||||
V2TimConversation conversation,
|
||||
) async {
|
||||
var msg = await messageManager.createFaceMessage(
|
||||
data: '',
|
||||
index: 0,
|
||||
);
|
||||
if (msg.code == 0) {
|
||||
return await _sendMessage(conversation, msg.data!);
|
||||
} else {
|
||||
UiTools.toast(msg.desc);
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/// 发送聊天记录消息
|
||||
Future<bool> sendMergerMessage(
|
||||
V2TimConversation conversation,
|
||||
) async {
|
||||
var msg = await messageManager.createMergerMessage(
|
||||
abstractList: [],
|
||||
compatibleText: '',
|
||||
msgIDList: [],
|
||||
title: '',
|
||||
);
|
||||
if (msg.code == 0) {
|
||||
return await _sendMessage(conversation, msg.data!);
|
||||
} else {
|
||||
UiTools.toast(msg.desc);
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/// 发送自定义消息
|
||||
Future<bool> sendCustomMessage(
|
||||
V2TimConversation conversation,
|
||||
CustomMessageModel customMessageModel,
|
||||
String desc,
|
||||
) async {
|
||||
var msg = await messageManager.createCustomMessage(
|
||||
data: customMessageModel.toJson(),
|
||||
desc: desc,
|
||||
);
|
||||
if (msg.code == 0) {
|
||||
return await _sendMessage(conversation, msg.data!);
|
||||
} else {
|
||||
UiTools.toast(msg.desc);
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
Future<bool> _sendMessage(
|
||||
V2TimConversation conversation,
|
||||
V2TimMsgCreateInfoResult result,
|
||||
) async {
|
||||
var sendMessageRes = await messageManager.sendMessage(
|
||||
id: result.id!,
|
||||
receiver: conversation.type == ConversationType.V2TIM_C2C
|
||||
? conversation.userID!
|
||||
: '',
|
||||
groupID: conversation.type == ConversationType.V2TIM_GROUP
|
||||
? conversation.groupID!
|
||||
: '',
|
||||
// isExcludedFromUnreadCount: true,
|
||||
// isExcludedFromLastMessage: true,
|
||||
// needReadReceipt: true,
|
||||
);
|
||||
|
||||
if (sendMessageRes.code == 0) {
|
||||
// TimMessageService.to
|
||||
// .add(conversation.conversationID, result.messageInfo!);
|
||||
// eventBus.fire(result.messageInfo!);
|
||||
fetchList();
|
||||
return true;
|
||||
} else {
|
||||
UiTools.toast(sendMessageRes.desc);
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/// 设置会话草稿
|
||||
Future<void> draft(
|
||||
V2TimConversation conversation, {
|
||||
String? draftText = "",
|
||||
}) async {
|
||||
await conversationManager.setConversationDraft(
|
||||
conversationID: conversation.conversationID,
|
||||
draftText: draftText,
|
||||
);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user