# Copyright (c) Huawei Technologies Co., Ltd. 2023-2025. All rights reserved.
"""任务 数据库表"""

import uuid
from datetime import UTC, datetime
from enum import Enum as PyEnum
from typing import Any

from sqlalchemy import DateTime, Enum, Float, ForeignKey, String, Text
from sqlalchemy.dialects.postgresql import JSONB, UUID
from sqlalchemy.orm import Mapped, mapped_column

from .base import Base


class ExecutorStatus(str, PyEnum):
    """执行器状态"""

    INIT = "init"
    WAITING = "waiting"
    RUNNING = "running"
    SUCCESS = "success"
    ERROR = "error"
    CANCELLED = "cancelled"


class LanguageType(str, PyEnum):
    """语言"""

    CHINESE = "zh"
    ENGLISH = "en"


class StepStatus(str, PyEnum):
    """步骤状态"""

    INIT = "init"
    WAITING = "waiting"
    RUNNING = "running"
    SUCCESS = "success"
    ERROR = "error"
    PARAM = "param"
    CANCELLED = "cancelled"


class StepType(str, PyEnum):
    """步骤类型"""

    API = "api"
    CHOICE = "choice"
    CMD = "cmd"
    CONVERT = "convert"
    FACTS = "facts"
    GRAPH = "graph"
    LLM = "llm"
    MCP = "mcp"
    RAG = "rag"
    SLOT = "slot"
    SUMMARY = "summary"
    SQL = "sql"
    SUGGEST = "suggest"


class Task(Base):
    """任务"""

    __tablename__ = "framework_task"
    userId: Mapped[str] = mapped_column(String(50), ForeignKey("framework_user.id"))  # noqa: N815
    """用户ID"""
    conversationId: Mapped[uuid.UUID | None] = mapped_column(  # noqa: N815
        UUID(as_uuid=True), ForeignKey("framework_conversation.id"), nullable=True,
    )
    """对话ID"""
    checkpointId: Mapped[uuid.UUID | None] = mapped_column(  # noqa: N815
        UUID(as_uuid=True), ForeignKey("framework_executor_checkpoint.id"),
        nullable=True, default=None,
    )
    """检查点ID"""
    recordId: Mapped[uuid.UUID | None] = mapped_column(  # noqa: N815
        UUID(as_uuid=True), nullable=True, default=None,
    )
    """记录ID"""
    id: Mapped[uuid.UUID] = mapped_column(UUID(as_uuid=True), primary_key=True, default_factory=uuid.uuid4)
    """任务ID"""
    updatedAt: Mapped[datetime] = mapped_column(  # noqa: N815
        DateTime(timezone=True), nullable=False, default_factory=lambda: datetime.now(UTC),
        onupdate=lambda: datetime.now(UTC),
    )


class TaskRuntime(Base):
    """任务运行时数据"""

    __tablename__ = "framework_task_runtime"

    taskId: Mapped[uuid.UUID] = mapped_column(  # noqa: N815
        UUID(as_uuid=True), ForeignKey("framework_task.id"), nullable=False,
        primary_key=True,
    )
    """任务ID"""
    time: Mapped[float] = mapped_column(
        Float, default_factory=lambda: round(datetime.now(UTC).timestamp(), 2), nullable=False,
    )
    """时间"""
    fullTime: Mapped[float] = mapped_column(Float, default=0.0, nullable=False)  # noqa: N815
    """完整时间成本"""
    authHeader: Mapped[str | None] = mapped_column(  # noqa: N815
        String(255), nullable=True, default=None,
    )
    """认证头"""
    userInput: Mapped[str] = mapped_column(Text, nullable=False, default="")  # noqa: N815
    """用户输入"""
    fullAnswer: Mapped[str] = mapped_column(Text, nullable=False, default="")  # noqa: N815
    """完整输出"""
    fact: Mapped[list[str]] = mapped_column(JSONB, nullable=False, default_factory=list)
    """记忆"""
    reasoning: Mapped[str] = mapped_column(Text, nullable=False, default="")
    """中间推理"""
    filledSlot: Mapped[dict[str, Any]] = mapped_column(JSONB, nullable=False, default_factory=dict)  # noqa: N815
    """计划"""
    document: Mapped[list[dict[uuid.UUID, Any]]] = mapped_column(JSONB, nullable=False, default_factory=dict)
    """关联文档"""
    language: Mapped[LanguageType] = mapped_column(Enum(LanguageType), nullable=False, default=LanguageType.CHINESE)
    """语言"""


class ExecutorCheckpoint(Base):
    """执行器检查点"""

    __tablename__ = "framework_executor_checkpoint"

    # 执行器级数据
    taskId: Mapped[uuid.UUID] = mapped_column(UUID(as_uuid=True), nullable=False)  # noqa: N815
    """任务ID"""
    appId: Mapped[uuid.UUID | None] = mapped_column(UUID(as_uuid=True), nullable=True)  # noqa: N815
    """应用ID"""
    executorId: Mapped[str] = mapped_column(String(255), nullable=False)  # noqa: N815
    """执行器ID（例如工作流ID）"""
    executorName: Mapped[str] = mapped_column(String(255), nullable=False)  # noqa: N815
    """执行器名称（例如工作流名称）"""
    executorStatus: Mapped[ExecutorStatus] = mapped_column(Enum(ExecutorStatus), nullable=False)  # noqa: N815
    """执行器状态"""
    # 步骤级数据
    stepId: Mapped[uuid.UUID] = mapped_column(UUID(as_uuid=True), nullable=False)  # noqa: N815
    """步骤ID"""
    stepName: Mapped[str] = mapped_column(String(255), nullable=False)  # noqa: N815
    """步骤名称"""
    stepStatus: Mapped[StepStatus] = mapped_column(Enum(StepStatus), nullable=False)  # noqa: N815
    """步骤状态"""
    stepType: Mapped[str] = mapped_column(String(255), nullable=False)  # noqa: N815
    """步骤类型"""
    id: Mapped[uuid.UUID] = mapped_column(UUID(as_uuid=True), primary_key=True, default_factory=uuid.uuid4)
    """检查点ID"""
    executorDescription: Mapped[str] = mapped_column(Text, nullable=False, default="")  # noqa: N815
    """执行器描述"""
    errorMessage: Mapped[dict[str, Any]] = mapped_column(JSONB, nullable=False, default_factory=dict)  # noqa: N815
    """错误信息"""
    extraData: Mapped[dict[str, Any]] = mapped_column(JSONB, nullable=False, default_factory=dict)  # noqa: N815
    """执行器额外数据"""


class ExecutorHistory(Base):
    """执行器历史"""

    __tablename__ = "framework_executor_history"

    taskId: Mapped[uuid.UUID] = mapped_column(UUID(as_uuid=True), nullable=False)  # noqa: N815
    """任务ID"""
    stepId: Mapped[uuid.UUID] = mapped_column(UUID(as_uuid=True), nullable=False)  # noqa: N815
    """步骤ID"""
    stepName: Mapped[str] = mapped_column(String(255), nullable=False)  # noqa: N815
    """步骤名称"""
    stepType: Mapped[str] = mapped_column(String(255), nullable=False)  # noqa: N815
    """步骤类型"""
    stepStatus: Mapped[StepStatus] = mapped_column(Enum(StepStatus), nullable=False)  # noqa: N815
    """步骤状态"""
    id: Mapped[uuid.UUID] = mapped_column(UUID(as_uuid=True), primary_key=True, default_factory=uuid.uuid4)
    """执行器历史ID"""
    inputData: Mapped[dict[str, Any]] = mapped_column(JSONB, nullable=False, default_factory=dict)  # noqa: N815
    """步骤输入数据"""
    outputData: Mapped[dict[str, Any]] = mapped_column(JSONB, nullable=False, default_factory=dict)  # noqa: N815
    """步骤输出数据"""
    extraData: Mapped[dict[str, Any]] = mapped_column(JSONB, nullable=False, default_factory=dict)  # noqa: N815
    """步骤额外数据"""
    createdAt: Mapped[datetime] = mapped_column(  # noqa: N815
        DateTime(timezone=True), nullable=False, default_factory=lambda: datetime.now(UTC),
    )
    """创建时间"""