from typing import List, Optional

from fastapi import APIRouter, Depends, Query
from sqlmodel import Session

from apis.base import standard_response, StandardResponse, PageResponse, standard_error_response
from db.database import get_db
from entity.device import Device, DeviceCreate, DeviceUpdate, DeviceInfo
from services.device_service import DeviceService

router = APIRouter()


@router.get("/list", response_model=StandardResponse[List[DeviceInfo]])
def get_device_list(
        name: Optional[str] = None,
        code: Optional[str] = None,
        device_type: Optional[str] = None,
        db: Session = Depends(get_db)):
    service = DeviceService(db)
    devices = list(service.get_device_list(name, code, device_type))
    return standard_response(data=devices)


@router.get("/page/", response_model=StandardResponse[PageResponse[Device]])
def get_device_page(
        name: Optional[str] = None,
        code: Optional[str] = None,
        device_type: Optional[str] = None,
        offset: int = Query(0, ge=0),  # 从第几条开始
        limit: int = Query(10, ge=1),  # 每页显示多少条记录
        db: Session = Depends(get_db)):
    service = DeviceService(db)

    # 获取分页后的设备列表和总数
    devices, total = service.get_device_page(name, code, device_type, offset, limit)

    return standard_response(
        data=PageResponse(total=total, items=devices)
    )


@router.post("/add", response_model=StandardResponse[DeviceInfo])
def create_device(device_data: DeviceCreate, db: Session = Depends(get_db)):
    service = DeviceService(db)
    device = service.create_device(device_data)
    return standard_response(data=device)


@router.post("/update", response_model=StandardResponse[DeviceInfo])
def update_device(device_data: DeviceUpdate, db: Session = Depends(get_db)):
    service = DeviceService(db)
    device = service.update_device(device_data)
    if not device:
        return standard_error_response(data=device_data, message="Device not found")
    return standard_response(data=device)


@router.delete("/delete", response_model=StandardResponse[int])
def delete_device(device_id: int, db: Session = Depends(get_db)):
    service = DeviceService(db)
    device = service.delete_device(device_id)
    if not device:
        return standard_error_response(data=device_id, message="Device not found")
    return standard_response(data=device_id)