Update README.md

Update docker-compose.yml
2025-09-02 00:34:13 +03:00 · 2025-09-02 00:33:03 +03:00 · 2025-09-02 00:30:33 +03:00 · 2025-09-02 00:16:07 +03:00 · 2025-09-02 00:14:45 +03:00 · 2025-09-01 23:44:56 +03:00
18 changed files with 1626 additions and 1165 deletions
@@ -1,113 +1,112 @@
-# TELEGRAM BOT CONFIGURATION
+# ===============================================
+# 🤖 REMNAWAVE BEDOLAGA BOT CONFIGURATION
+# ===============================================
+
+# ===== TELEGRAM BOT =====
 BOT_TOKEN=
 ADMIN_IDS=
-SUPPORT_USERNAME=
+SUPPORT_USERNAME=@support

-# DATABASE CONFIGURATION
-DATABASE_URL=sqlite+aiosqlite:///./bot.db
-REDIS_URL=redis://localhost:6379/0
+# ===== DATABASE =====
+# Для Docker используйте PostgreSQL:
+DATABASE_URL=postgresql+asyncpg://remnawave_user:secure_password_123@postgres:5432/remnawave_bot
+# Для локального запуска без Docker используйте SQLite: sqlite+aiosqlite:///./bot.db 
+# DATABASE_URL=postgresql+asyncpg://remnawave_user:secure_password_123@postgres:5432/remnawave_bot

-# REMNAWAVE API CONFIGURATION
+REDIS_URL=redis://redis:6379/0
+
+# Пароли для Docker (PostgreSQL/Redis)
+POSTGRES_DB=remnawave_bot
+POSTGRES_USER=remnawave_user
+POSTGRES_PASSWORD=secure_password_123
+
+# ===== REMNAWAVE API =====
 REMNAWAVE_API_URL=
 REMNAWAVE_API_KEY=

-# === NEW: Traffic Selection Mode Settings ===
+# ===== ТРИАЛ ПОДПИСКА =====
+TRIAL_DURATION_DAYS=3
+TRIAL_TRAFFIC_LIMIT_GB=10
+TRIAL_DEVICE_LIMIT=1
+TRIAL_SQUAD_UUID=
+DEFAULT_TRAFFIC_RESET_STRATEGY=MONTH
+DEFAULT_TRAFFIC_LIMIT_GB=100
+DEFAULT_DEVICE_LIMIT=1
+
+# ===== НАСТРОЙКИ ТРАФИКА =====
 # Режим выбора трафика:
 # "selectable" - пользователи выбирают пакеты трафика (по умолчанию)
-# "fixed" - фиксированный лимит трафика для всех подписок, доступно 5/10/25/50/100/250/0 (0 безлимит) гб 
+# "fixed" - фиксированный лимит трафика для всех подписок
 TRAFFIC_SELECTION_MODE=selectable

 # Фиксированный лимит трафика в ГБ (используется только в режиме "fixed")
 # 0 = безлимит
-# для "fixed" обязательно должы быть проставлены цены на пакеты 5/10/25/50/100/250/0 можно постать 0 руб - будет беслпатно
-FIXED_TRAFFIC_LIMIT_GB=0
+FIXED_TRAFFIC_LIMIT_GB=100

-# TRIAL SUBSCRIPTION SETTINGS
-TRIAL_DURATION_DAYS=3
-TRIAL_TRAFFIC_LIMIT_GB=10
-TRIAL_DEVICE_LIMIT=2
-TRIAL_SQUAD_UUID=
-DEFAULT_TRAFFIC_RESET_STRATEGY=MONTH
-
-# === УПРАВЛЕНИЕ ПЕРИОДАМИ ПОДПИСКИ ===
+# ===== ПЕРИОДЫ ПОДПИСКИ =====
 # Доступные периоды подписки (через запятую)
 # Возможные значения: 14,30,60,90,180,360
-AVAILABLE_SUBSCRIPTION_PERIODS=14,30,60,90,180,360
+AVAILABLE_SUBSCRIPTION_PERIODS=30,90,180
 AVAILABLE_RENEWAL_PERIODS=30,90,180

-# SUBSCRIPTION PRICING (в копейках для точности)
-BASE_SUBSCRIPTION_PRICE=50000
+# ===== ЦЕНЫ (в копейках) =====
+BASE_SUBSCRIPTION_PRICE=0

-PRICE_14_DAYS=5000
-PRICE_30_DAYS=9900  
-PRICE_60_DAYS=18900
-PRICE_90_DAYS=26900
-PRICE_180_DAYS=49900
-PRICE_360_DAYS=89900
+# Цены за периоды
+PRICE_14_DAYS=7000
+PRICE_30_DAYS=9900
+PRICE_60_DAYS=25900
+PRICE_90_DAYS=36900
+PRICE_180_DAYS=69900
+PRICE_360_DAYS=109900

-PRICE_TRAFFIC_5GB=2000
-PRICE_TRAFFIC_10GB=4000
-PRICE_TRAFFIC_25GB=6000
-PRICE_TRAFFIC_50GB=10000
-PRICE_TRAFFIC_100GB=15000
-PRICE_TRAFFIC_250GB=20000
-PRICE_TRAFFIC_UNLIMITED=25000
+# Цены за трафик
+PRICE_TRAFFIC_5GB=1000
+PRICE_TRAFFIC_10GB=2000
+PRICE_TRAFFIC_25GB=3000
+PRICE_TRAFFIC_50GB=4000
+PRICE_TRAFFIC_100GB=6000
+PRICE_TRAFFIC_250GB=10000
+PRICE_TRAFFIC_UNLIMITED=15000

+# Цена за дополнительное устройство
 PRICE_PER_DEVICE=5000

-# REFERRAL SYSTEM SETTINGS
-REFERRAL_REGISTRATION_REWARD=5000
+# ===== РЕФЕРАЛЬНАЯ СИСТЕМА =====
+REFERRAL_REGISTRATION_REWARD=10000
 REFERRED_USER_REWARD=10000
 REFERRAL_COMMISSION_PERCENT=25

-# Режим работы кнопки "Подключиться"
-# guide - открывает гайд подключения (режим 1)
-# miniapp_subscription - открывает ссылку подписки в мини-приложении (режим 2)
-# miniapp_custom - открывает заданную ссылку в мини-приложении (режим 3)
-CONNECT_BUTTON_MODE=miniapp_subscription
-# URL для режима miniapp_custom (обязателен при CONNECT_BUTTON_MODE=miniapp_custom)
-# MINIAPP_CUSTOM_URL=
-
-# AUTO-PAYMENT SETTINGS
+# ===== АВТОПРОДЛЕНИЕ =====
 AUTOPAY_WARNING_DAYS=3,1
+DEFAULT_AUTOPAY_DAYS_BEFORE=3
+MIN_BALANCE_FOR_AUTOPAY_KOPEKS=10000

-# MONITORING SETTINGS
-MONITORING_INTERVAL=60
-INACTIVE_USER_DELETE_MONTHS=3
+# ===== ПЛАТЕЖНЫЕ СИСТЕМЫ =====

-TRIAL_WARNING_HOURS=2
-ENABLE_NOTIFICATIONS=true
-NOTIFICATION_RETRY_ATTEMPTS=3
-MONITORING_LOGS_RETENTION_DAYS=30
-
-# PAYMENT SYSTEMS
+# Telegram Stars (работает автоматически)
 TELEGRAM_STARS_ENABLED=true
+
+# Tribute (https://tribute.app)
 TRIBUTE_ENABLED=false
 TRIBUTE_API_KEY=
 TRIBUTE_WEBHOOK_SECRET=your_webhook_secret
-TRIBUTE_DONATE_LINK=https://t.me/tribute/app?startapp=XXXX
+TRIBUTE_DONATE_LINK=
 TRIBUTE_WEBHOOK_PATH=/tribute-webhook
 TRIBUTE_WEBHOOK_PORT=8081

-# === НОВЫЕ НАСТРОЙКИ YOOKASSA ===
-# Включение/выключение YooKassa
+# YooKassa (https://yookassa.ru)
 YOOKASSA_ENABLED=false
-
-# Основные настройки YooKassa (получить в личном кабинете)
-YOOKASSA_SHOP_ID=your_shop_id_here
-YOOKASSA_SECRET_KEY=your_secret_key_here
-
-# URL для возврата после оплаты (необязательно, по умолчанию t.me/your_bot)
-YOOKASSA_RETURN_URL=https://yourdomain.com/payment-success
-
-# Email по умолчанию для чеков (если пользователь не указал свой)
+YOOKASSA_SHOP_ID=
+YOOKASSA_SECRET_KEY=
+YOOKASSA_RETURN_URL=
 YOOKASSA_DEFAULT_RECEIPT_EMAIL=receipts@yourdomain.com

 # Настройки чеков для налоговой
 YOOKASSA_VAT_CODE=1
 # Коды НДС:
 # 1 - НДС не облагается
-# 2 - НДС 0%  
+# 2 - НДС 0%
 # 3 - НДС 10%
 # 4 - НДС 20%
 # 5 - НДС 10/110
@@ -116,7 +115,7 @@ YOOKASSA_VAT_CODE=1
 YOOKASSA_PAYMENT_MODE=full_payment
 # Способы расчета:
 # full_payment - полная оплата
-# partial_payment - частичная оплата  
+# partial_payment - частичная оплата
 # advance - аванс
 # full_prepayment - полная предоплата
 # partial_prepayment - частичная предоплата
@@ -126,7 +125,7 @@ YOOKASSA_PAYMENT_MODE=full_payment
 YOOKASSA_PAYMENT_SUBJECT=service
 # Предметы расчета:
 # commodity - товар
-# excise - подакцизный товар  
+# excise - подакцизный товар
 # job - работа
 # service - услуга
 # gambling_bet - ставка в азартной игре
@@ -139,21 +138,63 @@ YOOKASSA_PAYMENT_SUBJECT=service
 # composite - составной предмет расчета
 # another - другое

-# Webhook для получения уведомлений от YooKassa
+# Webhook настройки
 YOOKASSA_WEBHOOK_PATH=/yookassa-webhook
 YOOKASSA_WEBHOOK_PORT=8082
-YOOKASSA_WEBHOOK_SECRET=ваш_секретный_ключ_для_webhook
+YOOKASSA_WEBHOOK_SECRET=your_webhook_secret

-WEBHOOK_URL=https://example.com
+# ===== НАСТРОЙКИ ОПИСАНИЙ ПЛАТЕЖЕЙ =====
+# Эти настройки позволяют изменить описания платежей, 
+# чтобы избежать блокировок платежных систем
+PAYMENT_SERVICE_NAME=Интернет-сервис
+PAYMENT_BALANCE_DESCRIPTION=Пополнение баланса
+PAYMENT_SUBSCRIPTION_DESCRIPTION=Оплата подписки
+PAYMENT_BALANCE_TEMPLATE={service_name} - {description}
+PAYMENT_SUBSCRIPTION_TEMPLATE={service_name} - {description}
+
+# ===== ИНТЕРФЕЙС И UX =====
+
+# Режим работы кнопки "Подключиться"
+# guide - открывает гайд подключения (режим 1)
+# miniapp_subscription - открывает ссылку подписки в мини-приложении (режим 2)
+# miniapp_custom - открывает заданную ссылку в мини-приложении (режим 3)
+CONNECT_BUTTON_MODE=guide
+
+# URL для режима miniapp_custom (обязателен при CONNECT_BUTTON_MODE=miniapp_custom)
+MINIAPP_CUSTOM_URL=
+
+# ===== МОНИТОРИНГ И УВЕДОМЛЕНИЯ =====
+MONITORING_INTERVAL=60
+INACTIVE_USER_DELETE_MONTHS=3
+
+# Уведомления
+TRIAL_WARNING_HOURS=2
+ENABLE_NOTIFICATIONS=true
+NOTIFICATION_RETRY_ATTEMPTS=3
+MONITORING_LOGS_RETENTION_DAYS=30
+NOTIFICATION_CACHE_HOURS=24
+
+# ===== РЕЖИМ ТЕХНИЧЕСКИХ РАБОТ =====
+MAINTENANCE_MODE=false
+MAINTENANCE_CHECK_INTERVAL=30
+MAINTENANCE_AUTO_ENABLE=true
+MAINTENANCE_MESSAGE=Ведутся технические работы. Сервис временно недоступен. Попробуйте позже.
+
+# ===== ЛОКАЛИЗАЦИЯ =====
+DEFAULT_LANGUAGE=ru
+AVAILABLE_LANGUAGES=ru,en
+
+# ===== ЛОГИРОВАНИЕ =====
+LOG_LEVEL=INFO
+LOG_FILE=logs/bot.log
+
+# ===== РАЗРАБОТКА =====
+DEBUG=false
+WEBHOOK_URL=
 WEBHOOK_PATH=/webhook

-# LOCALIZATION
-DEFAULT_LANGUAGE=ru
-AVAILABLE_LANGUAGES=ru
-
-# LOGGING
-LOG_LEVEL=INFO
-LOG_FILE=/tmp/bot.log
-
-# DEVELOPMENT
-DEBUG=false
+# ===== ДОПОЛНИТЕЛЬНЫЕ НАСТРОЙКИ =====
+# Конфигурация приложений для гайда подключения
+APP_CONFIG_PATH=app-config.json
+ENABLE_DEEP_LINKS=true
+APP_CONFIG_CACHE_TTL=3600
@@ -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"]
@@ -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("Мониторинг техработ остановлен")
@@ -93,6 +93,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 +262,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",
@@ -5,7 +5,7 @@ from sqlalchemy import select, and_, func
 from sqlalchemy.ext.asyncio import AsyncSession
 from sqlalchemy.orm import selectinload

-from app.database.models import PromoCode, PromoCodeUse, PromoCodeType
+from app.database.models import PromoCode, PromoCodeUse, PromoCodeType, User

 logger = logging.getLogger(__name__)

@@ -187,8 +187,13 @@ async def update_promocode(


 async def delete_promocode(db: AsyncSession, promocode: PromoCode) -> bool:
-    
    try:
+        from sqlalchemy import delete as sql_delete
+        
+        await db.execute(
+            sql_delete(PromoCodeUse).where(PromoCodeUse.promocode_id == promocode.id)
+        )
+        
        await db.delete(promocode)
        await db.commit()
        
@@ -222,15 +227,24 @@ async def get_promocode_statistics(db: AsyncSession, promocode_id: int) -> dict:
    today_uses = today_uses_result.scalar()
    
    recent_uses_result = await db.execute(
-        select(PromoCodeUse)
+        select(PromoCodeUse, User)
+        .join(User, PromoCodeUse.user_id == User.id)
        .where(PromoCodeUse.promocode_id == promocode_id)
        .order_by(PromoCodeUse.used_at.desc())
        .limit(10)
    )
-    recent_uses = recent_uses_result.scalars().all()
+    recent_uses_data = recent_uses_result.all()
+    
+    recent_uses = []
+    for use, user in recent_uses_data:
+        use.user_username = user.username
+        use.user_full_name = user.full_name
+        use.user_telegram_id = user.telegram_id
+        recent_uses.append(use)
    
    return {
        "total_uses": total_uses,
        "today_uses": today_uses,
        "recent_uses": recent_uses
-    }
+    }
+
@@ -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)
@@ -6,7 +6,7 @@ from sqlalchemy.ext.asyncio import AsyncSession

 from app.config import settings
 from app.states import AdminStates
-from app.database.models import User, PromoCodeType
+from app.database.models import PromoCode, PromoCodeUse, PromoCodeType, User
 from app.keyboards.admin import (
    get_admin_promocodes_keyboard, get_promocode_type_keyboard,
    get_admin_pagination_keyboard, get_confirmation_keyboard
@@ -77,6 +77,7 @@ async def show_promocodes_list(
        return
    
    text = f"🎫 <b>Список промокодов</b> (стр. {page}/{total_pages})\n\n"
+    keyboard = []
    
    for promo in promocodes:
        status_emoji = "✅" if promo.is_active else "❌"
@@ -93,9 +94,14 @@ async def show_promocodes_list(
        if promo.valid_until:
            text += f"⏰ До: {format_datetime(promo.valid_until)}\n"
        
-        text += f"🔧 Управление: /promo_{promo.id}\n\n"
-    
-    keyboard = []
+        keyboard.append([
+            types.InlineKeyboardButton(
+                text=f"🎫 {promo.code}", 
+                callback_data=f"promo_manage_{promo.id}"
+            )
+        ])
+        
+        text += "\n" 
    
    if total_pages > 1:
        pagination_row = get_admin_pagination_keyboard(
@@ -182,128 +188,75 @@ async def show_promocode_management(
    )
    await callback.answer()

-
@admin_required
@error_handler
-async def toggle_promocode_status(
+async def show_promocode_edit_menu(
    callback: types.CallbackQuery,
    db_user: User,
    db: AsyncSession
 ):
-    promo_id = int(callback.data.split('_')[-1])
-    
-    promo = await db.get(PromoCode, promo_id)
-    if not promo:
-        await callback.answer("❌ Промокод не найден", show_alert=True)
+    try:
+        promo_id = int(callback.data.split('_')[-1])
+    except (ValueError, IndexError):
+        await callback.answer("❌ Ошибка получения ID промокода", show_alert=True)
        return
    
-    new_status = not promo.is_active
-    await update_promocode(db, promo, is_active=new_status)
-    
-    status_text = "активирован" if new_status else "деактивирован"
-    await callback.answer(f"✅ Промокод {status_text}", show_alert=True)
-    
-    await show_promocode_management(callback, db_user, db)
-
-
-@admin_required
-@error_handler
-async def confirm_delete_promocode(
-    callback: types.CallbackQuery,
-    db_user: User,
-    db: AsyncSession
-):
-    promo_id = int(callback.data.split('_')[-1])
-    
    promo = await db.get(PromoCode, promo_id)
    if not promo:
        await callback.answer("❌ Промокод не найден", show_alert=True)
        return
    
    text = f"""
-⚠️ <b>Подтверждение удаления</b>
+✏️ <b>Редактирование промокода</b> <code>{promo.code}</code>

-Вы действительно хотите удалить промокод <code>{promo.code}</code>?
-
-<b>Внимание:</b> Это действие нельзя отменить!
+💰 <b>Текущие параметры:</b>
 """
    
-    keyboard = types.InlineKeyboardMarkup(inline_keyboard=[
+    if promo.type == PromoCodeType.BALANCE.value:
+        text += f"• Бонус: {settings.format_price(promo.balance_bonus_kopeks)}\n"
+    elif promo.type in [PromoCodeType.SUBSCRIPTION_DAYS.value, PromoCodeType.TRIAL_SUBSCRIPTION.value]:
+        text += f"• Дней: {promo.subscription_days}\n"
+    
+    text += f"• Использований: {promo.current_uses}/{promo.max_uses}\n"
+    
+    if promo.valid_until:
+        text += f"• До: {format_datetime(promo.valid_until)}\n"
+    else:
+        text += f"• Срок: бессрочно\n"
+    
+    text += f"\nВыберите параметр для изменения:"
+    
+    keyboard = [
        [
            types.InlineKeyboardButton(
-                text="✅ Да, удалить", 
-                callback_data=f"promo_delete_confirm_{promo.id}"
-            ),
+                text="📅 Дата окончания", 
+                callback_data=f"promo_edit_date_{promo.id}"
+            )
+        ],
+        [
            types.InlineKeyboardButton(
-                text="❌ Отмена", 
-                callback_data=f"promo_manage_{promo.id}"
+                text="📊 Количество использований", 
+                callback_data=f"promo_edit_uses_{promo.id}"
            )
        ]
-    ])
+    ]
    
-    await callback.message.edit_text(text, reply_markup=keyboard)
-    await callback.answer()
-
-
-@admin_required
-@error_handler
-async def delete_promocode_confirmed(
-    callback: types.CallbackQuery,
-    db_user: User,
-    db: AsyncSession
-):
-    promo_id = int(callback.data.split('_')[-1])
+    if promo.type == PromoCodeType.BALANCE.value:
+        keyboard.insert(1, [
+            types.InlineKeyboardButton(
+                text="💰 Сумма бонуса", 
+                callback_data=f"promo_edit_amount_{promo.id}"
+            )
+        ])
+    elif promo.type in [PromoCodeType.SUBSCRIPTION_DAYS.value, PromoCodeType.TRIAL_SUBSCRIPTION.value]:
+        keyboard.insert(1, [
+            types.InlineKeyboardButton(
+                text="📅 Количество дней", 
+                callback_data=f"promo_edit_days_{promo.id}"
+            )
+        ])
    
-    promo = await db.get(PromoCode, promo_id)
-    if not promo:
-        await callback.answer("❌ Промокод не найден", show_alert=True)
-        return
-    
-    code = promo.code
-    success = await delete_promocode(db, promo)
-    
-    if success:
-        await callback.answer(f"✅ Промокод {code} удален", show_alert=True)
-        await show_promocodes_list(callback, db_user, db)
-    else:
-        await callback.answer("❌ Ошибка удаления промокода", show_alert=True)
-
-
-@admin_required
-@error_handler
-async def show_promocode_stats(
-    callback: types.CallbackQuery,
-    db_user: User,
-    db: AsyncSession
-):
-    promo_id = int(callback.data.split('_')[-1])
-    
-    promo = await db.get(PromoCode, promo_id)
-    if not promo:
-        await callback.answer("❌ Промокод не найден", show_alert=True)
-        return
-    
-    stats = await get_promocode_statistics(db, promo_id)
-    
-    text = f"""
-📊 <b>Статистика промокода</b> <code>{promo.code}</code>
-
-📈 <b>Общая статистика:</b>
- Всего использований: {stats['total_uses']}
- Использований сегодня: {stats['today_uses']}
- Осталось использований: {promo.max_uses - promo.current_uses}
-
-📅 <b>Последние использования:</b>
-"""
-    
-    for use in stats['recent_uses'][:5]:
-        use_date = format_datetime(use.used_at)
-        text += f"- {use_date} (ID: {use.user_id})\n"
-    
-    if not stats['recent_uses']:
-        text += "- Пока не было использований\n"
-    
-    keyboard = types.InlineKeyboardMarkup(inline_keyboard=[
+    keyboard.extend([
        [
            types.InlineKeyboardButton(
                text="⬅️ Назад", 
@@ -312,7 +265,160 @@ async def show_promocode_stats(
        ]
    ])
    
+    await callback.message.edit_text(
+        text,
+        reply_markup=types.InlineKeyboardMarkup(inline_keyboard=keyboard)
+    )
+    await callback.answer()
+
+
+@admin_required
+@error_handler
+async def start_edit_promocode_date(
+    callback: types.CallbackQuery,
+    db_user: User,
+    state: FSMContext
+):
+    try:
+        promo_id = int(callback.data.split('_')[-1])
+    except (ValueError, IndexError):
+        await callback.answer("❌ Ошибка получения ID промокода", show_alert=True)
+        return
+    
+    await state.update_data(
+        editing_promo_id=promo_id,
+        edit_action="date"
+    )
+    
+    text = f"""
+📅 <b>Изменение даты окончания промокода</b>
+
+Введите количество дней до окончания (от текущего момента):
+• Введите <b>0</b> для бессрочного промокода
+• Введите положительное число для установки срока
+
+<i>Например: 30 (промокод будет действовать 30 дней)</i>
+
+ID промокода: {promo_id}
+"""
+    
+    keyboard = types.InlineKeyboardMarkup(inline_keyboard=[
+        [types.InlineKeyboardButton(text="❌ Отмена", callback_data=f"promo_edit_{promo_id}")]
+    ])
+    
    await callback.message.edit_text(text, reply_markup=keyboard)
+    await state.set_state(AdminStates.setting_promocode_expiry)
+    await callback.answer()
+
+
+@admin_required
+@error_handler
+async def start_edit_promocode_amount(
+    callback: types.CallbackQuery,
+    db_user: User,
+    state: FSMContext
+):
+    try:
+        promo_id = int(callback.data.split('_')[-1])
+    except (ValueError, IndexError):
+        await callback.answer("❌ Ошибка получения ID промокода", show_alert=True)
+        return
+    
+    await state.update_data(
+        editing_promo_id=promo_id,
+        edit_action="amount"
+    )
+    
+    text = f"""
+💰 <b>Изменение суммы бонуса промокода</b>
+
+Введите новую сумму в рублях:
+<i>Например: 500</i>
+
+ID промокода: {promo_id}
+"""
+    
+    keyboard = types.InlineKeyboardMarkup(inline_keyboard=[
+        [types.InlineKeyboardButton(text="❌ Отмена", callback_data=f"promo_edit_{promo_id}")]
+    ])
+    
+    await callback.message.edit_text(text, reply_markup=keyboard)
+    await state.set_state(AdminStates.setting_promocode_value)
+    await callback.answer()
+
+@admin_required
+@error_handler
+async def start_edit_promocode_days(
+    callback: types.CallbackQuery,
+    db_user: User,
+    state: FSMContext
+):
+    # ИСПРАВЛЕНИЕ: берем последний элемент как ID
+    try:
+        promo_id = int(callback.data.split('_')[-1])
+    except (ValueError, IndexError):
+        await callback.answer("❌ Ошибка получения ID промокода", show_alert=True)
+        return
+    
+    await state.update_data(
+        editing_promo_id=promo_id,
+        edit_action="days"
+    )
+    
+    text = f"""
+📅 <b>Изменение количества дней подписки</b>
+
+Введите новое количество дней:
+<i>Например: 30</i>
+
+ID промокода: {promo_id}
+"""
+    
+    keyboard = types.InlineKeyboardMarkup(inline_keyboard=[
+        [types.InlineKeyboardButton(text="❌ Отмена", callback_data=f"promo_edit_{promo_id}")]
+    ])
+    
+    await callback.message.edit_text(text, reply_markup=keyboard)
+    await state.set_state(AdminStates.setting_promocode_value)
+    await callback.answer()
+
+
+@admin_required
+@error_handler
+async def start_edit_promocode_uses(
+    callback: types.CallbackQuery,
+    db_user: User,
+    state: FSMContext
+):
+    try:
+        promo_id = int(callback.data.split('_')[-1])
+    except (ValueError, IndexError):
+        await callback.answer("❌ Ошибка получения ID промокода", show_alert=True)
+        return
+    
+    await state.update_data(
+        editing_promo_id=promo_id,
+        edit_action="uses"
+    )
+    
+    text = f"""
+📊 <b>Изменение максимального количества использований</b>
+
+Введите новое количество использований:
+• Введите <b>0</b> для безлимитных использований
+• Введите положительное число для ограничения
+
+<i>Например: 100</i>
+
+ID промокода: {promo_id}
+"""
+    
+    keyboard = types.InlineKeyboardMarkup(inline_keyboard=[
+        [types.InlineKeyboardButton(text="❌ Отмена", callback_data=f"promo_edit_{promo_id}")]
+    ])
+    
+    await callback.message.edit_text(text, reply_markup=keyboard)
+    await state.set_state(AdminStates.setting_promocode_uses)
    await callback.answer()


@@ -375,7 +481,6 @@ async def process_promocode_code(
        await message.answer("❌ Код должен содержать только латинские буквы и цифры (3-20 символов)")
        return
    
-    from app.database.crud.promocode import get_promocode_by_code
    existing = await get_promocode_by_code(db, code)
    if existing:
        await message.answer("❌ Промокод с таким кодом уже существует")
@@ -411,12 +516,18 @@ async def process_promocode_code(
 async def process_promocode_value(
    message: types.Message,
    db_user: User,
-    state: FSMContext
+    state: FSMContext,
+    db: AsyncSession
 ):
+    data = await state.get_data()
+    
+    if data.get('editing_promo_id'):
+        await handle_edit_value(message, db_user, state, db)
+        return
+    
    try:
        value = int(message.text.strip())
        
-        data = await state.get_data()
        promo_type = data.get('promocode_type')
        
        if promo_type == "balance" and (value < 1 or value > 10000):
@@ -437,13 +548,72 @@ async def process_promocode_value(
        await message.answer("❌ Введите корректное число")


+async def handle_edit_value(
+    message: types.Message,
+    db_user: User,
+    state: FSMContext,
+    db: AsyncSession
+):
+    data = await state.get_data()
+    promo_id = data.get('editing_promo_id')
+    edit_action = data.get('edit_action')
+    
+    promo = await db.get(PromoCode, promo_id)
+    if not promo:
+        await message.answer("❌ Промокод не найден")
+        await state.clear()
+        return
+    
+    try:
+        value = int(message.text.strip())
+        
+        if edit_action == "amount":
+            if value < 1 or value > 10000:
+                await message.answer("❌ Сумма должна быть от 1 до 10,000 рублей")
+                return
+            
+            await update_promocode(db, promo, balance_bonus_kopeks=value * 100)
+            await message.answer(
+                f"✅ Сумма бонуса изменена на {value}₽",
+                reply_markup=types.InlineKeyboardMarkup(inline_keyboard=[
+                    [types.InlineKeyboardButton(text="🎫 К промокоду", callback_data=f"promo_manage_{promo_id}")]
+                ])
+            )
+            
+        elif edit_action == "days":
+            if value < 1 or value > 3650:
+                await message.answer("❌ Количество дней должно быть от 1 до 3650")
+                return
+            
+            await update_promocode(db, promo, subscription_days=value)
+            await message.answer(
+                f"✅ Количество дней изменено на {value}",
+                reply_markup=types.InlineKeyboardMarkup(inline_keyboard=[
+                    [types.InlineKeyboardButton(text="🎫 К промокоду", callback_data=f"promo_manage_{promo_id}")]
+                ])
+            )
+        
+        await state.clear()
+        logger.info(f"Промокод {promo.code} отредактирован администратором {db_user.telegram_id}: {edit_action} = {value}")
+        
+    except ValueError:
+        await message.answer("❌ Введите корректное число")
+
+
@admin_required
@error_handler
 async def process_promocode_uses(
    message: types.Message,
    db_user: User,
-    state: FSMContext
+    state: FSMContext,
+    db: AsyncSession
 ):
+    data = await state.get_data()
+    
+    if data.get('editing_promo_id'):
+        await handle_edit_uses(message, db_user, state, db)
+        return
+    
    try:
        max_uses = int(message.text.strip())
        
@@ -465,6 +635,54 @@ async def process_promocode_uses(
        await message.answer("❌ Введите корректное число")


+async def handle_edit_uses(
+    message: types.Message,
+    db_user: User,
+    state: FSMContext,
+    db: AsyncSession
+):
+    data = await state.get_data()
+    promo_id = data.get('editing_promo_id')
+    
+    promo = await db.get(PromoCode, promo_id)
+    if not promo:
+        await message.answer("❌ Промокод не найден")
+        await state.clear()
+        return
+    
+    try:
+        max_uses = int(message.text.strip())
+        
+        if max_uses < 0 or max_uses > 100000:
+            await message.answer("❌ Количество использований должно быть от 0 до 100,000")
+            return
+        
+        if max_uses == 0:
+            max_uses = 999999
+        
+        if max_uses < promo.current_uses:
+            await message.answer(
+                f"❌ Новый лимит ({max_uses}) не может быть меньше текущих использований ({promo.current_uses})"
+            )
+            return
+        
+        await update_promocode(db, promo, max_uses=max_uses)
+        
+        uses_text = "безлимитное" if max_uses == 999999 else str(max_uses)
+        await message.answer(
+            f"✅ Максимальное количество использований изменено на {uses_text}",
+            reply_markup=types.InlineKeyboardMarkup(inline_keyboard=[
+                [types.InlineKeyboardButton(text="🎫 К промокоду", callback_data=f"promo_manage_{promo_id}")]
+            ])
+        )
+        
+        await state.clear()
+        logger.info(f"Промокод {promo.code} отредактирован администратором {db_user.telegram_id}: max_uses = {max_uses}")
+        
+    except ValueError:
+        await message.answer("❌ Введите корректное число")
+
+
@admin_required
@error_handler
 async def process_promocode_expiry(
@@ -473,6 +691,12 @@ async def process_promocode_expiry(
    state: FSMContext,
    db: AsyncSession
 ):
+    data = await state.get_data()
+    
+    if data.get('editing_promo_id'):
+        await handle_edit_expiry(message, db_user, state, db)
+        return
+    
    try:
        expiry_days = int(message.text.strip())
        
@@ -480,7 +704,6 @@ async def process_promocode_expiry(
            await message.answer("❌ Срок действия должен быть от 0 до 3650 дней")
            return
        
-        data = await state.get_data()
        code = data.get('promocode_code')
        promo_type = data.get('promocode_type')
        value = data.get('promocode_value', 0)
@@ -544,6 +767,209 @@ async def process_promocode_expiry(
        await message.answer("❌ Введите корректное число дней")


+async def handle_edit_expiry(
+    message: types.Message,
+    db_user: User,
+    state: FSMContext,
+    db: AsyncSession
+):
+    data = await state.get_data()
+    promo_id = data.get('editing_promo_id')
+    
+    promo = await db.get(PromoCode, promo_id)
+    if not promo:
+        await message.answer("❌ Промокод не найден")
+        await state.clear()
+        return
+    
+    try:
+        expiry_days = int(message.text.strip())
+        
+        if expiry_days < 0 or expiry_days > 3650:
+            await message.answer("❌ Срок действия должен быть от 0 до 3650 дней")
+            return
+        
+        valid_until = None
+        if expiry_days > 0:
+            valid_until = datetime.utcnow() + timedelta(days=expiry_days)
+        
+        await update_promocode(db, promo, valid_until=valid_until)
+        
+        if valid_until:
+            expiry_text = f"до {format_datetime(valid_until)}"
+        else:
+            expiry_text = "бессрочно"
+            
+        await message.answer(
+            f"✅ Срок действия промокода изменен: {expiry_text}",
+            reply_markup=types.InlineKeyboardMarkup(inline_keyboard=[
+                [types.InlineKeyboardButton(text="🎫 К промокоду", callback_data=f"promo_manage_{promo_id}")]
+            ])
+        )
+        
+        await state.clear()
+        logger.info(f"Промокод {promo.code} отредактирован администратором {db_user.telegram_id}: expiry = {expiry_days} дней")
+        
+    except ValueError:
+        await message.answer("❌ Введите корректное число дней")
+
+
+@admin_required
+@error_handler
+async def toggle_promocode_status(
+    callback: types.CallbackQuery,
+    db_user: User,
+    db: AsyncSession
+):
+    promo_id = int(callback.data.split('_')[-1])
+    
+    promo = await db.get(PromoCode, promo_id)
+    if not promo:
+        await callback.answer("❌ Промокод не найден", show_alert=True)
+        return
+    
+    new_status = not promo.is_active
+    await update_promocode(db, promo, is_active=new_status)
+    
+    status_text = "активирован" if new_status else "деактивирован"
+    await callback.answer(f"✅ Промокод {status_text}", show_alert=True)
+    
+    await show_promocode_management(callback, db_user, db)
+
+
+@admin_required
+@error_handler
+async def confirm_delete_promocode(
+    callback: types.CallbackQuery,
+    db_user: User,
+    db: AsyncSession
+):
+    try:
+        promo_id = int(callback.data.split('_')[-1])
+    except (ValueError, IndexError):
+        await callback.answer("❌ Ошибка получения ID промокода", show_alert=True)
+        return
+    
+    promo = await db.get(PromoCode, promo_id)
+    if not promo:
+        await callback.answer("❌ Промокод не найден", show_alert=True)
+        return
+    
+    text = f"""
+⚠️ <b>Подтверждение удаления</b>
+
+Вы действительно хотите удалить промокод <code>{promo.code}</code>?
+
+📊 <b>Информация о промокоде:</b>
+• Использований: {promo.current_uses}/{promo.max_uses}
+• Статус: {'Активен' if promo.is_active else 'Неактивен'}
+
+<b>⚠️ Внимание:</b> Это действие нельзя отменить!
+
+ID: {promo_id}
+"""
+    
+    keyboard = types.InlineKeyboardMarkup(inline_keyboard=[
+        [
+            types.InlineKeyboardButton(
+                text="✅ Да, удалить", 
+                callback_data=f"promo_delete_confirm_{promo.id}"
+            ),
+            types.InlineKeyboardButton(
+                text="❌ Отмена", 
+                callback_data=f"promo_manage_{promo.id}"
+            )
+        ]
+    ])
+    
+    await callback.message.edit_text(text, reply_markup=keyboard)
+    await callback.answer()
+
+@admin_required
+@error_handler
+async def delete_promocode_confirmed(
+    callback: types.CallbackQuery,
+    db_user: User,
+    db: AsyncSession
+):
+    try:
+        promo_id = int(callback.data.split('_')[-1])
+    except (ValueError, IndexError):
+        await callback.answer("❌ Ошибка получения ID промокода", show_alert=True)
+        return
+    
+    promo = await db.get(PromoCode, promo_id)
+    if not promo:
+        await callback.answer("❌ Промокод не найден", show_alert=True)
+        return
+    
+    code = promo.code
+    success = await delete_promocode(db, promo)
+    
+    if success:
+        await callback.answer(f"✅ Промокод {code} удален", show_alert=True)
+        await show_promocodes_list(callback, db_user, db)
+    else:
+        await callback.answer("❌ Ошибка удаления промокода", show_alert=True)
+
+
+@admin_required
+@error_handler
+async def show_promocode_stats(
+    callback: types.CallbackQuery,
+    db_user: User,
+    db: AsyncSession
+):
+    promo_id = int(callback.data.split('_')[-1])
+    
+    promo = await db.get(PromoCode, promo_id)
+    if not promo:
+        await callback.answer("❌ Промокод не найден", show_alert=True)
+        return
+    
+    stats = await get_promocode_statistics(db, promo_id)
+    
+    text = f"""
+📊 <b>Статистика промокода</b> <code>{promo.code}</code>
+
+📈 <b>Общая статистика:</b>
+- Всего использований: {stats['total_uses']}
+- Использований сегодня: {stats['today_uses']}
+- Осталось использований: {promo.max_uses - promo.current_uses}
+
+📅 <b>Последние использования:</b>
+"""
+    
+    if stats['recent_uses']:
+        for use in stats['recent_uses'][:5]:
+            use_date = format_datetime(use.used_at)
+            
+            if hasattr(use, 'user_username') and use.user_username:
+                user_display = f"@{use.user_username}"
+            elif hasattr(use, 'user_full_name') and use.user_full_name:
+                user_display = use.user_full_name
+            elif hasattr(use, 'user_telegram_id'):
+                user_display = f"ID{use.user_telegram_id}"
+            else:
+                user_display = f"ID{use.user_id}"
+            
+            text += f"- {use_date} | {user_display}\n"
+    else:
+        text += "- Пока не было использований\n"
+    
+    keyboard = types.InlineKeyboardMarkup(inline_keyboard=[
+        [
+            types.InlineKeyboardButton(
+                text="⬅️ Назад", 
+                callback_data=f"promo_manage_{promo.id}"
+            )
+        ]
+    ])
+    
+    await callback.message.edit_text(text, reply_markup=keyboard)
+    await callback.answer()
+
+
 def register_handlers(dp: Dispatcher):
    dp.callback_query.register(show_promocodes_menu, F.data == "admin_promocodes")
    dp.callback_query.register(show_promocodes_list, F.data == "admin_promo_list")
@@ -552,11 +978,22 @@ def register_handlers(dp: Dispatcher):
    
    dp.callback_query.register(show_promocode_management, F.data.startswith("promo_manage_"))
    dp.callback_query.register(toggle_promocode_status, F.data.startswith("promo_toggle_"))
-    dp.callback_query.register(confirm_delete_promocode, F.data.startswith("promo_delete_"))
-    dp.callback_query.register(delete_promocode_confirmed, F.data.startswith("promo_delete_confirm_"))
    dp.callback_query.register(show_promocode_stats, F.data.startswith("promo_stats_"))
    
+    dp.callback_query.register(start_edit_promocode_date, F.data.startswith("promo_edit_date_"))
+    dp.callback_query.register(start_edit_promocode_amount, F.data.startswith("promo_edit_amount_"))
+    dp.callback_query.register(start_edit_promocode_days, F.data.startswith("promo_edit_days_"))
+    dp.callback_query.register(start_edit_promocode_uses, F.data.startswith("promo_edit_uses_"))
+    
+    dp.callback_query.register(
+        show_promocode_edit_menu, 
+        F.data.regexp(r"^promo_edit_\d+$")
+    )
+    
+    dp.callback_query.register(delete_promocode_confirmed, F.data.startswith("promo_delete_confirm_"))
+    dp.callback_query.register(confirm_delete_promocode, F.data.startswith("promo_delete_"))
+    
    dp.message.register(process_promocode_code, AdminStates.creating_promocode)
    dp.message.register(process_promocode_value, AdminStates.setting_promocode_value)
    dp.message.register(process_promocode_uses, AdminStates.setting_promocode_uses)
-    dp.message.register(process_promocode_expiry, AdminStates.setting_promocode_expiry)
+    dp.message.register(process_promocode_expiry, AdminStates.setting_promocode_expiry)
@@ -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_")
-    )
+    )
@@ -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={
@@ -85,13 +85,7 @@ async def create_invite_message(
        [
            types.InlineKeyboardButton(
                text="📤 Поделиться",
-                switch_inline_query=invite_text
-            )
-        ],
-        [
-            types.InlineKeyboardButton(
-                text="📋 Скопировать ссылку",
-                callback_data="copy_referral_link"
+                switch_inline_query=invite_text 
            )
        ],
        [
@@ -104,7 +98,7 @@ async def create_invite_message(
    
    await callback.message.edit_text(
        f"📝 <b>Приглашение создано!</b>\n\n"
-        f"Используйте кнопку ниже для отправки приглашения или скопируйте текст:\n\n"
+        f"Нажмите кнопку «📤 Поделиться» чтобы отправить приглашение в любой чат, или скопируйте текст ниже:\n\n"
        f"<code>{invite_text}</code>",
        reply_markup=keyboard,
        parse_mode="HTML"
@@ -112,20 +106,6 @@ async def create_invite_message(
    await callback.answer()


-async def copy_referral_link(
-    callback: types.CallbackQuery,
-    db_user: User
-):
-    
-    bot_username = (await callback.bot.get_me()).username
-    referral_link = f"https://t.me/{bot_username}?start={db_user.referral_code}"
-    
-    await callback.answer(
-        f"Ссылка скопирована: {referral_link}",
-        show_alert=True
-    )
-
-
 def register_handlers(dp: Dispatcher):
    
    dp.callback_query.register(
@@ -137,8 +117,3 @@ def register_handlers(dp: Dispatcher):
        create_invite_message,
        F.data == "referral_create_invite"
    )
-    
-    dp.callback_query.register(
-        copy_referral_link,
-        F.data == "copy_referral_link"
-    )
@@ -1,4 +1,5 @@
 import logging
+from datetime import datetime
 from aiogram import Dispatcher, types, F
 from aiogram.filters import Command, StateFilter
 from aiogram.fsm.context import FSMContext
@@ -20,6 +21,62 @@ from app.utils.user_utils import generate_unique_referral_code
 logger = logging.getLogger(__name__)


+async def handle_potential_referral_code(
+    message: types.Message, 
+    state: FSMContext, 
+    db: AsyncSession
+):
+    current_state = await state.get_state()
+    logger.info(f"🔍 REFERRAL CHECK: Проверка сообщения '{message.text}' в состоянии {current_state}")
+    
+    if current_state not in [
+        RegistrationStates.waiting_for_rules_accept.state,
+        RegistrationStates.waiting_for_referral_code.state,
+        None 
+    ]:
+        return False
+    
+    user = await get_user_by_telegram_id(db, message.from_user.id)
+    if user and user.status == UserStatus.ACTIVE.value:
+        return False
+    
+    potential_code = message.text.strip()
+    if len(potential_code) < 4 or len(potential_code) > 20:
+        return False
+    
+    referrer = await get_user_by_referral_code(db, potential_code)
+    if not referrer:
+        await message.answer(
+            "❌ Неверный реферальный код.\n\n"
+            "💡 Если у вас есть реферальный код, убедитесь что он введен правильно.\n"
+            "⏭️ Для продолжения регистрации без реферального кода используйте команду /start"
+        )
+        return True 
+    
+    data = await state.get_data() or {}
+    data['referral_code'] = potential_code
+    data['referrer_id'] = referrer.id
+    await state.set_data(data)
+    
+    await message.answer("✅ Реферальный код принят!")
+    logger.info(f"✅ Реферальный код {potential_code} применен для пользователя {message.from_user.id}")
+    
+    if current_state != RegistrationStates.waiting_for_referral_code.state:
+        language = data.get('language', 'ru')
+        texts = get_texts(language)
+        
+        await message.answer(
+            texts.RULES_TEXT,
+            reply_markup=get_rules_keyboard(language)
+        )
+        await state.set_state(RegistrationStates.waiting_for_rules_accept)
+        logger.info("📋 Правила отправлены после ввода реферального кода")
+    else:
+        await complete_registration(message, state, db)
+    
+    return True 
+
+
 async def cmd_start(message: types.Message, state: FSMContext, db: AsyncSession, db_user=None):
    logger.info(f"🚀 START: Обработка /start от {message.from_user.id}")
    
@@ -36,6 +93,37 @@ async def cmd_start(message: types.Message, state: FSMContext, db: AsyncSession,
    
    if user and user.status != UserStatus.DELETED.value:
        logger.info(f"✅ Активный пользователь найден: {user.telegram_id}")
+        
+        profile_updated = False
+        
+        if user.username != message.from_user.username:
+            old_username = user.username
+            user.username = message.from_user.username
+            logger.info(f"📝 Username обновлен: '{old_username}' → '{user.username}'")
+            profile_updated = True
+        
+        if user.first_name != message.from_user.first_name:
+            old_first_name = user.first_name
+            user.first_name = message.from_user.first_name
+            logger.info(f"📝 Имя обновлено: '{old_first_name}' → '{user.first_name}'")
+            profile_updated = True
+        
+        if user.last_name != message.from_user.last_name:
+            old_last_name = user.last_name
+            user.last_name = message.from_user.last_name
+            logger.info(f"📝 Фамилия обновлена: '{old_last_name}' → '{user.last_name}'")
+            profile_updated = True
+        
+        user.last_activity = datetime.utcnow()
+        
+        if profile_updated:
+            user.updated_at = datetime.utcnow()
+            await db.commit()
+            await db.refresh(user)
+            logger.info(f"💾 Профиль пользователя {user.telegram_id} обновлен")
+        else:
+            await db.commit()
+        
        texts = get_texts(user.language)
        
        if referral_code and not user.referred_by_id:
@@ -107,6 +195,13 @@ async def cmd_start(message: types.Message, state: FSMContext, db: AsyncSession,
            user.remnawave_uuid = None
            user.has_had_paid_subscription = False
            user.referred_by_id = None
+            
+            user.username = message.from_user.username
+            user.first_name = message.from_user.first_name
+            user.last_name = message.from_user.last_name
+            user.updated_at = datetime.utcnow()
+            user.last_activity = datetime.utcnow()
+            
            from app.utils.user_utils import generate_unique_referral_code
            user.referral_code = await generate_unique_referral_code(db, user.telegram_id)
            
@@ -299,6 +394,10 @@ async def complete_registration_from_callback(
        logger.warning(f"⚠️ Пользователь {callback.from_user.id} уже активен! Показываем главное меню.")
        texts = get_texts(existing_user.language)
        
+        data = await state.get_data()
+        if data.get('referral_code') and not existing_user.referred_by_id:
+            await callback.message.answer("ℹ️ Вы уже зарегистрированы в системе. Реферальная ссылка не может быть применена.")
+        
        has_active_subscription = existing_user.subscription is not None
        subscription_is_active = False
        
@@ -362,7 +461,7 @@ async def complete_registration_from_callback(
        user = existing_user
        logger.info(f"✅ Пользователь {callback.from_user.id} восстановлен")
        
-    else:
+    elif not existing_user:
        logger.info(f"🆕 Создаем нового пользователя {callback.from_user.id}")
        
        referral_code = await generate_unique_referral_code(db, callback.from_user.id)
@@ -377,6 +476,20 @@ async def complete_registration_from_callback(
            referred_by_id=referrer_id,
            referral_code=referral_code 
        )
+    else:
+        logger.info(f"🔄 Обновляем существующего пользователя {callback.from_user.id}")
+        existing_user.status = UserStatus.ACTIVE.value
+        existing_user.language = language
+        if referrer_id and not existing_user.referred_by_id:
+            existing_user.referred_by_id = referrer_id
+        
+        from datetime import datetime
+        existing_user.updated_at = datetime.utcnow()
+        existing_user.last_activity = datetime.utcnow()
+        
+        await db.commit()
+        await db.refresh(existing_user)
+        user = existing_user
    
    if referrer_id:
        try:
@@ -451,6 +564,42 @@ async def complete_registration(
    
    existing_user = await get_user_by_telegram_id(db, message.from_user.id)
    
+    if existing_user and existing_user.status == UserStatus.ACTIVE.value:
+        logger.warning(f"⚠️ Пользователь {message.from_user.id} уже активен! Показываем главное меню.")
+        texts = get_texts(existing_user.language)
+        
+        data = await state.get_data()
+        if data.get('referral_code') and not existing_user.referred_by_id:
+            await message.answer("ℹ️ Вы уже зарегистрированы в системе. Реферальная ссылка не может быть применена.")
+        
+        has_active_subscription = existing_user.subscription is not None
+        subscription_is_active = False
+        
+        if existing_user.subscription:
+            subscription_is_active = existing_user.subscription.is_active
+        
+        try:
+            await message.answer(
+                texts.MAIN_MENU.format(
+                    user_name=existing_user.full_name,
+                    balance=texts.format_price(existing_user.balance_kopeks),
+                    subscription_status=_get_subscription_status(existing_user, texts)
+                ),
+                reply_markup=get_main_menu_keyboard(
+                    language=existing_user.language,
+                    is_admin=settings.is_admin(existing_user.telegram_id),
+                    has_had_paid_subscription=existing_user.has_had_paid_subscription,
+                    has_active_subscription=has_active_subscription,
+                    subscription_is_active=subscription_is_active
+                )
+            )
+        except Exception as e:
+            logger.error(f"Ошибка при показе главного меню существующему пользователю: {e}")
+            await message.answer(f"Добро пожаловать, {existing_user.full_name}!")
+        
+        await state.clear()
+        return
+    
    data = await state.get_data()
    language = data.get('language', 'ru')
    texts = get_texts(language)
@@ -483,7 +632,7 @@ async def complete_registration(
        user = existing_user
        logger.info(f"✅ Пользователь {message.from_user.id} восстановлен")
        
-    else:
+    elif not existing_user:
        logger.info(f"🆕 Создаем нового пользователя {message.from_user.id}")
        
        referral_code = await generate_unique_referral_code(db, message.from_user.id)
@@ -498,6 +647,20 @@ async def complete_registration(
            referred_by_id=referrer_id,
            referral_code=referral_code
        )
+    else:
+        logger.info(f"🔄 Обновляем существующего пользователя {message.from_user.id}")
+        existing_user.status = UserStatus.ACTIVE.value
+        existing_user.language = language
+        if referrer_id and not existing_user.referred_by_id:
+            existing_user.referred_by_id = referrer_id
+        
+        from datetime import datetime
+        existing_user.updated_at = datetime.utcnow()
+        existing_user.last_activity = datetime.utcnow()
+        
+        await db.commit()
+        await db.refresh(existing_user)
+        user = existing_user
    
    if referrer_id:
        try:
@@ -614,4 +777,13 @@ def register_handlers(dp: Dispatcher):
    )
    logger.info("✅ Зарегистрирован process_referral_code_input")
    
+    dp.message.register(
+        handle_potential_referral_code,
+        StateFilter(
+            RegistrationStates.waiting_for_rules_accept,
+            RegistrationStates.waiting_for_referral_code
+        )
+    )
+    logger.info("✅ Зарегистрирован handle_potential_referral_code")
+    
    logger.info("🔧 === КОНЕЦ регистрации обработчиков start.py ===")
@@ -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:
@@ -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()


@@ -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()
@@ -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,
@@ -142,27 +142,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")
        ])
    
@@ -292,9 +296,11 @@ def get_devices_keyboard(current: int, language: str = "ru") -> InlineKeyboardMa
        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 +312,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 +513,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 +633,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}"
            )
        ])
@@ -1,4 +1,5 @@
 import logging
+from datetime import datetime
 from typing import Callable, Dict, Any, Awaitable
 from aiogram import BaseMiddleware
 from aiogram.types import Message, CallbackQuery, TelegramObject, User as TgUser
@@ -56,7 +57,7 @@ class AuthMiddleware(BaseMiddleware):
                    )
                    
                    if is_registration_process:
-                        logger.info(f"📝 Пропускаем пользователя {user.id} в процессе регистрации")
+                        logger.info(f"🔍 Пропускаем пользователя {user.id} в процессе регистрации")
                        data['db'] = db
                        data['db_user'] = None
                        data['is_admin'] = False
@@ -124,8 +125,33 @@ class AuthMiddleware(BaseMiddleware):
                            logger.info(f"❌ Удаленный пользователь {user.id} попытался использовать бота без /start")
                            return
                    
-                    from datetime import datetime
+                    
+                    profile_updated = False
+                    
+                    if db_user.username != user.username:
+                        old_username = db_user.username
+                        db_user.username = user.username
+                        logger.info(f"📝 [Middleware] Username обновлен для {user.id}: '{old_username}' → '{db_user.username}'")
+                        profile_updated = True
+                    
+                    if db_user.first_name != user.first_name:
+                        old_first_name = db_user.first_name
+                        db_user.first_name = user.first_name
+                        logger.info(f"📝 [Middleware] Имя обновлено для {user.id}: '{old_first_name}' → '{db_user.first_name}'")
+                        profile_updated = True
+                    
+                    if db_user.last_name != user.last_name:
+                        old_last_name = db_user.last_name
+                        db_user.last_name = user.last_name
+                        logger.info(f"📝 [Middleware] Фамилия обновлена для {user.id}: '{old_last_name}' → '{db_user.last_name}'")
+                        profile_updated = True
+                    
                    db_user.last_activity = datetime.utcnow()
+                    
+                    if profile_updated:
+                        db_user.updated_at = datetime.utcnow()
+                        logger.info(f"💾 [Middleware] Профиль пользователя {user.id} обновлен в middleware")
+                    
                    await db.commit()

                data['db'] = db
@@ -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]:
@@ -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
@@ -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():
Author	SHA1	Message	Date
Egor	6df92bde2a	Update README.md	2025-09-02 00:34:13 +03:00
Egor	60ff006fec	Update README.md	2025-09-02 00:33:03 +03:00
Egor	0181f5e10c	Update docker-compose.yml	2025-09-02 00:30:33 +03:00
Egor	4bbcc60bbb	Update subscriptions.py	2025-09-02 00:16:07 +03:00
Egor	8e2138e2aa	Update subscriptions.py	2025-09-02 00:14:45 +03:00
Egor	70b9e8c10d	Update inline.py	2025-09-01 23:44:56 +03:00
Egor	dc1eddb0df	Update subscription.py	2025-09-01 23:44:02 +03:00
Egor	630551cc4b	Update README.md	2025-09-01 23:17:46 +03:00
Egor	4f94b25182	Update docker-compose.yml	2025-09-01 22:50:17 +03:00
Egor	d3b240eae3	Update Dockerfile	2025-09-01 22:49:41 +03:00
Egor	e2883d6727	Update main.py	2025-09-01 22:29:47 +03:00
Egor	21757b37ab	Update bot.py	2025-09-01 22:27:37 +03:00
Egor	9190857ffa	Update maintenance_service.py	2025-09-01 22:27:08 +03:00
Egor	a607443aa7	Update README.md	2025-09-01 19:59:39 +03:00
Egor	41969bc0c2	Update .env.example	2025-09-01 19:59:20 +03:00
Egor	0d443afb87	Update balance.py	2025-09-01 19:58:21 +03:00
Egor	3d85294d41	Update config.py	2025-09-01 19:55:23 +03:00
Egor	86896771a6	Update inline.py	2025-09-01 05:02:10 +03:00
Egor	42d52990fa	Update README.md	2025-09-01 04:34:16 +03:00
Egor	6296c8257f	Update README.md	2025-09-01 04:13:29 +03:00
Egor	14a40cb1b6	Create docker-compose.yml	2025-09-01 04:10:55 +03:00
Egor	d0e3650de5	Update config.py	2025-09-01 03:52:56 +03:00
Egor	df8ed666ae	Update menu.py	2025-09-01 03:51:29 +03:00
Egor	2217b7f800	Update config.py	2025-09-01 03:46:13 +03:00
Egor	924febc2f3	Update menu.py	2025-09-01 03:43:27 +03:00
Egor	729ffb7952	Update messages.py	2025-09-01 01:06:54 +03:00
Egor	1568ca7633	Update README.md	2025-09-01 00:11:27 +03:00
Egor	7d5e476580	Update referral.py	2025-08-31 23:18:00 +03:00
Egor	9bcd187358	Update referral.py	2025-08-31 23:14:44 +03:00
Egor	a9cbb6272f	Update referral.py	2025-08-31 23:07:27 +03:00
Egor	b524decfa7	Update referral.py	2025-08-31 23:04:00 +03:00
Egor	5ee01f7735	Update referral.py	2025-08-31 23:00:20 +03:00
Egor	f46f2d6523	Update start.py	2025-08-31 22:45:54 +03:00
Egor	435dbf6cee	Update auth.py	2025-08-31 22:42:02 +03:00
Egor	94d38eeb71	Update auth.py	2025-08-31 22:41:31 +03:00
Egor	0e7f6f90ed	Update auth.py	2025-08-31 22:40:41 +03:00
Egor	f3789287dc	Update start.py	2025-08-31 22:40:04 +03:00
Egor	a8312d7c10	Update promocode.py	2025-08-31 22:10:21 +03:00
Egor	612f4a7978	Update promocodes.py	2025-08-31 22:07:04 +03:00
Egor	2462347b5f	Update promocode.py	2025-08-31 22:06:15 +03:00
Egor	3ec3c0d76b	Update promocodes.py	2025-08-31 22:05:16 +03:00
Egor	8224aa98f4	Update promocodes.py	2025-08-31 22:02:00 +03:00
Egor	bb9d9422fb	Update promocode.py	2025-08-31 22:01:16 +03:00
Egor	f3a184ff00	Update promocodes.py	2025-08-31 21:53:25 +03:00
Egor	866e4586df	Update promocode.py	2025-08-31 21:52:18 +03:00
Egor	a30647893d	Update promocodes.py	2025-08-31 21:39:14 +03:00
Egor	73826312e5	Update promocodes.py	2025-08-31 19:08:16 +03:00
Egor	dae34dc0ef	Update promocodes.py	2025-08-31 18:59:39 +03:00
Egor	17d0c8c26f	Update promocodes.py	2025-08-31 18:50:55 +03:00
Egor	67831dc162	Update promocodes.py	2025-08-31 18:45:16 +03:00
Egor	ae84fbe141	Update promocodes.py	2025-08-31 18:36:54 +03:00
Egor	8c9bd890e8	Update promocodes.py	2025-08-31 18:35:57 +03:00
Egor	e8c1956de5	Update promocodes.py	2025-08-31 18:28:06 +03:00
Egor	1540a41d3a	Update .env.example	2025-08-31 17:40:08 +03:00
Egor	9cb61cb696	Update README.md	2025-08-31 17:39:52 +03:00
Egor	3511325285	Update auth.py	2025-08-31 16:18:42 +03:00
Egor	62507c5d28	Update auth.py	2025-08-31 16:10:28 +03:00
Egor	387df29a05	Update start.py	2025-08-31 15:40:31 +03:00
Egor	75dca7e1ad	Update start.py	2025-08-31 15:32:25 +03:00
Egor	2d5e54d5ad	Update README.md	2025-08-31 06:52:42 +03:00
Egor	d62b2b0d6f	Update README.md	2025-08-31 06:50:22 +03:00
Egor	e273719ad1	Update README.md	2025-08-31 06:49:41 +03:00
Egor	f6726f1c94	Update README.md	2025-08-31 06:15:32 +03:00