音频分离回调

const express = require('express');
const app = express();

app.use(express.json());

app.post('/vocal-separation-callback', (req, res) => {
  const { code, msg, data } = req.body;
  
  console.log('收到人声分离回调:', {
    taskId: data.task_id,
    status: code,
    message: msg
  });
  
  if (code === 200) {
    // 任务成功完成
    console.log('人声分离完成');
    const vocalInfo = data.vocal_removal_info;
    
    if (vocalInfo) {
      console.log('分离结果:');
      console.log(`  原始音频: ${vocalInfo.origin_url}`);
      
      // 根据不同的分离类型处理不同的文件
      if (vocalInfo.instrumental_url) {
        // separate_vocal 类型
        console.log(`  纯伴奏: ${vocalInfo.instrumental_url}`);
        console.log(`  纯人声: ${vocalInfo.vocal_url}`);
      } else {
        // split_stem 类型
        console.log(`  人声: ${vocalInfo.vocal_url}`);
        console.log(`  和声: ${vocalInfo.backing_vocals_url}`);
        console.log(`  鼓声: ${vocalInfo.drums_url}`);
        console.log(`  贝斯: ${vocalInfo.bass_url}`);
        console.log(`  吉他: ${vocalInfo.guitar_url}`);
        console.log(`  键盘: ${vocalInfo.keyboard_url}`);
        console.log(`  打击乐: ${vocalInfo.percussion_url}`);
        console.log(`  弦乐: ${vocalInfo.strings_url}`);
        console.log(`  合成器: ${vocalInfo.synth_url}`);
        console.log(`  音效: ${vocalInfo.fx_url}`);
        console.log(`  铜管乐: ${vocalInfo.brass_url}`);
        console.log(`  木管乐: ${vocalInfo.woodwinds_url}`);
      }
      
      // 下载分离后的音频文件
      const https = require('https');
      const fs = require('fs');
      
      const downloadFile = (url, filename) => {
        if (!url) return;
        
        const file = fs.createWriteStream(filename);
        https.get(url, (response) => {
          response.pipe(file);
          file.on('finish', () => {
            file.close();
            console.log(`已保存: ${filename}`);
          });
        }).on('error', (err) => {
          console.error(`下载失败 ${filename}:`, err.message);
        });
      };
      
      // 下载所有可用的音频文件
      Object.keys(vocalInfo).forEach(key => {
        if (vocalInfo[key] && key.endsWith('_url')) {
          const filename = `${data.task_id}_${key.replace('_url', '')}.mp3`;
          downloadFile(vocalInfo[key], filename);
        }
      });
    }
    
  } else {
    // 任务失败
    console.log('人声分离失败:', msg);
    
    // 处理失败情况...
    if (code === 400) {
      console.log('参数错误或音频格式不支持');
    } else if (code === 451) {
      console.log('源音频文件下载失败');
    } else if (code === 500) {
      console.log('服务器内部错误');
    }
  }
  
  // 返回200状态码确认收到回调
  res.status(200).json({ status: 'received' });
});

app.listen(3000, () => {
  console.log('回调服务器运行在端口 3000');
});