Upload 3 files

app.py

@@ -22,6 +22,12 @@ warnings.simplefilter('ignore', InsecureRequestWarning)
 # Prompt dosyasını import et
 from prompts import get_prompt_content_only
 
+# Enhanced features import et
+from enhanced_features import (
+    initialize_enhanced_features, process_image_message, 
+    handle_comparison_request, get_user_recommendations, profile_manager
+)
+
 # Gradio uyarılarını bastır
 warnings.filterwarnings("ignore", category=UserWarning, module="gradio.components.chatbot")
 
@@ -181,6 +187,9 @@ print(f"Toplam {len(products)} ürün yüklendi")
 if products:
     print(f"İlk ürün örneği: {products[0]}")
 
+# Enhanced features'ları başlat
+initialize_enhanced_features(OPENAI_API_KEY, products)
+
 # Hugging Face token
 hfapi = os.getenv("hfapi")
 if not hfapi:
@@ -303,10 +312,32 @@ def run_scheduler(chat_history_ref):
         time.sleep(60)
 
 @spaces.GPU(duration=1200)
-def chatbot_fn(user_message, history):
+def chatbot_fn(user_message, history, image=None):
     if history is None:
         history = []
 
+    # Enhanced features - Görsel işleme
+    if image is not None:
+        user_message = process_image_message(image, user_message)
+    
+    # Enhanced features - Karşılaştırma kontrolü
+    comparison_result = handle_comparison_request(user_message)
+    if comparison_result:
+        yield comparison_result
+        return
+    
+    # Enhanced features - Kişisel öneriler
+    user_id = "default_user"  # Gerçek uygulamada session ID kullanılır
+    recommendation_result = get_user_recommendations(user_id, user_message)
+    if recommendation_result:
+        # Kullanıcı etkileşimini kaydet
+        profile_manager.add_interaction(user_id, "recommendation_request", {
+            "message": user_message,
+            "timestamp": time.strftime("%Y-%m-%d %H:%M:%S")
+        })
+        yield recommendation_result
+        return
+
     # Log: Kullanıcı mesajını ekle
     try:
         with file_lock:
@@ -554,18 +585,52 @@ document.addEventListener('DOMContentLoaded', function() {
 """
 
 
-# Demo arayüzüne CSS'i ekleyin
-demo = gr.ChatInterface(
-    fn=chat_fn,
-    title="Trek Asistanı",
-    theme="soft",
-    type="messages",
-    flagging_mode="manual",
-    flagging_options=["Doğru", "Yanlış", "Emin değilim", "Diğer"],
-    save_history=True,
-    autoscroll=True,
-    css=custom_css
-)
+# Enhanced chatbot fonksiyonu image destekli
+def enhanced_chatbot_fn(message, history, image):
+    return chatbot_fn(message, history, image)
+
+# Demo arayüzü - Özel layout ile image upload destekli
+with gr.Blocks(css=custom_css, theme="soft", title="Trek Asistanı") as demo:
+    gr.Markdown("# 🚲 Trek Asistanı AI")
+    gr.Markdown("**Yeni özellikler:** Bisiklet fotoğrafı yükleyebilir, ürün karşılaştırması yapabilir ve kişisel öneriler alabilirsiniz!")
+    
+    with gr.Row():
+        with gr.Column(scale=4):
+            chatbot = gr.Chatbot(height=500)
+            
+        with gr.Column(scale=1):
+            gr.Markdown("### 🖼️ Bisiklet Fotoğrafı")
+            image_input = gr.Image(type="filepath", height=200)
+            gr.Markdown("### 🔍 Özel Komutlar")
+            gr.Markdown("""
+            • **Karşılaştırma:** "Émonda ve Madone karşılaştır"
+            • **Bütçe:** "50-100K TL bütçem var"  
+            • **Görsel:** Bisiklet fotoğrafı yükle
+            """)
+    
+    with gr.Row():
+        msg = gr.Textbox(
+            placeholder="Sorunuzu yazın veya fotoğraf yükleyip analiz isteyin...",
+            show_label=False,
+            scale=4
+        )
+        submit_btn = gr.Button("Gönder", scale=1)
+    
+    def respond(message, chat_history, image):
+        # Enhanced chatbot fonksiyonunu çağır
+        response_generator = chatbot_fn(message, chat_history, image)
+        
+        # Generator'dan son cevabı al
+        response = ""
+        for partial in response_generator:
+            response = partial
+        
+        # Chat history güncelle
+        chat_history.append((message, response))
+        return "", chat_history, None
+    
+    submit_btn.click(respond, [msg, chatbot, image_input], [msg, chatbot, image_input])
+    msg.submit(respond, [msg, chatbot, image_input], [msg, chatbot, image_input])
 
 if __name__ == "__main__":
     demo.launch(debug=True)

enhanced_features.py

@@ -0,0 +1,305 @@
+# -*- coding: utf-8 -*-
+"""
+Trek Chatbot Enhanced Features
+1. Görsel AI Entegrasyonu
+2. Kişiselleştirilmiş Öneri Motoru  
+3. Gelişmiş Ürün Karşılaştırma
+"""
+
+import os
+import json
+import base64
+import requests
+from datetime import datetime
+import pandas as pd
+
+# Kullanıcı profili dosyası
+USER_PROFILES_FILE = "user_profiles.json"
+
+class UserProfileManager:
+    """Kullanıcı profili yönetimi"""
+    
+    def __init__(self):
+        self.profiles = self.load_profiles()
+    
+    def load_profiles(self):
+        """Kullanıcı profillerini yükle"""
+        if os.path.exists(USER_PROFILES_FILE):
+            with open(USER_PROFILES_FILE, 'r', encoding='utf-8') as f:
+                return json.load(f)
+        return {}
+    
+    def save_profiles(self):
+        """Kullanıcı profillerini kaydet"""
+        with open(USER_PROFILES_FILE, 'w', encoding='utf-8') as f:
+            json.dump(self.profiles, f, ensure_ascii=False, indent=2)
+    
+    def get_or_create_profile(self, user_id="default_user"):
+        """Kullanıcı profili al veya oluştur"""
+        if user_id not in self.profiles:
+            self.profiles[user_id] = {
+                "created_at": datetime.now().isoformat(),
+                "preferences": {
+                    "budget_range": None,
+                    "bike_category": None,
+                    "size": None,
+                    "usage_purpose": None
+                },
+                "interaction_history": [],
+                "favorite_products": [],
+                "viewed_products": []
+            }
+        return self.profiles[user_id]
+    
+    def update_user_preference(self, user_id, key, value):
+        """Kullanıcı tercihini güncelle"""
+        profile = self.get_or_create_profile(user_id)
+        profile["preferences"][key] = value
+        self.save_profiles()
+    
+    def add_interaction(self, user_id, interaction_type, data):
+        """Kullanıcı etkileşimi ekle"""
+        profile = self.get_or_create_profile(user_id)
+        interaction = {
+            "timestamp": datetime.now().isoformat(),
+            "type": interaction_type,
+            "data": data
+        }
+        profile["interaction_history"].append(interaction)
+        # Son 50 etkileşimi tut
+        profile["interaction_history"] = profile["interaction_history"][-50:]
+        self.save_profiles()
+
+class VisualAI:
+    """Görsel AI işlemleri"""
+    
+    def __init__(self, openai_api_key):
+        self.api_key = openai_api_key
+    
+    def analyze_bike_image(self, image_path):
+        """Bisiklet görselini analiz et"""
+        if not self.api_key:
+            return "Görsel analiz için OpenAI API key gerekli."
+        
+        try:
+            # Görseli base64'e çevir
+            with open(image_path, "rb") as image_file:
+                base64_image = base64.b64encode(image_file.read()).decode('utf-8')
+            
+            headers = {
+                "Content-Type": "application/json",
+                "Authorization": f"Bearer {self.api_key}"
+            }
+            
+            payload = {
+                "model": "gpt-4-vision-preview",
+                "messages": [
+                    {
+                        "role": "user",
+                        "content": [
+                            {
+                                "type": "text",
+                                "text": "Bu bisiklet görselini analiz et. Hangi tip bisiklet? Marka, model tahmininde bulun. Trek bisikletleri hakkında uzmanısın."
+                            },
+                            {
+                                "type": "image_url",
+                                "image_url": {
+                                    "url": f"data:image/jpeg;base64,{base64_image}"
+                                }
+                            }
+                        ]
+                    }
+                ],
+                "max_tokens": 300
+            }
+            
+            response = requests.post("https://api.openai.com/v1/chat/completions", 
+                                   headers=headers, json=payload)
+            
+            if response.status_code == 200:
+                result = response.json()
+                return result["choices"][0]["message"]["content"]
+            else:
+                return f"Görsel analiz hatası: {response.status_code}"
+                
+        except Exception as e:
+            return f"Görsel analiz hatası: {str(e)}"
+
+class ProductComparison:
+    """Ürün karşılaştırma sistemi"""
+    
+    def __init__(self, products_data):
+        self.products = products_data
+    
+    def find_products_by_name(self, product_names):
+        """İsimlere göre ürünleri bul"""
+        found_products = []
+        for name in product_names:
+            for product in self.products:
+                if name.lower() in product[2].lower():  # product[2] = full_name
+                    found_products.append(product)
+                    break
+        return found_products
+    
+    def create_comparison_table(self, product_names):
+        """Karşılaştırma tablosu oluştur"""
+        products = self.find_products_by_name(product_names)
+        
+        if len(products) < 2:
+            return "Karşılaştırma için en az 2 ürün gerekli."
+        
+        # Tablo verilerini hazırla
+        comparison_data = []
+        for product in products:
+            name, item_info, full_name = product
+            
+            # Ürün bilgilerini parse et
+            stock_status = item_info[0] if len(item_info) > 0 else "Bilgi yok"
+            price = item_info[1] if len(item_info) > 1 and item_info[1] else "Fiyat yok"
+            product_link = item_info[2] if len(item_info) > 2 else ""
+            
+            comparison_data.append({
+                "Ürün": full_name,
+                "Stok": stock_status,
+                "Fiyat": f"{price} TL" if price != "Fiyat yok" else price,
+                "Link": product_link
+            })
+        
+        # DataFrame oluştur
+        df = pd.DataFrame(comparison_data)
+        
+        # Markdown tablosu olarak döndür
+        return df.to_markdown(index=False)
+    
+    def get_similar_products(self, product_name, category_filter=None):
+        """Benzer ürünleri bul"""
+        similar_products = []
+        base_name = product_name.lower().split()[0]  # İlk kelimeyi al
+        
+        for product in self.products:
+            product_full_name = product[2].lower()
+            if base_name in product_full_name and product_name.lower() != product_full_name:
+                if category_filter:
+                    if category_filter.lower() in product_full_name:
+                        similar_products.append(product)
+                else:
+                    similar_products.append(product)
+        
+        return similar_products[:5]  # İlk 5 benzer ürün
+
+class PersonalizedRecommendations:
+    """Kişiselleştirilmiş öneriler"""
+    
+    def __init__(self, profile_manager, products_data):
+        self.profile_manager = profile_manager
+        self.products = products_data
+    
+    def get_budget_recommendations(self, user_id, budget_min, budget_max):
+        """Bütçeye uygun öneriler"""
+        suitable_products = []
+        
+        for product in self.products:
+            if product[1][0] == "stokta" and product[1][1]:  # Stokta ve fiyatı var
+                try:
+                    price = float(product[1][1])
+                    if budget_min <= price <= budget_max:
+                        suitable_products.append(product)
+                except (ValueError, TypeError):
+                    continue
+        
+        # Kullanıcı tercihlerini kaydet
+        self.profile_manager.update_user_preference(user_id, "budget_range", [budget_min, budget_max])
+        
+        return suitable_products[:5]  # İlk 5 öneri
+    
+    def get_personalized_suggestions(self, user_id):
+        """Geçmiş davranışlara göre öneriler"""
+        profile = self.profile_manager.get_or_create_profile(user_id)
+        preferences = profile["preferences"]
+        
+        suggestions = []
+        
+        # Bütçe tercihi varsa ona göre filtrele
+        if preferences.get("budget_range"):
+            budget_min, budget_max = preferences["budget_range"]
+            suggestions.extend(self.get_budget_recommendations(user_id, budget_min, budget_max))
+        
+        # Kategori tercihi varsa ona göre filtrele  
+        if preferences.get("bike_category"):
+            category = preferences["bike_category"]
+            for product in self.products:
+                if category.lower() in product[2].lower() and product[1][0] == "stokta":
+                    suggestions.append(product)
+        
+        return list(set(suggestions))[:3]  # Duplicate'ları kaldır ve ilk 3'ü al
+
+# Global instance'lar
+profile_manager = UserProfileManager()
+visual_ai = None  # OpenAI key ile başlatılacak
+product_comparison = None  # Products data ile başlatılacak
+personalized_recommendations = None  # Profile manager ve products ile başlatılacak
+
+def initialize_enhanced_features(openai_api_key, products_data):
+    """Enhanced özellikleri başlat"""
+    global visual_ai, product_comparison, personalized_recommendations
+    
+    visual_ai = VisualAI(openai_api_key)
+    product_comparison = ProductComparison(products_data)
+    personalized_recommendations = PersonalizedRecommendations(profile_manager, products_data)
+
+def process_image_message(image_path, user_message):
+    """Görsel mesajını işle"""
+    if visual_ai and image_path:
+        image_analysis = visual_ai.analyze_bike_image(image_path)
+        return f"Görsel Analiz: {image_analysis}\n\nSoru: {user_message}"
+    return user_message
+
+def handle_comparison_request(user_message):
+    """Karşılaştırma talebini işle"""
+    if "karşılaştır" in user_message.lower() or "compare" in user_message.lower():
+        # Ürün isimlerini çıkarmaya çalış
+        words = user_message.lower().split()
+        potential_products = []
+        
+        # Bilinen model isimlerini ara
+        known_models = ["émonda", "madone", "domane", "marlin", "fuel", "powerfly", "fx"]
+        for word in words:
+            for model in known_models:
+                if model in word:
+                    potential_products.append(model)
+        
+        if len(potential_products) >= 2:
+            comparison_table = product_comparison.create_comparison_table(potential_products)
+            return f"Ürün Karşılaştırması:\n\n{comparison_table}"
+    
+    return None
+
+def get_user_recommendations(user_id, user_message):
+    """Kullanıcıya özel öneriler al"""
+    # Bütçe sorgusu varsa
+    if "bütçe" in user_message.lower() or "budget" in user_message.lower():
+        # Rakamları çıkarmaya çalış
+        import re
+        numbers = re.findall(r'\d+', user_message)
+        if len(numbers) >= 2:
+            budget_min = int(numbers[0]) * 1000  # K TL formatı için
+            budget_max = int(numbers[1]) * 1000
+            recommendations = personalized_recommendations.get_budget_recommendations(
+                user_id, budget_min, budget_max
+            )
+            
+            if recommendations:
+                rec_text = "Bütçenize uygun öneriler:\n\n"
+                for product in recommendations[:3]:
+                    rec_text += f"• {product[2]} - {product[1][1]} TL\n"
+                return rec_text
+    
+    # Genel kişisel öneriler
+    suggestions = personalized_recommendations.get_personalized_suggestions(user_id)
+    if suggestions:
+        sug_text = "Size özel önerilerimiz:\n\n"
+        for product in suggestions:
+            sug_text += f"• {product[2]} - {product[1][1]} TL\n"
+        return sug_text
+    
+    return None

requirements.txt

@@ -4,10 +4,10 @@ requests
 pandas
 python-docx
 huggingface_hub
-schedule
 openpyxl
 spaces
 google-auth
 google-auth-oauthlib
 google-auth-httplib2
 google-api-python-client
+tabulate