radionica3d/backend/routers/warehouse.py

from fastapi import APIRouter, Depends, HTTPException, Query
from typing import List, Optional
import db
import schemas
from dependencies import require_admin
import services.event_hooks as event_hooks

router = APIRouter(prefix="/admin/warehouse", tags=["warehouse"])

@router.get("/stock", response_model=dict)
async def get_warehouse_stock(
    page: int = Query(1, ge=1),
    size: int = Query(50, ge=1, le=100),
    material_id: Optional[int] = None,
    admin: dict = Depends(require_admin)
):
    offset = (page - 1) * size
    
    query = """
        SELECT w.*, m.name_en as material_name_en 
        FROM warehouse_stock w
        JOIN materials m ON w.material_id = m.id
    """
    params = []
    
    if material_id:
        query += " WHERE w.material_id = %s"
        params.append(material_id)
        
    query += " ORDER BY w.created_at DESC LIMIT %s OFFSET %s"
    params.extend([size, offset])
    
    stock = db.execute_query(query, tuple(params))
    
    count_query = "SELECT COUNT(*) as total FROM warehouse_stock"
    if material_id:
        count_query += " WHERE material_id = %s"
        total_res = db.execute_query(count_query, (material_id,))
    else:
        total_res = db.execute_query(count_query)
        
    return {
        "stock": stock,
        "total": total_res[0]['total'] if total_res else 0,
        "page": page,
        "size": size
    }

@router.post("/stock", response_model=dict)
async def add_stock_item(
    data: schemas.WarehouseItemCreate,
    admin: dict = Depends(require_admin)
):
    query = """
        INSERT INTO warehouse_stock (material_id, color_name, quantity, notes, is_active)
        VALUES (%s, %s, %s, %s, %s)
    """
    params = (data.material_id, data.color_name, data.quantity, data.notes, data.is_active)
    
    item_id = db.execute_commit(query, params)
    
    if not item_id:
        raise HTTPException(status_code=500, detail="Failed to add stock item")
        
    return {"id": item_id, "message": "Stock item added successfully"}

@router.patch("/stock/{item_id}", response_model=dict)
async def update_stock_item(
    item_id: int,
    data: schemas.WarehouseItemUpdate,
    admin: dict = Depends(require_admin)
):
    update_fields = []
    params = []
    
    if data.quantity is not None:
        update_fields.append("quantity = %s")
        params.append(data.quantity)
    
    if data.notes is not None:
        update_fields.append("notes = %s")
        params.append(data.notes)
        
    if data.is_active is not None:
        update_fields.append("is_active = %s")
        params.append(data.is_active)
        
    if not update_fields:
        raise HTTPException(status_code=400, detail="No fields to update")
        
    query = f"UPDATE warehouse_stock SET {', '.join(update_fields)} WHERE id = %s"
    params.append(item_id)
    
    db.execute_commit(query, tuple(params))
    
    return {"message": "Stock item updated successfully"}

@router.delete("/stock/{item_id}", response_model=dict)
async def delete_stock_item(
    item_id: int,
    admin: dict = Depends(require_admin)
):
    query = "DELETE FROM warehouse_stock WHERE id = %s"
    db.execute_commit(query, (item_id,))
    return {"message": "Stock item deleted successfully"}