灵应
356df4663e
Deploy / Staging E2E Tests (push) Has been cancelled
Deploy / Deploy Staging (push) Failing after 111h7m48s
CI/CD Pipeline / Frontend Lint (push) Failing after 111h7m57s
CI/CD Pipeline / Validate Code Quality And Tests (push) Failing after 111h7m57s
Deploy / Production Browser E2E (push) Failing after 1769h43m24s
Deploy / Deploy Production (push) Failing after 1769h43m26s
Deploy / Build Production Runtime Images (push) Failing after 1769h43m28s
Task #105: 修复剪辑计划/模板页面报服务器繁忙 - templates.py: list_templates/get_template/list_categories 加 try/except - templates.py: 新增 POST /{template_id}/toggle-favorite 兼容端点 - edit_plans.py: list_plans 加 try/except，ai_tasks 加 ImportError 守卫 Task #106: 修复素材库诊断按钮 + 缩略图/视频URL - asset_diagnosis.py: get_project_asset_diagnosis 加 try/except - assets.py: 注入 storage_service，生成签名 file_url - asset.py schema: 新增 file_url 字段 - 视频素材 thumbnail_url 为空时复用 file_url 作为封面 其他: - edit_plans/generation_tasks 支持 source_edit_plan_id - Alembic 迁移 022: 两表加 source_edit_plan_id 字段
110 lines
3.6 KiB
Python
110 lines
3.6 KiB
Python
"""EditPlan domain entity for Phase 8 模板编排引擎."""
|
|
|
|
from __future__ import annotations
|
|
|
|
import sys
|
|
from dataclasses import dataclass, field
|
|
from datetime import datetime, timezone
|
|
|
|
if sys.version_info >= (3, 11):
|
|
from enum import StrEnum
|
|
else:
|
|
from enum import Enum
|
|
|
|
class StrEnum(str, Enum):
|
|
pass
|
|
|
|
|
|
from typing import Any
|
|
from uuid import uuid4
|
|
|
|
|
|
class EditPlanStatus(StrEnum):
|
|
"""剪辑计划状态"""
|
|
|
|
DRAFT = "draft"
|
|
EDITING = "editing"
|
|
RENDERING = "rendering"
|
|
COMPLETED = "completed"
|
|
FAILED = "failed"
|
|
|
|
|
|
@dataclass(slots=True)
|
|
class EditPlan:
|
|
"""Phase 8 剪辑计划实体
|
|
|
|
基于某个 EditTemplate 创建的剪辑计划，包含具体的配置和状态追踪。
|
|
状态流转：draft → editing → rendering → completed / failed
|
|
"""
|
|
|
|
id: str
|
|
template_id: str
|
|
name: str
|
|
status: EditPlanStatus = EditPlanStatus.DRAFT
|
|
total_duration: float = 0.0
|
|
source_edit_plan_id: str = ""
|
|
config: dict[str, Any] = field(default_factory=dict)
|
|
created_at: datetime = field(default_factory=lambda: datetime.now(timezone.utc))
|
|
updated_at: datetime = field(default_factory=lambda: datetime.now(timezone.utc))
|
|
|
|
@classmethod
|
|
def create(
|
|
cls,
|
|
template_id: str,
|
|
name: str,
|
|
*,
|
|
config: dict[str, Any] | None = None,
|
|
total_duration: float = 0.0,
|
|
source_edit_plan_id: str = "",
|
|
) -> EditPlan:
|
|
"""创建新剪辑计划实例"""
|
|
clean_name = name.strip()
|
|
if not clean_name:
|
|
raise ValueError("计划名称不能为空")
|
|
if not template_id.strip():
|
|
raise ValueError("template_id 不能为空")
|
|
return cls(
|
|
id=uuid4().hex,
|
|
template_id=template_id.strip(),
|
|
name=clean_name,
|
|
status=EditPlanStatus.DRAFT,
|
|
total_duration=total_duration,
|
|
source_edit_plan_id=source_edit_plan_id.strip(),
|
|
config=config or {},
|
|
)
|
|
|
|
def start_editing(self) -> None:
|
|
"""开始编辑"""
|
|
if self.status != EditPlanStatus.DRAFT:
|
|
raise ValueError(f"只有 draft 状态的计划可以开始编辑，当前状态: {self.status}")
|
|
self.status = EditPlanStatus.EDITING
|
|
self.updated_at = datetime.now(timezone.utc)
|
|
|
|
def start_rendering(self) -> None:
|
|
"""开始渲染"""
|
|
if self.status != EditPlanStatus.EDITING:
|
|
raise ValueError(f"只有 editing 状态的计划可以开始渲染，当前状态: {self.status}")
|
|
self.status = EditPlanStatus.RENDERING
|
|
self.updated_at = datetime.now(timezone.utc)
|
|
|
|
def mark_completed(self) -> None:
|
|
"""标记为完成"""
|
|
if self.status != EditPlanStatus.RENDERING:
|
|
raise ValueError(f"只有 rendering 状态的计划可以标记完成，当前状态: {self.status}")
|
|
self.status = EditPlanStatus.COMPLETED
|
|
self.updated_at = datetime.now(timezone.utc)
|
|
|
|
def mark_failed(self) -> None:
|
|
"""标记为失败"""
|
|
if self.status != EditPlanStatus.RENDERING:
|
|
raise ValueError(f"只有 rendering 状态的计划可以标记失败，当前状态: {self.status}")
|
|
self.status = EditPlanStatus.FAILED
|
|
self.updated_at = datetime.now(timezone.utc)
|
|
|
|
def reset_to_draft(self) -> None:
|
|
"""重置为草稿状态（仅从 failed 状态可重置）"""
|
|
if self.status != EditPlanStatus.FAILED:
|
|
raise ValueError(f"只有 failed 状态的计划可以重置，当前状态: {self.status}")
|
|
self.status = EditPlanStatus.DRAFT
|
|
self.updated_at = datetime.now(timezone.utc)
|