Twilio实现呼叫转发与未接来电语音留言功能详解

const twilio = require("twilio");
const express = require("express");
const router = express.Router();

// 假设 getNumberWithoutUser 和 updateQuota 是你的数据库操作函数
// const { getNumberWithoutUser, updateQuota } = require("../db/dbOperations");

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

  // 假设根据 'To' 掩码号码获取用户信息和真实号码
  // const [numbers] = await getNumberWithoutUser(To);
  // if (!numbers) return res.status(400).send("User does not own this number");

  // 假设这些信息从数据库中获取
  const primaryPhoneNumber = "+8613800138000"; // 示例：用户的真实号码
  const isToPrimaryPhone = true; // 示例：是否开启了呼叫转发

  if (isToPrimaryPhone) {
    const twiml = new twilio.twiml.VoiceResponse();

    // 可选：在转接前播放欢迎语
    twiml.say({ voice: 'alice', language: 'zh-CN' }, "请稍候，我们正在为您转接。");

    // 使用Dial动词将呼叫转发到用户的真实号码
    // 设置15秒超时，如果未接听，则将控制权转交给 /webhook/handle_dial_outcome
    twiml.dial({
      timeout: 15, // 等待被叫方接听的秒数
      action: '/webhook/handle_dial_outcome', // 如果未接听，Twilio将请求此URL
      hangupOnStar: true // 允许呼叫者按 * 键跳过语音留言
    }, primaryPhoneNumber);

    // 假设更新呼叫配额
    // await updateQuota(numbers._id, To, "callForwarding", type);

    res.type("text/xml");
    return res.send(twiml.toString());
  }

  // 如果呼叫转发未启用或套餐已过期
  res.send("Call Forwarding is disabled or package has finished");
});

module.exports = router;

// ... (之前的require和router定义)

router.post("/webhook/handle_dial_outcome", async (req, res) => {
  const { DialCallStatus, To, From } = req.body; // DialCallStatus 表示Dial动词的执行结果
  const twiml = new twilio.twiml.VoiceResponse();

  // 检查Dial动词的执行状态
  if (DialCallStatus === 'no-answer' || DialCallStatus === 'busy' || DialCallStatus === 'failed') {
    // 如果呼叫未接听、占线或失败，则提示客户留言
    twiml.say({ voice: 'alice', language: 'zh-CN' }, "您拨打的用户暂时无法接听，请在哔声后留言。");
    twiml.record({
      maxLength: 60, // 最大录音时长60秒
      finishOnKey: '#', // 呼叫者按 # 键结束录音
      action: '/webhook/recording_status', // 录音完成后，Twilio将请求此URL
      transcribe: true, // 启用语音转文本
      transcribeCallback: '/webhook/transcription_status' // 转录完成后，Twilio将请求此URL
    });
    twiml.say({ voice: 'alice', language: 'zh-CN' }, "留言结束，感谢您的来电。");
  } else {
    // 其他状态，例如呼叫已完成（通常不会进入此分支，因为如果接听，Dial动词会直接连接，不会触发action）
    // 或者可以播放一个结束语
    twiml.say({ voice: 'alice', language: 'zh-CN' }, "感谢您的来电。");
  }

  res.type("text/xml");
  return res.send(twiml.toString());
});

// module.exports = router; // 如果是单独的文件，需要导出

// ... (之前的require和router定义)

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

  console.log(`收到新的语音留言：${RecordingUrl}，时长：${RecordingDuration}秒`);

  // 1. 将录音信息存储到数据库
  // const [numbers] = await getNumberWithoutUser(To); // 根据'To'掩码号码获取用户数据
  // if (numbers) {
  //   await appendMessage(numbers._id, To, From, {
  //     type: 'voicemail',
  //     url: RecordingUrl,
  //     duration: RecordingDuration,
  //     callSid: CallSid
  //   });
  //   // 2. 如果不需要等待转录结果，可以直接发送邮件通知
  //   // await sendMessageNotificationEmail(numbers.userEmail, "您有新的语音留言", `请访问：${RecordingUrl}`);
  // }

  // Twilio期望收到一个200 OK响应
  res.send("Voicemail recording processed.");
});

// ... (之前的require和router定义)

router.post("/webhook/transcription_status", async (req, res) => {
  const { TranscriptionStatus, TranscriptionText, RecordingUrl, CallSid, From, To } = req.body;

  if (TranscriptionStatus === 'completed') {
    console.log(`语音留言转录完成。录音：${RecordingUrl}，转录文本：${TranscriptionText}`);

    // 1. 更新数据库中对应的语音留言记录，添加转录文本
    // const [numbers] = await getNumberWithoutUser(To);
    // if (numbers) {
    //   // 假设有一个函数可以更新留言记录
    //   // await updateVoicemailTranscription(CallSid, TranscriptionText);

    //   // 2. 发送包含语音链接和转录文本的邮件通知
    //   // const emailBody = `您有一个新的语音留言：\n语音链接：${RecordingUrl}\n转录内容：${TranscriptionText}`;
    //   // await sendMessageNotificationEmail(numbers.userEmail, "您有新的语音留言及转录", emailBody);
    // }
  } else {
    console.log(`语音转录失败或进行中，状态：${TranscriptionStatus}`);
  }

  res.send("Voicemail transcription processed.");
});