feat(bot): improve intent handling and price comparator fallback

Added INTENT_GENERAL to handle greetings and small talk without hallucinating product searches.
Added INTENT_CONTACT to catch user requests to speak with a manager, returning direct contacts.
Enhanced PriceComparator to extract real Part Numbers from WooCommerce titles for Datacomp searches.
Implemented a broad search fallback in PriceComparator by cleaning category prefixes when exact SKU search fails.

Resolves bot intent hallucinations and fixes Datacomp scraper search coverage.

Author: PyDevDeep

app/core/constants.py

@@ -47,6 +47,8 @@
 INTENT_CHECKOUT = "checkout"
 INTENT_HYBRID = "hybrid"
 INTENT_FAQ = "faq"
+INTENT_GENERAL = "general"
+INTENT_CONTACT = "contact"
 
 # --- Regex Patterns ---
 REGEX_PHONE = r"(?:\+380|380|0)\d{9}"

app/services/price_comparator.py

@@ -58,6 +58,12 @@ async def compare(
 
         sku = woo_result.sku
 
+        import re
+
+        match = re.search(r"\(([^)]+)\)$", woo_result.name.strip())
+        if match:
+            sku = match.group(1).strip()
+
         if not sku:
             return PriceComparisonResult(
                 product_name=woo_result.name,
@@ -89,6 +95,22 @@ async def compare(
             logger.info("Cache MISS or FORCE REFRESH", sku=sku, is_checkout=is_checkout)
             dc_result = await self.scraper_service.scrape_datacomp(sku)
 
+            if not dc_result:
+                base_name = re.sub(r"\([^)]+\)$", "", woo_result.name).strip()
+                words = base_name.split()
+                start_idx = 0
+                for i, w in enumerate(words):
+                    if re.search(r"[A-Za-z]", w):
+                        start_idx = i
+                        break
+                cleaned_name = " ".join(words[start_idx:])
+
+                if cleaned_name and cleaned_name != sku:
+                    logger.info(
+                        "Fallback scraping by cleaned name", sku=sku, cleaned_name=cleaned_name
+                    )
+                    dc_result = await self.scraper_service.scrape_datacomp(cleaned_name)
+
             if dc_result:
                 dc_price_uah = dc_result.price_uah
                 dc_availability_raw = dc_result.availability_status

app/services/rag_engine.py

@@ -8,7 +8,9 @@
 from app.core.config import Settings
 from app.core.constants import (
     INTENT_CHECKOUT,
+    INTENT_CONTACT,
     INTENT_FAQ,
+    INTENT_GENERAL,
     INTENT_HYBRID,
     INTENT_PRODUCT,
     INTENT_SEARCH,
@@ -32,7 +34,12 @@
 from app.services.price_comparator import PriceComparator
 from app.services.telegram_service import TelegramService
 from app.services.vector_service import VectorService
-from app.utils.prompts import INTENT_ANALYZER_PROMPT, NO_CONTEXT_RESPONSE, RAG_SYSTEM_PROMPT
+from app.utils.prompts import (
+    INSTR_CONTACT_MANAGER,
+    INTENT_ANALYZER_PROMPT,
+    NO_CONTEXT_RESPONSE,
+    RAG_SYSTEM_PROMPT,
+)
 
 logger = get_logger(__name__)
 
@@ -92,6 +99,8 @@ async def detect_intent(self, question: str, history_context: str) -> dict[str,
             intent_search=INTENT_SEARCH,
             intent_checkout=INTENT_CHECKOUT,
             intent_hybrid=INTENT_HYBRID,
+            intent_general=INTENT_GENERAL,
+            intent_contact=INTENT_CONTACT,
         )
 
         try:
@@ -213,6 +222,15 @@ async def _get_intent_context(
             requires_lead = res.requires_lead
             lead_form_type = res.lead_form_type
 
+        elif intent_type == INTENT_CONTACT:
+            requires_lead = True
+            lead_form_type = "contact"
+            system_instructions.append(INSTR_CONTACT_MANAGER)
+            extracted_links.append(
+                {"text": LINK_TELEGRAM, "url": self.settings.telegram_contact_url}
+            )
+            extracted_links.append({"text": LINK_VIBER, "url": self.settings.viber_contact_url})
+
         return IntentContextResult(
             product_facts=product_facts,
             system_instructions=system_instructions,

app/utils/prompts.py

@@ -37,6 +37,10 @@
 5. CRITICAL (Hybrid): The presence of ANY question about delivery, payment, warranty, or installment plan FORCES the intent to "{intent_hybrid}". This is the only way to return FAQ queries.
    -> {{"intent": "{intent_hybrid}", "product_name": "model name (if any)", "strict_query": "commercial query (if any)", "broad_query": "short query (if any)", "category_query": "EXACT category name", "normalized_faq_queries": ["installment plan", "delivery"]}}
 6. CRITICAL: For "category_query" choose the EXACT name from this list: [{categories_str}]. If nothing fits - null.
+7. If the client uses conversational greetings, small talk, or says thanks (e.g., "привіт", "дякую", "як справи"):
+   -> {{"intent": "{intent_general}", "product_name": null, "strict_query": null, "broad_query": null, "category_query": null, "normalized_faq_queries": []}}
+8. If the client expresses a desire to contact a manager, talk to a human, or leave contacts:
+   -> {{"intent": "{intent_contact}", "product_name": null, "strict_query": null, "broad_query": null, "category_query": null, "normalized_faq_queries": []}}
 
 Respond ONLY with valid JSON."""
 
@@ -51,3 +55,4 @@
 INSTR_CHECKOUT_PRICE_ISSUE = "Інструкція: Ти щойно актуалізував дані на складі для фіналізації замовлення і виникла необхідність додаткового узгодження деталей постачання. Ввічливо скажи клієнту, що для завершення оформлення потрібне уточнення менеджера, і попроси залишити номер телефону (Telegram/Viber)."
 INSTR_DISCOUNT_AVAILABLE = "Інструкція: Для цього товару доступна індивідуальна знижка. Запропонуй клієнту передати номер телефону (Viber/Telegram), щоб менеджер узгодив з ним фінальну ціну."
 INSTR_PRICE_CHECKING = "Інформація для тебе: ціна на '{product_name}' зараз перевіряється. Скажи клієнту, що запит передано менеджеру і попроси контакти."
+INSTR_CONTACT_MANAGER = "Клієнт хоче зв'язатися з менеджером. ТВОЯ ЗАДАЧА: попросити клієнта залишити свій номер телефону в чаті АБО написати нам у Telegram/Viber (посилання вже згенеровані)."