""" Handler: Admin panel. Commands: /admin — open admin dashboard (IsAdmin protected) /stats — quick bot statistics (IsAdmin protected) /users — list registered users (IsAdmin protected) Reply keyboard: "ورود به پنل مدیریت" — same as /admin "بازگشت به منوی اصلی" — return to normal user keyboard Features: - View pending / completed / all orders - Manage paid orders (fulfill or cancel with user notification) - Edit product base prices (stored in PostgreSQL, persists across restarts) - Financial reports (today / week / month / total revenue) - Broadcast message to all users - Total users stat on dashboard - Admin guide / help All admin-facing text in Persian (فارسی). """ import contextlib import asyncio import logging from aiogram import Router, F from aiogram.types import Message, CallbackQuery, InlineKeyboardButton from aiogram.filters import Command from aiogram.fsm.context import FSMContext from aiogram.exceptions import TelegramBadRequest from config import config from filters import IsAdmin from states.states import AdminStates, ProductState, AccountMarginState from keyboards.callback_data import ProductCallback from keyboards.admin_product import ( product_list_kb, product_detail_kb, product_edit_success_kb, ) from database.db import ( get_all_orders, get_order, update_order_status, get_all_product_prices, update_product_price, get_price_or_default, get_revenue_by_period, get_total_users, get_order_count_by_status, get_all_users, get_open_tickets, ) from keyboards.admin import ( admin_panel_kb, admin_order_kb, admin_paid_order_kb, admin_back_kb, admin_finance_kb, admin_broadcast_confirm_kb, ) from keyboards.admin_reply import admin_reply_kb from keyboards.reply import main_reply_kb from keyboards.inline import back_to_menu_kb from utils.emojis import get_pe, PREMIUM_EMOJIS router = Router(name="admin") # ═══════════════════════════════════════════════════════════════════════ # FULL ADMIN PANEL V2 # Does not replace existing admin callbacks. # New callbacks use admin2: # ═══════════════════════════════════════════════════════════════════════ FULL_ADMIN_V2_INSTALLED = True def _admin2_kb(rows): from aiogram.types import InlineKeyboardMarkup, InlineKeyboardButton return InlineKeyboardMarkup(inline_keyboard=rows) def _admin2_user_name(row): name = row.get("full_name") if hasattr(row, "get") else row["full_name"] username = row.get("username") if hasattr(row, "get") else row["username"] name = name or "بدون نام" if username: return f"{name} (@{username})" return name def _admin2_date(value): if not value: return "—" try: return str(value)[:16].replace("T", " ") except Exception: return str(value) async def _admin2_user_stats(user_id: int): pool = await get_pool() user = await pool.fetchrow( """ SELECT * FROM users WHERE user_id = $1 """, user_id, ) if not user: return None orders = await pool.fetch( """ SELECT * FROM orders WHERE user_id = $1 ORDER BY created_at DESC """, user_id, ) try: payments = await pool.fetch( """ SELECT p.*, o.product, o.status AS order_status FROM payments p LEFT JOIN orders o ON o.order_id = p.order_id WHERE o.user_id = $1 ORDER BY p.order_id DESC """, user_id, ) except Exception: payments = [] return user, orders, payments # ───────────────────────────────────────────────────────────────────── # Main V2 dashboard # ───────────────────────────────────────────────────────────────────── @router.callback_query(F.data == "admin2:panel", IsAdmin()) async def cb_admin2_panel(callback: CallbackQuery) -> None: await callback.answer() users = await get_total_users() pending = await get_order_count_by_status("pending") paid = await get_order_count_by_status("paid") delivered = await get_order_count_by_status("delivered") cancelled = await get_order_count_by_status("cancelled") today = await get_revenue_by_period("today") week = await get_revenue_by_period("week") month = await get_revenue_by_period("month") total = await get_revenue_by_period("all") text = ( f"{get_pe('shield')} پنل مدیریت کامل\n\n" f"{get_pe('users')} کاربران: {users}\n" f"{get_pe('yellow_circle')} در انتظار: {pending}\n" f"{get_pe('green_circle')} پرداخت‌شده: {paid}\n" f"{get_pe('check')} تکمیل‌شده: {delivered}\n" f"{get_pe('cross')} لغوشده: {cancelled}\n\n" f"{get_pe('money')} درآمد امروز: {_safe_amount(today)} تومان\n" f"{get_pe('calendar')} این هفته: {_safe_amount(week)} تومان\n" f"{get_pe('calendar')} این ماه: {_safe_amount(month)} تومان\n" f"{get_pe('diamond')} درآمد کل: {_safe_amount(total)} تومان" ) kb = _admin2_kb([ [ InlineKeyboardButton( text=f"{get_pe('users')} کاربران", callback_data="admin2:users:0" ), InlineKeyboardButton( text=f"{get_pe('chart')} سفارش‌ها", callback_data="admin2:orders:0" ), ], [ InlineKeyboardButton( text=f"{get_pe('yellow_circle')} در انتظار", callback_data="admin2:orders:pending:0" ), InlineKeyboardButton( text=f"{get_pe('green_circle')} پرداخت‌شده", callback_data="admin2:orders:paid:0" ), ], [ InlineKeyboardButton( text=f"{get_pe('check')} تکمیل‌شده", callback_data="admin2:orders:delivered:0" ), InlineKeyboardButton( text=f"{get_pe('cross')} لغوشده", callback_data="admin2:orders:cancelled:0" ), ], [ InlineKeyboardButton( text=f"{get_pe('money')} گزارش مالی", callback_data="admin2:finance" ), InlineKeyboardButton( text=f"{get_pe('chart')} آمار", callback_data="admin2:stats" ), ], [ InlineKeyboardButton( text=f"{get_pe('home')} پنل قدیمی", callback_data="admin:panel" ), ], ]) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text(text, reply_markup=kb) # ───────────────────────────────────────────────────────────────────── # Users # ───────────────────────────────────────────────────────────────────── @router.callback_query(F.data.startswith("admin2:users:"), IsAdmin()) async def cb_admin2_users(callback: CallbackQuery) -> None: await callback.answer() page = int(callback.data.split(":")[2]) per_page = 8 users = await get_all_users() total = len(users) start = page * per_page items = users[start:start + per_page] if not items: page = 0 start = 0 items = users[:per_page] text = ( f"{get_pe('users')} مدیریت کاربران\n" f"تعداد کل: {total}\n" f"صفحه: {page + 1} از {max(1, (total + per_page - 1) // per_page)}\n\n" ) rows = [] for u in items: uid = u["user_id"] name = u["full_name"] or "بدون نام" username = f"@{u['username']}" if u["username"] else "بدون یوزرنیم" text += ( f"{get_pe('user')} {name}\n" f"ID: {uid} | {username}\n" f"ورود: {_admin2_date(u['joined_at'])}\n\n" ) rows.append([ InlineKeyboardButton( text=f"{get_pe('user')} {name[:25]}", callback_data=f"admin2:user:{uid}" ) ]) nav = [] if page > 0: nav.append( InlineKeyboardButton( text=f"{get_pe('back_arrow')} قبلی", callback_data=f"admin2:users:{page - 1}" ) ) if start + per_page < total: nav.append( InlineKeyboardButton( text=f"بعدی {get_pe('next')}", callback_data=f"admin2:users:{page + 1}" ) ) if nav: rows.append(nav) rows.append([ InlineKeyboardButton( text=f"{get_pe('home')} پنل مدیریت", callback_data="admin2:panel" ) ]) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( text, reply_markup=_admin2_kb(rows) ) # ───────────────────────────────────────────────────────────────────── # User profile # ───────────────────────────────────────────────────────────────────── @router.callback_query(F.data.startswith("admin2:user:"), IsAdmin()) async def cb_admin2_user(callback: CallbackQuery) -> None: await callback.answer() user_id = int(callback.data.split(":")[2]) result = await _admin2_user_stats(user_id) if not result: await callback.answer("کاربر پیدا نشد.", show_alert=True) return user, orders, payments = result username = ( f"@{user['username']}" if user["username"] else "—" ) phone = ( user["phone_number"] if "phone_number" in user and user["phone_number"] else ( user["phone"] if "phone" in user and user["phone"] else "—" ) ) wallet = ( user["wallet_balance"] if "wallet_balance" in user and user["wallet_balance"] is not None else 0 ) successful = sum( 1 for o in orders if o["status"] == "delivered" ) total_spent = sum( int(o["amount_irt"] or 0) for o in orders if o["status"] == "delivered" ) text = ( f"{get_pe('user')} پروفایل کامل کاربر\n\n" f"{get_pe('user')} نام: {user['full_name'] or '—'}\n" f"{get_pe('telegram')} یوزرنیم: {username}\n" f"{get_pe('shield')} User ID: {user_id}\n" f"{get_pe('call')} شماره: {phone}\n" f"{get_pe('calendar')} تاریخ ورود: {_admin2_date(user['joined_at'])}\n" f"{get_pe('money')} موجودی کیف پول: {_safe_amount(wallet)} تومان\n\n" f"{get_pe('shopping')} کل سفارش‌ها: {len(orders)}\n" f"{get_pe('check')} خریدهای موفق: {successful}\n" f"{get_pe('money')} مجموع خرید موفق: {_safe_amount(total_spent)} تومان\n" f"{get_pe('card')} پرداخت‌ها: {len(payments)}" ) kb = _admin2_kb([ [ InlineKeyboardButton( text=f"{get_pe('shopping')} سفارش‌های کاربر", callback_data=f"admin2:userorders:{user_id}:0" ) ], [ InlineKeyboardButton( text=f"{get_pe('money')} پرداخت‌های کاربر", callback_data=f"admin2:userpayments:{user_id}:0" ) ], [ InlineKeyboardButton( text=f"{get_pe('back_arrow')} کاربران", callback_data="admin2:users:0" ), InlineKeyboardButton( text=f"{get_pe('home')} پنل", callback_data="admin2:panel" ) ], ]) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( text, reply_markup=kb ) # ───────────────────────────────────────────────────────────────────── # User orders # ───────────────────────────────────────────────────────────────────── @router.callback_query(F.data.startswith("admin2:userorders:"), IsAdmin()) async def cb_admin2_userorders(callback: CallbackQuery) -> None: await callback.answer() _, _, user_id, page = callback.data.split(":") user_id = int(user_id) page = int(page) orders = await get_all_orders() orders = [o for o in orders if o["user_id"] == user_id] per_page = 8 start = page * per_page items = orders[start:start + per_page] text = ( f"{get_pe('shopping')} سفارش‌های کاربر\n" f"User ID: {user_id}\n" f"تعداد: {len(orders)}\n\n" ) rows = [] for o in items: text += ( f"{get_pe('box')} سفارش #{o['order_id']}\n" f"محصول: {o['product']}\n" f"مبلغ: {_safe_amount(o['amount_irt'])} تومان\n" f"وضعیت: {_status_fa(o['status'])}\n" f"تاریخ: {_admin2_date(o['created_at'])}\n\n" ) rows.append([ InlineKeyboardButton( text=f"#{o['order_id']} — جزئیات", callback_data=f"admin2:order:{o['order_id']}" ) ]) nav = [] if page > 0: nav.append( InlineKeyboardButton( text=f"{get_pe('back_arrow')} قبلی", callback_data=f"admin2:userorders:{user_id}:{page - 1}" ) ) if start + per_page < len(orders): nav.append( InlineKeyboardButton( text=f"بعدی {get_pe('next')}", callback_data=f"admin2:userorders:{user_id}:{page + 1}" ) ) if nav: rows.append(nav) rows.append([ InlineKeyboardButton( text=f"{get_pe('user')} پروفایل کاربر", callback_data=f"admin2:user:{user_id}" ) ]) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( text, reply_markup=_admin2_kb(rows) ) # ───────────────────────────────────────────────────────────────────── # All orders / filtered orders # ───────────────────────────────────────────────────────────────────── @router.callback_query(F.data.regexp(r"^admin2:orders:[0-9]+$"), IsAdmin()) async def cb_admin2_orders_all(callback: CallbackQuery) -> None: await _admin2_orders_page(callback, None, int(callback.data.split(":")[2])) @router.callback_query(F.data.regexp(r"^admin2:orders:(pending|paid|delivered|cancelled):[0-9]+$"), IsAdmin()) async def cb_admin2_orders_filtered(callback: CallbackQuery) -> None: parts = callback.data.split(":") await _admin2_orders_page(callback, parts[2], int(parts[3])) async def _admin2_orders_page(callback: CallbackQuery, status, page): await callback.answer() orders = await get_all_orders(status=status) if status else await get_all_orders() per_page = 8 start = page * per_page items = orders[start:start + per_page] title = "تمام سفارش‌ها" if not status else f"سفارش‌های {_status_fa(status)}" text = ( f"{get_pe('chart')} {title}\n" f"تعداد: {len(orders)}\n" f"صفحه: {page + 1}\n\n" ) rows = [] for o in items: text += ( f"{get_pe('box')} #{o['order_id']}\n" f"{get_pe('user')} کاربر: {o['user_id']}\n" f"{get_pe('shopping')} محصول: {o['product']}\n" f"{get_pe('money')} مبلغ: {_safe_amount(o['amount_irt'])} تومان\n" f"وضعیت: {_status_fa(o['status'])}\n" f"تاریخ: {_admin2_date(o['created_at'])}\n\n" ) rows.append([ InlineKeyboardButton( text=f"#{o['order_id']} — مشاهده کامل", callback_data=f"admin2:order:{o['order_id']}" ) ]) nav = [] if page > 0: target = ( f"admin2:orders:{status}:{page - 1}" if status else f"admin2:orders:{page - 1}" ) nav.append( InlineKeyboardButton( text=f"{get_pe('back_arrow')} قبلی", callback_data=target ) ) if start + per_page < len(orders): target = ( f"admin2:orders:{status}:{page + 1}" if status else f"admin2:orders:{page + 1}" ) nav.append( InlineKeyboardButton( text=f"بعدی {get_pe('next')}", callback_data=target ) ) if nav: rows.append(nav) rows.append([ InlineKeyboardButton( text=f"{get_pe('home')} پنل مدیریت", callback_data="admin2:panel" ) ]) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( text, reply_markup=_admin2_kb(rows) ) # ───────────────────────────────────────────────────────────────────── # Order details + customer details # ───────────────────────────────────────────────────────────────────── @router.callback_query(F.data.startswith("admin2:order:"), IsAdmin()) async def cb_admin2_order(callback: CallbackQuery) -> None: await callback.answer() order_id = int(callback.data.split(":")[2]) order = await get_order(order_id) if not order: await callback.answer("سفارش پیدا نشد.", show_alert=True) return pool = await get_pool() user = await pool.fetchrow( "SELECT * FROM users WHERE user_id = $1", order["user_id"] ) username = ( f"@{user['username']}" if user and user["username"] else "—" ) full_name = user["full_name"] if user else "—" details = order["details"] or "—" text = ( f"{get_pe('box')} جزئیات کامل سفارش #{order_id}\n\n" f"{get_pe('user')} نام: {full_name}\n" f"{get_pe('telegram')} یوزرنیم: {username}\n" f"{get_pe('shield')} User ID: {order['user_id']}\n\n" f"{get_pe('shopping')} محصول: {order['product']}\n" f"{get_pe('money')} مبلغ: {_safe_amount(order['amount_irt'])} تومان\n" f"{get_pe('chart')} وضعیت: {_status_fa(order['status'])}\n" f"{get_pe('calendar')} تاریخ: {_admin2_date(order['created_at'])}\n\n" f"{get_pe('box')} جزئیات سفارش:\n" f"{details}" ) rows = [ [ InlineKeyboardButton( text=f"{get_pe('user')} پروفایل کاربر", callback_data=f"admin2:user:{order['user_id']}" ) ], [ InlineKeyboardButton( text=f"{get_pe('check')} تحویل", callback_data=f"admin:deliver:{order_id}" ), InlineKeyboardButton( text=f"{get_pe('cross')} لغو", callback_data=f"admin:cancel:{order_id}" ), ], [ InlineKeyboardButton( text=f"{get_pe('back_arrow')} سفارش‌ها", callback_data="admin2:orders:0" ), InlineKeyboardButton( text=f"{get_pe('home')} پنل", callback_data="admin2:panel" ) ], ] with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( text, reply_markup=_admin2_kb(rows) ) # ───────────────────────────────────────────────────────────────────── # User payments # ───────────────────────────────────────────────────────────────────── @router.callback_query(F.data.startswith("admin2:userpayments:"), IsAdmin()) async def cb_admin2_userpayments(callback: CallbackQuery) -> None: await callback.answer() _, _, user_id, page = callback.data.split(":") user_id = int(user_id) page = int(page) result = await _admin2_user_stats(user_id) if not result: await callback.answer("کاربر پیدا نشد.", show_alert=True) return _, _, payments = result per_page = 8 start = page * per_page items = payments[start:start + per_page] text = ( f"{get_pe('money')} پرداخت‌های کاربر\n" f"User ID: {user_id}\n" f"تعداد: {len(payments)}\n\n" ) for pay in items: text += ( f"{get_pe('money')} سفارش: #{pay['order_id']}\n" f"مبلغ: {_safe_amount(pay['amount_irt'])} تومان\n" f"کیف پول: {_safe_amount(pay['wallet_used'])} تومان\n" f"وضعیت پرداخت: {pay['status']}\n" f"محصول: {pay['product'] or '—'}\n\n" ) rows = [] nav = [] if page > 0: nav.append( InlineKeyboardButton( text=f"{get_pe('back_arrow')} قبلی", callback_data=f"admin2:userpayments:{user_id}:{page - 1}" ) ) if start + per_page < len(payments): nav.append( InlineKeyboardButton( text=f"بعدی {get_pe('next')}", callback_data=f"admin2:userpayments:{user_id}:{page + 1}" ) ) if nav: rows.append(nav) rows.append([ InlineKeyboardButton( text=f"{get_pe('user')} پروفایل کاربر", callback_data=f"admin2:user:{user_id}" ) ]) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( text, reply_markup=_admin2_kb(rows) ) # ───────────────────────────────────────────────────────────────────── # Statistics # ───────────────────────────────────────────────────────────────────── @router.callback_query(F.data == "admin2:stats", IsAdmin()) async def cb_admin2_stats(callback: CallbackQuery) -> None: await callback.answer() users = await get_total_users() pending = await get_order_count_by_status("pending") paid = await get_order_count_by_status("paid") delivered = await get_order_count_by_status("delivered") cancelled = await get_order_count_by_status("cancelled") text = ( f"{get_pe('chart')} آمار کامل ربات\n\n" f"{get_pe('users')} کاربران: {users}\n\n" f"{get_pe('yellow_circle')} در انتظار: {pending}\n" f"{get_pe('green_circle')} پرداخت‌شده: {paid}\n" f"{get_pe('check')} تکمیل‌شده: {delivered}\n" f"{get_pe('cross')} لغوشده: {cancelled}\n\n" f"{get_pe('money')} درآمد امروز: " f"{_safe_amount(await get_revenue_by_period('today'))} تومان\n" f"{get_pe('calendar')} درآمد این هفته: " f"{_safe_amount(await get_revenue_by_period('week'))} تومان\n" f"{get_pe('calendar')} درآمد این ماه: " f"{_safe_amount(await get_revenue_by_period('month'))} تومان\n" f"{get_pe('diamond')} درآمد کل: " f"{_safe_amount(await get_revenue_by_period('all'))} تومان" ) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( text, reply_markup=_admin2_kb([ [ InlineKeyboardButton( text=f"{get_pe('home')} پنل مدیریت", callback_data="admin2:panel" ) ] ]) ) # ───────────────────────────────────────────────────────────────────── # Finance # ───────────────────────────────────────────────────────────────────── @router.callback_query(F.data == "admin2:finance", IsAdmin()) async def cb_admin2_finance(callback: CallbackQuery) -> None: await callback.answer() today = await get_revenue_by_period("today") week = await get_revenue_by_period("week") month = await get_revenue_by_period("month") total = await get_revenue_by_period("all") text = ( f"{get_pe('money')} گزارش مالی\n\n" f"{get_pe('calendar')} امروز:\n" f"{_safe_amount(today)} تومان\n\n" f"{get_pe('calendar')} این هفته:\n" f"{_safe_amount(week)} تومان\n\n" f"{get_pe('calendar')} این ماه:\n" f"{_safe_amount(month)} تومان\n\n" f"{get_pe('diamond')} کل:\n" f"{_safe_amount(total)} تومان" ) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( text, reply_markup=_admin2_kb([ [ InlineKeyboardButton( text=f"{get_pe('home')} پنل مدیریت", callback_data="admin2:panel" ) ] ]) ) # ───────────────────────────────────────────────────────────────────── # /admin2 command # ───────────────────────────────────────────────────────────────────── @router.message(Command("admin2"), IsAdmin()) async def cmd_admin2(message: Message, state: FSMContext) -> None: await state.clear() users = await get_total_users() pending = await get_order_count_by_status("pending") paid = await get_order_count_by_status("paid") delivered = await get_order_count_by_status("delivered") text = ( f"{get_pe('shield')} پنل مدیریت کامل\n\n" f"{get_pe('users')} کاربران: {users}\n" f"{get_pe('yellow_circle')} در انتظار: {pending}\n" f"{get_pe('green_circle')} پرداخت‌شده: {paid}\n" f"{get_pe('check')} تکمیل‌شده: {delivered}" ) await message.answer( text, reply_markup=_admin2_kb([ [ InlineKeyboardButton( text=f"{get_pe('users')} کاربران", callback_data="admin2:users:0" ), InlineKeyboardButton( text=f"{get_pe('chart')} سفارش‌ها", callback_data="admin2:orders:0" ), ], [ InlineKeyboardButton( text=f"{get_pe('yellow_circle')} در انتظار", callback_data="admin2:orders:pending:0" ), InlineKeyboardButton( text=f"{get_pe('green_circle')} پرداخت‌شده", callback_data="admin2:orders:paid:0" ), ], [ InlineKeyboardButton( text=f"{get_pe('check')} تکمیل‌شده", callback_data="admin2:orders:delivered:0" ), InlineKeyboardButton( text=f"{get_pe('cross')} لغوشده", callback_data="admin2:orders:cancelled:0" ), ], [ InlineKeyboardButton( text=f"{get_pe('money')} مالی", callback_data="admin2:finance" ), InlineKeyboardButton( text=f"{get_pe('chart')} آمار", callback_data="admin2:stats" ), ], ]) ) logger = logging.getLogger(__name__) def _status_fa(status: str) -> str: return { "pending": "در انتظار", "paid": "پرداخت شده", "delivered": "تحویل شده", "cancelled": "لغو شده", }.get(status, status) def _safe_amount(amount: int) -> str: return f"{amount:,}".replace(",", "،") if amount else "—" # ═══════════════════════════════════════════════════════════════════════ # REPLY KEYBOARD HANDLERS (text buttons) # ═══════════════════════════════════════════════════════════════════════ @router.message(F.text.contains("ورود به پنل مدیریت"), IsAdmin()) async def reply_btn_admin_panel(message: Message, state: FSMContext) -> None: """Open admin dashboard when the admin taps the reply keyboard button.""" await _show_admin_dashboard(message, state) @router.message(F.text.contains("بازگشت به منوی اصلی"), IsAdmin()) async def reply_btn_back_to_main(message: Message, state: FSMContext) -> None: """Return to the normal user keyboard.""" await state.clear() await message.answer( f"{get_pe('home')} منوی اصلی\nیک سرویس را انتخاب کنید:", reply_markup=main_reply_kb(), ) # ═══════════════════════════════════════════════════════════════════════ # COMMAND HANDLERS # ═══════════════════════════════════════════════════════════════════════ @router.message(Command("admin"), IsAdmin()) async def cmd_admin(message: Message, state: FSMContext) -> None: """Open admin dashboard — protected by IsAdmin filter.""" await _show_admin_dashboard(message, state) @router.message(Command("stats"), IsAdmin()) async def cmd_stats(message: Message) -> None: """Show quick bot statistics for admins — protected by IsAdmin filter.""" user_count = await get_total_users() pending = await get_order_count_by_status("pending") paid = await get_order_count_by_status("paid") delivered = await get_order_count_by_status("delivered") cancelled = await get_order_count_by_status("cancelled") today_rev = await get_revenue_by_period("today") month_rev = await get_revenue_by_period("month") total_rev = await get_revenue_by_period("all") open_tickets = await get_open_tickets() await message.answer( f"{get_pe('chart')} آمار سریع ربات\n\n" f"{get_pe('users')} کل کاربران: {user_count}\n" f"{get_pe('yellow_circle')} سفارشات در انتظار: {pending}\n" f"{get_pe('green_circle')} پرداخت شده: {paid}\n" f"{get_pe('check')} انجام شده: {delivered}\n" f"{get_pe('cross')} لغو شده: {cancelled}\n\n" f"{get_pe('ticket')} تیکت‌های باز: {len(open_tickets)}\n\n" f"{get_pe('money')} درآمد امروز: {_safe_amount(today_rev)} تومان\n" f"{get_pe('calendar')} درآمد ماهانه: {_safe_amount(month_rev)} تومان\n" f"{get_pe('diamond')} درآمد کل: {_safe_amount(total_rev)} تومان", reply_markup=admin_reply_kb(), ) @router.message(Command("test_emojis"), F.from_user.id == 6756840637) async def debug_test_emojis(message: Message): """Debug command to test premium emoji IDs and report broken ones.""" await message.answer(f"{get_pe('search')} در حال تست ایموجی‌های پرمیوم... این کار حدود ۲۰ ثانیه زمان می‌برد.") failed_emojis = [] for key, data in PREMIUM_EMOJIS.items(): fallback, premium_id = data if not premium_id: continue test_text = f"Test {key}: {fallback}" try: # Explicitly parse_mode="HTML" just in case global default is missing await message.bot.send_message( chat_id=6756840637, text=test_text, parse_mode="HTML" ) await asyncio.sleep(0.3) # Anti-flood delay except Exception: # If it fails (e.g., DOCUMENT_INVALID), record the broken key failed_emojis.append(f"Key: {key} | ID: {premium_id}") if failed_emojis: report = f"{get_pe('warning')} این ایموجی‌ها نامعتبر هستند و باعث کرش ربات می‌شوند:\n\n" + "\n".join(failed_emojis) else: report = f"{get_pe('check')} تمامی ایموجی‌ها سالم هستند!" await message.bot.send_message(chat_id=6756840637, text=report) @router.message(Command("users"), IsAdmin()) async def cmd_users(message: Message) -> None: """Show the total number of registered users — protected by IsAdmin filter.""" from database.db import get_pool pool = await get_pool() rows = await pool.fetch( "SELECT user_id, username, full_name, is_admin, joined_at " "FROM users ORDER BY joined_at DESC LIMIT 50" ) if not rows: await message.answer(f"{get_pe('users')} هیچ کاربری ثبت‌نام نکرده است.", reply_markup=admin_reply_kb()) return lines = [f"{get_pe('users')} لیست کاربران (تا ۵۰ نفر آخر)\n"] for r in rows: admin_tag = " "+get_pe('shield') if r["is_admin"] else "" username = f"@{r['username']}" if r["username"] else "—" lines.append( f"• {r['user_id']} | {r['full_name']} | {username}{admin_tag}" ) lines.append(f"\nتعداد کل: {len(rows)} کاربر") await message.answer("\n".join(lines), reply_markup=admin_reply_kb()) # ═══════════════════════════════════════════════════════════════════════ # ADMIN GUIDE / HELP # ═══════════════════════════════════════════════════════════════════════ @router.callback_query(F.data == "admin:guide", IsAdmin()) async def cb_admin_guide(callback: CallbackQuery) -> None: """Show the admin guide — how to use the panel, respond to tickets, broadcast.""" await callback.answer() guide_text = ( f"{get_pe('star')} راهنمای مدیران\n\n" f"{get_pe('num1')} {get_pe('chart')} آمار کاربران\n" " تعداد کل کاربران ثبت‌شده و وضعیت سفارشات را نمایش می‌دهد.\n\n" f"{get_pe('num2')} {get_pe('blue_heart')} ارسال پیام همگانی (Broadcast)\n" " متنی بنویسید و آن را به تمام کاربران ربات ارسال کنید.\n" " پیش از ارسال، پیش‌نمایشی از پیام نمایش داده می‌شود.\n" " پس از تأیید، ربات به هر کاربر یک پیام ارسال می‌کند.\n\n" f"{get_pe('num3')} {get_pe('ticket')} مدیریت تیکت‌ها\n" " وقتی کاربری تیکت پشتیبانی ارسال کند، پیام او برای شما\n" " فوروارد می‌شود. روی دکمه «پاسخ» کلیک کنید و پاسخ خود\n" " را بنویسید. پاسخ شما برای کاربر ارسال خواهد شد.\n" f" همچنین می‌توانید تیکت را بدون پاسخ با «{get_pe('check')} بستن تیکت» ببندید.\n\n" f"{get_pe('small_blue_diamond')} {get_pe('money')} مدیریت قیمت محصولات\n" " قیمت پایه محصولات (به دلار) را ویرایش کنید.\n" " قیمت نهایی = (قیمت دلاری × نرخ لحظه‌ای ارز) × (۱ + ۲۰٪)\n\n" f"{get_pe('small_blue_diamond')} {get_pe('exchange')} حاشیه سود اکانت‌ها\n" " درصد حاشیه سود اکانت‌های شماره مجازی را تنظیم کنید.\n" " قیمت نهایی = قیمت پایه × (۱ + حاشیه سود٪)\n\n" f"{get_pe('small_blue_diamond')} {get_pe('chart')} گزارش مالی\n" " درآمد امروز، هفتگی، ماهانه و کل را مشاهده کنید.\n\n" f"{get_pe('small_blue_diamond')} {get_pe('ticket')} سفارشات\n" " سفارشات در انتظار، پرداخت شده، تکمیل شده و لغو شده.\n" " سفارشات پرداخت شده را پس از انجام، به «انجام شده» تغییر\n" " دهید تا به کاربر اطلاع‌رسانی شود.\n\n" f"{get_pe('key_lock')} دستورات سریع:\n" " /admin — باز کردن پنل مدیریت\n" " /stats — آمار سریع\n" " /users — لیست کاربران" ) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( guide_text, reply_markup=admin_back_kb(), ) # ═══════════════════════════════════════════════════════════════════════ # INTERNAL HELPERS # ═══════════════════════════════════════════════════════════════════════ async def _show_admin_dashboard(message: Message, state: FSMContext) -> None: """Display the admin dashboard with inline keyboard.""" await state.clear() user_count = await get_total_users() await message.answer( f"{get_pe('gear')} پنل مدیریت\n\n" f"{get_pe('users')} تعداد کاربران: {user_count}\n\n" "یک عملیات را انتخاب کنید:", reply_markup=admin_panel_kb(user_count), ) # ═══════════════════════════════════════════════════════════════════════ # INLINE CALLBACK HANDLERS (all protected by IsAdmin filter) # ═══════════════════════════════════════════════════════════════════════ @router.callback_query(F.data == "admin:panel", IsAdmin()) async def cb_admin_panel(callback: CallbackQuery, state: FSMContext) -> None: await callback.answer() await state.clear() user_count = await get_total_users() with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( f"{get_pe('gear')} پنل مدیریت\n\n" f"{get_pe('users')} تعداد کاربران: {user_count}\n\n" "یک عملیات را انتخاب کنید:", reply_markup=admin_panel_kb(user_count), ) @router.callback_query(F.data == "admin:users_stat", IsAdmin()) async def cb_admin_users_stat(callback: CallbackQuery) -> None: await callback.answer() user_count = await get_total_users() pending_count = await get_order_count_by_status("pending") paid_count = await get_order_count_by_status("paid") delivered_count = await get_order_count_by_status("delivered") cancelled_count = await get_order_count_by_status("cancelled") with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( f"{get_pe('users')} آمار کاربران و سفارشات\n\n" f"{get_pe('user')} کل کاربران: {user_count}\n" f"{get_pe('yellow_circle')} سفارشات در انتظار: {pending_count}\n" f"{get_pe('green_circle')} سفارشات پرداخت شده: {paid_count}\n" f"{get_pe('check')} سفارشات انجام شده: {delivered_count}\n" f"{get_pe('cross')} سفارشات لغو شده: {cancelled_count}", reply_markup=admin_back_kb(), ) @router.callback_query(F.data == "admin:pending", IsAdmin()) async def cb_admin_pending(callback: CallbackQuery) -> None: await callback.answer() orders = await get_all_orders(status="pending") if not orders: with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( f"{get_pe('ticket')} سفارش در انتظاری وجود ندارد.", reply_markup=admin_back_kb(), ) else: lines = [f"{get_pe('ticket')} سفارش‌های در انتظار\n"] for o in orders[:20]: lines.append( f"#{o['order_id']} | {o['product']} | " f"{_safe_amount(o['amount_irt'])} تومان | کاربر: {o['user_id']}" ) text = "\n".join(lines) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text(text, reply_markup=admin_back_kb()) @router.callback_query(F.data == "admin:paid_orders", IsAdmin()) async def cb_admin_paid_orders(callback: CallbackQuery) -> None: await callback.answer() orders = await get_all_orders(status="paid") if not orders: with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( f"{get_pe('ticket')} سفارش پرداخت شده‌ای برای پردازش وجود ندارد.", reply_markup=admin_back_kb(), ) else: lines = [f"{get_pe('check')} سفارشات پرداخت شده (نیاز به پردازش)\n"] for o in orders[:20]: lines.append( f"#{o['order_id']} | {o['product']} | " f"{_safe_amount(o['amount_irt'])} تومان | کاربر: {o['user_id']}" ) lines.append("\nروی سفارش مورد نظر کلیک کنید:") from aiogram.types import InlineKeyboardButton, InlineKeyboardMarkup from utils.emojis import get_plain_emoji buttons = [] for o in orders[:10]: buttons.append([InlineKeyboardButton( text=f"{get_plain_emoji('box')} #{o['order_id']} — {o['product'][:30]}", callback_data=f"admin:view_paid:{o['order_id']}", )]) buttons.append([InlineKeyboardButton( text=f"{get_plain_emoji('home')} پنل مدیریت", callback_data="admin:panel", )]) kb = InlineKeyboardMarkup(inline_keyboard=buttons) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text("\n".join(lines), reply_markup=kb) @router.callback_query(F.data.startswith("admin:view_paid:"), IsAdmin()) async def cb_admin_view_paid(callback: CallbackQuery) -> None: await callback.answer() order_id = int(callback.data.split(":")[3]) order = await get_order(order_id) if not order: await callback.answer(f"{get_pe('warning')} سفارش یافت نشد.", show_alert=True) return with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( f"{get_pe('star')} جزئیات سفارش #{order['order_id']}\n\n" f"{get_pe('user')} شناسه کاربر: {order['user_id']}\n" f"{get_pe('box')} محصول: {order['product']}\n" f"{get_pe('note')} جزئیات: {order['details'] or '—'}\n" f"{get_pe('money')} مبلغ: {_safe_amount(order['amount_irt'])} تومان\n" f"{get_pe('calendar')} تاریخ: {order['created_at'][:16] if order['created_at'] else '—'}\n" f"{get_pe('chart')} وضعیت: {get_pe('green_circle')} پرداخت شده\n\n" "عملیات مورد نظر را انتخاب کنید:", reply_markup=admin_paid_order_kb(order_id), ) @router.callback_query(F.data.startswith("admin:complete:"), IsAdmin()) async def cb_admin_complete(callback: CallbackQuery) -> None: await callback.answer() order_id = int(callback.data.split(":")[2]) order = await get_order(order_id) if not order: await callback.answer(f"{get_pe('warning')} سفارش یافت نشد.", show_alert=True) return await update_order_status(order_id, "delivered") try: await callback.bot.send_message( order["user_id"], f"{get_pe('check')} سفارش شما تکمیل شد!\n\n" f"{get_pe('box')} شماره سفارش: #{order_id}\n" f"{get_pe('shopping')} محصول: {order['product']}\n\n" f"از خرید شما متشکریم! {get_pe('check')}" ) except Exception as exc: logger.warning("Could not notify user %s: %s", order["user_id"], exc) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( f"{get_pe('check')} سفارش #{order_id} به عنوان انجام شده ثبت شد.\n" f"{get_pe('user')} به کاربر {order['user_id']} اطلاع‌رسانی شد.", reply_markup=admin_back_kb(), ) @router.callback_query(F.data == "admin:completed", IsAdmin()) async def cb_admin_completed(callback: CallbackQuery) -> None: await callback.answer() orders = await get_all_orders(status="delivered") if not orders: with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( f"{get_pe('check')} هنوز سفارش تکمیل شده‌ای وجود ندارد.", reply_markup=admin_back_kb(), ) else: lines = [f"{get_pe('check')} سفارش‌های تکمیل شده\n"] for o in orders[:20]: lines.append(f"#{o['order_id']} | {o['product']} | {_safe_amount(o['amount_irt'])} تومان") with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text("\n".join(lines), reply_markup=admin_back_kb()) @router.callback_query(F.data == "admin:all_orders", IsAdmin()) async def cb_admin_all(callback: CallbackQuery) -> None: await callback.answer() orders = await get_all_orders() if not orders: with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text(f"{get_pe('ticket')} سفارشی یافت نشد.", reply_markup=admin_back_kb()) else: lines = [f"{get_pe('chart')} تمام سفارش‌ها\n"] for o in orders[:20]: status_e = {"pending": get_pe('yellow_circle'), "paid": get_pe('green_circle'), "delivered": get_pe('check'), "cancelled": get_pe('cross')}.get(o["status"], get_pe('question')) lines.append( f"#{o['order_id']} | {o['product']} | " f"{_safe_amount(o['amount_irt'])} تومان | {status_e} {_status_fa(o['status'])}" ) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text("\n".join(lines), reply_markup=admin_back_kb()) @router.callback_query(F.data == "admin:finance", IsAdmin()) async def cb_admin_finance(callback: CallbackQuery) -> None: await callback.answer() today = await get_revenue_by_period("today") week = await get_revenue_by_period("week") month = await get_revenue_by_period("month") total = await get_revenue_by_period("all") with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( f"{get_pe('chart')} گزارش مالی\n\n" f"{get_pe('calendar')} درآمد امروز: {_safe_amount(today)} تومان\n" f"{get_pe('calendar')} درآمد هفتگی: {_safe_amount(week)} تومان\n" f"{get_pe('calendar')} درآمد ماهانه: {_safe_amount(month)} تومان\n" f"{get_pe('money')} درآمد کل: {_safe_amount(total)} تومان\n\n" "شامل سفارشات پرداخت شده و انجام شده.", reply_markup=admin_finance_kb(), ) @router.callback_query(F.data == "admin:account_margin", IsAdmin()) async def cb_admin_account_margin(callback: CallbackQuery, state: FSMContext) -> None: """Show current account profit margin and allow admin to change it.""" await callback.answer() from database.db import get_profit_margin current_margin = await get_profit_margin(config.ACCOUNT_PROFIT_MARGIN_PERCENT) await state.set_state(AccountMarginState.waiting_for_margin) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( f"{get_pe('exchange')} حاشیه سود اکانت‌ها\n\n" f"{get_pe('money')} حاشیه فعلی: {current_margin}%\n\n" "لطفاً درصد جدید را ارسال کنید:\n" "(مثال: 30 برای ۳۰٪ حاشیه سود)\n\n" "قیمت نهایی = قیمت پایه × (۱ + حاشیه سود٪)", reply_markup=admin_back_kb(), ) @router.message(AccountMarginState.waiting_for_margin) async def msg_account_margin_input(message: Message, state: FSMContext) -> None: """Receive new account profit margin value and persist it to the DB.""" if not await IsAdmin()(message): return text = message.text.strip() try: new_margin = float(text) if new_margin < 0 or new_margin > 500: raise ValueError except ValueError: await message.answer(f"{get_pe('warning')} لطفاً عددی بین ۰ تا ۵۰۰ ارسال کنید.") return # Persist to DB so it applies immediately (and survives restarts) from database.db import set_profit_margin await set_profit_margin(new_margin) # Keep the in-memory value in sync for any code reading config directly config.ACCOUNT_PROFIT_MARGIN_PERCENT = new_margin await state.clear() try: await message.delete() except Exception: pass await message.answer( f"{get_pe('check')} حاشیه سود اکانت‌ها بروزرسانی شد!\n\n" f"{get_pe('exchange')} حاشیه جدید: {new_margin}%\n\n" f"{get_pe('idea')} قیمت نهایی اکانت‌ها = قیمت پایه × (۱ + {new_margin}٪)", reply_markup=admin_back_kb(), ) @router.callback_query(F.data == "admin:broadcast", IsAdmin()) async def cb_admin_broadcast(callback: CallbackQuery, state: FSMContext) -> None: await callback.answer() await state.set_state(AdminStates.broadcast_message) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( f"{get_pe('blue_heart')} ارسال پیام همگانی\n\n" "متن پیامی که می‌خواهید به تمام کاربران ارسال شود را بنویسید.\n\n" "برای انصراف روی «پنل مدیریت» کلیک کنید.", reply_markup=admin_back_kb(), ) @router.message(AdminStates.broadcast_message) async def msg_broadcast_text(message: Message, state: FSMContext) -> None: if not await IsAdmin()(message): return text = message.text.strip() if len(text) < 2: await message.answer(f"{get_pe('warning')} پیام نمی‌تواند خالی باشد.") return await state.update_data(broadcast_text=text) from aiogram.types import InlineKeyboardMarkup, InlineKeyboardButton from utils.emojis import get_plain_emoji preview_kb = InlineKeyboardMarkup(inline_keyboard=[ [InlineKeyboardButton(text=f"{get_plain_emoji('check')} ارسال به همه", callback_data="admin:broadcast:send")], [InlineKeyboardButton(text=f"{get_plain_emoji('cross')} انصراف", callback_data="admin:panel")], ]) await message.answer( f"{get_pe('blue_heart')} پیش‌نمایش پیام همگانی:\n\n" f"{text}\n\n" "این پیام به تمام کاربران ثبت‌شده ارسال خواهد شد.\n" "آیا مطمئن هستید؟", reply_markup=preview_kb, ) @router.callback_query(F.data == "admin:broadcast:send", IsAdmin()) async def cb_broadcast_send(callback: CallbackQuery, state: FSMContext) -> None: await callback.answer() data = await state.get_data() broadcast_text = data.get("broadcast_text") if not broadcast_text: await callback.answer(f"{get_pe('warning')} متن پیام یافت نشد.", show_alert=True) return await state.clear() users = await get_all_users() total = len(users) sent = 0 failed = 0 await callback.message.edit_text( f"{get_pe('blue_heart')} در حال ارسال پیام همگانی...\n\n" f"{get_pe('users')} تعداد کل کاربران: {total}\n" "لطفاً صبر کنید...", reply_markup=admin_back_kb(), ) for user_row in users: user_id = user_row["user_id"] try: await callback.bot.send_message(user_id, broadcast_text) sent += 1 except Exception: failed += 1 await asyncio.sleep(0.05) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( f"{get_pe('blue_heart')} ارسال پیام همگانی تکمیل شد!\n\n" f"{get_pe('users')} کل کاربران: {total}\n" f"{get_pe('check')} موفق: {sent}\n" f"{get_pe('cross')} ناموفق: {failed}", reply_markup=admin_back_kb(), ) @router.callback_query(F.data == "admin:tickets", IsAdmin()) async def cb_admin_tickets(callback: CallbackQuery) -> None: """Show open support tickets.""" await callback.answer() open_tickets = await get_open_tickets() if not open_tickets: with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( f"{get_pe('ticket')} تیکت‌های باز\n\nهیچ تیکت بازی وجود ندارد.", reply_markup=admin_back_kb(), ) else: lines = [f"{get_pe('ticket')} تیکت‌های باز ({len(open_tickets)})\n"] for t in open_tickets[:20]: lines.append( f"#{t['ticket_id']} | {get_pe('user')} {t['full_name']} | " f"{get_pe('calendar')} {t['created_at'][:16] if t['created_at'] else '—'}\n" f" {get_pe('comment')} {t['message'][:80]}{'…' if len(t['message']) > 80 else ''}\n" f" {get_pe('pointing')} پاسخ: /reply_{t['user_id']}" ) lines.append("\nبرای پاسخ، دستور پاسخ زیر هر تیکت را ارسال کنید.") with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text("\n".join(lines), reply_markup=admin_back_kb()) @router.callback_query(F.data == "admin:prices", IsAdmin()) async def cb_admin_prices(callback: CallbackQuery, state: FSMContext) -> None: """Show the inline product list with live DB prices. This is the "Single-Message Panel" — the same message is edited at each step, keeping the chat clean. """ await callback.answer() await state.clear() price_rows = await get_all_product_prices() if not price_rows: with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( f"{get_pe('money')} هیچ محصولی یافت نشد.", reply_markup=admin_back_kb(), ) return # Build the list of dicts for the keyboard builder products = [ { "product_key": row["product_key"], "label": row["label"], "usd_price": float(row["usd_price"]), } for row in price_rows ] text = ( f"{get_pe('money')} مدیریت قیمت محصولات\n\n" "روی محصول مورد نظر کلیک کنید تا قیمت آن را ویرایش کنید:" ) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( text, reply_markup=product_list_kb(products), ) # ─── ProductCallback: SELECT (show detail view) ───────────────────── @router.callback_query( ProductCallback.filter(F.action == "select"), IsAdmin(), ) async def cb_product_select( callback: CallbackQuery, callback_data: ProductCallback, state: FSMContext, ) -> None: """Show product details with an "ویرایش قیمت" inline button. This edits the same message — no new messages in the chat. """ await callback.answer() await state.clear() key = callback_data.product_key price_rows = await get_all_product_prices() product = next((r for r in price_rows if r["product_key"] == key), None) if not product: await callback.answer(f"{get_pe('warning')} محصول یافت نشد.", show_alert=True) return label = product["label"] price = float(product["usd_price"]) text = ( f"{get_pe('box')} جزئیات محصول\n\n" f"{get_pe('tag')} نام: {label}\n" f"{get_pe('key_icon')} کلید: {key}\n" f"{get_pe('money')} قیمت فعلی: ${price:.2f}\n\n" f"{get_pe('idea')} قیمت نهایی = (قیمت دلاری × نرخ ارز) × (۱ + ۲۰٪ حاشیه)" ) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( text, reply_markup=product_detail_kb(key, label, price), ) # ─── ProductCallback: EDIT (enter FSM state) ──────────────────────── @router.callback_query( ProductCallback.filter(F.action == "edit"), IsAdmin(), ) async def cb_product_edit( callback: CallbackQuery, callback_data: ProductCallback, state: FSMContext, ) -> None: """Enter FSM state — ask admin to type the new USD price. Edits the same message to keep the chat clean. """ await callback.answer() key = callback_data.product_key # Store the product key in FSM state so we can retrieve it later await state.update_data(price_key=key) await state.set_state(ProductState.waiting_for_price) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( f"{get_pe('star')} ویرایش قیمت\n\n" f"محصول: {key}\n\n" "لطفاً قیمت جدید را به عدد (دلار) ارسال کنید:\n" "(مثال: 29.99)", reply_markup=admin_back_kb(), ) # ─── ProductState: receive new price text ──────────────────────────── @router.message(ProductState.waiting_for_price) async def msg_product_price_input(message: Message, state: FSMContext) -> None: """Receive the new price, update DB, edit bot message to success. CRITICAL UX: Deletes the admin's text message to keep chat clean, then edits the original bot message to show confirmation. """ if not await IsAdmin()(message): return text = message.text.strip() # Validate the price input try: new_price = float(text) if new_price <= 0: raise ValueError except ValueError: await message.answer(f"{get_pe('warning')} لطفاً یک عدد مثبت معتبر ارسال کنید.") return data = await state.get_data() key = data.get("price_key") if not key: await message.answer(f"{get_pe('warning')} خطا: کلید محصول یافت نشد. لطفاً دوباره از پنل شروع کنید.") await state.clear() return old_price = await get_price_or_default(key) updated = await update_product_price(key, new_price) # CRITICAL UX: Delete the admin's text message to keep chat clean try: await message.delete() except Exception: pass # message may already be deleted or permissions issue await state.clear() if not updated: # Try to find the original message to edit it try: await message.answer( f"{get_pe('warning')} خطا در به‌روزرسانی قیمت {key}.", reply_markup=admin_back_kb(), ) except Exception: pass return # Success: edit the original bot message to show confirmation success_text = ( f"{get_pe('check')} قیمت با موفقیت بروزرسانی شد.\n\n" f"{get_pe('box')} محصول: {key}\n" f"{get_pe('money')} قیمت قبلی: ${old_price:.2f}\n" f"{get_pe('money')} قیمت جدید: ${new_price:.2f}\n\n" f"{get_pe('idea')} قیمت نهایی = (قیمت دلاری × نرخ ارز) × (۱ + ۲۰٪ حاشیه)" ) try: await message.answer( success_text, reply_markup=product_edit_success_kb(), ) except Exception: pass # NOTE: The old AdminStates.edit_price_key and edit_price_value handlers # have been replaced by the inline ProductCallback system above. # See: cb_admin_prices → cb_product_select → cb_product_edit → msg_product_price_input @router.callback_query(F.data.startswith("admin:deliver:"), IsAdmin()) async def cb_admin_deliver(callback: CallbackQuery) -> None: await callback.answer() order_id = int(callback.data.split(":")[2]) order = await get_order(order_id) await update_order_status(order_id, "delivered") if order: try: await callback.bot.send_message( order["user_id"], f"{get_pe('check')} سفارش شما تکمیل شد!\n\n" f"{get_pe('box')} شماره سفارش: #{order_id}\n" f"{get_pe('shopping')} محصول: {order['product']}\n\n" f"از خرید شما متشکریم! {get_pe('check')}" ) except Exception as exc: logger.warning("Could not notify user %s: %s", order["user_id"], exc) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( f"{get_pe('check')} سفارش #{order_id} به عنوان تحویل شده ثبت شد.", reply_markup=admin_back_kb(), ) @router.callback_query(F.data.startswith("admin:cancel:"), IsAdmin()) async def cb_admin_cancel(callback: CallbackQuery) -> None: await callback.answer() order_id = int(callback.data.split(":")[2]) order = await get_order(order_id) await update_order_status(order_id, "cancelled") if order: try: await callback.bot.send_message( order["user_id"], f"{get_pe('cross')} سفارش شما لغو شد.\n\n" f"{get_pe('box')} شماره سفارش: #{order_id}\n" f"{get_pe('shopping')} محصول: {order['product']}\n\n" "اگر سؤالی دارید با پشتیبانی تماس بگیرید." ) except Exception as exc: logger.warning("Could not notify user %s: %s", order["user_id"], exc) with contextlib.suppress(TelegramBadRequest): await callback.message.edit_text( f"{get_pe('cross')} سفارش #{order_id} لغو شد.", reply_markup=admin_back_kb(), )