"""Employee management routes"""
from fastapi import APIRouter, Depends, HTTPException
from sqlalchemy.orm import Session
from sqlalchemy.exc import IntegrityError
from ..database import get_db
from ..crud import employees as employees_crud
from ..models.employee import EmployeeCreate
from ..utils.loggers import auth_logger

router = APIRouter()

@router.get("/")
async def get_employees(db: Session = Depends(get_db)):
    """Get all employees"""
    try:
        employees_list = db.query(employees_crud.Employee).all()
        return [
            {
                "id": emp.id,
                "firstName": emp.first_name,
                "lastName": emp.last_name,
                "department": emp.department,
                "office": emp.office,
                "createdAt": emp.created_at
            }
            for emp in employees_list
        ]
    except Exception as e:
        auth_logger.error(f"Error fetching employees: {e}", exc_info=True)
        raise HTTPException(status_code=500, detail="Ошибка при получении списка сотрудников")

@router.post("/")
async def create_employee(employee: EmployeeCreate, db: Session = Depends(get_db)):
    """Create new employee"""
    try:
        # Check if employee already exists
        existing = employees_crud.get_employee_by_lastname(db, employee.last_name)
        if existing:
            raise HTTPException(
                status_code=400,
                detail="Сотрудник с такой фамилией уже существует"
            )

        db_employee = employees_crud.create_employee(db, employee)
        auth_logger.info(
            "Employee created",
            extra={"employee_id": db_employee.id}
        )
        
        return {
            "id": db_employee.id,
            "firstName": db_employee.first_name,
            "lastName": db_employee.last_name,
            "department": db_employee.department,
            "office": db_employee.office,
            "createdAt": db_employee.created_at
        }
        
    except HTTPException:
        raise
    except IntegrityError:
        raise HTTPException(
            status_code=400,
            detail="Сотрудник с такими данными уже существует"
        )
    except Exception as e:
        auth_logger.error(f"Error creating employee: {e}", exc_info=True)
        raise HTTPException(status_code=500, detail="Ошибка при создании сотрудника")