Update app.py

app.py

@@ -51,6 +51,17 @@ def normalize_turkish(text):
         text = text.replace(tr_char, eng_char)
     return text
 
+# NEW: Basit retry/backoff'lu güvenli GET wrapper
+def safe_get(url, timeout=5, retries=2, verify=False, **kwargs):
+    last_exc = None
+    for i in range(retries + 1):
+        try:
+            return requests.get(url, timeout=timeout, verify=verify, **kwargs)
+        except requests.RequestException as e:
+            last_exc = e
+            time.sleep(0.3 * (2 ** i))
+    raise last_exc
+
 def fetch_warehouse_inventory(warehouse, product_name, search_terms):
     """Tek bir mağazanın stok bilgisini al"""
     try:
@@ -62,7 +73,8 @@ def fetch_warehouse_inventory(warehouse, product_name, search_terms):
         
         # 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)
+        # CHANGED: requests.get -> safe_get
+        inventory_response = safe_get(inventory_url, timeout=5, verify=False)
         
         if inventory_response.status_code != 200:
             return None
@@ -102,7 +114,6 @@ def fetch_warehouse_inventory(warehouse, product_name, search_terms):
             # Eğer sadece beden sorgusu ise
             if is_only_size_query:
                 # Beden terimini ürün başlığında ara (parantez içinde veya dışında)
-                # Örnek: "Marlin 5 (M)" veya "Marlin 5 M" veya "Marlin 5 - M"
                 if size_query in product_title.split() or f'({size_query})' in product_title or f' {size_query} ' in product_title or product_title.endswith(f' {size_query}'):
                     qty = int(product.get('qty', 0))
                     stock = int(product.get('stock', 0))
@@ -217,7 +228,8 @@ def get_realtime_stock_parallel(product_name):
         
         # Ö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)
+        # CHANGED: requests.get -> safe_get
+        warehouses_response = safe_get(warehouses_url, timeout=5, verify=False)
         
         if warehouses_response.status_code != 200:
             print(f"Mağaza listesi alınamadı: {warehouses_response.status_code}")
@@ -297,7 +309,8 @@ def get_realtime_stock(product_name):
     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=3, verify=False)  # Timeout 3 saniye
+        # CHANGED: requests.get -> safe_get
+        warehouses_response = safe_get(warehouses_url, timeout=5, verify=False)  # Timeout 5 saniye
         
         if warehouses_response.status_code != 200:
             print(f"Mağaza listesi alınamadı: {warehouses_response.status_code}")
@@ -330,7 +343,8 @@ 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=3, verify=False)  # Timeout 3 saniye
+            # CHANGED: requests.get -> safe_get
+            inventory_response = safe_get(inventory_url, timeout=5, verify=False)  # Timeout 5 saniye
             
             if inventory_response.status_code != 200:
                 continue
@@ -453,13 +467,21 @@ OPENAI_API_KEY = os.getenv("OPENAI_API_KEY")
 if not OPENAI_API_KEY:
     print("Hata: OPENAI_API_KEY çevre değişkeni ayarlanmamış!")
 
+# NEW: V1 bayrağı (stok sorularında LLM bypass)
+GROUND_STOCK_ONLY = os.getenv("GROUND_STOCK_ONLY", "1") == "1"
+
 # Trek bisiklet ürünlerini çekme
 url = 'https://www.trekbisiklet.com.tr/output/8582384479'
-response = requests.get(url, verify=False, timeout=60)
-if response.status_code == 200 and response.content:
-    root = ET.fromstring(response.content)
-else:
-    print(f"HTTP hatası: {response.status_code}")
+# CHANGED: requests.get -> safe_get
+try:
+    response = safe_get(url, verify=False, timeout=60)
+    if response.status_code == 200 and response.content:
+        root = ET.fromstring(response.content)
+    else:
+        print(f"HTTP hatası: {response.status_code}")
+        root = None
+except Exception as e:
+    print(f"XML çekme hatası: {e}")
     root = None
 
 products = []
@@ -476,9 +498,15 @@ if root is not None:
         name = name_words[0]
         full_name = ' '.join(name_words)
         
-        stock_amount = "stokta" if stock_elem.text and stock_elem.text > '0' else "stokta değil"
+        # CHANGED: stok kontrolü int'e çevrildi
+        try:
+            stock_val = int((stock_elem.text or "0").strip())
+        except (ValueError, TypeError):
+            stock_val = 0
+        stock_amount = "stokta" if stock_val > 0 else "stokta değil"
         
-        # Stokta olmayan ürünler için fiyat/link bilgisi eklemiyoruz
+        # Stokta olmayan ürünler için fiyat/link bilgisi yine saklanıyor (aşağıda)
+        # Stokta olanlar için detaylar
         if stock_amount == "stokta":
             # Normal fiyat bilgisini al - Güvenli versiyon
             price_elem = item.find('priceTaxWithCur')
@@ -492,42 +520,34 @@ if root is not None:
             price_rebate_elem = item.find('priceRebateWithTax')
             price_rebate_str = price_rebate_elem.text if price_rebate_elem is not None and price_rebate_elem.text else ""
             
-            # Havale indirimi fiyatını al (havale indirimli kampanyalı fiyat) - Güvenli versiyon
+            # Havale indirimli kampanyalı fiyatı - Güvenli versiyon
             price_rebate_money_order_elem = item.find('priceRebateWithMoneyOrderWithTax')
             price_rebate_money_order_str = price_rebate_money_order_elem.text if price_rebate_money_order_elem is not None and price_rebate_money_order_elem.text else ""
             
             # Normal fiyatı yuvarla
             try:
                 price_float = float(price_str)
-                # Fiyat 200000 üzerindeyse en yakın 5000'lik basamağa yuvarla
                 if price_float > 200000:
-                    price = str(round(price_float / 5000) * 5000)  # En yakın 5000'e yuvarla
-                # Fiyat 30000 üzerindeyse en yakın 1000'lik basamağa yuvarla
+                    price = str(round(price_float / 5000) * 5000)
                 elif price_float > 30000:
-                    price = str(round(price_float / 1000) * 1000)  # En yakın 1000'e yuvarla
-                # Fiyat 10000 üzerindeyse en yakın 100'lük basamağa yuvarla
+                    price = str(round(price_float / 1000) * 1000)
                 elif price_float > 10000:
-                    price = str(round(price_float / 100) * 100)  # En yakın 100'e yuvarla
-                # Diğer durumlarda en yakın 10'luk basamağa yuvarla
+                    price = str(round(price_float / 100) * 100)
                 else:
-                    price = str(round(price_float / 10) * 10)  # En yakın 10'a yuvarla
+                    price = str(round(price_float / 10) * 10)
             except (ValueError, TypeError):
-                price = price_str  # Sayıya dönüştürülemezse olduğu gibi bırak
+                price = price_str
             
             # Havale indirimli orijinal fiyatı yuvarla (varsa)
             if price_eft_str:
                 try:
                     price_eft_float = float(price_eft_str)
-                    # Fiyat 200000 üzerindeyse en yakın 5000'lik basamağa yuvarla
                     if price_eft_float > 200000:
                         price_eft = str(round(price_eft_float / 5000) * 5000)
-                    # Fiyat 30000 üzerindeyse en yakın 1000'lik basamağa yuvarla
                     elif price_eft_float > 30000:
                         price_eft = str(round(price_eft_float / 1000) * 1000)
-                    # Fiyat 10000 üzerindeyse en yakın 100'lük basamağa yuvarla
                     elif price_eft_float > 10000:
                         price_eft = str(round(price_eft_float / 100) * 100)
-                    # Diğer durumlarda en yakın 10'luk basamağa yuvarla
                     else:
                         price_eft = str(round(price_eft_float / 10) * 10)
                 except (ValueError, TypeError):
@@ -539,16 +559,12 @@ if root is not None:
             if price_rebate_str:
                 try:
                     price_rebate_float = float(price_rebate_str)
-                    # Fiyat 200000 üzerindeyse en yakın 5000'lik basamağa yuvarla
                     if price_rebate_float > 200000:
                         price_rebate = str(round(price_rebate_float / 5000) * 5000)
-                    # Fiyat 30000 üzerindeyse en yakın 1000'lik basamağa yuvarla
                     elif price_rebate_float > 30000:
                         price_rebate = str(round(price_rebate_float / 1000) * 1000)
-                    # Fiyat 10000 üzerindeyse en yakın 100'lük basamağa yuvarla
                     elif price_rebate_float > 10000:
                         price_rebate = str(round(price_rebate_float / 100) * 100)
-                    # Diğer durumlarda en yakın 10'luk basamağa yuvarla
                     else:
                         price_rebate = str(round(price_rebate_float / 10) * 10)
                 except (ValueError, TypeError):
@@ -556,20 +572,16 @@ if root is not None:
             else:
                 price_rebate = ""
             
-            # Havale indirimli kampanyalı fiyatı yuvarla (varsa)
+            # Havale indirimli kampanyalı fiyatı (varsa)
             if price_rebate_money_order_str:
                 try:
                     price_rebate_money_order_float = float(price_rebate_money_order_str)
-                    # Fiyat 200000 üzerindeyse en yakın 5000'lik basamağa yuvarla
                     if price_rebate_money_order_float > 200000:
                         price_rebate_money_order = str(round(price_rebate_money_order_float / 5000) * 5000)
-                    # Fiyat 30000 üzerindeyse en yakın 1000'lik basamağa yuvarla
                     elif price_rebate_money_order_float > 30000:
                         price_rebate_money_order = str(round(price_rebate_money_order_float / 1000) * 1000)
-                    # Fiyat 10000 üzerindeyse en yakın 100'lük basamağa yuvarla
                     elif price_rebate_money_order_float > 10000:
                         price_rebate_money_order = str(round(price_rebate_money_order_float / 100) * 100)
-                    # Diğer durumlarda en yakın 10'luk basamağa yuvarla
                     else:
                         price_rebate_money_order = str(round(price_rebate_money_order_float / 10) * 10)
                 except (ValueError, TypeError):
@@ -660,14 +672,14 @@ def download_documents_from_drive():
                 file_io.seek(0)
                 doc = Document(file_io)
                 
-                content = f"\\n=== {file['name']} ===\\n"
+                content = f"\n=== {file['name']} ===\n"
                 for paragraph in doc.paragraphs:
                     if paragraph.text.strip():
-                        content += paragraph.text + "\\n"
+                        content += paragraph.text + "\n"
                 
                 all_content.append(content)
         
-        document_content = "\\n".join(all_content)
+        document_content = "\n".join(all_content)
         print(f"Toplam {len(files)} döküman yüklendi.")
         
     except Exception as e:
@@ -683,7 +695,7 @@ def clear_log_file():
         if os.path.exists(LOG_FILE):
             with file_lock:
                 with open(LOG_FILE, 'w', encoding='utf-8') as f:
-                    f.write("Log dosyası temizlendi.\\n")
+                    f.write("Log dosyası temizlendi.\n")
             print("Log dosyası temizlendi.")
     except Exception as e:
         print(f"Log dosyası temizleme hatası: {e}")
@@ -696,11 +708,68 @@ def run_scheduler(chat_history):
         schedule.run_pending()
         time.sleep(60)
 
+# NEW: Stok sorularına deterministik, tamamen veri tabanlı yanıt
+def answer_stock_grounded(user_message):
+    """
+    Stok sorularına tamamen veri-tabanlı, deterministik yanıt üretir.
+    Yalnızca API + XML kullanır, LLM'ye gitmez.
+    """
+    # 1) Ürün adı çıkarma (mevcut mantığın güvenli versiyonu)
+    skip_words = ['stok','stock','kaç','adet','tane','var','mı','mi','mevcut','mu','bulunuyor',
+                  'hangi','mağaza','nerede','durumu','stoklarda','stokta',
+                  'için','ve','ile','toplam','toplamda','fiyat','fiyatı','ne','nedir','kadar',
+                  'beden','bedeni','bedenli']
+    words = [w for w in user_message.lower().split() if w not in skip_words]
+    if not words:
+        return "Hangi ürün için stok bakmamı istersiniz?"
+
+    # Sadece beden mi sorulmuş?
+    size_terms = {'xs','s','m','ml','l','xl','xxl','2xl','3xl','small','medium','large',
+                  '44','46','48','50','52','54','56','58','60'}
+    is_only_size = (len(words) == 1 and words[0] in size_terms)
+    product_name = words[0] if is_only_size else ' '.join(words)
+
+    # 2) Gerçek zamanlı stok (paralel)
+    stock_text = get_realtime_stock_parallel(product_name)
+    if not stock_text:
+        return f"'{product_name}' için stok bilgisine şu an erişemedim."
+
+    # 3) XML’den (varsa) fiyat/link/resim ekle (sadece veride olanı)
+    norm_query = normalize_turkish(product_name).replace(" ", "")
+    extra_lines = []
+    added = 0
+    try:
+        for name, info, full_name in products:
+            if added >= 3:  # Aşırı büyümeyi engelle
+                break
+            norm_full = normalize_turkish(full_name).replace(" ", "")
+            if norm_query and norm_query in norm_full:
+                normal_price = f"\nFiyat: {info[1]} TL" if len(info) > 1 and info[1] else ""
+                product_link = f"\nÜrün linki: {info[2]}" if len(info) > 2 and info[2] else ""
+                product_image = f"\nÜrün resmi: {info[6]}" if len(info) > 6 and info[6] else ""
+                eft = f"\nHavale indirimi: {info[3]} TL" if len(info) > 3 and info[3] else ""
+                rebate = f"\nKampanyalı fiyat: {info[4]} TL" if len(info) > 4 and info[4] else ""
+                rebate_mo = f"\nHavale kampanyalı: {info[5]} TL" if len(info) > 5 and info[5] else ""
+                extra_lines.append(f"{full_name} (veriden):{normal_price}{rebate}{eft}{rebate_mo}{product_link}{product_image}")
+                added += 1
+    except Exception:
+        pass
+
+    extra_block = ("\n\n" + "\n---\n".join(extra_lines)) if extra_lines else ""
+    return f"{stock_text}{extra_block}"
+
 # Chatbot fonksiyonu - STOK API ENTEGRASYONU EKLENDİ
 def chatbot_fn(user_message, history, image=None):
     if history is None:
         history = []
 
+    # NEW: Grounded stock only — stok sorgusuysa LLM'yi tamamen bypass
+    if is_stock_query(user_message) and GROUND_STOCK_ONLY:
+        print("Grounded stok modu: LLM devre dışı, veri tabanlı yanıt oluşturuluyor...")
+        deterministic_answer = answer_stock_grounded(user_message)
+        yield deterministic_answer
+        return
+
     try:
         # Enhanced features - Görsel işleme
         if image is not None:
@@ -719,7 +788,7 @@ def chatbot_fn(user_message, history, image=None):
     try:
         with file_lock:
             with open(LOG_FILE, 'a', encoding='utf-8') as f:
-                f.write(f"User: {user_message}\\n")
+                f.write(f"User: {user_message}\n")
     except Exception as e:
         print(f"Dosya yazma hatası (Kullanıcı): {e}")
 
@@ -730,12 +799,11 @@ def chatbot_fn(user_message, history, image=None):
     if document_content:
         system_messages.append({"role": "system", "content": f"Dökümanlardan gelen bilgiler: {document_content[:3000]}"})  # Token limiti için kısalt
     
-    # STOK SORGUSU KONTROLÜ - YENİ EKLENEN KISIM
-    if is_stock_query(user_message):
+    # STOK SORGUSU KONTROLÜ - (Eski yol) sadece GROUND_STOCK_ONLY kapalıysa
+    if is_stock_query(user_message) and not GROUND_STOCK_ONLY:
         print("Stok sorgusu algılandı, API'den veri çekiliyor...")
         
         # Mesajdan ürün adını çıkarmaya çalış
-        # Basit bir yaklaşım: stok kelimelerini temizleyip kalan kelimeleri ürün adı olarak kullan
         product_words = []
         skip_words = ['stok', 'stock', 'kaç', 'adet', 'tane', 'var', 'mı', 'mi', 
                       'mevcut', 'mu', 'bulunuyor', 'hangi', 'mağaza', 'nerede', 
@@ -845,7 +913,7 @@ def chatbot_fn(user_message, history, image=None):
                         
                         # Fiyat bilgisi varsa al
                         if len(product_info[1]) > 1 and product_info[1][1]:
-                            normal_price = f"\\nFiyat: {product_info[1][1]} TL"
+                            normal_price = f"\nFiyat: {product_info[1][1]} TL"
                             print(f"Fiyat bulundu: {product_info[1][1]}")
                         else:
                             normal_price = ""
@@ -857,7 +925,7 @@ def chatbot_fn(user_message, history, image=None):
                         rebate_money_order_price = ""
                         
                         if len(product_info[1]) > 4 and product_info[1][4] and product_info[1][4] != "":
-                            rebate_price = f"\\nKampanyalı fiyat: {product_info[1][4]} TL"
+                            rebate_price = f"\nKampanyalı fiyat: {product_info[1][4]} TL"
                             
                             try:
                                 normal_price_float = float(product_info[1][1])
@@ -874,26 +942,26 @@ def chatbot_fn(user_message, history, image=None):
                                     else:
                                         discount_amount_rounded = round(discount_amount / 10) * 10
                                         
-                                    discount_info = f"\\nYapılan indirim: {discount_amount_rounded:.0f} TL"
+                                    discount_info = f"\nYapılan indirim: {discount_amount_rounded:.0f} TL"
                             except (ValueError, TypeError):
                                 discount_info = ""
                             
                             rebate_money_order_price = ""
                         else:
                             if product_info[1][3] and product_info[1][3] != "":
-                                eft_price = f"\\nHavale indirimli fiyat: {product_info[1][3]} TL"
+                                eft_price = f"\nHavale indirimli fiyat: {product_info[1][3]} TL"
                         
-                        product_link = f"\\nÜrün linki: {product_info[1][2]}"
+                        product_link = f"\nÜrün linki: {product_info[1][2]}"
                         product_image = ""
                         if len(product_info[1]) > 6 and product_info[1][6]:
-                            product_image = f"\\nÜrün resmi: {product_info[1][6]}"
+                            product_image = f"\nÜrün resmi: {product_info[1][6]}"
                         
                         # API'den stok alındıysa sadece fiyat/görsel/link ekle
                         if has_stock_from_api:
-                            new_msg = f"ÜRÜN BİLGİLERİ (Fiyat/Link):\\n{normal_price}{rebate_price}{discount_info}{eft_price}{rebate_money_order_price}{product_link}{product_image}"
+                            new_msg = f"ÜRÜN BİLGİLERİ (Fiyat/Link):\n{normal_price}{rebate_price}{discount_info}{eft_price}{rebate_money_order_price}{product_link}{product_image}"
                         else:
                             # API'den stok alınmadıysa hem stok hem fiyat bilgisi ekle
-                            new_msg = f"{product_info[2]} {product_info[1][0]}\\n{normal_price}{rebate_price}{discount_info}{eft_price}{rebate_money_order_price}{product_link}{product_image}"
+                            new_msg = f"{product_info[2]} {product_info[1][0]}\n{normal_price}{rebate_price}{discount_info}{eft_price}{rebate_money_order_price}{product_link}{product_image}"
                     else:
                         # Stokta değilse
                         if has_stock_from_api:
@@ -963,7 +1031,7 @@ def chatbot_fn(user_message, history, image=None):
     try:
         with file_lock:
             with open(LOG_FILE, 'a', encoding='utf-8') as f:
-                f.write(f"Bot: {partial_response}\\n")
+                f.write(f"Bot: {partial_response}\n")
     except Exception as e:
         print(f"Dosya yazma hatası (Bot): {e}")
 
@@ -1247,4 +1315,4 @@ with gr.Blocks(css=custom_css, theme="soft", title="Trek Asistanı", head=storag
     msg.submit(respond, [msg, chatbot], [msg, chatbot], show_progress=True)
 
 if __name__ == "__main__":
-    demo.launch(debug=True)
+    demo.launch(debug=True)