338 lines
10 KiB
Dart
338 lines
10 KiB
Dart
import 'dart:developer';
|
||
|
||
import 'package:flutter/services.dart';
|
||
import 'package:flutter_openim_sdk/flutter_openim_sdk.dart';
|
||
|
||
class ConversationManager {
|
||
MethodChannel _channel;
|
||
late OnConversationListener listener;
|
||
|
||
ConversationManager(this._channel);
|
||
|
||
/// 会话监听
|
||
Future setConversationListener(OnConversationListener listener) {
|
||
this.listener = listener;
|
||
return _channel.invokeMethod('setConversationListener', _buildParam({}));
|
||
}
|
||
|
||
/// 获取所有会话
|
||
Future<List<ConversationInfo>> getAllConversationList(
|
||
{String? operationID}) =>
|
||
_channel
|
||
.invokeMethod(
|
||
'getAllConversationList',
|
||
_buildParam({
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}))
|
||
.then((value) =>
|
||
Utils.toList(value, (map) => ConversationInfo.fromJson(map)));
|
||
|
||
/// 分页获取会话
|
||
/// [offset] 开始下标
|
||
/// [count] 每页数量
|
||
Future<List<ConversationInfo>> getConversationListSplit({
|
||
int offset = 0,
|
||
int count = 20,
|
||
String? operationID,
|
||
}) =>
|
||
_channel
|
||
.invokeMethod(
|
||
'getConversationListSplit',
|
||
_buildParam({
|
||
'offset': offset,
|
||
'count': count,
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}))
|
||
.then((value) =>
|
||
Utils.toList(value, (map) => ConversationInfo.fromJson(map)));
|
||
|
||
/// 查询会话，如果会话不存在会自动生成一个
|
||
/// [sourceID] 如果是单聊会话传userID，如果是群聊会话传GroupID
|
||
/// [sessionType] 参考[ConversationType]
|
||
Future<ConversationInfo> getOneConversation({
|
||
required String sourceID,
|
||
required int sessionType,
|
||
String? operationID,
|
||
}) =>
|
||
_channel
|
||
.invokeMethod(
|
||
'getOneConversation',
|
||
_buildParam({
|
||
"sourceID": sourceID,
|
||
"sessionType": sessionType,
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}))
|
||
.then((value) =>
|
||
Utils.toObj(value, (map) => ConversationInfo.fromJson(map)));
|
||
|
||
/// 根据会话id获取多个会话
|
||
/// [conversationIDList] 会话id列表
|
||
Future<List<ConversationInfo>> getMultipleConversation({
|
||
required List<String> conversationIDList,
|
||
String? operationID,
|
||
}) =>
|
||
_channel
|
||
.invokeMethod(
|
||
'getMultipleConversation',
|
||
_buildParam({
|
||
"conversationIDList": conversationIDList,
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}))
|
||
.then((value) =>
|
||
Utils.toList(value, (map) => ConversationInfo.fromJson(map)));
|
||
|
||
/// 设置会话草稿
|
||
/// [conversationID] 会话id
|
||
/// [draftText] 草稿
|
||
Future setConversationDraft({
|
||
required String conversationID,
|
||
required String draftText,
|
||
String? operationID,
|
||
}) =>
|
||
_channel.invokeMethod(
|
||
'setConversationDraft',
|
||
_buildParam({
|
||
"conversationID": conversationID,
|
||
"draftText": draftText,
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}));
|
||
|
||
/// 置顶会话
|
||
/// [conversationID] 会话id
|
||
/// [isPinned] true：置顶，false：取消置顶
|
||
Future pinConversation({
|
||
required String conversationID,
|
||
required bool isPinned,
|
||
String? operationID,
|
||
}) =>
|
||
_channel.invokeMethod(
|
||
'pinConversation',
|
||
_buildParam({
|
||
"conversationID": conversationID,
|
||
"isPinned": isPinned,
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}));
|
||
|
||
/// 置顶会话
|
||
/// [conversationID] 会话id
|
||
Future hideConversation({
|
||
required String conversationID,
|
||
String? operationID,
|
||
}) =>
|
||
_channel.invokeMethod(
|
||
'hideConversation',
|
||
_buildParam({
|
||
"conversationID": conversationID,
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}));
|
||
|
||
/// 获取未读消息总数
|
||
/// int.tryParse(count) ?? 0;
|
||
Future<dynamic> getTotalUnreadMsgCount({
|
||
String? operationID,
|
||
}) =>
|
||
_channel.invokeMethod(
|
||
'getTotalUnreadMsgCount',
|
||
_buildParam({
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}));
|
||
|
||
/// 查询会话id
|
||
/// [sourceID] 如果是单聊值传用户ID，如果是群聊值传组ID
|
||
/// [sessionType] 参考[ConversationType]
|
||
// Future<dynamic> getConversationIDBySessionType({
|
||
// required String sourceID,
|
||
// required int sessionType,
|
||
// }) =>
|
||
// _channel.invokeMethod(
|
||
// 'getConversationIDBySessionType',
|
||
// _buildParam({
|
||
// "sourceID": sourceID,
|
||
// "sessionType": sessionType,
|
||
// }));
|
||
|
||
/// 消息免打扰设置
|
||
/// [conversationID] 会话id
|
||
/// [status] 0：正常；1：不接受消息；2：接受在线消息不接受离线消息；
|
||
Future<dynamic> setConversationRecvMessageOpt({
|
||
required String conversationID,
|
||
required int status,
|
||
String? operationID,
|
||
}) =>
|
||
_channel.invokeMethod(
|
||
'setConversationRecvMessageOpt',
|
||
_buildParam({
|
||
"conversationID": conversationID,
|
||
"status": status,
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}));
|
||
|
||
/// 查询免打扰状态
|
||
/// [conversationIDList] 会话id列表
|
||
/// 返回：[{"conversationId":"single_13922222222","result":0}]，result值：0：正常；1：不接受消息；2：接受在线消息不接受离线消息；
|
||
Future<List<dynamic>> getConversationRecvMessageOpt({
|
||
required List<String> conversationIDList,
|
||
String? operationID,
|
||
}) =>
|
||
_channel
|
||
.invokeMethod(
|
||
'getConversationRecvMessageOpt',
|
||
_buildParam({
|
||
"conversationIDList": conversationIDList,
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}))
|
||
.then((value) => Utils.toListMap(value));
|
||
|
||
/// 阅后即焚
|
||
/// [conversationID] 会话id
|
||
/// [isPrivate] true：开启，false：关闭
|
||
Future<dynamic> setConversationPrivateChat({
|
||
required String conversationID,
|
||
required bool isPrivate,
|
||
String? operationID,
|
||
}) =>
|
||
_channel.invokeMethod(
|
||
'setConversationPrivateChat',
|
||
_buildParam({
|
||
"conversationID": conversationID,
|
||
"isPrivate": isPrivate,
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}));
|
||
|
||
/// 删除本地以及服务器的会话
|
||
/// [conversationID] 会话ID
|
||
Future<dynamic> deleteConversationAndDeleteAllMsg({
|
||
required String conversationID,
|
||
String? operationID,
|
||
}) =>
|
||
_channel.invokeMethod(
|
||
'deleteConversationAndDeleteAllMsg',
|
||
_buildParam({
|
||
"conversationID": conversationID,
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}));
|
||
|
||
/// 清空会话里的消息
|
||
/// [conversationID] 会话ID
|
||
Future<dynamic> clearConversationAndDeleteAllMsg({
|
||
required String conversationID,
|
||
String? operationID,
|
||
}) =>
|
||
_channel.invokeMethod(
|
||
'clearConversationAndDeleteAllMsg',
|
||
_buildParam({
|
||
"conversationID": conversationID,
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}));
|
||
|
||
/// 删除所有本地会话
|
||
Future<dynamic> deleteAllConversationFromLocal({
|
||
String? operationID,
|
||
}) =>
|
||
_channel.invokeMethod(
|
||
'deleteAllConversationFromLocal',
|
||
_buildParam({
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}));
|
||
|
||
/// 重置强提醒标识[GroupAtType]
|
||
/// [conversationID] 会话id
|
||
Future<dynamic> resetConversationGroupAtType({
|
||
required String conversationID,
|
||
String? operationID,
|
||
}) =>
|
||
_channel.invokeMethod(
|
||
'resetConversationGroupAtType',
|
||
_buildParam({
|
||
"conversationID": conversationID,
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}));
|
||
|
||
/// 查询@所有人标识
|
||
Future<dynamic> getAtAllTag({
|
||
String? operationID,
|
||
}) =>
|
||
_channel.invokeMethod(
|
||
'getAtAllTag',
|
||
_buildParam({
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}));
|
||
|
||
/// 查询@所有人标识
|
||
String get atAllTag => 'AtAllTag';
|
||
|
||
/// 全局免打扰
|
||
/// [status] 0：正常；1：不接受消息；2：接受在线消息不接受离线消息；
|
||
Future<dynamic> setGlobalRecvMessageOpt({
|
||
required int status,
|
||
String? operationID,
|
||
}) =>
|
||
_channel.invokeMethod(
|
||
'setGlobalRecvMessageOpt',
|
||
_buildParam({
|
||
"status": status,
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}));
|
||
|
||
/// 设置阅后即焚时长
|
||
/// [conversationID] 会话id
|
||
/// [burnDuration] 时长s，默认30s
|
||
Future<dynamic> setConversationBurnDuration({
|
||
required String conversationID,
|
||
int burnDuration = 30,
|
||
String? operationID,
|
||
}) =>
|
||
_channel.invokeMethod(
|
||
'setConversationBurnDuration',
|
||
_buildParam({
|
||
"conversationID": conversationID,
|
||
"burnDuration": burnDuration,
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}));
|
||
|
||
/// 标记消息已读
|
||
/// [conversationID] 会话ID
|
||
/// [messageIDList] 被标记的消息clientMsgID
|
||
Future markConversationMessageAsRead({
|
||
required String conversationID,
|
||
String? operationID,
|
||
}) =>
|
||
_channel.invokeMethod(
|
||
'markConversationMessageAsRead',
|
||
_buildParam({
|
||
"conversationID": conversationID,
|
||
"operationID": Utils.checkOperationID(operationID),
|
||
}));
|
||
|
||
/// 会话列表自定义排序规则。
|
||
List<ConversationInfo> simpleSort(List<ConversationInfo> list) => list
|
||
..sort((a, b) {
|
||
if ((a.isPinned == true && b.isPinned == true) ||
|
||
(a.isPinned != true && b.isPinned != true)) {
|
||
int aCompare = a.draftTextTime! > a.latestMsgSendTime!
|
||
? a.draftTextTime!
|
||
: a.latestMsgSendTime!;
|
||
int bCompare = b.draftTextTime! > b.latestMsgSendTime!
|
||
? b.draftTextTime!
|
||
: b.latestMsgSendTime!;
|
||
if (aCompare > bCompare) {
|
||
return -1;
|
||
} else if (aCompare < bCompare) {
|
||
return 1;
|
||
} else {
|
||
return 0;
|
||
}
|
||
} else if (a.isPinned == true && b.isPinned != true) {
|
||
return -1;
|
||
} else {
|
||
return 1;
|
||
}
|
||
});
|
||
|
||
static Map _buildParam(Map param) {
|
||
param["ManagerName"] = "conversationManager";
|
||
log('param: $param');
|
||
return param;
|
||
}
|
||
}
|