Upload 2 files

app.py

@@ -6,6 +6,8 @@ import xml.etree.ElementTree as ET
 import schedule
 import time
 import threading
+import uuid
+import hashlib
 from huggingface_hub import HfApi, create_repo, hf_hub_download
 import warnings
 import pandas as pd
@@ -25,7 +27,8 @@ 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
+    handle_comparison_request, get_user_recommendations, profile_manager,
+    get_user_profile_summary, get_user_chat_context
 )
 from image_renderer import extract_product_info_for_gallery, format_message_with_images
 
@@ -330,17 +333,17 @@ def chatbot_fn(user_message, history, image=None):
             return
         
         # Enhanced features - Kişisel öneriler
-        user_id = "default_user"  # Gerçek uygulamada session ID kullanılır
+        user_id = getattr(chatbot_fn, '_current_session_id', 'default_user')
+        
+        # Profil sorguları kontrol et
+        if any(keyword in user_message.lower() for keyword in ["profil", "tercih", "geçmiş", "hatırla", "kaydet"]):
+            profile_summary = get_user_profile_summary(user_id)
+            yield profile_summary
+            return
+        
         recommendation_result = get_user_recommendations(user_id, user_message)
         if recommendation_result:
-            # Kullanıcı etkileşimini kaydet
-            try:
-                profile_manager.add_interaction(user_id, "recommendation_request", {
-                    "message": user_message,
-                    "timestamp": time.strftime("%Y-%m-%d %H:%M:%S")
-                })
-            except Exception as e:
-                print(f"Profile save error: {e}")
+            # Kullanıcı etkileşimini kaydet (artık get_user_recommendations içinde)
             yield recommendation_result
             return
 
@@ -362,6 +365,30 @@ def chatbot_fn(user_message, history, image=None):
     # Döküman verilerini sistem mesajlarına ekle
     if document_content:
         system_messages.append({"role": "system", "content": f"Dökümanlardan gelen bilgiler: {document_content}"})
+    
+    # Kullanıcı profil bilgilerini ve geçmiş kontekstini ekle
+    try:
+        user_id = getattr(chatbot_fn, '_current_session_id', 'default_user')
+        profile = profile_manager.get_or_create_profile(user_id)
+        preferences = profile.get("preferences", {})
+        
+        # Kullanıcı tercihlerini sistem mesajı olarak ekle
+        if any(preferences.values()):
+            pref_info = []
+            if preferences.get("bike_category"):
+                pref_info.append(f"Kategori: {preferences['bike_category']}")
+            if preferences.get("budget_range"):
+                pref_info.append(f"Bütçe: {preferences['budget_range'][0]:,.0f}-{preferences['budget_range'][1]:,.0f} TL")
+            if preferences.get("usage_purpose"):
+                pref_info.append(f"Kullanım amacı: {preferences['usage_purpose']}")
+            
+            if pref_info:
+                system_messages.append({
+                    "role": "system", 
+                    "content": f"KULLANICI TERÇİHLERİ: {', '.join(pref_info)}. Bu bilgileri dikkate alarak daha kişiselleştirilmiş öneriler sun."
+                })
+    except Exception as e:
+        print(f"Profile context error: {e}")
 
     # Kullanıcı mesajında ürün ismi geçiyorsa ekle
     input_words = user_message.lower().split()
@@ -805,10 +832,22 @@ with gr.Blocks(css=custom_css, theme="soft", title="Trek Asistanı") as demo:
         elem_id="msg-input"
     )
     
-    def respond(message, chat_history):
+    # Session state için gizli bileşen
+    session_state = gr.State({})
+    
+    def respond(message, chat_history, session_state):
         if not message.strip():
-            return "", chat_history
+            return "", chat_history, session_state
             
+        # Session ID oluştur veya mevcut olanı kullan
+        if not session_state or 'session_id' not in session_state:
+            # Browser fingerprint benzeri benzersiz ID oluştur
+            session_id = str(uuid.uuid4())[:8] + hashlib.md5(str(time.time()).encode()).hexdigest()[:8]
+            session_state = {'session_id': session_id}
+        
+        # Session ID'yi chatbot_fn'e geç
+        chatbot_fn._current_session_id = session_state['session_id']
+        
         # Chat history'yi chatbot_fn için uygun formata çevir
         formatted_history = []
         if chat_history:
@@ -829,7 +868,18 @@ with gr.Blocks(css=custom_css, theme="soft", title="Trek Asistanı") as demo:
             if chat_history is None:
                 chat_history = []
             chat_history.append((message, response))
-            return "", chat_history
+            
+            # Kullanıcı profiline sohbet geçmişini kaydet
+            try:
+                profile_manager.add_interaction(session_state['session_id'], "chat_message", {
+                    "user_message": message,
+                    "bot_response": response,
+                    "timestamp": time.strftime("%Y-%m-%d %H:%M:%S")
+                })
+            except Exception as e:
+                print(f"Profile chat save error: {e}")
+            
+            return "", chat_history, session_state
             
         except Exception as e:
             error_msg = f"Üzgünüm, bir hata oluştu: {str(e)}"
@@ -837,9 +887,9 @@ with gr.Blocks(css=custom_css, theme="soft", title="Trek Asistanı") as demo:
             if chat_history is None:
                 chat_history = []
             chat_history.append((message, error_msg))
-            return "", chat_history
+            return "", chat_history, session_state
     
-    msg.submit(respond, [msg, chatbot], [msg, chatbot])
+    msg.submit(respond, [msg, chatbot, session_state], [msg, chatbot, session_state])
 
 if __name__ == "__main__":
     demo.launch(debug=True)

enhanced_features.py

@@ -70,7 +70,76 @@ class UserProfileManager:
         profile["interaction_history"].append(interaction)
         # Son 50 etkileşimi tut
         profile["interaction_history"] = profile["interaction_history"][-50:]
+        
+        # Otomatik tercih çıkarımı
+        self._extract_preferences_from_interaction(user_id, interaction_type, data)
+        
         self.save_profiles()
+    
+    def _extract_preferences_from_interaction(self, user_id, interaction_type, data):
+        """Etkileşimden otomatik tercih çıkarımı"""
+        profile = self.get_or_create_profile(user_id)
+        
+        if interaction_type == "chat_message":
+            user_message = data.get("user_message", "").lower()
+            
+            # Bütçe tespiti
+            import re
+            if "bütçe" in user_message or "budget" in user_message:
+                numbers = re.findall(r'\d+', user_message)
+                if len(numbers) >= 1:
+                    try:
+                        budget_value = int(numbers[0]) * 1000  # K TL formatı için
+                        if budget_value > 10000:  # Makul bütçe aralığı
+                            current_budget = profile["preferences"].get("budget_range")
+                            if not current_budget:
+                                # Bütçe aralığını tahmin et
+                                budget_max = budget_value * 1.5
+                                profile["preferences"]["budget_range"] = [budget_value, budget_max]
+                    except ValueError:
+                        pass
+            
+            # Bisiklet kategorisi tespiti
+            bike_categories = {
+                "dağ": "dağ bisikleti",
+                "mountain": "dağ bisikleti", 
+                "mtb": "dağ bisikleti",
+                "yol": "yol bisikleti",
+                "road": "yol bisikleti",
+                "şehir": "şehir bisikleti",
+                "city": "şehir bisikleti",
+                "urban": "şehir bisikleti",
+                "elektrikli": "elektrikli bisiklet",
+                "electric": "elektrikli bisiklet",
+                "e-bike": "elektrikli bisiklet",
+                "gravel": "gravel bisiklet"
+            }
+            
+            for keyword, category in bike_categories.items():
+                if keyword in user_message:
+                    profile["preferences"]["bike_category"] = category
+                    break
+            
+            # Kullanım amacı tespiti
+            usage_purposes = {
+                "işe": "günlük ulaşım",
+                "work": "günlük ulaşım",
+                "spor": "spor ve egzersiz",
+                "sport": "spor ve egzersiz",
+                "egzersiz": "spor ve egzersiz",
+                "fitness": "spor ve egzersiz",
+                "tur": "tur ve gezi",
+                "tour": "tur ve gezi",
+                "gezi": "tur ve gezi",
+                "yarış": "yarış ve performans",
+                "race": "yarış ve performans",
+                "performance": "yarış ve performans"
+            }
+            
+            for keyword, purpose in usage_purposes.items():
+                if keyword in user_message:
+                    profile["preferences"]["usage_purpose"] = purpose
+                    break
 
 class VisualAI:
     """Görsel AI işlemleri"""
@@ -356,9 +425,79 @@ def handle_comparison_request(user_message):
         print(f"Comparison error: {e}")
         return None
 
+def get_user_chat_context(user_id, limit=5):
+    """Son sohbet geçmişini kontekst için al"""
+    try:
+        profile = profile_manager.get_or_create_profile(user_id)
+        interactions = profile.get("interaction_history", [])
+        
+        # Son chat mesajlarını al
+        chat_messages = []
+        for interaction in reversed(interactions):
+            if interaction['type'] == 'chat_message' and len(chat_messages) < limit:
+                data = interaction['data']
+                chat_messages.append({
+                    "user": data.get('user_message', ''),
+                    "assistant": data.get('bot_response', ''),
+                    "timestamp": data.get('timestamp', '')
+                })
+        
+        return list(reversed(chat_messages))  # Kronolojik sıra
+        
+    except Exception as e:
+        print(f"Chat context error: {e}")
+        return []
+
+def get_user_profile_summary(user_id):
+    """Kullanıcı profil özetini döndür"""
+    try:
+        profile = profile_manager.get_or_create_profile(user_id)
+        preferences = profile.get("preferences", {})
+        
+        if not any(preferences.values()):
+            return "Henüz tercihleriniz kaydedilmemiş. Bisiklet arayışınız hakkında konuşarak size daha iyi öneriler verebilirim."
+        
+        summary = "🔄 **Kaydedilen Tercihleriniz:**\n\n"
+        
+        if preferences.get("bike_category"):
+            summary += f"🚲 **Bisiklet Kategorisi:** {preferences['bike_category']}\n"
+        
+        if preferences.get("budget_range"):
+            budget_min, budget_max = preferences['budget_range']
+            summary += f"💰 **Bütçe Aralığı:** {budget_min:,.0f} - {budget_max:,.0f} TL\n"
+        
+        if preferences.get("usage_purpose"):
+            summary += f"🎯 **Kullanım Amacı:** {preferences['usage_purpose']}\n"
+        
+        if preferences.get("size"):
+            summary += f"📏 **Boyut:** {preferences['size']}\n"
+        
+        # Son etkileşimler
+        interactions = profile.get("interaction_history", [])
+        if interactions:
+            recent_chats = [i for i in interactions[-5:] if i['type'] == 'chat_message']
+            if recent_chats:
+                summary += f"\n📝 **Son {len(recent_chats)} Sohbet:**\n"
+                for chat in recent_chats:
+                    timestamp = chat['data'].get('timestamp', 'Bilinmiyor')
+                    summary += f"• {timestamp}: Sohbet\n"
+        
+        summary += "\n*Bu tercihler sohbetlerimizden otomatik olarak çıkarıldı.*"
+        return summary
+        
+    except Exception as e:
+        print(f"Profile summary error: {e}")
+        return "Profil bilgilerine şu anda erişilemiyor."
+
 def get_user_recommendations(user_id, user_message):
     """Kullanıcıya özel öneriler al"""
     try:
+        # Kullanıcı etkileşimini kaydet (tercih çıkarımı için)
+        profile_manager.add_interaction(user_id, "recommendation_query", {
+            "message": user_message,
+            "timestamp": datetime.now().isoformat()
+        })
+        
         # Bütçe sorgusu varsa
         if "bütçe" in user_message.lower() or "budget" in user_message.lower():
             # Rakamları çıkarmaya çalış
@@ -376,15 +515,47 @@ def get_user_recommendations(user_id, user_message):
                     for product in recommendations[:3]:
                         rec_text += f"• {product[2]} - {product[1][1]} TL\n"
                     return rec_text
+            elif len(numbers) >= 1 and personalized_recommendations:
+                # Tek sayı varsa aralık oluştur
+                budget_center = int(numbers[0]) * 1000
+                budget_min = int(budget_center * 0.8)
+                budget_max = int(budget_center * 1.2)
+                recommendations = personalized_recommendations.get_budget_recommendations(
+                    user_id, budget_min, budget_max
+                )
+                
+                if recommendations:
+                    rec_text = f"{numbers[0]}K TL 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
+        # Kullanıcı profili tercihleri varsa öneri ver
         if personalized_recommendations:
-            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
+            profile = profile_manager.get_or_create_profile(user_id)
+            preferences = profile.get("preferences", {})
+            
+            # Eğer kullanıcının kaydedilmiş tercihleri varsa
+            if any(preferences.values()):
+                suggestions = personalized_recommendations.get_personalized_suggestions(user_id)
+                if suggestions:
+                    sug_text = "Tercihlerinize göre önerilerimiz:\n\n"
+                    for product in suggestions[:3]:
+                        sug_text += f"• {product[2]} - {product[1][1]} TL\n"
+                    
+                    # Tercih özetini ekle
+                    pref_summary = []
+                    if preferences.get("bike_category"):
+                        pref_summary.append(f"Kategori: {preferences['bike_category']}")
+                    if preferences.get("budget_range"):
+                        pref_summary.append(f"Bütçe: {preferences['budget_range'][0]:,.0f}-{preferences['budget_range'][1]:,.0f} TL")
+                    if preferences.get("usage_purpose"):
+                        pref_summary.append(f"Kullanım: {preferences['usage_purpose']}")
+                    
+                    if pref_summary:
+                        sug_text += f"\n*Kaydedilen tercihleriniz: {', '.join(pref_summary)}*"
+                    
+                    return sug_text
         
         return None
     except Exception as e: