new_version1

2022-02-16 15:36:37 +08:00
parent cd0865853b
commit f3261d2ce4
99 changed files with 4404 additions and 3093 deletions
--- a/lib/src/manager/im_conversation_manager.dart
+++ b/lib/src/manager/im_conversation_manager.dart
@@ -20,15 +20,22 @@ class ConversationManager {

  /// Get all conversations
  /// 获取所有会话
-  Future<List<ConversationInfo>> getAllConversationList() => _channel
-      .invokeMethod('getAllConversationList', _buildParam({}))
-      .then((value) => _toList(value));
+  Future<List<ConversationInfo>> getAllConversationList(
+          {String? operationID}) =>
+      _channel
+          .invokeMethod(
+              'getAllConversationList',
+              _buildParam({
+                "operationID": _checkOperationID(operationID),
+              }))
+          .then((value) => _toList(value));

  /// Paging to get conversation
-  /// 分页获取会话, [offset]下次获取开始index
+  /// 分页获取会话
  Future<List<ConversationInfo>> getConversationListSplit({
    int offset = 0,
    int count = 20,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
@@ -36,18 +43,20 @@ class ConversationManager {
              _buildParam({
                'offset': offset,
                'count': count,
+                "operationID": _checkOperationID(operationID),
              }))
          .then((value) => _toList(value));

-  /// Get a single conversation info
-  /// [sourceID]  if it is a single chat, Its value is userID. if it is a group chat, Its value is groupID
-  /// [sessionType]  if it is a single chat, it value is 1. if it is a group chat, it value is 2
-  /// 获取单个会话
-  /// [sourceID]如果是单聊值传用户id，如果是群聊值传组id
-  /// [sessionType]如果是单聊值传1，如果是群聊值传2
-  Future<ConversationInfo> getSingleConversation({
+  /// Get a conversation, if it doesn't exist it will be created automatically
+  /// [sourceID] if it is a single chat, Its value is userID. if it is a group chat, Its value is groupID
+  /// [sessionType] if it is a single chat, it value is 1. if it is a group chat, it value is 2
+  /// 获取一个会话，如果不存在会自动创建
+  /// [sourceID] 如果是单聊值传用户ID，如果是群聊值传组ID
+  /// [sessionType] 如果是单聊值传1，如果是群聊值传2
+  Future<ConversationInfo> getOneConversation({
    required String sourceID,
    required int sessionType,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
@@ -55,6 +64,7 @@ class ConversationManager {
              _buildParam({
                "sourceID": sourceID,
                "sessionType": sessionType,
+                "operationID": _checkOperationID(operationID),
              }))
          .then((value) => _toObj(value));

@@ -62,12 +72,14 @@ class ConversationManager {
  /// 获取多个会话
  Future<List<ConversationInfo>> getMultipleConversation({
    required List<String> conversationIDList,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
              'getMultipleConversation',
              _buildParam({
                "conversationIDList": conversationIDList,
+                "operationID": _checkOperationID(operationID),
              }))
          .then((value) => _toList(value));

@@ -75,12 +87,14 @@ class ConversationManager {
  /// 删除会话
  Future deleteConversation({
    required String conversationID,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
              'deleteConversation',
              _buildParam({
                "conversationID": conversationID,
+                "operationID": _checkOperationID(operationID),
              }))
          .then((value) => _printValue(value));

@@ -89,6 +103,7 @@ class ConversationManager {
  Future setConversationDraft({
    required String conversationID,
    required String draftText,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
@@ -96,6 +111,7 @@ class ConversationManager {
              _buildParam({
                "conversationID": conversationID,
                "draftText": draftText,
+                "operationID": _checkOperationID(operationID),
              }))
          .then((value) => _printValue(value));

@@ -104,6 +120,7 @@ class ConversationManager {
  Future pinConversation({
    required String conversationID,
    required bool isPinned,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
@@ -111,33 +128,47 @@ class ConversationManager {
              _buildParam({
                "conversationID": conversationID,
                "isPinned": isPinned,
+                "operationID": _checkOperationID(operationID),
              }))
          .then((value) => _printValue(value));

  /// Mark single chat messages as read
  /// 标记单聊已读
-  Future<dynamic> markSingleMessageHasRead({required String userID}) =>
-      _channel.invokeMethod(
-          'markSingleMessageHasRead', _buildParam({'userID': userID}));
+  // Future<dynamic> markSingleMessageHasRead({required String userID}) =>
+  //     _channel.invokeMethod(
+  //         'markSingleMessageHasRead', _buildParam({'userID': userID}));

  /// Mark group chat messages as read
  /// 标记群聊已读
-  Future<dynamic> markGroupMessageHasRead({required String groupID}) =>
+  Future<dynamic> markGroupMessageHasRead({
+    required String groupID,
+    String? operationID,
+  }) =>
      _channel.invokeMethod(
-          'markGroupMessageHasRead', _buildParam({'groupID': groupID}));
+          'markGroupMessageHasRead',
+          _buildParam({
+            'groupID': groupID,
+            "operationID": _checkOperationID(operationID),
+          }));

  /// Get the total number of unread messages
  /// 获取未读消息总数
-  Future<dynamic> getTotalUnreadMsgCount() =>
-      _channel.invokeMethod('getTotalUnreadMsgCount', _buildParam({}));
+  Future<dynamic> getTotalUnreadMsgCount({
+    String? operationID,
+  }) =>
+      _channel.invokeMethod(
+          'getTotalUnreadMsgCount',
+          _buildParam({
+            "operationID": _checkOperationID(operationID),
+          }));

  /// Query conversation id
-  /// [sourceID] : if it is a single chat, Its value is userID. if it is a group chat, Its value is groupID
-  /// [sessionType] : if it is a single chat, it value is 1. if it is a group chat, it value is 2
+  /// [sourceID] if it is a single chat, Its value is userID. if it is a group chat, Its value is groupID
+  /// [sessionType] if it is a single chat, it value is 1. if it is a group chat, it value is 2
  /// 查询会话id
-  /// [sourceID]如果是单聊值传用户id，如果是群聊值传组id
-  /// [sessionType]如果是单聊值传1，如果是群聊值传2
-  Future<dynamic> getConversationID({
+  /// [sourceID] 如果是单聊值传用户ID，如果是群聊值传组ID
+  /// [sessionType] 如果是单聊值传1，如果是群聊值传2
+  Future<dynamic> getConversationIDBySessionType({
    required String sourceID,
    required int sessionType,
  }) =>
@@ -149,18 +180,20 @@ class ConversationManager {
          }));

  /// Message Do Not Disturb
-  /// [status] 1: Do not receive messages, 2: Do not notify when messages are received; 0: Normal
+  /// [status] 1: Do not receive messages. 2: Do not notify when messages are received. 0: Normal.
  /// 消息免打扰设置
  /// [status] 1：不接受消息；2：接受在线消息不接受离线消息；3：正常
  Future<dynamic> setConversationRecvMessageOpt({
    required List<String> conversationIDList,
    required int status,
+    String? operationID,
  }) =>
      _channel.invokeMethod(
          'setConversationRecvMessageOpt',
          _buildParam({
            "conversationIDList": conversationIDList,
            "status": status,
+            "operationID": _checkOperationID(operationID),
          }));

  /// Message Do Not Disturb
@@ -168,12 +201,14 @@ class ConversationManager {
  /// 查询免打扰状态
  Future<List<dynamic>> getConversationRecvMessageOpt({
    required List<String> conversationIDList,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
              'getConversationRecvMessageOpt',
              _buildParam({
                "conversationIDList": conversationIDList,
+                "operationID": _checkOperationID(operationID),
              }))
          .then((value) => _formatJson(value));

@@ -181,13 +216,13 @@ class ConversationManager {
  /// 会话列表自定义排序规则
  List<ConversationInfo> simpleSort(List<ConversationInfo> list) => list
    ..sort((a, b) {
-      if ((a.isPinned == 1 && b.isPinned == 1) ||
-          (a.isPinned != 1 && b.isPinned != 1)) {
-        int aCompare = a.draftTimestamp! > a.latestMsgSendTime!
-            ? a.draftTimestamp!
+      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.draftTimestamp! > b.latestMsgSendTime!
-            ? b.draftTimestamp!
+        int bCompare = b.draftTextTime! > b.latestMsgSendTime!
+            ? b.draftTextTime!
            : b.latestMsgSendTime!;
        if (aCompare > bCompare) {
          return -1;
@@ -196,7 +231,7 @@ class ConversationManager {
        } else {
          return 0;
        }
-      } else if (a.isPinned == 1 && b.isPinned != 1) {
+      } else if (a.isPinned == true && b.isPinned != true) {
        return -1;
      } else {
        return 1;
@@ -222,4 +257,8 @@ class ConversationManager {
  static String _printValue(value) {
    return value;
  }
+
+  static String _checkOperationID(String? obj) {
+    return obj ?? DateTime.now().millisecondsSinceEpoch.toString();
+  }
 }
--- a/lib/src/manager/im_friendship_manager.dart
+++ b/lib/src/manager/im_friendship_manager.dart
@@ -18,82 +18,189 @@ class FriendshipManager {

  /// Get friend info by user id
  /// 查询好友信息
-  Future<List<UserInfo>> getFriendsInfo({required List<String> uidList}) =>
+  Future<List<UserInfo>> getFriendsInfo({
+    required List<String> uidList,
+    String? operationID,
+  }) =>
      _channel
-          .invokeMethod('getFriendsInfo', _buildParam({"uidList": uidList}))
-          .then((value) => _toList(value));
+          .invokeMethod(
+              'getFriendsInfo',
+              _buildParam({
+                "uidList": uidList,
+                "operationID": _checkOperationID(operationID),
+              }))
+          .then((value) => _toList(value, (v) => UserInfo.fromJson(v.cast())));

  /// Send an friend application
  /// 发送一个好友请求
-  Future<dynamic> addFriend({required String uid, required String reason}) =>
+  Future<dynamic> addFriend({
+    required String uid,
+    String? reason,
+    String? operationID,
+  }) =>
      _channel.invokeMethod(
-          'addFriend', _buildParam({"uid": uid, "reqMessage": reason}));
+          'addFriend',
+          _buildParam({
+            "toUserID": uid,
+            "reqMsg": reason,
+            "operationID": _checkOperationID(operationID),
+          }));

-  /// Get all friend application, sent to you by others
-  /// 获取所有好友申请
-  Future<List<UserInfo>> getFriendApplicationList() => _channel
-      .invokeMethod('getFriendApplicationList', _buildParam({}))
-      .then((value) => _toList(value));
+  /// Get someone's request to add me as a friend
+  /// 获取别人加我为好友的申请
+  Future<List<FriendApplicationInfo>> getRecvFriendApplicationList(
+          {String? operationID}) =>
+      _channel
+          .invokeMethod(
+              'getRecvFriendApplicationList',
+              _buildParam({
+                "operationID": _checkOperationID(operationID),
+              }))
+          .then((value) =>
+              _toList(value, (v) => FriendApplicationInfo.fromJson(v.cast())));
+
+  /// Get friend requests from me
+  /// 获取我发出的好友申请
+  Future<List<FriendApplicationInfo>> getSendFriendApplicationList(
+          {String? operationID}) =>
+      _channel
+          .invokeMethod(
+              'getSendFriendApplicationList',
+              _buildParam({
+                "operationID": _checkOperationID(operationID),
+              }))
+          .then((value) =>
+              _toList(value, (v) => FriendApplicationInfo.fromJson(v.cast())));

  /// Find all friends including those who have been added to the blacklist
  /// 获取好友列表包含已拉入黑名单的好友
-  Future<List<UserInfo>> getFriendList() => _channel
-      .invokeMethod('getFriendList', _buildParam({}))
-      .then((value) => _toList(value));
+  Future<List<UserInfo>> getFriendList({String? operationID}) => _channel
+      .invokeMethod(
+          'getFriendList',
+          _buildParam({
+            "operationID": _checkOperationID(operationID),
+          }))
+      .then((value) => _toList(value, (v) => UserInfo.fromJson(v.cast())));

  /// Find all friends including those who have been added to the blacklist
  /// 获取好友列表
-  Future<List<dynamic>> getFriendListMap() => _channel
-      .invokeMethod('getFriendList', _buildParam({}))
+  Future<List<dynamic>> getFriendListMap({String? operationID}) => _channel
+      .invokeMethod(
+          'getFriendList',
+          _buildParam({
+            "operationID": _checkOperationID(operationID),
+          }))
      .then((value) => _toListMap(value));

  /// Modify friend information, only [comment] can be modified
  /// 设置好友备注
-  Future<dynamic> setFriendInfo(
-          {required String uid, required String comment}) =>
+  Future<dynamic> setFriendRemark({
+    required String uid,
+    required String remark,
+    String? operationID,
+  }) =>
      _channel.invokeMethod(
-          'setFriendInfo',
+          'setFriendRemark',
          _buildParam({
-            'uid': uid,
-            'comment': comment,
+            'toUserID': uid,
+            'remark': remark,
+            "operationID": _checkOperationID(operationID),
          }));

  /// Add friends to blacklist
  /// 加入黑名单
-  Future<dynamic> addToBlackList({required String uid}) =>
-      _channel.invokeMethod('addToBlackList', _buildParam({"uid": uid}));
+  Future<dynamic> addBlacklist({
+    required String uid,
+    String? operationID,
+  }) =>
+      _channel.invokeMethod(
+          'addBlacklist',
+          _buildParam({
+            "uid": uid,
+            "operationID": _checkOperationID(operationID),
+          }));

  /// Find all blacklist
  /// 获取黑名单列表
-  Future<List<UserInfo>> getBlackList() => _channel
-      .invokeMethod('getBlackList', _buildParam({}))
-      .then((value) => _toList(value));
+  Future<List<UserInfo>> getBlacklist({String? operationID}) => _channel
+      .invokeMethod(
+          'getBlacklist',
+          _buildParam({
+            "operationID": _checkOperationID(operationID),
+          }))
+      .then((value) => _toList(value, (v) => UserInfo.fromJson(v.cast())));

  /// Remove from blacklist
  /// 从黑名单移除
-  Future<dynamic> deleteFromBlackList({required String uid}) =>
-      _channel.invokeMethod('deleteFromBlackList', _buildParam({"uid": uid}));
+  Future<dynamic> removeBlacklist({
+    required String uid,
+    String? operationID,
+  }) =>
+      _channel.invokeMethod(
+          'removeBlacklist',
+          _buildParam({
+            "uid": uid,
+            "operationID": _checkOperationID(operationID),
+          }));

  /// Determine if there is a friendship by userId
  /// 检查友好关系
-  Future<List<UserInfo>> checkFriend(List<String> uidList) => _channel
-      .invokeMethod('checkFriend', _buildParam({'uidList': uidList}))
-      .then((value) => _toList(value));
+  Future<List<FriendshipInfo>> checkFriend({
+    required List<String> uidList,
+    String? operationID,
+  }) =>
+      _channel
+          .invokeMethod(
+              'checkFriend',
+              _buildParam({
+                'uidList': uidList,
+                "operationID": _checkOperationID(operationID),
+              }))
+          .then((value) =>
+              _toList(value, (v) => FriendshipInfo.fromJson(v.cast())));

  /// Dissolve friendship from friend list
  /// 删除好友
-  Future<dynamic> deleteFromFriendList({required String uid}) =>
-      _channel.invokeMethod('deleteFromFriendList', _buildParam({"uid": uid}));
+  Future<dynamic> deleteFriend({
+    required String uid,
+    String? operationID,
+  }) =>
+      _channel.invokeMethod(
+          'deleteFriend',
+          _buildParam({
+            "uid": uid,
+            "operationID": _checkOperationID(operationID),
+          }));

  /// Accept application of be friend
  /// 接受好友请求
-  Future<dynamic> acceptFriendApplication({required String uid}) => _channel
-      .invokeMethod('acceptFriendApplication', _buildParam({"uid": uid}));
+  Future<dynamic> acceptFriendApplication({
+    required String uid,
+    String? handleMsg,
+    String? operationID,
+  }) =>
+      _channel.invokeMethod(
+          'acceptFriendApplication',
+          _buildParam({
+            "toUserID": uid,
+            "handleMsg": handleMsg,
+            "operationID": _checkOperationID(operationID),
+          }));

  /// Refuse application of be friend
  /// 拒绝好友请求
-  Future<dynamic> refuseFriendApplication({required String uid}) => _channel
-      .invokeMethod('refuseFriendApplication', _buildParam({"uid": uid}));
+  Future<dynamic> refuseFriendApplication({
+    required String uid,
+    String? handleMsg,
+    String? operationID,
+  }) =>
+      _channel.invokeMethod(
+          'refuseFriendApplication',
+          _buildParam({
+            "toUserID": uid,
+            "handleMsg": handleMsg,
+            "operationID": _checkOperationID(operationID),
+          }));

  ///
  // Future<dynamic> forceSyncFriendApplication() {
@@ -115,10 +222,10 @@ class FriendshipManager {
    return param;
  }

-  static List<UserInfo> _toList(String? value) {
+  static List<T> _toList<T>(String? value, T f(Map map)) {
    var list = _formatJson(value);
-    if (null == list) return <UserInfo>[];
-    return (list as List).map((e) => UserInfo.fromJson(e)).toList();
+    if (null == list) return <T>[];
+    return (list as List).map((e) => f(e)).toList();
  }

  static List<dynamic> _toListMap(String? value) {
@@ -133,4 +240,8 @@ class FriendshipManager {
  static String _printValue(value) {
    return value;
  }
+
+  static String _checkOperationID(String? obj) {
+    return obj ?? DateTime.now().millisecondsSinceEpoch.toString();
+  }
 }
--- a/lib/src/manager/im_group_manager.dart
+++ b/lib/src/manager/im_group_manager.dart
@@ -23,6 +23,7 @@ class GroupManager {
    required String groupId,
    required List<String> uidList,
    String? reason,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
@@ -31,6 +32,7 @@ class GroupManager {
                'gid': groupId,
                'reason': reason,
                'uidList': uidList,
+                "operationID": _checkOperationID(operationID),
              }))
          .then((value) => (_formatJson(value) as List)
              .map((e) => GroupInviteResult.fromJson(e))
@@ -42,6 +44,7 @@ class GroupManager {
    required String groupId,
    required List<String> uidList,
    String? reason,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
@@ -50,6 +53,7 @@ class GroupManager {
                'gid': groupId,
                'reason': reason,
                'uidList': uidList,
+                "operationID": _checkOperationID(operationID),
              }))
          .then((value) => (_formatJson(value) as List)
              .map((e) => GroupInviteResult.fromJson(e))
@@ -60,6 +64,7 @@ class GroupManager {
  Future<List<GroupMembersInfo>> getGroupMembersInfo({
    required String groupId,
    required List<String> uidList,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
@@ -67,19 +72,20 @@ class GroupManager {
              _buildParam({
                'gid': groupId,
                'uidList': uidList,
+                "operationID": _checkOperationID(operationID),
              }))
          .then((value) => (_formatJson(value) as List)
              .map((e) => GroupMembersInfo.fromJson(e))
              .toList());

  /// Get the list of group members
-  /// [filter] 0: all user, 1: group owner, 2: administrator
-  /// [next] begin index, pull and fill 0 for the first time
-  /// 获取组成员列表
-  Future<GroupMembersList> getGroupMemberList({
+  /// 分页获取组成员列表
+  Future<List<GroupMembersInfo>> getGroupMemberList({
    required String groupId,
    int filter = 0,
-    int next = 0,
+    int offset = 0,
+    int count = 0,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
@@ -87,16 +93,22 @@ class GroupManager {
              _buildParam({
                'gid': groupId,
                'filter': filter,
-                'next': next,
+                'offset': offset,
+                'count': count,
+                'operationID': _checkOperationID(operationID),
              }))
-          .then((value) => GroupMembersList.fromJson(_formatJson(value)));
+          .then((value) => (_formatJson(value) as List)
+              .map((e) => GroupMembersInfo.fromJson(e))
+              .toList());

  /// Get the list of group members
-  /// 获取组成员列表
+  /// 分页获取组成员列表
  Future<dynamic> getGroupMemberListMap({
    required String groupId,
    int filter = 0,
-    int next = 0,
+    int offset = 0,
+    int count = 0,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
@@ -104,49 +116,72 @@ class GroupManager {
              _buildParam({
                'gid': groupId,
                'filter': filter,
-                'next': next,
+                'offset': offset,
+                'count': count,
+                'operationID': _checkOperationID(operationID),
              }))
          .then((value) => _formatJson(value));

  /// Find all groups you have joined
  /// 查询已加入的组列表
-  Future<List<GroupInfo>> getJoinedGroupList() => _channel
-      .invokeMethod('getJoinedGroupList', _buildParam({}))
+  Future<List<GroupInfo>> getJoinedGroupList({String? operationID}) => _channel
+      .invokeMethod(
+          'getJoinedGroupList',
+          _buildParam({
+            'operationID': _checkOperationID(operationID),
+          }))
      .then((value) => (_formatJson(value) as List)
          .map((e) => GroupInfo.fromJson(e))
          .toList());

  /// Find all groups you have joined
  /// 查询已加入的组列表
-  Future<List<dynamic>> getJoinedGroupListMap() => _channel
-      .invokeMethod('getJoinedGroupList', _buildParam({}))
+  Future<List<dynamic>> getJoinedGroupListMap({String? operationID}) => _channel
+      .invokeMethod(
+          'getJoinedGroupList',
+          _buildParam({
+            'operationID': _checkOperationID(operationID),
+          }))
      .then((value) => _formatJson(value));

  /// Check if you are a member of the group
  /// 检查是否已加入组
-  Future<bool> isJoinedGroup({required String gid}) => getJoinedGroupList()
-      .then((list) => list.where((e) => e.groupID == gid).length > 0);
+  Future<bool> isJoinedGroup({
+    required String gid,
+    String? operationID,
+  }) =>
+      getJoinedGroupList(
+        operationID: _checkOperationID(operationID),
+      ).then((list) => list.where((e) => e.groupID == gid).length > 0);

  /// Create a group
  /// 创建一个组
-  Future<dynamic> createGroup({
+  Future<GroupInfo> createGroup({
    String? groupName,
    String? notification,
    String? introduction,
    String? faceUrl,
+    int? groupType,
+    String? ex,
    required List<GroupMemberRole> list,
+    String? operationID,
  }) =>
-      _channel.invokeMethod(
-          'createGroup',
-          _buildParam({
-            'gInfo': {
-              "groupName": groupName,
-              "notification": notification,
-              "introduction": introduction,
-              "faceUrl": faceUrl,
-            },
-            'memberList': list.map((e) => e.toJson()).toList()
-          }));
+      _channel
+          .invokeMethod(
+              'createGroup',
+              _buildParam({
+                'gInfo': {
+                  "groupName": groupName,
+                  "notification": notification,
+                  "introduction": introduction,
+                  "faceURL": faceUrl,
+                  "groupType": groupType,
+                  "ex": ex,
+                },
+                'memberList': list.map((e) => e.toJson()).toList(),
+                'operationID': _checkOperationID(operationID),
+              }))
+          .then((value) => GroupInfo.fromJson(_formatJson(value)));

  /// Edit group information
  /// 编辑组资料
@@ -156,26 +191,37 @@ class GroupManager {
    String? notification,
    String? introduction,
    String? faceUrl,
+    String? ex,
+    String? operationID,
  }) =>
      _channel.invokeMethod(
          'setGroupInfo',
          _buildParam({
+            "gid": groupID,
            'gInfo': {
-              "groupID": groupID,
+              // "groupID": groupID,
              "groupName": groupName,
              "notification": notification,
              "introduction": introduction,
-              "faceUrl": faceUrl,
+              "faceURL": faceUrl,
+              "ex": ex,
            },
+            'operationID': _checkOperationID(operationID),
          }));

  /// Find group information by group id
  /// 查询组信息
  Future<List<GroupInfo>> getGroupsInfo({
    required List<String> gidList,
+    String? operationID,
  }) =>
      _channel
-          .invokeMethod('getGroupsInfo', _buildParam({'gidList': gidList}))
+          .invokeMethod(
+              'getGroupsInfo',
+              _buildParam({
+                'gidList': gidList,
+                'operationID': _checkOperationID(operationID),
+              }))
          .then((value) {
        List list = _formatJson(value);
        return list.map((e) => GroupInfo.fromJson(e)).toList();
@@ -186,23 +232,27 @@ class GroupManager {
  Future<dynamic> joinGroup({
    required String gid,
    String? reason,
+    String? operationID,
  }) =>
      _channel.invokeMethod(
          'joinGroup',
          _buildParam({
            'gid': gid,
            'reason': reason,
+            'operationID': _checkOperationID(operationID),
          }));

  /// Leave group
  /// 退出组
  Future<dynamic> quitGroup({
    required String gid,
+    String? operationID,
  }) =>
      _channel.invokeMethod(
          'quitGroup',
          _buildParam({
            'gid': gid,
+            'operationID': _checkOperationID(operationID),
          }));

  /// Give group permissions to others
@@ -210,44 +260,76 @@ class GroupManager {
  Future<dynamic> transferGroupOwner({
    required String gid,
    required String uid,
+    String? operationID,
  }) =>
      _channel.invokeMethod(
          'transferGroupOwner',
          _buildParam({
            'gid': gid,
            'uid': uid,
+            'operationID': _checkOperationID(operationID),
          }));

-  /// Get the list of applications
-  /// 获取所有进组申请
-  Future<GroupApplicationList> getGroupApplicationList() => _channel
-      .invokeMethod('getGroupApplicationList', _buildParam({}))
-      .then((value) => GroupApplicationList.fromJson(_formatJson(value)));
+  /// As the group owner or administrator, get the list of received group members' applications to join the group.
+  /// 作为群主或者管理员，获取收到的群成员申请进群列表。
+  Future<List<GroupApplicationInfo>> getRecvGroupApplicationList(
+          {String? operationID}) =>
+      _channel
+          .invokeMethod(
+              'getRecvGroupApplicationList',
+              _buildParam({
+                'operationID': _checkOperationID(operationID),
+              }))
+          .then((value) => (_formatJson(value) as List)
+              .map((e) => GroupApplicationInfo.fromJson(e))
+              .toList());
+
+  /// Get the record of the group membership application issued by yourself
+  /// 获取自己发出的入群申请记录
+  Future<List<GroupApplicationInfo>> getSendGroupApplicationList(
+          {String? operationID}) =>
+      _channel
+          .invokeMethod(
+              'getSendGroupApplicationList',
+              _buildParam({
+                'operationID': _checkOperationID(operationID),
+              }))
+          .then((value) => (_formatJson(value) as List)
+              .map((e) => GroupApplicationInfo.fromJson(e))
+              .toList());

  /// Accept group application
-  /// 同意进组申请
+  /// 管理员或者群主同意某人进入某群
  Future<dynamic> acceptGroupApplication({
-    required GroupApplicationInfo info,
-    required String reason,
+    required String gid,
+    required String uid,
+    String? handleMsg,
+    String? operationID,
  }) =>
      _channel.invokeMethod(
          'acceptGroupApplication',
          _buildParam({
-            'application': info.toJson(),
-            'reason': reason,
+            'gid': gid,
+            'uid': uid,
+            'handleMsg': handleMsg,
+            'operationID': _checkOperationID(operationID),
          }));

  /// Refuse group application
-  /// 拒绝进组申请
+  /// 管理员或者群主拒绝某人进入某群
  Future<dynamic> refuseGroupApplication({
-    required GroupApplicationInfo info,
-    required String reason,
+    required String gid,
+    required String uid,
+    String? handleMsg,
+    String? operationID,
  }) =>
      _channel.invokeMethod(
          'refuseGroupApplication',
          _buildParam({
-            'application': info.toJson(),
-            'reason': reason,
+            'gid': gid,
+            'uid': uid,
+            'handleMsg': handleMsg,
+            'operationID': _checkOperationID(operationID),
          }));

  ///
@@ -280,4 +362,8 @@ class GroupManager {
  static String _printValue(value) {
    return value;
  }
+
+  static String _checkOperationID(String? obj) {
+    return obj ?? DateTime.now().millisecondsSinceEpoch.toString();
+  }
 }
--- a/lib/src/manager/im_manager.dart
+++ b/lib/src/manager/im_manager.dart
@@ -3,6 +3,7 @@ import 'dart:developer';

 import 'package:flutter/services.dart';
 import 'package:flutter_openim_sdk/flutter_openim_sdk.dart';
+import 'package:flutter_openim_sdk/src/manager/im_user_manager.dart';

 class IMManager {
  MethodChannel _channel;
@@ -10,13 +11,13 @@ class IMManager {
  late FriendshipManager friendshipManager;
  late MessageManager messageManager;
  late GroupManager groupManager;
+  late UserManager userManager;

  // late OfflinePushManager offlinePushManager;
  // late SignalingManager signalingManager;
-  late InitSDKListener _initSDKListener;
+  late ConnectListener _connectListener;
  late String uid;
  late UserInfo uInfo;
-  bool isInitialized = false;
  bool isLogined = false;

  IMManager(this._channel) {
@@ -24,6 +25,7 @@ class IMManager {
    friendshipManager = FriendshipManager(_channel);
    messageManager = MessageManager(_channel);
    groupManager = GroupManager(_channel);
+    userManager = UserManager(_channel);
    // offlinePushManager = OfflinePushManager(_channel);
    // signalingManager = SignalingManager(_channel);
    _addNativeCallback(_channel);
@@ -33,112 +35,88 @@ class IMManager {
    _channel.setMethodCallHandler((call) {
      try {
        log('Flutter : $call');
-        if (call.method == ListenerType.initSDKListener) {
+        if (call.method == ListenerType.connectListener) {
+          String type = call.arguments['type'];
+          switch (type) {
+            case 'onConnectFailed':
+              int? errCode = call.arguments['errCode'];
+              String? errMsg = call.arguments['errMsg'];
+              _connectListener.connectFailed(errCode, errMsg);
+              break;
+            case 'onConnecting':
+              _connectListener.connecting();
+              break;
+            case 'onConnectSuccess':
+              _connectListener.connectSuccess();
+              break;
+            case 'onKickedOffline':
+              _connectListener.kickedOffline();
+              break;
+            case 'onUserSigExpired':
+              _connectListener.userSigExpired();
+              break;
+          }
+        } else if (call.method == ListenerType.userListener) {
          String type = call.arguments['type'];
          dynamic data = call.arguments['data'];
          switch (type) {
            case 'onSelfInfoUpdated':
              uInfo = UserInfo.fromJson(_formatJson(data));
-              _initSDKListener.selfInfoUpdated(uInfo);
-              break;
-            case 'onConnectFailed':
-              int? errCode = call.arguments['errCode'];
-              String? errMsg = call.arguments['errMsg'];
-              _initSDKListener.connectFailed(errCode, errMsg);
-              break;
-            case 'onConnecting':
-              _initSDKListener.connecting();
-              break;
-            case 'onConnectSuccess':
-              _initSDKListener.connectSuccess();
-              break;
-            case 'onKickedOffline':
-              _initSDKListener.kickedOffline();
-              break;
-            case 'onUserSigExpired':
-              _initSDKListener.userSigExpired();
+              userManager.userListener.selfInfoUpdated(uInfo);
              break;
          }
        } else if (call.method == ListenerType.groupListener) {
-          var args = call.arguments;
-          String type = args['type'];
-          Map<dynamic, dynamic> map = args['data'];
+          String type = call.arguments['type'];
+          dynamic data = call.arguments['data'];
          switch (type) {
-            case 'onMemberEnter':
-              groupManager.groupListener.memberEnter(
-                map['groupId'],
-                (_formatJson(map['memberList']) as List)
-                    .map((e) => GroupMembersInfo.fromJson(e))
-                    .toList(),
-              );
+            case 'onGroupApplicationAccepted':
+              final i = GroupApplicationInfo.fromJson(_formatJson(data));
+              groupManager.groupListener.groupApplicationAccepted(i);
              break;
-            case 'onMemberLeave':
-              groupManager.groupListener.memberLeave(
-                map['groupId'],
-                GroupMembersInfo.fromJson(_formatJson(map['member'])),
-              );
+            case 'onGroupApplicationAdded':
+              final i = GroupApplicationInfo.fromJson(_formatJson(data));
+              groupManager.groupListener.groupApplicationAdded(i);
              break;
-            case 'onMemberInvited':
-              groupManager.groupListener.memberInvited(
-                map['groupId'],
-                GroupMembersInfo.fromJson(_formatJson(map['opUser'])),
-                (_formatJson(map['memberList']) as List)
-                    .map((e) => GroupMembersInfo.fromJson(e))
-                    .toList(),
-              );
+            case 'onGroupApplicationDeleted':
+              final i = GroupApplicationInfo.fromJson(_formatJson(data));
+              groupManager.groupListener.groupApplicationDeleted(i);
              break;
-            case 'onMemberKicked':
-              groupManager.groupListener.memberKicked(
-                map['groupId'],
-                GroupMembersInfo.fromJson(_formatJson(map['opUser'])),
-                (_formatJson(map['memberList']) as List)
-                    .map((e) => GroupMembersInfo.fromJson(e))
-                    .toList(),
-              );
-              break;
-            case 'onGroupCreated':
-              groupManager.groupListener.groupCreated(
-                map['groupId'],
-              );
+            case 'onGroupApplicationRejected':
+              final i = GroupApplicationInfo.fromJson(_formatJson(data));
+              groupManager.groupListener.groupApplicationRejected(i);
              break;
            case 'onGroupInfoChanged':
-              groupManager.groupListener.groupInfoChanged(
-                map['groupId'],
-                GroupInfo.fromJson(_formatJson(map['groupInfo'])),
-              );
+              final i = GroupInfo.fromJson(_formatJson(data));
+              groupManager.groupListener.groupInfoChanged(i);
              break;
-            case 'onReceiveJoinApplication':
-              groupManager.groupListener.receiveJoinApplication(
-                map['groupId'],
-                GroupMembersInfo.fromJson(_formatJson(map['member'])),
-                map['opReason'],
-              );
+            case 'onGroupMemberAdded':
+              final i = GroupMembersInfo.fromJson(_formatJson(data));
+              groupManager.groupListener.groupMemberAdded(i);
              break;
-            case 'onApplicationProcessed':
-              groupManager.groupListener.applicationProcessed(
-                map['groupId'],
-                GroupMembersInfo.fromJson(_formatJson(map['opUser'])),
-                map['agreeOrReject'],
-                map['opReason'],
-              );
+            case 'onGroupMemberDeleted':
+              final i = GroupMembersInfo.fromJson(_formatJson(data));
+              groupManager.groupListener.groupMemberDeleted(i);
+              break;
+            case 'onGroupMemberInfoChanged':
+              final i = GroupMembersInfo.fromJson(_formatJson(data));
+              groupManager.groupListener.groupMemberInfoChanged(i);
+              break;
+            case 'onJoinedGroupAdded':
+              final i = GroupInfo.fromJson(_formatJson(data));
+              groupManager.groupListener.joinedGroupAdded(i);
+              break;
+            case 'onJoinedGroupDeleted':
+              final i = GroupInfo.fromJson(_formatJson(data));
+              groupManager.groupListener.joinedGroupDeleted(i);
+              break;
+            case 'onReceiveJoinGroupApplicationAdded':
+              final i = GroupApplicationInfo.fromJson(_formatJson(data));
+              groupManager.groupListener.receiveJoinGroupApplicationAdded(i);
+              break;
+            case 'onReceiveJoinGroupApplicationDeleted':
+              final i = GroupApplicationInfo.fromJson(_formatJson(data));
+              groupManager.groupListener.receiveJoinGroupApplicationDeleted(i);
              break;
-            // case 'onMemberInfoChanged':
-            //   break;
-            // case 'onGroupDismissed':
-            //   break;
-            // case 'onGroupRecycled':
-            //   break;
-            //
-            // case 'onGrantAdministrator':
-            //   break;
-            // case 'onRevokeAdministrator':
-            //   break;
-            // case 'onQuitFromGroup':
-            //   break;
-            // case 'onReceiveRESTCustomData':
-            //   break;
-            // case 'onGroupAttributeChanged':
-            //   break;
          }
        } else if (call.method == ListenerType.advancedMsgListener) {
          var type = call.arguments['type'];
@@ -147,29 +125,17 @@ class IMManager {
            case 'onRecvNewMessage':
              var value = call.arguments['data']['newMessage'];
              var msg = Message.fromJson(_formatJson(value));
-              for (var listener in messageManager.advancedMsgListeners) {
-                if (listener.id == id) {
-                  listener.recvNewMessage(msg);
-                }
-              }
+              messageManager.advancedMsgListener.recvNewMessage(msg);
              break;
            case 'onRecvMessageRevoked':
              var value = call.arguments['data']['revokedMessage'];
-              for (var listener in messageManager.advancedMsgListeners) {
-                if (listener.id == id) {
-                  listener.recvMessageRevoked(value);
-                }
-              }
+              messageManager.advancedMsgListener.recvMessageRevoked(value);
              break;
            case 'onRecvC2CReadReceipt':
              var value = call.arguments['data']['haveReadMessage'];
              var l = _formatJson(value) as List;
              var list = l.map((e) => HaveReadInfo.fromJson(e)).toList();
-              for (var listener in messageManager.advancedMsgListeners) {
-                if (listener.id == id) {
-                  listener.recvC2CReadReceipt(list);
-                }
-              }
+              messageManager.advancedMsgListener.recvC2CReadReceipt(list);
              break;
          }
        } else if (call.method == ListenerType.msgSendProgressListener) {
@@ -226,38 +192,43 @@ class IMManager {
        } else if (call.method == ListenerType.friendListener) {
          String type = call.arguments['type'];
          dynamic data = call.arguments['data'];
-          UserInfo u = UserInfo.fromJson(_formatJson(data));
+
          switch (type) {
-            case 'onBlackListAdd':
-              friendshipManager.friendshipListener.blackListAdd(u);
+            case 'onBlacklistAdded':
+              final u = BlacklistInfo.fromJson(_formatJson(data));
+              friendshipManager.friendshipListener.blacklistAdded(u);
              break;
-            case 'onBlackListDeleted':
-              friendshipManager.friendshipListener.blackListDeleted(u);
+            case 'onBlacklistDeleted':
+              final u = BlacklistInfo.fromJson(_formatJson(data));
+              friendshipManager.friendshipListener.blacklistDeleted(u);
              break;
-            case 'onFriendApplicationListAccept':
-              friendshipManager.friendshipListener
-                  .friendApplicationListAccept(u);
+            case 'onFriendApplicationAccepted':
+              final u = FriendApplicationInfo.fromJson(_formatJson(data));
+              friendshipManager.friendshipListener.friendApplicationAccepted(u);
              break;
-            case 'onFriendApplicationListAdded':
-              friendshipManager.friendshipListener
-                  .friendApplicationListAdded(u);
+            case 'onFriendApplicationAdded':
+              final u = FriendApplicationInfo.fromJson(_formatJson(data));
+              friendshipManager.friendshipListener.friendApplicationAdded(u);
              break;
-            case 'onFriendApplicationListDeleted':
-              friendshipManager.friendshipListener
-                  .friendApplicationListDeleted(u);
+            case 'onFriendApplicationDeleted':
+              final u = FriendApplicationInfo.fromJson(_formatJson(data));
+              friendshipManager.friendshipListener.friendApplicationDeleted(u);
              break;
-            case 'onFriendApplicationListReject':
-              friendshipManager.friendshipListener
-                  .friendApplicationListReject(u);
+            case 'onFriendApplicationListRejected':
+              final u = FriendApplicationInfo.fromJson(_formatJson(data));
+              friendshipManager.friendshipListener.friendApplicationRejected(u);
              break;
            case 'onFriendInfoChanged':
+              final u = FriendInfo.fromJson(_formatJson(data));
              friendshipManager.friendshipListener.friendInfoChanged(u);
              break;
-            case 'onFriendListAdded':
-              friendshipManager.friendshipListener.friendListAdded(u);
+            case 'onFriendAdded':
+              final u = FriendInfo.fromJson(_formatJson(data));
+              friendshipManager.friendshipListener.friendAdded(u);
              break;
-            case 'onFriendListDeleted':
-              friendshipManager.friendshipListener.friendListDeleted(u);
+            case 'onFriendDeleted':
+              final u = FriendInfo.fromJson(_formatJson(data));
+              friendshipManager.friendshipListener.friendDeleted(u);
              break;
          }
        }
@@ -272,61 +243,74 @@ class IMManager {
  /// Initialize SDK
  ///
  /// [platform] Refer to [IMPlatform]
-  /// [ipApi] Api server ip address
-  /// [ipWs] WebSocket ip address
-  /// [dbPath] Data storage directory
+  /// [apiAddr] Api server ip address
+  /// [wsAddr] WebSocket ip address
+  /// [dataDir] Data storage directory
  /// 初始化SDK
  /// [platform] 平台编号[IMPlatform]
-  /// [ipApi]    SDK api地址
-  /// [ipWs]     SDK websocket地址
-  /// [dbPath]   SDK数据库存储目录
+  /// [apiAddr]    SDK api地址
+  /// [wsAddr]     SDK websocket地址
+  /// [dataDir]   SDK数据库存储目录
  Future<dynamic> initSDK({
    required int platform,
-    required String ipApi,
-    required String ipWs,
-    required String dbPath,
-    required InitSDKListener listener,
+    required String apiAddr,
+    required String wsAddr,
+    required String dataDir,
+    required ConnectListener listener,
+    int logLevel = 6,
+    String? objectStorage,
+    String? operationID,
  }) {
-    _initSDKListener = listener;
-    return _channel
-        .invokeMethod(
-            'initSDK',
-            _buildParam(
-              {
-                "platform": platform,
-                "ipApi": ipApi,
-                "ipWs": ipWs,
-                "dbDir": dbPath
-              },
-            ))
-        .then((value) => isInitialized = true);
+    _connectListener = listener;
+    return _channel.invokeMethod(
+        'initSDK',
+        _buildParam(
+          {
+            "platform": platform,
+            "api_addr": apiAddr,
+            "ws_addr": wsAddr,
+            "data_dir": dataDir,
+            "log_level": logLevel,
+            "object_storage": objectStorage,
+            "operationID": _checkOperationID(operationID),
+          },
+        ));
  }

  @deprecated
  Future<dynamic> unInitSDK() {
-    return _channel.invokeMethod('unInitSDK', _buildParam({})).then((value) {
-      isInitialized = false;
-      return value;
-    });
+    return _channel.invokeMethod('unInitSDK', _buildParam({}));
  }

  /// Login sdk
  /// 登录
-  Future<UserInfo> login({required String uid, required String token}) async {
-    this.uid = uid;
+  Future<UserInfo> login({
+    required String uid,
+    required String token,
+    String? operationID,
+  }) async {
    await _channel.invokeMethod(
      'login',
-      _buildParam({'uid': uid, 'token': token}),
+      _buildParam({
+        'uid': uid,
+        'token': token,
+        'operationID': _checkOperationID(operationID),
+      }),
    );
    this.isLogined = true;
-    this.uInfo = (await getUsersInfo([uid])).first;
+    this.uid = uid;
+    this.uInfo = await userManager.getSelfUserInfo();
    return uInfo;
  }

  /// Logout sdk
  /// 登出
-  Future<dynamic> logout() async {
-    var value = await _channel.invokeMethod('logout', _buildParam({}));
+  Future<dynamic> logout({String? operationID}) async {
+    var value = await _channel.invokeMethod(
+        'logout',
+        _buildParam({
+          'operationID': _checkOperationID(operationID),
+        }));
    this.isLogined = false;
    return value;
  }
@@ -337,65 +321,24 @@ class IMManager {

  /// Current user id
  /// 获取当前登录用户id
-  Future<String> getLoginUid() async => uid;
+  Future<String> getLoginUserID() async => uid;

  /// Current user info
  /// 获取当前登录用户信息
  Future<UserInfo> getLoginUserInfo() async => uInfo;

-  /// Modify current user info
-  /// 修改当前登录用户资料
-  Future<String?> setSelfInfo(
-          {String? name,
-          String? icon,
-          int? gender,
-          String? mobile,
-          String? birth,
-          String? email,
-          String? ex}) =>
-      _channel.invokeMethod(
-          'setSelfInfo',
-          _buildParam({
-            'uid': uid,
-            'name': name,
-            'icon': icon,
-            'gender': gender,
-            'mobile': mobile,
-            'birth': birth,
-            'email': email,
-            'ex': ex,
-          }));
-
-  /// Query user information
-  /// 查询用户信息
-  Future<List<UserInfo>> getUsersInfo(List<String> uidList) => _channel
-      .invokeMethod('getUsersInfo', _buildParam({'uidList': uidList}))
-      .then((value) => _toList(value));
-
-  ///
-  Future enabledSDKLog({required bool enabled}) => _channel.invokeMethod(
-      'setSdkLog', _buildParam({'sdkLog': enabled ? 0 : 1}));
-
-  ///
-  Future<dynamic> forceSyncLoginUerInfo(List<String> uidList) =>
-      _channel.invokeMethod('forceSyncLoginUerInfo', _buildParam({}));
-
-  ///
-  // Future<dynamic> forceReConn() {
-  //   return _channel.invokeMethod('forceReConn', _buildParam({}));
-  // }
-
  static Map _buildParam(Map param) {
    param["ManagerName"] = "imManager";
    return param;
  }

-  static List<UserInfo> _toList(String value) =>
-      (_formatJson(value) as List).map((e) => UserInfo.fromJson(e)).toList();
-
  static dynamic _formatJson(value) => jsonDecode(_printValue(value));

  static String _printValue(value) {
    return value;
  }
+
+  static String _checkOperationID(String? obj) {
+    return obj ?? DateTime.now().millisecondsSinceEpoch.toString();
+  }
 }
--- a/lib/src/manager/im_message_manager.dart
+++ b/lib/src/manager/im_message_manager.dart
@@ -5,28 +5,20 @@ import 'package:flutter_openim_sdk/flutter_openim_sdk.dart';

 class MessageManager {
  MethodChannel _channel;
-  List<AdvancedMsgListener> advancedMsgListeners = List.empty(growable: true);
+
+  // List<AdvancedMsgListener> advancedMsgListeners = List.empty(growable: true);
  MsgSendProgressListener? msgSendProgressListener;
+  late AdvancedMsgListener advancedMsgListener;

  MessageManager(this._channel);

-  /// Add a message listener
+  /// Set a message listener
  /// 消息监听
-  Future addAdvancedMsgListener(AdvancedMsgListener listener) {
-    advancedMsgListeners.add(listener);
+  Future setAdvancedMsgListener(AdvancedMsgListener listener) {
+    this.advancedMsgListener = listener;
+    // advancedMsgListeners.add(listener);
    return _channel.invokeMethod(
-        'addAdvancedMsgListener',
-        _buildParam({
-          'id': listener.id,
-        }));
-  }
-
-  /// Remove a message listener
-  @deprecated
-  Future removeAdvancedMsgListener(AdvancedMsgListener listener) {
-    advancedMsgListeners.remove(listener);
-    return _channel.invokeMethod(
-        'removeAdvancedMsgListener',
+        'setAdvancedMsgListener',
        _buildParam({
          'id': listener.id,
        }));
@@ -47,7 +39,8 @@ class MessageManager {
    required Message message,
    String? userID,
    String? groupID,
-    bool onlineUserOnly = false,
+    OfflinePushInfo? offlinePushInfo,
+    String? operationID,
  }) =>
      _channel.invokeMethod(
          'sendMessage',
@@ -55,7 +48,8 @@ class MessageManager {
            'message': message.toJson(),
            'userID': userID ?? '',
            'groupID': groupID ?? '',
-            'onlineUserOnly': onlineUserOnly,
+            'offlinePushInfo': offlinePushInfo?.toJson(),
+            'operationID': _checkOperationID(operationID),
          })) /*.then((value) => _toObj(value))*/;

  /// Find all history message
@@ -67,40 +61,57 @@ class MessageManager {
    String? groupID,
    Message? startMsg,
    int? count,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
              'getHistoryMessageList',
              _buildParam({
                'userID': userID ?? '',
-                'startMsg': startMsg?.toJson() /*?? {}*/,
                'groupID': groupID ?? '',
+                'startClientMsgID': startMsg?.clientMsgID ?? '',
                'count': count ?? 10,
+                'operationID': _checkOperationID(operationID),
              }))
          .then((value) => _toList(value));

  /// Revoke the sent information
  /// 撤回消息
-  Future revokeMessage({required Message message}) =>
-      _channel.invokeMethod('revokeMessage', _buildParam(message.toJson()));
+  Future revokeMessage({
+    required Message message,
+    String? operationID,
+  }) =>
+      _channel.invokeMethod(
+          'revokeMessage',
+          _buildParam(message.toJson()
+            ..addAll({
+              "operationID": _checkOperationID(operationID),
+            })));

  /// Delete message
  /// 删除消息
-  Future deleteMessageFromLocalStorage({required Message message}) =>
+  Future deleteMessageFromLocalStorage({
+    required Message message,
+    String? operationID,
+  }) =>
      _channel.invokeMethod(
-          'deleteMessageFromLocalStorage', _buildParam(message.toJson()));
+          'deleteMessageFromLocalStorage',
+          _buildParam(message.toJson()
+            ..addAll({
+              "operationID": _checkOperationID(operationID),
+            })));

  ///
-  @deprecated
-  Future deleteMessages({required List<Message> msgList}) =>
-      _channel.invokeMethod('deleteMessages',
-          _buildParam({"msgList": msgList.map((e) => e.toJson()).toList()}));
+  // Future deleteMessages({required List<Message> msgList}) =>
+  //     _channel.invokeMethod('deleteMessages',
+  //         _buildParam({"msgList": msgList.map((e) => e.toJson()).toList()}));

  ///
  Future insertSingleMessageToLocalStorage({
    String? receiverID,
    String? senderID,
    Message? message,
+    String? operationID,
  }) =>
      _channel.invokeMethod(
          'insertSingleMessageToLocalStorage',
@@ -108,53 +119,68 @@ class MessageManager {
            "message": message?.toJson(),
            "receiverID": receiverID,
            "senderID": senderID,
+            "operationID": _checkOperationID(operationID),
          }));

  /// Query the message according to the message id
-  Future findMessages({required List<String> messageIDList}) =>
-      _channel.invokeMethod(
-          'findMessages',
-          _buildParam({
-            "messageIDList": messageIDList,
-          }));
+  // Future findMessages({required List<String> messageIDList}) =>
+  //     _channel.invokeMethod(
+  //         'findMessages',
+  //         _buildParam({
+  //           "messageIDList": messageIDList,
+  //         }));

  /// Mark c2c message as read
  /// 标记c2c消息已读
  Future markC2CMessageAsRead({
    required String userID,
    required List<String> messageIDList,
+    String? operationID,
  }) =>
      _channel.invokeMethod(
          'markC2CMessageAsRead',
          _buildParam({
            "messageIDList": messageIDList,
            "userID": userID,
+            "operationID": _checkOperationID(operationID),
          }));

  /// Typing
  /// 正在输入提示
  Future typingStatusUpdate({
    required String userID,
-    bool typing = false,
+    String? msgTip,
+    String? operationID,
  }) =>
      _channel.invokeMethod(
          'typingStatusUpdate',
          _buildParam({
-            "typing": typing ? 'yes' : 'no',
+            "msgTip": msgTip,
            "userID": userID,
+            "operationID": _checkOperationID(operationID),
          }));

  /// Create text message
  /// 创建文本消息
-  Future<Message> createTextMessage({required String text}) => _channel
-      .invokeMethod('createTextMessage', _buildParam({'text': text}))
-      .then((value) => _toObj(value));
+  Future<Message> createTextMessage({
+    required String text,
+    String? operationID,
+  }) =>
+      _channel
+          .invokeMethod(
+              'createTextMessage',
+              _buildParam({
+                'text': text,
+                "operationID": _checkOperationID(operationID),
+              }))
+          .then((value) => _toObj(value));

  /// Create @ message
  /// 创建@消息
  Future<Message> createTextAtMessage({
    required String text,
    required List<String> atUidList,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
@@ -162,26 +188,40 @@ class MessageManager {
            _buildParam({
              'text': text,
              'atUserList': atUidList,
+              "operationID": _checkOperationID(operationID),
            }),
          )
          .then((value) => _toObj(value));

  /// Create picture message
  /// 创建图片消息
-  Future<Message> createImageMessage({required String imagePath}) => _channel
-      .invokeMethod(
-        'createImageMessage',
-        _buildParam({'imagePath': imagePath}),
-      )
-      .then((value) => _toObj(value));
+  Future<Message> createImageMessage({
+    required String imagePath,
+    String? operationID,
+  }) =>
+      _channel
+          .invokeMethod(
+            'createImageMessage',
+            _buildParam({
+              'imagePath': imagePath,
+              "operationID": _checkOperationID(operationID),
+            }),
+          )
+          .then((value) => _toObj(value));

  /// Create picture message
  /// 创建图片消息
-  Future<Message> createImageMessageFromFullPath({required String imagePath}) =>
+  Future<Message> createImageMessageFromFullPath({
+    required String imagePath,
+    String? operationID,
+  }) =>
      _channel
          .invokeMethod(
            'createImageMessageFromFullPath',
-            _buildParam({'imagePath': imagePath}),
+            _buildParam({
+              'imagePath': imagePath,
+              "operationID": _checkOperationID(operationID),
+            }),
          )
          .then((value) => _toObj(value));

@@ -190,11 +230,16 @@ class MessageManager {
  Future<Message> createSoundMessage({
    required String soundPath,
    required int duration,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
            'createSoundMessage',
-            _buildParam({'soundPath': soundPath, "duration": duration}),
+            _buildParam({
+              'soundPath': soundPath,
+              "duration": duration,
+              "operationID": _checkOperationID(operationID),
+            }),
          )
          .then((value) => _toObj(value));

@@ -203,11 +248,16 @@ class MessageManager {
  Future<Message> createSoundMessageFromFullPath({
    required String soundPath,
    required int duration,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
            'createSoundMessageFromFullPath',
-            _buildParam({'soundPath': soundPath, "duration": duration}),
+            _buildParam({
+              'soundPath': soundPath,
+              "duration": duration,
+              "operationID": _checkOperationID(operationID),
+            }),
          )
          .then((value) => _toObj(value));

@@ -218,6 +268,7 @@ class MessageManager {
    required String videoType,
    required int duration,
    required String snapshotPath,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
@@ -227,6 +278,7 @@ class MessageManager {
                'videoType': videoType,
                'duration': duration,
                'snapshotPath': snapshotPath,
+                "operationID": _checkOperationID(operationID),
              }))
          .then((value) => _toObj(value));

@@ -237,6 +289,7 @@ class MessageManager {
    required String videoType,
    required int duration,
    required String snapshotPath,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
@@ -246,6 +299,7 @@ class MessageManager {
                'videoType': videoType,
                'duration': duration,
                'snapshotPath': snapshotPath,
+                "operationID": _checkOperationID(operationID),
              }))
          .then((value) => _toObj(value));

@@ -254,6 +308,7 @@ class MessageManager {
  Future<Message> createFileMessage({
    required String filePath,
    required String fileName,
+    String? operationID,
  }) {
    return _channel
        .invokeMethod(
@@ -261,6 +316,7 @@ class MessageManager {
            _buildParam({
              'filePath': filePath,
              'fileName': fileName,
+              "operationID": _checkOperationID(operationID),
            }))
        .then((value) => _toObj(value));
  }
@@ -270,6 +326,7 @@ class MessageManager {
  Future<Message> createFileMessageFromFullPath({
    required String filePath,
    required String fileName,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
@@ -277,6 +334,7 @@ class MessageManager {
              _buildParam({
                'filePath': filePath,
                'fileName': fileName,
+                "operationID": _checkOperationID(operationID),
              }))
          .then((value) => _toObj(value));

@@ -286,6 +344,7 @@ class MessageManager {
    required List<Message> messageList,
    required String title,
    required List<String> summaryList,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
@@ -294,17 +353,22 @@ class MessageManager {
                'messageList': messageList.map((e) => e.toJson()).toList(),
                'title': title,
                'summaryList': summaryList,
+                "operationID": _checkOperationID(operationID),
              }))
          .then((value) => _toObj(value));

  /// Create forward message
  /// 创建转发消息
-  Future<Message> createForwardMessage({required Message message}) {
+  Future<Message> createForwardMessage({
+    required Message message,
+    String? operationID,
+  }) {
    return _channel
        .invokeMethod(
            'createForwardMessage',
            _buildParam({
              'message': message.toJson(),
+              "operationID": _checkOperationID(operationID),
            }))
        .then((value) => _toObj(value));
  }
@@ -315,6 +379,7 @@ class MessageManager {
    required double latitude,
    required double longitude,
    required String description,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
@@ -323,6 +388,7 @@ class MessageManager {
                'latitude': latitude,
                'longitude': longitude,
                'description': description,
+                "operationID": _checkOperationID(operationID),
              }))
          .then((value) => _toObj(value));

@@ -332,6 +398,7 @@ class MessageManager {
    required String data,
    required String extension,
    required String description,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
@@ -340,6 +407,7 @@ class MessageManager {
                'data': data,
                'extension': extension,
                'description': description,
+                "operationID": _checkOperationID(operationID),
              }))
          .then((value) => _toObj(value));

@@ -348,6 +416,7 @@ class MessageManager {
  Future<Message> createQuoteMessage({
    required String text,
    required Message quoteMsg,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
@@ -355,6 +424,7 @@ class MessageManager {
              _buildParam({
                'quoteText': text,
                'quoteMessage': quoteMsg.toJson(),
+                "operationID": _checkOperationID(operationID),
              }))
          .then((value) => _toObj(value));

@@ -362,24 +432,42 @@ class MessageManager {
  /// 创建卡片消息
  Future<Message> createCardMessage({
    required Map<String, dynamic> data,
+    String? operationID,
  }) =>
      _channel
          .invokeMethod(
              'createCardMessage',
              _buildParam({
                'cardMessage': data,
+                "operationID": _checkOperationID(operationID),
              }))
          .then((value) => _toObj(value));

  /// Clear all c2c history message
  /// 清空单聊消息记录
-  Future<dynamic> clearC2CHistoryMessage({required String uid}) => _channel
-      .invokeMethod('clearC2CHistoryMessage', _buildParam({"userID": uid}));
+  Future<dynamic> clearC2CHistoryMessage({
+    required String uid,
+    String? operationID,
+  }) =>
+      _channel.invokeMethod(
+          'clearC2CHistoryMessage',
+          _buildParam({
+            "userID": uid,
+            "operationID": _checkOperationID(operationID),
+          }));

  /// Clear all group history
  /// 清空组消息记录
-  Future<dynamic> clearGroupHistoryMessage({required String gid}) => _channel
-      .invokeMethod('clearGroupHistoryMessage', _buildParam({"groupID": gid}));
+  Future<dynamic> clearGroupHistoryMessage({
+    required String gid,
+    String? operationID,
+  }) =>
+      _channel.invokeMethod(
+          'clearGroupHistoryMessage',
+          _buildParam({
+            "groupID": gid,
+            "operationID": _checkOperationID(operationID),
+          }));

  ///
  // void forceSyncMsg() {
@@ -401,4 +489,8 @@ class MessageManager {
  static String _printValue(value) {
    return value;
  }
+
+  static String _checkOperationID(String? obj) {
+    return obj ?? DateTime.now().millisecondsSinceEpoch.toString();
+  }
 }
--- a/lib/src/manager/im_user_manager.dart
+++ b/lib/src/manager/im_user_manager.dart
@@ -0,0 +1,95 @@
+import 'dart:convert';
+
+import 'package:flutter/services.dart';
+import 'package:flutter_openim_sdk/flutter_openim_sdk.dart';
+
+class UserManager {
+  MethodChannel _channel;
+  late UserListener userListener;
+
+  UserManager(this._channel);
+
+  /// Observe user info changes
+  /// 用户资料改变监听
+  Future setUserListener(UserListener listener) {
+    this.userListener = listener;
+    return _channel.invokeMethod('setUserListener', _buildParam({}));
+  }
+
+  /// Query user information
+  /// 获取用户资料
+  Future<List<UserInfo>> getUsersInfo({
+    required List<String> uidList,
+    String? operationID,
+  }) =>
+      _channel
+          .invokeMethod(
+              'getUsersInfo',
+              _buildParam({
+                'uidList': uidList,
+                'operationID': _checkOperationID(operationID),
+              }))
+          .then((value) => _toList(value, (v) => UserInfo.fromJson(v.cast())));
+
+  /// Get the information of the currently logged in user
+  /// 获取当前登录用户的信息
+  Future<UserInfo> getSelfUserInfo({
+    String? operationID,
+  }) =>
+      _channel
+          .invokeMethod(
+              'getSelfUserInfo',
+              _buildParam({
+                'operationID': _checkOperationID(operationID),
+              }))
+          .then((value) => UserInfo.fromJson(_formatJson(value)));
+
+  /// Modify current user info
+  /// 修改当前登录用户资料
+  Future<String?> setSelfInfo({
+    String? nickname,
+    String? faceURL,
+    int? gender,
+    int? appMangerLevel,
+    String? phoneNumber,
+    String? birth,
+    String? email,
+    String? ex,
+    String? operationID,
+  }) =>
+      _channel.invokeMethod(
+          'setSelfInfo',
+          _buildParam({
+            // 'userID': userID,
+            'nickname': nickname,
+            'faceURL': faceURL,
+            'gender': gender,
+            'appMangerLevel': appMangerLevel,
+            'phoneNumber': phoneNumber,
+            'birth': birth,
+            'email': email,
+            'ex': ex,
+            'operationID': _checkOperationID(operationID),
+          }));
+
+  static Map _buildParam(Map param) {
+    param["ManagerName"] = "userManager";
+    return param;
+  }
+
+  static List<T> _toList<T>(String? value, T f(Map map)) {
+    var list = _formatJson(value);
+    if (null == list) return <T>[];
+    return (list as List).map((e) => f(e)).toList();
+  }
+
+  static dynamic _formatJson(value) => jsonDecode(_printValue(value));
+
+  static String _printValue(value) {
+    return value;
+  }
+
+  static String _checkOperationID(String? obj) {
+    return obj ?? DateTime.now().millisecondsSinceEpoch.toString();
+  }
+}