362 lines
13 KiB
PHP
362 lines
13 KiB
PHP
<?php
|
|
|
|
namespace App\Jobs;
|
|
|
|
use App\Models\VideoGeneration;
|
|
use App\Services\GoogleCloudStorageService;
|
|
use App\Services\Video\BgmService;
|
|
use App\Services\Video\GeminiScriptService;
|
|
use App\Services\Video\TtsService;
|
|
use App\Services\Video\VeoVideoService;
|
|
use App\Services\Video\VideoAssemblyService;
|
|
use Illuminate\Bus\Queueable;
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
|
use Illuminate\Foundation\Bus\Dispatchable;
|
|
use Illuminate\Queue\InteractsWithQueue;
|
|
use Illuminate\Queue\SerializesModels;
|
|
use Illuminate\Support\Facades\Log;
|
|
|
|
class VideoGenerationJob implements ShouldQueue
|
|
{
|
|
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
|
|
|
|
public int $timeout = 1800; // 30분
|
|
|
|
public int $tries = 1;
|
|
|
|
private int $videoGenerationId;
|
|
|
|
private ?string $selectedTitle;
|
|
|
|
private ?array $customScenario;
|
|
|
|
public function __construct(int $videoGenerationId, ?string $selectedTitle = null, ?array $customScenario = null)
|
|
{
|
|
$this->videoGenerationId = $videoGenerationId;
|
|
$this->selectedTitle = $selectedTitle;
|
|
$this->customScenario = $customScenario;
|
|
$this->onQueue('mng');
|
|
}
|
|
|
|
public function handle(
|
|
GeminiScriptService $gemini,
|
|
VeoVideoService $veo,
|
|
TtsService $tts,
|
|
BgmService $bgm,
|
|
VideoAssemblyService $assembly,
|
|
GoogleCloudStorageService $gcs
|
|
): void {
|
|
$video = VideoGeneration::withoutGlobalScopes()->find($this->videoGenerationId);
|
|
|
|
if (! $video) {
|
|
Log::error('VideoGenerationJob: 레코드를 찾을 수 없음', ['id' => $this->videoGenerationId]);
|
|
|
|
return;
|
|
}
|
|
|
|
$workDir = storage_path("app/video_gen/{$video->id}");
|
|
if (! is_dir($workDir)) {
|
|
mkdir($workDir, 0755, true);
|
|
}
|
|
|
|
$totalCost = 0.0;
|
|
|
|
try {
|
|
// === Step 1: 시나리오 생성 ===
|
|
$video->updateProgress(VideoGeneration::STATUS_SCENARIO_READY, 5, '시나리오 생성 중...');
|
|
|
|
if ($this->customScenario) {
|
|
$scenario = $this->customScenario;
|
|
} else {
|
|
$title = $this->selectedTitle ?? $video->title;
|
|
$scenario = $gemini->generateScenario($title, $video->keyword);
|
|
|
|
if (empty($scenario) || empty($scenario['scenes'])) {
|
|
$video->markFailed('시나리오 생성 실패');
|
|
|
|
return;
|
|
}
|
|
}
|
|
|
|
$video->update([
|
|
'scenario' => $scenario,
|
|
'title' => $scenario['title'] ?? $video->title,
|
|
]);
|
|
|
|
$scenes = $scenario['scenes'] ?? [];
|
|
$totalCost += 0.001; // Gemini 비용
|
|
|
|
// === Step 2: 나레이션 생성 ===
|
|
$video->updateProgress(VideoGeneration::STATUS_GENERATING_TTS, 15, '나레이션 생성 중...');
|
|
|
|
$narrationPaths = $tts->synthesizeScenes($scenes, $workDir);
|
|
|
|
if (empty($narrationPaths)) {
|
|
$video->markFailed('나레이션 생성 실패');
|
|
|
|
return;
|
|
}
|
|
|
|
$totalCost += 0.01; // TTS 비용
|
|
|
|
// === Step 3: 영상 클립 생성 ===
|
|
$video->updateProgress(VideoGeneration::STATUS_GENERATING_CLIPS, 20, '영상 클립 생성 요청 중...');
|
|
|
|
$clipPaths = [];
|
|
$operations = [];
|
|
|
|
// 모든 장면의 영상 생성 요청 (비동기)
|
|
foreach ($scenes as $scene) {
|
|
$sceneNum = $scene['scene_number'];
|
|
$prompt = $scene['visual_prompt'] ?? '';
|
|
$duration = $scene['duration'] ?? 8;
|
|
|
|
$video->updateProgress(
|
|
VideoGeneration::STATUS_GENERATING_CLIPS,
|
|
20 + (int) (($sceneNum / count($scenes)) * 10),
|
|
"영상 클립 생성 요청 중 ({$sceneNum}/".count($scenes).')'
|
|
);
|
|
|
|
$result = $veo->generateClip($prompt, $duration);
|
|
|
|
if (! $result) {
|
|
$video->markFailed("장면 {$sceneNum} 영상 생성 요청 실패");
|
|
|
|
return;
|
|
}
|
|
|
|
$operations[$sceneNum] = $result['operationName'];
|
|
}
|
|
|
|
$totalCost += count($scenes) * 1.20; // Veo 비용 (Fast 기준 8초당 $1.20)
|
|
|
|
// 모든 영상 클립 완료 대기
|
|
$skippedScenes = [];
|
|
|
|
foreach ($operations as $sceneNum => $operationName) {
|
|
$video->updateProgress(
|
|
VideoGeneration::STATUS_GENERATING_CLIPS,
|
|
30 + (int) (($sceneNum / count($scenes)) * 40),
|
|
"영상 클립 생성 대기 중 ({$sceneNum}/".count($scenes).')'
|
|
);
|
|
|
|
$result = $veo->waitAndSave(
|
|
$operationName,
|
|
"{$workDir}/clip_{$sceneNum}.mp4"
|
|
);
|
|
|
|
if ($result['path']) {
|
|
$clipPaths[$sceneNum] = $result['path'];
|
|
|
|
continue;
|
|
}
|
|
|
|
// 실패 시: RAI 필터링이면 프롬프트 수정 후 재시도
|
|
Log::warning("VideoGenerationJob: 장면 {$sceneNum} 실패, 재시도 중", [
|
|
'error' => $result['error'],
|
|
]);
|
|
|
|
$video->updateProgress(
|
|
VideoGeneration::STATUS_GENERATING_CLIPS,
|
|
30 + (int) (($sceneNum / count($scenes)) * 40),
|
|
"장면 {$sceneNum} 재시도 중 (프롬프트 수정)..."
|
|
);
|
|
|
|
$scene = $scenes[$sceneNum - 1] ?? null;
|
|
$retryPrompt = $this->makeSafePrompt($scene['visual_prompt'] ?? '');
|
|
$retryResult = $veo->generateClip($retryPrompt, $scene['duration'] ?? 8);
|
|
|
|
if ($retryResult) {
|
|
$retryWait = $veo->waitAndSave(
|
|
$retryResult['operationName'],
|
|
"{$workDir}/clip_{$sceneNum}.mp4"
|
|
);
|
|
|
|
if ($retryWait['path']) {
|
|
$clipPaths[$sceneNum] = $retryWait['path'];
|
|
Log::info("VideoGenerationJob: 장면 {$sceneNum} 재시도 성공");
|
|
|
|
continue;
|
|
}
|
|
}
|
|
|
|
// 재시도도 실패 → 건너뛰기
|
|
$skippedScenes[] = $sceneNum;
|
|
Log::warning("VideoGenerationJob: 장면 {$sceneNum} 최종 실패, 건너뛰기", [
|
|
'error' => $result['error'],
|
|
]);
|
|
}
|
|
|
|
// 성공한 클립이 절반 미만이면 전체 실패
|
|
if (count($clipPaths) < ceil(count($scenes) / 2)) {
|
|
$video->markFailed('영상 클립 생성 실패 (성공: '.count($clipPaths).'/'.count($scenes).')');
|
|
|
|
return;
|
|
}
|
|
|
|
if (! empty($skippedScenes)) {
|
|
Log::info('VideoGenerationJob: 건너뛴 장면', ['scenes' => $skippedScenes]);
|
|
}
|
|
|
|
// 장면 순서로 정렬
|
|
ksort($clipPaths);
|
|
|
|
$video->update(['clips_data' => $clipPaths]);
|
|
|
|
// 건너뛴 장면 필터링: 나레이션/자막도 성공한 클립에 맞춤
|
|
$activeSceneNums = array_keys($clipPaths);
|
|
$activeScenes = array_filter($scenes, fn ($s) => in_array($s['scene_number'], $activeSceneNums));
|
|
$activeScenes = array_values($activeScenes);
|
|
|
|
// 나레이션 키를 장면 번호로 유지 (concatNarrations에서 scene_number로 매칭)
|
|
$activeNarrationPaths = [];
|
|
foreach ($activeSceneNums as $num) {
|
|
if (isset($narrationPaths[$num])) {
|
|
$activeNarrationPaths[$num] = $narrationPaths[$num];
|
|
}
|
|
}
|
|
|
|
// === Step 4: BGM 생성/선택 ===
|
|
$video->updateProgress(VideoGeneration::STATUS_GENERATING_BGM, 75, 'AI 배경음악 생성 중...');
|
|
|
|
$bgmMood = $scenario['bgm_mood'] ?? 'upbeat';
|
|
$totalDuration = array_sum(array_column($activeScenes, 'duration'));
|
|
|
|
// 1순위: Google Lyria AI 배경음악 생성
|
|
$bgmPath = $bgm->generateWithLyria($bgmMood, $totalDuration, "{$workDir}/bgm.mp3");
|
|
if ($bgmPath) {
|
|
$totalCost += 0.06; // Lyria 비용 ($0.06/30초)
|
|
}
|
|
|
|
// 2순위: 프리셋 BGM 파일
|
|
if (! $bgmPath) {
|
|
$bgmPath = $bgm->select($bgmMood, "{$workDir}/bgm.mp3");
|
|
}
|
|
|
|
// 3순위: FFmpeg 앰비언트 BGM
|
|
if (! $bgmPath) {
|
|
$bgmPath = $bgm->generateAmbient($bgmMood, $totalDuration, "{$workDir}/bgm.mp3");
|
|
}
|
|
|
|
// === Step 5: 최종 합성 ===
|
|
$video->updateProgress(VideoGeneration::STATUS_ASSEMBLING, 80, '영상 합성 중...');
|
|
|
|
// 5-1. 클립 결합
|
|
$concatPath = "{$workDir}/concat.mp4";
|
|
$concatResult = $assembly->concatClips(array_values($clipPaths), $concatPath);
|
|
|
|
if (! $concatResult) {
|
|
$video->markFailed('영상 클립 결합 실패');
|
|
|
|
return;
|
|
}
|
|
|
|
// 5-2. 나레이션 결합 (성공한 장면만)
|
|
$narrationConcatPath = "{$workDir}/narration_full.mp3";
|
|
$assembly->concatNarrations($activeNarrationPaths, $activeScenes, $narrationConcatPath);
|
|
|
|
// 5-3. 자막 생성 (실제 TTS 오디오 길이 기반 싱크)
|
|
$narrationDurations = [];
|
|
foreach ($activeNarrationPaths as $sceneNum => $narPath) {
|
|
$dur = $assembly->getAudioDuration($narPath);
|
|
if ($dur > 0) {
|
|
$narrationDurations[$sceneNum] = $dur;
|
|
}
|
|
}
|
|
|
|
$subtitlePath = "{$workDir}/subtitles.ass";
|
|
$assembly->generateAssSubtitle($activeScenes, $subtitlePath, $narrationDurations);
|
|
|
|
// 5-4. 최종 합성
|
|
$video->updateProgress(VideoGeneration::STATUS_ASSEMBLING, 90, '최종 합성 중...');
|
|
|
|
$finalPath = "{$workDir}/final_{$video->id}.mp4";
|
|
$result = $assembly->assemble(
|
|
$concatPath,
|
|
file_exists($narrationConcatPath) ? $narrationConcatPath : null,
|
|
$bgmPath,
|
|
$subtitlePath,
|
|
$finalPath
|
|
);
|
|
|
|
if (! $result) {
|
|
$video->markFailed('최종 영상 합성 실패');
|
|
|
|
return;
|
|
}
|
|
|
|
// === GCS 업로드 ===
|
|
$gcsPath = null;
|
|
|
|
if ($gcs->isAvailable()) {
|
|
$video->updateProgress(VideoGeneration::STATUS_ASSEMBLING, 95, 'GCS 업로드 중...');
|
|
|
|
$objectName = "video_gen/{$video->id}/final_{$video->id}.mp4";
|
|
$gcsUri = $gcs->upload($finalPath, $objectName);
|
|
|
|
if ($gcsUri) {
|
|
$gcsPath = $objectName;
|
|
Log::info('VideoGenerationJob: GCS 업로드 성공', [
|
|
'id' => $video->id,
|
|
'gcs_path' => $objectName,
|
|
]);
|
|
} else {
|
|
Log::warning('VideoGenerationJob: GCS 업로드 실패, 로컬 파일로 계속', [
|
|
'id' => $video->id,
|
|
]);
|
|
}
|
|
}
|
|
|
|
// === 완료 ===
|
|
$stepMsg = empty($skippedScenes)
|
|
? '완료'
|
|
: '완료 (장면 '.implode(',', $skippedScenes).' 건너뜀)';
|
|
|
|
$video->update([
|
|
'status' => VideoGeneration::STATUS_COMPLETED,
|
|
'progress' => 100,
|
|
'current_step' => $stepMsg,
|
|
'output_path' => $finalPath,
|
|
'gcs_path' => $gcsPath,
|
|
'cost_usd' => $totalCost,
|
|
]);
|
|
|
|
// 중간 파일 정리
|
|
$assembly->cleanup($workDir);
|
|
|
|
Log::info('VideoGenerationJob: 영상 생성 완료', [
|
|
'id' => $video->id,
|
|
'output' => $finalPath,
|
|
'gcs_path' => $gcsPath,
|
|
'cost' => $totalCost,
|
|
]);
|
|
} catch (\Exception $e) {
|
|
Log::error('VideoGenerationJob: 예외 발생', [
|
|
'id' => $video->id,
|
|
'error' => $e->getMessage(),
|
|
'trace' => $e->getTraceAsString(),
|
|
]);
|
|
|
|
$video->markFailed($e->getMessage());
|
|
}
|
|
}
|
|
|
|
public function failed(\Throwable $exception): void
|
|
{
|
|
$video = VideoGeneration::withoutGlobalScopes()->find($this->videoGenerationId);
|
|
$video?->markFailed('Job 실패: '.$exception->getMessage());
|
|
}
|
|
|
|
/**
|
|
* RAI 필터링 방지를 위해 프롬프트를 안전하게 수정
|
|
*/
|
|
private function makeSafePrompt(string $prompt): string
|
|
{
|
|
// 사람 관련 키워드를 풍경/오브젝트 중심으로 대체
|
|
$prompt = preg_replace('/\b(woman|man|girl|boy|person|people|her|his|she|he)\b/i', 'subject', $prompt);
|
|
|
|
// 안전 키워드 추가
|
|
return 'Safe for all audiences. Professional stock footage style. '.$prompt;
|
|
}
|
|
}
|