License/backend/app/routers/domains.py

from fastapi import APIRouter, Depends, HTTPException, Query
from pydantic import BaseModel
from sqlalchemy import select, func
from sqlalchemy.ext.asyncio import AsyncSession
from app.database import get_db
from app.models.domain import MonitoredDomain
from app.models.monitoring import SuperAdmin
from app.schemas.domain import (
    MonitoredDomainCreate,
    MonitoredDomainResponse,
)
from app.services.domain_fetch import fetch_domain_transactions

router = APIRouter(prefix="/api/domains", tags=["domains"])


@router.post("/", response_model=MonitoredDomainResponse, status_code=201)
async def add_domain(
    payload: MonitoredDomainCreate,
    db: AsyncSession = Depends(get_db),
):
    """添加需要监控的域名，同时创建对应的超管记录"""
    existing = await db.execute(
        select(MonitoredDomain).where(MonitoredDomain.domain == payload.domain)
    )
    if existing.scalar_one_or_none():
        raise HTTPException(status_code=409, detail="域名已在监控中")

    # 如果未指定超管，自动创建一条超管记录
    sa_id = payload.super_admin_id
    if sa_id is None:
        max_id_result = await db.execute(select(func.max(SuperAdmin.id)))
        max_id = max_id_result.scalar() or 0
        new_sa = SuperAdmin(
            id=max_id + 1,
            username=payload.domain,
            nickname=payload.domain,
            remark=payload.remark or None,
        )
        db.add(new_sa)
        await db.flush()
        sa_id = new_sa.id

    record = MonitoredDomain(domain=payload.domain, remark=payload.remark or None, super_admin_id=sa_id)
    db.add(record)
    await db.commit()
    await db.refresh(record)
    return record


@router.get("/", response_model=list[MonitoredDomainResponse])
async def list_domains(db: AsyncSession = Depends(get_db)):
    """获取所有已监控的域名列表"""
    result = await db.execute(select(MonitoredDomain))
    return result.scalars().all()


class MonitoredDomainUpdate(BaseModel):
    """更新域名备注"""
    remark: str = ""


@router.patch("/{domain_id}", response_model=MonitoredDomainResponse)
async def update_domain_remark(
    domain_id: int,
    payload: MonitoredDomainUpdate,
    db: AsyncSession = Depends(get_db),
):
    """更新域名备注，并同步到关联的超管"""
    result = await db.execute(
        select(MonitoredDomain).where(MonitoredDomain.id == domain_id)
    )
    record = result.scalar_one_or_none()
    if not record:
        raise HTTPException(status_code=404, detail="域名不存在")
    record.remark = payload.remark or None
    # 同步到关联的超管
    if record.super_admin_id:
        sa_result = await db.execute(
            select(SuperAdmin).where(SuperAdmin.id == record.super_admin_id)
        )
        sa = sa_result.scalar_one_or_none()
        if sa:
            sa.remark = payload.remark or None
    await db.commit()
    await db.refresh(record)
    return record


@router.delete("/{domain_id}", status_code=204)
async def remove_domain(domain_id: int, db: AsyncSession = Depends(get_db)):
    """移除指定 ID 的监控域名"""
    result = await db.execute(
        select(MonitoredDomain).where(MonitoredDomain.id == domain_id)
    )
    record = result.scalar_one_or_none()
    if not record:
        raise HTTPException(status_code=404, detail="域名不存在")
    await db.delete(record)
    await db.commit()


@router.get("/{domain_id}/transactions")
async def get_domain_transactions(
    domain_id: int,
    fetch_date: str | None = Query(None, description="爬取指定日期，格式 YYYY-MM-DD，不传则查全部"),
    db: AsyncSession = Depends(get_db),
):
    """爬取指定域名的监控数据并入库"""
    result = await db.execute(
        select(MonitoredDomain).where(MonitoredDomain.id == domain_id)
    )
    record = result.scalar_one_or_none()
    if not record:
        raise HTTPException(status_code=404, detail="域名不存在")

    data = await fetch_domain_transactions(record.domain, db, fetch_date=fetch_date)
    return {"status": "ok", "domain": record.domain, "data": data}


@router.post("/fetch-all", status_code=202)
async def fetch_all_transactions(
    fetch_date: str | None = Query(None, description="爬取指定日期，格式 YYYY-MM-DD，不传则查全部"),
    db: AsyncSession = Depends(get_db),
):
    """批量爬取所有已启用域名的监控数据"""
    result = await db.execute(
        select(MonitoredDomain).where(MonitoredDomain.is_active == True)
    )
    domains = result.scalars().all()
    errors = []
    for d in domains:
        try:
            await fetch_domain_transactions(d.domain, db, fetch_date=fetch_date)
        except Exception as e:
            errors.append({"domain": d.domain, "error": str(e)})
    return {"status": "ok", "total": len(domains), "errors": errors}