Upload 239 files

.env

@@ -0,0 +1,12 @@
+DB_HOST=mysql-22f29707-student-4328.h.aivencloud.com
+DB_USER=avnadmin
+DB_PASSWORD=AVNS_D-m-KFb1aPKlV4JBIw7
+DB_NAME=demohmdrinks
+DB_PORT=18340
+MONGO_URI = mongodb+srv://muyxue:389126@cluster0.190kw.mongodb.net/hmdrinks?retryWrites=true&w=majority&appName=Cluster0
+GROQ_API_KEY=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
+COHERE_API_KEY=v34SUVXvG16NlmEZQt1mtwSeUbbdbxCy5KCFue11
+GOOGLE_API_KEY_1=AIzaSyCO-RlqYewC4e9BEPoC8m-AxHUY7J3_o2E
+COHERE_API_KEY_2= v34SUVXvG16NlmEZQt1mtwSeUbbdbxCy5KCFue11
+COHERE_API_KEY_3= v34SUVXvG16NlmEZQt1mtwSeUbbdbxCy5KCFue11
+GOOGLE_API_KEY=AIzaSyCO-RlqYewC4e9BEPoC8m-AxHUY7J3_o2E

api_key.txt

@@ -0,0 +1,2 @@
+AIzaSyBka2z9sIE-BIHXb9o2Z-hoZ6TPzXCDnac
+AIzaSyAW23eFBB3u2bUfM0sxk-WS_nS2-sV4cUA

ca.pem

@@ -0,0 +1,26 @@
+-----BEGIN CERTIFICATE-----
+MIIEUDCCArigAwIBAgIUfxHeji94PVdRnLYTj22XRvvdXXwwDQYJKoZIhvcNAQEM
+BQAwQDE+MDwGA1UEAww1NDY4MDI2MDYtZGM1OC00NDM4LTg0ODctNzQxNWE5MjVl
+YjJmIEdFTiAxIFByb2plY3QgQ0EwHhcNMjUwNjE5MDkyNzM2WhcNMzUwNjE3MDky
+NzM2WjBAMT4wPAYDVQQDDDU0NjgwMjYwNi1kYzU4LTQ0MzgtODQ4Ny03NDE1YTky
+NWViMmYgR0VOIDEgUHJvamVjdCBDQTCCAaIwDQYJKoZIhvcNAQEBBQADggGPADCC
+AYoCggGBAMqawd0fx+VhLXb1sOcvAOJAjnybF4phtphIZywDc+wrSiJKmKpFdIEV
+9d4hyzHqby7uyFvXp4qe710D/1vYzTfAtWyYra3Fq5FAR+rZoQfKeBJneLvWr4OM
+O4nhntrXLWoz5z5dvrwwMQdFXK5zWL776gsWo9Zfved1/VrBma0PMnLWGCxBhe8D
+CUvFwj9WDLcBu1Wpemj5hNUYV7HrIKYKnRXT6LsW8LAcwdVvwkFMeTYXoAvxZime
+jgdm0l9aBHmkxVQB4yV2jzSjYl+RfBv9Fr0sFsTjYRhWTnqgotwQ/kWtV2lPvTC8
+9RrR+Zv4Npr5GFva856J8F7vJYE4u8iXtcW88/8R2BD6X7Is0bNSXN4ddb4e1uG1
+xibOwNdFAbaiRfQpdg5uA87LCbb4JsU0WRe705qJHOPynVMQsQHDqioexVkJwNot
+FhRG7j9rQLMihC5IRbxYql0FLamm0xb32Z4bSTqmwQacQF+uB27i6rxB3w8wV2C0
+tXmBa9siVwIDAQABo0IwQDAdBgNVHQ4EFgQUHgH+oY6nEHz0RQ7Kov6/1L1/scYw
+EgYDVR0TAQH/BAgwBgEB/wIBADALBgNVHQ8EBAMCAQYwDQYJKoZIhvcNAQEMBQAD
+ggGBAJSFK9FoV5d/PxtrP2z+BViDjgXeoJ6tLVykLjpVEr0OCIzwgi3F8O4a1U7P
+2BQu5URiiiC28aoIvDXcmowQFJBw6DaVIadGACifNORCWals+gT+4l2kdnRFW8fy
+gP+cHjj9IBLtmcgttMTTRArTYgYO9GfuK1PMD8srG/syue5V/bQ6+vmO6gAtuTs1
+cnQXzzMyZKNLb90MERfojegLXCyoI2O5nC604fhDSgnVUKzw7g6vRPHAWPQGCZn1
+DwpI7BydRRs57F/Tigz8EgbzC2cuTQaaWr3oOiBTsGl5Nkc2iPxKXzoPHMUT3MD3
+vRosEkl+LN5hupYbaHagHT50n9j+AG5KXiRoN4S0IxJZWSGMpYMYEQ4Qkd3AvRnW
+ECdT5ZXXm19a4teTZIk1fZ9dITnn/vobfW0MhpG4kkHIOBHVy4VJrLqFrQfLOVQM
+qVgKdc0K6FfDnfNdvkrfzJoLoR0X6AtVS60pfpolBXNQEPNWcdKDL0DSBbZ+rnid
+9nYErA==
+-----END CERTIFICATE-----

controller/CallbackController.py

@@ -0,0 +1,212 @@
+from fastapi import APIRouter, Request,HTTPException
+from fastapi.security import HTTPBearer, HTTPAuthorizationCredentials
+from fastapi.requests import Request
+import yaml
+from typing import Dict
+from fastapi.responses import RedirectResponse
+from service import CallBackService
+import json
+from fastapi.responses import JSONResponse
+from models.Database_Entity import PaymentCallbackLog
+with open("config.yaml", "r") as f:
+    config = yaml.safe_load(f)
+base_backend_java  = config["callback_urls"]
+base_frontend = config["frontend"]
+
+router = APIRouter()
+
+class JWTBearer(HTTPBearer):
+    def __init__(self, auto_error: bool = True):
+        super(JWTBearer, self).__init__(auto_error=auto_error)
+
+    async def __call__(self, request: Request):
+        credentials: HTTPAuthorizationCredentials = await super(JWTBearer, self).__call__(request)
+        if credentials:
+            if credentials.scheme != "Bearer":
+                raise HTTPException(status_code=401, detail="Invalid authentication scheme.")
+            return credentials.credentials
+        else:
+            raise HTTPException(status_code=401, detail="Invalid authorization code.")
+
+jwt_bearer = JWTBearer()
+
+
+
+@router.post("/android/zalo")
+async def zalo_callback_post(request: Request):
+    try:
+        json_data = await request.json()
+        data_str =json_data.get("data")
+        
+        if data_str:
+               data_dict = json.loads(data_str)
+               app_trans_id = data_dict.get("app_trans_id")
+               PaymentCallbackLog(
+    type="zalopay",
+    app_trans_id=data_dict.get("app_trans_id"),
+    raw_data=data_dict,
+    status="success" if data_dict.get("status") == "1" else "fail",
+    is_refund = False
+).save()
+
+               print(app_trans_id)
+               data = await CallBackService.zalo_callback(str(app_trans_id))
+               return data
+    except Exception as e:
+        print("Lỗi khi gọi callback web zalo:", e)
+        return JSONResponse(content={"error": "Internal server error"}, status_code=500)
+
+
+@router.post("/android/group/zalo")
+async def zalo_callback_post(request: Request):
+    try:
+        json_data = await request.json()
+        data_str =json_data.get("data")
+        if data_str:
+               data_dict = json.loads(data_str)
+               app_trans_id = data_dict.get("app_trans_id")
+               PaymentCallbackLog(
+    type="zalopay",
+    app_trans_id=data_dict.get("app_trans_id"),
+    raw_data=data_dict,
+    status="success" if data_dict.get("status") == "1" else "fail",
+    is_refund = False
+).save()
+               print(app_trans_id)
+               data = await CallBackService.zalo_group_callback(str(app_trans_id))
+               return data
+    except Exception as e:
+        print("Lỗi khi gọi callback group ảndroid zalo:", e)
+        return JSONResponse(content={"error": "Internal server error"}, status_code=500)
+
+
+@router.get("/android/payOs")
+async def return_url_handler(code: str = None, id: str = None, cancel: bool = None, status: str = None, orderCode: str = None):
+    try:
+     return await  CallBackService.android_payos_callback(status,orderCode)
+    except Exception as e:
+        print("Lỗi khi gọi callback android payos:", e)
+        # Trả về lỗi 500 - Internal Server Error
+        return JSONResponse(content={"error": "Internal server error"}, status_code=500)
+
+
+@router.get("/android/group/payOs")
+async def return_url_handler1(code: str = None, id: str = None, cancel: bool = None, status: str = None, orderCode: str = None):
+    try:
+     return await CallBackService.android_group_payOs_callback(status,orderCode)
+    except Exception as e:
+        print("Lỗi khi gọi callback group payos:", e)
+        return JSONResponse(content={"error": "Internal server error"}, status_code=500)
+    
+
+@router.get("/web/payOs")
+async def return_url_handler(code: str = None, id: str = None, cancel: bool = None, status: str = None, orderCode: str = None):
+    try:
+     return await CallBackService.web_payos_callback(code, id, cancel, status, orderCode)
+    except Exception as e:
+        print("Lỗi khi gọi callback web payos:", e)
+        # Trả về lỗi 500 - Internal Server Error
+        return JSONResponse(content={"error": "Internal server error"}, status_code=500)
+       
+
+@router.post("/android/momo")
+async def return_url_handler(request: Request):
+    json_data = await request.json()
+    print(json_data)
+   
+    data_str =json_data.get("data")
+    order_id_original = json_data.get("orderId")
+    order_id = ""
+    if order_id_original.startswith("MOMO-"):
+      order_id = order_id_original[len("MOMO-"):]
+    result_code = json_data.get("resultCode")
+    PaymentCallbackLog(
+    type="momo",
+    order_id=order_id,
+    raw_data=json_data,
+    status="success" if result_code == 0 else "fail",
+    is_refund = False
+).save()
+    print(data_str)
+
+    try:
+        result = await CallBackService.momo_callback(order_id_original,result_code)
+        print(result)
+    except Exception as e:
+        print("Lỗi khi gọi call back android momo:", e)
+        
+    if 0 != int(result_code):
+        return RedirectResponse(url=f"{base_frontend['android_redirect_base']}?status=-49")
+    else :
+        return RedirectResponse(url=f"{base_frontend['android_redirect_base']}?status=1")
+
+
+@router.post("/android/group/momo")
+async def return_url_handler(request: Request):
+    json_data = await request.json()
+    print(json_data)
+   
+    data_str =json_data.get("data")
+    order_id = json_data.get("orderId")
+    if order_id.startswith("MOMO-"):
+      order_id = order_id[len("MOMO-"):]
+
+    result_code = json_data.get("resultCode")
+    print(data_str)
+    PaymentCallbackLog(
+    type="momo",
+    order_id=order_id,
+    raw_data=json_data,
+    status="success" if result_code == 0 else "fail",
+    is_refund = False
+).save()
+
+    try:
+        result = await CallBackService.momo_group_callback(order_id,result_code)
+        print(result)
+    except Exception as e:
+        print("Lỗi khi gọi callback android group momo:", e)
+    if 0 != int(result_code):
+        return RedirectResponse(url=f"""{base_frontend["android_group_redirect_base"]}?status=-49""")
+    else :
+        return RedirectResponse(url=f"""{base_frontend["android_group_redirect_base"]}?status=1""")
+
+
+@router.get("/android/vnpay_ipn")
+async def vnpay_ipn(request: Request):
+    params: Dict[str, str] = dict(request.query_params)
+    # Lưu callback vnpay
+    PaymentCallbackLog(
+    type="vnpay",
+    txn_ref=params.get("vnp_TxnRef"),
+    raw_data=params,
+    status="success" if params.get("vnp_ResponseCode") == "00" else "fail",
+    is_refund = False
+).save()
+
+    try:
+     return await CallBackService.vnpay_callbackk(params)
+    except Exception as e:
+        print("Lỗi khi gọi callback vnpay:", e)
+        # Trả về lỗi 500 - Internal Server Error
+        return JSONResponse(content={"error": "Internal server error"}, status_code=500)
+
+
+@router.get("/android/group/vnpay_ipn")
+async def vnpay_ipn(request: Request):
+    params: Dict[str, str] = dict(request.query_params)
+    # Lưu callback vnpay
+    PaymentCallbackLog(
+    type="vnpay",
+    txn_ref=params.get("vnp_TxnRef"),
+    raw_data=params,
+    status="success" if params.get("vnp_ResponseCode") == "00" else "fail",
+    is_refund = False
+).save()
+
+    try:
+     return await CallBackService.vnpay_group_callback(params)
+    except Exception as e:
+        print("Lỗi khi gọi callback group vnpay ipn:", e)
+        # Trả về lỗi 500 - Internal Server Error
+        return JSONResponse(content={"error": "Internal server error"}, status_code=500)

controller/ChatController.py

@@ -0,0 +1,224 @@
+from fastapi import APIRouter, Form, Request,Depends,HTTPException,BackgroundTasks
+from service import ChatService
+from fastapi.security import HTTPBearer, HTTPAuthorizationCredentials
+from request import RequestChat
+from fastapi.requests import Request
+from fastapi.responses import JSONResponse
+import asyncio
+router = APIRouter()
+import asyncio
+# Lưu task đang chạy theo chat_history_id
+task_registry: dict[str, asyncio.Task] = {}
+# Lưu stop_event để dừng từng task
+stop_events: dict[str, asyncio.Event] = {}
+import decode_token
+from models.Database_Entity import StopSignal
+from models.Database_Entity  import ChatHistory, User
+from repository.MySQL import UserRepository
+
+class JWTBearer(HTTPBearer):
+    def __init__(self, auto_error: bool = True):
+        super(JWTBearer, self).__init__(auto_error=auto_error)
+
+    async def __call__(self, request: Request):
+        credentials: HTTPAuthorizationCredentials = await super(JWTBearer, self).__call__(request)
+        if credentials:
+            if credentials.scheme != "Bearer":
+                raise HTTPException(status_code=401, detail="Invalid authentication scheme.")
+            return credentials.credentials
+        else:
+            raise HTTPException(status_code=401, detail="Invalid authorization code.")
+
+jwt_bearer = JWTBearer()
+
+
+@router.get("/chat/user_history")
+async def get_user_chat_history(token: str = Depends(jwt_bearer)):
+    try:
+     user_id_token = decode_token.JwtService.extract_user_id(token)
+     return await ChatService.get_user_chat_history(user_id_token)
+    except Exception as e:
+        print("Lỗi khi gọi user history chat:", e)
+        return JSONResponse(content={"error": "Internal server error"}, status_code=500)
+
+
+@router.post("/new_chat/create/")
+async def create_chat(token: str = Depends(jwt_bearer)):
+  try:
+    user_id_token = decode_token.JwtService.extract_user_id(token)
+    new_chat = await ChatService.create_new_chat_history(user_id_token)
+    return new_chat
+  except Exception as e:
+        print("Lỗi khi gọi create new chat:", e)
+        return JSONResponse(content={"error": "Internal server error"}, status_code=500)
+
+
+from bson import ObjectId
+@router.post("/question")
+async def question(
+    request: RequestChat.ChatWithServer,
+    background_tasks: BackgroundTasks,
+    token: str = Depends(jwt_bearer)
+):
+    try:
+        user_id_token = decode_token.JwtService.extract_user_id(token)
+        user_role = decode_token.JwtService.extract_user_role(token)
+        chat_id = request.chat_history_id
+
+        stop_event = asyncio.Event()
+        stop_events[chat_id] = stop_event
+        print(f"[CREATE] stop_event id: {id(stop_event)} for chat_id: {chat_id}")
+        chat_history = ChatHistory.objects(pk=ObjectId(chat_id)).first()
+
+        if chat_history:
+         signal = StopSignal.objects(chat_history=chat_history).first()
+         if not signal:
+            signal = StopSignal(chat_history=chat_history)
+         signal.is_stopped = False
+         signal.stopped_at = None
+         signal.save()
+
+        async def run_chat():
+            try:
+                result = await ChatService.chat_with_user(
+                    request.user_input,
+                    user_id_token,
+                    request.language,
+                    user_role,
+                    token,
+                    chat_id,
+                    stop_event
+                )
+                return result
+            except asyncio.CancelledError:
+                print(f"🛑 Task {chat_id} was cancelled by asyncio.")
+                return {"status": "cancelled"}
+            except Exception as e:
+                print(f"❌ Lỗi trong task {chat_id}:", e)
+                return {"error": str(e)}
+            finally:
+                # Dọn dẹp
+                stop_events.pop(chat_id, None)
+                task_registry.pop(chat_id, None)
+
+        task = asyncio.create_task(run_chat())
+        task_registry[chat_id] = task
+        return await task
+
+    except Exception as e:
+        print("Lỗi khi chạy:", e)
+        return JSONResponse(content={"error": "Internal server error"}, status_code=500)
+    
+     
+from datetime import datetime
+@router.post("/stop-task/{chat_history_id}")
+async def stop_task(chat_history_id: str, token: str = Depends(jwt_bearer)):
+    user_id = int(decode_token.JwtService.extract_user_id(token))
+    if not isinstance(user_id, int) or user_id <= 0:
+        raise HTTPException(status_code=400, detail="Invalid user_id: must be a positive integer")
+    check = UserRepository.getUserByUserId(user_id)
+    if check is None:
+        raise HTTPException(status_code=400, detail="User not found or has been deleted in MySQL")
+    
+    check_history_id = UserRepository.getChatHistory(user_id,chat_history_id)
+    if check_history_id is None:
+        raise HTTPException(status_code=400, detail="Chat not found or has been deleted in MySQL")
+    
+    user = User.objects(user_id=user_id).first()
+    if not user:
+        return {"error": "User not found or has been deleted in MongoDB"}
+    event = stop_events.get(chat_history_id)
+    task = task_registry.get(chat_history_id)
+    print(f"🚨 Đã vào stop-task với chat_history_id = {chat_history_id}")
+    print(f"🔎 stop_event: {event}, task: {task}")
+    # Set event trong RAM
+    if event:
+        print(f"🛑 Setting stop_event for {chat_history_id}")
+        event.set()
+    # Cancel task
+    if task:
+        print(f"🔪 Cancelling task for {chat_history_id}")
+        task.cancel()
+
+    # Cập nhật trạng thái stop vào MongoDB
+    from bson import ObjectId
+
+    chat_history = ChatHistory.objects(pk=ObjectId(chat_history_id)).first()
+
+    if chat_history:
+        signal = StopSignal.objects(chat_history=chat_history).first()
+        if not signal:
+            signal = StopSignal(chat_history=chat_history)
+        signal.is_stopped = True
+        signal.stopped_at = datetime.utcnow()
+        signal.save()
+    return {"message": f"Stop signal sent for chat_history_id {chat_history_id}"}
+
+
+@router.put("/regenerate")
+async def regenerate(request: RequestChat.Regenerate, token: str = Depends(jwt_bearer)):
+    try:
+     user_id_token = decode_token.JwtService.extract_user_id(token)
+     user_role = decode_token.JwtService.extract_user_role(token)
+     chat_id = request.chat_id
+     stop_event = asyncio.Event()
+     stop_events[chat_id] = stop_event
+     print(f"[CREATE] stop_event id: {id(stop_event)} for chat_id: {chat_id}")
+     chat_history = ChatHistory.objects(pk=ObjectId(chat_id)).first()
+
+     if chat_history:
+         signal = StopSignal.objects(chat_history=chat_history).first()
+         if not signal:
+            signal = StopSignal(chat_history=chat_history)
+         signal.is_stopped = False
+         signal.stopped_at = None
+         signal.save()
+     
+     async def run_chat():
+            try: 
+                new_chat = await ChatService.regenerate(request.question_new ,user_id_token,request.languages ,user_role,token,request.chat_id,stop_event)
+                return new_chat
+            except asyncio.CancelledError:
+                print(f"🛑 Task {chat_id} was cancelled by asyncio.")
+                return {"status": "cancelled"}
+            except Exception as e:
+                print(f"❌ Lỗi trong task {chat_id}:", e)
+                return {"error": str(e)}
+     task = asyncio.create_task(run_chat())
+     task_registry[chat_id] = task
+     return await task
+    except Exception as e:
+        print("Lỗi khi gọi regenerate:", e)
+        return JSONResponse(content={"error": "Internal server error"}, status_code=500)
+
+
+@router.put("/update")
+async def update_chat_name(request: RequestChat.UpdateNameChat, token: str = Depends(jwt_bearer)):
+    try:
+     user_id_token = decode_token.JwtService.extract_user_id(token)
+     updated_chat = await ChatService.update_chat_name(request.chat_id, request.name_chat,user_id_token)
+     return updated_chat
+    except Exception as e:
+        print("Lỗi khi gọi update:", e)
+        return JSONResponse(content={"error": "Internal server error"}, status_code=500)
+
+
+@router.delete("/delete")
+async def delete_chat(request: RequestChat.DeleteChatRequest, token: str = Depends(jwt_bearer)):
+    try:
+     user_id_token = decode_token.JwtService.extract_user_id(token)
+     deleted_chat = await ChatService.soft_delete_chat(request.chat_id,user_id_token)
+     return deleted_chat
+    except Exception as e:
+        print("Lỗi khi gọi deleted:", e)
+        return JSONResponse(content={"error": "Internal server error"}, status_code=500)
+
+
+@router.get("/list_detail_chat/{chat_id}")
+async def get_chat_details(chat_id: str, token: str = Depends(jwt_bearer)):
+    try:
+     user_id_token = decode_token.JwtService.extract_user_id(token)
+     return await ChatService.get_chat_details(chat_id,user_id_token)
+    except Exception as e:
+        print("Lỗi khi gọi list_detail_chat:", e)
+        return JSONResponse(content={"error": "Internal server error"}, status_code=500)

controller/GroupOrderController.py

@@ -0,0 +1,25 @@
+from fastapi import APIRouter, Form, Request,Depends,HTTPException
+from service import ChatService
+from fastapi.security import HTTPBearer, HTTPAuthorizationCredentials
+from request import RequestChat
+from typing import Optional
+from fastapi.requests import Request
+from fastapi.responses import JSONResponse
+
+router = APIRouter()
+
+class JWTBearer(HTTPBearer):
+    def __init__(self, auto_error: bool = True):
+        super(JWTBearer, self).__init__(auto_error=auto_error)
+
+    async def __call__(self, request: Request):
+        credentials: HTTPAuthorizationCredentials = await super(JWTBearer, self).__call__(request)
+        if credentials:
+            if credentials.scheme != "Bearer":
+                raise HTTPException(status_code=401, detail="Invalid authentication scheme.")
+            return credentials.credentials
+        else:
+            raise HTTPException(status_code=401, detail="Invalid authorization code.")
+
+jwt_bearer = JWTBearer()
+import decode_token

controller/RecommendController.py

@@ -0,0 +1,25 @@
+from fastapi import APIRouter, Form, Request,Depends,HTTPException
+from service import ChatService
+from fastapi.security import HTTPBearer, HTTPAuthorizationCredentials
+from request import RequestChat
+from typing import Optional
+from fastapi.requests import Request
+
+
+router = APIRouter()
+
+class JWTBearer(HTTPBearer):
+    def __init__(self, auto_error: bool = True):
+        super(JWTBearer, self).__init__(auto_error=auto_error)
+
+    async def __call__(self, request: Request):
+        credentials: HTTPAuthorizationCredentials = await super(JWTBearer, self).__call__(request)
+        if credentials:
+            if credentials.scheme != "Bearer":
+                raise HTTPException(status_code=401, detail="Invalid authentication scheme.")
+            return credentials.credentials
+        else:
+            raise HTTPException(status_code=401, detail="Invalid authorization code.")
+
+jwt_bearer = JWTBearer()
+import decode_token

controller/RedirectController.py

@@ -0,0 +1,96 @@
+from fastapi import APIRouter, Form, Request,Depends,HTTPException
+from service import ChatService
+from fastapi.security import HTTPBearer, HTTPAuthorizationCredentials
+from request import RequestChat
+from typing import Optional
+from fastapi.requests import Request
+
+
+router = APIRouter()
+
+class JWTBearer(HTTPBearer):
+    def __init__(self, auto_error: bool = True):
+        super(JWTBearer, self).__init__(auto_error=auto_error)
+
+    async def __call__(self, request: Request):
+        credentials: HTTPAuthorizationCredentials = await super(JWTBearer, self).__call__(request)
+        if credentials:
+            if credentials.scheme != "Bearer":
+                raise HTTPException(status_code=401, detail="Invalid authentication scheme.")
+            return credentials.credentials
+        else:
+            raise HTTPException(status_code=401, detail="Invalid authorization code.")
+
+jwt_bearer = JWTBearer()
+import decode_token
+from service import RedirectService
+from typing import Optional
+from fastapi import Request, Query
+from fastapi.responses import JSONResponse
+@router.get("/android/zalo")
+async def zalo_callback_get(
+    amount: Optional[int] = Query(None),
+    appid: Optional[str] = Query(None),
+    apptransid: Optional[str] = Query(None),
+    bankcode: Optional[str] = Query(None),
+    checksum: Optional[str] = Query(None),
+    discountamount: Optional[int] = Query(None),
+    pmcid: Optional[int] = Query(None),
+    status: Optional[int] = Query(None)
+):
+    return await RedirectService.zalo_redirect(status,apptransid)
+
+
+@router.get("/android/group/zalo")
+async def zalo_callback_get(
+    amount: Optional[int] = Query(None),
+    appid: Optional[str] = Query(None),
+    apptransid: Optional[str] = Query(None),
+    bankcode: Optional[str] = Query(None),
+    checksum: Optional[str] = Query(None),
+    discountamount: Optional[int] = Query(None),
+    pmcid: Optional[int] = Query(None),
+    status: Optional[int] = Query(None)
+):
+    return await RedirectService.zalo_group_redirect(status,apptransid)
+
+@router.get("/web/zalo")
+async def zalo_web_callback_get(request: Request):
+    return await RedirectService.zalo_web_redirect(request.query_params)
+
+
+@router.get("/android/momo")
+async def return_url_handler_1(request: Request):
+    query_params = request.query_params
+    return await RedirectService.android_momo_redirect(query_params)
+
+@router.get("/android/group/momo")
+async def return_url_handler_group_momo(request: Request):
+    query_params = request.query_params
+    return await RedirectService.android_group_momo_redirect(query_params)
+
+
+from urllib.parse import urlencode
+@router.get("/web/momo")
+async def return_url_handler_web(request: Request):
+    query_params = request.query_params
+    return await RedirectService.web_momo_redirect(query_params)
+
+
+
+from typing import Dict
+@router.get("/android/vnpay")
+async def vnpay_ipn_redirect(request: Request):
+    params: Dict[str, str] = dict(request.query_params)
+    return await RedirectService.android_vnpay_ipn_redirect(params)
+
+
+@router.get("/android/group/vnpay")
+async def vnpay_ipn_redirect(request: Request):
+    params: Dict[str, str] = dict(request.query_params)
+    return await RedirectService.android_vnpay_group_ipn_redirect(params)
+
+@router.get("/web/vnpay")
+async def vnpay_ipn_redirect(request: Request):
+    query_params = request.query_params
+    return await RedirectService.web_vnpay_ipn_redirect(query_params)

controller/RefundController.py

@@ -0,0 +1,150 @@
+from fastapi import APIRouter, Request, Depends, HTTPException
+from fastapi.security import HTTPBearer, HTTPAuthorizationCredentials
+from fastapi.requests import Request
+from fastapi.responses import JSONResponse
+import asyncio
+router = APIRouter()
+import asyncio
+class JWTBearer(HTTPBearer):
+    def __init__(self, auto_error: bool = True):
+        super(JWTBearer, self).__init__(auto_error=auto_error)
+
+    async def __call__(self, request: Request):
+        credentials: HTTPAuthorizationCredentials = await super(JWTBearer, self).__call__(request)
+        if credentials:
+            if credentials.scheme != "Bearer":
+                raise HTTPException(status_code=401, detail="Invalid authentication scheme.")
+            return credentials.credentials
+        else:
+            raise HTTPException(status_code=401, detail="Invalid authorization code.")
+import sys,os
+sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), "..")))
+jwt_bearer = JWTBearer()
+import decode_token
+
+from models.Database_Entity import StopSignal
+from models.Database_Entity  import ChatHistory,PaymentCallbackLog
+from service.RefundService import *
+from models.Database_Entity import PaymentCallbackLog
+from bson import ObjectId
+from mongoengine import connect
+from dotenv import load_dotenv
+load_dotenv()
+MONGO_URI = os.getenv("MONGO_URI", "")
+connect("chatbot_hmdrinks", host=MONGO_URI)
+
+
+async def refund_by_type_and_code(type: str, code: str):
+    if type.lower() == "zalopay":
+        log = PaymentCallbackLog.objects(type="zalopay", app_trans_id=code).first()
+        if not log:
+            return {"code": -3, "message": "Không tìm thấy giao dịch ZaloPay"}
+        data =  call_zalopay_refund(
+            app_trans_id=code,
+            amount=log.raw_data.get("amount", 0),
+            description="Hoàn tiền ZaloPay"
+        )
+        return_code = data.get("return_code")
+        if return_code == 3:
+            log.is_refund = True
+            log.save()
+            return {"code": 0 , "message": f"Hoàn tiền thành công", "data": data}
+        else:
+            log.is_refund = False
+            log.save()
+            return {"code": -1 , "message": f"Hoàn tiền thất bại", "data": data}
+      
+
+    elif type.lower() == "vnpay":
+        log = PaymentCallbackLog.objects(type="vnpay", txn_ref=code).first()
+        if not log:
+            return {"code": -2, "message": "Không tìm thấy giao dịch VNPay"}
+        raw = log.raw_data
+        data =  call_vnpay_refund(
+            txn_ref=code,
+            amount=int(raw.get("vnp_Amount", 0)),  # VNPAY trả về x100
+            transaction_date=raw.get("vnp_PayDate"),
+            transaction_no=raw.get("vnp_TransactionNo"),
+            create_by="system_refund",
+            order_info=raw.get("vnp_OrderInfo", "Hoàn tiền VNPay")
+        )
+  
+        resultCode = data.get("data").get("vnp_ResponseCode")
+        message = data.get("data").get("vnp_Message")
+        if resultCode == "00":
+            log.is_refund = True
+            log.save()
+            return {"code": 0 , "message": f"Hoàn tiền thành công {message}", "data": data}
+        else:
+            log.is_refund = False
+            log.save()
+            return {"code": -1 , "message": f"Hoàn tiền thất bại {message}", "data": data}
+
+    elif type.lower() == "momo":
+        log = PaymentCallbackLog.objects(type="momo", order_id=code).first()
+        if not log:
+            return {"code": -3, "message": "Không tìm thấy giao dịch MoMo"}
+        if log.raw_data.get("payType", "") != "qr":
+            return {"code": -2 , "message": f"Payment không thể hoàn tiền với ", "data": data}
+        data =  call_momo_refund(
+            trans_id=log.raw_data.get("transId", 0),
+            amount=log.raw_data.get("amount", 0),
+            description=f"Hoàn tiền MoMo cho giao dịch {code}"
+        )
+        resultCode = data.get("resultCode")
+        if resultCode == 0:
+            log.is_refund = True
+            log.save()
+            return {"code": 0 , "message": f"Hoàn tiền thành công", "data": data}
+        else:
+            log.is_refund = False
+            log.save()
+            return {"code": -1 , "message": f"Hoàn tiền thất bại", "data": data}
+    else:
+        return {"code": -4, "message": f"Không hỗ trợ cổng thanh toán '{type}'"}
+
+from fastapi import  HTTPException
+from pydantic import BaseModel
+
+
+class Refund(BaseModel):
+    type: str
+    code: str
+
+
+@router.post("/refund")
+async def refund_endpoint(request: Refund,token: str = Depends(jwt_bearer)):
+    type = request.type
+    code = request.code
+    user_role = decode_token.JwtService.extract_user_role(token)
+    if user_role != "ADMIN":
+        return JSONResponse(content={"message": "Not allow"}, status_code=404)
+    
+    data = asyncio.run(refund_by_type_and_code(type = type,code=code))
+    if data.get("code") != 0 :
+        return JSONResponse(content={"message": f"Not allow type {type}","status": -1, "data":data}, status_code=404)
+    else:
+        return JSONResponse(
+        content={
+            "status": 0,
+            "data": data
+        },
+        status_code=200
+    )
+
+
+@router.post("/refund-schedule")
+async def refund_endpoint_schedule(request: Refund):
+    type = request.type
+    code = request.code
+    data = asyncio.run(refund_by_type_and_code(type = type,code=code))
+    if data.get("code") != 0 :
+        return JSONResponse(content={"message": f"Not allow type {type}","status": -1, "data":data}, status_code=404)
+    else:
+        return JSONResponse(
+        content={
+            "status": 0,
+            "data": data
+        },
+        status_code=200
+    )

function/__init__.py

@@ -0,0 +1 @@
+from function import *

function/advance_shopping/call_gemini/tool_call.py

@@ -0,0 +1,44 @@
+import base64
+import os
+import json
+from google import genai
+from google.genai import types
+
+thinking_config = types.ThinkingConfig(include_thoughts=True, thinking_budget=5000)
+
+def generate(prompt: str, max_retries: int = 3):
+    client = genai.Client(
+        api_key="AIzaSyA4eTxl-suN_D8COMiRA5UmrF-6vW7etys",
+    )
+    model = "gemini-2.5-flash-preview-05-20"
+    contents = [
+        types.Content(
+            role="user",
+            parts=[
+                types.Part.from_text(text=prompt),
+            ],
+        ),
+    ]
+    generate_content_config = types.GenerateContentConfig(
+        response_mime_type="application/json",
+        thinking_config=thinking_config
+    )
+
+    for attempt in range(max_retries + 1):
+        result = ""
+        try:
+            for chunk in client.models.generate_content_stream(
+                model=model,
+                contents=contents,
+                config=generate_content_config,
+            ):
+                if chunk.text:  # Đảm bảo chunk.text không rỗng
+                    result += chunk.text
+
+            if result.strip():  # Nếu kết quả không rỗng
+                return json.loads(result)
+
+        except Exception as e:
+            print(f"[Lần {attempt + 1}] Lỗi khi gọi Gemini hoặc phân tích JSON: {e}")
+
+    raise RuntimeError("Không thể tạo nội dung sau nhiều lần thử.")

function/advance_shopping/function/test.py

@@ -0,0 +1,615 @@
+# def extract_quantity(input: str, full_test, data) -> str:
+#     import base64
+#     import os
+#     from google import genai
+#     from google.genai import types
+#     client = genai.Client(
+#         api_key="AIzaSyBka2z9sIE-BIHXb9o2Z-hoZ6TPzXCDnac",
+#     )
+
+#     model = "gemini-2.5-flash-preview-05-20"
+#     prompt = f"""
+# Bạn là một chuyên gia trong việc trích xuất và lấy số lượng trong câu hỏi đồng thời lấy size sản phẩm ngoài ra bạn sẽ lấy tên sản phẩm kèm theo.
+# Bạn sẽ thực hiện lấy đúng, chính xác số lượng sản phẩm đó.
+# Ngoài ra hãy tham khảo thêm: {full_test} để xác xem liệu là sản phẩm nào thực sự bạn không cần phải lấy trong này có đề cập các sản phẩm không tồn tại. Nếu gặp không cần phải trích xuất dữ liệu chúng. Hãy đọc kĩ phân tích để tránh việc lấy nhầm sản phẩm không tồn tại.
+# Phân biệt rõ ràng dù là Trà đào hay trà đào thì nó giống nhau khi viết thường vậy thì các sản phẩm khác cũng giống vậy. Không phải ưng cái thì trà chanh, cái thì Trà chanh điều này là sai hoàn toàn.
+# Nhớ kĩ câu hỏi đầu vào của người dùng trong đó Người dùng hỏi: là câu hỏi trước đó người dùng nói khi đó trợ lý thấy thiếu sót điều gì sẽ hỏi lại và người dùng trả lời tiếp. Hãy nhớ Người dùng trả lời luôn là câu trả lời cuối cùng. 
+# Khi thực hiện phân tích bạn hãy xem thêm phần data này: {data}. Đây là các trích xuất bản ghi trước đó khi câu hỏi người dùng đưa vào bạn phải vận dụng để tạo ra list phù hợp mà không làm hao phí data này.
+# - Nếu data không có, không cần check nhưng nếu có data vui lòng check kĩ càng
+# **Yêu cầu phản hồi:**
+# - Chỉ trả về số lượng duy nhất sau khi thực hiện. Yêu cầu không giải thích gì thêm.
+# - Nếu sản phẩm đó trùng tên nhung khác size thì vẫn để riêng ra ví dụ ['"size": "M", "quantity": "5", name: "trà đào"', '"size": "L", "quantity": "3", name: "trà đào"']
+# - Chỉ trả về kiểu số ví dụ 1,2,3,... Nếu không có bắt được thì vui lòng để None
+# - Trả về Size duy nhất của sản phẩm. Nếu có nhiều size của sản phẩm thì phải trích xuất ra đúng ví dụ ['"size": "M", "quantity": "5", name: "trà đào"', '"size": "L", "quantity": "3", name: "trà đào"'] là cùng trà đào mà có sie khác nhau. Vui lòng không tự sinh ra size của sản phẩm chỉ khi trong đó có thông tin về size của đúng sản phẩm đó thì mới lấy ra size của sản phẩm đó.
+# - Vui lòng để nguyên tên sản phẩm ví dụ trà đào là trà đào nếu họ ghi Trà đào thì mới lấy Trà đào tức là không được thay đổi tên sản phẩm, viết hoa hay viết thường
+# - Formart trả về là: Json: "size": "M", "quantity": "5", name: "trà đào"
+# - Nếu xóa sản phẩm đó thì vui lòng không hiển thị lại trong chuỗi. Xác định rõ sản phẩm nào cần xóa, sản phẩm nào cập nhật để điều chỉnh list một cách hợp lý
+# - Ví dụ có nhiều sản phẩm thì json ghép trong 1 chuỗi
+
+# **Văn bản đầu vào cần xử lý:**
+# \"{input}\"
+# """
+#     contents = [
+#         types.Content(
+#             role="user",
+#             parts=[
+#                 types.Part.from_text(text=f"""{prompt}"""),
+#             ],
+#         ),
+#     ]
+#     generate_content_config = types.GenerateContentConfig(
+#         response_mime_type="application/json",
+#     )
+
+#     result = ""
+
+#     for chunk in client.models.generate_content_stream(
+#     model=model,
+#     contents=contents,
+#     config=generate_content_config,
+# ):
+#       result += chunk.text  # Gom tất cả vào 1 chuỗi
+    
+#     result = result.strip()
+#     return result
+
+
+def extract_quantity(input: str, full_test, data) -> str:
+    import base64
+    import os
+    import time
+    from google import genai
+    from google.genai import types
+
+    client = genai.Client(
+        api_key="AIzaSyBka2z9sIE-BIHXb9o2Z-hoZ6TPzXCDnac",
+    )
+
+    model = "gemini-2.5-flash-preview-05-20"
+
+    prompt = f"""
+Bạn là một chuyên gia trong việc trích xuất và lấy số lượng trong câu hỏi đồng thời lấy size sản phẩm ngoài ra bạn sẽ lấy tên sản phẩm kèm theo.
+Bạn sẽ thực hiện lấy đúng, chính xác số lượng sản phẩm đó.
+Ngoài ra hãy tham khảo thêm: {full_test} để xác xem liệu là sản phẩm nào thực sự bạn không cần phải lấy trong này có đề cập các sản phẩm không tồn tại. Nếu gặp không cần phải trích xuất dữ liệu chúng. Hãy ��ọc kĩ phân tích để tránh việc lấy nhầm sản phẩm không tồn tại.
+Phân biệt rõ ràng dù là Trà đào hay trà đào thì nó giống nhau khi viết thường vậy thì các sản phẩm khác cũng giống vậy. Không phải ưng cái thì trà chanh, cái thì Trà chanh điều này là sai hoàn toàn.
+Nhớ kĩ câu hỏi đầu vào của người dùng trong đó Người dùng hỏi: là câu hỏi trước đó người dùng nói khi đó trợ lý thấy thiếu sót điều gì sẽ hỏi lại và người dùng trả lời tiếp. Hãy nhớ Người dùng trả lời luôn là câu trả lời cuối cùng. 
+Khi thực hiện phân tích bạn hãy xem thêm phần data này: {data}. Đây là các trích xuất bản ghi trước đó khi câu hỏi người dùng đưa vào bạn phải vận dụng để tạo ra list phù hợp mà không làm hao phí data này.
+- Nếu data không có, không cần check nhưng nếu có data vui lòng check kĩ càng
+
+**Yêu cầu phản hồi:**
+- Chỉ trả về số lượng duy nhất sau khi thực hiện. Yêu cầu không giải thích gì thêm.
+- Nếu sản phẩm đó trùng tên nhưng khác size thì vẫn để riêng ra ví dụ ['"size": "M", "quantity": "5", name: "trà đào"', '"size": "L", "quantity": "3", name: "trà đào"']
+- Chỉ trả về kiểu số ví dụ 1,2,3,... Nếu không có bắt được thì vui lòng để None
+- Trả về Size duy nhất của sản phẩm. Nếu có nhiều size của sản phẩm thì phải trích xuất ra đúng ví dụ ['"size": "M", "quantity": "5", name: "trà đào"', '"size": "L", "quantity": "3", name: "trà đào"'] là cùng trà đào mà có size khác nhau. Vui lòng không tự sinh ra size của sản phẩm chỉ khi trong đó có thông tin về size của đúng sản phẩm đó thì mới lấy ra size của sản phẩm đó.
+- Vui lòng để nguyên tên sản phẩm ví dụ trà đào là trà đào nếu họ ghi Trà đào thì mới lấy Trà đào tức là không được thay đổi tên sản phẩm, viết hoa hay viết thường
+- Format trả về là: Json: "size": "M", "quantity": "5", name: "trà đào"
+- Nếu xóa sản phẩm đó thì vui lòng không hiển thị lại trong chuỗi. Xác định rõ sản phẩm nào cần xóa, sản phẩm nào cập nhật để điều chỉnh list một cách hợp lý
+- Ví dụ có nhiều sản phẩm thì json ghép trong 1 chuỗi
+
+**Văn bản đầu vào cần xử lý:**
+\"{input}\""""
+
+    contents = [
+        types.Content(
+            role="user",
+            parts=[
+                types.Part.from_text(text=prompt),
+            ],
+        )
+    ]
+
+    generate_content_config = types.GenerateContentConfig(
+        response_mime_type="application/json",
+    )
+
+    retries = 0
+    max_retries = 2
+    while retries <= max_retries:
+        try:
+            result = ""
+            for chunk in client.models.generate_content_stream(
+                model=model,
+                contents=contents,
+                config=generate_content_config,
+            ):
+                result += chunk.text
+            result = result.strip()
+            if result:  # Nếu có nội dung thì trả về luôn
+                return result
+        except Exception as e:
+            pass  # Có thể log lỗi nếu muốn
+        retries += 1
+        time.sleep(1)  # Nghỉ 1 giây trước khi thử lại
+
+    return "None"
+
+
+def generate_question(user_input: str, data_cleant: list, data_check: list, full_test: str) -> str:
+    import base64
+    import os
+    import time
+    from google import genai
+    from google.genai import types
+
+    client = genai.Client(
+        api_key="AIzaSyBka2z9sIE-BIHXb9o2Z-hoZ6TPzXCDnac",
+    )
+
+    model = "gemini-2.5-flash-preview-05-20"
+
+    prompt = f"""
+Bạn là một chuyên gia trong việc đặt câu hỏi làm rõ thông tin sản phẩm còn thiếu từ người dùng, dựa trên kết quả phân tích đầu vào.
+
+### 1. Mục tiêu:
+- Từ danh sách sản phẩm người dùng yêu cầu (`data_cleant`), kết hợp với kết quả kiểm tra (`data_check`), bạn cần tạo **một câu hỏi duy nhất** để làm rõ những thông tin còn thiếu hoặc chưa chính xác.
+- Hãy đọc kĩ phần mô tả: {full_test} để xác định xem liệu là với câu hỏi người dùng và data truyền vào các nhận xét này sẽ chỉ ra điểm yếu kém mã mỗi sản phầm còn tồn đọng. Nếu có hãy vui lòng tạo câu hỏi một cách chính xác, công tâm.
+- Luôn đảm bảo câu hỏi bao quanh được các nhận xét của mình.
+- Với các sản phẩm không tồn tại thì không cần hỏi nữa tuy nhiên nếu không còn sản phẩm gì thì hãy hỏi người dùng liệu có muốn mua sản phẩm khác hay không
+- Nếu không có gì cần hỏi thêm, chỉ trả về chuỗi "None" (không có dấu ngoặc) khi cảm thấy tất cả đã đáp ứng được.
+
+### 2. Định nghĩa dữ liệu:
+- `data_cleant`: danh sách sản phẩm đã được tách từ văn bản người dùng, mỗi phần tử gồm:
+  - "name": tên sản phẩm.
+  - "size": kích cỡ (có thể thiếu).
+  - "quantity": số lượng (có thể thiếu).
+
+- `data_check`: danh sách tương ứng (cùng thứ tự) với `data_cleant`, mỗi phần tử chứa kết quả kiểm tra:
+  - Nếu bắt đầu bằng ❌: sản phẩm không tồn tại → loại khỏi danh sách hỏi.
+  - Nếu chứa ⚠️: sản phẩm có tồn tại nhưng thiếu thông tin → cần hỏi lại.
+  - Nếu chứa ✅: sản phẩm hợp lệ và đầy đủ → không cần hỏi lại.
+
+### 3. Yêu cầu tạo câu hỏi:
+- Bỏ qua hoàn toàn các sản phẩm có `check` bắt đầu bằng ❌, không hỏi lại, chỉ có thể đề cập nhẹ rằng chúng đã bị loại.
+- Với các sản phẩm còn lại (⚠️ hoặc ✅):
+  - Nếu thiếu `size` hoặc `quantity`, hãy đặt **một câu hỏi duy nhất** để làm rõ toàn bộ phần còn thiếu.
+  - Nếu mọi thứ đã đầy đủ và hợp lệ, chỉ trả về "None".
+- Nếu data_cleant rỗng hoặc không có sản phẩm nào cần hỏi, hãy hỏi họ xem có muốn mua sản phẩm khác hay không
+
+### 4. Văn bản người dùng đã nhập:
+"{user_input}"
+
+### 5. Danh sách sản phẩm đã xử lý (`data_cleant`):
+{data_cleant}
+
+### 6. Kết quả kiểm tra từng sản phẩm (`data_check`):
+{data_check}
+
+### 7. Tổng hợp kết quả kiểm tra:
+{full_test}
+
+### ⚠️ Quy tắc bắt buộc:
+- **Chỉ trả về một câu hỏi duy nhất** hoặc chuỗi "None".
+- **Không giải thích, không liệt kê lại dữ liệu, không mô tả lại logic.**
+"""
+
+    contents = [
+        types.Content(
+            role="user",
+            parts=[
+                types.Part.from_text(text=prompt),
+            ],
+        )
+    ]
+
+    generate_content_config = types.GenerateContentConfig(
+        response_mime_type="application/json",
+    )
+
+    for attempt in range(3):  # thử tối đa 3 lần
+        try:
+            result = ""
+            for chunk in client.models.generate_content_stream(
+                model=model,
+                contents=contents,
+                config=generate_content_config,
+            ):
+                if chunk.text:
+                    result += chunk.text
+
+            return result.strip()
+        except Exception as e:
+            if attempt == 2:
+                raise e  # nếu thử 3 lần vẫn lỗi, raise ra ngoài
+            time.sleep(1)  # chờ 1s trước khi retry
+
+
+# def generate_question(user_input: str, data_cleant: list, data_check: list, full_test:str) -> str:
+#     import base64
+#     import os
+#     from google import genai
+#     from google.genai import types
+
+#     client = genai.Client(
+#         api_key="AIzaSyBka2z9sIE-BIHXb9o2Z-hoZ6TPzXCDnac",
+#     )
+
+#     model = "gemini-2.5-flash-preview-05-20"
+
+#     prompt = f"""
+# Bạn là một chuyên gia trong việc đặt câu hỏi làm rõ thông tin sản phẩm còn thiếu từ người dùng, dựa trên kết quả phân tích đầu vào.
+
+# ### 1. Mục tiêu:
+# - Từ danh sách sản phẩm người dùng yêu cầu (`data_cleant`), kết hợp với kết quả kiểm tra (`data_check`), bạn cần tạo **một câu hỏi duy nhất** để làm rõ những thông tin còn thiếu hoặc chưa chính xác.
+# - Hãy đọc kĩ phần mô tả: {full_test} để xác định xem liệu là với câu hỏi người dùng và data truyền vào các nhận xét này sẽ chỉ ra điểm yếu kém mã mỗi sản phầm còn tồn đọng. Nếu có hãy vui lòng tạo câu hỏi một cách chính xác, công tâm.
+# - Luôn đảm bảo câu hỏi bao quanh được các nhận xét của mình.
+# - Với các sản phẩm không tồn tại thì không cần hỏi nữa tuy nhiên nếu không còn sản phẩm gì thì hãy hỏi người dùng liệu có muốn mua sản phẩm khác hay không
+# - Nếu không có gì cần hỏi thêm, chỉ trả về chuỗi `"None"` (không có dấu ngoặc) khi cảm thấy tất cả đã đáp ứng được.
+
+# ### 2. Định nghĩa dữ liệu:
+# - `data_cleant`: danh sách sản phẩm đã được tách từ văn bản người dùng, mỗi phần tử gồm:
+#   - `"name"`: tên sản phẩm.
+#   - `"size"`: kích cỡ (có thể thiếu).
+#   - `"quantity"`: số lượng (có thể thiếu).
+
+# - `data_check`: danh sách tương ứng (cùng thứ tự) với `data_cleant`, mỗi phần tử chứa kết quả kiểm tra:
+#   - Nếu bắt đầu bằng `❌`: sản phẩm không tồn tại → loại khỏi danh sách hỏi.
+#   - Nếu chứa `⚠️`: sản phẩm có tồn tại nhưng thiếu thông tin → cần hỏi lại.
+#   - Nếu chứa `✅`: sản phẩm hợp lệ và đầy đủ → không cần hỏi lại.
+
+# ### 3. Yêu cầu tạo câu hỏi:
+# - Bỏ qua hoàn toàn các sản phẩm có `check` bắt đầu bằng `❌`, không hỏi lại, chỉ có thể đề cập nhẹ rằng chúng đã bị loại.
+# - Với các sản phẩm còn lại (⚠️ hoặc ✅):
+#   - Nếu thiếu `size` hoặc `quantity`, hãy đặt **một câu hỏi duy nhất** để làm rõ toàn bộ phần còn thiếu.
+#   - Nếu mọi thứ đã đầy đủ và hợp lệ, chỉ trả về `"None"`.
+# - Nếu data_cleant rỗng hoặc không có sản phẩm nào cần hỏi, hãy hỏi họ xem có muốn mua sản phẩm khác hay không
+
+# ### 4. Văn bản người dùng đã nhập:
+# \"{user_input}\"
+
+# ### 5. Danh sách sản phẩm đã xử lý (`data_cleant`):
+# {data_cleant}
+
+# ### 6. Kết quả kiểm tra từng sản phẩm (`data_check`):
+# {data_check}
+
+# ### 7. Tổng hợp kết quả kiểm tra:
+# {full_test}
+
+# ### ⚠️ Quy tắc bắt buộc:
+# - **Chỉ trả về một câu hỏi duy nhất** hoặc chuỗi `"None"`.
+# - **Không giải thích, không liệt kê lại dữ liệu, không mô tả lại logic.**
+# """
+
+#     contents = [
+#         types.Content(
+#             role="user",
+#             parts=[
+#                 types.Part.from_text(text=prompt),
+#             ],
+#         )
+#     ]
+
+#     generate_content_config = types.GenerateContentConfig(
+#         response_mime_type="application/json",
+#     )
+
+#     result = ""
+
+#     for chunk in client.models.generate_content_stream(
+#         model=model,
+#         contents=contents,
+#         config=generate_content_config,
+#     ):
+#         result += chunk.text
+
+#     return result.strip()
+
+
+
+
+example_json = [
+  { "name": "trà đào", "size": "S", "quantity": 2, "action": "update" },
+  { "name": "trà sữa", "size": "S", "action": "delete" },
+  { "name": "hồng trà", "size": "M", "quantity": 1, "action": "add" }
+]
+
+
+def classify_data(input: str,  structured_data,max_retries=3, retry_delay=1.0) -> str:
+    import base64
+    import os
+    from google import genai
+    from google.genai import types
+    client = genai.Client(
+        api_key="AIzaSyA4eTxl-suN_D8COMiRA5UmrF-6vW7etys",
+    )
+
+    model = "gemini-2.5-flash-preview-05-20"
+    prompt = f"""
+Bạn là một chuyên gia xử lý ngôn ngữ, có nhiệm vụ xác định **ý định** của người dùng đối với các sản phẩm (thêm, cập nhật hoặc xóa) và trích xuất chính xác thông tin liên quan.
+- Bên này chỉ  được  hỏi các sản phẩm liên quan đến đồ uống, nc ngọt, không đc phép thêm các sản phẩm thể loại khác nhu sách, phim, movie
+### Dữ liệu đầu vào:
+-  Câu query mới: "{input}"
+-  Dữ liệu sản phẩm cũ: {structured_data}
+---
+
+###  Yêu cầu xử lý:
+
+1. So sánh **câu query mới** và **Dữ liệu sản phẩm cũ** để xác định **ý định chính** của người dùng là:
+   - Xác định đúng tên sản phẩm, size được đề cập đến và nếu có hành động xóa thì phải gán thêm action đúng chỗ không phải tạo ra đối tượng khác.
+   - `add`: thêm sản phẩm mới. 
+   - `update`: cập nhật thông tin sản phẩm cũ (tên, size, số lượng).
+   - `delete`: xóa sản phẩm (có thể là một hoặc nhiều).
+2. Trích xuất dữ liệu dạng JSON list gồm các sản phẩm bị ảnh hưởng trong câu mới.
+2. Nếu là hành động thêm cần xác định rõ tên sản phẩm, size (nếu có) và số lượng (nếu có). Và ý nghĩa câu {input} ví dụ họ cũng thêm vào sản phẩm đã tồn tại đó thì quantity phải cộng lên hoặc giảm xuống.(Quan trọng)
+3. Mỗi sản phẩm trong JSON phải có các trường:
+   - `name`: tên sản phẩm.
+   - `size`: nếu có, ghi size. Nếu không có ghi "None". Phân biệt rõ size này là của sản phẩm nào.
+   - `quantity`: nếu có, ghi số lượng. Nếu không có ghi là 1. Nếu không có số lượng thì ghi là 1. Số lượng không bao giờ được phép ấm nếu trừ hay giảm mà âm hoặc bằng 0 thì phải gán là 0.
+   - `action`: hành động tương ứng (add / update / delete).
+   -  size_old: Nếu là hành động `update`, cần xác định rõ **size cũ** của sản phẩm để cập nhật.(Chỉ khi nào có yêu cầu thay thế size(thay thế size mà không đổi số lượng thì số lượng phải giữ nguyên), kích cỡ)
+4. Nếu là hành động `delete`, cần xác định rõ **tên và size** của sản phẩm cần xóa.
+6. Nếu có hành động thay sản phẩm này bằng sản phâm khác thì cần xác định rõ tên sản phẩm mới và size mới, khi đó sản phẩm mới size mới là add còn cái bị thay thế sẽ thành deleted.
+5. Nếu sản phẩm không đủ thông tin (thiếu tên), thì **bỏ qua** không thêm vào JSON.
+6. Nếu người dùng nói xóa toàn bộ sản phẩm, thì liệt kê tất cả sản phẩm hiện có trong structured_data với action là `delete`.
+7. Nếu không xác định được hành động nào, trả về `"None"`.
+8. Nếu đã có sản phẩm trong structured_data nhưng không được đề cập trong câu mới, thì giữ nguyên thông tin của sản phẩm đó. Nếu có đề cập thì xác định rõ ý định của người dùng
+**Yêu cầu phản hồi phải tuân theo:
+ -  Vui lòng trả về danh sách toàn bộ các sản phẩm gồm có các dữ liệu cũ và dữ liệu update, luôn thay dữ liệu cu c bằng dữ liệu mới nếu có update,delete nếu không có update,delete thì giữ nguyên dữ liệu cũ.
+ -  Dữ liệu insert,add cũng phải được thêm vào danh sách này, không được tạo ra một đối tượng khác mà phải là một chuỗi JSON nối tiếp với các sản phẩm khác.
+ -  Không được phép viết hoa tên sản phẩm, chỉ viết thường trừ khi bản gốc đã viết hoa. Không thêm dấu câu, không xuống dòng.
+ -  Luôn trả về đầy đủ gồm các sản phẩm size delete, update, add, insert trong một chuỗi JSON nối tiếp.
+---
+### ✅ Output mẫu (phải đúng định dạng JSON array, không xuống dòng, không giải thích):
+
+```json
+{example_json}
+```
+"""
+    contents = [
+        types.Content(
+            role="user",
+            parts=[
+                types.Part.from_text(text=f"""{prompt}"""),
+            ],
+        ),
+    ]
+    generate_content_config = types.GenerateContentConfig(
+        response_mime_type="application/json",
+    )
+
+    result = ""
+
+
+    for attempt in range(1, max_retries + 1):
+        try:
+            result = ""
+            for chunk in client.models.generate_content_stream(
+                model=model,
+                contents=contents,
+                config=generate_content_config,
+            ):
+                if chunk.text:
+                    result += chunk.text
+            return result.strip()
+        except Exception as e:
+            if attempt == max_retries:
+                raise RuntimeError(f"[Gemini classify_data failed] After {max_retries} attempts: {str(e)}")
+            else:
+                import time
+                print(f"[Retry {attempt}/{max_retries}] Error: {e}. Retrying in {retry_delay} seconds...")
+                time.sleep(retry_delay)
+
+
+def update_data(input: str, input_old, structured_data, max_retries: int = 2) -> str:
+    import base64
+    import os
+    import time
+    from google import genai
+    from google.genai import types
+
+    client = genai.Client(
+        api_key="AIzaSyBka2z9sIE-BIHXb9o2Z-hoZ6TPzXCDnac",
+    )
+
+    model = "gemini-2.5-flash-preview-05-20"
+
+    prompt = f"""
+Bạn là một chuyên gia trong việc cập nhật lại sản phẩm từ yêu cầu mới của người dùng dựa trên yêu cầu trước đó.
+
+- Câu query mới: {input}
+- Câu query cũ: {input_old}
+- Dữ liệu sản phẩm ban đầu được trích xuất từ câu cũ:
+{structured_data}
+
+**Yêu cầu xử lý:**
+
+1. So sánh giữa câu query mới và câu query cũ để xác định người dùng đã thay đổi gì: về tên sản phẩm, size, số lượng hoặc loại bỏ/thêm sản phẩm.
+2. Dựa vào structured_data, xác định các sản phẩm trong câu mới để cập nhật tương ứng.
+3. Nếu người dùng đổi tên sản phẩm, thì thay thế sản phẩm cũ gần nhất (vị trí hoặc tên) bằng sản phẩm mới đó.
+4. Nếu người dùng cập nhật size cho sản phẩm, thì ghi đè size mới.
+5. Nếu người dùng không nói rõ size, nhưng sản phẩm đó đã tồn tại trong structured_data, thì giữ nguyên size cũ.
+6. Nếu người dùng cập nhật số lượng, thì ghi đè lại số lượng theo câu mới.
+7. Nếu có sản phẩm mới hoàn toàn chưa có trong structured_data và đủ thông tin (tên, số lượng, size), thì thêm vào danh sách.
+8. Nếu sản phẩm mới không có đủ thông tin (thiếu tên, size hoặc số lượng), thì bỏ qua không thêm.
+9. Nếu một sản phẩm trong structured_data không bị thay đổi hoặc nhắc đến trong câu mới, thì giữ nguyên thông tin sản phẩm đó.
+10. Nếu không thể xác định được bất kỳ sản phẩm nào trong câu mới, thì trả về "None"
+11. Nếu người dùng có đề cập giữ lại thì xác định xem có sản phẩm nào trong structured_data không bị thay đổi thì giữ lại sản phẩm đó.
+12. Nếu người dùng nói mua thêm hay thêm sản phẩm(các từ có ngữ ý là mua sản phẩm khác) mà không có trong structured_data thì bạn sẽ thêm sản phẩm mới vào danh sách
+**Phản hồi chỉ gồm chuỗi JSON không giải thích gì thêm. Mỗi sản phẩm là một object JSON trong chuỗi nối tiếp, ví dụ:**
+
+**Tuyệt đối không viết hoa tên sản phẩm trừ khi bản gốc đã viết hoa. Không thêm dấu câu, không xuống dòng.**
+
+**Văn bản đầu vào mới cần xử lý:**
+"{input}"
+"""
+
+    contents = [
+        types.Content(
+            role="user",
+            parts=[types.Part.from_text(prompt)],
+        ),
+    ]
+    generate_content_config = types.GenerateContentConfig(
+        response_mime_type="application/json",
+    )
+
+    for attempt in range(max_retries + 1):
+        result = ""
+        try:
+            for chunk in client.models.generate_content_stream(
+                model=model,
+                contents=contents,
+                config=generate_content_config,
+            ):
+                if chunk.text:
+                    result += chunk.text
+
+            result = result.strip()
+            if result:
+                return result
+
+        except Exception as e:
+            print(f"[Lần {attempt + 1}] Lỗi khi gọi Gemini: {e}")
+            time.sleep(1)
+
+    raise RuntimeError("Không thể tạo dữ liệu cập nhật sau nhiều lần thử.")
+
+
+# def update_data(input: str, input_old, structured_data) -> str:
+#     import base64
+#     import os
+#     from google import genai
+#     from google.genai import types
+#     client = genai.Client(
+#         api_key="AIzaSyBka2z9sIE-BIHXb9o2Z-hoZ6TPzXCDnac",
+#     )
+
+#     model = "gemini-2.5-flash-preview-05-20"
+#     prompt = f"""
+# Bạn là một chuyên gia trong việc cập nhật lại sản phẩm từ yêu cầu mới của người dùng dựa trên yêu cầu trước đó.
+
+# - Câu query mới: {input}
+# - Câu query cũ: {input_old}
+# - Dữ liệu sản phẩm ban đầu được trích xuất từ câu cũ:
+# {structured_data}
+
+# **Yêu cầu xử lý:**
+
+# 1. So sánh giữa câu query mới và câu query cũ để xác định người dùng đã thay đổi gì: về tên sản phẩm, size, số lượng hoặc loại bỏ/thêm sản phẩm.
+# 2. Dựa vào structured_data, xác định các sản phẩm trong câu mới để cập nhật tương ứng.
+# 3. Nếu người dùng đổi tên sản phẩm, thì thay thế sản phẩm cũ gần nhất (vị trí hoặc tên) bằng sản phẩm mới đó.
+# 4. Nếu người dùng cập nhật size cho sản phẩm, thì ghi đè size mới.
+# 5. Nếu người dùng không nói rõ size, nhưng sản phẩm đó đã tồn tại trong structured_data, thì giữ nguyên size cũ.
+# 6. Nếu người dùng cập nhật số lượng, thì ghi đè lại số lượng theo câu mới.
+# 7. Nếu có sản phẩm mới hoàn toàn chưa có trong structured_data và đủ thông tin (tên, số lượng, size), thì thêm vào danh sách.
+# 8. Nếu sản phẩm mới không có đủ thông tin (thiếu tên, size hoặc số lượng), thì bỏ qua không thêm.
+# 9. Nếu một sản phẩm trong structured_data không bị thay đổi hoặc nhắc đến trong câu mới, thì giữ nguyên thông tin sản phẩm đó.
+# 10. Nếu không thể xác định được bất kỳ sản phẩm nào trong câu mới, thì trả về "None"
+# 11. Nếu người dùng có đề cập giữ lại thì xác định xem có sản phẩm nào trong structured_data không bị thay đổi thì giữ lại sản phẩm đó.
+# 12. Nếu người dùng nói mua thêm hay thêm sản phẩm(các từ có ngữ ý là mua sản phẩm khác) mà không có trong structured_data thì bạn sẽ thêm sản phẩm mới vào danh sách
+# **Phản hồi chỉ gồm chuỗi JSON không giải thích gì thêm. Mỗi sản phẩm là một object JSON trong chuỗi nối tiếp, ví dụ:**
+
+
+# **Tuyệt đối không viết hoa tên sản phẩm trừ khi bản gốc đã viết hoa. Không thêm dấu câu, không xuống dòng.**
+
+# **Văn bản đầu vào mới cần xử lý:**
+# "{input}"
+
+# """
+#     contents = [
+#         types.Content(
+#             role="user",
+#             parts=[
+#                 types.Part.from_text(text=f"""{prompt}"""),
+#             ],
+#         ),
+#     ]
+#     generate_content_config = types.GenerateContentConfig(
+#         response_mime_type="application/json",
+#     )
+
+#     result = ""
+
+#     for chunk in client.models.generate_content_stream(
+#     model=model,
+#     contents=contents,
+#     config=generate_content_config,
+# ):
+#       result += chunk.text
+    
+#     result = result.strip()
+#     return result
+
+
+def validate_products(data_list, server_java):
+    validated_data = []
+    
+    for product in data_list:
+        product_name = product.get("name")
+        product_size = product.get("size")
+
+        if product_name not in [None, "", "None"] and product_size not in [None, "", "None"]:
+            check = server_java.search_product(keyword=product_name, size=product_size)
+
+            if check is None:
+                # Không thêm sản phẩm này vào danh sách kết quả
+                print(f"❌ Không tồn tại sản phẩm '{product_name}' với size '{product_size}'")
+                continue  # bỏ qua sản phẩm này
+
+            # Nếu tồn tại nhưng không có size
+            if isinstance(check, tuple) and (len(check) > 2 and check[2] in [None, "", "None"]):
+                product["check"] = f"⚠️ Sản phẩm '{product_name}' không có size '{product_size}'"
+            else:
+                product["check"] = f"✅ Sản phẩm '{product_name}' với size '{product_size}' tồn tại"
+
+            validated_data.append(product)
+
+        else:
+            product["check"] = "⚠️ Thiếu thông tin sản phẩm (name hoặc size)"
+            validated_data.append(product)
+
+    return validated_data
+
+
+def validate_product_list(data_list, server_java):
+    print(data_list)
+    annotated_list = []
+    clean_list = []
+    full_test = ""
+
+    for product in data_list:
+        product_copy = product.copy()
+        product_name = product_copy.get("name")
+        product_size = product_copy.get("size")
+
+        if product_name not in [None, "", "None"]:
+            check = server_java.search_product(keyword=product_name, size=product_size)
+
+            if check is None:
+                full_test += f".Không tồn tại sản phẩm '{product_name}' với size '{product_size} \n"
+                product_copy["check"] = f"❌ Không tồn tại sản phẩm '{product_name}' với size '{product_size}'"
+                product_copy["deleted"] = True
+            elif isinstance(check, tuple) and (len(check) > 2 and check[2] in [None, "", "None"]):
+                product_copy["check"] = f"⚠️ Sản phẩm '{product_name}' không có size '{product_size}'"
+                full_test += f".Không tồn tại sản phẩm '{product_name}' không có size '{product_size}"
+                product_copy["deleted"] = True
+            else:
+                product_copy["check"] = f"✅ Sản phẩm '{product_name}' với size '{product_size}' tồn tại"
+                if  int(check[3]) == 0:
+                    full_test += f".Sản phẩm '{product_name}' size '{product_size} hiện tại không còn hàng"
+                    product_copy["deleted"] = True
+                if product['quantity'] in [None, "", "None"]:
+                    full_test += f".Sản phẩm '{product_name}' size '{product_size} chưa nhập số lượng"
+                elif int(check[3]) < int(product['quantity']):
+                    full_test += f".Sản phẩm '{product_name}' size '{product_size} hiện tại không có đủ số lượng, số lượng còn lại chỉ là tầm {int(check[3])}"    
+        else:
+            product_copy["check"] = "⚠️ Thiếu thông tin sản phẩm (name hoặc size)"
+
+        annotated_list.append(product_copy)
+
+        if not product_copy.get("deleted", False):
+            # Tạo một bản sao sạch chỉ chứa các trường cần thiết
+            clean_item = {
+                "name": product_copy.get("name"),
+                "size": product_copy.get("size"),
+                "quantity": product_copy.get("quantity"),
+                "check": product_copy.get("check")
+            }
+            clean_list.append(clean_item)
+
+    return annotated_list, clean_list, full_test
+
+
+
+
+

function/advance_shopping/prompt/context_prompt.py

@@ -0,0 +1,38 @@
+def build_context_prompt(chat_history: str, cart_exists: str) -> str:
+    """
+    Tạo prompt đầu vào cho LLM dựa trên đoạn hội thoại và trạng thái giỏ hàng.
+
+    Parameters:
+    - chat_history (str): Đoạn hội thoại giữa chatbot và người dùng.
+    - cart_exists (str): "Yes" nếu còn giỏ hàng, "No" nếu không.
+
+    Returns:
+    - str: Prompt hoàn chỉnh để gửi cho LLM.
+    """
+    return f"""
+Bạn là một chuyên gia trong việc xử lý ngữ cảnh hội thoại để hỗ trợ mua sắm.
+
+Tôi sẽ cung cấp cho bạn:
+- Một đoạn hội thoại giữa chatbot và người dùng (chat_history).
+- Trạng thái giỏ hàng (cart_exists), giá trị là "Yes" nếu người dùng đang còn giỏ hàng, "No" nếu không.
+
+Yêu cầu:
+- Nếu cart_exists là "Yes", bạn phải đưa ra **một câu hỏi duy nhất** để hướng người dùng quay lại việc mua sản phẩm, dựa vào đoạn hội thoại trước.
+- Nếu cart_exists là "No", chỉ trả về "None", không thêm bất kỳ nội dung nào khác.
+- Không tóm tắt, không giải thích, chỉ trả về câu hỏi hoặc "None".
+
+Nếu câu trả lời bạn tạo ra có ý hỏi người dùng về việc thêm, xóa, sửa sản phẩm vào giỏ hay tạo thanh toán thì hãy trả thêm một biến gọi là is_question_orders và gán là True nếu không có hãy gán là False.
+Hãy trả về format Json gồm có hai biến là question và  is_question_orders
+
+
+Dữ liệu đầu vào:
+chat_history:
+{chat_history}
+
+cart_exists: {cart_exists}
+
+Trả lời:
+""".strip()
+
+
+

function/advance_shopping/prompt/multitool_prompt.py

@@ -0,0 +1,83 @@
+example_json_multi_prompt = {
+  "question": "Thêm sản phẩm nước ép xoài size H vào giỏ hàng, xóa sản phẩm trà chanh khỏi giỏ hàng.",
+  "question_normal": {
+    "question_normal1": "Xem danh sách các bài viết mới."
+  },
+  "confirm_order": False
+}
+
+
+def build_multi_tool_prompt(question: str, user_answer: str, tools: list) -> str:
+ tool_list = ", ".join(tools)
+ prompt = f"""Bạn là một chuyên gia trong việc phân tích ý định người dùng để xác định **tất cả hành động** cần thực hiện trong hệ thống bán hàng.
+
+### Dữ liệu đầu vào:
+- Một câu hỏi từ hệ thống gửi tới người dùng:
+question: "{question}"
+
+- Một câu trả lời từ người dùng:
+user_answer: "{user_answer}"
+
+- Danh sách các tool khả dụng:
+{tool_list}
+
+---
+
+### Danh sách tool và chức năng:
+- `insert_cart`: Thêm sản phẩm vào giỏ hàng
+- `update_cart`: Cập nhật thông tin sản phẩm đã có trong giỏ hàng (ví dụ: size, số lượng)
+- `delete_item_cart`: Xoá một sản phẩm cụ thể khỏi giỏ hàng
+- `deleted all cart`: Xoá toàn bộ giỏ hàng
+- `confirm_order`: Xác nhận đơn hàng hiện tại
+
+---
+
+### Yêu cầu:
+1. Phân tích kỹ câu trả lời của người dùng.
+2. Xác định **mọi hành động** mà người dùng mong muốn thực hiện.
+3. Gán đúng với một trong các tool trong danh sách.
+4. Với các tool `insert_cart`, `update_cart`, `delete_item_cart`, cần có các tham số:
+   - `product_name`: tên sản phẩm (bắt buộc)
+   - `size`: kích cỡ (nếu có)
+   - `quantity`: số lượng (nếu có)
+5. Các tool `confirm_order` và `deleted all cart` không cần tham số.
+7. Yêu cầu đặt hàng mà vẫn có các thông tin về tên sản phẩm hoặc size hay cả hai đều phải giữ lại trong question
+6. Các câu nói về xác nhận thanh toán, xem giỏ hàng đều không cần để question
+
+---
+
+### Định dạng đầu ra:
+ạn chỉ cần viết lại một câu duy nhất mô tả lại các hành động bằng ngôn ngữ tự nhiên và xác định rõ tên sản phẩm mà họ đề cập. Vui lòng viết rõ ràng chính xác để có thể hiểu bạn nói gì nghĩa là dùng , cho các hành động khác. Nếu có yêu cầu xác nhận thanh toán thì thêm một trường là confirm_orders và câu hỏi sẽ đc đưa vào question. Sau đó hãy trả về Json
+Bạn sẽ nhận được một câu mô tả hành động từ người dùng.
+Hãy đọc kỹ và phân loại nội dung theo 3 yêu cầu sau:
+1. question:
+- Viết lại duy nhất một câu mô tả đầy đủ các hành động liên quan đến việc mua hàng, bao gồm:
+ + Thêm/xóa sản phẩm khỏi giỏ hàng
+ + Chọn size, loại sản phẩm
+ + Đặt hàng, xác nhận đơn hàng
+ + Các thao tác với đơn hàng, giỏ hàng, thanh toán
+ + Hành động phải nối bằng dấu phẩy “,”, và ghi rõ tên sản phẩm, size nếu có.
+ + Các câu nói về xác nhận thanh toán, xem giỏ hàng, xóa vật phẩm trong giỏ hàng đều không cần để question
+2. question_normal:
+- Tách các câu hỏi hoặc hành động không liên quan đến việc mua hàng, như:
+  + Xem bài viết, tra cứu thông tin, hỏi khuyến mãi
+  + Xem bài đăng, thời gian mở cửa, v.v.
+  + Trả về dưới dạng dictionary với các khóa: question_normal1, question_normal2, ...
+  + Nhưng nếu câu hỏi đó liên quan đến việc xem sản phẩm trong giỏ hàng, đơn hàng hay các hành động liện quan có giỏ hàng, đơn hàng thì vui lòng không bỏ vào question_normal
+3. confirm_order:
+  + Gán giá trị true nếu câu chứa hành động xác nhận đơn hàng hoặc thanh toán (ví dụ: “xác nhận đơn hàng”, “đặt mua”, “tôi muốn thanh toán”,...)
+  + Gán false nếu không có hành động đó.
+. Trả về một JSON gồm 3 trường:
+Ví dụ: 
+"question": theo mô tả của minh ỏ trên.  Các câu nói về xác nhận thanh toán, xem giỏ hàng, xóa vật phẩm trong giỏ hàng đều không cần để question chỉ cần để.  Yêu cầu đặt hàng mà vẫn có các thông tin về tên sản phẩm hoặc size hay cả hai đều phải giữ lại question ""
+"question chỉ trống khi câu đó riêng lẻ là xác nhận mua hàng, tôi muốn mua hàng, đặt hàng, tiến hành thanh toán,..."
+"question_normal": theo mô tả trên
+"confirm_order": true hoặc false
+
+
+Ví dụ trả về: 
+{example_json_multi_prompt}
+
+Bắt đầu phân tích dữ liệu sau đây."""
+
+ return prompt

function/advance_shopping/prompt/user_intent.py

@@ -0,0 +1,127 @@
+json_example = {
+  "type": """ "shopping_question" | "normal_question" | "unclear" """,
+  "clarification_question_if_unclear": """ "string | null" """,
+  "is_confirm_cart": """ Yes  | No""",
+  "is_deleted_cart": """ Yes | No""",
+  "is_confirm_order": """Yes | No """,
+  "is_deleted_order": """ Yes| No""",
+  "is_view_cart": """ Yes| No""",
+}
+
+
+
+
+def build_detailed_user_intent_prompt(cart_status: str, chat_history: str, user_question: str) -> str:
+    prompt = f"""
+Bạn là một hệ thống phân tích hội thoại thông minh trong lĩnh vực thương mại điện tử, có nhiệm vụ xác định ý định của người dùng dựa trên hội thoại với chatbot và trạng thái giỏ hàng hiện tại.
+
+### Mục tiêu:
+Phân loại **câu hỏi mới nhất của người dùng** vào một trong ba nhóm ý định sau:
+
+---
+
+### 1. `shopping_question` – Câu hỏi mang ý định mua sắm
+
+**Định nghĩa**: Là câu hỏi thể hiện mong muốn của người dùng muốn thực hiện một hành động mua sắm online hoặc tương tác với các chức năng thương mại điện tử.
+
+**Các hành động phổ biến cần nhận diện:**
+- Thêm sản phẩm vào giỏ hàng  → `add_to_cart`
+- Xác nhận đơn hàng → `confirm_order`
+- Tiến hành thanh toán → `checkout`
+- Kiểm tra giỏ hàng hiện tại → `view_cart`
+- Xóa sản phẩm khỏi giỏ hàng → `remove_item`
+- Đặt hàng → `place_order`
+
+** Các câu hỏi về sản phẩm, xem sản phẩm không liên quan tới loại này
+** Các từ hỏi về thông tin đơn hàng, tình trạng giao đơn hay hỏi về quá trình đơn không liên quan đến này
+
+**Từ khóa thường gặp:**
+- **Động từ**: mua, buy, đặt, order, xác nhận, thanh toán,  kiểm tra
+- **Đối tượng**: sản phẩm, món, đồ, item, giỏ hàng,  đơn hàng, order(Vui lòng kèm theo động từ ở trên)
+
+**Phân loại là `shopping_question` nếu**:
+- Có ý định thực hiện hành động thương mại rõ ràng(tôi muốn mua, thêm sản phẩm, xóa sản phẩm, loại bỏ,..)
+- Nhắc đến giỏ hàng
+- Có động từ hành động và danh từ liên quan mua sắm
+- **Các hành động liên quan đến việc xem thông tin, dữ liệu sản phẩm(xem sản phẩm trà chanh, thông tin về cà phê,...) không được tính là shopping_question`**. Quan trọng
+
+---
+
+### 2. `normal_question` – Câu hỏi thông thường không liên quan đến giao dịch
+
+**Ví dụ**:
+- Hỏi thông tin về thương hiệu, xuất xứ
+- Hỏi về khuyến mãi, giờ mở cửa
+- Tư vấn không đi kèm hành động mua cụ thể
+
+---
+
+### 3. `unclear` – Không rõ ý định
+
+**Khi nào áp dụng?**
+- Câu nói mơ hồ, không đủ thông tin để xác định
+- Có thể là ý định mua nhưng chưa rõ ràng
+
+**Yêu cầu bổ sung nếu chọn `unclear`:**
+- Đề xuất một câu hỏi gợi mở giúp làm rõ thêm ý định người dùng  
+  *(Ví dụ: "Bạn muốn mình thêm món đó vào giỏ luôn không ạ?")*
+
+---
+##is_confirm_cart: Yes | No
+Mô tả: Xác định xem người dùng có yêu cầu xác nhận hoặc đồng ý với nội dung giỏ hàng hiện tại hay không (ví dụ: "giỏ hàng của tôi đã đúng chưa?", "tôi xác nhận giỏ hàng này").
+Yes: Người dùng muốn xác nhận nội dung giỏ hàng.
+No: Người dùng không xác nhận giỏ hàng (mà có thể thêm/xóa sản phẩm, xem giỏ, v.v.).
+###is_deleted_cart: Yes | No
+Mô tả: Xác định xem người dùng có yêu cầu xóa toàn bộ giỏ hàng hiện tại hay không, xóa toàn bộ sản phẩm đã thêm vào hay không
+Yes: Người dùng muốn xóa giỏ hàng.
+No: Người dùng không muốn xóa giỏ hàng.
+###is_confirm_order: Yes | No
+Mô tả: Xác định xem người dùng có ý định xác nhận, hoàn tất, hoặc tiến hành đặt/mua ngay lập tức một đơn hàng hoặc sản phẩm hay không. Đây là điểm mà bạn đã góp ý.
+Yes: Nếu người dùng sử dụng các từ ngữ như "xác nhận đơn hàng", "đặt hàng", "mua luôn", "thanh toán", "quyết định mua", hoặc các câu lệnh rõ ràng thể hiện mong muốn hoàn tất giao dịch (chứ không chỉ dừng lại ở việc thêm vào giỏ hàng). Kể cả khi có yêu cầu "thêm vào giỏ" kèm theo một ý định mua sắm mạnh mẽ và hoàn tất (ví dụ: "thêm vào giỏ và mua luôn", "thêm vào giỏ, tôi quyết định mua sản phẩm này"), thì giá trị này vẫn là Yes.
+No: Nếu người dùng chỉ muốn thêm sản phẩm vào giỏ hàng, xem giỏ hàng, xóa sản phẩm khỏi giỏ hàng, hoặc các hành động khác mà không đi kèm ý định hoàn tất giao dịch ngay lập tức.
+###is_deleted_order: Yes| No
+Mô tả: Xác định xem người dùng có yêu cầu hủy bỏ một đơn hàng đã được đặt hoặc đang trong quá trình xử lý hay không.
+Yes: Người dùng muốn hủy đơn hàng.
+No: Người dùng không muốn hủy đơn hàng.
+###is_view_cart: Yes| No
+Mô tả: Xác định xem người dùng có yêu cầu muốn xem thông tin về giỏ hàng, sản phẩm trong giỏ(Chỉ kèm theo khi có đề cập giỏ hàng, đơn hàng), sản phẫm nãy giờ nguời dùng đã thêm cập nhật vào giỏ
+Yes: Người dùng muốn xem giỏ hàng, đơn hàng, danh sách sản phẩm nãy giờ mà người dùng đã thêm(Phải kiểm tra xem có kèm theo giỏ hàng, đơn hàng đồ không) .
+No: Người dùng không muốn xem.
+
+### Phân tích bổ sung:
+Ngoài phân loại chính, bạn cũng cần **trích xuất xem câu nói có chứa hành động nào sau đây không**:
+- Tạo giỏ hàng mới
+- Xóa giỏ hàng
+- Xác nhận tạo đơn hàng
+- Hủy đơn hàng
+- Xem đơn hàng
+- Nếu câu hỏi người dùng kết hợp nhiều ý ví dụ xem xong rồi xác nhận mua, xem xong rồi xóa thì hãy vui lòng đánh dấu thêm thứ tự thực hiện trong đó.
+
+---
+
+### DỮ LIỆU ĐẦU VÀO
+
+**Trạng thái giỏ hàng hiện tại:**  
+{cart_status}
+
+**Lịch sử hội thoại gần nhất:**  
+\"\"\"\n{chat_history.strip()}\n\"\"\"  
+
+**Câu hỏi hiện tại của người dùng:**  
+\"{user_question.strip()}\"
+
+---
+
+### ĐỊNH DẠNG ĐẦU RA (JSON)
+
+```json
+{json_example}
+Hãy phân tích cẩn thận dựa trên ngữ cảnh trước khi đưa ra kết luận.
+Luôn Đảm bảo trong câu trả lời luôn đảm bảo trong json trả về có 'question'. Tuyệt đối không được phép trả dữ liệu mà không có trường question.
+Hãy xem xét kĩ xem câu hỏi người dùng có phải mua sắm hay không hay chỉ đơn thuần là câu hỏi khác nếu có hãy tách chúng ra.
+"""
+    return prompt.strip()
+  
+# data =  build_detailed_user_intent_prompt("No","","Xem giỏ hàng của tôi")
+# with open("user_intent_prompt.txt", "w", encoding="utf-8") as f:
+#     f.write(data)

function/advance_shopping/server_java/config.yaml

@@ -0,0 +1,53 @@
+frontend:
+  web_payment_base: "http://localhost:5173"
+  base: "http://localhost:5173"
+  web_redirect_paths:
+    zalo: "payment-online-status"
+    momo: "payment-online-status-momo"
+    payos: "payment-online-status-payos"
+    vnpay: "payment-online-status-vnpay"
+  android_redirect_base: "myapp://open/order-complete"
+  android_group_redirect_base: "myapp://open/order-group-complete"
+
+
+callback_urls:
+  base: http://localhost:1010
+  zalo:
+    single:
+      web: 
+        callback: api/payment/zalo/callback
+      android:
+        callback: api/payment/zalo/callback
+    group:
+      android:
+         callback: api/payment-group/zalo/callback
+      
+  momo:
+    single:
+      web: 
+        callback: api/payment/momo/callback
+      android:
+        callback: api/payment/momo/callback
+    group:
+      android:
+         callback: api/payment-group/momo/callback
+
+  payos:
+    single:
+      web: 
+        callback: api/payment/payOS/callback
+      android:
+        callback: api/payment/payOS/callback
+    group:
+      android:
+         callback: api/payment-group/payOS/callback
+  
+  vnpay:
+    single:
+      web: 
+        callback: api/payment/vnpay_ipn
+      android:
+        callback: api/payment/vnpay_ipn
+    group:
+      android:
+         callback: api/payment-group/vnpay_ipn

function/advance_shopping/server_java/server_java.py

@@ -0,0 +1,338 @@
+import requests
+import urllib.parse
+import yaml
+with open("config.yaml", "r") as f:
+    config = yaml.safe_load(f)
+base_backend_java  = config["callback_urls"]["base"]
+base_frontend = config["frontend"]["base"]
+api = base_backend_java
+def search_product(keyword, page=1,  limit=5, language="VN", size=None):
+    encoded_keyword = urllib.parse.quote(keyword)
+    print(api)
+    url = f"{api}/api/product/search?keyword={encoded_keyword}&page={page}&limit={limit}&language={language}"
+    print(url)
+    try:
+        response = requests.get(url)
+        response.raise_for_status()
+        data = response.json()
+
+        # Lấy danh sách sản phẩm
+        products = data.get("productResponseList", [])
+        if not products:
+            print("⚠️ Không tìm thấy sản phẩm.")
+            return None
+
+        # Lấy sản phẩm đầu tiên
+        first_product = products[0]
+        pro_id = first_product.get("proId")
+        pro_name = first_product.get("proName")
+        variants = first_product.get("listProductVariants", [])
+
+
+       
+        size_check = ""
+        stock_check = 0
+        price_check = 0
+        for v in variants:
+            if  v['size'] == size:
+                size_check = v['size']
+                stock_check = v['stock']
+                price_check = v['price']
+                break
+            # print(f"  + Size: {v['size']}, Giá: {v['price']} VND, Tồn kho: {v['stock']}")
+
+        return pro_id, pro_name, size_check, stock_check, price_check
+
+    except requests.RequestException as e:
+        print(f"❌ Lỗi kết nối: {e}")
+    except ValueError:
+        print("❌ Lỗi parse JSON.")
+
+
+def insert_cartItem(userId: int, cart_id: int, proId:int, size, quantity, token:str = "",  language="VN"):
+    url = f"{api}/api/cart-item/insert"
+    headers = {
+        "Authorization": f"Bearer {token}",
+        "Content-Type": "application/json",
+    }
+
+    body = {
+        "userId": userId,
+        "cartId": cart_id,
+        "proId": proId,
+        "size": size,
+        "quantity": quantity,
+        "language": language
+    }
+
+    try:
+        response = requests.post(url, json=body, headers=headers)
+        # response.raise_for_status()
+        if not response.ok:
+            print("❌ Lỗi HTTP", response.status_code)
+            try:
+                print("📦 Nội dung lỗi JSON:", response.json())
+            except Exception:
+                print("📜 Nội dung lỗi (text):", response.text)
+            return None
+        return response.json()
+
+    except requests.exceptions.RequestException as e:
+        print("Lỗi khi gọi API:", e)
+        return None
+
+
+def update_cartItem_quantity(userId: int, cartItemId: int, quantity, token):
+    url = f"{api}/api/cart-item/update"
+    headers = {
+        "Authorization": f"Bearer {token}",
+        "Content-Type": "application/json",
+    }
+
+    body = {
+        "userId": userId,
+        "cartItemId": cartItemId,
+        "quantity": quantity,
+    }
+    response = requests.put(url, json=body, headers=headers)
+    try:
+        
+        # response.raise_for_status()
+        if not response.ok:
+            print("❌ Lỗi HTTP", response.status_code)
+            try:
+                print("📦 Nội dung lỗi JSON:", response.json())
+            except Exception:
+                print("📜 Nội dung lỗi (text):", response.text)
+            return None
+        return response.json()
+    except requests.exceptions.RequestException as e:
+        print("Lỗi khi gọi API:", e)
+        return response.content
+
+
+def update_cartItem_size(userId: int, cartItemId: int, size, token):
+    url = f"{api}/api/cart-item/change-size"
+    headers = {
+        "Authorization": f"Bearer {token}",
+        "Content-Type": "application/json",
+    }
+
+    body = {
+        "userId": userId,
+        "cartItemId": cartItemId,
+        "size": size,
+    }
+    try:
+        response = requests.put(url, json=body, headers=headers)
+        
+        if not response.ok:
+            print("❌ Lỗi HTTP", response.status_code)
+            try:
+        
+                return response.json()
+            except Exception:           
+                return response.text
+        return response.json()
+    except requests.exceptions.RequestException as e:
+        print("Lỗi khi gọi API:", e)
+        
+
+def remove_one_cartItem( userId, cartItemId,token):
+    url = f"{api}/api/cart-item/delete/{cartItemId}"
+    headers = {
+        "Authorization": f"Bearer {token}",
+        "Content-Type": "application/json",
+    }
+
+    body = {
+        "userId": userId,
+        "cartItemId": cartItemId,
+    }
+
+    try:
+        response = requests.delete(url, json=body, headers=headers)
+        response.raise_for_status()
+        if not response.ok:
+            print("❌ Lỗi HTTP", response.status_code)
+            try:
+                print("📦 Nội dung lỗi JSON:", response.json())
+                return response.json()
+            except Exception:
+                
+                print("📜 Nội dung lỗi (text):", response.text)
+                return response.text
+            return None
+        return response.json()
+    except requests.exceptions.RequestException as e:
+        print("Lỗi khi gọi API:", e)
+        return None
+
+
+def remove_all_cartItem(userId, cartId,token):
+    url = f"{api}/api/cart/delete-allItem/{cartId}"
+    headers = {
+        "Authorization": f"Bearer {token}",
+        "Content-Type": "application/json",
+    }
+
+    body = {
+        "userId": userId,
+        "cartId": cartId,
+    }
+
+    try:
+        response = requests.delete(url, json=body, headers=headers)
+        if not response.ok:
+            print("❌ Lỗi HTTP", response.status_code)
+            try:
+                print("📦 Nội dung lỗi JSON:", response.json())
+                return response.json()
+            except Exception:
+                
+                print("📜 Nội dung lỗi (text):", response.text)
+                return response.text
+        return response.json() 
+    except requests.exceptions.RequestException as e:
+        print("Lỗi khi gọi API:", e)
+        return None
+
+
+def create_orders(user_id, cartId, token, language="VN"):
+    url = f"{api}/api/orders/create"
+    headers = {
+        "Authorization": f"Bearer {token}",
+        "Content-Type": "application/json",
+    }
+
+    body = {
+        
+  "userId": user_id,
+  "cartId": cartId,
+  "voucherId": "string",
+  "pointCoinUse": 0,
+  "note": "string",
+  "language": language
+
+    }
+
+    try:
+        response = requests.post(url, json=body, headers=headers)
+        if not response.ok:
+            print("❌ Lỗi HTTP", response.status_code)
+            try:
+                print("📦 Nội dung lỗi JSON:", response.json())
+                return response.json()
+            except Exception:
+                print("📜 Nội dung lỗi (text):", response.text)
+                return response.text
+        return response.json()  
+    except requests.exceptions.RequestException as e:
+        print("Lỗi khi gọi API:", e)
+        return None
+
+
+def confirm_orders_AI(user_id,token, orderId):
+    url = f"{api}/api/orders/confirm"
+    headers = {
+        "Authorization": f"Bearer {token}",
+        "Content-Type": "application/json",
+    }
+    body = {
+
+  "userId": user_id,
+  "orderId": orderId,
+
+    }
+
+    try:
+        response = requests.post(url, json=body, headers=headers)
+        if not response.ok:
+            print("❌ Lỗi HTTP", response.status_code)
+            try:
+                print("📦 Nội dung lỗi JSON:", response.json())
+                return response.json()
+            except Exception:
+                print("📜 Nội dung lỗi (text):", response.text)
+                return response.text
+        return response.json()
+    except requests.exceptions.RequestException as e:
+        print("Lỗi khi gọi API:", e)
+        return None
+  
+
+def confirm_cancel_AI(user_id,token, orderId):
+    url = f"{api}/api/orders/confirm-cancel-ai"
+    headers = {
+        "Authorization": f"Bearer {token}",
+        "Content-Type": "application/json",
+    }
+    body = {
+
+  "userId": user_id,
+  "orderId": orderId,
+
+    }
+
+    try:
+        response = requests.post(url, json=body, headers=headers)
+        if not response.ok:
+            print("❌ Lỗi HTTP", response.status_code)
+            try:
+                print("📦 Nội dung lỗi JSON:", response.json())
+                return response.json()
+            except Exception:
+                print("📜 Nội dung lỗi (text):", response.text)
+                return response.text
+        return response.json()
+    except requests.exceptions.RequestException as e:
+        print("Lỗi khi gọi API:", e)
+        return None
+
+        
+def create_cart(user_id, token):
+    print(token)
+    print(user_id)
+    url = f"{api}/api/cart/createAI"
+    headers = {
+        "Authorization": f"Bearer {token}",
+        "Content-Type": "application/json",
+    }
+
+    body = {
+        "userId": user_id
+    }
+    try:
+        response = requests.post(url, json=body, headers=headers)
+        response.raise_for_status()
+        return response.json()
+    except requests.exceptions.RequestException as e:
+        print("Lỗi khi gọi API:", e)
+        return None
+
+
+# print(search_product(keyword="trà gừng",size="L"))
+
+# data = create_cart(4, "eyJhbGciOiJIUzI1NiJ9.eyJVc2VySWQiOiI0IiwiUm9sZXMiOiJDVVNUT01FUiIsInN1YiI6ImxpbmgiLCJpYXQiOjE3NDg1NDE4ODgsImV4cCI6MTc0OTQ0MTg4OH0.6pEg1hdSDRvfAQK5YYJsQY_OfZPV9_EqqVvTGbHftvc")
+# print(data)
+
+# data1 = insert_cartItem(4, 775, 38, "L", 2, "eyJhbGciOiJIUzI1NiJ9.eyJVc2VySWQiOiI0IiwiUm9sZXMiOiJDVVNUT01FUiIsInN1YiI6ImxpbmgiLCJpYXQiOjE3NDgwNzAxNTgsImV4cCI6MTc0ODk3MDE1OH0.nGHuJ-eNocxtAhIFk-GD4nehKnQH8uSjyGsnqgVT3eQ")
+# print(data1)
+
+# data2 = update_cartItem_quantity(4, 1226, 5, "eyJhbGciOiJIUzI1NiJ9.eyJVc2VySWQiOiI0IiwiUm9sZXMiOiJDVVNUT01FUiIsInN1YiI6ImxpbmgiLCJpYXQiOjE3NDgwNzAxNTgsImV4cCI6MTc0ODk3MDE1OH0.nGHuJ-eNocxtAhIFk-GD4nehKnQH8uSjyGsnqgVT3eQ")
+# print(data2)
+
+# data3 = update_cartItem_size(4, 1226, "K", "eyJhbGciOiJIUzI1NiJ9.eyJVc2VySWQiOiI0IiwiUm9sZXMiOiJDVVNUT01FUiIsInN1YiI6ImxpbmgiLCJpYXQiOjE3NDgwNzAxNTgsImV4cCI6MTc0ODk3MDE1OH0.nGHuJ-eNocxtAhIFk-GD4nehKnQH8uSjyGsnqgVT3eQ")
+# print(data3)
+
+# data4 = remove_one_cartItem(4, 1226, "eyJhbGciOiJIUzI1NiJ9.eyJVc2VySWQiOiI0IiwiUm9sZXMiOiJDVVNUT01FUiIsInN1YiI6ImxpbmgiLCJpYXQiOjE3NDgwNzAxNTgsImV4cCI6MTc0ODk3MDE1OH0.nGHuJ-eNocxtAhIFk-GD4nehKnQH8uSjyGsnqgVT3eQ")
+# print(data4)
+
+# data5 = remove_all_cartItem(4, 773, "eyJhbGciOiJIUzI1NiJ9.eyJVc2VySWQiOiI0IiwiUm9sZXMiOiJDVVNUT01FUiIsInN1YiI6ImxpbmgiLCJpYXQiOjE3NDgwNzAxNTgsImV4cCI6MTc0ODk3MDE1OH0.nGHuJ-eNocxtAhIFk-GD4nehKnQH8uSjyGsnqgVT3eQ")
+# print(data5)
+
+# data6 = create_orders(4, 787, "eyJhbGciOiJIUzI1NiJ9.eyJVc2VySWQiOiI0IiwiUm9sZXMiOiJDVVNUT01FUiIsInN1YiI6ImxpbmgiLCJpYXQiOjE3NDg1NDE4ODgsImV4cCI6MTc0OTQ0MTg4OH0.6pEg1hdSDRvfAQK5YYJsQY_OfZPV9_EqqVvTGbHftvc")
+# print(data6)
+
+# data7 = confirm_orders_AI(4, "eyJhbGciOiJIUzI1NiJ9.eyJVc2VySWQiOiI0IiwiUm9sZXMiOiJDVVNUT01FUiIsInN1YiI6ImxpbmgiLCJpYXQiOjE3NDg1NDE4ODgsImV4cCI6MTc0OTQ0MTg4OH0.6pEg1hdSDRvfAQK5YYJsQY_OfZPV9_EqqVvTGbHftvc", 652)
+# print(data7)

function/agent/function_call.py

@@ -0,0 +1,190 @@
+from langchain_core.tools import tool
+from langchain_openai import ChatOpenAI
+import os
+import os,sys
+BASE_DIR = os.path.abspath(os.path.join(os.path.dirname(__file__), "../../"))
+sys.path.insert(0, BASE_DIR)
+import function.gemini_response.filter_query_internal as filter_query
+
+
+#Test OpenAI
+os.environ["OPENAI_API_KEY"] = "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"
+llm = ChatOpenAI(model="gpt-4.1")
+
+#Test google
+os.environ["GOOGLE_API_KEY"] = "AIzaSyB_7ahCuAOZU0UKcON_A00ya5breHTEgQM"
+from langchain_google_genai import GoogleGenerativeAIEmbeddings, ChatGoogleGenerativeAI
+llm1 = ChatGoogleGenerativeAI(model='gemini-2.5-flash-preview-05-20',temperature=0.6)
+
+from langchain_core.messages import HumanMessage, ToolMessage
+
+
+@tool
+def question_information(query: str) -> str:
+    """
+    Trả lời các câu hỏi về thông tin liên hệ của cửa hàng, thông tin về sinh viên, tên đề tài các nội dung liên quan mà không phải sql
+
+    Hàm này chỉ phục vụ mục đích cung cấp thông tin liên lạc của cửa hàng, bao gồm:
+      - Số điện thoại liên hệ.
+      - Địa chỉ cửa hàng.
+      - Giờ làm việc.
+      - Email hỗ trợ.
+      - Các kênh liên hệ khác như Facebook, Zalo, v.v.
+
+    ⚠️ Lưu ý: 
+    - Hàm này KHÔNG trả lời các câu hỏi khác như: gợi ý món ăn, tư vấn sản phẩm, giá cả, chương trình khuyến mãi, cách pha chế đồ uống, v.v.
+    - Nếu truy vấn không liên quan đến thông tin cửa hàng, hàm sẽ từ chối trả lời.
+
+    Args:
+        query (str): Câu hỏi của người dùng liên quan đến thông tin liên hệ của cửa hàng. bao gồm:
+      - Số điện thoại liên hệ.
+      - Địa chỉ cửa hàng.
+      - Giờ làm việc.
+      - Email hỗ trợ.
+      - Các kênh liên hệ khác như Facebook, Zalo, v.v.
+
+    Returns:
+        str: Thông tin liên hệ của cửa hàng hoặc thông báo từ chối nếu câu hỏi không phù hợp. Xác định rõ câu hỏi không viết gọn
+    """
+    return query
+    
+
+@tool(description="Vui lòng giữ đúng truy vấn người dùng không tạo ra câu truy vấn khác ý nghĩa câu hỏi người dùng định hỏi, (**yêu cầu phải bám sát không được tự sinh câu hỏi)")
+def question_sql(query: str)->str:
+    """
+    Hỗ trợ truy xuất schema của database để giúp tạo truy vấn SQL cho các bảng sau:
+    
+    - **Giỏ hàng (cart, cart_item)**
+    - **Danh mục sản phẩm(tên sản phẩm) (category, category_translation)**
+    - **Liên hệ và yêu thích (contact, favourite, favourite_item)**
+    - **Thông báo (notification)**
+    - **Đơn hàng (orders, order_item, shipment)**
+    - **Thanh toán (otp, payments)**
+    - **Bài viết & tin tức (post, post_translation)**
+    - **Lịch sử giá (price_history)**
+    - **Sản phẩm (product, product_translation, product_variants)**
+    - **Đánh giá sản phẩm (review)**
+    - **Người dùng (user, user_coin, token)**
+    - **Mã giảm giá & phiếu giảm giá (voucher, user_voucher)**
+    - **Xác nhận về mua/xem, xóa  giỏ hàng, đơn hàng**(Hãy lưu ý những câu hỏi về này)
+    
+    ⚠ **Lưu ý**: 
+    - Chỉ hỗ trợ truy vấn liên quan đến các bảng trong database.
+    - Không trả lời các câu hỏi về thông tin cửa hàng như số điện thoại, email, giờ làm việc.
+    
+    Args:
+        query (str): Câu hỏi liên quan đến việc truy vấn dữ liệu từ database.
+    
+    Returns:
+        str: Mô tả bảng tương ứng hoặc thông báo từ chối nếu câu hỏi không phù hợp.
+    """
+    return query
+
+
+@tool
+def question_general(query: str) -> str:
+    """
+    Xử lý các câu hỏi không liên quan đến các công cụ có sẵn.
+
+    Hàm này nhận vào một câu hỏi dưới dạng chuỗi và trả về câu hỏi đó 
+    mà không thực hiện bất kỳ xử lý nào khác. Nó có thể được sử dụng như 
+    một phương án dự phòng khi không có tool nào phù hợp để xử lý câu hỏi.
+
+    Args:
+        query (str): Câu hỏi đầu vào từ người dùng.
+
+    Returns:
+        str: Trả về chính câu hỏi mà không thay đổi.
+    """
+    return query
+
+
+
+
+@tool(description="""ác định xem truy vấn có phải là câu chào hỏi hay không.  
+    Câu chào hỏi bao gồm các từ hoặc cụm từ thể hiện sự chào đón, bắt đầu cuộc trò chuyện, chẳng hạn như:
+    - "Xin chào", "Chào bạn", "Hello", "Hi", "Hey", "Good morning", "Good evening", ...  
+    - Cụm từ mang ý nghĩa xã giao: "Rất vui ��ược gặp bạn", "Hôm nay bạn thế nào?", "Chúc một ngày tốt lành", ...  
+
+    Lưu ý:
+    - Chỉ xử lý các câu hỏi thuộc nhóm chào hỏi.
+    - Không liên quan đến **question_sql** hoặc các câu hỏi về dữ liệu.
+
+    Args:
+        query (str): Câu hỏi đầu vào của người dùng.
+
+    Returns:
+        str: Trả về câu hỏi nếu nó thuộc nhóm chào hỏi, ngược lại có thể xử lý theo yêu cầu cụ thể.""")
+def question_hello(query: str)->str:
+    """
+    Xác định xem truy vấn có phải là câu chào hỏi hay không.  
+    Câu chào hỏi bao gồm các từ hoặc cụm từ thể hiện sự chào đón, bắt đầu cuộc trò chuyện, chẳng hạn như:
+    - "Xin chào", "Chào bạn", "Hello", "Hi", "Hey", "Good morning", "Good evening", ...  
+    - Cụm từ mang ý nghĩa xã giao: "Rất vui được gặp bạn", "Hôm nay bạn thế nào?", "Chúc một ngày tốt lành", ...  
+
+    Lưu ý:
+    - Chỉ xử lý các câu hỏi thuộc nhóm chào hỏi.
+    - Không liên quan đến **question_sql** hoặc các câu hỏi về dữ liệu.
+
+    Args:
+        query (str): Câu hỏi đầu vào của người dùng.
+
+    Returns:
+        str: Trả về câu hỏi nếu nó thuộc nhóm chào hỏi, ngược lại có thể xử lý theo yêu cầu cụ thể.
+    """
+    return query
+
+
+import asyncio
+import importlib
+import function.chat as chat_module
+async def update_tool_calls(tool_calls, chat_id,user_id,user_input):
+
+    updated_calls = []
+    
+    for tool in tool_calls:
+        query = tool['args']['query']
+        list_history = await chat_module.get_chat_details_text(chat_id, user_id)
+        new_question = await filter_query.response_rename_question(user_input, list_history, query)
+        tool['args']['query'] = new_question
+        new_name = await filter_query.response_general(new_question, list_history)
+        if new_name is not None and new_name == "question_sql":
+         tool['name'] = new_name.strip()
+         updated_calls.append(tool)
+        if new_name == "question_general":
+            tool['name'] = new_name.strip()
+            updated_calls.append(tool)
+            return updated_calls
+        else:
+            return tool_calls
+    
+    return updated_calls
+
+
+async def process_user_query(user_input, user_id, role, language,chat_id):
+    always_call_tool_llm = llm.bind_tools([question_information, question_sql, question_hello], tool_choice=True,strict=True)
+    tool_calls = always_call_tool_llm.invoke(f"{user_input}").tool_calls
+    
+    for tc in tool_calls:
+        tc["user_id"] = user_id
+        tc["role"] = role
+        tc["language"] = language
+    print("Tool gốc:",tool_calls)
+    data = await update_tool_calls(tool_calls,chat_id,user_id,user_input)
+   
+    for item in data:
+        item['chat_id'] = chat_id
+    print("Tool update: ", data)
+    return data
+
+
+# import asyncio
+
+async def main():
+    await process_user_query("Tôi muốn thêm trà chanh size L vào giỏ hàng", 4, "CUSTOMER", "VN", "67d2fc6607b51a01e3beb501")
+
+if __name__ == "__main__":
+    loop = asyncio.new_event_loop()
+    asyncio.set_event_loop(loop)
+    loop.run_until_complete(main())
+    loop.close()

function/agent/pipeline_agent.py

@@ -0,0 +1,136 @@
+import os,sys
+BASE_DIR = os.path.abspath(os.path.join(os.path.dirname(__file__), "../../"))
+sys.path.insert(0, BASE_DIR)
+from  function.file import extract_file as extract_file
+import function.agent.function_call as fc
+import function.function_agent.multi_agent as multi_agent
+import function.function_agent.map_toolcall as map_toolcall
+import function.gemini_response.response_all as response_all
+from models.Database_Entity import StopSignal
+from advance_shopping.server_java import server_java
+async def check_should_stop(chat_id: str, stop_event: object = None):
+    # Trường hợp dừng qua RAM (in-memory)
+    await asyncio.sleep(0.1)
+    if stop_event and stop_event.is_set():
+        print("🛑 Dừng qua stop_event.")
+        return {"status": "cancelled"}
+
+    # Trường hợp dừng qua MongoDB
+    await asyncio.sleep(0.1)
+    if StopSignal.objects(chat_history=chat_id, is_stopped=True).first():
+        print("🛑 Dừng vì có StopSignal trong DB.")
+        return {"status": "cancelled"}
+
+    return None  # Không bị dừng
+
+
+async def rollback_cart_if_stopped(stop_event, result_multi_task, chat_id: str, user_id: int, token: str):
+    if stop_event and stop_event.is_set():
+        for task_id, task_result in result_multi_task.items():
+            if task_result.get("is_shopping"):
+                print(f"INFO: Bắt đầu rollback task mua sắm: {task_id}")
+                chat_cart = ChatCart()
+                latest_unconfirmed_cart = ChatCart.objects(chat_history=chat_id).order_by('-created_at').first()
+                if latest_unconfirmed_cart:
+                    chat_cart = latest_unconfirmed_cart
+                
+                # Khôi phục trạng thái backup
+                chat_cart.cart_products = chat_cart.backup_cart_products
+                chat_cart.status = chat_cart.backup_status
+                chat_cart.confirmed_order = chat_cart.backup_confirmed_order
+
+                chat_cart.save()
+                cart_id = chat_cart.cart_id
+                order_id = chat_cart.order_id
+
+                if order_id:
+                    try:
+                        server_java.confirm_cancel_AI(int(user_id), token, order_id)
+                        print(f"✅ Đã huỷ đơn hàng: {order_id}")
+                    except Exception as e:
+                        print(f"ERROR khi huỷ đơn hàng {order_id}: {e}")
+                if cart_id:
+                    try:
+                        server_java.remove_all_cartItem(int(user_id), cart_id, token)
+                        print(f"✅ Đã xoá item trong giỏ hàng: {cart_id}")
+                    except Exception as e:
+                        print(f"ERROR khi xoá cart item {cart_id}: {e}")
+
+                # Reset các ID để tránh nhầm lẫn về sau
+                chat_cart.order_id = None
+                chat_cart.cart_id = None
+                chat_cart.save()
+
+            else:
+                print(f"Task {task_id} không phải mua sắm, không cần rollback.")
+
+
+from typing import Optional
+import asyncio
+from models.Database_Entity import StopSignal,ChatCart
+async def multi_query_user(
+    user_input: str,
+    user_id: int,
+    role,
+    languages: str,
+    chat_id,
+    token,
+    stop_event: Optional[asyncio.Event] = None
+) -> str:
+    
+    chat_cart = ChatCart()
+    latest_unconfirmed_cart = ChatCart.objects(chat_history=chat_id,status ="pending").order_by('-created_at').first()
+    if latest_unconfirmed_cart:
+        chat_cart = latest_unconfirmed_cart
+        chat_cart.backup_cart_products = chat_cart.cart_products
+        chat_cart.backup_status = chat_cart.status
+        chat_cart.backup_confirmed_order = chat_cart.confirmed_order
+        chat_cart.save()
+
+    result_check = await check_should_stop(chat_id, stop_event)
+    if result_check:
+        return result_check
+
+    multi_tasks = await fc.process_user_query(user_input, user_id, role, languages, chat_id)
+
+    result_check = await check_should_stop(chat_id, stop_event)
+    if result_check:
+        return result_check
+    
+    result_multi_task = await multi_agent.process_toolcalls_with_order(multi_tasks, token, stop_event,chat_id)
+    chat_cart = ChatCart()
+    if stop_event and stop_event.is_set():
+       await rollback_cart_if_stopped(stop_event, result_multi_task, chat_id, user_id, token)
+
+
+    result_check = await check_should_stop(chat_id, stop_event)
+    if result_check:
+        await rollback_cart_if_stopped(stop_event, result_multi_task, chat_id, user_id, token)
+        return result_check
+
+    map_tool_result = map_toolcall.map_toolcalls_with_results(multi_tasks, result_multi_task)
+
+    result_check = await check_should_stop(chat_id, stop_event)
+    if result_check:
+        await rollback_cart_if_stopped(stop_event, result_multi_task, chat_id, user_id, token)
+        return result_check
+
+    result = await response_all.response_all(user_input, map_tool_result)
+
+    result_check = await check_should_stop(chat_id, stop_event)
+    if result_check:
+        await rollback_cart_if_stopped(stop_event, result_multi_task, chat_id, user_id, token)
+        return result_check
+    
+    return result if result is not None else {"status": "empty"}
+
+
+    
+# import asyncio
+# # if __name__ == "__main__":
+# #     token = "eyJhbGciOiJIUzI1NiJ9.eyJVc2VySWQiOiI0IiwiUm9sZXMiOiJDVVNUT01FUiIsInNlc3Npb25JZCI6ImJkM2M5MmNkLTczMzgtNDlmNS04NzIyLTUwMDU0Zjk5MjRhZSIsInN1YiI6ImxpbmgiLCJpYXQiOjE3NDg3NjcwNDUsImV4cCI6MTc0OTY2NzA0NX0.X4d4GcstDhaVC1nbPWWkN3sUEHNUltDtD5KgP_mzPrM"
+# #     result = asyncio.run(multi_query_user("Tôi muốn thêm sản phẩm Yogurt Đào size S vào giỏ hàng và tôi quyết định mua sản phẩm này", 4 , "CUSTOMER", "VN","67d009fee0a638763885c195",token=token))
+# #     print(result)
+# if __name__ == "__main__":
+#     result = asyncio.run(multi_query_user("Tôi muốn thêm trà chanh size L vào giỏ", 4, "CUSTOMER", "ADMIN","67d2fc6607b51a01e3beb501",""))
+#     print(result)

function/analyze/execute_query.py

@@ -0,0 +1,394 @@
+import sys
+import os
+
+# Thêm thư mục gốc (chứa thư mục "function") vào sys.path
+sys.path.append(os.path.abspath(os.path.join(os.getcwd(), "..")))
+import os
+from dotenv import load_dotenv
+
+# Load biến môi trường từ file .env
+load_dotenv()
+
+DB_HOST = os.getenv("DB_HOST")
+DB_USER = os.getenv("DB_USER")
+DB_PASSWORD = os.getenv("DB_PASSWORD")
+DB_NAME =  os.getenv("DB_NAME")
+DB_PORT =  os.getenv("DB_PORT")
+
+import os
+from urllib.parse import quote
+
+password = os.getenv("DB_PASSWORD")  # VD: 'Yahana0509@'
+DB_PASSWORD = quote(password)
+# Tạo connection string
+connection_uri = f"mysql+pymysql://{DB_USER}:{DB_PASSWORD}@{DB_HOST}:{DB_PORT}/{DB_NAME}"
+from langchain_community.utilities.sql_database import SQLDatabase
+from langchain_experimental.sql import SQLDatabaseChain
+import sys
+import os
+import pymysql
+from fastapi import HTTPException
+import sys
+import os
+
+
+from fastapi.encoders import jsonable_encoder
+import re
+from function.prompt import prompt_main as prompt
+import function.prompt.prompt_custom as prompt_cus
+os.environ["GOOGLE_API_KEY"] = "AIzaSyCO-RlqYewC4e9BEPoC8m-AxHUY7J3_o2E"
+from bson import ObjectId
+db = SQLDatabase.from_uri(connection_uri)
+from dotenv import load_dotenv
+import filter.filter_role as filter_role_1
+import filter.filter_sql_injection as filter_sql_injection_1
+import filter.result as query_result_1
+import response.ResponseChat as res_chat
+from datetime import datetime
+import pytz
+from mongoengine import connect
+import os
+import nltk
+import function.agent.pipeline_agent as pipeline_agent
+nltk.download('punkt')
+from models.Database_Entity import User, ChatHistory, DetailChat
+from dotenv import load_dotenv
+load_dotenv()
+MONGO_URI = os.getenv("MONGO_URI", "")
+connect("chatbot_hmdrinks", host=MONGO_URI)
+import re
+
+def contains_delete(sql: str) -> bool:
+    return bool(re.search(r'\bdelete\b', sql, re.IGNORECASE))
+load_dotenv()
+
+#setup model
+from bson import ObjectId
+import random
+from langchain_google_genai import GoogleGenerativeAIEmbeddings, ChatGoogleGenerativeAI
+llm1 = ChatGoogleGenerativeAI(model='gemini-2.5-flash-preview-05-20',temperature=0.5)
+
+#setup kết nối database
+db = SQLDatabase.from_uri(connection_uri)
+db_chain = SQLDatabaseChain.from_llm(llm=llm1,db=db,prompt= prompt.PROMPT)
+
+from prompt.prompt_syntax_insert import is_insert_related_to_product_category_variant, filter_syntax_sql
+import sqlparse
+
+
+import sys
+import os
+sys.path.append(os.path.abspath(os.path.join(os.getcwd(), '..')))
+from prompt import prompt_detail_table
+
+schema_mapping = {
+        "payments": prompt_detail_table.prompt_payments,
+        "user": prompt_detail_table.prompt_users,
+        "user_voucher": prompt_detail_table.prompt_user_voucher,
+        "category": prompt_detail_table.prompt_categort,
+        "category_translation": prompt_detail_table.prompt_category_translation,
+        "cart": prompt_detail_table.prompt_cart,
+        "cart_item": prompt_detail_table.prompt_cart_item,
+        "orders":prompt_detail_table.prompt_orders,
+        "order_item": prompt_detail_table.prompt_order_item,
+        "payment": prompt_detail_table.prompt_payments,
+        "favourite": prompt_detail_table.prompt_favourite,
+        "favourite_item": prompt_detail_table.prompt_fav_item,
+        "post": prompt_detail_table.prompt_post,
+        "post_translation": prompt_detail_table.prompt_post_translation,
+        "product": prompt_detail_table.prompt_product,
+        "product_translation": prompt_detail_table.prompt_product_translation,
+        "shipment": prompt_detail_table.prompt_shipment,
+        "product_variants": prompt_detail_table.prompt_product_variants,
+        "review": prompt_detail_table.prompt_review,
+        "user_coin": prompt_detail_table.prompt_user_coin,
+        "absence": prompt_detail_table.prompt_absence,
+        "cart_group": prompt_detail_table.prompt_cart_group,
+        "cart_item_group": prompt_detail_table.prompt_cartitem_group,
+        "group_orders": prompt_detail_table.prompt_group_orders,
+        "payments_group": prompt_detail_table.prompt_payments_group,
+        "group_order_members":prompt_detail_table.prompt_group_orders_member,
+        "shipment_group":prompt_detail_table.prompt_shipment_group,
+        "shipper_attendance":prompt_detail_table.prompt_shipper_attendance,
+        "shipper_commission_detail":prompt_detail_table.prompt_shipper_commission_detail,
+        "shipper_salary_summary":prompt_detail_table.prompt_shipper_salary_summary,
+        "voucher": prompt_detail_table.prompt_voucher
+    }
+
+
+def get_schemas_from_sql(sql_query: str, schema_mapping: dict):
+    import sqlglot
+    print("SQL query:", sql_query)
+    parsed_query = sqlglot.parse_one(sql_query, read="mysql")
+    
+    # Lấy danh sách bảng duy nhất trong query
+    table_names = list({t.name for t in parsed_query.find_all(sqlglot.exp.Table)})
+
+    schemas_used = {}
+    for table in table_names:
+        if table in schema_mapping:
+            schemas_used[table] = schema_mapping[table]
+        else:
+            print(f"⚠️ Warning: Table '{table}' not found in schema_mapping")
+
+    # Gom toàn bộ schema thành 1 chuỗi duy nhất
+    all_schemas = "\n\n".join(
+        [f"Schema for table '{table}':\n{schemas_used[table]}" for table in schemas_used]
+    )
+
+    return all_schemas
+
+
+def build_sql_fix_prompt(schemas_result: dict, sql: str,user_id: int) -> str:
+   
+ prompt = f"""
+Bạn là một chuyên gia cơ sở dữ liệu.
+
+Dưới đây là mô tả schema chi tiết của các bảng có trong hệ thống:
+
+{schemas_result}
+
+---
+
+Dưới đây là một câu SQL đang bị lỗi do không đúng tên bảng hoặc tên cột:
+
+```sql
+{sql.strip()}
+Yêu cầu của bạn là:
+User Id: {user_id}
+Dựa trên các schema ở trên, hãy kiểm tra và chỉnh sửa câu SQL sao cho:
+Tên bảng, tên cột phải chính xác theo schema.
+Logic và mục đích của truy vấn được giữ nguyên.
+Chỉ trả lại phần SQL đã được chỉnh sửa (không giải thích, không chú thích, không thêm nhận xét).
+Loại bỏ các câu comment chỉ trả lại câu SQL chính xác sau khi bạn đã chỉnh sửa.
+Vui lòng chỉnh sửa một cách chính xác nhất.
+Trả lời dưới dạng một truy vấn SQL duy nhất.
+** Tham khảo thêm các lỗi sau để tránh:
+ - "- Tránh các lỗi như :\n"
+    "  (1054, \"Unknown column 'oi.pro_id' in 'field list'\")\n . Luôn đảm bảo bạn không bao giờ bị lỗi này"
+    "  (1054, \"Unknown column 'oi.note' in 'field list'\") . Luôn đảm bảo bạn không bao giờ bị lỗi này\n"
+    "  (1054, \"Unknown column 'oi.size' in 'field list'\") . Luôn đảm bảo bạn không bao giờ bị lỗi này \n"
+    "  (1054, \"Unknown column 'c.is_deleted' in 'on clause'\").  Luôn đảm bảo bạn không bao giờ bị lỗi này\n"
+"""
+ return prompt
+
+
+
+
+async def execute_query_user(user_input: str, user_id: int, languages: str, role: str):
+    PROMPT_CUSTOM = await prompt_cus.get_prompt_custom(user_input)
+    check_insert = is_insert_related_to_product_category_variant(user_input)
+
+    db_config = {
+        "host": os.getenv("DB_HOST"),
+        "user": os.getenv("DB_USER"),
+        "database": os.getenv("DB_NAME"),
+        "password": os.getenv("DB_PASSWORD"),
+        "port": int(os.getenv("DB_PORT", 3306)),
+        "charset": "utf8mb4",
+        "cursorclass": pymysql.cursors.DictCursor,
+    }
+
+
+    def regenerate_sql_until_safe():
+     max_retry = 5
+     retry_count = 0
+
+     while retry_count < max_retry:
+        try:
+            regenerated_data = db_chain.run(f"""
+                Role: {text_role}
+                Language: {languages}
+                Question: {user_input}.
+            """)
+            regenerated_sql = extract_sql_from_response(regenerated_data)
+            if regenerated_sql:
+                regenerated_sql = clean_sql(regenerated_sql)
+                if not re.search(r"%{1,2}s", regenerated_sql):  # đã sạch
+                    return regenerated_sql
+            retry_count += 1
+        except Exception as e:
+            return f"❌ Lỗi khi tạo lại truy vấn lần {retry_count + 1}: {str(e)}"
+
+     return "❌ Lỗi: Không thể tạo được truy vấn an toàn sau nhiều lần thử."
+
+
+    def execute_query_with_pymysql(query, multi=False):
+        connection = pymysql.connect(**db_config)
+        try:
+            with connection.cursor() as cursor:
+                results = []
+                if multi:
+                    # Dùng sqlparse để chia câu truy vấn cho an toàn
+                    statements = sqlparse.split(query)
+                    for stmt in statements:
+                        stmt = stmt.strip()
+                        if stmt:
+                            cursor.execute(stmt)
+                            results.append(cursor.fetchall())
+                else:
+                    cursor.execute(query)
+                    results = cursor.fetchall()
+                connection.commit()
+                return results
+        except pymysql.MySQLError as e:
+            return str(e)
+        finally:
+            connection.close()
+
+    def clean_sql(sql) -> str:
+        print("Clean sql1:", sql)
+        if isinstance(sql, dict) and sql:
+           first_value = next(iter(sql.values()))
+           sql = first_value
+        sql = re.sub(r"```sql", "", sql, flags=re.IGNORECASE)
+        sql = sql.replace("```sql", "")
+        sql = re.sub(r"```", "", sql)
+        return sql.strip()
+        # sql = re.sub(r"```sql", "", sql, flags=re.IGNORECASE)
+        # sql = sql.replace("```sql", "")
+        # # sql = re.sub(r'%%s', r'%s', sql)
+        # sql = re.sub(r"```", "", sql)
+        # return sql.strip()
+
+    def extract_sql_from_response(data):
+     match = re.search(r"\[SQL:\s*```sql\s*(.*?)\s*```]", data, re.DOTALL)
+     if match:
+        return clean_sql(match.group(1))
+     match = re.search(r"SQLQuery:\s*(.*)", data, re.DOTALL)
+     if match:
+        return clean_sql(match.group(1))
+
+     return None
+
+    def extract_sql_from_error(error_msg):
+    # Case 1: [SQL: ```sql ... ```]
+     match = re.search(r"\[SQL:\s*```sql\s*(.*?)\s*```]", error_msg, re.DOTALL)
+     if match:
+        return clean_sql(match.group(1))
+
+
+     match = re.search(r"```(?:sql)?\s*\r?\n(.*?)```", error_msg, re.DOTALL)
+     if match:
+        return clean_sql(match.group(1))
+
+     return None
+
+    def process_and_execute_sql(sql):
+     print("NHận sql: ",sql )
+     data = sql
+     if isinstance(data, dict) and data:
+      print("Là dict")
+      first_key, first_value = next(iter(data.items()))
+      sql = first_value
+     elif isinstance(data, list) and data:
+       sql = "\n\n".join(data)
+
+     sql_clean = clean_sql(sql)
+     print("SQL Clean: ", sql_clean)
+     if re.search(r"%{1,2}s", sql_clean):
+       regenerated_sql = regenerate_sql_until_safe()
+       sql_clean = clean_sql(regenerated_sql)
+     result = get_schemas_from_sql(sql_clean, schema_mapping)
+     prompt = build_sql_fix_prompt(schemas_result=result,sql = str(sql_clean),user_id =user_id)
+     from advance_shopping.call_gemini import tool_call
+     data = tool_call.generate(prompt = prompt)
+     sql_clean = clean_sql(data)
+     print("SQL step2: ", sql_clean)
+     if contains_delete(sql_clean):
+            return "Lỗi: Bạn không dược phép thực hiện truy vấn DELETE trong hệ thống này."
+
+     if re.search(r"\bIF\b.*\bTHEN\b", sql_clean, re.IGNORECASE):
+        return "❌ Lỗi: Không được dùng IF...THEN trong SQL. Vui lòng chia nhỏ truy vấn."
+
+     if check_insert:
+        check_syntax = filter_syntax_sql(sql_clean, PROMPT_CUSTOM, user_input)
+        if check_syntax is True:
+            # Tách từng câu và thực thi tuần tự
+            try:
+                connection = pymysql.connect(**db_config)
+                with connection.cursor() as cursor:
+                    statements = sqlparse.split(sql_clean)
+                    results = []
+                    for stmt in statements:
+                        stmt = stmt.strip()
+                        if stmt:
+                            cursor.execute(stmt)
+                            try:
+                                results.append(cursor.fetchall())
+                            except:
+                                results.append("✅ OK")  # Có thể là câu SET hoặc INSERT
+                    connection.commit()
+                    return results
+            except Exception as e:
+                return f"❌ Lỗi khi thực thi từng truy vấn: {str(e)}"
+            finally:
+                connection.close()
+        else:
+            try:
+                regenerated_data = db_chain.run(f"""
+                    Role: {text_role}
+                    Language: {languages}
+                    Question: {user_input}.
+                """)
+                regenerated_sql = extract_sql_from_response(regenerated_data)
+                if regenerated_sql:
+                    return process_and_execute_sql(regenerated_sql)
+                else:
+                    return "❌ Lỗi: Không thể tạo lại truy vấn hợp lệ."
+            except Exception as regen_error:
+                return f"❌ Lỗi khi tạo lại truy vấn: {str(regen_error)}"
+     else:
+        return execute_query_with_pymysql(sql_clean, multi=True)
+
+
+    
+    PROMPT_CUSTOM.template += (
+        "\n\n⚠️ Lưu ý: Do NOT use IF...THEN...ELSE...END in SQL. "
+        "Only use plain SELECT, INSERT, UPDATE, JOIN, SET statements. "
+        "Tuyệt đối cấm dùng %%s hoặc %s để lấy giá trị từ biến. "
+        "SQL phải chứa giá trị cố định, không dùng placeholder hay biến bind."
+    )
+
+    db_chain = SQLDatabaseChain.from_llm(llm=llm1, db=db, prompt=PROMPT_CUSTOM)
+    text_role = f"{role} (userId = {user_id})" if role == "ADMIN" else f"{role} (userId = {user_id}), not role ADMIN"
+
+    try:
+        data = db_chain.run(f"""
+            Role: {text_role}
+            Language: {languages}
+            Question: {user_input}.
+        """)
+        extracted_sql = extract_sql_from_response(data)
+        if extracted_sql:
+            return process_and_execute_sql(extracted_sql)
+        else:
+            return data
+
+    except Exception as e:
+         error_message = str(e)
+         extracted_sql = extract_sql_from_error(error_message)
+
+         if extracted_sql:
+            fix_sql = re.sub(r"```sql", "", extracted_sql)
+            fix_sql = extracted_sql.replace("```", "")
+            fix_sql = extracted_sql.replace("```sql", "")
+            # fix_sql = re.sub(r'%%s', r'%s', fix_sql)
+            if contains_delete(fix_sql):
+               return "Lỗi: Bạn không dược phép thực hiện truy vấn DELETE trong hệ thống này."
+            return process_and_execute_sql(fix_sql)
+         else:
+            # Không trích xuất được SQL -> Thử tạo lại truy vấn từ đầu
+            try:
+                regenerated_data = db_chain.run(f"""
+                    Role: {text_role}
+                    Language: {languages}
+                    Question: {user_input}.
+                """)
+                regenerated_sql = extract_sql_from_response(regenerated_data)
+                if regenerated_sql:
+                    return process_and_execute_sql(regenerated_sql)
+                else:
+                    return "❌ Lỗi: Không thể tạo lại truy vấn hợp lệ sau lỗi."
+            except Exception as regen_error:
+                return f"❌ Lỗi khi tạo lại truy vấn từ lỗi: {str(regen_error)}"