sion123
83668cea3c
核心改动：将超时与任务失败明确区分，超时场景保留 taskId 和 pending 状态， 等待下次恢复，避免重复计费；仅 API 明确返回 failed 时才清理 taskId 并重试。 - phase-videos.js: 恢复失败分超时/失败处理，超时保留 taskId 置 pending - phase-videos.js: 轮询结果超时也保留 taskId 存 pending - video-poll-utils.js: 增加 isTaskFailed 判断；超时禁止创建新任务 - video-poll-utils.js: 提升轮询重试次数至 5 次以允许超时等待
227 lines
8.2 KiB
JavaScript
227 lines
8.2 KiB
JavaScript
/**
|
||
* Phase: videos — 视频生成（VEO / Grok / Kling）
|
||
*
|
||
* 图生视频，批量提交，生成后自动上传 OSS
|
||
* 支持 task ID 恢复：中断后重跑时优先恢复已有任务
|
||
*/
|
||
|
||
const path = require('path')
|
||
const { saveManifest, ensureDir, log, getManifestDir } = require('./pipeline-utils')
|
||
|
||
async function phaseVideos(manifest, manifestPath, options) {
|
||
const dir = getManifestDir(manifestPath)
|
||
const videosDir = path.join(dir, 'videos')
|
||
ensureDir(videosDir)
|
||
|
||
const accountConfig = options.accountConfig || {}
|
||
const videoModel = manifest.videoModel || accountConfig.videoModel || 'veo3-fast-frames'
|
||
|
||
// 筛选需要生视频的 item：
|
||
// done — 正常流程，图片已确认且已上传
|
||
// pending / failed — 重试场景，agent 只需将 item 设为 pending 即可触发再生
|
||
// 前提：有 url（图片已上传）+ videoPrompt，且 confirmed 未被显式拒绝
|
||
const videoCandidates = manifest.items.filter(it => {
|
||
if (it.confirmed === false) return false
|
||
if (!it.url || !it.videoPrompt) return false
|
||
return ['done', 'pending', 'failed'].includes(it.status)
|
||
})
|
||
|
||
if (videoCandidates.length === 0) {
|
||
console.log("\n⚠️ [videos] 没有符合条件的 item 进入视频生成阶段")
|
||
console.log(" manifest 中共有", manifest.items.length, "个 item，逐一诊断:")
|
||
for (const it of manifest.items) {
|
||
const reasons = []
|
||
if (it.confirmed === false) reasons.push("confirmed=false")
|
||
if (!it.url) reasons.push("缺少 url（图片未上传）")
|
||
if (!it.videoPrompt) reasons.push("缺少 videoPrompt")
|
||
if (it.confirmed !== false && it.url && it.videoPrompt && !["done","pending","failed"].includes(it.status)) {
|
||
reasons.push("status=" + (it.status || "undefined") + "（不在 done/pending/failed 中）")
|
||
}
|
||
console.log(" - item", it.id || manifest.items.indexOf(it), ":", reasons.length > 0 ? reasons.join(", ") : "已满足全部条件（不应在此）")
|
||
}
|
||
console.log("\n 修复命令:")
|
||
console.log(" node .claude/skills/video-from-script/scripts/pipeline.js confirm --manifest", manifestPath, "--all")
|
||
console.log()
|
||
}
|
||
|
||
// 已有视频（本地或 OSS）且状态为 done 的跳过，其余清理视频引用但保留 taskId 供恢复
|
||
const items = []
|
||
for (const it of videoCandidates) {
|
||
if (it.video || it.videoUrl) {
|
||
if (it.status === 'done') continue
|
||
delete it.video
|
||
delete it.videoUrl
|
||
delete it.videoDuration
|
||
}
|
||
items.push(it)
|
||
}
|
||
if (items.length === 0) { log('videos', '无待处理 item，跳过'); return }
|
||
|
||
// 选择生成器
|
||
let Api, pollFn
|
||
const modelLower = videoModel.toLowerCase()
|
||
if (modelLower.includes('grok')) {
|
||
const gen = require('../grok-video-generator')
|
||
Api = gen.GrokApi; pollFn = gen.pollWithRetry
|
||
} else if (modelLower.includes('kling')) {
|
||
const gen = require('../kling-video-generator')
|
||
Api = gen.KlingApi; pollFn = gen.pollWithRetry
|
||
} else {
|
||
const gen = require('../veo-video-generator')
|
||
Api = gen.VeoApi; pollFn = gen.pollWithRetry
|
||
}
|
||
|
||
const ratio = manifest.format || '9:16'
|
||
log('videos', `共 ${items.length} 个, 模型: ${videoModel}`)
|
||
|
||
// Phase 1: 恢复已有任务（有 videoTaskId 的 item）
|
||
const recovered = []
|
||
const needSubmit = []
|
||
|
||
for (const item of items) {
|
||
if (item.videoTaskId) {
|
||
recovered.push(item)
|
||
} else {
|
||
needSubmit.push(item)
|
||
}
|
||
}
|
||
|
||
if (recovered.length > 0) {
|
||
log('videos', `尝试恢复 ${recovered.length} 个中断任务...`)
|
||
await Promise.allSettled(
|
||
recovered.map(async (item) => {
|
||
try {
|
||
log('videos', ` 恢复 item ${item.id}: ${item.videoTaskId}`)
|
||
const result = await pollFn(item.videoTaskId, item.videoPrompt, {
|
||
outputDir: videosDir,
|
||
aspectRatio: ratio,
|
||
imageUrl: item.url,
|
||
lastFrameUrl: item.lastFrameUrl || '',
|
||
})
|
||
if (result.file) {
|
||
item.video = path.relative(dir, result.file).replace(/\\/g, '/')
|
||
item.videoDuration = result.duration
|
||
item.status = 'done'
|
||
delete item.videoTaskId
|
||
log('videos', ` item ${item.id} 恢复成功`)
|
||
}
|
||
} catch (err) {
|
||
const isFail = err.isTaskFailure === true
|
||
if (isFail) {
|
||
log('videos', ` item ${item.id} 恢复失败（任务失败）: ${err.message}，将重新提交`)
|
||
delete item.videoTaskId
|
||
needSubmit.push(item)
|
||
} else {
|
||
log('videos', ` item ${item.id} 恢复超时（保留 taskId 下次重试）: ${err.message}`)
|
||
item.status = 'pending'
|
||
}
|
||
}
|
||
})
|
||
)
|
||
saveManifest(manifestPath, manifest)
|
||
}
|
||
|
||
if (needSubmit.length === 0) { log('videos', '全部通过恢复完成'); return }
|
||
|
||
// Phase 2: 提交新任务（并发 5，Kling 最大并发）
|
||
const concurrency = 5
|
||
log('videos', `提交 ${needSubmit.length} 个新任务（并发: ${concurrency}）...`)
|
||
|
||
const submitted = []
|
||
for (let i = 0; i < needSubmit.length; i += concurrency) {
|
||
const batch = needSubmit.slice(i, i + concurrency)
|
||
const batchResults = await Promise.allSettled(
|
||
batch.map(async (item) => {
|
||
const extraOpts = item.lastFrameUrl
|
||
? { aspectRatio: ratio, lastFrameUrl: item.lastFrameUrl, mode: 'pro' }
|
||
: { aspectRatio: ratio }
|
||
try {
|
||
const taskId = await Api.create(item.url, item.videoPrompt, extraOpts)
|
||
return { item, taskId, error: null }
|
||
} catch (err) {
|
||
return { item, taskId: null, error: err.message }
|
||
}
|
||
})
|
||
)
|
||
for (const r of batchResults) {
|
||
const val = r.status === 'fulfilled' ? r.value : { item: null, taskId: null, error: r.reason }
|
||
submitted.push(val)
|
||
if (val.item && val.taskId) {
|
||
val.item.videoTaskId = val.taskId
|
||
}
|
||
}
|
||
saveManifest(manifestPath, manifest)
|
||
}
|
||
|
||
// Phase 3: 轮询新任务
|
||
const pending = submitted.filter(s => s.taskId)
|
||
if (pending.length === 0) {
|
||
log('videos', '所有任务提交失败')
|
||
for (const s of submitted) {
|
||
if (s.item) { s.item.status = 'failed'; s.item.error = s.error || '提交失败' }
|
||
}
|
||
saveManifest(manifestPath, manifest)
|
||
return
|
||
}
|
||
|
||
log('videos', `等待 ${pending.length} 个视频生成...`)
|
||
|
||
const pollResults = await Promise.allSettled(
|
||
pending.map(async ({ item, taskId }) => {
|
||
try {
|
||
const result = await pollFn(taskId, item.videoPrompt, {
|
||
outputDir: videosDir,
|
||
aspectRatio: ratio,
|
||
imageUrl: item.url,
|
||
lastFrameUrl: item.lastFrameUrl || '',
|
||
})
|
||
return { item, result, ok: true }
|
||
} catch (err) {
|
||
return { item, error: err.message, ok: false, isTaskFailure: err.isTaskFailure === true }
|
||
}
|
||
})
|
||
)
|
||
|
||
for (const r of pollResults) {
|
||
const val = r.status === 'fulfilled'
|
||
? r.value
|
||
: { ok: false, error: r.reason?.message || String(r.reason), isTaskFailure: r.reason?.isTaskFailure === true }
|
||
if (val.ok && val.result.file) {
|
||
val.item.video = path.relative(dir, val.result.file).replace(/\\/g, '/')
|
||
val.item.videoDuration = val.result.duration
|
||
val.item.status = 'done'
|
||
delete val.item.videoTaskId
|
||
} else if (val.item) {
|
||
if (val.isTaskFailure) {
|
||
val.item.status = 'failed'
|
||
val.item.error = val.error || '视频生成未返回文件'
|
||
delete val.item.videoTaskId
|
||
} else {
|
||
log('videos', ` item ${val.item.id} 生成超时（保留 taskId 待恢复）: ${val.error}`)
|
||
val.item.status = 'pending'
|
||
}
|
||
}
|
||
saveManifest(manifestPath, manifest)
|
||
}
|
||
|
||
// 上传视频到 OSS
|
||
const { uploadFile } = require('../oss-upload')
|
||
const videoItems = manifest.items.filter(it => it.video && !it.videoUrl)
|
||
if (videoItems.length > 0) {
|
||
log('videos', `上传 ${videoItems.length} 个视频到 OSS...`)
|
||
for (const item of videoItems) {
|
||
const videoPath = path.resolve(dir, item.video)
|
||
try {
|
||
const { url } = await uploadFile(videoPath)
|
||
item.videoUrl = url
|
||
log('videos', ` ${item.video} → OK`)
|
||
} catch (err) {
|
||
log('videos', ` ${item.video} 上传失败: ${err.message}`)
|
||
}
|
||
}
|
||
saveManifest(manifestPath, manifest)
|
||
}
|
||
}
|
||
|
||
module.exports = { phaseVideos }
|