如何自定义消息id about fluttertencentimplugin HOT 3 CLOSED

class ImChatDataManager extends ValueNotifier<void> {  
  /// 当前界面聊天数据内容
  List<DataEntity> data = [];

    /// 发送消息
  sendMessage(MessageNode node) async {
    if (loginUserInfo == null) {
      Fluttertoast.showToast(msg: "消息发送失败，请重试!");
      return;
    }

    // 添加到消息队列
    String randomId = UuidUtil.getUuid();
    this.data.add(
          DataEntity(
            id: randomId,
            status: ImChatMessageStatus.Sending,
            message: MessageEntity(
              id: this.id,
              sessionType: type,
              self: true,
              elemList: [node],
              userInfo: loginUserInfo,
            ),
          ),
        );

    // 更新滚动条到底部
    notifyListeners();
    toBottom();

    // 发送消息，在有结果后进行更新操作
    await MessageUtil.sendMessage(
      session: SessionEntity(
        id: this.id,
        type: this.type,
      ),
      node: node,
      dateSender: (dateMessage) => this.insertDataByRandomId(
        randomId,
        dateMessage,
        notify: false,
      ),
    ).then((res) {
      this.updateDataStatusByRandomId(randomId, ImChatMessageStatus.Success, message: res);
    }).catchError((res) {
      this.updateDataStatusByRandomId(randomId, ImChatMessageStatus.Error);
    });

    notifyListeners();
    toBottom();
  }

  /// 根据随机ID 更新消息对象
  updateDataStatusByRandomId(String randomId, ImChatMessageStatus status, {MessageEntity message}) {
    // 因为更新的对象一般都是发送消息时添加进去的，所以一定程度上来说，倒序查找要快一点
    for (int index = this.data.length - 1; index > 0; index--) {
      DataEntity entity = this.data[index];
      if (entity.id == randomId) {
        this.data[index].status = status;
        if (message != null) {
          this.data[index].message = message;
        }
        break;
      }
    }
    notifyListeners();
  }

  /// 更新消息对象
  updateMessage(MessageEntity message) {
    for (int i = 0; i < this.data.length; i++) {
      if (message == this.data[i].message) {
        this.data[i].message = message;
        notifyListeners();
        break;
      }
    }
  }

  /// 删除消息
  removeMessage(MessageEntity message) {
    int index = -1;
    for (int i = 0; i < this.data.length; i++) {
      if (message == this.data[i].message) {
        index = i;
        break;
      }
    }
    if (index != -1) {
      this.data.removeAt(index);
      notifyListeners();
    }
  }

  /// 添加单条数据，根据随机ID
  insertDataByRandomId(String randomId, MessageEntity item, {notify: true}) {
    for (int i = 0; i < this.data.length; i++) {
      if (this.data[i].id == randomId) {
        this.data.insert(
              i,
              DataEntity(
                message: item,
                status: getMessageStatus(item),
              ),
            );

        if (notify) {
          notifyListeners();
        }
        break;
      }
    }
  }

  /// 添加单条数据
  insertData(int index, MessageEntity item, {notify: true}) {
    this.data.insert(
          index,
          DataEntity(
            message: item,
            status: getMessageStatus(item),
          ),
        );

    if (notify) {
      notifyListeners();
    }
  }

}

        imChatDataManager.sendMessage(ImageMessageNode(
          path: value.resource,
        ));

/// 数据实体
class DataEntity {
  /// 消息ID(仅在一次会话中有效)
  String id;

  /// 消息对象
  MessageEntity message;

  /// 状态
  ImChatMessageStatus status;

  DataEntity({
    this.id,
    this.message,
    this.status,
  });
}

/// Im消息状态
enum ImChatMessageStatus {
  /// 发送中
  Sending,

  /// 发送成功
  Success,

  /// 发送失败
  Error,
}

sendMessage(MessageNode node) async {
    if (loginUserInfo == null) {
      Fluttertoast.showToast(msg: "消息发送失败，请重试!");
      return;
    }

    // 添加到消息队列
    String randomId = UuidUtil.getUuid();
    this.data.add(
          DataEntity(
            id: randomId,
            status: ImChatMessageStatus.Sending,
            message: MessageEntity(
              id: this.id,
              sessionType: type,
              self: true,
              elemList: [node],
              userInfo: loginUserInfo,
            ),
          ),
        );

    // 更新滚动条到底部
    notifyListeners();
    toBottom();

    // 发送消息，在有结果后进行更新操作
    await MessageUtil.sendMessage(
      session: SessionEntity(
        id: this.id,
        type: this.type,
      ),
      node: node,
      dateSender: (dateMessage) => this.insertDataByRandomId(
        randomId,
        dateMessage,
        notify: false,
      ),
    ).then((res) {
      this.updateDataStatusByRandomId(randomId, ImChatMessageStatus.Success, message: res);
    }).catchError((res) {
      this.updateDataStatusByRandomId(randomId, ImChatMessageStatus.Error);
    });

    notifyListeners();
    toBottom();
  }