Update app.py

app.py

@@ -874,7 +874,7 @@ class VeterinaryContextManager:
 context_manager = VeterinaryContextManager()
 
 # Enhanced product response with veterinary domain expertise
-def generate_veterinary_product_response(product_info: Dict[str, Any], user_context: Dict[str, Any]) -> str:
+def generate_veterinary_product_response(product_info: Dict[str, Any], user_context: Dict[str, Any], reply_language: str = 'en') -> str:
     """Generate comprehensive veterinary product response with intelligent information handling"""
     
     def clean_text(text):
@@ -904,18 +904,38 @@ def generate_veterinary_product_response(product_info: Dict[str, Any], user_cont
     except Exception as e:
         logger.warning(f"Error checking PDF link for {product_name}: {e}")
     
-    # Build the response
-    response = f"""🧪 *Name:* {product_name}
+    # Build the response based on language
+    if reply_language == 'ur':
+        response = f"""🧪 *نام:* {product_name}
+📦 *قسم:* {product_type}
+🏥 *زمرہ:* {category}
+💊 *استعمال:* {indications}"""
+        
+        # Add PDF link if available, in the requested format
+        if pdf_link:
+            response += f"\n\n📄 پروڈکٹ بروشر دستیاب ہے\n🔗 {product_name} پی ڈی ایف:\n{pdf_link}"
+        
+        # Add menu options in Urdu
+        response += f"""
+
+💬 *دستیاب اختیارات:*
+1️⃣ ویٹرنری کنسلٹنٹ سے بات کریں
+2️⃣ دستیابی کے بارے میں پوچھیں
+3️⃣ مین مینو پر واپس جائیں
+
+💬 ایک اختیار منتخب کریں یا متعلقہ مصنوعات کے بارے میں پوچھیں"""
+    else:
+        response = f"""🧪 *Name:* {product_name}
 📦 *Type:* {product_type}
 🏥 *Category:* {category}
 💊 *Used For:* {indications}"""
-    
-    # Add PDF link if available, in the requested format
-    if pdf_link:
-        response += f"\n\n📄 Product Brochure Available\n🔗 {product_name} PDF:\n{pdf_link}"
-    
-    # Add menu options
-    response += f"""
+        
+        # Add PDF link if available, in the requested format
+        if pdf_link:
+            response += f"\n\n📄 Product Brochure Available\n🔗 {product_name} PDF:\n{pdf_link}"
+        
+        # Add menu options
+        response += f"""
 
 💬 *Available Actions:*
 1️⃣ Talk to Veterinary Consultant
@@ -1788,6 +1808,39 @@ async def process_incoming_message(from_number: str, msg: dict):
         if not message_body:
             return
         
+        # 🎯 LANGUAGE DETECTION FOR TEXT MESSAGES - STRICTLY ENGLISH OR URDU ONLY
+        reply_language = 'en'  # Default to English
+        try:
+            detected_lang = detect(message_body)
+            logger.info(f"[Process] Raw detected language: {detected_lang}")
+            
+            # STRICTLY ENGLISH OR URDU ONLY - REJECT ALL OTHER LANGUAGES
+            if detected_lang in ['en', 'ur']:
+                reply_language = detected_lang
+                logger.info(f"[Process] Valid language detected: {detected_lang}")
+            else:
+                # Reject any other language and force to English
+                reply_language = 'en'
+                logger.warning(f"[Process] Invalid language '{detected_lang}' detected - forcing to English")
+            
+            # Check if text contains Urdu/Arabic characters or Islamic greetings
+            urdu_arabic_pattern = re.compile(r'[\u0600-\u06FF\u0750-\u077F\u08A0-\u08FF\uFB50-\uFDFF\uFE70-\uFEFF]')
+            islamic_greetings = ['assalamu', 'assalam', 'salam', 'salaam', 'adaab', 'namaste', 'khuda', 'allah']
+            
+            has_urdu_chars = bool(urdu_arabic_pattern.search(message_body))
+            has_islamic_greeting = any(greeting in message_body.lower() for greeting in islamic_greetings)
+            
+            if has_urdu_chars or has_islamic_greeting:
+                detected_lang = 'ur'
+                reply_language = 'ur'
+                logger.info(f"[Process] Overriding language detection to Urdu due to Arabic/Urdu characters or Islamic greeting")
+            
+            logger.info(f"[Process] Final language set to: {reply_language}")
+            
+        except Exception as e:
+            logger.warning(f"[Process] Language detection failed: {e}, defaulting to English")
+            reply_language = 'en'
+        
         # Check for greetings with multilingual support
         if is_greeting(message_body):
             # Check if user is currently in AI chat mode - if so, don't trigger menu mode
@@ -1798,13 +1851,28 @@ async def process_incoming_message(from_number: str, msg: dict):
                 return
             else:
                 # Only trigger menu mode if not in AI chat mode
-                welcome_msg = generate_veterinary_welcome_message()
+                # Generate welcome message in detected language
+                if reply_language == 'ur':
+                    welcome_msg = (
+                        "🩺 *اپیکس بائیوٹیکل ویٹرنری اسسٹنٹ*\n\n"
+                        "آپ کا خیر مقدم ہے! میں آپ کی ویٹرنری مصنوعات کے بارے میں مدد کر سکتا ہوں۔\n\n"
+                        "📋 *مین مینو:*\n"
+                        "1️⃣ مصنوعات تلاش کریں\n"
+                        "2️⃣ زمرے براؤز کریں\n"
+                        "3️⃣ کیٹلاگ ڈاؤن لوڈ کریں\n"
+                        "4️⃣ اے آئی چیٹ موڈ\n\n"
+                        "💬 اپنا انتخاب لکھیں یا 'main' لکھ کر مین مینو پر واپس جائیں۔"
+                    )
+                else:
+                    welcome_msg = generate_veterinary_welcome_message()
+                
                 send_whatsjet_message(from_number, welcome_msg)
                 context_manager.update_context(
                     from_number, 
                     current_state='main_menu', 
                     current_menu='main_menu', 
-                    current_menu_options=list(MENU_CONFIG['main_menu']['option_descriptions'].values())
+                    current_menu_options=list(MENU_CONFIG['main_menu']['option_descriptions'].values()),
+                    reply_language=reply_language
                 )
                 return
         
@@ -1814,25 +1882,55 @@ async def process_incoming_message(from_number: str, msg: dict):
             mapped_navigation = process_intelligent_voice_command(message_body, current_state, user_context)
             if mapped_navigation == 'main':
                 logger.info(f"[Process] Navigation command detected: '{message_body}' -> 'main'")
-                welcome_msg = generate_veterinary_welcome_message()
+                # Generate welcome message in detected language
+                if reply_language == 'ur':
+                    welcome_msg = (
+                        "🩺 *اپیکس بائیوٹیکل ویٹرنری اسسٹنٹ*\n\n"
+                        "آپ کا خیر مقدم ہے! میں آپ کی ویٹرنری مصنوعات کے بارے میں مدد کر سکتا ہوں۔\n\n"
+                        "📋 *مین مینو:*\n"
+                        "1️⃣ مصنوعات تلاش کریں\n"
+                        "2️⃣ زمرے براؤز کریں\n"
+                        "3️⃣ کیٹلاگ ڈاؤن لوڈ کریں\n"
+                        "4️⃣ اے آئی چیٹ موڈ\n\n"
+                        "💬 اپنا انتخاب لکھیں یا 'main' لکھ کر مین مینو پر واپس جائیں۔"
+                    )
+                else:
+                    welcome_msg = generate_veterinary_welcome_message()
+                
                 send_whatsjet_message(from_number, welcome_msg)
                 context_manager.update_context(
                     from_number, 
                     current_state='main_menu', 
                     current_menu='main_menu', 
-                    current_menu_options=list(MENU_CONFIG['main_menu']['option_descriptions'].values())
+                    current_menu_options=list(MENU_CONFIG['main_menu']['option_descriptions'].values()),
+                    reply_language=reply_language
                 )
                 return
         
         # Also check for text-based navigation commands
         if message_body.lower() in ['main', 'menu', 'start', 'home', 'back']:
-            welcome_msg = generate_veterinary_welcome_message()
+            # Generate welcome message in detected language
+            if reply_language == 'ur':
+                welcome_msg = (
+                    "🩺 *اپیکس بائیوٹیکل ویٹرنری اسسٹنٹ*\n\n"
+                    "آپ کا خیر مقدم ہے! میں آپ کی ویٹرنری مصنوعات کے بارے میں مدد کر سکتا ہوں۔\n\n"
+                    "📋 *مین مینو:*\n"
+                    "1️⃣ مصنوعات تلاش کریں\n"
+                    "2️⃣ زمرے براؤز کریں\n"
+                    "3️⃣ کیٹلاگ ڈاؤن لوڈ کریں\n"
+                    "4️⃣ اے آئی چیٹ موڈ\n\n"
+                    "💬 اپنا انتخاب لکھیں یا 'main' لکھ کر مین مینو پر واپس جائیں۔"
+                )
+            else:
+                welcome_msg = generate_veterinary_welcome_message()
+            
             send_whatsjet_message(from_number, welcome_msg)
             context_manager.update_context(
                 from_number, 
                 current_state='main_menu', 
                 current_menu='main_menu', 
-                current_menu_options=list(MENU_CONFIG['main_menu']['option_descriptions'].values())
+                current_menu_options=list(MENU_CONFIG['main_menu']['option_descriptions'].values()),
+                reply_language=reply_language
             )
             return
         
@@ -1933,7 +2031,7 @@ async def process_incoming_message(from_number: str, msg: dict):
                             current_menu='product_inquiry',
                             current_menu_options=list(MENU_CONFIG['product_inquiry']['option_descriptions'].values())
                         )
-                        await send_product_image_with_caption(from_number, selected_product, user_context)
+                        await send_product_image_with_caption(from_number, selected_product, user_context, reply_language)
                     else:
                         send_whatsjet_message(from_number, get_menu_validation_message(current_state, user_context))
                 elif current_state == 'all_products_menu':
@@ -1949,7 +2047,7 @@ async def process_incoming_message(from_number: str, msg: dict):
                                 current_menu='product_inquiry',
                                 current_menu_options=list(MENU_CONFIG['product_inquiry']['option_descriptions'].values())
                             )
-                            await send_product_image_with_caption(from_number, selected_product, user_context)
+                            await send_product_image_with_caption(from_number, selected_product, user_context, reply_language)
                         else:
                             send_whatsjet_message(from_number, get_menu_validation_message(current_state, user_context))
                     else:
@@ -1968,7 +2066,7 @@ async def process_incoming_message(from_number: str, msg: dict):
                             current_menu='product_inquiry',
                             current_menu_options=list(MENU_CONFIG['product_inquiry']['option_descriptions'].values())
                         )
-                        await send_product_image_with_caption(from_number, selected_product, user_context)
+                        await send_product_image_with_caption(from_number, selected_product, user_context, reply_language)
                         return
                     else:
                         # Check if the invalid input might be a product query
@@ -2008,7 +2106,7 @@ async def process_incoming_message(from_number: str, msg: dict):
                 current_menu_options=list(MENU_CONFIG['product_inquiry']['option_descriptions'].values())
             )
             # Only send one reply: image+caption if possible, else text
-            await send_product_image_with_caption(from_number, exact_match, user_context)
+            await send_product_image_with_caption(from_number, exact_match, user_context, reply_language)
             return
 
         # --- END NEW LOGIC ---
@@ -2041,7 +2139,7 @@ async def process_incoming_message(from_number: str, msg: dict):
                     current_menu='product_inquiry',
                     current_menu_options=list(MENU_CONFIG['product_inquiry']['option_descriptions'].values())
                 )
-                await send_product_image_with_caption(from_number, selected_product, user_context)
+                await send_product_image_with_caption(from_number, selected_product, user_context, reply_language)
                 return
             
             # If it's a category/symptom search with multiple products, show all products
@@ -2080,9 +2178,36 @@ async def handle_general_query_with_ai(from_number: str, query: str, user_contex
         
         if is_company_query:
             if reply_language == 'ur':
-                response = "🏥 *Apex Biotical Solutions*\n\nہم ایک پیشہ ور ویٹرنری پروڈکٹس کمپنی ہیں۔\n\n💬 *براہ کرم 'main' لکھ کر مین مینو پر جائیں*"
+                response = (
+                    "🏥 *Apex Biotical Solutions*\n\n"
+                    "ہم ایک پیشہ ور ویٹرنری فارماسیوٹیکل کمپنی ہیں جو مندرجہ ذیل میں مہارت رکھتے ہیں:\n\n"
+                    "📦 *ہماری مصنوعات:*\n"
+                    "• سانس کی مدد (Respira Aid Plus, Bromacid)\n"
+                    "• جگر کی صحت (Heposel, Liverpex)\n"
+                    "• مدافعتی نظام (EC-Immune)\n"
+                    "• اینٹی بائیوٹکس (Tribiotic, Para C.E)\n"
+                    "• وٹامنز اور سپلیمنٹس (Symodex, Adek Gold)\n\n"
+                    "💬 *مصنوعات دیکھنے کے لیے:*\n"
+                    "• 'main' لکھ کر مین مینو پر جائیں"
+                )
             else:
-                response = "🏥 *Apex Biotical Solutions*\n\nWe are a professional veterinary products company.\n\n💬 *Please type 'main' to go to main menu*"
+                response = (
+                    "🏥 *Apex Biotical Solutions*\n\n"
+                    "We are a leading veterinary pharmaceutical company specializing in:\n\n"
+                    "📦 *Our Products:*\n"
+                    "• Respiratory support (Respira Aid Plus, Bromacid)\n"
+                    "• Liver health (Heposel, Liverpex)\n"
+                    "• Immune system (EC-Immune)\n"
+                    "• Antibiotics (Tribiotic, Para C.E)\n"
+                    "• Vitamins & supplements (Symodex, Adek Gold)\n\n"
+                    "🌍 *Our Focus:*\n"
+                    "• Professional veterinary solutions\n"
+                    "• Quality pharmaceutical products\n"
+                    "• Comprehensive animal healthcare\n\n"
+                    "💬 *To explore our products:*\n"
+                    "• Type 'main' to see the main menu\n"
+                    "• Type a product name (e.g., 'hydropex', 'respira aid plus')"
+                )
             send_whatsjet_message(from_number, response)
             return
         
@@ -2193,29 +2318,33 @@ async def handle_clarification_response(from_number: str, response: str, user_co
         clean_response = response.strip().lower()
         
         if clean_response in ['yes', 'y', 'apex', 'apex biotical', 'apex biotical solution']:
-            # User confirmed they want Apex Biotical
-            clarification_product = user_context.get('clarification_product', 'apex biotical')
+            # User confirmed they want Apex Biotical - provide company information
+            company_info = (
+                "🏥 *Apex Biotical Solutions*\n\n"
+                "We are a leading veterinary pharmaceutical company specializing in:\n\n"
+                "📦 *Our Products:*\n"
+                "• Respiratory support (Respira Aid Plus, Bromacid)\n"
+                "• Liver health (Heposel, Liverpex)\n"
+                "• Immune system (EC-Immune)\n"
+                "• Antibiotics (Tribiotic, Para C.E)\n"
+                "• Vitamins & supplements (Symodex, Adek Gold)\n\n"
+                "🌍 *Our Focus:*\n"
+                "• Professional veterinary solutions\n"
+                "• Quality pharmaceutical products\n"
+                "• Comprehensive animal healthcare\n\n"
+                "💬 *To explore our products:*\n"
+                "• Type a product name (e.g., 'hydropex', 'respira aid plus')\n"
+                "• Type 'main' to see the main menu\n"
+                "• Ask about specific symptoms or conditions"
+            )
             
-            # Search for the product
-            products = get_veterinary_product_matches(clarification_product)
+            send_whatsjet_message(from_number, company_info)
+            
+            # Update context
+            user_context['awaiting_clarification'] = False
+            user_context.pop('clarification_product', None)
+            context_manager.update_context(from_number, **user_context)
             
-            if products:
-                # Found the product - show detailed information
-                product = products[0]
-                await send_product_with_image(from_number, product, user_context)
-                
-                # Update context
-                user_context['current_product'] = product
-                user_context['current_state'] = 'product_detail'
-                user_context['awaiting_clarification'] = False
-                user_context.pop('clarification_product', None)
-                context_manager.update_context(from_number, **user_context)
-            else:
-                # Product not found even after clarification
-                send_whatsjet_message(from_number, "❌ *Product not found. Please type 'main' to go to main menu.*")
-                user_context['awaiting_clarification'] = False
-                user_context.pop('clarification_product', None)
-                context_manager.update_context(from_number, **user_context)
         else:
             # User didn't confirm - use OpenAI for intelligent response
             if OPENAI_API_KEY:
@@ -3018,7 +3147,7 @@ def ensure_images_dir():
     logger.info(f"[Image] Ensured images directory exists: {images_dir}")
 
 # New feature: Send product image with caption (product details)
-async def send_product_image_with_caption(from_number: str, product: Dict[str, Any], user_context: Dict[str, Any]):
+async def send_product_image_with_caption(from_number: str, product: Dict[str, Any], user_context: Dict[str, Any], reply_language: str = 'en'):
     """
     Send product image (if available) with product details as caption in a single WhatsApp message.
     Only uses cPanel images from https://amgocus.com/uploads/images/
@@ -3026,7 +3155,7 @@ async def send_product_image_with_caption(from_number: str, product: Dict[str, A
     """
     ensure_images_dir()
     product_name = product.get('Product Name', 'Unknown Product')
-    details = generate_veterinary_product_response(product, user_context)
+    details = generate_veterinary_product_response(product, user_context, reply_language)
     
     logger.info(f"[Product] Processing cPanel image for product: {product_name}")
     
@@ -3128,7 +3257,7 @@ async def test_product_image_with_caption(phone: str):
         product = products_df.iloc[0].to_dict()
         user_context = {}
         
-        await send_product_image_with_caption(phone, product, user_context)
+        await send_product_image_with_caption(phone, product, user_context, 'en')
         
         return {
             "success": True,
@@ -3890,7 +4019,7 @@ async def test_send_product_image(phone: str, product_name: str = "Bromacid"):
         user_context = context_manager.get_context(phone)
         
         logger.info(f"[Test] Testing send_product_image_with_caption for product: {product_name}")
-        await send_product_image_with_caption(phone, product, user_context)
+        await send_product_image_with_caption(phone, product, user_context, 'en')
         
         return {
             "status": "sent", 
@@ -4017,13 +4146,13 @@ You are a professional veterinary product assistant for Apex Biotical. The user
 Available Products:
 {products_text}
 
-Please provide:
-1. A professional, welcoming response acknowledging their query
-2. A brief summary of what these products are for (if it's a category like "poultry products", explain the category)
-3. List all products with their numbers and brief descriptions
-4. Clear instructions on how to proceed
+Please provide a CONCISE response:
+1. Brief acknowledgment (1 line max)
+2. Simple numbered list of products with category only
+3. Clear instructions on how to proceed
 
-Format your response professionally with emojis and clear structure. Keep it concise but informative.
+Keep it SHORT and PRECISE. No marketing language, no detailed explanations, no repetition.
+Format: Brief intro + numbered list + instructions only.
 """
                         
                         response = openai.ChatCompletion.create(
@@ -4155,7 +4284,7 @@ Format your response professionally with emojis and clear structure. Keep it con
                 # Check if it might be about a product but needs clarification
                 if 'apex' in clean_query:
                     clarification_message = (
-                        "🤔 *I found a similar product in our database.*\n\n"
+                        "🤔 *Product Inquiry*\n\n"
                         "Are you asking about:\n"
                         "• Apex Biotical Solution\n"
                         "• Or something else?\n\n"