Update app.py

app.py

@@ -14,28 +14,103 @@ import threading
 from huggingface_hub import HfApi, hf_hub_download
 from huggingface_hub.utils import RepositoryNotFoundError
 
-# --- Configuration ---
-BOT_TOKEN = os.getenv("BOT_TOKEN", "7566834146:AAGiG4MaTZZvvbTVsqEJVG5SYK5hUlc_Ewo") # Use environment variable or default
+from aiogram import Bot, Dispatcher, executor, types
+import asyncio
+
+import base64
+from google import genai
+from google.genai import types
+
+BOT_TOKEN = os.getenv("BOT_TOKEN", "YOUR_DEFAULT_BOT_TOKEN")
 HOST = '0.0.0.0'
 PORT = 7860
-DATA_FILE = 'data.json' # Local file for visitor data
+DATA_FILE = 'data.json'
 
-# Hugging Face Settings
 REPO_ID = "flpolprojects/teledata"
-HF_DATA_FILE_PATH = "data.json" # Path within the HF repo
-HF_TOKEN_WRITE = os.getenv("HF_TOKEN_WRITE") # Token with write access
-HF_TOKEN_READ = os.getenv("HF_TOKEN_READ") # Token with read access (can be same as write)
+HF_DATA_FILE_PATH = "data.json"
+HF_TOKEN_WRITE = os.getenv("HF_TOKEN_WRITE")
+HF_TOKEN_READ = os.getenv("HF_TOKEN_READ")
+GEMINI_API_KEY = os.getenv("GEMINI_API_KEY")
 
 app = Flask(__name__)
 logging.basicConfig(level=logging.INFO)
-app.secret_key = os.urandom(24) # For potential future session use
+app.secret_key = os.urandom(24)
 
-# --- Hugging Face & Data Handling ---
 _data_lock = threading.Lock()
-visitor_data_cache = {} # In-memory cache
+visitor_data_cache = {}
+chat_history_cache = []
+
+bot = Bot(token=BOT_TOKEN)
+dp = Dispatcher(bot)
+
+APP_CONTEXT_TEXT = """
+Morshen Group: Международный IT холдинг.
+Объединяем передовые технологические компании для создания инновационных
+решений мирового уровня. Мы строим будущее технологий сегодня.
+Лидер инноваций 2025.
+Контакт: Telegram @morshenkhan, Телефон +996 500 398 754.
+
+Экосистема инноваций: В состав холдинга входят компании, специализирующиеся на различных
+направлениях передовых технологий, создавая синергию для прорывных решений.
+
+Morshen Alpha: Флагманская компания холдинга.
+Специализация: Искусственный интеллект, Квантовые технологии, Бизнес-решения.
+Деятельность: Разрабатываем передовые бизнес-решения, проводим R&D в сфере AI
+и квантовых технологий. Наши инновации формируют будущее индустрии.
+Статистика: 3+ Страны присутствия, 3K+ Готовых клиентов, 5+ Лет на рынке.
+
+Holmgard Studio: Инновационная студия разработки.
+Специализация: Веб-разработка, Мобильные приложения, ПО на заказ.
+Деятельность: Создает высокотехнологичные веб-сайты,
+мобильные приложения и ПО для бизнеса любого масштаба.
+Использует передовые технологии и гибкие методологии.
+Статистика: 10+ Лет опыта, PRO Любая сложность, FAST Высокая скорость.
+Веб-сайт: https://holmgard.ru. Контакт через @morshenkhan.
+
+Глобальное присутствие: Наши инновационные решения и экспертиза доступны в странах Центральной Азии и за ее пределами:
+Узбекистан
+Казахстан
+Кыргызстан
+Расширяем горизонты...
+
+Сохранить визитку: Телефон +996 500 398 754, Morshen Group, Международный IT Холдинг. Сделайте скриншот экрана.
+"""
+
+def generate_ai_response(prompt_text):
+    if not GEMINI_API_KEY:
+        logging.error("GEMINI_API_KEY not set. Cannot generate AI response.")
+        return "Ошибка: Сервер не настроен для ответа на вопросы (отсутствует API ключ)."
+    try:
+        client = genai.Client(api_key=GEMINI_API_KEY)
+        model = "learnlm-2.0-flash-experimental"
+        contextualized_prompt = f"""
+Основываясь на следующей информации о Morshen Group и ее дочерних компаниях, ответь на вопрос пользователя.
+Если информация отсутствует, так и скажи. Не придумывай информацию, которой нет в тексте.
+Отвечай на русском языке.
+
+Информация о Morshen Group:
+{APP_CONTEXT_TEXT}
+
+Вопрос пользователя: {prompt_text}
+
+Ответ:
+"""
+        contents = [types.Content(role="user", parts=[types.Part.from_text(text=contextualized_prompt)])]
+        generate_content_config = types.GenerateContentConfig(response_mime_type="text/plain")
+
+        response = client.models.generate_content(
+            model=model,
+            contents=contents,
+            config=generate_content_config,
+            stream=False # Use non-streaming for simplicity in this context
+        )
+        return response.text.strip()
+    except Exception as e:
+        logging.error(f"Error generating AI response: {e}")
+        return f"Произошла ошибка при генерации ответа: {e}"
 
 def download_data_from_hf():
-    global visitor_data_cache
+    global visitor_data_cache, chat_history_cache
     if not HF_TOKEN_READ:
         logging.warning("HF_TOKEN_READ not set. Skipping Hugging Face download.")
         return False
@@ -48,60 +123,76 @@ def download_data_from_hf():
             token=HF_TOKEN_READ,
             local_dir=".",
             local_dir_use_symlinks=False,
-            force_download=True, # Ensure we get the latest version
-            etag_timeout=10 # Shorter timeout to avoid hanging
+            force_download=True,
+            etag_timeout=10
         )
         logging.info("Data file successfully downloaded from Hugging Face.")
-        # Force reload from downloaded file
         with _data_lock:
             try:
                 with open(DATA_FILE, 'r', encoding='utf-8') as f:
-                    visitor_data_cache = json.load(f)
+                    full_data = json.load(f)
+                    visitor_data_cache = full_data.get("visitors", {})
+                    chat_history_cache = full_data.get("chats", [])
                 logging.info("Successfully loaded downloaded data into cache.")
             except (FileNotFoundError, json.JSONDecodeError) as e:
                  logging.error(f"Error reading downloaded data file: {e}. Starting with empty cache.")
                  visitor_data_cache = {}
+                 chat_history_cache = []
         return True
     except RepositoryNotFoundError:
         logging.error(f"Hugging Face repository '{REPO_ID}' not found. Cannot download data.")
-        # Don't clear local cache if repo not found, might have local data
     except Exception as e:
         logging.error(f"Error downloading data from Hugging Face: {e}")
-        # Don't clear local cache on generic download errors
     return False
 
 def load_visitor_data():
-    global visitor_data_cache
+    global visitor_data_cache, chat_history_cache
     with _data_lock:
-        if not visitor_data_cache: # Only load from file if cache is empty
+        if not visitor_data_cache or not chat_history_cache:
             try:
                 with open(DATA_FILE, 'r', encoding='utf-8') as f:
-                    visitor_data_cache = json.load(f)
-                logging.info("Visitor data loaded from local JSON.")
+                    full_data = json.load(f)
+                    visitor_data_cache = full_data.get("visitors", {})
+                    chat_history_cache = full_data.get("chats", [])
+                logging.info("Data loaded from local JSON.")
             except FileNotFoundError:
                 logging.warning(f"{DATA_FILE} not found locally. Starting with empty data.")
                 visitor_data_cache = {}
+                chat_history_cache = []
             except json.JSONDecodeError:
                 logging.error(f"Error decoding {DATA_FILE}. Starting with empty data.")
                 visitor_data_cache = {}
+                chat_history_cache = []
             except Exception as e:
-                logging.error(f"Unexpected error loading visitor data: {e}")
+                logging.error(f"Unexpected error loading data: {e}")
                 visitor_data_cache = {}
-        return visitor_data_cache
+                chat_history_cache = []
+        return {"visitors": visitor_data_cache, "chats": chat_history_cache}
 
-def save_visitor_data(data):
+
+def save_visitor_data(data_to_update):
     with _data_lock:
         try:
-            # Update cache first
-            visitor_data_cache.update(data)
-            # Save updated cache to file
+            visitor_data_cache.update(data_to_update)
+            full_data = {"visitors": visitor_data_cache, "chats": chat_history_cache}
             with open(DATA_FILE, 'w', encoding='utf-8') as f:
-                json.dump(visitor_data_cache, f, ensure_ascii=False, indent=4)
-            logging.info(f"Visitor data successfully saved to {DATA_FILE}.")
-            # Trigger upload after successful local save
-            upload_data_to_hf_async() # Use async upload
+                json.dump(full_data, f, ensure_ascii=False, indent=4)
+            logging.info(f"Data successfully saved to {DATA_FILE}.")
+            upload_data_to_hf_async()
         except Exception as e:
-            logging.error(f"Error saving visitor data: {e}")
+            logging.error(f"Error saving data: {e}")
+
+def save_chat_message(chat_entry):
+     with _data_lock:
+         try:
+             chat_history_cache.append(chat_entry)
+             full_data = {"visitors": visitor_data_cache, "chats": chat_history_cache}
+             with open(DATA_FILE, 'w', encoding='utf-8') as f:
+                 json.dump(full_data, f, ensure_ascii=False, indent=4)
+             logging.info(f"Chat message successfully saved to {DATA_FILE}.")
+             upload_data_to_hf_async()
+         except Exception as e:
+             logging.error(f"Error saving chat message: {e}")
 
 def upload_data_to_hf():
     if not HF_TOKEN_WRITE:
@@ -113,7 +204,7 @@ def upload_data_to_hf():
 
     try:
         api = HfApi()
-        with _data_lock: # Ensure file isn't being written while reading for upload
+        with _data_lock:
              file_content_exists = os.path.getsize(DATA_FILE) > 0
              if not file_content_exists:
                  logging.warning(f"{DATA_FILE} is empty. Skipping upload.")
@@ -126,15 +217,13 @@ def upload_data_to_hf():
                  repo_id=REPO_ID,
                  repo_type="dataset",
                  token=HF_TOKEN_WRITE,
-                 commit_message=f"Update visitor data {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}"
+                 commit_message=f"Update data {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}"
              )
-        logging.info("Visitor data successfully uploaded to Hugging Face.")
+        logging.info("Data successfully uploaded to Hugging Face.")
     except Exception as e:
         logging.error(f"Error uploading data to Hugging Face: {e}")
-        # Consider adding retry logic here if needed
 
 def upload_data_to_hf_async():
-     # Run upload in a separate thread to avoid blocking web requests
      upload_thread = threading.Thread(target=upload_data_to_hf, daemon=True)
      upload_thread.start()
 
@@ -143,11 +232,10 @@ def periodic_backup():
          logging.info("Periodic backup disabled: HF_TOKEN_WRITE not set.")
          return
      while True:
-         time.sleep(3600) # Backup every hour
+         time.sleep(3600)
          logging.info("Initiating periodic backup...")
          upload_data_to_hf()
 
-# --- Telegram Verification ---
 def verify_telegram_data(init_data_str):
     try:
         parsed_data = parse_qs(init_data_str)
@@ -167,8 +255,8 @@ def verify_telegram_data(init_data_str):
         if calculated_hash == received_hash:
             auth_date = int(parsed_data.get('auth_date', [0])[0])
             current_time = int(time.time())
-            if current_time - auth_date > 86400: # Allow data up to 24 hours old
-                 logging.warning(f"Telegram InitData is older than 1 hour (Auth Date: {auth_date}, Current: {current_time}).")
+            if current_time - auth_date > 86400:
+                 logging.warning(f"Telegram InitData is older than 24 hours (Auth Date: {auth_date}, Current: {current_time}).")
             return parsed_data, True
         else:
             logging.warning(f"Data verification failed. Calculated: {calculated_hash}, Received: {received_hash}")
@@ -177,7 +265,6 @@ def verify_telegram_data(init_data_str):
         logging.error(f"Error verifying Telegram data: {e}")
         return None, False
 
-# --- HTML Templates ---
 TEMPLATE = """
 <!DOCTYPE html>
 <html lang="ru">
@@ -199,8 +286,8 @@ TEMPLATE = """
             --tg-theme-button-text-color: {{ theme.button_text_color | default('#ffffff') }};
             --tg-theme-secondary-bg-color: {{ theme.secondary_bg_color | default('#1e1e1e') }};
 
-            --bg-gradient: linear-gradient(160deg, #1a232f 0%, #121212 100%);
-            --card-bg: rgba(44, 44, 46, 0.8); /* Semi-transparent card */
+            --bg-gradient: linear-gradient(160deg, #1a232f 0%, var(--tg-theme-bg-color, #121212) 100%);
+            --card-bg: rgba(44, 44, 46, 0.8);
             --card-bg-solid: #2c2c2e;
             --text-color: var(--tg-theme-text-color);
             --text-secondary-color: var(--tg-theme-hint-color);
@@ -208,16 +295,16 @@ TEMPLATE = """
             --accent-gradient-green: linear-gradient(95deg, #34c759, #30d158);
             --tag-bg: rgba(255, 255, 255, 0.1);
             --border-radius-s: 8px;
-            --border-radius-m: 14px; /* Increased radius */
-            --border-radius-l: 18px; /* Increased radius */
+            --border-radius-m: 14px;
+            --border-radius-l: 18px;
             --padding-s: 10px;
-            --padding-m: 18px; /* Increased padding */
-            --padding-l: 28px; /* Increased padding */
+            --padding-m: 18px;
+            --padding-l: 28px;
             --font-family: 'Inter', -apple-system, BlinkMacSystemFont, "Segoe UI", Roboto, Helvetica, Arial, sans-serif;
             --shadow-color: rgba(0, 0, 0, 0.3);
             --shadow-light: 0 4px 15px var(--shadow-color);
             --shadow-medium: 0 6px 25px var(--shadow-color);
-            --backdrop-blur: 10px; /* Glassmorphism effect */
+            --backdrop-blur: 10px;
         }
         * { box-sizing: border-box; margin: 0; padding: 0; }
         html {
@@ -229,11 +316,11 @@ TEMPLATE = """
             background: var(--bg-gradient);
             color: var(--text-color);
             padding: var(--padding-m);
-            padding-bottom: 120px; /* More space for fixed button */
+            padding-bottom: 120px;
             overscroll-behavior-y: none;
             -webkit-font-smoothing: antialiased;
             -moz-osx-font-smoothing: grayscale;
-            visibility: hidden; /* Hide until ready */
+            visibility: hidden;
             min-height: 100vh;
         }
         .container {
@@ -252,7 +339,7 @@ TEMPLATE = """
         }
         .logo { display: flex; align-items: center; gap: var(--padding-s); }
         .logo img {
-            width: 50px; /* Larger logo */
+            width: 50px;
             height: 50px;
             border-radius: 50%;
             background-color: var(--card-bg-solid);
@@ -260,12 +347,12 @@ TEMPLATE = """
             border: 2px solid rgba(255, 255, 255, 0.15);
             box-shadow: 0 2px 8px rgba(0, 0, 0, 0.2);
         }
-        .logo span { font-size: 1.6em; font-weight: 700; letter-spacing: -0.5px; } /* Bold, slightly larger */
+        .logo span { font-size: 1.6em; font-weight: 700; letter-spacing: -0.5px; }
         .btn {
             display: inline-flex; align-items: center; justify-content: center;
             padding: 12px var(--padding-m); border-radius: var(--border-radius-m);
             background: var(--accent-gradient); color: var(--tg-theme-button-text-color);
-            text-decoration: none; font-weight: 600; /* Bolder */
+            text-decoration: none; font-weight: 600;
             border: none; cursor: pointer;
             transition: all 0.25s cubic-bezier(0.4, 0, 0.2, 1);
             gap: 8px; font-size: 1em;
@@ -298,14 +385,14 @@ TEMPLATE = """
             background-color: var(--card-bg);
             border-radius: var(--border-radius-l);
             padding: var(--padding-l);
-            margin-bottom: 0; /* Removed bottom margin, gap handles spacing */
+            margin-bottom: 0;
             box-shadow: var(--shadow-medium);
             border: 1px solid rgba(255, 255, 255, 0.08);
             backdrop-filter: blur(var(--backdrop-blur));
             -webkit-backdrop-filter: blur(var(--backdrop-blur));
         }
         .section-title {
-            font-size: 2em; /* Larger titles */
+            font-size: 2em;
             font-weight: 700; margin-bottom: var(--padding-s); line-height: 1.25;
             letter-spacing: -0.6px;
         }
@@ -314,7 +401,7 @@ TEMPLATE = """
             margin-bottom: var(--padding-m);
         }
         .description {
-            font-size: 1.05em; line-height: 1.6; color: var(--text-secondary-color); /* Slightly larger desc */
+            font-size: 1.05em; line-height: 1.6; color: var(--text-secondary-color);
             margin-bottom: var(--padding-m);
         }
         .stats-grid {
@@ -334,7 +421,7 @@ TEMPLATE = """
             background-color: var(--card-bg-solid);
             padding: var(--padding-m); border-radius: var(--border-radius-m);
             margin-bottom: var(--padding-s); display: flex; align-items: center;
-            gap: var(--padding-m); /* Increased gap */
+            gap: var(--padding-m);
             font-size: 1.1em; font-weight: 500;
             border: 1px solid rgba(255, 255, 255, 0.08);
             transition: background-color 0.2s ease, transform 0.2s ease;
@@ -350,11 +437,11 @@ TEMPLATE = """
         }
         .save-card-button {
             position: fixed;
-            bottom: 30px; /* Raised */
+            bottom: 30px;
             left: 50%;
             transform: translateX(-50%);
-            padding: 14px 28px; /* Larger padding */
-            border-radius: 30px; /* More rounded */
+            padding: 14px 28px;
+            border-radius: 30px;
             background: var(--accent-gradient-green);
             color: var(--tg-theme-button-text-color);
             text-decoration: none;
@@ -363,17 +450,17 @@ TEMPLATE = """
             cursor: pointer;
             transition: all 0.3s cubic-bezier(0.4, 0, 0.2, 1);
             z-index: 1000;
-            box-shadow: var(--shadow-medium), 0 0 0 4px rgba(var(--tg-theme-bg-color-rgb, 18, 18, 18), 0.5); /* Add outer glow */
-            font-size: 1.05em; /* Slightly larger text */
+            box-shadow: var(--shadow-medium), 0 0 0 4px rgba(var(--tg-theme-bg-color-rgb, 18, 18, 18), 0.5);
+            font-size: 1.05em;
             display: flex;
             align-items: center;
-            gap: 10px; /* Increased gap */
+            gap: 10px;
             backdrop-filter: blur(5px);
             -webkit-backdrop-filter: blur(5px);
         }
         .save-card-button:hover {
             opacity: 0.95;
-            transform: translateX(-50%) scale(1.05); /* Slightly larger scale */
+            transform: translateX(-50%) scale(1.05);
             box-shadow: var(--shadow-medium), 0 0 0 4px rgba(var(--tg-theme-bg-color-rgb, 18, 18, 18), 0.3);
         }
         .save-card-button i { font-size: 1.2em; }
@@ -382,7 +469,7 @@ TEMPLATE = """
         .modal {
             display: none; position: fixed; z-index: 1001;
             left: 0; top: 0; width: 100%; height: 100%;
-            overflow: auto; background-color: rgba(0,0,0,0.7); /* Darker backdrop */
+            overflow: auto; background-color: rgba(0,0,0,0.7);
             backdrop-filter: blur(8px);
             -webkit-backdrop-filter: blur(8px);
             animation: fadeIn 0.3s ease-out;
@@ -587,7 +674,6 @@ TEMPLATE = """
             root.style.setProperty('--tg-theme-button-text-color', themeParams.button_text_color || '#ffffff');
             root.style.setProperty('--tg-theme-secondary-bg-color', themeParams.secondary_bg_color || '#1e1e1e');
 
-            // Optional: Convert main bg color to RGB for glow effect alpha
             try {
                  const bgColor = themeParams.bg_color || '#121212';
                  const r = parseInt(bgColor.slice(1, 3), 16);
@@ -595,7 +681,7 @@ TEMPLATE = """
                  const b = parseInt(bgColor.slice(5, 7), 16);
                  root.style.setProperty('--tg-theme-bg-color-rgb', `${r}, ${g}, ${b}`);
             } catch (e) {
-                 root.style.setProperty('--tg-theme-bg-color-rgb', `18, 18, 18`); // Fallback
+                 root.style.setProperty('--tg-theme-bg-color-rgb', `18, 18, 18`);
             }
         }
 
@@ -604,7 +690,6 @@ TEMPLATE = """
                  console.error("Telegram WebApp script not loaded or initData is missing.");
                  const greetingElement = document.getElementById('greeting');
                  if(greetingElement) greetingElement.textContent = 'Не удалось связаться с Telegram.';
-                 // Apply default dark theme maybe? Or leave as is.
                  document.body.style.visibility = 'visible';
                  return;
              }
@@ -615,7 +700,6 @@ TEMPLATE = """
             applyTheme(tg.themeParams);
             tg.onEvent('themeChanged', () => applyTheme(tg.themeParams));
 
-            // Send initData for verification and user logging
              fetch('/verify', {
                  method: 'POST',
                  headers: {
@@ -633,16 +717,12 @@ TEMPLATE = """
                      console.log('Backend verification successful.');
                  } else {
                      console.warn('Backend verification failed:', data.message);
-                     // Potentially show a non-blocking warning to user if needed
                  }
              })
              .catch(error => {
                  console.error('Error sending initData for verification:', error);
-                 // Display a more user-friendly error?
              });
 
-
-             // User Greeting (using unsafe data for immediate feedback)
              const user = tg.initDataUnsafe?.user;
              const greetingElement = document.getElementById('greeting');
              if (user) {
@@ -653,16 +733,14 @@ TEMPLATE = """
                  console.warn('Telegram User data not available (initDataUnsafe.user is empty).');
              }
 
-             // Contact Links
              const contactButtons = document.querySelectorAll('.contact-link');
              contactButtons.forEach(button => {
                  button.addEventListener('click', (e) => {
                      e.preventDefault();
-                     tg.openTelegramLink('https://t.me/morshenkhan'); // Use actual contact username
+                     tg.openTelegramLink('https://t.me/morshenkhan');
                  });
              });
 
-             // Modal Setup
              const modal = document.getElementById("saveModal");
              const saveCardBtn = document.getElementById("save-card-btn");
              const closeBtn = document.getElementById("modal-close-btn");
@@ -704,7 +782,7 @@ TEMPLATE = """
                       if(greetingElement) greetingElement.textContent = 'Ошибка загрузки интерфейса Telegram.';
                       document.body.style.visibility = 'visible';
                   }
-             }, 3500); // Slightly longer timeout
+             }, 3500);
         }
 
     </script>
@@ -718,7 +796,7 @@ ADMIN_TEMPLATE = """
 <head>
     <meta charset="UTF-8">
     <meta name="viewport" content="width=device-width, initial-scale=1.0">
-    <title>Admin - Посетители</title>
+    <title>Admin - Посетители и Чаты</title>
     <link rel="preconnect" href="https://fonts.googleapis.com">
     <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin>
     <link href="https://fonts.googleapis.com/css2?family=Inter:wght@300;400;500;600;700&display=swap" rel="stylesheet">
@@ -734,6 +812,7 @@ ADMIN_TEMPLATE = """
             --admin-success: #198754;
             --admin-danger: #dc3545;
             --admin-warning: #ffc107;
+            --admin-info: #0dcaf0;
             --border-radius: 12px;
             --padding: 1.5rem;
             --font-family: 'Inter', sans-serif;
@@ -747,25 +826,28 @@ ADMIN_TEMPLATE = """
             line-height: 1.6;
         }
         .container { max-width: 1140px; margin: 0 auto; }
-        h1 { text-align: center; color: var(--admin-secondary); margin-bottom: var(--padding); font-weight: 600; }
+        h1, h2 { text-align: center; color: var(--admin-secondary); margin-bottom: var(--padding); font-weight: 600; }
+         h2 { margin-top: var(--padding); border-top: 1px solid var(--admin-border); padding-top: var(--padding); }
         .user-grid {
             display: grid;
             grid-template-columns: repeat(auto-fill, minmax(280px, 1fr));
             gap: var(--padding);
             margin-top: var(--padding);
         }
-        .user-card {
+        .user-card, .chat-card {
             background-color: var(--admin-card-bg);
             border-radius: var(--border-radius);
             padding: var(--padding);
             box-shadow: 0 4px 15px var(--admin-shadow);
             border: 1px solid var(--admin-border);
-            display: flex;
-            flex-direction: column;
-            align-items: center;
-            text-align: center;
             transition: transform 0.2s ease-in-out, box-shadow 0.2s ease-in-out;
         }
+        .user-card {
+             display: flex;
+             flex-direction: column;
+             align-items: center;
+             text-align: center;
+        }
         .user-card:hover {
             transform: translateY(-5px);
             box-shadow: 0 8px 25px rgba(0, 0, 0, 0.08);
@@ -774,7 +856,7 @@ ADMIN_TEMPLATE = """
             width: 80px; height: 80px;
             border-radius: 50%; margin-bottom: 1rem;
             object-fit: cover; border: 3px solid var(--admin-border);
-            background-color: #eee; /* Placeholder bg */
+            background-color: #eee;
         }
         .user-card .name { font-weight: 600; font-size: 1.2em; margin-bottom: 0.3rem; color: var(--admin-primary); }
         .user-card .username { color: var(--admin-secondary); margin-bottom: 0.8rem; font-size: 0.95em; }
@@ -782,7 +864,7 @@ ADMIN_TEMPLATE = """
         .user-card .detail-item { margin-bottom: 0.3rem; }
         .user-card .detail-item strong { color: var(--admin-text); }
         .user-card .timestamp { font-size: 0.8em; color: var(--admin-secondary); margin-top: 1rem; }
-        .no-users { text-align: center; color: var(--admin-secondary); margin-top: 2rem; font-size: 1.1em; }
+        .no-users, .no-chats { text-align: center; color: var(--admin-secondary); margin-top: 2rem; font-size: 1.1em; }
         .alert {
              background-color: #fff3cd; border-left: 6px solid var(--admin-warning);
              margin-bottom: var(--padding); padding: 1rem 1.5rem;
@@ -833,14 +915,105 @@ ADMIN_TEMPLATE = """
          .admin-controls .loader {
              border: 4px solid #f3f3f3; border-radius: 50%; border-top: 4px solid var(--admin-primary);
              width: 20px; height: 20px; animation: spin 1s linear infinite; display: inline-block; margin-left: 10px; vertical-align: middle;
-             display: none; /* Hidden by default */
+             display: none;
          }
          @keyframes spin { 0% { transform: rotate(0deg); } 100% { transform: rotate(360deg); } }
+
+        /* Chat History Styles */
+        .chat-history { margin-top: var(--padding); }
+        .chat-message {
+             margin-bottom: var(--padding-s);
+             padding: var(--padding-s) var(--padding-m);
+             border-radius: var(--border-radius-s);
+             max-width: 85%;
+             word-wrap: break-word;
+        }
+        .chat-message.user {
+             background-color: var(--admin-primary);
+             color: white;
+             align-self: flex-start;
+             margin-right: auto;
+        }
+        .chat-message.bot {
+             background-color: #e9ecef;
+             color: var(--admin-text);
+             align-self: flex-end;
+             margin-left: auto;
+        }
+         .chat-message .sender { font-weight: 600; margin-bottom: 4px; font-size: 0.9em;}
+         .chat-message .text { margin-bottom: 4px; font-size: 1em;}
+         .chat-message .time { font-size: 0.75em; color: rgba(255, 255, 255, 0.7); text-align: right; display: block;}
+         .chat-message.bot .time { color: #495057; }
+
+        .chat-thread {
+            background-color: var(--admin-card-bg);
+            border-radius: var(--border-radius);
+            padding: var(--padding);
+            box-shadow: 0 4px 15px var(--admin-shadow);
+            border: 1px solid var(--admin-border);
+            margin-bottom: var(--padding);
+        }
+        .chat-thread-header {
+            font-weight: 600;
+            font-size: 1.1em;
+            margin-bottom: var(--padding-m);
+            padding-bottom: var(--padding-s);
+            border-bottom: 1px solid var(--admin-border);
+             display: flex;
+             justify-content: space-between;
+             align-items: center;
+        }
+         .chat-thread-header span { color: var(--admin-primary); }
+        .chat-thread-messages {
+            display: flex;
+            flex-direction: column;
+            gap: var(--padding-s);
+        }
+
+        /* Send Message Form */
+        .send-message-form {
+             margin-top: var(--padding);
+             padding: var(--padding);
+             background: var(--admin-card-bg);
+             border-radius: var(--border-radius);
+             box-shadow: 0 4px 15px var(--admin-shadow);
+             border: 1px solid var(--admin-border);
+        }
+         .send-message-form h3 { margin-top: 0; margin-bottom: 1rem; color: var(--admin-secondary); font-weight: 600;}
+         .send-message-form label { display: block; margin-bottom: 0.5rem; font-weight: 500;}
+         .send-message-form select, .send-message-form textarea {
+             width: 100%;
+             padding: 0.75rem;
+             margin-bottom: 1rem;
+             border: 1px solid var(--admin-border);
+             border-radius: 8px;
+             font-family: var(--font-family);
+             font-size: 1em;
+             box-sizing: border-box;
+         }
+         .send-message-form textarea { min-height: 100px; resize: vertical; }
+         .send-message-form button {
+             display: inline-block;
+             padding: 10px 20px;
+             font-size: 1em;
+             font-weight: 500;
+             color: #fff;
+             background-color: var(--admin-success);
+             border: none;
+             border-radius: 8px;
+             cursor: pointer;
+             transition: background-color 0.2s ease;
+         }
+         .send-message-form button:hover { background-color: #157347; }
+         .send-message-status { margin-top: 1rem; text-align: center; font-weight: 500;}
+         .status-success { color: var(--admin-success); }
+         .status-error { color: var(--admin-danger); }
+         .status-info { color: var(--admin-info); }
     </style>
 </head>
 <body>
     <div class="container">
-        <h1>Посетители Mini App</h1>
+        <h1>Admin Panel</h1>
         <div class="alert">ВНИМАНИЕ: Этот раздел не защищен! Добавьте аутентификацию для реального использования.</div>
 
         <div class="admin-controls">
@@ -851,8 +1024,9 @@ ADMIN_TEMPLATE = """
             <div class="status" id="status-message"></div>
         </div>
 
-        <button class="refresh-btn" onclick="location.reload()">Обновить список</button>
+        <button class="refresh-btn" onclick="location.reload()">Обновить страницу</button>
 
+        <h2>Посетители Mini App</h2>
         {% if users %}
             <div class="user-grid">
                 {% for user in users|sort(attribute='visited_at', reverse=true) %}
@@ -862,7 +1036,7 @@ ADMIN_TEMPLATE = """
                         {% if user.username %}
                             <div class="username"><a href="https://t.me/{{ user.username }}" target="_blank" style="color: inherit; text-decoration: none;">@{{ user.username }}</a></div>
                         {% else %}
-                             <div class="username" style="height: 1.3em;"></div> {# Placeholder for spacing #}
+                             <div class="username" style="height: 1.3em;"></div>
                         {% endif %}
                         <div class="details">
                            <div class="detail-item"><strong>ID:</strong> {{ user.id }}</div>
@@ -877,11 +1051,75 @@ ADMIN_TEMPLATE = """
         {% else %}
             <p class="no-users">Данных о посетителях пока нет.</p>
         {% endif %}
+
+         <h2>История чатов с ботом</h2>
+         {% if chats %}
+            <div class="chat-history">
+                {% for chat_id, messages in chats|dictsort %}
+                    <div class="chat-thread">
+                         <div class="chat-thread-header">
+                             <span>Чат ID: {{ chat_id }}</span>
+                             {% set chat_user = users_by_id.get(chat_id|int) %}
+                             {% if chat_user %}
+                                 <span>Пользователь:
+                                     {% if chat_user.username %}
+                                         <a href="https://t.me/{{ chat_user.username }}" target="_blank" style="color: var(--admin-secondary); text-decoration: none;">@{{ chat_user.username }}</a>
+                                     {% else %}
+                                         {{ chat_user.first_name or 'Неизвестный' }}
+                                     {% endif %}
+                                     ({{ chat_user.id }})
+                                 </span>
+                             {% else %}
+                                 <span>Пользователь: Неизвестен ({{ chat_id }})</span>
+                             {% endif %}
+                         </div>
+                        <div class="chat-thread-messages">
+                            {% for message in messages %}
+                                <div class="chat-message {{ 'user' if message.role == 'user' else 'bot' }}">
+                                    <div class="sender">{{ message.sender_name }}</div>
+                                    <div class="text">{{ message.text }}</div>
+                                     <div class="time">{{ message.timestamp_str }}</div>
+                                </div>
+                            {% endfor %}
+                        </div>
+                    </div>
+                {% endfor %}
+            </div>
+         {% else %}
+             <p class="no-chats">История чатов пуста.</p>
+         {% endif %}
+
+         <div class="send-message-form">
+             <h3>Отправить сообщение пользователю</h3>
+             <form id="sendMessageForm">
+                 <label for="chat_id">Выберите пользователя (Chat ID):</label>
+                 <select id="chat_id" name="chat_id" required>
+                     <option value="">-- Выберите --</option>
+                     {% for user in users|sort(attribute='first_name') %}
+                         <option value="{{ user.id }}">
+                             {{ user.first_name or '' }} {{ user.last_name or '' }}
+                             {% if user.username %} (@{{ user.username }}) {% endif %}
+                             (ID: {{ user.id }})
+                         </option>
+                     {% endfor %}
+                 </select>
+
+                 <label for="message_text">Текст сообщения:</label>
+                 <textarea id="message_text" name="message_text" required></textarea>
+
+                 <button type="submit">Отправить</button>
+             </form>
+              <div class="send-message-status" id="sendMessageStatus"></div>
+         </div>
+
+
     </div>
 
     <script>
         const loader = document.getElementById('loader');
         const statusMessage = document.getElementById('status-message');
+        const sendMessageForm = document.getElementById('sendMessageForm');
+        const sendMessageStatus = document.getElementById('sendMessageStatus');
 
         async function handleFetch(url, action) {
             loader.style.display = 'inline-block';
@@ -894,7 +1132,9 @@ ADMIN_TEMPLATE = """
                     statusMessage.textContent = data.message;
                     statusMessage.style.color = 'var(--admin-success)';
                     if (action === 'скачивание') {
-                        setTimeout(() => location.reload(), 1500); // Reload after download success
+                        setTimeout(() => location.reload(), 1500);
+                    } else {
+                        setTimeout(() => statusMessage.textContent = '', 3000);
                     }
                 } else {
                     throw new Error(data.message || 'Произошла ошибка');
@@ -903,6 +1143,7 @@ ADMIN_TEMPLATE = """
                 statusMessage.textContent = `Ошибка ${action}: ${error.message}`;
                 statusMessage.style.color = 'var(--admin-danger)';
                 console.error(`Error during ${action}:`, error);
+                setTimeout(() => statusMessage.textContent = '', 5000);
             } finally {
                 loader.style.display = 'none';
             }
@@ -915,17 +1156,115 @@ ADMIN_TEMPLATE = """
         function triggerUpload() {
             handleFetch('/admin/upload_data', 'загрузка');
         }
+
+        sendMessageForm.addEventListener('submit', async function(event) {
+            event.preventDefault();
+            const chatId = document.getElementById('chat_id').value;
+            const messageText = document.getElementById('message_text').value;
+
+            if (!chatId || !messageText.trim()) {
+                sendMessageStatus.textContent = 'Выберите пользователя и введите текст сообщения.';
+                sendMessageStatus.className = 'send-message-status status-warning';
+                return;
+            }
+
+            sendMessageStatus.textContent = 'Отправка сообщения...';
+            sendMessageStatus.className = 'send-message-status status-info';
+
+            try {
+                const response = await fetch('/admin/send_message', {
+                    method: 'POST',
+                    headers: { 'Content-Type': 'application/json' },
+                    body: JSON.stringify({ chat_id: chatId, message: messageText })
+                });
+                const data = await response.json();
+
+                if (response.ok && data.status === 'ok') {
+                    sendMessageStatus.textContent = 'Сообщение успешно отправлено!';
+                    sendMessageStatus.className = 'send-message-status status-success';
+                    document.getElementById('message_text').value = '';
+                    setTimeout(() => location.reload(), 1500); // Reload to show sent message
+                } else {
+                    throw new Error(data.message || 'Неизвестная ошибка');
+                }
+            } catch (error) {
+                sendMessageStatus.textContent = `Ошибка отправки: ${error.message}`;
+                sendMessageStatus.className = 'send-message-status status-error';
+                console.error('Error sending message:', error);
+            }
+        });
+
     </script>
 </body>
 </html>
 """
 
-# --- Flask Routes ---
+@dp.message_handler()
+async def handle_messages(message: types.Message):
+    user_id = message.from_user.id
+    user_full_name = message.from_user.full_name or f"User {user_id}"
+    chat_id = message.chat.id
+    message_text = message.text
+
+    now = time.time()
+    timestamp_str = datetime.fromtimestamp(now).strftime('%Y-%m-%d %H:%M:%S')
+
+    save_chat_message({
+        'chat_id': chat_id,
+        'role': 'user',
+        'sender_id': user_id,
+        'sender_name': user_full_name,
+        'text': message_text,
+        'timestamp': now,
+        'timestamp_str': timestamp_str
+    })
+
+    logging.info(f"Received message from user {user_id} ({user_full_name}): {message_text}")
+
+    try:
+        ai_response_text = generate_ai_response(message_text)
+        await message.answer(ai_response_text)
+
+        now_bot = time.time()
+        timestamp_str_bot = datetime.fromtimestamp(now_bot).strftime('%Y-%m-%d %H:%M:%S')
+        save_chat_message({
+            'chat_id': chat_id,
+            'role': 'bot',
+            'sender_id': bot.id,
+            'sender_name': "Bot",
+            'text': ai_response_text,
+            'timestamp': now_bot,
+            'timestamp_str': timestamp_str_bot
+        })
+        logging.info(f"Sent AI response to user {user_id}: {ai_response_text}")
+
+    except Exception as e:
+        logging.error(f"Error handling message for user {user_id}: {e}")
+        await message.answer("Произошла ошибка при обработке вашего запроса.")
+        now_bot = time.time()
+        timestamp_str_bot = datetime.fromtimestamp(now_bot).strftime('%Y-%m-%d %H:%M:%S')
+        save_chat_message({
+            'chat_id': chat_id,
+            'role': 'bot',
+            'sender_id': bot.id,
+            'sender_name': "Bot",
+            'text': "Произошла ошибка при обработке вашего запроса.",
+            'timestamp': now_bot,
+            'timestamp_str': timestamp_str_bot
+        })
+
+
+def run_bot():
+    try:
+        logging.info("Starting aiogram bot polling...")
+        executor.start_polling(dp, skip_updates=True)
+    except Exception as e:
+        logging.error(f"Error starting aiogram bot polling: {e}")
+
+
 @app.route('/')
 def index():
-    # Pass theme parameters for initial render if available (e.g., from query params or session)
-    # For simplicity, we let the JS handle theme application after tg.ready()
-    theme_params = {} # Or load from request if needed
+    theme_params = {}
     return render_template_string(TEMPLATE, theme=theme_params)
 
 @app.route('/verify', methods=['POST'])
@@ -951,9 +1290,8 @@ def verify_data():
             user_id = user_info_dict.get('id')
             if user_id:
                 now = time.time()
-                # Create data entry for the specific user
                 user_entry = {
-                    str(user_id): { # Use string keys for JSON compatibility
+                    str(user_id): {
                         'id': user_id,
                         'first_name': user_info_dict.get('first_name'),
                         'last_name': user_info_dict.get('last_name'),
@@ -961,12 +1299,11 @@ def verify_data():
                         'photo_url': user_info_dict.get('photo_url'),
                         'language_code': user_info_dict.get('language_code'),
                         'is_premium': user_info_dict.get('is_premium', False),
-                        'phone_number': user_info_dict.get('phone_number'), # Note: Only available if requested via button
+                        'phone_number': user_info_dict.get('phone_number'),
                         'visited_at': now,
                         'visited_at_str': datetime.fromtimestamp(now).strftime('%Y-%m-%d %H:%M:%S')
                     }
                 }
-                # Save/update this specific user's data
                 save_visitor_data(user_entry)
             return jsonify({"status": "ok", "verified": True, "user": user_info_dict}), 200
         else:
@@ -979,14 +1316,29 @@ def verify_data():
 
 @app.route('/admin')
 def admin_panel():
-    # WARNING: This route is unprotected! Add proper authentication/authorization.
-    current_data = load_visitor_data() # Load from cache/file
-    users_list = list(current_data.values())
-    return render_template_string(ADMIN_TEMPLATE, users=users_list)
+    full_data = load_visitor_data()
+    users_list = list(full_data.get("visitors", {}).values())
+    chat_entries = full_data.get("chats", [])
+
+    chats_by_id = {}
+    for chat in chat_entries:
+        chat_id = str(chat.get('chat_id'))
+        if chat_id not in chats_by_id:
+            chats_by_id[chat_id] = []
+        chats_by_id[chat_id].append(chat)
+
+    for chat_id in chats_by_id:
+        chats_by_id[chat_id].sort(key=lambda x: x.get('timestamp', 0))
+
+    users_by_id = {user['id']: user for user in users_list}
+
+    return render_template_string(ADMIN_TEMPLATE,
+                                  users=users_list,
+                                  chats=chats_by_id,
+                                  users_by_id=users_by_id)
 
 @app.route('/admin/download_data', methods=['POST'])
 def admin_trigger_download():
-    # WARNING: Unprotected endpoint
     success = download_data_from_hf()
     if success:
          return jsonify({"status": "ok", "message": "Скачивание данных с Hugging Face завершено. Страница будет обновлена."})
@@ -995,53 +1347,101 @@ def admin_trigger_download():
 
 @app.route('/admin/upload_data', methods=['POST'])
 def admin_trigger_upload():
-    # WARNING: Unprotected endpoint
     if not HF_TOKEN_WRITE:
         return jsonify({"status": "error", "message": "HF_TOKEN_WRITE не настроен на сервере."}), 400
-    upload_data_to_hf_async() # Trigger async upload
+    upload_data_to_hf_async()
     return jsonify({"status": "ok", "message": "Загрузка данных на Hugging Face запущена в фоновом режиме."})
 
+@app.route('/admin/send_message', methods=['POST'])
+def admin_send_message():
+    try:
+        req_data = request.get_json()
+        chat_id = req_data.get('chat_id')
+        message_text = req_data.get('message')
+
+        if not chat_id or not message_text:
+            return jsonify({"status": "error", "message": "Missing chat_id or message text"}), 400
+
+        try:
+            chat_id = int(chat_id)
+        except ValueError:
+             return jsonify({"status": "error", "message": "Invalid chat ID"}), 400
+
+        loop = asyncio.new_event_loop()
+        asyncio.set_event_loop(loop)
+        try:
+            loop.run_until_complete(bot.send_message(chat_id=chat_id, text=message_text))
+
+            now = time.time()
+            timestamp_str = datetime.fromtimestamp(now).strftime('%Y-%m-%d %H:%M:%S')
+            save_chat_message({
+                'chat_id': chat_id,
+                'role': 'admin_sent',
+                'sender_id': 'admin', # Or a specific admin identifier
+                'sender_name': 'Admin',
+                'text': message_text,
+                'timestamp': now,
+                'timestamp_str': timestamp_str
+            })
+
+            return jsonify({"status": "ok", "message": "Сообщение успешно отправлено!"}), 200
+        except Exception as e:
+            logging.error(f"Error sending message via bot API: {e}")
+            return jsonify({"status": "error", "message": f"Ошибка отправки сообщения через Bot API: {e}"}), 500
+        finally:
+            loop.close()
+
+
+    except Exception as e:
+        logging.exception("Error in /admin/send_message endpoint")
+        return jsonify({"status": "error", "message": "Internal server error"}), 500
+
 
-# --- App Initialization ---
 if __name__ == '__main__':
-    print("---")
-    print("--- MORSHEN GROUP MINI APP SERVER ---")
-    print("---")
-    print(f"Flask server starting on http://{HOST}:{PORT}")
-    print(f"Using Bot Token ID: {BOT_TOKEN.split(':')[0]}")
-    print(f"Visitor data file: {DATA_FILE}")
-    print(f"Hugging Face Repo: {REPO_ID}")
-    print(f"HF Data Path: {HF_DATA_FILE_PATH}")
+    logging.info("---")
+    logging.info("--- MORSHEN GROUP MINI APP & BOT SERVER ---")
+    logging.info("---")
+    logging.info(f"Flask server starting on http://{HOST}:{PORT}")
+    logging.info(f"Using Bot Token ID: {BOT_TOKEN.split(':')[0]}")
+    logging.info(f"Visitor data file: {DATA_FILE}")
+    logging.info(f"Hugging Face Repo: {REPO_ID}")
+    logging.info(f"HF Data Path: {HF_DATA_FILE_PATH}")
     if not HF_TOKEN_READ or not HF_TOKEN_WRITE:
-         print("---")
-         print("--- WARNING: HUGGING FACE TOKEN(S) NOT SET ---")
-         print("--- Backup/restore functionality will be limited. Set HF_TOKEN_READ and HF_TOKEN_WRITE environment variables.")
-         print("---")
+         logging.warning("---")
+         logging.warning("--- WARNING: HUGGING FACE TOKEN(S) NOT SET ---")
+         logging.warning("--- Backup/restore functionality will be limited. Set HF_TOKEN_READ and HF_TOKEN_WRITE environment variables.")
+         logging.warning("---")
     else:
-         print("--- Hugging Face tokens found.")
-         # Initial attempt to download data on startup
-         print("--- Attempting initial data download from Hugging Face...")
+         logging.info("--- Hugging Face tokens found.")
+         logging.info("--- Attempting initial data download from Hugging Face...")
          download_data_from_hf()
 
-    # Load initial data from local file (might have been updated by download)
+    if not GEMINI_API_KEY:
+        logging.warning("---")
+        logging.warning("--- WARNING: GEMINI_API_KEY NOT SET ---")
+        logging.warning("--- AI response functionality will be disabled. Set GEMINI_API_KEY environment variable.")
+        logging.warning("---")
+    else:
+         logging.info("--- GEMINI_API_KEY found.")
+
     load_visitor_data()
 
-    print("---")
-    print("--- SECURITY WARNING ---")
-    print("--- The /admin route and its sub-routes are NOT protected.")
-    print("--- Implement proper authentication before deploying.")
-    print("---")
+    logging.warning("---")
+    logging.warning("--- SECURITY WARNING ---")
+    logging.warning("--- The /admin route and its sub-routes are NOT protected.")
+    logging.warning("--- Implement proper authentication before deploying.")
+    logging.warning("---")
 
-    # Start periodic backup thread if write token is available
     if HF_TOKEN_WRITE:
         backup_thread = threading.Thread(target=periodic_backup, daemon=True)
         backup_thread.start()
-        print("--- Periodic backup thread started (every hour).")
+        logging.info("--- Periodic backup thread started (every hour).")
     else:
-        print("--- Periodic backup disabled (HF_TOKEN_WRITE missing).")
+        logging.info("--- Periodic backup disabled (HF_TOKEN_WRITE missing).")
+
+    bot_thread = threading.Thread(target=run_bot, daemon=True)
+    bot_thread.start()
+    logging.info("--- Telegram bot polling thread started.")
 
-    print("--- Server Ready ---")
-    # Use a production server like Waitress or Gunicorn instead of app.run() for deployment
-    # from waitress import serve
-    # serve(app, host=HOST, port=PORT)
-    app.run(host=HOST, port=PORT, debug=False) # debug=False for production recommended
+    logging.info("--- Server Ready ---")
+    app.run(host=HOST, port=PORT, debug=False)