fix

.gitignore

@@ -1,5 +1,6 @@
 .env__pycache__/
 .env
+__pycache__
 log/
 alembic/versions/
 static/media/
@@ -14,3 +15,5 @@ venv/
 .ruff_cache/00
 .pytest_cache/
 note.txt
+
+process _data/

app/dialogflow/api/v1/dialogflow.py

@@ -275,12 +275,12 @@ async def booking_trip(request: Request) -> Response:
 
     origin_code, origin_id, origin_ids, dest_code, dest_id, dest_ids = None, None, None, None, None, None
     if origin_office:
-        origin_code, origin_id = await dialog_service.find_id_and_code_provine_by_name_office(origin_office)
+        origin_id, origin_code = await dialog_service.find_id_and_code_provine_by_name_office(origin_office)
         origin_ids = await dialog_service.find_id_office_by_name_office(origin_office)
     elif raw_departure_city:
         origin_code = origin_codes.get(raw_departure_city)
     if dest_office:
-        dest_code, dest_id = await dialog_service.find_id_and_code_provine_by_name_office(dest_office)
+        dest_id, dest_code  = await dialog_service.find_id_and_code_provine_by_name_office(dest_office)
         dest_ids = await dialog_service.find_id_office_by_name_office(dest_office)
     elif raw_destination_city:
         dest_code = origin_codes.get(raw_destination_city)

app/dialogflow/services/dialog_service.py

@@ -213,6 +213,13 @@ class DialogService:
                                 return group["provinceId"]
         return None
 
+    async def find_all_origin_by_name_office(self, office_name: str):
+        data = await self.search_pickup_points(origin=office_name)
+        if data.get("origin"):
+            origins = data["origin"]
+            return origins
+        return None
+
     async def find_id_and_code_provine_by_name_office(self, office_name: str):
         data = await self.search_pickup_points(origin=office_name)
         if data.get("origin"):