添加伴奏回调

from flask import Flask, request, jsonify
import requests

app = Flask(__name__)

@app.route('/instrumental-callback', methods=['POST'])
def handle_callback():
    data = request.json
    
    code = data.get('code')
    msg = data.get('msg')
    callback_data = data.get('data', {})
    task_id = callback_data.get('task_id')
    callback_type = callback_data.get('callbackType')
    instrumental_data = callback_data.get('data', [])
    
    print(f"收到伴奏生成回调: {task_id}, 类型: {callback_type}, 状态: {code}")
    
    if code == 200:
        # 任务成功
        if callback_type == 'text':
            print("文本生成完成")
            
        elif callback_type == 'first':
            print("第一个伴奏音轨生成完成")
            if instrumental_data:
                track = instrumental_data[0]
                print(f"音轨标题: {track.get('title')}")
                print(f"伴奏音频链接: {track.get('audio_url')}")
                print(f"时长: {track.get('duration')} 秒")
                print(f"伴奏风格: {track.get('tags')}")
                
        elif callback_type == 'complete':
            print("所有伴奏音轨生成完成")
            print(f"共生成 {len(instrumental_data)} 个伴奏音轨:")
            
            for i, track in enumerate(instrumental_data):
                print(f"音轨 {i + 1}: {track.get('title')} - {track.get('audio_url')}")
                print(f"风格: {track.get('tags')}")
                
                # 下载伴奏音频示例
                try:
                    audio_url = track.get('audio_url')
                    if audio_url:
                        response = requests.get(audio_url)
                        if response.status_code == 200:
                            filename = f"instrumental_{task_id}_{i + 1}.mp3"
                            with open(filename, "wb") as f:
                                f.write(response.content)
                            print(f"伴奏音频已保存为 {filename}")
                except Exception as e:
                    print(f"伴奏音频下载失败: {e}")
                    
    else:
        # 任务失败
        print(f"伴奏生成失败: {msg}")
        
        # 处理失败情况...
        if code == 400:
            print("参数错误或源音频无效")
        elif code == 429:
            print("积分不足")
        elif code == 500:
            print("服务器内部错误")
    
    # 返回200状态码确认已收到回调
    return jsonify({'status': 'received'}), 200

if __name__ == '__main__':
    app.run(host='0.0.0.0', port=3000)

<?php
header('Content-Type: application/json');

// 获取POST数据
$input = file_get_contents('php://input');
$data = json_decode($input, true);

$code = $data['code'] ?? null;
$msg = $data['msg'] ?? '';
$callbackData = $data['data'] ?? [];
$taskId = $callbackData['task_id'] ?? '';
$callbackType = $callbackData['callbackType'] ?? '';
$instrumentalData = $callbackData['data'] ?? [];

error_log("收到伴奏生成回调: $taskId, 类型: $callbackType, 状态: $code");

if ($code === 200) {
    // 任务成功
    switch ($callbackType) {
        case 'text':
            error_log("文本生成完成");
            break;
            
        case 'first':
            error_log("第一个伴奏音轨生成完成");
            if (!empty($instrumentalData)) {
                $track = $instrumentalData[0];
                error_log("音轨标题: " . ($track['title'] ?? ''));
                error_log("伴奏音频链接: " . ($track['audio_url'] ?? ''));
                error_log("时长: " . ($track['duration'] ?? 0) . " 秒");
                error_log("伴奏风格: " . ($track['tags'] ?? ''));
            }
            break;
            
        case 'complete':
            error_log("所有伴奏音轨生成完成");
            error_log("共生成 " . count($instrumentalData) . " 个伴奏音轨:");
            
            foreach ($instrumentalData as $index => $track) {
                $title = $track['title'] ?? '';
                $audioUrl = $track['audio_url'] ?? '';
                $tags = $track['tags'] ?? '';
                error_log("音轨 " . ($index + 1) . ": $title - $audioUrl");
                error_log("风格: $tags");
                
                // 下载伴奏音频示例
                try {
                    if ($audioUrl) {
                        $audioContent = file_get_contents($audioUrl);
                        if ($audioContent !== false) {
                            $filename = "instrumental_{$taskId}_" . ($index + 1) . ".mp3";
                            file_put_contents($filename, $audioContent);
                            error_log("伴奏音频已保存为 $filename");
                        }
                    }
                } catch (Exception $e) {
                    error_log("伴奏音频下载失败: " . $e->getMessage());
                }
            }
            break;
    }
    
} else {
    // 任务失败
    error_log("伴奏生成失败: $msg");
    
    // 处理失败情况...
    if ($code === 400) {
        error_log("参数错误或源音频无效");
    } elseif ($code === 429) {
        error_log("积分不足");
    } elseif ($code === 500) {
        error_log("服务器内部错误");
    }
}

// 返回200状态码确认已收到回调
http_response_code(200);
echo json_encode(['status' => 'received']);
?>