使用Twilio实现呼叫转接未接通后的语音留言功能

const twilio = require("twilio");
const express = require("express");
const router = express.Router();
// ... (其他引入和数据库操作函数)

router.post("/webhook/voice", async (req, res) => {
  const { To, From, CallStatus } = req.body;

  const [numbers] = await getNumberWithoutUser(To);
  if (!numbers) return res.status(400).send("User does not own this number");

  const type = numbers.numbers.subscriptions.find(
    (subscription) => subscription.active
  ).type;
  const isToPrimaryPhone =
    numbers?.numbers?.settings?.forwarding?.toPrimaryPhone;
  const primaryPhoneNumber =
    numbers?.numbers?.settings?.forwarding?.primaryPhoneNumber;

  if (isToPrimaryPhone) {
    switch (CallStatus) {
      case "ringing":
        const twiml = new twilio.twiml.VoiceResponse();

        // 1. 尝试呼叫用户的真实号码，设置超时为7秒
        // 如果在7秒内未接通，Twilio将继续执行TwiML中的下一个指令
        const dial = twiml.dial({
          timeout: 7 // 设置呼叫超时时间，单位：秒
        });
        dial.number(primaryPhoneNumber); // 拨打用户的真实号码

        // ... (后续的语音留言逻辑将在此处添加)

        await updateQuota(numbers._id, To, "callForwarding", type);
        res.type("text/xml");
        return res.send(twiml.toString());

      case "completed":
        await appendCall(numbers._id, To, From, req.body);
        return res.send("success");
    }
  }
  res.send("Call Forwarding is disabled or package has finished");
});

      case "ringing":
        const twiml = new twilio.twiml.VoiceResponse();

        const dial = twiml.dial({
          timeout: 7
        });
        dial.number(primaryPhoneNumber);

        // 如果主号码未接通（超时、忙线、无人接听），则执行以下语音留言逻辑
        twiml.say({ voice: 'Polly.Zhiyu', language: 'zh-CN' }, "您好，您拨打的用户暂时无法接听，请在滴声后留言。"); // 语音提示
        twiml.record({
          recordingStatusCallback: "https://your-ngrok-url/webhook/voice/voicemail-callback", // 替换为您的实际回调URL
          maxLength: 60, // 最大录音时长60秒
          finishOnKey: '*' // 呼叫方按*号结束录音
        });
        twiml.say({ voice: 'Polly.Zhiyu', language: 'zh-CN' }, "感谢您的留言，再见。"); // 录音结束后的提示

        await updateQuota(numbers._id, To, "callForwarding", type);
        res.type("text/xml");
        return res.send(twiml.toString());

// ... (其他引入)

router.post("/webhook/voice/voicemail-callback", async (req, res) => {
  const { RecordingUrl, CallSid, From, To, RecordingDuration, TranscriptionText } = req.body;

  console.log(`收到语音留言回调：`);
  console.log(`录音URL: ${RecordingUrl}`);
  console.log(`呼叫SID: ${CallSid}`);
  console.log(`呼叫方: ${From}`);
  console.log(`被叫方 (掩码号码): ${To}`);
  console.log(`录音时长: ${RecordingDuration} 秒`);
  // 如果Twilio自动转录服务已开启，这里可能包含TranscriptionText
  console.log(`转录文本: ${TranscriptionText}`);

  try {
    // 1. 根据To (掩码号码) 查找对应的用户ID和配置
    const [numbers] = await getNumberWithoutUser(To);
    if (!numbers) {
      console.error(`未找到掩码号码 ${To} 对应的用户配置`);
      return res.status(400).send("Invalid masked number");
    }

    const userId = numbers._id;
    const userEmail = numbers?.numbers?.settings?.emailForVoicemail; // 假设用户设置了接收语音留言的邮箱

    // 2. 将录音信息存储到数据库 (例如，您的messagingCollectionUtils或一个新的voicemailCollection)
    // appendMessage(userId, To, From, { type: 'voicemail', url: RecordingUrl, duration: RecordingDuration, transcription: TranscriptionText });
    // 或者创建一个专门的appendVoicemail函数
    // await appendVoicemail(userId, To, From, RecordingUrl, RecordingDuration, TranscriptionText);
    console.log(`语音留言信息已记录到数据库。`);

    // 3. 如果Twilio没有提供TranscriptionText，您可以使用Twilio的API手动进行转录
    // const transcription = await client.recordings(CallSid).transcriptions.create({
    //   recordingSid: req.body.RecordingSid // 或者直接使用RecordingSid
    // });
    // const fullTranscriptionText = transcription.transcriptionText;

    // 4. 发送邮件通知用户
    if (userEmail) {
      const emailSubject = `您有一个新的语音留言来自 ${From}`;
      const emailBody = `
        <p>您好，</p>
        <p>您有一个新的语音留言。</p>
        <p><b>呼叫方:</b> ${From}</p>
        <p><b>录音时长:</b> ${RecordingDuration} 秒</p>
        <p><b>录音链接:</b> <a href="${RecordingUrl}">${RecordingUrl}</a></p>
        ${TranscriptionText ? `<p><b>转录文本:</b> ${TranscriptionText}</p>` : ''}
        <p>请点击链接收听。</p>
        <p>祝您愉快！</p>
      `;
      await sendMessageNotificationEmail(userEmail, emailSubject, emailBody); // 假设您有发送邮件的函数
      console.log(`语音留言通知邮件已发送至 ${userEmail}。`);
    } else {
      console.warn(`用户 ${userId} 未配置接收语音留言的邮箱。`);
    }

    // Twilio期望一个空的TwiML响应或一个简单的消息
    res.type("text/xml");
    res.send(new twilio.twiml.VoiceResponse().toString());

  } catch (error) {
    console.error("处理语音留言回调时发生错误:", error);
    res.status(500).send("Error processing voicemail callback");
  }
});