Upload 16 files

main.py

@@ -6,6 +6,7 @@ import os
 import requests 
 from fastapi.security import OAuth2PasswordRequestForm
 from schemas import SortOption
+from fastapi.responses import JSONResponse
 
 # Import modules
 from schemas import (
@@ -18,7 +19,7 @@ from modules.retrieval import retrieve_context, get_destinations_paginated, get_
 from modules.generation import build_rag_prompt, call_llm_api, parse_llm_response
 from modules.weather import get_current_weather
 from core.config import settings
-
+from typing import List, Optional
 import favorites
 
 # Khởi tạo Vectorizer
@@ -48,6 +49,14 @@ app.add_middleware(
     allow_headers=["*"],
 )
 
+@app.exception_handler(Exception)
+async def global_exception_handler(request: Request, exc: Exception):
+    print(f"🔥 LỖI NGHIÊM TRỌNG (500) TẠI {request.url}: {exc}")
+    return JSONResponse(
+        status_code=500,
+        content={"message": "Internal Server Error", "detail": str(exc)},
+    )
+
 @app.get("/", tags=["Health"])
 def root():
     """Health check endpoint"""
@@ -93,12 +102,27 @@ app.include_router(favorites.router, prefix="/favorites", tags=["User Favorites"
 # ==========================================
 @app.get("/destinations", response_model=PaginatedResponse)
 async def list_destinations(
-    filters: HardConstraints = Depends(),
-    sort_by: SortOption = Query(SortOption.RATING_DESC, description="Sắp xếp theo: Tên (A-Z) hoặc Rating"),
+    
+    budget_range: Optional[List[str]] = Query(None, description="Lọc theo ngân sách"),
+    available_time: Optional[List[str]] = Query(None, description="Lọc theo thời gian"),
+    companion_tag: Optional[List[str]] = Query(None, description="Lọc theo người đi cùng"),
+    season_tag: Optional[List[str]] = Query(None, description="Lọc theo mùa"),
+    location_province: Optional[str] = Query(None, description="Lọc theo tỉnh"),
+    # -----------------------
+    
+    sort_by: SortOption = Query(SortOption.RATING_DESC),
     page: int = Query(1, ge=1),
     limit: int = Query(10, ge=1, le=50)
 ):
-    """Hiển thị danh sách địa điểm theo trang và bộ lọc cơ bản (Không dùng AI)"""
+    # Bước 2: Gom lại thành object HardConstraints để truyền cho hàm xử lý
+    filters = HardConstraints(
+        budget_range=budget_range,
+        available_time=available_time,
+        companion_tag=companion_tag,
+        season_tag=season_tag,
+        location_province=location_province
+    )
+
     return get_destinations_paginated(filters, sort_by, page, limit)
 
 # ==========================================

modules/retrieval.py

@@ -77,10 +77,36 @@ def get_destinations_paginated(filters: HardConstraints, sort_option: SortOption
                        .limit(limit)
     
     results = []
-    for doc in cursor:
-        doc["id"] = str(doc.get("landmark_id", "")) 
-        results.append(doc)
-        
+    print(f"--- Đang xử lý trang {page} ---")
+    
+    for index, doc in enumerate(cursor):
+        try:
+            # 1. FIX LỖI OBJECT ID (Quan trọng nhất)
+            if "_id" in doc:
+                doc["_id"] = str(doc["_id"]) # Chuyển ObjectId thành string ngay lập tức
+            
+            # 2. Xử lý ID
+            # Ưu tiên landmark_id, nếu không có thì lấy _id đã string hóa
+            doc["id"] = str(doc.get("landmark_id", doc.get("_id", "")))
+
+            # 3. Xử lý Rating (Chống null)
+            if doc.get("overall_rating") is None:
+                doc["overall_rating"] = 0.0
+            
+            # 4. Xử lý Image (Chống null)
+            if doc.get("image_urls") is None:
+                doc["image_urls"] = []
+
+            results.append(doc)
+            
+        except Exception as e:
+            # IN LỖI RA TERMINAL ĐỂ BẠN THẤY
+            print(f"❌ LỖI DATA TẠI ITEM #{index} (Landmark ID: {doc.get('landmark_id')}):")
+            print(f"   Lý do: {e}")
+            # continue giúp bỏ qua item lỗi này, không làm sập cả trang
+            continue 
+    # --- KẾT THÚC ĐOẠN CODE SỬA ---
+
     return {
         "data": results,
         "total": total_docs,

schemas.py

@@ -17,13 +17,31 @@ class WeatherInfo(BaseModel):
     icon: str = Field(..., description="Mã icon của OpenWeather")
 
 class HardConstraints(BaseModel):
-    # Dùng cho cả filter danh sách và AI
-    budget_range: Optional[List[str]] = Field(default=None, description="Ngân sách (multi-select)")
-    available_time: Optional[List[str]] = Field(default=None, description="Thời gian rảnh")
-    companion_tag: Optional[List[str]] = Field(default=None, description="Bạn đồng hành")
-    season_tag: Optional[List[str]] = Field(default=None, description="Mùa")
-    location_province: Optional[str] = Field(default=None, description="Lọc theo tỉnh thành")
-
+    budget_range: Optional[List[str]] = Query(
+        default=None, 
+        description="Ngân sách (multi-select), VD: ?budget_range=thấp&budget_range=cao"
+    )
+    
+    available_time: Optional[List[str]] = Query(
+        default=None, 
+        description="Thời gian rảnh"
+    )
+    
+    companion_tag: Optional[List[str]] = Query(
+        default=None, 
+        description="Bạn đồng hành"
+    )
+    
+    season_tag: Optional[List[str]] = Query(
+        default=None, 
+        description="Mùa"
+    )
+    
+    location_province: Optional[str] = Query(
+        default=None, 
+        description="Lọc theo tỉnh thành"
+    )
+    
 # --- 2. PAGINATION & LIST VIEW SCHEMAS ---
 class DestinationSummary(BaseModel):
     # Khớp với logic: Backend sẽ gán landmark_id vào field này