Update app.py

app.py

@@ -18,7 +18,6 @@ from googleapiclient.http import MediaIoBaseDownload
 import io
 import warnings
 from requests.packages.urllib3.exceptions import InsecureRequestWarning
-import re  # NEW: yıl tespiti için
 warnings.simplefilter('ignore', InsecureRequestWarning)
 
 # Prompt dosyasını import et
@@ -52,17 +51,6 @@ 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:
@@ -74,8 +62,7 @@ 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}"
-        # CHANGED: requests.get -> safe_get
-        inventory_response = safe_get(inventory_url, timeout=5, verify=False)
+        inventory_response = requests.get(inventory_url, timeout=3, verify=False)
         
         if inventory_response.status_code != 200:
             return None
@@ -115,6 +102,7 @@ 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))
@@ -229,8 +217,7 @@ def get_realtime_stock_parallel(product_name):
         
         # Önce mağaza listesini al
         warehouses_url = f"{STOCK_API_BASE}?action=warehouses&endpoint=warehouses"
-        # CHANGED: requests.get -> safe_get
-        warehouses_response = safe_get(warehouses_url, timeout=5, verify=False)
+        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}")
@@ -310,8 +297,7 @@ 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"
-        # CHANGED: requests.get -> safe_get
-        warehouses_response = safe_get(warehouses_url, timeout=5, verify=False)  # Timeout 5 saniye
+        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}")
@@ -344,8 +330,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}"
-            # CHANGED: requests.get -> safe_get
-            inventory_response = safe_get(inventory_url, timeout=5, verify=False)  # Timeout 5 saniye
+            inventory_response = requests.get(inventory_url, timeout=3, verify=False)  # Timeout 3 saniye
             
             if inventory_response.status_code != 200:
                 continue
@@ -468,21 +453,13 @@ 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'
-# 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}")
+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}")
     root = None
 
 products = []
@@ -499,15 +476,9 @@ if root is not None:
         name = name_words[0]
         full_name = ' '.join(name_words)
         
-        # 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"
+        stock_amount = "stokta" if stock_elem.text and stock_elem.text > '0' else "stokta değil"
         
-        # Stokta olmayan ürünler için fiyat/link bilgisi yine saklanıyor (aşağıda)
-        # Stokta olanlar için detaylar
+        # Stokta olmayan ürünler için fiyat/link bilgisi eklemiyoruz
         if stock_amount == "stokta":
             # Normal fiyat bilgisini al - Güvenli versiyon
             price_elem = item.find('priceTaxWithCur')
@@ -521,34 +492,42 @@ 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 indirimli kampanyalı fiyatı - Güvenli versiyon
+            # Havale indirimi fiyatını al (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)
+                    price = str(round(price_float / 5000) * 5000)  # En yakın 5000'e yuvarla
+                # Fiyat 30000 üzerindeyse en yakın 1000'lik basamağa yuvarla
                 elif price_float > 30000:
-                    price = str(round(price_float / 1000) * 1000)
+                    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
                 elif price_float > 10000:
-                    price = str(round(price_float / 100) * 100)
+                    price = str(round(price_float / 100) * 100)  # En yakın 100'e yuvarla
+                # Diğer durumlarda en yakın 10'luk basamağa yuvarla
                 else:
-                    price = str(round(price_float / 10) * 10)
+                    price = str(round(price_float / 10) * 10)  # En yakın 10'a yuvarla
             except (ValueError, TypeError):
-                price = price_str
+                price = price_str  # Sayıya dönüştürülemezse olduğu gibi bırak
             
             # 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):
@@ -560,12 +539,16 @@ 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):
@@ -573,16 +556,20 @@ if root is not None:
             else:
                 price_rebate = ""
             
-            # Havale indirimli kampanyalı fiyatı (varsa)
+            # Havale indirimli kampanyalı fiyatı yuvarla (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):
@@ -623,40 +610,6 @@ if root is not None:
 
 print(f"Toplam {len(products)} ürün yüklendi.")
 
-# NEW: Ürün adlarındaki yılları topla (yıl doğrulama/tolerans için)
-PRODUCT_YEARS = set()
-year_pat = re.compile(r'(?:19|20)\d{2}')
-for _, _, full_name in products:
-    for y in year_pat.findall(full_name or ""):
-        PRODUCT_YEARS.add(y)
-print(f"Yıl seti (ürün adlarından): {sorted(PRODUCT_YEARS)}")
-
-# NEW: Yıl toleransı yardımcıları
-def strip_unseen_years(q: str):
-    """Sorgudan, ürünlerde hiç bulunmayan yıl(lar)ı temizle."""
-    if not q:
-        return q, []
-    years = re.findall(r'(?:19|20)\d{2}', q)
-    removed = []
-    new_q = q
-    for y in years:
-        if y not in PRODUCT_YEARS:
-            new_q = re.sub(r'\b' + re.escape(y) + r'\b', '', new_q)
-            removed.append(y)
-    new_q = ' '.join(new_q.split())
-    return new_q, removed
-
-def remove_all_years(q: str):
-    """Sorgudaki tüm yıl ifadelerini (19xx/20xx) sil."""
-    if not q:
-        return q
-    new_q = re.sub(r'\b(?:19|20)\d{2}\b', '', q)
-    return ' '.join(new_q.split())
-
-def is_no_stock_text(text: str):
-    """'stokta bulunmuyor' ifadesini içeriyor mu?"""
-    return bool(text) and ("stokta bulunmuyor" in text)
-
 # Initialize enhanced features
 initialize_enhanced_features(OPENAI_API_KEY, products)
 
@@ -707,14 +660,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:
@@ -730,7 +683,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}")
@@ -743,83 +696,11 @@ def run_scheduler(chat_history):
         schedule.run_pending()
         time.sleep(60)
 
-# NEW: Stok sorularına deterministik, tamamen veri tabanlı yanıt (YIL TOLERANSI ENTEGRE)
-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.
-    YIL TOLERANSI: XML'de hiç olmayan yıl(lar)ı sorgudan otomatik çıkarır.
-    """
-    # 1) Ürün adı çıkarma
-    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']
-    tokens = [w for w in user_message.lower().split() if w not in skip_words]
-    if not tokens:
-        return "Hangi ürün için stok bakmamı istersiniz?"
-
-    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(tokens) == 1 and tokens[0] in size_terms)
-    raw_name = tokens[0] if is_only_size else ' '.join(tokens)
-
-    # 2) Sorgudan, XML'de hiç bulunmayan yıl(lar)ı çıkar
-    refined_name, removed_years = strip_unseen_years(raw_name)
-    product_name = refined_name or raw_name  # emniyet
-
-    # 3) İlk deneme (refined query ile)
-    stock_text = get_realtime_stock_parallel(product_name)
-
-    # 4) Hâlâ "stokta yok" ve sorguda YIL vardıysa: tüm yılları silip bir kez daha dene
-    had_any_year = bool(re.search(r'(?:19|20)\d{2}', raw_name))
-    if (not stock_text or is_no_stock_text(stock_text)) and had_any_year:
-        name_wo_years = remove_all_years(raw_name)
-        if name_wo_years and name_wo_years != product_name:
-            retry_text = get_realtime_stock_parallel(name_wo_years)
-            if retry_text and not is_no_stock_text(retry_text):
-                stock_text = retry_text
-                product_name = name_wo_years  # raporlamada bu adı kullan
-
-    if not stock_text:
-        return f"'{product_name}' için stok bilgisine şu an erişemedim."
-
-    # 5) 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:
-                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:
@@ -838,7 +719,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}")
 
@@ -849,11 +730,12 @@ 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Ü - (Eski yol) sadece GROUND_STOCK_ONLY kapalıysa
-    if is_stock_query(user_message) and not GROUND_STOCK_ONLY:
+    # STOK SORGUSU KONTROLÜ - YENİ EKLENEN KISIM
+    if is_stock_query(user_message):
         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', 
@@ -963,7 +845,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 = ""
@@ -975,7 +857,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])
@@ -992,26 +874,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:
@@ -1081,7 +963,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}")
 
@@ -1365,4 +1247,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)