Performance optimization: Add parallel API calls and caching for faster stock queries

app.py

@@ -6,6 +6,7 @@ import xml.etree.ElementTree as ET
 import schedule
 import time
 import threading
+from concurrent.futures import ThreadPoolExecutor, as_completed
 from huggingface_hub import HfApi, create_repo, hf_hub_download
 import warnings
 import pandas as pd
@@ -32,6 +33,10 @@ from image_renderer import extract_product_info_for_gallery, format_message_with
 # STOK API ENTEGRASYONU - YENİ EKLENEN KISIM
 STOCK_API_BASE = "https://video.trek-turkey.com/bizimhesap-proxy.php"
 
+# Stock cache (5 dakikalık cache)
+stock_cache = {}
+CACHE_DURATION = 300  # 5 dakika (saniye cinsinden)
+
 def normalize_turkish(text):
     """Türkçe karakterleri normalize et"""
     if not text:
@@ -46,12 +51,183 @@ def normalize_turkish(text):
         text = text.replace(tr_char, eng_char)
     return text
 
+def fetch_warehouse_inventory(warehouse, product_name, search_terms):
+    """Tek bir mağazanın stok bilgisini al"""
+    try:
+        warehouse_id = warehouse['id']
+        warehouse_name = warehouse['title']
+        
+        # DSW'yi ayrı tut (gelecek stok için)
+        is_dsw = 'DSW' in warehouse_name or 'ÖN SİPARİŞ' in warehouse_name.upper()
+        
+        # Mağaza stoklarını al
+        inventory_url = f"{STOCK_API_BASE}?action=inventory&warehouse={warehouse_id}&endpoint=inventory/{warehouse_id}"
+        inventory_response = requests.get(inventory_url, timeout=3, verify=False)
+        
+        if inventory_response.status_code != 200:
+            return None
+            
+        inventory_data = inventory_response.json()
+        
+        # API yanıtını kontrol et
+        if 'data' not in inventory_data or 'inventory' not in inventory_data['data']:
+            return None
+        
+        products = inventory_data['data']['inventory']
+        
+        # Ürünü ara
+        warehouse_variants = []
+        dsw_stock_count = 0
+        
+        for product in products:
+            product_title = normalize_turkish(product.get('title', '')).lower()
+            original_title = product.get('title', '')
+            
+            # Tüm arama terimlerinin ürün başlığında olup olmadığını kontrol et
+            if all(term in product_title for term in search_terms):
+                qty = int(product.get('qty', 0))
+                stock = int(product.get('stock', 0))
+                actual_stock = max(qty, stock)
+                
+                if actual_stock > 0:
+                    # DSW ise gelecek stok olarak say
+                    if is_dsw:
+                        dsw_stock_count += actual_stock
+                        continue
+                    
+                    # Normal mağaza stoğu - varyant detayını sakla
+                    variant_info = original_title
+                    
+                    # Ürün adını temizle
+                    possible_names = [
+                        product_name.upper(), 
+                        product_name.lower(), 
+                        product_name.title(),
+                        product_name.upper().replace('I', 'İ'),
+                        product_name.upper().replace('İ', 'I'),
+                    ]
+                    
+                    if 'fx sport' in product_name.lower():
+                        possible_names.extend(['FX Sport AL 3', 'FX SPORT AL 3', 'Fx Sport Al 3'])
+                    
+                    for possible_name in possible_names:
+                        variant_info = variant_info.replace(possible_name, '').strip()
+                    
+                    variant_info = ' '.join(variant_info.split())
+                    
+                    if variant_info and variant_info != original_title:
+                        warehouse_variants.append(f"{variant_info}: ✓ Stokta")
+                    else:
+                        warehouse_variants.append(f"{original_title}: ✓ Stokta")
+        
+        # Sonuç döndür
+        if warehouse_variants and not is_dsw:
+            return {'warehouse': warehouse_name, 'variants': warehouse_variants, 'is_dsw': False}
+        elif dsw_stock_count > 0:
+            return {'dsw_stock': dsw_stock_count, 'is_dsw': True}
+        
+        return None
+        
+    except Exception:
+        return None
+
+def get_realtime_stock_parallel(product_name):
+    """API'den gerçek zamanlı stok bilgisini çek - Paralel versiyon with cache"""
+    try:
+        # Cache kontrolü
+        cache_key = normalize_turkish(product_name).lower()
+        current_time = time.time()
+        
+        if cache_key in stock_cache:
+            cached_data, cached_time = stock_cache[cache_key]
+            # Cache hala geçerli mi?
+            if current_time - cached_time < CACHE_DURATION:
+                print(f"Cache'den döndürülüyor: {product_name}")
+                return cached_data
+        
+        # Önce mağaza listesini al
+        warehouses_url = f"{STOCK_API_BASE}?action=warehouses&endpoint=warehouses"
+        warehouses_response = requests.get(warehouses_url, timeout=3, verify=False)
+        
+        if warehouses_response.status_code != 200:
+            print(f"Mağaza listesi alınamadı: {warehouses_response.status_code}")
+            return None
+            
+        warehouses_data = warehouses_response.json()
+        
+        # API yanıtını kontrol et
+        if 'data' not in warehouses_data or 'warehouses' not in warehouses_data['data']:
+            print("Mağaza verisi bulunamadı")
+            return None
+        
+        warehouses = warehouses_data['data']['warehouses']
+        
+        # Ürün adını normalize et
+        search_terms = normalize_turkish(product_name).lower().split()
+        print(f"Aranan ürün: {product_name} -> {search_terms}")
+        
+        stock_info = {}
+        total_dsw_stock = 0
+        total_stock = 0
+        
+        # Paralel olarak tüm mağazaları sorgula
+        with ThreadPoolExecutor(max_workers=10) as executor:
+            # Tüm mağazalar için görev oluştur
+            futures = {
+                executor.submit(fetch_warehouse_inventory, warehouse, product_name, search_terms): warehouse 
+                for warehouse in warehouses
+            }
+            
+            # Sonuçları topla
+            for future in as_completed(futures):
+                result = future.result()
+                if result:
+                    if result.get('is_dsw'):
+                        total_dsw_stock += result.get('dsw_stock', 0)
+                    else:
+                        warehouse_name = result['warehouse']
+                        stock_info[warehouse_name] = result['variants']
+                        total_stock += 1  # En az bir mağazada var
+        
+        # Sonucu oluştur
+        if not stock_info:
+            # Mağazada yok ama DSW'de varsa
+            if total_dsw_stock > 0:
+                result = f"{product_name}: Şu anda mağazalarda stokta yok, ancak yakında gelecek. Ön sipariş verebilirsiniz."
+            else:
+                result = f"{product_name}: Şu anda hiçbir mağazada stokta bulunmuyor."
+        else:
+            # Minimal prompt oluştur - varyant detaylarıyla
+            prompt_lines = [f"{product_name} stok durumu:"]
+            for warehouse, variants in stock_info.items():
+                if isinstance(variants, list):
+                    prompt_lines.append(f"- {warehouse}:")
+                    for variant in variants:
+                        prompt_lines.append(f"  • {variant}")
+                else:
+                    prompt_lines.append(f"- {warehouse}: {variants}")
+            
+            # Güvenlik: Toplam adet bilgisi gösterme
+            if total_stock > 0:
+                prompt_lines.append(f"✓ Ürün stokta mevcut")
+            
+            result = "\n".join(prompt_lines)
+        
+        # Sonucu cache'e kaydet
+        stock_cache[cache_key] = (result, current_time)
+        
+        return result
+    
+    except Exception as e:
+        print(f"API hatası: {e}")
+        return None
+
 def get_realtime_stock(product_name):
     """API'den gerçek zamanlı stok bilgisini çek - Minimal versiyon"""
     try:
         # Önce mağaza listesini al - endpoint parametresi eklendi
         warehouses_url = f"{STOCK_API_BASE}?action=warehouses&endpoint=warehouses"
-        warehouses_response = requests.get(warehouses_url, timeout=5, verify=False)
+        warehouses_response = requests.get(warehouses_url, timeout=3, verify=False)  # Timeout 3 saniye
         
         if warehouses_response.status_code != 200:
             print(f"Mağaza listesi alınamadı: {warehouses_response.status_code}")
@@ -84,7 +260,7 @@ def get_realtime_stock(product_name):
             
             # Mağaza stoklarını al - endpoint parametresi eklendi
             inventory_url = f"{STOCK_API_BASE}?action=inventory&warehouse={warehouse_id}&endpoint=inventory/{warehouse_id}"
-            inventory_response = requests.get(inventory_url, timeout=5, verify=False)
+            inventory_response = requests.get(inventory_url, timeout=3, verify=False)  # Timeout 3 saniye
             
             if inventory_response.status_code != 200:
                 continue
@@ -507,7 +683,7 @@ def chatbot_fn(user_message, history, image=None):
             all_stock_info = []
             
             # Önce direkt API'de ara
-            stock_info = get_realtime_stock(product_name)
+            stock_info = get_realtime_stock_parallel(product_name)
             if stock_info:
                 all_stock_info.append((product_name, stock_info))
             
@@ -515,12 +691,12 @@ def chatbot_fn(user_message, history, image=None):
             if len(product_words) <= 2 and 'fx' in product_name:
                 # FX 3 varsa ara
                 if '3' in product_name:
-                    fx3_info = get_realtime_stock('fx 3')
+                    fx3_info = get_realtime_stock_parallel('fx 3')
                     if fx3_info:
                         all_stock_info.append(('FX 3', fx3_info))
                     
                     # FX Sport AL 3 de ara
-                    fx_sport_info = get_realtime_stock('fx sport al 3')
+                    fx_sport_info = get_realtime_stock_parallel('fx sport al 3')
                     if fx_sport_info:
                         all_stock_info.append(('FX Sport AL 3', fx_sport_info))