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;

小云雀

剪映出品的AI视频和图片创作助手

1949

查看详情

// ... (之前的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."); });