Upload 4 files

orders/models.py

@@ -0,0 +1,25 @@
+# models.py
+from sqlalchemy import Column, ForeignKey, Integer, String, Float, JSON, ARRAY
+from sqlalchemy.orm import relationship
+from core.database import Base
+
+class Meal(Base):
+    __tablename__ = "meals"
+
+    id = Column(Integer, primary_key=True, index=True)
+    name = Column(String, index=True)
+    description = Column(String)
+    price = Column(Float)
+
+    orders = relationship("Order", back_populates="meal")
+
+class Order(Base):
+    __tablename__ = "orders"
+
+    id = Column(Integer, primary_key=True, index=True)
+    user_id = Column(Integer, ForeignKey("users.id"))
+    meal_id = Column(Integer, ForeignKey("meals.id"))
+    quantity = Column(Integer)
+
+    user = relationship("User", back_populates="orders")
+    meal = relationship("Meal", back_populates="orders")

orders/routes.py

@@ -0,0 +1,61 @@
+from fastapi import APIRouter, status, Depends, HTTPException
+from typing import List, Optional
+from core.database import get_db
+from core.security import get_current_user
+from orders.services import create_meal, get_meals, get_meal, update_meal, delete_meal, create_user_order, get_user_orders
+from orders.schemas import OrderCreate, OrderBase, Order, MealBase, MealCreate, MealUpdate, Meal
+from sqlalchemy.orm import Session
+from services.recommendation_service import MealRecommender
+
+
+order_router = APIRouter(
+    prefix="/orders",
+    tags=["Orders"],
+    responses={404: {"description": "Not found"}, 401: {"description": "Unauthorized"}}
+)
+
+meal_router = APIRouter(
+    prefix="/meals",
+    tags=["Meals"],
+    responses={404: {"description": "Not found"}, 401: {"description": "Unauthorized"}}
+)
+
+
+@meal_router.get("/health", tags=["Health"])
+def health_check():
+    return {"status": "ok"}
+
+@meal_router.get("/", response_model=MealBase)
+async def meal_create(data: MealCreate, db: Session = Depends(get_db)):
+    return create_meal(db, data)
+
+@meal_router.get("/", response_model=List[MealBase])
+def meals_get(skip: int = 0, limit: int = 100, db: Session = Depends(get_db)):
+    return get_meals(db, skip=skip, limit=limit)
+
+@meal_router.get("/{meal_id}", response_model=MealBase)
+def meal_get(meal_id: int, db: Session = Depends(get_db)):
+    return get_meal(db, meal_id)
+
+@meal_router.put("/{meal_id}", response_model=MealBase)
+def meal_update(meal_id: int, data: MealUpdate, db: Session = Depends(get_db)):
+    return update_meal(db, meal_id, data)
+
+@meal_router.delete("/{meal_id}", response_model=MealBase)
+def meal_delete(meal_id: int, db: Session = Depends(get_db)):
+    return delete_meal(db, meal_id)
+
+@order_router.post("/", response_model=OrderBase)
+def create_order(order: OrderCreate, current_user: OrderBase = Depends(get_current_user), db: Session = Depends(get_db)):
+    return create_user_order(db, order, current_user.id)
+
+@order_router.get("/", response_model=List[OrderBase])
+def read_user_orders(skip: int = 0, limit: int = 100, current_user: OrderBase = Depends(get_current_user), db: Session = Depends(get_db)):
+    return get_user_orders(db, user_id=current_user.id, skip=skip, limit=limit)
+
+@meal_router.get("/recommendations/", response_model=List[MealBase])
+async def get_recommendations(current_user: OrderBase = Depends(get_current_user), db: Session = Depends(get_db)):
+    recommender = MealRecommender()
+    recommendations = recommender.get_recommendations(current_user)
+    return recommendations
+

orders/schemas.py

@@ -0,0 +1,33 @@
+from pydantic import BaseModel
+
+
+class MealBase(BaseModel):
+    name: str
+    description: str
+    price: float
+
+class MealCreate(MealBase):
+    pass
+
+class MealUpdate(MealBase):
+    pass
+
+class Meal(MealBase):
+    id: int
+
+    class Config:
+        orm_mode = True
+
+class OrderBase(BaseModel):
+    quantity: int
+
+class OrderCreate(OrderBase):
+    meal_id: int
+
+class Order(OrderBase):
+    id: int
+    user_id = int
+    meal_id = int
+
+    class Config:
+        orm_mode = True

orders/services.py

@@ -0,0 +1,44 @@
+from sqlalchemy.orm import Session
+from typing import List
+from orders.schemas import MealCreate, MealUpdate, OrderCreate
+from orders.models import Meal, Order
+
+def get_meals(db: Session, skip: int = 0, limit: int = 100):
+    return db.query(Meal).offset(skip).limit(limit).all()
+
+def create_meal(db: Session, meal: MealCreate):
+    db_meal = Meal(**meal.dict())
+    db.add(db_meal)
+    db.commit()
+    db.refresh(db_meal)
+    return db_meal
+
+def get_meal(db: Session, meal_id: int):
+    return db.query(Meal).filter(Meal.id == meal_id).first()
+
+def update_meal(db: Session, meal_id: int, meal: MealUpdate):
+    db_meal = db.query(Meal).filter(Meal.id == meal_id).first()
+    if db_meal:
+        update_data = meal.dict(exclude_unset=True)
+        for key, value in update_data.items():
+            setattr(db_meal, key, value)
+        db.commit()
+        db.refresh(db_meal)
+    return db_meal
+
+def delete_meal(db: Session, meal_id: int):
+    db_meal = db.query(Meal).filter(Meal.id == meal_id).first()
+    if db_meal:
+        db.delete(db_meal)
+        db.commit()
+    return db_meal
+
+def create_user_order(db: Session, order: OrderCreate, user_id: int):
+    db_order = Order(**order.dict(), user_id=user_id)
+    db.add(db_order)
+    db.commit()
+    db.refresh(db_order)
+    return db_order
+
+def get_user_orders(db: Session, user_id: int, skip: int = 0, limit: int = 100):
+    return db.query(Order).filter(Order.user_id == user_id).offset(skip).limit(limit).all()