Update subscription.py

.env.example

@@ -21,8 +21,10 @@ POSTGRES_USER=remnawave_user
 POSTGRES_PASSWORD=secure_password_123
 
 # ===== REMNAWAVE API =====
-REMNAWAVE_API_URL=
+REMNAWAVE_API_URL=https://panel.example.com
 REMNAWAVE_API_KEY=
+# Для панелей установленных скриптом eGames прописывать ключ в формате XXXXXXX:DDDDDDDD - https://panel.example.com/auth/login?XXXXXXX=DDDDDDDD
+REMNAWAVE_SECRET_KEY=your_secret_key_here
 
 # ===== ТРИАЛ ПОДПИСКА =====
 TRIAL_DURATION_DAYS=3
@@ -143,6 +145,15 @@ YOOKASSA_WEBHOOK_PATH=/yookassa-webhook
 YOOKASSA_WEBHOOK_PORT=8082
 YOOKASSA_WEBHOOK_SECRET=your_webhook_secret
 
+# ===== НАСТРОЙКИ ОПИСАНИЙ ПЛАТЕЖЕЙ =====
+# Эти настройки позволяют изменить описания платежей, 
+# чтобы избежать блокировок платежных систем
+PAYMENT_SERVICE_NAME=Интернет-сервис
+PAYMENT_BALANCE_DESCRIPTION=Пополнение баланса
+PAYMENT_SUBSCRIPTION_DESCRIPTION=Оплата подписки
+PAYMENT_BALANCE_TEMPLATE={service_name} - {description}
+PAYMENT_SUBSCRIPTION_TEMPLATE={service_name} - {description}
+
 # ===== ИНТЕРФЕЙС И UX =====
 
 # Режим работы кнопки "Подключиться"

Dockerfile

@@ -1,35 +1,43 @@
-
 FROM python:3.11-slim
-
 WORKDIR /app
 
 # Install system dependencies
 RUN apt-get update && apt-get install -y \
     gcc \
+    wget \
     && rm -rf /var/lib/apt/lists/*
 
 # Copy requirements first for better caching
 COPY requirements.txt .
 RUN pip install --no-cache-dir -r requirements.txt
 
+# Create non-root user with specific UID/GID for consistency
+RUN groupadd -g 1000 app && \
+    useradd -u 1000 -g 1000 -m -s /bin/bash app
+
 # Copy application code
 COPY . .
 
-# Create logs directory
-RUN mkdir -p logs
+# Create necessary directories and set permissions
+RUN mkdir -p logs data && \
+    chown -R app:app /app && \
+    chmod -R 755 /app && \
+    chmod -R 777 logs
+
+# Switch to non-root user
+USER app
 
 # Set environment variables
 ENV PYTHONPATH=/app
 ENV PYTHONUNBUFFERED=1
 
-# Create non-root user
-RUN useradd --create-home --shell /bin/bash app
-RUN chown -R app:app /app
-USER app
-
-# Expose webhook ports для платежных систем
+# Expose webhook ports
 EXPOSE 8081
 EXPOSE 8082
 
+# Health check
+HEALTHCHECK --interval=30s --timeout=10s --start-period=30s --retries=3 \
+    CMD wget --no-verbose --tries=1 --spider http://localhost:8081/health || exit 1
+
 # Run the application
 CMD ["python", "main.py"]

README.md

@@ -51,6 +51,7 @@
 - 📈 **Масштабируемость** 
 - 🔧 **Мониторинг** - Prometheus, Grafana, health checks
 - 🔧 **Режим технических работ** - Ручное включение + Мониторинг системы, который в случае падении панели Remnawave переведет бота в режим технических работ и обратно - отключит его, если панель поднимется.
+- Интеграция с системой защиты панели Remnawave через куки-аутентификацию, которая используется в [remnawave-reverse-proxy](https://github.com/eGamesAPI/remnawave-reverse-proxy) для скрытия панели от несанкционированного доступа.
 
 ---
 
@@ -71,10 +72,10 @@ nano .env  # Заполни токены и настройки
 mkdir -p logs data
 
 # 4. Запусти всё разом
-docker compose up -d --build
+docker compose up -d
 
 # 5. Проверь статус
-docker compose logs -f bot
+docker compose logs 
 ```
 
 ### ⚙️ ENV параметры
@@ -113,8 +114,10 @@ POSTGRES_USER=remnawave_user
 POSTGRES_PASSWORD=secure_password_123
 
 # ===== REMNAWAVE API =====
-REMNAWAVE_API_URL=
+REMNAWAVE_API_URL=https://panel.example.com
 REMNAWAVE_API_KEY=
+# Для панелей установленных скриптом eGames прописывать ключ в формате XXXXXXX:DDDDDDDD - https://panel.example.com/auth/login?XXXXXXX=DDDDDDDD
+REMNAWAVE_SECRET_KEY=your_secret_key_here
 
 # ===== ТРИАЛ ПОДПИСКА =====
 TRIAL_DURATION_DAYS=3
@@ -235,6 +238,15 @@ YOOKASSA_WEBHOOK_PATH=/yookassa-webhook
 YOOKASSA_WEBHOOK_PORT=8082
 YOOKASSA_WEBHOOK_SECRET=your_webhook_secret
 
+# ===== НАСТРОЙКИ ОПИСАНИЙ ПЛАТЕЖЕЙ =====
+# Эти настройки позволяют изменить описания платежей, 
+# чтобы избежать блокировок платежных систем
+PAYMENT_SERVICE_NAME=Интернет-сервис
+PAYMENT_BALANCE_DESCRIPTION=Пополнение баланса
+PAYMENT_SUBSCRIPTION_DESCRIPTION=Оплата подписки
+PAYMENT_BALANCE_TEMPLATE={service_name} - {description}
+PAYMENT_SUBSCRIPTION_TEMPLATE={service_name} - {description}
+
 # ===== ИНТЕРФЕЙС И UX =====
 
 # Режим работы кнопки "Подключиться"
@@ -329,7 +341,7 @@ services:
       retries: 3
 
   bot:
-    build: .
+    image: fr1ngg/remnawave-bedolaga-telegram-bot:latest
     container_name: remnawave_bot
     restart: unless-stopped
     depends_on:
@@ -343,8 +355,8 @@ services:
       DATABASE_URL: postgresql+asyncpg://${POSTGRES_USER:-remnawave_user}:${POSTGRES_PASSWORD:-secure_password_123}@postgres:5432/${POSTGRES_DB:-remnawave_bot}
       REDIS_URL: redis://redis:6379/0
     volumes:
-      - ./logs:/app/logs
-      - ./data:/app/data
+      - ./logs:/app/logs:rw
+      - ./data:/app/data:rw
       - /etc/timezone:/etc/timezone:ro
       - /etc/localtime:/etc/localtime:ro
     ports:
@@ -352,12 +364,12 @@ services:
       - "${YOOKASSA_WEBHOOK_PORT:-8082}:8082"
     networks:
       - bot_network
-    healthcheck:
-      test: ["CMD", "wget", "--no-verbose", "--tries=1", "--spider", "http://localhost:8081/health"]
-      interval: 30s
-      timeout: 10s
-      retries: 3
-      start_period: 60s
+    user: "1000:1000"
+    command: >
+      bash -c "
+        mkdir -p /app/logs /app/data &&
+        python main.py
+      "
 
 volumes:
   postgres_data:
@@ -422,16 +434,16 @@ your-domain.com {
 
 ```bash
 # Быстрый старт
-docker compose up -d --build
+docker compose up -d
 
 # Статус сервисов
 docker compose ps
 
 # Логи
-docker compose logs -f bot
+docker compose logs
 
 # Перезапуск
-docker compose restart bot
+docker compose restart
 
 # Остановка
 docker compose down
@@ -451,27 +463,32 @@ docker compose down -v --remove-orphans
 ### 👤 **Для пользователей**
 
 🛒 **Умная покупка подписок**
-- 📅 Выбор периода (14-360 дней)
-- 📊 Настройка трафика (5GB - безлимит)
-- 🌍 Выбор стран через сквады
-- 📱 Количество устройств (1-10)
+- 📅 Выбор периода (14-360 дней) (С возможностью настройки выводимых периодов 14/30/60/90/180/360 дней)
+- 📊 Настройка трафика (5GB - безлимит) (Можно откоючить данный шаг, всем подпискам выдавать единый)
+- 🌍 Выбор стран через сквады (Доступно при наличие двух стран(сквадов) в продаже)
+- 📱 Количество устройств (1-5)
+
+ 🧪 **Тестовая подписка**
+ - Получение настраиваемой разовой тестовой подписки
+ - Уведомления об истечении с предложением о переходе н платную версию
 
 💰 **Удобные платежи**
 - ⭐ Telegram Stars 
-- 💳 Tribute (автопополнение)
+- 💳 Tribute 
 - 💳 YooKassa
 - 🎁 Реферальные бонусы
+- Детальная история транзакций 
 
 📱 **Управление подписками**
 - 📈 Просмотр статистики использования
 - 🔄 Автопродление с баланса
 - 🔄 Сброс/увеличение трафика
-- 🌍 Смена стран на лету
+- 🌍 Смена стран на лету (Доступно при наличие двух стран(сквадов) в продаже)
+- 📱 Настройка устройств с возможностью докупки(до 10ти устройств) + сброса устройств
 
 🎁 **Бонусная система**
 - 🎫 Промокоды на деньги/дни
 - 👥 Реферальная программа 
-- 🆓 Бесплатный триал
 - 🔔 Ежедневные уведомления
 
 </td>
@@ -488,26 +505,35 @@ docker compose down -v --remove-orphans
 👥 **Управление пользователями**
 - 🔍 Поиск и редактирование профилей
 - 💰 Управление балансами
-- 🚫 Блокировка/разблокировка
-- 📋 Массовые операции
+- 🚫 Блокировка/разблокировка/удаление
 
 🎫 **Промо-система**
-- 🎁 Создание промокодов (деньги/дни)
+- 🎁 Создание промокодов (деньги/дни/длинный триал)
 - 📊 Статистика использования
-- 🔄 Массовая генерация
-- ⚙️ Гибкие условия активации
+- ⚙️ Полное редактирование промокодов (Изминение условий, активация/деактивация/удаление + статистика применения) 
 
 🖥️ **Мониторинг системы**
 - 💚 Состояние Remnawave панели
-- 🔄 Синхронизация данных
-- 🌐 Управление сквадами
+- 🔄 Синхронизация данных (Передача данных из панели в бота)
+- 🌐 Управление сквадами 
 - 📋 Логи и диагностика
+- 🚧 Автоматический режим тех. работ (Включение в случае падения коннекта с панелью Remnawave c уведомлениями администраторам)
 
 📨 **Коммуникации**
 - 📢 Рассылки по сегментам
 - 🔔 Автоуведомления о продлении
 - 💬 Система поддержки
 - 📝 Настройка правил сервиса
+- Поддержка HTML разметки 
+
+🚧 **Режим технических работ**
+- Ручное включение/отключение с указанием причины
+- Включение/выключение мониторинга состояния панели (проверяет соеденение до панели раз в 30 сек(можно изменить промежуток)
+- Принудительаная проверка API
+
+📖 **Правила сервиса**
+- Настройка правил сервиса
+- Просмотр текущих правил
 
 </td>
 </tr>

app/bot.py

@@ -52,6 +52,9 @@ async def setup_bot() -> tuple[Bot, Dispatcher]:
         default=DefaultBotProperties(parse_mode=ParseMode.HTML)
     )
     
+    maintenance_service.set_bot(bot)
+    logger.info("Бот установлен в maintenance_service")
+    
     try:
         redis_client = redis.from_url(settings.REDIS_URL)
         await redis_client.ping()
@@ -107,7 +110,6 @@ async def setup_bot() -> tuple[Bot, Dispatcher]:
 
 
 async def shutdown_bot():
-    """Корректное завершение работы бота"""
     try:
         await maintenance_service.stop_monitoring()
         logger.info("Мониторинг техработ остановлен")

app/config.py

@@ -16,6 +16,7 @@ class Settings(BaseSettings):
     
     REMNAWAVE_API_URL: str
     REMNAWAVE_API_KEY: str
+    REMNAWAVE_SECRET_KEY: Optional[str] = None
     
     TRIAL_DURATION_DAYS: int = 3
     TRIAL_TRAFFIC_LIMIT_GB: int = 10
@@ -93,6 +94,12 @@ class Settings(BaseSettings):
     YOOKASSA_WEBHOOK_PATH: str = "/yookassa-webhook"
     YOOKASSA_WEBHOOK_PORT: int = 8082
     YOOKASSA_WEBHOOK_SECRET: Optional[str] = None
+    PAYMENT_BALANCE_DESCRIPTION: str = "Пополнение баланса"
+    PAYMENT_SUBSCRIPTION_DESCRIPTION: str = "Оплата подписки"
+    PAYMENT_SERVICE_NAME: str = "Интернет-сервис"
+    PAYMENT_BALANCE_TEMPLATE: str = "{service_name} - {description}"
+    PAYMENT_SUBSCRIPTION_TEMPLATE: str = "{service_name} - {description}"
+
 
     CONNECT_BUTTON_MODE: str = "guide"
     MINIAPP_CUSTOM_URL: str = ""
@@ -256,6 +263,24 @@ class Settings(BaseSettings):
             
         except (ValueError, AttributeError):
             return [30, 90, 180]
+
+    def get_balance_payment_description(self, amount_kopeks: int) -> str:
+        return self.PAYMENT_BALANCE_TEMPLATE.format(
+            service_name=self.PAYMENT_SERVICE_NAME,
+            description=f"{self.PAYMENT_BALANCE_DESCRIPTION} на {self.format_price(amount_kopeks)}"
+        )
+    
+    def get_subscription_payment_description(self, period_days: int, amount_kopeks: int) -> str:
+        return self.PAYMENT_SUBSCRIPTION_TEMPLATE.format(
+            service_name=self.PAYMENT_SERVICE_NAME,
+            description=f"{self.PAYMENT_SUBSCRIPTION_DESCRIPTION} на {period_days} дней"
+        )
+    
+    def get_custom_payment_description(self, description: str) -> str:
+        return self.PAYMENT_BALANCE_TEMPLATE.format(
+            service_name=self.PAYMENT_SERVICE_NAME,
+            description=description
+        )
     
     model_config = {
         "env_file": ".env",

app/database/crud/subscription.py

@@ -512,7 +512,7 @@ async def get_subscription_renewal_cost(
         if subscription.traffic_limit_gb > 0:
             traffic_cost = TRAFFIC_PRICES.get(subscription.traffic_limit_gb, 0)
         
-        devices_cost = max(0, subscription.device_limit - 1) * settings.PRICE_PER_DEVICE
+        devices_cost = max(0, subscription.device_limit - settings.DEFAULT_DEVICE_LIMIT) * settings.PRICE_PER_DEVICE
         
         total_cost = base_price + servers_cost + traffic_cost + devices_cost
         

app/external/remnawave_api.py

@@ -8,6 +8,7 @@ import aiohttp
 import logging
 from dataclasses import dataclass
 from enum import Enum
+from urllib.parse import urlparse, urljoin
 
 logger = logging.getLogger(__name__)
 
@@ -33,7 +34,7 @@ class RemnaWaveUser:
     username: str
     status: UserStatus
     used_traffic_bytes: int
-    lifetime_used_traffic_bytes: int  # Новое поле
+    lifetime_used_traffic_bytes: int 
     traffic_limit_bytes: int
     traffic_limit_strategy: TrafficLimitStrategy
     expire_at: datetime
@@ -92,10 +93,12 @@ class RemnaWaveAPIError(Exception):
 
 class RemnaWaveAPI:
     
-    def __init__(self, base_url: str, api_key: str):
+    def __init__(self, base_url: str, api_key: str, secret_key: Optional[str] = None):
         self.base_url = base_url.rstrip('/')
         self.api_key = api_key
+        self.secret_key = secret_key 
         self.session: Optional[aiohttp.ClientSession] = None
+        self.authenticated = False 
         
     def _detect_connection_type(self) -> str:
         parsed = urlparse(self.base_url)
@@ -124,18 +127,29 @@ class RemnaWaveAPI:
             
         headers = {
             'Authorization': f'Bearer {self.api_key}',
-            'Content-Type': 'application/json'
+            'Content-Type': 'application/json',
+            'Accept': 'application/json',
+            'X-Forwarded-Proto': 'https',
+            'X-Forwarded-For': '127.0.0.1',
+            'X-Real-IP': '127.0.0.1'
         }
         
+        cookies = None
+        if self.secret_key:
+            if ':' in self.secret_key:
+                key_name, key_value = self.secret_key.split(':', 1)
+                cookies = {key_name: key_value}
+                logger.debug(f"🍪 Используем куки: {key_name}=***")
+            else:
+                cookies = {self.secret_key: self.secret_key}
+                logger.debug(f"🍪 Используем куки: {self.secret_key}=***")
+        
         connector_kwargs = {}
         
         if conn_type == "local":
             logger.debug("🏠 Использую локальные заголовки proxy")
             headers.update({
-                'X-Forwarded-For': '127.0.0.1',
-                'X-Forwarded-Proto': 'https',
                 'X-Forwarded-Host': 'localhost',
-                'X-Real-IP': '127.0.0.1',
                 'Host': 'localhost'
             })
             
@@ -152,11 +166,18 @@ class RemnaWaveAPI:
             
         connector = aiohttp.TCPConnector(**connector_kwargs)
         
-        self.session = aiohttp.ClientSession(
-            timeout=aiohttp.ClientTimeout(total=30),
-            headers=headers,
-            connector=connector
-        )
+        session_kwargs = {
+            'timeout': aiohttp.ClientTimeout(total=30),
+            'headers': headers,
+            'connector': connector
+        }
+        
+        if cookies:
+            session_kwargs['cookies'] = cookies
+            
+        self.session = aiohttp.ClientSession(**session_kwargs)
+        self.authenticated = True 
+                
         return self
         
     async def __aexit__(self, exc_type, exc_val, exc_tb):
@@ -194,6 +215,8 @@ class RemnaWaveAPI:
                 
                 if response.status >= 400:
                     error_message = response_data.get('message', f'HTTP {response.status}')
+                    logger.error(f"API Error {response.status}: {error_message}")
+                    logger.error(f"Response: {response_text[:500]}")
                     raise RemnaWaveAPIError(
                         error_message, 
                         response.status, 

app/handlers/admin/messages.py

@@ -45,7 +45,8 @@ async def show_messages_menu(
     
     await callback.message.edit_text(
         text,
-        reply_markup=get_admin_messages_keyboard(db_user.language)
+        reply_markup=get_admin_messages_keyboard(db_user.language),
+        parse_mode="HTML"  
     )
     await callback.answer()
 
@@ -60,7 +61,8 @@ async def show_broadcast_targets(
     await callback.message.edit_text(
         "🎯 <b>Выбор целевой аудитории</b>\n\n"
         "Выберите категорию пользователей для рассылки:",
-        reply_markup=get_broadcast_target_keyboard(db_user.language)
+        reply_markup=get_broadcast_target_keyboard(db_user.language),
+        parse_mode="HTML" 
     )
     await callback.answer()
 
@@ -118,7 +120,8 @@ async def show_messages_history(
     
     await callback.message.edit_text(
         text,
-        reply_markup=types.InlineKeyboardMarkup(inline_keyboard=keyboard)
+        reply_markup=types.InlineKeyboardMarkup(inline_keyboard=keyboard),
+        parse_mode="HTML"  
     )
     await callback.answer()
 
@@ -135,7 +138,7 @@ async def show_custom_broadcast(
     stats = await get_users_statistics(db)
     
     text = f"""
-🔍 <b>Рассылка по критериям</b>
+📝 <b>Рассылка по критериям</b>
 
 📊 <b>Доступные фильтры:</b>
 
@@ -158,7 +161,8 @@ async def show_custom_broadcast(
     
     await callback.message.edit_text(
         text,
-        reply_markup=get_custom_criteria_keyboard(db_user.language)
+        reply_markup=get_custom_criteria_keyboard(db_user.language),
+        parse_mode="HTML" 
     )
     await callback.answer()
 
@@ -196,7 +200,8 @@ async def select_custom_criteria(
         f"<i>Поддерживается HTML разметка</i>",
         reply_markup=types.InlineKeyboardMarkup(inline_keyboard=[
             [types.InlineKeyboardButton(text="❌ Отмена", callback_data="admin_messages")]
-        ])
+        ]),
+        parse_mode="HTML" 
     )
     
     await state.set_state(AdminStates.waiting_for_broadcast_message)
@@ -233,7 +238,8 @@ async def select_broadcast_target(
         f"<i>Поддерживается HTML разметка</i>",
         reply_markup=types.InlineKeyboardMarkup(inline_keyboard=[
             [types.InlineKeyboardButton(text="❌ Отмена", callback_data="admin_messages")]
-        ])
+        ]),
+        parse_mode="HTML" 
     )
     
     await state.set_state(AdminStates.waiting_for_broadcast_message)
@@ -284,7 +290,8 @@ async def process_broadcast_message(
     
     await message.answer(
         preview_text,
-        reply_markup=types.InlineKeyboardMarkup(inline_keyboard=keyboard)
+        reply_markup=types.InlineKeyboardMarkup(inline_keyboard=keyboard),
+        parse_mode="HTML"  
     )
     await state.set_state(AdminStates.confirming_broadcast)
 
@@ -304,7 +311,8 @@ async def confirm_broadcast(
     await callback.message.edit_text(
         "📨 Начинаю рассылку...\n\n"
         "⏳ Это может занять несколько минут.",
-        reply_markup=None
+        reply_markup=None,
+        parse_mode="HTML" 
     )
     
     if target.startswith('custom_'):
@@ -367,7 +375,8 @@ async def confirm_broadcast(
         result_text,
         reply_markup=types.InlineKeyboardMarkup(inline_keyboard=[
             [types.InlineKeyboardButton(text="📨 К рассылкам", callback_data="admin_messages")]
-        ])
+        ]),
+        parse_mode="HTML" 
     )
     
     await state.clear()
@@ -548,4 +557,4 @@ def register_handlers(dp: Dispatcher):
     dp.callback_query.register(show_custom_broadcast, F.data == "admin_msg_custom")
     dp.callback_query.register(select_custom_criteria, F.data.startswith("criteria_"))
     
-    dp.message.register(process_broadcast_message, AdminStates.waiting_for_broadcast_message)
+    dp.message.register(process_broadcast_message, AdminStates.waiting_for_broadcast_message)

app/handlers/admin/subscriptions.py

@@ -306,13 +306,13 @@ async def show_pricing_settings(
 """
     
     keyboard = [
-        [
-            types.InlineKeyboardButton(text="📅 Периоды", callback_data="admin_edit_period_prices"),
-            types.InlineKeyboardButton(text="📈 Трафик", callback_data="admin_edit_traffic_prices")
-        ],
-        [
-            types.InlineKeyboardButton(text="📱 Устройства", callback_data="admin_edit_device_price")
-        ],
+      #  [
+      #      types.InlineKeyboardButton(text="📅 Периоды", callback_data="admin_edit_period_prices"),
+      #      types.InlineKeyboardButton(text="📈 Трафик", callback_data="admin_edit_traffic_prices")
+      #  ],
+      #  [
+      #      types.InlineKeyboardButton(text="📱 Устройства", callback_data="admin_edit_device_price")
+      #  ],
         [
             types.InlineKeyboardButton(text="⬅️ Назад", callback_data="admin_subscriptions")
         ]
@@ -405,8 +405,7 @@ async def show_countries_management(
     
     keyboard = [
         [
-            types.InlineKeyboardButton(text="🔄 Обновить", callback_data="admin_subs_countries"),
-            types.InlineKeyboardButton(text="⚙️ API настройки", callback_data="admin_rw_api")
+            types.InlineKeyboardButton(text="🔄 Обновить", callback_data="admin_subs_countries")
         ],
         [
             types.InlineKeyboardButton(text="📊 Статистика нод", callback_data="admin_rw_nodes"),
@@ -495,4 +494,4 @@ def register_handlers(dp: Dispatcher):
     dp.callback_query.register(
         handle_subscriptions_pagination, 
         F.data.startswith("admin_subs_list_page_")
-    )
+    )

app/handlers/balance.py

@@ -412,7 +412,7 @@ async def process_yookassa_payment_amount(
             db=db,
             user_id=db_user.id,
             amount_kopeks=amount_kopeks,
-            description=f"Пополнение баланса VPN на {settings.format_price(amount_kopeks)}",
+            description=settings.get_balance_payment_description(amount_kopeks),
             receipt_email=None,
             receipt_phone=None,
             metadata={

app/handlers/subscription.py

@@ -198,7 +198,7 @@ async def get_subscription_cost(subscription, db: AsyncSession) -> int:
             )
         
         traffic_cost = TRAFFIC_PRICES.get(subscription.traffic_limit_gb, 0)
-        devices_cost = max(0, subscription.device_limit - 1) * settings.PRICE_PER_DEVICE
+        devices_cost = max(0, subscription.device_limit - settings.DEFAULT_DEVICE_LIMIT) * settings.PRICE_PER_DEVICE
         
         total_cost = base_cost + servers_cost + traffic_cost + devices_cost
         
@@ -328,7 +328,7 @@ async def start_subscription_purchase(
     initial_data = {
         'period_days': None,
         'countries': [],
-        'devices': 1,
+        'devices': settings.DEFAULT_DEVICE_LIMIT, 
         'total_price': 0
     }
     
@@ -349,6 +349,9 @@ async def handle_add_countries(
     db: AsyncSession,
     state: FSMContext
 ):
+    if not await _should_show_countries_management():
+        await callback.answer("ℹ️ Управление серверами недоступно - доступен только один сервер", show_alert=True)
+        return
     
     texts = get_texts(db_user.language)
     subscription = db_user.subscription
@@ -366,7 +369,7 @@ async def handle_add_countries(
             current_countries_names.append(country['name'])
     
     text = "🌍 <b>Управление странами подписки</b>\n\n"
-    text += f"📍 <b>Текущие страны ({len(current_countries)}):</b>\n"
+    text += f"📋 <b>Текущие страны ({len(current_countries)}):</b>\n"
     if current_countries_names:
         text += "\n".join(f"• {name}" for name in current_countries_names)
     else:
@@ -409,11 +412,11 @@ async def get_countries_price_by_uuids_fallback(country_uuids: List[str], db: As
                     total_price += price
                     prices_list.append(price)
                 else:
-                    default_price = 1000
+                    default_price = 0
                     total_price += default_price
                     prices_list.append(default_price)
             except Exception:
-                default_price = 1000
+                default_price = 0
                 total_price += default_price
                 prices_list.append(default_price)
         
@@ -421,7 +424,7 @@ async def get_countries_price_by_uuids_fallback(country_uuids: List[str], db: As
         
     except Exception as e:
         logger.error(f"Ошибка fallback функции: {e}")
-        default_prices = [1000] * len(country_uuids)
+        default_prices = [0] * len(country_uuids)
         return sum(default_prices), default_prices
 
 async def handle_manage_country(
@@ -1155,12 +1158,24 @@ async def select_period(
         )
         await state.set_state(SubscriptionStates.selecting_traffic)
     else:
-        countries = await _get_available_countries()
-        await callback.message.edit_text(
-            texts.SELECT_COUNTRIES,
-            reply_markup=get_countries_keyboard(countries, [], db_user.language)
-        )
-        await state.set_state(SubscriptionStates.selecting_countries)
+        if await _should_show_countries_management():
+            countries = await _get_available_countries()
+            await callback.message.edit_text(
+                texts.SELECT_COUNTRIES,
+                reply_markup=get_countries_keyboard(countries, [], db_user.language)
+            )
+            await state.set_state(SubscriptionStates.selecting_countries)
+        else:
+            countries = await _get_available_countries()
+            available_countries = [c for c in countries if c.get('is_available', True)]
+            data['countries'] = [available_countries[0]['uuid']] if available_countries else []
+            await state.set_data(data)
+            
+            await callback.message.edit_text(
+                texts.SELECT_DEVICES,
+                reply_markup=get_devices_keyboard(1, db_user.language)
+            )
+            await state.set_state(SubscriptionStates.selecting_devices)
     
     await callback.answer()
 
@@ -1237,7 +1252,6 @@ async def select_traffic(
     state: FSMContext,
     db_user: User
 ):
-    
     traffic_gb = int(callback.data.split('_')[1])
     texts = get_texts(db_user.language)
     
@@ -1246,14 +1260,25 @@ async def select_traffic(
     data['total_price'] += TRAFFIC_PRICES[traffic_gb]
     await state.set_data(data)
     
-    countries = await _get_available_countries()
+    if await _should_show_countries_management():
+        countries = await _get_available_countries()
+        await callback.message.edit_text(
+            texts.SELECT_COUNTRIES,
+            reply_markup=get_countries_keyboard(countries, [], db_user.language)
+        )
+        await state.set_state(SubscriptionStates.selecting_countries)
+    else:
+        countries = await _get_available_countries()
+        available_countries = [c for c in countries if c.get('is_available', True)]
+        data['countries'] = [available_countries[0]['uuid']] if available_countries else []
+        await state.set_data(data)
+        
+        await callback.message.edit_text(
+            texts.SELECT_DEVICES,
+            reply_markup=get_devices_keyboard(1, db_user.language)
+        )
+        await state.set_state(SubscriptionStates.selecting_devices)
     
-    await callback.message.edit_text(
-        texts.SELECT_COUNTRIES,
-        reply_markup=get_countries_keyboard(countries, [], db_user.language)
-    )
-    
-    await state.set_state(SubscriptionStates.selecting_countries)
     await callback.answer()
 
 
@@ -1344,7 +1369,7 @@ async def select_devices(
         if c['uuid'] in data['countries']
     )
     
-    devices_price = (devices - 1) * settings.PRICE_PER_DEVICE
+    devices_price = max(0, devices - settings.DEFAULT_DEVICE_LIMIT) * settings.PRICE_PER_DEVICE
     
     data['devices'] = devices
     data['total_price'] = base_price + countries_price + devices_price
@@ -1389,7 +1414,7 @@ async def devices_continue(
     else:
         traffic_price = TRAFFIC_PRICES.get(data['traffic_gb'], 0)
     
-    devices_price = (data['devices'] - 1) * settings.PRICE_PER_DEVICE
+    devices_price = max(0, data['devices'] - settings.DEFAULT_DEVICE_LIMIT) * settings.PRICE_PER_DEVICE
     total_price = base_price + traffic_price + countries_price + devices_price
     
     data['total_price'] = total_price
@@ -1449,7 +1474,7 @@ async def confirm_purchase(
             countries_price += country['price_kopeks']
             server_prices.append(country['price_kopeks'])
     
-    devices_price = (data['devices'] - 1) * settings.PRICE_PER_DEVICE
+    devices_price = max(0, data['devices'] - settings.DEFAULT_DEVICE_LIMIT) * settings.PRICE_PER_DEVICE
     
     if settings.is_traffic_fixed():
         traffic_price = TRAFFIC_PRICES.get(settings.get_fixed_traffic_limit(), 0)
@@ -1667,9 +1692,11 @@ async def handle_subscription_settings(
 Выберите что хотите изменить:
 """
     
+    show_countries = await _should_show_countries_management()
+    
     await callback.message.edit_text(
         settings_text,
-        reply_markup=get_subscription_settings_keyboard(db_user.language),
+        reply_markup=get_subscription_settings_keyboard(db_user.language, show_countries),
         parse_mode="HTML"
     )
     await callback.answer()
@@ -1858,7 +1885,7 @@ async def _get_available_countries():
                 countries.append({
                     "uuid": squad["uuid"],
                     "name": squad_name,
-                    "price_kopeks": 1000, 
+                    "price_kopeks": 0, 
                     "is_available": True
                 })
         
@@ -1989,6 +2016,15 @@ async def handle_add_country_to_subscription(
     
     await callback.answer()
 
+async def _should_show_countries_management() -> bool:
+    try:
+        countries = await _get_available_countries()
+        available_countries = [c for c in countries if c.get('is_available', True)]
+        return len(available_countries) > 1
+    except Exception as e:
+        logger.error(f"Ошибка проверки доступных серверов: {e}")
+        return True
+
 
 async def confirm_add_countries_to_subscription(
     callback: types.CallbackQuery,
@@ -2207,7 +2243,7 @@ async def handle_connect_subscription(
     subscription = db_user.subscription
     
     if not subscription or not subscription.subscription_url:
-        await callback.answer("❌ У вас нет активной подписки или ссылка еще генерируется", show_alert=True)
+        await callback.answer("⚠ У вас нет активной подписки или ссылка еще генерируется", show_alert=True)
         return
     
     connect_mode = settings.CONNECT_BUTTON_MODE
@@ -2216,13 +2252,10 @@ async def handle_connect_subscription(
         keyboard = InlineKeyboardMarkup(inline_keyboard=[
             [
                 InlineKeyboardButton(
-                    text="🔗 Открыть подписку", 
+                    text="🔗 Открыть подписку в мини-приложении", 
                     web_app=types.WebAppInfo(url=subscription.subscription_url)
                 )
             ],
-            [
-                InlineKeyboardButton(text="📋 Показать ссылку", callback_data="open_subscription_link")
-            ],
             [
                 InlineKeyboardButton(text="⬅️ Назад", callback_data="menu_subscription")
             ]
@@ -2230,9 +2263,9 @@ async def handle_connect_subscription(
         
         await callback.message.edit_text(
             f"""
-🔗 <b>Подключить подписку</b>
+📱 <b>Подключить подписку</b>
 
-📱 Нажмите кнопку ниже, чтобы открыть подписку в мини-приложении Telegram:
+🚀 Нажмите кнопку ниже, чтобы открыть подписку в мини-приложении Telegram:
             """,
             reply_markup=keyboard,
             parse_mode="HTML"
@@ -2240,7 +2273,7 @@ async def handle_connect_subscription(
         
     elif connect_mode == "miniapp_custom":
         if not settings.MINIAPP_CUSTOM_URL:
-            await callback.answer("❌ Кастомная ссылка для мини-приложения не настроена", show_alert=True)
+            await callback.answer("⚠ Кастомная ссылка для мини-приложения не настроена", show_alert=True)
             return
             
         keyboard = InlineKeyboardMarkup(inline_keyboard=[
@@ -2250,9 +2283,6 @@ async def handle_connect_subscription(
                     web_app=types.WebAppInfo(url=settings.MINIAPP_CUSTOM_URL)
                 )
             ],
-            [
-                InlineKeyboardButton(text="📋 Показать ссылку подписки", callback_data="open_subscription_link")
-            ],
             [
                 InlineKeyboardButton(text="⬅️ Назад", callback_data="menu_subscription")
             ]
@@ -2263,9 +2293,6 @@ async def handle_connect_subscription(
 🚀 <b>Подключить подписку</b>
 
 📱 Нажмите кнопку ниже, чтобы открыть приложение:
-
-📋 <b>Ссылка подписки:</b>
-<code>{subscription.subscription_url}</code>
             """,
             reply_markup=keyboard,
             parse_mode="HTML"

app/keyboards/inline.py

@@ -1,4 +1,5 @@
 from typing import List, Optional
+from aiogram import types
 from aiogram.types import InlineKeyboardMarkup, InlineKeyboardButton
 
 from app.config import settings, PERIOD_PRICES, TRAFFIC_PRICES
@@ -107,15 +108,28 @@ def get_subscription_keyboard(
             connect_mode = settings.CONNECT_BUTTON_MODE
             
             if connect_mode == "miniapp_subscription":
-                button_text = "🚀 Открыть в мини-приложении"
+                keyboard.append([
+                    InlineKeyboardButton(
+                        text="🚀 Открыть в мини-приложении",
+                        web_app=types.WebAppInfo(url=subscription.subscription_url)
+                    )
+                ])
             elif connect_mode == "miniapp_custom":
-                button_text = "🚀 Открыть приложение"
+                if settings.MINIAPP_CUSTOM_URL:
+                    keyboard.append([
+                        InlineKeyboardButton(
+                            text="🚀 Открыть приложение",
+                            web_app=types.WebAppInfo(url=settings.MINIAPP_CUSTOM_URL)
+                        )
+                    ])
+                else:
+                    keyboard.append([
+                        InlineKeyboardButton(text="🔗 Подключиться", callback_data="subscription_connect")
+                    ])
             else:
-                button_text = "🔗 Подключиться"
-                
-            keyboard.append([
-                InlineKeyboardButton(text=button_text, callback_data="subscription_connect")
-            ])
+                keyboard.append([
+                    InlineKeyboardButton(text="🔗 Подключиться", callback_data="subscription_connect")
+                ])
         
         if not is_trial and subscription and subscription.days_left <= 3:
             keyboard.append([
@@ -142,27 +156,31 @@ def get_subscription_keyboard(
     
     return InlineKeyboardMarkup(inline_keyboard=keyboard)
 
-def get_subscription_settings_keyboard(language: str = "ru") -> InlineKeyboardMarkup:
+def get_subscription_settings_keyboard(language: str = "ru", show_countries_management: bool = True) -> InlineKeyboardMarkup:
     from app.config import settings
     
     texts = get_texts(language)
-    keyboard = [
-        [
+    keyboard = []
+    
+    if show_countries_management:
+        keyboard.append([
             InlineKeyboardButton(text="🌍 Добавить страны", callback_data="subscription_add_countries")
-        ],
+        ])
+    
+    keyboard.extend([
         [
             InlineKeyboardButton(text="📱 Добавить устройства", callback_data="subscription_add_devices")
         ],
         [
             InlineKeyboardButton(text="🔄 Сбросить устройства", callback_data="subscription_reset_devices")
         ]
-    ]
+    ])
     
     if settings.is_traffic_selectable():
-        keyboard.insert(1, [
+        keyboard.insert(-2, [
             InlineKeyboardButton(text="📈 Добавить трафик", callback_data="subscription_add_traffic")
         ])
-        keyboard.insert(2, [
+        keyboard.insert(-2, [
             InlineKeyboardButton(text="🔄 Сбросить трафик", callback_data="subscription_reset_traffic")
         ])
     
@@ -287,14 +305,19 @@ def get_devices_keyboard(current: int, language: str = "ru") -> InlineKeyboardMa
     texts = get_texts(language)
     keyboard = []
     
-    for devices in range(1, 6): 
-        price = (devices - 1) * settings.PRICE_PER_DEVICE
-        price_text = f" (+{texts.format_price(price)})" if price > 0 else ""
+    start_devices = settings.DEFAULT_DEVICE_LIMIT
+    end_devices = max(start_devices + 3, 6) 
+    
+    for devices in range(start_devices, end_devices): 
+        price = max(0, devices - settings.DEFAULT_DEVICE_LIMIT) * settings.PRICE_PER_DEVICE
+        price_text = f" (+{texts.format_price(price)})" if price > 0 else " (включено)"
         emoji = "✅" if devices == current else "⚪"
         
+        device_word = _get_device_declension(devices)
+        
         keyboard.append([
             InlineKeyboardButton(
-                text=f"{emoji} {devices} устройство{_get_device_suffix(devices)}{price_text}",
+                text=f"{emoji} {devices} {device_word}{price_text}",
                 callback_data=f"devices_{devices}"
             )
         ])
@@ -306,6 +329,13 @@ def get_devices_keyboard(current: int, language: str = "ru") -> InlineKeyboardMa
     
     return InlineKeyboardMarkup(inline_keyboard=keyboard)
 
+def _get_device_declension(count: int) -> str:
+    if count % 10 == 1 and count % 100 != 11:
+        return "устройство"
+    elif count % 10 in [2, 3, 4] and count % 100 not in [12, 13, 14]:
+        return "устройства"
+    else:
+        return "устройств"
 
 def get_subscription_confirm_keyboard(language: str = "ru") -> InlineKeyboardMarkup:
     texts = get_texts(language)
@@ -500,16 +530,6 @@ def get_pagination_keyboard(
     
     return keyboard
 
-
-def _get_device_suffix(count: int) -> str:
-    if count == 1:
-        return ""
-    elif 2 <= count <= 4:
-        return "а"
-    else:
-        return ""
-
-
 def get_confirmation_keyboard(
     confirm_data: str,
     cancel_data: str = "cancel",
@@ -630,9 +650,11 @@ def get_add_devices_keyboard(current_devices: int, language: str = "ru") -> Inli
         price = add_count * settings.PRICE_PER_DEVICE
         total_devices = current_devices + add_count
         
+        add_device_word = _get_device_declension(add_count)
+        
         keyboard.append([
             InlineKeyboardButton(
-                text=f"📱 +{add_count} устройство{_get_device_suffix(add_count)} (итого: {total_devices}) - {settings.format_price(price)}",
+                text=f"📱 +{add_count} {add_device_word} (итого: {total_devices}) - {settings.format_price(price)}",
                 callback_data=f"add_devices_{add_count}"
             )
         ])

app/services/maintenance_service.py

@@ -28,8 +28,15 @@ class MaintenanceService:
         self._status = MaintenanceStatus(is_active=False)
         self._check_task: Optional[asyncio.Task] = None
         self._is_checking = False
-        self._max_consecutive_failures = 3 
+        self._max_consecutive_failures = 3
+        self._bot = None 
+        self._last_notification_sent = None 
         
+    def set_bot(self, bot):
+        """Устанавливает ссылку на бота для отправки уведомлений"""
+        self._bot = bot
+        logger.info("Бот установлен для maintenance_service")
+    
     @property
     def status(self) -> MaintenanceStatus:
         return self._status
@@ -51,6 +58,51 @@ class MaintenanceService:
         else:
             return settings.get_maintenance_message()
     
+    async def _notify_admins(self, message: str, alert_type: str = "info"):
+        """Отправка уведомлений администраторам"""
+        if not self._bot:
+            logger.warning("Бот не установлен, уведомления не могут быть отправлены")
+            return
+        
+        cache_key = f"maintenance_notification_{alert_type}"
+        if await cache.get(cache_key):
+            return
+        
+        admin_ids = settings.get_admin_ids()
+        if not admin_ids:
+            logger.warning("Список администраторов пуст")
+            return
+        
+        emoji_map = {
+            "error": "🚨",
+            "warning": "⚠️", 
+            "success": "✅",
+            "info": "ℹ️"
+        }
+        emoji = emoji_map.get(alert_type, "ℹ️")
+        
+        formatted_message = f"{emoji} <b>Maintenance Service</b>\n\n{message}"
+        
+        success_count = 0
+        for admin_id in admin_ids:
+            try:
+                await self._bot.send_message(
+                    chat_id=admin_id,
+                    text=formatted_message,
+                    parse_mode="HTML"
+                )
+                success_count += 1
+                await asyncio.sleep(0.1) 
+                
+            except Exception as e:
+                logger.error(f"Ошибка отправки уведомления админу {admin_id}: {e}")
+        
+        if success_count > 0:
+            logger.info(f"Уведомление отправлено {success_count} администраторам")
+            await cache.set(cache_key, True, expire=300)
+        else:
+            logger.error("Не удалось отправить уведомления ни одному администратору")
+    
     async def enable_maintenance(self, reason: Optional[str] = None, auto: bool = False) -> bool:
         try:
             if self._status.is_active:
@@ -64,6 +116,18 @@ class MaintenanceService:
             
             await self._save_status_to_cache()
             
+            notification_msg = f"""
+Режим технических работ ВКЛЮЧЕН
+
+📋 <b>Причина:</b> {self._status.reason}
+🤖 <b>Автоматически:</b> {'Да' if auto else 'Нет'}
+🕐 <b>Время:</b> {self._status.enabled_at.strftime('%d.%m.%Y %H:%M:%S')}
+
+Обычные пользователи временно не смогут использовать бота.
+"""
+            
+            await self._notify_admins(notification_msg, "warning" if auto else "info")
+            
             logger.warning(f"🔧 Режим техработ ВКЛЮЧЕН. Причина: {self._status.reason}")
             return True
             
@@ -77,6 +141,11 @@ class MaintenanceService:
                 logger.info("Режим техработ уже выключен")
                 return True
             
+            was_auto = self._status.auto_enabled
+            duration = None
+            if self._status.enabled_at:
+                duration = datetime.utcnow() - self._status.enabled_at
+            
             self._status.is_active = False
             self._status.enabled_at = None
             self._status.reason = None
@@ -85,6 +154,27 @@ class MaintenanceService:
             
             await self._save_status_to_cache()
             
+            duration_str = ""
+            if duration:
+                hours = int(duration.total_seconds() // 3600)
+                minutes = int((duration.total_seconds() % 3600) // 60)
+                if hours > 0:
+                    duration_str = f"\n⏱️ <b>Длительность:</b> {hours}ч {minutes}мин"
+                else:
+                    duration_str = f"\n⏱️ <b>Длительность:</b> {minutes}мин"
+            
+            notification_msg = f"""
+Режим технических работ ВЫКЛЮЧЕН
+
+🤖 <b>Автоматически:</b> {'Да' if was_auto else 'Нет'}
+🕐 <b>Время:</b> {datetime.utcnow().strftime('%d.%m.%Y %H:%M:%S')}
+{duration_str}
+
+Сервис снова доступен для пользователей.
+"""
+            
+            await self._notify_admins(notification_msg, "success")
+            
             logger.info("✅ Режим техработ ВЫКЛЮЧЕН")
             return True
             
@@ -102,6 +192,17 @@ class MaintenanceService:
             
             self._check_task = asyncio.create_task(self._monitoring_loop())
             logger.info(f"🔄 Запущен мониторинг API RemnaWave (интервал: {settings.get_maintenance_check_interval()}с)")
+            
+            await self._notify_admins(f"""
+Мониторинг технических работ запущен
+
+🔄 <b>Интервал проверки:</b> {settings.get_maintenance_check_interval()} секунд
+🤖 <b>Автовключение:</b> {'Включено' if settings.is_maintenance_auto_enable() else 'Отключено'}
+🎯 <b>Порог ошибок:</b> {self._max_consecutive_failures}
+
+Система будет следить за доступностью API.
+""", "info")
+            
             return True
             
         except Exception as e:
@@ -117,7 +218,8 @@ class MaintenanceService:
                 except asyncio.CancelledError:
                     pass
             
-            logger.info("⏹️ Мониторинг API остановлен")
+            await self._notify_admins("Мониторинг технических работ остановлен", "info")
+            logger.info("ℹ️ Мониторинг API остановлен")
             return True
             
         except Exception as e:
@@ -138,6 +240,18 @@ class MaintenanceService:
                 is_connected = await test_api_connection(api)
                 
                 if is_connected:
+                    # API восстановилось
+                    if not self._status.api_status:
+                        await self._notify_admins(f"""
+API RemnaWave восстановлено!
+
+✅ <b>Статус:</b> Доступно
+🕐 <b>Время восстановления:</b> {self._status.last_check.strftime('%H:%M:%S')}
+🔄 <b>Неудачных попыток было:</b> {self._status.consecutive_failures}
+
+API снова отвечает на запросы.
+""", "success")
+                    
                     self._status.api_status = True
                     self._status.consecutive_failures = 0
                     
@@ -147,9 +261,21 @@ class MaintenanceService:
                     
                     return True
                 else:
+                    was_available = self._status.api_status
                     self._status.api_status = False
                     self._status.consecutive_failures += 1
                     
+                    if was_available:
+                        await self._notify_admins(f"""
+API RemnaWave недоступно!
+
+❌ <b>Статус:</b> Недоступно
+🕐 <b>Время обнаружения:</b> {self._status.last_check.strftime('%H:%M:%S')}
+🔄 <b>Попытка:</b> {self._status.consecutive_failures}
+
+Началась серия неудачных проверок API.
+""", "error")
+                    
                     if (self._status.consecutive_failures >= self._max_consecutive_failures and
                         not self._status.is_active and
                         settings.is_maintenance_auto_enable()):
@@ -163,6 +289,17 @@ class MaintenanceService:
                     
         except Exception as e:
             logger.error(f"Ошибка проверки API: {e}")
+            
+            if self._status.api_status:
+                await self._notify_admins(f"""
+Ошибка при проверке API RemnaWave
+
+❌ <b>Ошибка:</b> {str(e)}
+🕐 <b>Время:</b> {datetime.utcnow().strftime('%H:%M:%S')}
+
+Не удалось выполнить проверку доступности API.
+""", "error")
+            
             self._status.api_status = False
             self._status.consecutive_failures += 1
             return False
@@ -216,7 +353,7 @@ class MaintenanceService:
             if status_data.get("last_check"):
                 self._status.last_check = datetime.fromisoformat(status_data["last_check"])
             
-            logger.info(f"📥 Состояние техработ загружено из кеша: активен={self._status.is_active}")
+            logger.info(f"🔥 Состояние техработ загружено из кеша: активен={self._status.is_active}")
             
         except Exception as e:
             logger.error(f"Ошибка загрузки состояния из кеша: {e}")
@@ -232,7 +369,8 @@ class MaintenanceService:
             "consecutive_failures": self._status.consecutive_failures,
             "monitoring_active": self._check_task is not None and not self._check_task.done(),
             "auto_enable_configured": settings.is_maintenance_auto_enable(),
-            "check_interval": settings.get_maintenance_check_interval()
+            "check_interval": settings.get_maintenance_check_interval(),
+            "bot_connected": self._bot is not None
         }
     
     async def force_api_check(self) -> Dict[str, Any]:

app/services/remnawave_service.py

@@ -25,7 +25,8 @@ class RemnaWaveService:
     def __init__(self):
         self.api = RemnaWaveAPI(
             base_url=settings.REMNAWAVE_API_URL,
-            api_key=settings.REMNAWAVE_API_KEY
+            api_key=settings.REMNAWAVE_API_KEY,
+            secret_key=settings.REMNAWAVE_SECRET_KEY
         )
 
     def _parse_remnawave_date(self, date_str: str) -> datetime:

app/services/subscription_service.py

@@ -249,7 +249,7 @@ class SubscriptionService:
                 server_prices.append(0)
                 logger.warning(f"⚠️ Сервер ID {server_id} недоступен")
 
-        devices_price = max(0, devices - 1) * settings.PRICE_PER_DEVICE
+        devices_price = max(0, devices - settings.DEFAULT_DEVICE_LIMIT) * settings.PRICE_PER_DEVICE
         
         total_price = base_price + traffic_price + total_servers_price + devices_price
         
@@ -277,7 +277,7 @@ class SubscriptionService:
                 subscription.connected_squads, db
             )
             
-            devices_price = max(0, subscription.device_limit - 1) * settings.PRICE_PER_DEVICE
+            devices_price = max(0, subscription.device_limit - settings.DEFAULT_DEVICE_LIMIT) * settings.PRICE_PER_DEVICE
             
             traffic_price = TRAFFIC_PRICES.get(subscription.traffic_limit_gb, 0)
             
@@ -364,7 +364,7 @@ class SubscriptionService:
                     prices_list.append(price)
                     logger.debug(f"🏷️ Страна {server.display_name}: {price/100}₽")
                 else:
-                    default_price = 1000  
+                    default_price = 0  
                     total_price += default_price
                     prices_list.append(default_price)
                     logger.warning(f"⚠️ Сервер {country_uuid} недоступен, используем базовую цену: {default_price/100}₽")
@@ -374,7 +374,7 @@ class SubscriptionService:
             
         except Exception as e:
             logger.error(f"Ошибка получения цен стран: {e}")
-            default_prices = [1000] * len(country_uuids)
+            default_prices = [0] * len(country_uuids)
             return sum(default_prices), default_prices
     
     async def _get_countries_price(self, country_uuids: List[str], db: AsyncSession) -> int:

docker-compose.yml

@@ -0,0 +1,77 @@
+services:
+  postgres:
+    image: postgres:15-alpine
+    container_name: remnawave_bot_db
+    restart: unless-stopped
+    environment:
+      POSTGRES_DB: ${POSTGRES_DB:-remnawave_bot}
+      POSTGRES_USER: ${POSTGRES_USER:-remnawave_user}
+      POSTGRES_PASSWORD: ${POSTGRES_PASSWORD:-secure_password_123}
+      POSTGRES_INITDB_ARGS: "--encoding=UTF8"
+    volumes:
+      - postgres_data:/var/lib/postgresql/data
+    networks:
+      - bot_network
+    healthcheck:
+      test: ["CMD-SHELL", "pg_isready -U ${POSTGRES_USER:-remnawave_user} -d ${POSTGRES_DB:-remnawave_bot}"]
+      interval: 30s
+      timeout: 5s
+      retries: 5
+      start_period: 30s
+
+  redis:
+    image: redis:7-alpine
+    container_name: remnawave_bot_redis
+    restart: unless-stopped
+    command: redis-server --appendonly yes
+    volumes:
+      - redis_data:/data
+    networks:
+      - bot_network
+    healthcheck:
+      test: ["CMD", "redis-cli", "ping"]
+      interval: 30s
+      timeout: 10s
+      retries: 3
+
+  bot:
+    image: fr1ngg/remnawave-bedolaga-telegram-bot:latest
+    container_name: remnawave_bot
+    restart: unless-stopped
+    depends_on:
+      postgres:
+        condition: service_healthy
+      redis:
+        condition: service_healthy
+    env_file:
+      - .env
+    environment:
+      DATABASE_URL: postgresql+asyncpg://${POSTGRES_USER:-remnawave_user}:${POSTGRES_PASSWORD:-secure_password_123}@postgres:5432/${POSTGRES_DB:-remnawave_bot}
+      REDIS_URL: redis://redis:6379/0
+    volumes:
+      - ./logs:/app/logs:rw
+      - ./data:/app/data:rw
+      - /etc/timezone:/etc/timezone:ro
+      - /etc/localtime:/etc/localtime:ro
+    ports:
+      - "${TRIBUTE_WEBHOOK_PORT:-8081}:8081"
+      - "${YOOKASSA_WEBHOOK_PORT:-8082}:8082"
+    networks:
+      - bot_network
+    user: "1000:1000"
+    command: >
+      bash -c "
+        mkdir -p /app/logs /app/data &&
+        python main.py
+      "
+
+volumes:
+  postgres_data:
+  redis_data:
+
+networks:
+  bot_network:
+    driver: bridge
+    ipam:
+      config:
+        - subnet: 172.20.0.0/16

main.py

@@ -77,6 +77,8 @@ async def main():
         bot, dp = await setup_bot()
         
         monitoring_service.bot = bot
+        maintenance_service.set_bot(bot) 
+        logger.info("🔗 Бот подключен к сервисам мониторинга и техработ")
         
         payment_service = PaymentService(bot)
         
@@ -95,11 +97,16 @@ async def main():
         else:
             logger.info("ℹ️ YooKassa отключена, webhook сервер не запускается")
         
-        logger.info("🔍 Запуск службы мониторинга...")
+        logger.info("📊 Запуск службы мониторинга...")
         monitoring_task = asyncio.create_task(monitoring_service.start_monitoring())
         
-        logger.info("🔧 Запуск службы техработ...")
-        maintenance_task = asyncio.create_task(maintenance_service.start_monitoring())
+        logger.info("🔧 Проверка службы техработ...")
+        if not maintenance_service._check_task or maintenance_service._check_task.done():
+            logger.info("🔧 Запуск службы техработ...")
+            maintenance_task = asyncio.create_task(maintenance_service.start_monitoring())
+        else:
+            logger.info("🔧 Служба техработ уже запущена")
+            maintenance_task = None
         
         logger.info("🔄 Запуск polling...")
         polling_task = asyncio.create_task(dp.start_polling(bot, skip_updates=True))
@@ -131,7 +138,7 @@ async def main():
                         logger.error(f"Служба мониторинга завершилась с ошибкой: {exception}")
                         monitoring_task = asyncio.create_task(monitoring_service.start_monitoring())
                         
-                if maintenance_task.done():
+                if maintenance_task and maintenance_task.done():
                     exception = maintenance_task.exception()
                     if exception:
                         logger.error(f"Служба техработ завершилась с ошибкой: {exception}")
@@ -154,7 +161,7 @@ async def main():
         logger.info("🛑 Начинается корректное завершение работы...")
         
         if yookassa_server_task and not yookassa_server_task.done():
-            logger.info("⏹️ Остановка YooKassa webhook сервера...")
+            logger.info("ℹ️ Остановка YooKassa webhook сервера...")
             yookassa_server_task.cancel()
             try:
                 await yookassa_server_task
@@ -162,7 +169,7 @@ async def main():
                 pass
         
         if monitoring_task and not monitoring_task.done():
-            logger.info("⏹️ Остановка службы мониторинга...")
+            logger.info("ℹ️ Остановка службы мониторинга...")
             monitoring_service.stop_monitoring()
             monitoring_task.cancel()
             try:
@@ -171,7 +178,7 @@ async def main():
                 pass
         
         if maintenance_task and not maintenance_task.done():
-            logger.info("⏹️ Остановка службы техработ...")
+            logger.info("ℹ️ Остановка службы техработ...")
             await maintenance_service.stop_monitoring()
             maintenance_task.cancel()
             try:
@@ -180,7 +187,7 @@ async def main():
                 pass
         
         if polling_task and not polling_task.done():
-            logger.info("⏹️ Остановка polling...")
+            logger.info("ℹ️ Остановка polling...")
             polling_task.cancel()
             try:
                 await polling_task
@@ -188,7 +195,7 @@ async def main():
                 pass
         
         if webhook_server:
-            logger.info("⏹️ Остановка Tribute webhook сервера...")
+            logger.info("ℹ️ Остановка Tribute webhook сервера...")
             await webhook_server.stop()
         
         if 'bot' in locals():