// 根據(jù)wx提供的api創(chuàng)建錄音管理對(duì)象
const recorderManager = wx.getRecorderManager();

// 監(jiān)聽(tīng)語(yǔ)音識(shí)別結(jié)束后的行為
recorderManager.onStop(recorderResponse => {
 // tempFilePath 是錄制的音頻文件
 const { tempFilePath } = recorderResponse;

 // 上傳音頻文件，完成語(yǔ)音識(shí)別翻譯
 wx.uploadFile({
 url: 'http://127.0.0.1:7001/voice', // 該服務(wù)在后面搭建。另外，小程序發(fā)布時(shí)要求后臺(tái)服務(wù)提供https服務(wù)！這里的地址僅為開(kāi)發(fā)環(huán)境配置。
 filePath: tempFilePath,
 name: 'file',
 complete: res => {
  console.log(res); // 我們期待res，就是翻譯后的內(nèi)容
 }
 });
});

// 開(kāi)始錄音，觸發(fā)條件可以是按鈕或其他，由你自己決定
recorderManager.start({
 duration: 5000 // 最長(zhǎng)錄制時(shí)間
 // 其他參數(shù)可以默認(rèn)，更多參數(shù)可以查看https://developers.weixin.qq.com/miniprogram/dev/api/media/recorder/RecorderManager.start.html
});

http://127.0.0.1:7001/voice

npm i egg-init -g
egg-init voice-server --type=simple
cd voice-server
npm i

npm run dev

module.exports = appInfo => {
 ...
 config.multipart = {
 fileSize: '2gb', // 限制文件大小
 whitelist: [ '.aac', '.m4a', '.mp3' ], // 支持上傳的文件后綴名
 };

 config.security = {
 csrf: {
  enable: false // 關(guān)閉csrf
 }
 };
 ...
}

const Controller = require('egg').Controller;
const fs = require('fs');
const path = require('path');
const pump = require('mz-modules/pump');
const uuidv1 = require('uuid/v1'); // 依賴(lài)于uuid庫(kù)，用于生成唯一文件名，使用npm i uuid安裝即可

// 音頻文件上傳后存儲(chǔ)的路徑
const targetPath = path.resolve(__dirname, '..', '..', 'uploads');

class VoiceController extends Controller {
 constructor(params) {
 super(params);
 if (!fs.existsSync(targetPath)) {
  fs.mkdirSync(targetPath);
 }
 }

 async translate() {
 const parts = this.ctx.multipart({ autoFields: true });
 let stream;
 const voicePath = path.join(targetPath, uuidv1());
 while (!isEmpty((stream = await parts()))) {
  await pump(stream, fs.createWriteStream(voicePath));
 }
 // 到這里就完成了文件上傳。如果你不需要文件落地，也可以在后續(xù)的操作中，直接使用stream操作文件流

 ...
 // 音頻編碼
 // 科大訊飛語(yǔ)音識(shí)別
 ...
 }
}

module.exports = app => {
 const { router, controller } = app;
 router.get('/', controller.home.index);
 router.get('/voice', controller.voice.translate);
};

npm i ffmpeg-static
npm i fluent-ffmpeg

const { Service } = require('egg');
const ffmpeg = require('fluent-ffmpeg');
const ffmpegStatic = require('ffmpeg-static');
const path = require('path');
const fs = require('fs');

ffmpeg.setFfmpegPath(ffmpegStatic.path);

class FFmpegService extends Service {
 async aac2pcm(voicePath) {
  const command = ffmpeg(voicePath);

  // 方便測(cè)試，我們將轉(zhuǎn)碼后文件落地到磁盤(pán)
  const targetDir = path.join(path.dirname(voicePath), 'pcm');
  if (!fs.existsSync(targetDir)) {
   fs.mkdirSync(targetDir);
  }

  const target = path.join(targetDir, path.basename(voicePath)) + '.pcm';
  return new Promise((resolve, reject) => {
   command
    .audioCodec('pcm_s16le')
    .audioChannels(2)
    .audioBitrate(8000)
    .output(target)
    .on('error', error => {
     reject(error);
    })
    .on('end', () => {
     resolve(target);
    })
    .run();
  });
 }
}

module.exports = FFmpegService;

// app/controller/voice.js
...
async translate() {
 ...
 ...
 const pcmPath = await this.ctx.service.ffmpeg.aac2pcm(voicePath);
 ...
}
...

npm i axios // 網(wǎng)絡(luò)請(qǐng)求庫(kù)
npm i md5 // 科大訊飛接口中需要md5計(jì)算
npm i form-urlencoded // 接口中需要對(duì)部分內(nèi)容進(jìn)行urlencoded

const { Service } = require('egg');
const fs = require('fs');
const formUrlencoded = require('form-urlencoded').default;
const axios = require('axios');
const md5 = require('md5');
const API_KEY = 'xxxx'; // 在科大訊飛控制臺(tái)上可以查到服務(wù)的APIKey
const API_ID = 'xxxxx'; // 同樣可以在控制臺(tái)查到

class XFYunService extends Service {
 async voiceTranslate(voicePath) {
  // 繼上文，暴力的讀取文件
  let data = fs.readFileSync(voicePath);
  // 將內(nèi)容進(jìn)行base64編碼
  data = new Buffer(data).toString('base64');
  // 進(jìn)行url encode
  data = formUrlencoded({ audio: data });
  const params = {
   engine_type: 'sms16k',
   aue: 'raw'
  };
  const x_CurTime = Math.floor(new Date().getTime() / 1000) + '',
   x_Param = new Buffer(JSON.stringify(params)).toString('base64');
  return axios({
   url: 'http://api.xfyun.cn/v1/service/v1/iat',
   method: 'POST',
   data,
   headers: {
    'X-Appid': API_ID,
    'X-CurTime': x_CurTime,
    'X-Param': x_Param,
    'X-CheckSum': md5(API_KEY + x_CurTime + x_Param)
   }
  }).then(res => {
   // 查詢(xún)成功后，返回response的data
   return res.data || {};
  });
 }
}

module.exports = XFYunService;

// app/controller/voice.js
...
async translate() {
 ...
 ...
 const result = await this.ctx.service.xfyun.voiceTranslate(pcmPath);
 this.ctx.body = result;
 if (+result.code !== 0) {
  this.ctx.status = 500;
 }
}
...