feat: add api select trip and time trip

app/api/routes.py

@@ -1,3 +1,4 @@
+from typing import Dict, List
 from fastapi import FastAPI, APIRouter, HTTPException, Request, Response # type: ignore
 from fastapi.responses import JSONResponse, RedirectResponse, HTMLResponse # type: ignore
 from datetime import datetime, timedelta
@@ -188,6 +189,8 @@ async def price(request: Request):
         return DialogFlowResponseAPI(text=text, payload=payload)
     except:
         return DialogFlowResponseAPI(text=["Hệ thống xảy ra lỗi. Quý khách vui lòng thử lại sau hoặc liên hệ Trung tâm tổng đài 1900 6067 để được hỗ trợ."])
+
+
 @router.post('/trip/list')
 async def booking_trip(request: Request) -> Response:
     body = await request.json()
@@ -218,25 +221,35 @@ async def booking_trip(request: Request) -> Response:
             if total > 0:
                 list_raw_departure_times = sorted(list(set([ trip["raw_departure_time"] for trip in data])))
                 schedule_time_trip = "**" + "** | **".join(map(str, list_raw_departure_times)) + "**"
+                trips = []
                 routes_name = []
                 for trip in data:
                     if trip["route"] and trip["route"]["name"] not in routes_name:
                         routes_name.append(trip["route"]["name"])
-                text = [" | ".join(map(str, routes_name))]
+                    trips.append({
+                            "route_name": trip["route"]["name"],
+                            "route_id": trip["route_id"],
+                            "id": trip["id"],
+                            "departure_date": trip["raw_departure_date"],
+                            "departure_time": trip["raw_departure_time"],
+                            "kind": trip["seat_type_name"]
+                            })
+                text = ["\n".join(f"{i+1}. {name}" for i, name in enumerate(routes_name))]
                 payload={
                                 "richContent": [
                                     [
                                         {
                                             "type": "chips",
                                             "options": [ 
-                                                {"text": name} for name in routes_name
+                                                {"text": name} for name in (routes_name)
                                             ]
                                         }
                                     ]
                                 ]
                             }
                 parameters = {
-                    "trip_list": routes_name
+                    "trip_list": trips,
+                    "routes_name": routes_name
                 }
                 return DialogFlowResponseAPI(text=text, payload=payload,parameters=parameters)                
             
@@ -271,6 +284,58 @@ async def booking_trip(request: Request) -> Response:
                     },
                 }
         )
+
+@router.post('trip/check-trip-select')
+async def is_valid_select_trip(request: Request) -> Response:
+    body = await request.json()
+    raw_input = body.get("text", "")
+    print('raw input:', raw_input)
+    session_info = body.get("sessionInfo", {})
+    parameters = session_info.get("parameters")
+    routes_name = parameters.get("routes_name")
+    if raw_input in routes_name:
+        trip_list: List[Dict[str, any]] = parameters.get("trip_list")
+        for trip in trip_list:
+            if trip["route_name"] == raw_input:
+                route_id = trip["route_id"]
+                break
+
+        parameters = {
+                "is_valid_trip": True,
+                "route_name": raw_input,
+                "route_id": route_id | None
+            }
+    else:
+        parameters = {
+                "is_valid_trip": False,
+            }
+    return DialogFlowResponseAPI(parameters=parameters)
+
+@router.post('trip/time-trip-list')
+async def time_trip(request: Request) -> Response:
+    try:
+        body = await request.json()
+        session_info = body.get("sessionInfo", {})
+        parameters = session_info.get("parameters")
+        trip_list: List[Dict[str, any]] = parameters.get("trip_list", [])
+        raw_route_id = parameters.get("route_id", None)
+        route_id = int(raw_route_id) if raw_route_id else None
+        time_list = []
+        for trip in trip_list:
+            if trip["route_id"] == route_id:
+                time_list.append(trip["departure_time"])
+        parameters = {
+            "time_list": time_list
+        }
+        text = [" | ".join(map(str, time_list))]
+        return DialogFlowResponseAPI(text=text)
+    except Exception as e:
+        print(e)
+        return DialogFlowResponseAPI(text=["Hệ thống xảy ra lỗi. Quý khách vui lòng thử lại sau hoặc liên hệ Trung tâm tổng đài 1900 6067 để được hỗ trợ."])
+    
+    return DialogFlowResponseAPI(parameters=parameters)
+
+
 @router.get("/")
 def home():
     return "Hello World!"