Upload app.py

app.py

@@ -58,6 +58,51 @@ else:
         logger.error(f"❌ Twilio client hatası: {e}")
         twilio_client = None
 
+# Mağaza stok bilgilerini çekme fonksiyonu
+def get_warehouse_stock(product_name):
+    """B2B API'den mağaza stok bilgilerini çek"""
+    try:
+        warehouse_url = 'https://video.trek-turkey.com/bizimhesap-warehouse-xml.php'
+        response = requests.get(warehouse_url, verify=False, timeout=15)
+        
+        if response.status_code != 200:
+            return None
+            
+        root = ET.fromstring(response.content)
+        
+        # Ürünü ara
+        for product in root.findall('Product'):
+            product_name_elem = product.find('ProductName')
+            if product_name_elem is not None and product_name_elem.text:
+                xml_product_name = product_name_elem.text.lower().strip()
+                search_name = product_name.lower().strip()
+                
+                # Fuzzy matching
+                if search_name in xml_product_name or xml_product_name in search_name:
+                    warehouses = product.find('Warehouses')
+                    if warehouses is not None:
+                        warehouse_info = []
+                        for warehouse in warehouses.findall('Warehouse'):
+                            name_elem = warehouse.find('Name')
+                            stock_elem = warehouse.find('Stock')
+                            
+                            if name_elem is not None and stock_elem is not None:
+                                warehouse_name = name_elem.text if name_elem.text else "Bilinmeyen"
+                                try:
+                                    stock_count = int(stock_elem.text) if stock_elem.text else 0
+                                    if stock_count > 0:
+                                        warehouse_info.append(f"{warehouse_name}: {stock_count} adet")
+                                except (ValueError, TypeError):
+                                    pass
+                        
+                        return warehouse_info if warehouse_info else ["Hiçbir mağazada stokta bulunmuyor"]
+        
+        return ["Ürün bulunamadı"]
+        
+    except Exception as e:
+        print(f"Mağaza stok bilgisi çekme hatası: {e}")
+        return None
+
 # Trek bisiklet ürünlerini çekme - DÜZELTİLMİŞ VERSİYON
 try:
     print("🔍 XML DEBUG TEST BAŞLADI")
@@ -707,13 +752,36 @@ def process_whatsapp_message_with_memory(user_message, phone_number):
             try:
                 product_result = improved_whatsapp_bot.process_message(user_message)
                 if product_result['is_product_query'] and product_result['response']:
-                    # Use improved search response directly
-                    messages.append({
-                        "role": "system",
-                        "content": f"ÜRÜN BİLGİSİ (BF Space):\n{product_result['response']}\n\nSADECE bu bilgileri kullanarak kullanıcıya yardımcı ol. Bu bilgiler dışında ek bilgi ekleme."
-                    })
-                    product_found_improved = True
-                    logger.info("✅ BF Space: Improved product search used")
+                    # Check if user is asking about specific warehouse/store location
+                    if any(keyword in user_message.lower() for keyword in ['mağaza', 'mağazada', 'nerede', 'hangi mağaza', 'şube']):
+                        # Get warehouse stock info for the found products
+                        if product_result['products_found']:
+                            warehouse_info_parts = []
+                            for product in product_result['products_found'][:2]:  # Max 2 products
+                                product_name = product[2]  # Full product name
+                                warehouse_stock = get_warehouse_stock(product_name)
+                                if warehouse_stock:
+                                    warehouse_info_parts.append(f"{product_name} mağaza stogu:")
+                                    warehouse_info_parts.extend(warehouse_stock)
+                                    warehouse_info_parts.append("")
+                            
+                            if warehouse_info_parts:
+                                warehouse_response = "\n".join(warehouse_info_parts)
+                                messages.append({
+                                    "role": "system",
+                                    "content": f"MAĞAZA STOK BİLGİSİ (BF Space):\n{warehouse_response}\n\nSADECE bu bilgileri kullanarak kullanıcıya yardımcı ol."
+                                })
+                                product_found_improved = True
+                                logger.info("✅ BF Space: Warehouse stock info used")
+                    
+                    if not product_found_improved:
+                        # Use improved search response directly
+                        messages.append({
+                            "role": "system",
+                            "content": f"ÜRÜN BİLGİSİ (BF Space):\n{product_result['response']}\n\nSADECE bu bilgileri kullanarak kullanıcıya yardımcı ol. Bu bilgiler dışında ek bilgi ekleme."
+                        })
+                        product_found_improved = True
+                        logger.info("✅ BF Space: Improved product search used")
             except Exception as e:
                 logger.error(f"❌ BF Space: Improved search error: {e}")
         
@@ -896,11 +964,33 @@ def process_whatsapp_message(user_message):
             try:
                 product_result = improved_whatsapp_bot.process_message(user_message)
                 if product_result['is_product_query'] and product_result['response']:
-                    system_messages.append({
-                        "role": "system",
-                        "content": f"ÜRÜN BİLGİSİ (BF Space Backup):\n{product_result['response']}\n\nSADECE bu bilgileri kullanarak kullanıcıya yardımcı ol. Bu bilgiler dışında ek bilgi ekleme."
-                    })
-                    product_found_improved = True
+                    # Check if user is asking about specific warehouse/store location
+                    if any(keyword in user_message.lower() for keyword in ['mağaza', 'mağazada', 'nerede', 'hangi mağaza', 'şube']):
+                        # Get warehouse stock info for the found products
+                        if product_result['products_found']:
+                            warehouse_info_parts = []
+                            for product in product_result['products_found'][:2]:  # Max 2 products
+                                product_name = product[2]  # Full product name
+                                warehouse_stock = get_warehouse_stock(product_name)
+                                if warehouse_stock:
+                                    warehouse_info_parts.append(f"{product_name} mağaza stogu:")
+                                    warehouse_info_parts.extend(warehouse_stock)
+                                    warehouse_info_parts.append("")
+                            
+                            if warehouse_info_parts:
+                                warehouse_response = "\n".join(warehouse_info_parts)
+                                system_messages.append({
+                                    "role": "system",
+                                    "content": f"MAĞAZA STOK BİLGİSİ (BF Space Backup):\n{warehouse_response}\n\nSADECE bu bilgileri kullanarak kullanıcıya yardımcı ol."
+                                })
+                                product_found_improved = True
+                    
+                    if not product_found_improved:
+                        system_messages.append({
+                            "role": "system",
+                            "content": f"ÜRÜN BİLGİSİ (BF Space Backup):\n{product_result['response']}\n\nSADECE bu bilgileri kullanarak kullanıcıya yardımcı ol. Bu bilgiler dışında ek bilgi ekleme."
+                        })
+                        product_found_improved = True
             except Exception as e:
                 print(f"BF Space backup: Improved search error: {e}")