Update app.py

app.py

@@ -2086,18 +2086,21 @@ async def process_incoming_message(from_number: str, msg: dict):
         logger.info(f"[Process] Checking for product name in message: '{message_body}' from state: {current_state}")
         products = get_veterinary_product_matches(message_body)
 
-        # --- NEW LOGIC: Check for exact match first ---
+        # --- IMPROVED LOGIC: Check for exact product name match first ---
         normalized_input = normalize(message_body).lower().strip()
         exact_match = None
-        for product in products:
-            product_name = product.get('Product Name', '')
-            normalized_product_name = normalize(product_name).lower().strip()
-            if normalized_product_name == normalized_input:
-                exact_match = product
-                break
-
+        
+        # First, try to find exact product name match in the database
+        if products_df is not None and not products_df.empty:
+            for _, row in products_df.iterrows():
+                product_name = str(row.get('Product Name', '')).lower().strip()
+                normalized_product_name = normalize(product_name).lower().strip()
+                if normalized_product_name == normalized_input:
+                    exact_match = row.to_dict()
+                    logger.info(f"[Process] Exact product name match found: {exact_match.get('Product Name', 'Unknown')}")
+                    break
+        
         if exact_match:
-            logger.info(f"[Process] Exact product match found: {exact_match.get('Product Name', 'Unknown')}")
             context_manager.update_context(
                 from_number,
                 current_product=exact_match,