Initial commit

.env

@@ -0,0 +1 @@
+API_BASE_URL=https://api-dev.futabus.vn

Dockerfile

@@ -0,0 +1,11 @@
+FROM python:3.9
+
+ENV API_BASE_URL https://api-dev.futabus.vn
+
+COPY . .
+
+WORKDIR /
+
+RUN pip install --no-cache-dir --upgrade -r /requirements.txt
+
+CMD ["uvicorn", "app:app", "--host", "0.0.0.0", "--port", "7860"]

app/api/routes.py

@@ -0,0 +1,264 @@
+from fastapi import FastAPI, APIRouter, HTTPException, Request, Response # type: ignore
+from fastapi.responses import JSONResponse, RedirectResponse, HTMLResponse # type: ignore
+from datetime import datetime, timedelta
+from fastapi.templating import Jinja2Templates
+
+
+from app.services import api
+from app.utils.constants import code_province
+from app.types.Respone import DialogFlowResponseAPI
+router = APIRouter()
+
+templates = Jinja2Templates(directory="app/templates")
+
+def to_datetime_from_Dialogflow(time: dict):
+    date_time = datetime(int(time["year"]), int(time["month"]), int(time["day"]))
+    return date_time
+
+# Xử lý fromTime và toTime
+def process_dates_to_timestamp(from_time: datetime = None, to_time: datetime = None):
+    print(from_time)
+    if to_time is None and from_time is not None:
+        to_time = from_time.replace(hour=23, minute=59, second=59)
+    
+    if from_time is None:
+        today = datetime.today().date()
+        from_time = datetime.combine(today, datetime.min.time())
+        to_time = datetime.combine(today, datetime.max.time()) - timedelta(microseconds=1)
+
+    return int(from_time.timestamp()) * 1000 , int(to_time.timestamp()) * 1000
+def get_param_from_dialogflow(body: any):
+    session_info = body.get("sessionInfo", {})
+    parameters = session_info.get("parameters")
+    raw_date = parameters.get("date")
+    if raw_date is not None:
+        raw_date = to_datetime_from_Dialogflow(raw_date)
+    raw_departure_city = parameters.get("departure_city")
+    raw_destination_city = parameters.get("destination_city")
+    raw_ticket_number = parameters.get("ticket_number")
+    raw_time_of_day = parameters.get("time_of_day")
+    return raw_departure_city, raw_destination_city, raw_ticket_number, raw_date, raw_time_of_day
+
+async def search_route_ids_from_province(departure_code: str, destination_code: str):
+    response = await api.get(f'/metadata/office/routes?DestCode={destination_code}&OriginCode={departure_code}')
+    route_ids = []
+    if isinstance(response, list):  # Kiểm tra nếu data là danh sách
+            route_ids = [route.get("routeId", -1) for route in response]
+
+    return route_ids
+
+@router.post('/routes')
+async def route(request: Request):
+    body = await request.json()
+    raw_departure_city, raw_destination_city, raw_ticket_number , raw_date, _ = get_param_from_dialogflow(body)
+    
+    
+    ticket_count = int(raw_ticket_number) if raw_ticket_number else 1
+
+    if raw_date is None:
+        from_time, to_time = process_dates_to_timestamp()
+        date = datetime.today().date().strftime('%m-%d-%Y')
+    else:
+        date = raw_date.strftime('%m-%d-%Y')
+        from_time, to_time = process_dates_to_timestamp(raw_date)
+    departure_code = code_province.get(raw_departure_city)
+    destination_code = code_province.get(raw_destination_city)
+    route_dep_to_des = await search_route_ids_from_province(departure_code,destination_code)
+    route_des_to_dep = await search_route_ids_from_province(destination_code,departure_code)
+    routes_ids = list(set(route_dep_to_des + route_des_to_dep))
+    payload = {
+        "from_time": from_time,
+        "to_time": to_time,
+        "route_ids": routes_ids,
+        "ticket_count": 1,
+        "sort_by": ["price", "departure_time"]
+    }
+    try:
+        respone = await api.post("/search/trips", payload=payload)
+        data = respone["data"]["items"]
+        total = respone["data"]["total"]
+        if total > 0:
+            price = data[0]["price"]
+            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)) + "**"
+            link = f'https://stag.futabus.vn/dat-ve?from={departure_code}&fromTime={date}&isReturn=false&ticketCount={ticket_count}&to={destination_code}&toTime='
+            text = [f"Lộ trình **{raw_departure_city}** - **{raw_destination_city}**: **{total}** tuyến xe.\n \
+                                     Thời gian các tuyến xe khởi hành: {schedule_time_trip}\n \
+                                     Giá vé: **{price}** VND.\n \
+                                     Quý khách vui lòng truy cập vào [**tại đây**]({link}) để xem chi tiết lịch trình."]
+            payload = {
+                                "richContent": [
+                                    [
+                                        {
+                                            "type": "chips",
+                                            "options": [
+                                                {"text": "Đặt vé"},
+                                                {"text": "Xem lịch trình khác"},
+                                                {"text": "Không, cảm ơn"}
+                                            ]
+                                        }
+                                    ]
+                                ]
+                            }
+            
+            return DialogFlowResponseAPI(text=text, payload=payload)
+
+        text = [f"Hệ thống không tìm thấy tuyến xe nào phù hợp với lộ trình **{raw_departure_city}** - **{raw_destination_city}** của quý khách.\n Quý khách vui lòng thử lại với lộ trình khác hoặc liên hệ Trung tâm tổng đài 1900 6067 để được hỗ trợ."]
+        payload = {
+                                "richContent": [
+                                    [
+                                        {
+                                            "type": "chips",
+                                            "options": [
+                                                {"text": "Xem lịch trình khác"},
+                                                {"text": "Không, cảm ơn"}
+                                            ]
+                                        }
+                                    ]
+                                ]
+                            }
+        return DialogFlowResponseAPI(text=text, payload=payload)
+        # return DialogFlowResponeAPI(text=['Hello'])
+    except Exception as 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ợ."])
+
+
+@router.post('/price')
+async def price(request: Request):
+    body = await request.json()
+    raw_departure_city, raw_destination_city, _, raw_date, _ = get_param_from_dialogflow(body)
+    
+    if raw_date is None:
+        from_time, to_time = process_dates_to_timestamp()
+    from_time, to_time = process_dates_to_timestamp(raw_date)
+
+    departure_code = code_province.get(raw_departure_city)
+    destination_code = code_province.get(raw_destination_city)
+    route_dep_to_des = await search_route_ids_from_province(departure_code,destination_code)
+    route_des_to_dep = await search_route_ids_from_province(destination_code,departure_code)
+    routes_ids = list(set(route_dep_to_des + route_des_to_dep))
+    payload = {
+        "from_time": from_time,
+        "to_time": to_time,
+        "route_ids": routes_ids,
+        "ticket_count": 1,
+        "sort_by": ["price", "departure_time"]
+    }
+    try:
+        respone = await api.post("/search/trips", payload=payload)
+        total = respone["data"]["total"]
+        if total > 0:
+            price = respone["data"]["items"][0]["price"]
+            text = [f"Lộ trình **{raw_departure_city}** - **{raw_destination_city}**\n"
+                                     f"Giá vé: **{price}** VND.\nBạn có muốn đặt vé không?"
+                                     ]
+            payload = {
+                                "richContent": [
+                                    [
+                                        {
+                                            "type": "chips",
+                                            "options": [
+                                                {"text": "Có, tôi muốn đặt vé"},
+                                                {"text": "Xem giá vé lịch trình khác"},
+                                                {"text": "Không, cảm ơn"}
+                                            ]
+                                        }
+                                    ]
+                                ]
+                            }
+            return DialogFlowResponseAPI(text=text, payload=payload)
+        text = [f"Hệ thống không tìm thấy tuyến xe nào phù hợp với lộ trình **{raw_departure_city}** - **{raw_destination_city}** của quý khách.\n Quý khách vui lòng thử lại với lộ trình khác hoặc liên hệ Trung tâm tổng đài 1900 6067 để được hỗ trợ."]
+        payload={
+                                "richContent": [
+                                    [
+                                        {
+                                            "type": "chips",
+                                            "options": [
+                                                {"text": "Xem giá vé lịch trình khác"},
+                                                {"text": "Không, cảm ơn"}
+                                            ]
+                                        }
+                                    ]
+                                ]
+                            }
+        
+        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/booking')
+async def booking_trip(request: Request) -> Response:
+    body = await request.json()
+    raw_departure_city, raw_destination_city, raw_ticket_number, raw_date, raw_time_of_day = get_param_from_dialogflow(body)
+    
+    date = raw_date.strftime('%m-%d-%Y')
+    from_time, to_time = process_dates_to_timestamp(raw_date)
+    ticket_count = int(raw_ticket_number) if raw_ticket_number else 1
+
+    departure_code = code_province.get(raw_departure_city)
+    destination_code = code_province.get(raw_destination_city)
+
+    route_dep_to_des = await search_route_ids_from_province(departure_code,destination_code)
+    route_des_to_dep = await search_route_ids_from_province(destination_code,departure_code)
+    routes_ids = list(set(route_dep_to_des + route_des_to_dep))
+    payload = {
+        "from_time": from_time,
+        "to_time": to_time,
+        "route_ids": routes_ids,
+        "ticket_count": ticket_count,
+        "sort_by": ["price", "departure_time"]
+    }
+    try:
+        respone = await api.post("/search/trips", payload=payload)
+        if respone.get('status') == 200:
+            data = respone["data"]["items"]
+            total = respone["data"]["total"]
+            if total > 0:
+                price = respone["data"]["items"][0]["price"]
+                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)) + "**"
+                link = f'https://stag.futabus.vn/dat-ve?from={departure_code}&fromTime={date}&isReturn=false&ticketCount={ticket_count}&to={destination_code}&toTime='
+                
+                text= [f"Lộ trình **{raw_departure_city}** - **{raw_destination_city}**: **{total}** tuyến xe.\n"
+                                        f"Thời gian các tuyến xe khởi hành: {schedule_time_trip}\n"
+                                        f"Giá vé: **{price}** VND.\n"
+                                        f"Quý khách vui lòng truy cập vào [**tại đây**]({link}) để tiến hành đặt vé."]
+                return DialogFlowResponseAPI(text=text)                
+            
+        text = [f"Hệ thống không tìm thấy tuyến xe nào phù hợp với lộ trình **{raw_departure_city}** - **{raw_destination_city}** của quý khách.\n Quý khách vui lòng thử lại với lộ trình khác hoặc liên hệ Trung tâm tổng đài 1900 6067 để được hỗ trợ."]
+        payload={
+                                "richContent": [
+                                    [
+                                        {
+                                            "type": "chips",
+                                            "options": [
+                                                {"text": "Xem lịch trình khác"},
+                                                {"text": "Không, cảm ơn"}
+                                            ]
+                                        }
+                                    ]
+                                ]
+                            }
+                        
+        return DialogFlowResponseAPI(text=text, payload=payload)
+    except Exception as e:
+        print(e)
+        return JSONResponse(
+                    {
+                    "fulfillment_response": {
+                        "messages": [
+                        {
+                            "text": {
+                            "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.get("/")
+def home():
+    return "Hello World!"
+
+@router.get('/chatbot', response_class=HTMLResponse)
+async def index(request: Request):
+    return templates.TemplateResponse("index.html", {"request": request, "title": "Dawi Chatbot"})

app/busbooking-451909-aa92e337868d.json

@@ -0,0 +1,13 @@
+{
+  "type": "service_account",
+  "project_id": "busbooking-451909",
+  "private_key_id": "aa92e337868d77340f1e1bc3d0119738f48b8a49",
+  "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQDwozPFZx+v2DH+\nXFMLaft+4tnaWKPDGEgQ0IGwmXUtgVzd7iuH/fI9tXFiRw1ecFGAzundf1qiJJis\npMgfMxXm5fWpaKa4AM5LKxootKYPLZeJ3/N+BhJkCSmDXZmk6TuBff3WBRUkDj9n\nQTnpRSCBsCxArvm2zw6PSUqHwPiW/g05q6escmHXZUO3wpLgFz41u1Xy7M2Rc/bO\n3j6OYogYxZkp5aY5EpWhUKO2+qNVaVQqDweJhQ7/M+UpX5Va9VdMAM7dm3BUIy1Y\n3c8NDgUvL5uXKljoHrPpGXm+1QZTnrT18y3Jmo5PxkIF0u/SXDnFTYl9CL876ewq\nYaN55d9fAgMBAAECggEAArpm8Nr9cfnqfy6+xkdaUZLy01Xj7WdOEdq7Taw/ttdb\nnSyBE9aeM3LmKS4TCboOQn6WCivSdDoj/PkVR71Fh0ueIGCOW1GvBQ0lC8cYht2G\ndUqzsP8SoE22ScX64vK9+PbbtNxz4+fBckM8C9f7yVyc89LIA/mO+bLkBGv8pYGQ\nNg2Po8Oi8wjA06XMEaFVfrURnyQoUVVeIXBn/L0TViL/vSo0wshYQw9hoXI6RrUW\n1SDjfRmzOIt63R7x4Bn/BZYvgjtRewAL325ooZVXqrzXHZ9yinC/7BIrxQCF9Ncr\nuKok9SDhNES2OUUbO8QlwW4EVvTkiCb59r26jqU26QKBgQD6K2AyZ1u2XRI9HpW3\nsAeshUDcG/Gj0cnWQlpe6hr+UOrMt7LIgOhuQeR1/5EZ/ZLG8FYKE096ffP/2ND8\nG+JzTTj5Fiv9ZzUdKWPQGE5D6TwJmVAO6R8ZaodykkIgg7Thn17og4EbeSAqNtey\nh2LSLnYrT9imjfR78n+vPYCwfQKBgQD2PvRknpN+zMYnMUA/pho0/c7G8kbORiWp\nDpHabHDbtdKSgWC3enQ3bVPSeGiZNvrjSar+1/8H2C3WovhgYTp4o7+IdM2cKWOZ\nJsQNbgoXYgeaylIiwZGRQN0x1q4ho2w3UGxu3spupyFFo8yNRay8JkCI6OMX+ZWd\nG2QXQEOSCwKBgQCrZa55uhC+x9NoJp1DBYqsa3t9knOi3mffsQRDhTdLSFsmOTF3\nZ8JXUDPbmGZsnSvDuwPn0UUh0kuq3XyJTf1/K8g9+C/ZZK2iNipZd12f75sfpHeS\nT6vr+O2l1IkTx8jU0CDxQq/hB8K+yWZMva85+3UgxYrUyetYRFOw131k7QKBgGxc\nt9+viOi75FdK7SMVTWMUbfJOm6oaZGhI6RZdsix9jvS5yn3zfUEG82QjaKRD9ZQf\nzwfmtWwWTdWuUe7X2otMQ/UgsXqPHC1BSfU+/2Ha2c3cStjQpeZtzOkpt+dFq1GM\nKqt/j0WydonW0yU4DBOgIbYeBhF+28APVbSFqzaRAoGBAPRPNNCJcbIsCZEyBgwn\nCgK9W5anZDVmtwXbAVAoKMzzxFVi49W+6Lduw9oeTqgx9J1AdQMwV27I0hcPtfBE\nw5IVhrQsd6dRKDt/CJwEN6/iR9AqLx3T/rO342yOIi9GSPsFISQiiPDywfkNSzj6\nhT0eDw3eRs/RUv0zqcjFUjNI\n-----END PRIVATE KEY-----\n",
+  "client_email": "chatbot@busbooking-451909.iam.gserviceaccount.com",
+  "client_id": "111019976759266480456",
+  "auth_uri": "https://accounts.google.com/o/oauth2/auth",
+  "token_uri": "https://oauth2.googleapis.com/token",
+  "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
+  "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/chatbot%40busbooking-451909.iam.gserviceaccount.com",
+  "universe_domain": "googleapis.com"
+}

app/core/config.py

@@ -0,0 +1,9 @@
+import os
+from dotenv import load_dotenv
+
+load_dotenv()  # Load biến môi trường từ file .env
+
+class Settings:
+    API_BASE_URL = os.getenv("API_BASE_URL")  # API gốc (backend dev)
+
+settings = Settings()

app/services/api.py

@@ -0,0 +1,61 @@
+import httpx
+from app.core.config import settings
+from typing import Optional, Dict, Any
+
+API_BASE_URL = settings.API_BASE_URL  # Lấy base URL từ config
+
+async def get(endpoint: str, params: Optional[Dict[str, Any]] = None, headers: Optional[Dict[str, str]] = None):
+    """Gọi API GET"""
+    url = f"{API_BASE_URL}{endpoint}"
+    headers = headers or {}
+    async with httpx.AsyncClient() as client:
+        try:
+            response = await client.get(url, headers=headers, params=params)
+            response.raise_for_status()
+            return response.json()
+        except httpx.HTTPStatusError as http_err:
+            return {"error": f"HTTP {http_err.response.status_code}: {http_err.response.text}"}
+        except Exception as err:
+            return {"error": f"Request failed: {str(err)}"}
+
+async def post(endpoint: str , payload: Dict[str, Any] = None,headers: Optional[Dict[str, str]] = None):
+    """Gọi API POST"""
+    url = f"{API_BASE_URL}{endpoint}"
+    headers = headers or {"Content-Type": "application/json"}
+    async with httpx.AsyncClient() as client:
+        try:
+            response = await client.post(url, json=payload, headers=headers)
+            response.raise_for_status()
+            return response.json()
+        except httpx.HTTPStatusError as http_err:
+            return {"error": f"HTTP {http_err.response.status_code}: {http_err.response.text}"}
+        except Exception as err:
+            return {"error": f"Request failed: {str(err)}"}
+
+async def put_api(endpoint: str, payload: Dict[str, Any], headers: Optional[Dict[str, str]] = None):
+    """Gọi API PUT"""
+    url = f"{API_BASE_URL}{endpoint}"
+    headers = headers or {"Content-Type": "application/json"}
+    async with httpx.AsyncClient() as client:
+        try:
+            response = await client.put(url, json=payload, headers=headers)
+            response.raise_for_status()
+            return response.json()
+        except httpx.HTTPStatusError as http_err:
+            return {"error": f"HTTP {http_err.response.status_code}: {http_err.response.text}"}
+        except Exception as err:
+            return {"error": f"Request failed: {str(err)}"}
+
+async def delete_api(endpoint: str, params: Optional[Dict[str, Any]] = None, headers: Optional[Dict[str, str]] = None):
+    """Gọi API DELETE"""
+    url = f"{API_BASE_URL}{endpoint}"
+    headers = headers or {}
+    async with httpx.AsyncClient() as client:
+        try:
+            response = await client.delete(url, headers=headers, params=params)
+            response.raise_for_status()
+            return response.json()
+        except httpx.HTTPStatusError as http_err:
+            return {"error": f"HTTP {http_err.response.status_code}: {http_err.response.text}"}
+        except Exception as err:
+            return {"error": f"Request failed: {str(err)}"}

app/templates/index.html

@@ -0,0 +1,25 @@
+<link rel="stylesheet" href="https://www.gstatic.com/dialogflow-console/fast/df-messenger/prod/v1/themes/df-messenger-default.css">
+<script src="https://www.gstatic.com/dialogflow-console/fast/df-messenger/prod/v1/df-messenger.js"></script>
+<df-messenger
+  location="us-central1"
+  project-id="busbooking-451909"
+  agent-id="76716506-e80a-413a-931b-6b61ef715d31"
+  language-code="vi"
+  max-query-length="-1">
+  <df-messenger-chat-bubble
+   chat-title="Bus Booking">
+  </df-messenger-chat-bubble>
+</df-messenger>
+<style>
+  df-messenger {
+    z-index: 999;
+    position: fixed;
+    --df-messenger-font-color: #000;
+    --df-messenger-font-family: Google Sans;
+    --df-messenger-chat-background: #f3f6fc;
+    --df-messenger-message-user-background: #d3e3fd;
+    --df-messenger-message-bot-background: #fff;
+    bottom: 16px;
+    right: 16px;
+  }
+</style>

app/types/Respone.py

@@ -0,0 +1,35 @@
+from fastapi.responses import JSONResponse
+from pydantic import BaseModel
+from typing import List, Dict, Any, Optional
+
+class MessageText(BaseModel):
+    text: List[str]
+
+class Message(BaseModel):
+    text: MessageText = None
+    payload: Optional[Dict[str, Any]] = None  # Thêm trường payload tùy chọn
+
+    
+
+class FulfillmentResponse(BaseModel):
+    messages: List[Message]
+
+class DialogflowResponse(BaseModel):
+    fulfillment_response: FulfillmentResponse
+
+def DialogFlowResponseAPI(text: List[str], payload: Optional[Dict[str, Any]] = None):
+    """
+    Hàm tạo JSON response cho Dialogflow CX, hỗ trợ payload tùy chỉnh.
+    """
+
+    messages = []
+    messages.append(Message(text=MessageText(text=text)))
+    
+    if payload:
+        messages.append(Message(payload=payload))
+
+    response_data = DialogflowResponse(
+        fulfillment_response=FulfillmentResponse(messages=messages)
+    )
+
+    return JSONResponse(content=response_data.model_dump())

app/utils/code_province.json

@@ -0,0 +1,68 @@
+{
+  "Hà Nội": "HANOI",
+  "Hà Giang": "HAGIANG",
+  "Cao Bằng": "CAOBANG",
+  "Bắc Kạn": "BACKAN",
+  "Tuyên Quang": "TUYENQUANG",
+  "Lào Cai": "LAOCAI",
+  "Điện Biên": "DIENBIEN",
+  "Lai Châu": "LAICHAU",
+  "Sơn La": "SONLA",
+  "Yên Bái": "YENBAI",
+  "Hoà Bình": "HOABINH",
+  "Thái Nguyên": "THAINGUYEN",
+  "Lạng Sơn": "LANGSON",
+  "Quảng Ninh": "QUANGNINH",
+  "Bắc Giang": "BACGIANG",
+  "Phú Thọ": "PHUTHO",
+  "Vĩnh Phúc": "VINHPHUC",
+  "Bắc Ninh": "BACNINH",
+  "Hải Dương": "HAIDUONG",
+  "Hải Phòng": "HAIPHONG",
+  "Hưng Yên": "HUNGYEN",
+  "Thái Bình": "THAIBINH",
+  "Hà Nam": "HANAM",
+  "Nam Định": "NAMDINH",
+  "Ninh Bình": "NINHBINH",
+  "Thanh Hóa": "THANHHOA",
+  "Nghệ An": "NGHEAN",
+  "Hà Tĩnh": "HATINH",
+  "Quảng Bình": "QUANGBINH",
+  "Quảng Trị": "QUANGTRI",
+  "Huế": "HUE",
+  "Đà Nẵng": "DANANG",
+  "Quảng Nam": "QUANGNAM",
+  "Quảng Ngãi": "QUANGNGAI",
+  "Bình Định": "BINHDINH",
+  "Phú Yên": "PHUYEN",
+  "Khánh Hòa": "KHANHHOA",
+  "Ninh Thuận": "NINHTHUAN",
+  "Bình Thuận": "BINHTHUAN",
+  "Kon Tum": "KONTUM",
+  "Gia Lai": "GIALAI",
+  "Đắk Lắk": "DAKLAK",
+  "Đắk Nông": "DAKNONG",
+  "Đà Lạt": "DALAT",
+  "Thành phố Đà Lạt": "DALAT",
+  "Lâm Đồng": "LAMDONG",
+  "Bình Phước": "BINHPHUOC",
+  "Tây Ninh": "TAYNINH",
+  "Bình Dương": "BINHDUONG",
+  "Đồng Nai": "DONGNAI",
+  "Bà Rịa - Vũng Tàu": "VUNGTAU",
+  "Hồ Chí Minh": "TPHCM",
+  "Thành phố Hồ Chí Minh": "TPHCM",
+  "Long An": "LONGAN",
+  "Tiền Giang": "TIENGIANG",
+  "Bến Tre": "BENTRE",
+  "Trà Vinh": "TRAVINH",
+  "Vĩnh Long": "VINHLONG",
+  "Đồng Tháp": "DONGTHAP",
+  "An Giang": "ANGIANG",
+  "Kiên Giang": "KIENGIANG",
+  "Cần Thơ": "CANTHO",
+  "Hậu Giang": "HAUGIANG",
+  "Sóc Trăng": "SOCTRANG",
+  "Bạc Liêu": "BACLIEU",
+  "Cà Mau": "CAMAU"
+}

app/utils/constants.py

@@ -0,0 +1,5 @@
+import json
+
+# Đọc dữ liệu từ file JSON
+with open("app/utils/code_province.json", "r", encoding="utf-8") as file:
+    code_province = json.load(file)

main.py

@@ -0,0 +1,10 @@
+from fastapi import FastAPI
+from app.api.routes import router
+
+app = FastAPI(title="FastAPI Proxy Service")
+
+app.include_router(router, prefix="/api")
+
+if __name__ == "__main__":
+    import uvicorn
+    uvicorn.run(app, host="0.0.0.0", port=8000, reload=True)

requirements.txt

@@ -0,0 +1,24 @@
+annotated-types==0.7.0
+anyio==4.8.0
+certifi==2025.1.31
+click==8.1.8
+colorama==0.4.6
+exceptiongroup==1.2.2
+fastapi==0.115.11
+h11==0.14.0
+httpcore==1.0.7
+httptools==0.6.4
+httpx==0.28.1
+idna==3.10
+Jinja2==3.1.6
+MarkupSafe==3.0.2
+pydantic==2.10.6
+pydantic_core==2.27.2
+python-dotenv==1.0.1
+PyYAML==6.0.2
+sniffio==1.3.1
+starlette==0.46.0
+typing_extensions==4.12.2
+uvicorn==0.34.0
+watchfiles==1.0.4
+websockets==15.0.1