Sora2API 视频生成回调

from flask import Flask, request, jsonify
import requests
import json

app = Flask(__name__)

@app.route('/sora2-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('taskId')
    param_json = callback_data.get('paramJson', '{}')
    response_data = callback_data.get('response', {})
    video_url = response_data.get('imageUrl', '')
    success_flag = callback_data.get('successFlag')
    error_code = callback_data.get('errorCode')
    error_message = callback_data.get('errorMessage')
    complete_time = callback_data.get('completeTime')
    
    print(f"收到Sora2API视频生成回调: {task_id}, 状态: {code}, successFlag: {success_flag}")
    
    if code == 200 and success_flag == 1:
        # 任务成功完成
        print("Sora2API视频生成完成")
        
        # 解析原始请求参数
        try:
            params = json.loads(param_json)
            print(f"原始提示词: {params.get('prompt', '')}")
            print(f"清晰度: {params.get('quality', '')}")
        except json.JSONDecodeError as e:
            print(f"解析paramJson失败: {e}")
        
        # 处理生成的视频
        if video_url:
            print(f"生成结果URL: {video_url}")
            print(f"完成时间: {complete_time}")
            
            # 下载视频示例
            try:
                response = requests.get(video_url)
                if response.status_code == 200:
                    filename = f"sora2_video_{task_id}.mp4"
                    with open(filename, "wb") as f:
                        f.write(response.content)
                    print(f"视频已保存为 {filename}")
            except Exception as e:
                print(f"下载视频失败: {e}")
                
    else:
        # 任务失败
        print(f"Sora2API视频生成失败: {error_message or msg}")
        print(f"错误码: {error_code}")
        
        # 处理失败情况...
    
    # 返回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['taskId'] ?? '';
$paramJson = $callbackData['paramJson'] ?? '{}';
$responseData = $callbackData['response'] ?? [];
$videoUrl = $responseData['imageUrl'] ?? '';
$successFlag = $callbackData['successFlag'] ?? 0;
$errorCode = $callbackData['errorCode'] ?? 0;
$errorMessage = $callbackData['errorMessage'] ?? '';
$completeTime = $callbackData['completeTime'] ?? '';

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

if ($code === 200 && $successFlag === 1) {
    // 任务成功完成
    error_log("Sora2API视频生成完成");
    
    // 解析原始请求参数
    $params = json_decode($paramJson, true);
    if ($params) {
        error_log("原始提示词: " . ($params['prompt'] ?? ''));
        error_log("清晰度: " . ($params['quality'] ?? ''));
    } else {
        error_log("解析paramJson失败");
    }
    
    // 处理生成的视频
    if (!empty($videoUrl)) {
        error_log("生成结果URL: $videoUrl");
        error_log("完成时间: $completeTime");
        
        // 下载视频示例
        try {
            $videoContent = file_get_contents($videoUrl);
            if ($videoContent !== false) {
                $filename = "sora2_video_{$taskId}.mp4";
                file_put_contents($filename, $videoContent);
                error_log("视频已保存为 $filename");
            }
        } catch (Exception $e) {
            error_log("下载视频失败: " . $e->getMessage());
        }
    }
    
} else {
    // 任务失败
    error_log("Sora2API视频生成失败: " . ($errorMessage ?: $msg));
    error_log("错误码: $errorCode");
    
    // 处理失败情况...
}

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