sendMessage method

void sendMessage(NIMMessage message, { NIMMessage? replyMsg, NIMMessagePushConfig? pushConfig, })

发送消息最终实现 message 消息 replyMsg 回复消息 pushConfig 推送配置 aiAgent 消息发送的AI代理

Implementation

void sendMessage(
  NIMMessage message, {
  NIMMessage? replyMsg,
  NIMMessagePushConfig? pushConfig,
}) async {
  final params = await ChatMessageHelper.getSenderParams(
    message,
    conversationId,
    pushConfig: pushConfig,
  );
  //设置aiAgent
  // 根据forcePushAccountIds 设置
  NIMAIUser? aiAgent;
  if (pushConfig?.forcePushAccountIds?.isNotEmpty == true ||
      message.pushConfig?.forcePushAccountIds?.isNotEmpty == true) {
    final pushList = pushConfig?.forcePushAccountIds?.isNotEmpty == true
        ? pushConfig?.forcePushAccountIds
        : message.pushConfig?.forcePushAccountIds;
    for (var accId in pushList!) {
      if (AIUserManager.instance.getAIUserById(accId!) != null) {
        aiAgent = AIUserManager.instance.getAIUserById(accId);
        break;
      }
    }
  }
  if (aiAgent == null && isAIUser()) {
    //如果是AI用户，设置aiAgent 为单聊对象
    aiAgent = AIUserManager.instance.getAIUserById(_sessionId!);
  }
  //处理重发的case，从消息的 Config 中获取
  if (aiAgent == null && message.aiConfig?.accountId?.isNotEmpty == true) {
    aiAgent = AIUserManager.instance.getAIUserById(
      message.aiConfig!.accountId!,
    );
  }
  //根据回复消息设置上下文
  List<NIMAIModelCallMessage>? aiMessages;
  if (aiAgent != null && replyMsg != null) {
    final textMsg = ChatMessageHelper.getAIContentMsg(replyMsg);
    if (textMsg != null) {
      aiMessages = [
        NIMAIModelCallMessage(
          type: 0,
          msg: textMsg,
          role: NIMAIModelRoleType.user,
        ),
      ];
    }
  }
  NIMMessageAIConfigParams? aiConfigParams;
  if (aiAgent != null) {
    final aiStreamMode = await IMKitClient.enableAIStream;
    // AI 参数处理
    aiConfigParams = NIMMessageAIConfigParams(
      accountId: aiAgent.accountId,
      aiStream: aiStreamMode,
    );
    if (ChatMessageHelper.getAIContentMsg(message)?.isNotEmpty == true) {
      NIMAIModelCallContent content = NIMAIModelCallContent(
        type: 0,
        msg: ChatMessageHelper.getAIContentMsg(message),
      );
      aiConfigParams.content = content;
    }
  }
  //处理与数字人单聊的上下文
  if (aiConfigParams != null) {
    if (aiMessages?.isNotEmpty == true) {
      aiConfigParams.messages = aiMessages;
    } else if (isAIUser()) {
      //如果没有AI上下文，则取最近的30条消息
      aiConfigParams.messages = getAIMessages();
    }
  }

  params.aiConfig = aiConfigParams;

  //处理重发case
  if (replyMsg == null &&
      message.sendingState == NIMMessageSendingState.failed &&
      message.threadReply?.messageClientId?.isNotEmpty == true) {
    replyMsg = (await NimCore.instance.messageService.getMessageListByRefers(
      messageRefers: [message.threadReply!],
    ))
        .data
        ?.first;
  }

  //发送前的对外回调
  if (ChatKitClient.instance.messageAction != null) {
    ChatKitClient.instance.messageAction!(message, conversationId, params);
  }

  if (replyMsg != null) {
    ChatMessageRepo.replyMessage(
      msg: message,
      replyMsg: replyMsg,
      params: params,
    ).then((result) {
      _handleMessageSendResult(result);
    });
  } else {
    ChatMessageRepo.sendMessage(
      message: message,
      conversationId: conversationId,
      params: params,
    ).then((result) {
      _handleMessageSendResult(result);
    });
  }
}