音乐视频生成回调

from flask import Flask, request, jsonify
import requests
import os
from datetime import datetime

app = Flask(__name__)

@app.route('/video-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')
    video_url = callback_data.get('video_url')
    
    print(f"收到音乐视频生成回调: {task_id}, 状态: {code}")
    
    if code == 200:
        # 生成成功
        print("音乐视频生成完成")
        print(f"视频URL: {video_url}")
        
        # 下载视频文件示例
        if video_url:
            try:
                response = requests.get(video_url, stream=True)
                if response.status_code == 200:
                    filename = f"video_{task_id}.mp4"
                    
                    with open(filename, "wb") as f:
                        for chunk in response.iter_content(chunk_size=8192):
                            f.write(chunk)
                    
                    # 检查文件信息
                    file_size = os.path.getsize(filename)
                    print(f"视频文件已下载为 {filename}, 大小: {file_size} bytes")
                    
                    # 可以进行后续处理
                    process_video(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

def process_video(filename):
    """视频后处理示例"""
    try:
        # 获取文件信息
        file_stats = os.stat(filename)
        
        print(f"视频文件详情:")
        print(f"  文件大小: {file_stats.st_size} bytes")
        print(f"  创建时间: {datetime.fromtimestamp(file_stats.st_ctime)}")
        
        # 这里可以添加视频处理逻辑
        # 例如：使用opencv、ffmpeg等进行视频分析、格式转换等
        
    except Exception as e:
        print(f"视频处理失败: {e}")

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'] ?? '';
$videoUrl = $callbackData['video_url'] ?? '';

error_log("收到音乐视频生成回调: $taskId, 状态: $code");

if ($code === 200) {
    // 生成成功
    error_log("音乐视频生成完成");
    error_log("视频URL: $videoUrl");
    
    // 下载视频文件示例
    if ($videoUrl) {
        try {
            // 使用流式下载处理大文件
            $context = stream_context_create([
                'http' => [
                    'timeout' => 300 // 5分钟超时
                ]
            ]);
            
            $videoContent = file_get_contents($videoUrl, false, $context);
            if ($videoContent !== false) {
                $filename = "video_{$taskId}.mp4";
                file_put_contents($filename, $videoContent);
                
                // 检查文件信息
                $fileSize = filesize($filename);
                error_log("视频文件已下载为 $filename, 大小: $fileSize bytes");
                
                // 可以进行后续处理
                processVideo($filename);
            }
        } catch (Exception $e) {
            error_log("视频文件下载失败: " . $e->getMessage());
        }
    }
    
} else {
    // 生成失败
    error_log("音乐视频生成失败: $msg");
    
    // 处理失败情况...
    if ($code === 400) {
        error_log("源音频无效或参数错误");
    } elseif ($code === 429) {
        error_log("积分不足");
    } elseif ($code === 500) {
        error_log("服务器内部错误");
    }
}

/**
 * 视频后处理示例
 */
function processVideo($filename) {
    try {
        // 获取文件信息
        $fileInfo = pathinfo($filename);
        $fileSize = filesize($filename);
        $createTime = date('Y-m-d H:i:s', filectime($filename));
        
        error_log("视频文件详情:");
        error_log("  文件名: " . $fileInfo['basename']);
        error_log("  文件大小: $fileSize bytes");
        error_log("  创建时间: $createTime");
        
        // 这里可以添加视频处理逻辑
        // 例如：调用ffmpeg进行格式转换、缩略图生成等
        
    } catch (Exception $e) {
        error_log("视频处理失败: " . $e->getMessage());
    }
}

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