# پنل مدیریت داخل ربات تلگرام — شامل مدیریت پنل‌ها و کاربران پاسارگارد from telegram import Update, InlineKeyboardButton, InlineKeyboardMarkup from telegram.ext import ContextTypes, ConversationHandler from config import ADMIN_ID from database import get_setting, set_setting, list_panels, get_panel_by_id from services.pasarguard import PasarGuardClient, bytes_to_gb WAITING_WELCOME = 1 WAITING_USER_FIELD = 2 # ساخت/ویرایش کاربر چندمرحله‌ای WAITING_ADMIN_TEXT = 41 # جستجو/ارسال همگانی/تنظیمات مدیریت def is_admin(user_id: int) -> bool: if not user_id: return False if user_id == ADMIN_ID: return True try: from db_extras import is_bot_admin_id return is_bot_admin_id(user_id) except Exception: return False def main_keyboard(): def btn(text, data, style=None): kw = {"text": text, "callback_data": data} if style: kw["style"] = style try: return InlineKeyboardButton(**kw) except TypeError: return InlineKeyboardButton(text, callback_data=data) return InlineKeyboardMarkup([ [btn("📊 آمار ربات", "admin_stats", "primary")], [btn("📝 تنظیم پیام‌ها", "admin_msgs"), btn("👋 خوش‌آمدگویی", "admin_welcome")], [btn("🖥 مدیریت پنل‌ها", "admin_panels")], [btn("📦 محصولات", "admin_products"), btn("📁 دسته‌ها", "admin_categories")], [btn("📋 سرویس‌های فروخته‌شده", "admin_orders")], [btn("👥 کاربران ربات", "admin_bot_users")], [btn("📣 ارسال همگانی", "admin_broadcast"), btn("🔎 جستجوی کاربر", "admin_user_search")], [btn("🛠 وب‌پنل", "admin_web"), btn("🎁 رفرال", "admin_referral")], [btn("🌱 رشد و تست", "admin_growth"), btn("🏷 کد هدیه", "admin_gifts")], [btn("🤝 نمایندگی‌ها", "admin_resellers"), btn("🎧 تیکت‌ها", "admin_tickets")], [btn("⭐ امتیاز خرید", "admin_loyalty")], [btn("💳 کارت‌ها / پرداخت", "admin_cards")], [btn("🧾 درخواست‌های شارژ", "admin_charges")], [btn("✨ ایموجی پریمیوم", "admin_premiji"), btn("⌨️ منوی شیشه‌ای", "admin_inline_menu")], [btn("👮 ادمین‌های ربات", "admin_botadmins")], [btn("⏱ سرویس ساعتی", "admin_hourly"), btn("🧹 بهینه‌سازی", "admin_optimize")], [btn("🛡 آنتی‌اسپم", "admin_antispam")], [btn("💾 فاصله بکاپ", "admin_backup_cfg")], [InlineKeyboardButton("📂 گیت‌هاب پروژه", url="https://github.com/FarnoudHosseini/FarnoudBot")], [btn("🏠 منوی اصلی", "admin_to_start")], ]) def panels_keyboard(panels): rows = [] for p in panels: status = "🟢" if p.get("last_status") in ("online", "connected") else "⚪" rows.append([InlineKeyboardButton( f"{status} {p['name']} ({p['panel_type']})", callback_data=f"admin_panel_{p['id']}" )]) rows.append([InlineKeyboardButton("🏠 منوی اصلی", callback_data="admin_to_start")]) return InlineKeyboardMarkup(rows) def panel_menu_keyboard(panel_id: int): try: del_btn = InlineKeyboardButton("🗑 حذف پنل", callback_data=f"admin_pdelete_{panel_id}", style="danger") except TypeError: del_btn = InlineKeyboardButton("🗑 حذف پنل", callback_data=f"admin_pdelete_{panel_id}") return InlineKeyboardMarkup([ [InlineKeyboardButton("📊 وضعیت / آمار", callback_data=f"admin_pstats_{panel_id}")], [InlineKeyboardButton("👥 لیست کاربران VPN", callback_data=f"admin_pusers_{panel_id}")], [InlineKeyboardButton("➕ افزودن کاربر VPN", callback_data=f"admin_padduser_{panel_id}")], [InlineKeyboardButton("📦 سقف فروش", callback_data=f"admin_pmax_{panel_id}")], [InlineKeyboardButton("♻️ روش تمدید", callback_data=f"admin_prenew_{panel_id}")], [del_btn], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panels")], ]) async def admin_panel(update: Update, context: ContextTypes.DEFAULT_TYPE): user = update.effective_user if not user or not is_admin(user.id): if update.message: await update.message.reply_text("⛔️ دسترسی ندارید.") return text = "⚙️ پنل مدیریت فرنود\n\nاز دکمه‌های زیر استفاده کنید." if update.callback_query: await update.callback_query.answer() await update.callback_query.edit_message_text(text, reply_markup=main_keyboard(), parse_mode="HTML") else: await update.message.reply_text(text, reply_markup=main_keyboard(), parse_mode="HTML") async def admin_callback(update: Update, context: ContextTypes.DEFAULT_TYPE): query = update.callback_query await query.answer() user = update.effective_user if not user or not is_admin(user.id): await query.edit_message_text("⛔️ دسترسی ندارید.") return ConversationHandler.END data = query.data # اگر در حال ورود کد/ایموجی پریمیوم بود و دکمه دیگری زده شد، عملیات لغو شود if context.user_data.get("premiji_step") and not (data or "").startswith("admin_premiji"): context.user_data.pop("premiji_step", None) context.user_data.pop("premiji_code", None) if data == "admin_panel": await admin_panel(update, context) return ConversationHandler.END if data == "admin_view_welcome": current = await get_setting("welcome_message", "—") await query.edit_message_text( f"📄 پیام خوش‌آمد فعلی:\n\n{current}", reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")]]), parse_mode="HTML", ) return ConversationHandler.END if data == "set_welcome": await query.edit_message_text( "📝 پیام خوش‌آمد جدید را ارسال کنید.\nبرای انصراف /start بزنید.", parse_mode="HTML", ) return WAITING_WELCOME if data == "admin_close" or data == "admin_to_start": from handlers.wallet import main_user_keyboard from database import get_setting_sync from telegram import ReplyKeyboardRemove use_glass = get_setting_sync("inline_main_menu", "0") == "1" is_adm = is_admin(user.id) if use_glass: try: await query.edit_message_text( "🏠 منوی اصلی", reply_markup=main_user_keyboard(is_admin=is_adm, force_inline=True), ) except Exception: await context.bot.send_message( user.id, "🏠 منوی اصلی", reply_markup=main_user_keyboard(is_admin=is_adm, force_inline=True), ) try: await context.bot.send_message(user.id, "‎", reply_markup=ReplyKeyboardRemove()) except Exception: pass else: try: await query.edit_message_text("🏠 منوی اصلی") except Exception: pass await context.bot.send_message( user.id, "🏠 منوی اصلی", reply_markup=main_user_keyboard(is_admin=is_adm, force_inline=False), ) return ConversationHandler.END # ---- حذف پنل ---- if data.startswith("admin_pdelete_"): pid = int(data.replace("admin_pdelete_", "")) panel = get_panel_by_id(pid) name = (panel or {}).get("name") or str(pid) await query.edit_message_text( f"⚠️ حذف پنل «{name}»؟\nاین عمل قابل بازگشت نیست.", reply_markup=InlineKeyboardMarkup([ [ InlineKeyboardButton("✅ بله، حذف شود", callback_data=f"admin_pdeleteok_{pid}"), InlineKeyboardButton("❌ خیر", callback_data=f"admin_panel_{pid}"), ], ]), ) return ConversationHandler.END if data.startswith("admin_pdeleteok_"): pid = int(data.replace("admin_pdeleteok_", "")) from database import delete_panel ok = delete_panel(pid) await query.edit_message_text( "✅ پنل حذف شد." if ok else "❌ حذف ناموفق.", reply_markup=InlineKeyboardMarkup([ [InlineKeyboardButton("🖥 پنل‌ها", callback_data="admin_panels")], [InlineKeyboardButton("🔙 مدیریت", callback_data="admin_panel")], ]), ) return ConversationHandler.END # ---- پنل‌ها ---- if data == "admin_panels": panels = list_panels() if not panels: await query.edit_message_text( "هنوز پنلی متصل نیست.\nاز پنل وب اضافه کنید.", reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")]]), ) return ConversationHandler.END await query.edit_message_text( "🖥 انتخاب پنل:", reply_markup=panels_keyboard(panels), parse_mode="HTML", ) return ConversationHandler.END if data.startswith("admin_panel_"): pid = int(data.replace("admin_panel_", "")) panel = get_panel_by_id(pid) if not panel: await query.edit_message_text("پنل یافت نشد.") return ConversationHandler.END await query.edit_message_text( f"🖥 {panel['name']}\n{panel['base_url']}\n\nیک گزینه را انتخاب کنید:", reply_markup=panel_menu_keyboard(pid), parse_mode="HTML", ) return ConversationHandler.END if data.startswith("admin_pmax_"): pid=int(data.replace("admin_pmax_","")) panel=get_panel_by_id(pid) context.user_data["admin_input_mode"]="panel_max" context.user_data["admin_panel_id"]=pid await query.edit_message_text( f"📦 سقف فروش «{panel['name'] if panel else '—'}» را بفرستید.\n۰ = بدون محدودیت.\n/cancel برای انصراف" ) return WAITING_ADMIN_TEXT if data.startswith("admin_prenew_"): pid = int(data.replace("admin_prenew_", "")) panel = get_panel_by_id(pid) current = (panel or {}).get("renew_mode") or "reset_both" labels = { "reset_both": "ریست زمان و حجم", "reset_time": "ریست زمان فقط", "reset_volume": "ریست حجم فقط", "additive": "بدون ریست (افزایشی)", } rows = [ [InlineKeyboardButton(f"{'✅ ' if current==k else ''}{v}", callback_data=f"admin_prenewset_{pid}_{k}")] for k, v in labels.items() ] rows.append([InlineKeyboardButton("🔙 بازگشت", callback_data=f"admin_panel_{pid}")]) await query.edit_message_text( f"♻️ روش تمدید پنل «{(panel or {}).get('name') or pid}»\n" f"فعلی: {labels.get(current, current)}", reply_markup=InlineKeyboardMarkup(rows), parse_mode="HTML", ) return ConversationHandler.END if data.startswith("admin_prenewset_"): parts = data.replace("admin_prenewset_", "").split("_", 1) pid, mode = int(parts[0]), parts[1] from database import set_panel_field set_panel_field(pid, "renew_mode", mode) await query.edit_message_text( f"✅ روش تمدید ذخیره شد: {mode}", reply_markup=panel_menu_keyboard(pid), parse_mode="HTML", ) return ConversationHandler.END if data.startswith("admin_pstats_"): pid = int(data.replace("admin_pstats_", "")) panel = get_panel_by_id(pid) if not panel: await query.edit_message_text("پنل یافت نشد.") return ConversationHandler.END try: from services.panel_client import get_panel_client client = get_panel_client(panel) from database import update_panel_status s = client.get_system_stats() or {} if s.get("error"): raise RuntimeError(s.get("error")) update_panel_status(pid, "online") cpu = s.get("cpu_usage", s.get("cpu", "—")) users = s.get("users") or {} total_u = s.get("total_user", s.get("users_total", users.get("total", "—"))) active_u = s.get("users_active", s.get("active_users", users.get("active", "—"))) mem = s.get("mem_used") or s.get("memory_used") mem_t = s.get("mem_total") or s.get("memory_total") mem_s = f"{mem}/{mem_t}" if mem is not None else "—" text = ( f"📊 {panel['name']}\n" f"وضعیت: ✅ آنلاین\n" f"آدرس: {panel['base_url']}\n" f"نوع: {panel.get('panel_type')}\n\n" f"CPU: {cpu}\n" f"رم: {mem_s}\n" f"کاربران کل: {total_u}\n" f"کاربران فعال: {active_u}" ) except Exception as e: try: from database import update_panel_status update_panel_status(pid, "offline") except Exception: pass text = ( f"📊 {panel['name']}\n" f"وضعیت: ❌ آفلاین\n" f"آدرس: {panel['base_url']}\n" f"خطا: {e}" ) await query.edit_message_text( text, reply_markup=panel_menu_keyboard(pid), parse_mode="HTML", ) return ConversationHandler.END if data.startswith("admin_pusers_"): pid = int(data.replace("admin_pusers_", "")) panel = get_panel_by_id(pid) if not panel: await query.edit_message_text("پنل یافت نشد.") return ConversationHandler.END try: client = PasarGuardClient(panel["base_url"], panel["username"], panel["password"], verify_ssl=False) data_u = client.get_users(offset=0, limit=20) users = data_u.get("users") or [] if not users: text = "لیست کاربران خالی است." kb = panel_menu_keyboard(pid) else: rows = [] lines = [f"👥 کاربران {panel['name']} (۲۰ تای اول)\n"] for u in users: uname = u.get("username", "?") st = u.get("status", "?") lines.append(f"• {uname} — {st}") rows.append([ InlineKeyboardButton(f"✏️ {uname}", callback_data=f"admin_pedit_{pid}_{uname}"), InlineKeyboardButton("🗑", callback_data=f"admin_pdel_{pid}_{uname}"), ]) rows.append([InlineKeyboardButton("🔙 بازگشت", callback_data=f"admin_panel_{pid}")]) text = "\n".join(lines) kb = InlineKeyboardMarkup(rows) except Exception as e: text = f"❌ خطا: {e}" kb = panel_menu_keyboard(pid) await query.edit_message_text(text, reply_markup=kb, parse_mode="HTML") return ConversationHandler.END if data.startswith("admin_pdel_"): # admin_pdel_{pid}_{username} rest = data.replace("admin_pdel_", "", 1) pid_str, _, uname = rest.partition("_") pid = int(pid_str) panel = get_panel_by_id(pid) if not panel: await query.edit_message_text("پنل یافت نشد.") return ConversationHandler.END try: PasarGuardClient(panel["base_url"], panel["username"], panel["password"], verify_ssl=False).delete_user(uname) await query.edit_message_text( f"✅ کاربر {uname} حذف شد.", reply_markup=panel_menu_keyboard(pid), parse_mode="HTML", ) except Exception as e: await query.edit_message_text(f"❌ خطا: {e}", reply_markup=panel_menu_keyboard(pid)) return ConversationHandler.END if data.startswith("admin_padduser_"): pid = int(data.replace("admin_padduser_", "")) panel = get_panel_by_id(pid) if not panel: await query.edit_message_text("پنل یافت نشد.") return ConversationHandler.END context.user_data["vpn_panel_id"] = pid context.user_data["vpn_mode"] = "create" context.user_data["vpn_user"] = {} context.user_data["vpn_step"] = "username" await query.edit_message_text( "➕ ساخت کاربر VPN\n\n" "نام کاربری را بفرستید (۳ تا ۳۲ کاراکتر، حروف/عدد/_):\n" "برای انصراف /start", parse_mode="HTML", ) return WAITING_USER_FIELD if data.startswith("admin_pedit_"): rest = data.replace("admin_pedit_", "", 1) pid_str, _, uname = rest.partition("_") pid = int(pid_str) panel = get_panel_by_id(pid) if not panel: await query.edit_message_text("پنل یافت نشد.") return ConversationHandler.END context.user_data["vpn_panel_id"] = pid context.user_data["vpn_mode"] = "edit" context.user_data["vpn_edit_username"] = uname context.user_data["vpn_user"] = {} context.user_data["vpn_step"] = "data_limit" await query.edit_message_text( f"✏️ ویرایش {uname}\n\n" "حد حجم را به گیگابایت بفرستید (0 = نامحدود):\n" "یا بنویسید - برای رد کردن این فیلد.", parse_mode="HTML", ) return WAITING_USER_FIELD if data=="admin_referral": from database import get_setting_sync pct=get_setting_sync("referral_percent","10"); signup=get_setting_sync("referral_signup_bonus","0") cap=get_setting_sync("referral_monthly_cap","0"); minimum=get_setting_sync("referral_min_amount","0") await query.edit_message_text( f"🎁 سیستم رفرال\n\nپورسانت: {pct}%\nپاداش ثبت‌نام: {signup} تومان\nحداقل خرید مشمول: {minimum} تومان\nسقف ماهانه: {cap or '∞'} تومان", parse_mode="HTML", reply_markup=InlineKeyboardMarkup([ [InlineKeyboardButton("درصد پورسانت",callback_data="admin_ref_pct"), InlineKeyboardButton("پاداش ثبت‌نام",callback_data="admin_ref_signup")], [InlineKeyboardButton("حداقل مبلغ",callback_data="admin_ref_min"), InlineKeyboardButton("سقف ماهانه",callback_data="admin_ref_cap")], [InlineKeyboardButton("🔙 بازگشت",callback_data="admin_panel")] ])) return ConversationHandler.END if data.startswith("admin_ref_") and data in ("admin_ref_pct","admin_ref_signup","admin_ref_min","admin_ref_cap"): context.user_data["admin_input_mode"]="ref_"+data.replace("admin_ref_","") await query.edit_message_text("مقدار جدید را فقط به صورت عدد بفرستید:") return WAITING_ADMIN_TEXT if data == "admin_user_search": context.user_data["admin_input_mode"] = "search_users" await query.edit_message_text("🔎 آیدی، یوزرنیم، نام یا شماره کاربر را بفرستید:") return WAITING_ADMIN_TEXT if data == "admin_broadcast": await query.edit_message_text( "📣 نوع ارسال را انتخاب کنید:", reply_markup=InlineKeyboardMarkup([ [InlineKeyboardButton("همگانی", callback_data="admin_bc_all"), InlineKeyboardButton("دارای موجودی", callback_data="admin_bc_balance")], [InlineKeyboardButton("بدون موجودی", callback_data="admin_bc_nobalance"), InlineKeyboardButton("دارای زیرمجموعه", callback_data="admin_bc_refs")], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")], ]), ) return ConversationHandler.END if data.startswith("admin_bc_") and data in ( "admin_bc_all", "admin_bc_balance", "admin_bc_nobalance", "admin_bc_refs" ): mode = data.replace("admin_bc_", "") context.user_data["admin_broadcast_mode"] = mode context.user_data["admin_input_mode"] = "broadcast" await query.edit_message_text( "📝 متن پیام همگانی را بفرستید.\n" "کدهای p_xxxxxxxx به ایموجی پریمیوم تبدیل می‌شوند.\n\n" "/cancel برای انصراف" ) return WAITING_ADMIN_TEXT # انتخاب پین در ارسال همگانی if data in ("admin_bc_pin_yes", "admin_bc_pin_no"): context.user_data["admin_bc_pin"] = data.endswith("_yes") from db_extras import get_menu_buttons items = [x for x in get_menu_buttons() if x.get("enabled", True)] rows = [[InlineKeyboardButton("بدون دکمه", callback_data="admin_bc_btn_none")]] for it in items[:20]: label = (it.get("label") or it.get("key") or "?")[:40] rows.append([InlineKeyboardButton( f"📎 {label}", callback_data=f"admin_bc_btn_{it.get('key') or it.get('callback')}", )]) rows.append([InlineKeyboardButton("🏠 منوی اصلی", callback_data="admin_bc_btn_menu_home")]) rows.append([InlineKeyboardButton("❌ انصراف", callback_data="admin_panel")]) await query.edit_message_text( "📎 دکمه‌ی قابل attach را از لیست انتخاب کنید:", reply_markup=InlineKeyboardMarkup(rows), ) return ConversationHandler.END if data.startswith("admin_bc_btn_"): btn_key = data.replace("admin_bc_btn_", "") context.user_data["admin_bc_btn"] = btn_key # اجرای ارسال msg = context.user_data.pop("admin_broadcast_text", "") bc = context.user_data.pop("admin_broadcast_mode", "all") pin = context.user_data.pop("admin_bc_pin", False) context.user_data.pop("admin_input_mode", None) if not msg: await query.edit_message_text("❌ متن پیام خالی است.", reply_markup=main_keyboard()) return ConversationHandler.END from db_users import list_bot_users, count_referrals from db_extras import apply_premium_emojis, get_menu_buttons, extract_premium_from_label users, _ = list_bot_users(limit=100000) body = apply_premium_emojis(msg) kb = None if btn_key and btn_key != "none": if btn_key == "menu_home": kb = InlineKeyboardMarkup([[InlineKeyboardButton("🏠 منوی اصلی", callback_data="menu_home")]]) else: items = get_menu_buttons() match = next((x for x in items if (x.get("key") or x.get("callback")) == btn_key), None) if match: raw = (match.get("label") or match.get("key") or "دکمه")[:40] clean, eid = extract_premium_from_label(raw) kwargs = {"text": clean or "•", "callback_data": match.get("callback") or "menu_home"} if eid: kwargs["icon_custom_emoji_id"] = eid try: kb = InlineKeyboardMarkup([[InlineKeyboardButton(**kwargs)]]) except TypeError: kb = InlineKeyboardMarkup([[InlineKeyboardButton(kwargs["text"], callback_data=kwargs["callback_data"])]]) else: kb = InlineKeyboardMarkup([[InlineKeyboardButton("🏠 منوی اصلی", callback_data="menu_home")]]) import asyncio sent = failed = 0 await query.edit_message_text("⏳ در حال ارسال...") for u in users: bal = int(u.get("balance") or 0) try: refs = count_referrals(u["telegram_id"]) except Exception: refs = 0 if not ( bc == "all" or (bc == "balance" and bal > 0) or (bc == "nobalance" and bal <= 0) or (bc == "refs" and refs > 0) ): continue try: m = await context.bot.send_message( u["telegram_id"], body, parse_mode="HTML", reply_markup=kb ) if pin: try: await context.bot.pin_chat_message( u["telegram_id"], m.message_id, disable_notification=True ) except Exception: pass sent += 1 except Exception: failed += 1 if (sent + failed) % 25 == 0: await asyncio.sleep(0.35) await query.edit_message_text( f"✅ ارسال انجام شد.\nموفق: {sent}\nناموفق: {failed}", reply_markup=main_keyboard(), ) return ConversationHandler.END if data == "admin_web": from database import get_sync_connection, get_setting_sync conn=get_sync_connection() try: with conn.cursor() as cur: cur.execute("SELECT username FROM admins ORDER BY id LIMIT 1") row=cur.fetchone() finally: conn.close() panel_url = ( get_setting_sync("web_panel_url", "") or get_setting_sync("admin_panel_url", "") or "http://YOUR_SERVER_IP:5000" ) await query.edit_message_text( f"🛠 مدیریت وب‌پنل\n\n" f"🌐 آدرس ورود:\n{panel_url}\n\n" f"نام کاربری فعلی: {(row or {}).get('username','—')}\n" "اطلاعات ورود را در مرورگر وارد کنید.\n" "از گزینه‌های زیر می‌توانید اعتبار ورود را تغییر دهید.", parse_mode="HTML", reply_markup=InlineKeyboardMarkup([ [InlineKeyboardButton("✏️ تغییر نام کاربری", callback_data="admin_web_user")], [InlineKeyboardButton("🔐 تغییر رمز عبور", callback_data="admin_web_pass")], [InlineKeyboardButton("🔗 تنظیم آدرس وب‌پنل", callback_data="admin_web_url")], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")], ]), ) return ConversationHandler.END if data == "admin_web_url": context.user_data["admin_input_mode"] = "web_url" await query.edit_message_text( "🔗 آدرس کامل وب‌پنل را بفرستید.\n" "مثال: https://panel.example.com یا http://1.2.3.4:5000\n" "/cancel برای انصراف", parse_mode="HTML", ) return WAITING_ADMIN_TEXT if data in ("admin_web_user","admin_web_pass"): context.user_data["admin_input_mode"]="web_user" if data.endswith("user") else "web_pass" await query.edit_message_text("مقدار جدید را بفرستید:") return WAITING_ADMIN_TEXT if data == "admin_bot_users": from db_users import list_bot_users, ROLE_LABELS users, total = list_bot_users(limit=15) lines = [f"👥 کاربران ربات (نمایش ۱۵ از {total})\n"] rows = [] for u in users: lines.append(f"• {u['telegram_id']} {u.get('username') or ''} — {ROLE_LABELS.get(u.get('role'), u.get('role'))} — {int(u.get('balance') or 0):,}") rows.append([InlineKeyboardButton(f"👤 {u['telegram_id']}", callback_data=f"admin_bu_{u['telegram_id']}")]) rows.append([InlineKeyboardButton("🎁 ریست تست همه کاربران", callback_data="admin_reset_trial_all")]) rows.append([InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")]) await query.edit_message_text("\n".join(lines), reply_markup=InlineKeyboardMarkup(rows), parse_mode="HTML") return ConversationHandler.END if data.startswith("admin_bu_"): from db_users import get_bot_user, ROLE_LABELS, count_referrals, get_user_activity tid = int(data.replace("admin_bu_", "")) u = get_bot_user(tid) if not u: await query.edit_message_text("کاربر یافت نشد") return ConversationHandler.END refs = count_referrals(tid) text = ( f"👤 {u.get('first_name') or ''} {u.get('last_name') or ''}\n" f"آیدی: {u['telegram_id']}\n" f"یوزرنیم: @{u.get('username') or '—'}\n" f"موبایل: {u.get('phone') or '—'}\n" f"موجودی: {int(u.get('balance') or 0):,} تومان\n" f"نقش: {ROLE_LABELS.get(u.get('role'), u.get('role'))}\n" f"زیرمجموعه: {refs}\n" f"مسدود: {'بله' if u.get('is_blocked') else 'خیر'}" ) used_trial = False try: from db_growth import has_used_trial used_trial = bool(has_used_trial(tid)) except Exception: pass text += f"\nتست رایگان: {'استفاده شده ✅' if used_trial else 'آزاد 🎁'}" kb = InlineKeyboardMarkup([ [ InlineKeyboardButton("➕۱۰هزار", callback_data=f"admin_bal_{tid}_10000"), InlineKeyboardButton("➕۵۰هزار", callback_data=f"admin_bal_{tid}_50000"), InlineKeyboardButton("➕۱۰۰هزار", callback_data=f"admin_bal_{tid}_100000"), ], [ InlineKeyboardButton("عادی", callback_data=f"admin_role_{tid}_user"), InlineKeyboardButton("نماینده", callback_data=f"admin_role_{tid}_reseller"), ], [ InlineKeyboardButton("نماینده ویژه", callback_data=f"admin_role_{tid}_reseller_vip"), InlineKeyboardButton("VIP", callback_data=f"admin_role_{tid}_vip"), ], [InlineKeyboardButton("🎁 ریست تست رایگان", callback_data=f"admin_reset_trial_{tid}")], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_bot_users")], ]) await query.edit_message_text(text, reply_markup=kb, parse_mode="HTML") return ConversationHandler.END if data.startswith("admin_bal_"): from db_users import add_balance, get_bot_user parts = data.split("_") tid, amt = int(parts[2]), int(parts[3]) add_balance(tid, amt, "admin_panel") u = get_bot_user(tid) await query.answer(f"موجودی: {int(u['balance']):,}", show_alert=True) # refresh query.data = f"admin_bu_{tid}" return await admin_callback(update, context) if data.startswith("admin_role_"): from db_users import update_bot_user parts = data.split("_") # admin_role_{tid}_{role} role may be reseller_vip tid = int(parts[2]) role = "_".join(parts[3:]) update_bot_user(tid, role=role) await query.answer("نقش به‌روز شد", show_alert=True) query.data = f"admin_bu_{tid}" return await admin_callback(update, context) if data.startswith("admin_reset_trial_"): from db_growth import reset_user_trial, reset_trials_bulk from database import get_setting_sync target = data.replace("admin_reset_trial_", "") premium = "🎁" try: # پیام قابل شخصی‌سازی از تنظیمات msg_tpl = get_setting_sync( "trial_reset_message", f"{premium} تست رایگان شما دوباره فعال شد!\nاکنون می‌توانید مجدداً از تست رایگان استفاده کنید.", ) or f"{premium} تست رایگان شما دوباره فعال شد!" except Exception: msg_tpl = f"{premium} تست رایگان شما دوباره فعال شد!" if target == "all": count = reset_trials_bulk(None) await query.answer(f"تست {count} کاربر ریست شد", show_alert=True) # پیام گروهی — فقط به کسانی که قبلاً تست داشتند سخت است؛ ادمین می‌تواند جدا broadcast کند try: await context.bot.send_message( query.from_user.id, f"✅ تست رایگان همه کاربران ریست شد ({count} نفر).\n" "در صورت نیاز از «ارسال همگانی» پیام اطلاع‌رسانی بفرستید.", ) except Exception: pass query.data = "admin_bot_users" return await admin_callback(update, context) else: tid = int(target) reset_user_trial(tid) try: await context.bot.send_message(tid, msg_tpl) except Exception as e: print("notify trial reset:", e) await query.answer("تست کاربر ریست و پیام ارسال شد", show_alert=True) query.data = f"admin_bu_{tid}" return await admin_callback(update, context) if data == "admin_categories": from db_products import list_categories cats = list_categories(active_only=False) or [] lines = ["📁 دسته‌بندی محصولات\n"] rows = [] for c in cats[:30]: st = "🟢" if c.get("is_active", 1) else "🔴" lines.append(f"• {st} #{c['id']} {c.get('name') or '—'}") if not cats: lines.append("دسته‌ای تعریف نشده. از وب‌پنل اضافه کنید.") rows.append([InlineKeyboardButton("🌐 مدیریت در وب‌پنل", callback_data="admin_web")]) rows.append([InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")]) await query.edit_message_text("\n".join(lines), reply_markup=InlineKeyboardMarkup(rows), parse_mode="HTML") return ConversationHandler.END if data == "admin_growth": from database import get_setting_sync te = get_setting_sync("trial_enabled", "0") == "1" tv = get_setting_sync("trial_volume_gb", "1") or "1" td = get_setting_sync("trial_days", "1") or "1" fj = get_setting_sync("force_join_enabled", "0") == "1" fp = get_setting_sync("force_phone_enabled", "0") == "1" textg = ( "🌱 رشد و احراز / تست رایگان\n\n" f"تست رایگان: {'🟢 فعال' if te else '🔴 خاموش'}\n" f"حجم تست: {tv} GB | مدت: {td} روز\n" f"عضویت اجباری: {'🟢' if fj else '🔴'} | موبایل اجباری: {'🟢' if fp else '🔴'}\n\n" "تنظیمات پیشرفته (پنل تست، پروتکل) از وب‌پنل." ) rows = [ [InlineKeyboardButton( ("🔴 خاموش کردن تست" if te else "🟢 روشن کردن تست"), callback_data="admin_trial_toggle", )], [InlineKeyboardButton("📦 حجم تست (GB)", callback_data="admin_trial_vol")], [InlineKeyboardButton("📅 مدت تست (روز)", callback_data="admin_trial_days")], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")], ] await query.edit_message_text(textg, reply_markup=InlineKeyboardMarkup(rows), parse_mode="HTML") return ConversationHandler.END if data == "admin_trial_toggle": from database import get_setting_sync, set_setting_sync te = get_setting_sync("trial_enabled", "0") == "1" set_setting_sync("trial_enabled", "0" if te else "1") await query.answer("تست " + ("خاموش" if te else "روشن") + " شد", show_alert=True) query.data = "admin_growth" return await admin_callback(update, context) if data == "admin_trial_vol": context.user_data["admin_input_mode"] = "trial_vol" await query.edit_message_text("حجم تست رایگان را به گیگابایت بفرستید (مثلاً 1):\n/cancel انصراف") return WAITING_ADMIN_TEXT if data == "admin_trial_days": context.user_data["admin_input_mode"] = "trial_days" await query.edit_message_text("مدت تست رایگان را به روز بفرستید (مثلاً 1):\n/cancel انصراف") return WAITING_ADMIN_TEXT if data == "admin_gifts": from db_users import list_gift_codes codes = list_gift_codes() or [] lines = ["🏷 کدهای هدیه\n"] for g in codes[:20]: lines.append( f"• {g.get('code')} — {int(g.get('amount') or 0):,} ت " f"({int(g.get('used_count') or 0)}/{int(g.get('max_uses') or 1)}) " f"{'🟢' if g.get('is_active', 1) else '🔴'}" ) if not codes: lines.append("کدی نیست.") rows = [ [InlineKeyboardButton("➕ ساخت کد هدیه", callback_data="admin_gift_add")], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")], ] await query.edit_message_text("\n".join(lines), reply_markup=InlineKeyboardMarkup(rows), parse_mode="HTML") return ConversationHandler.END if data == "admin_gift_add": context.user_data["admin_input_mode"] = "gift_add" await query.edit_message_text( "کد هدیه را این‌طور بفرستید:\n" "کد مبلغ حداکثر_استفاده\n" "مثال: NOWROZ 50000 10\n/cancel انصراف", parse_mode="HTML", ) return WAITING_ADMIN_TEXT if data == "admin_resellers": from db_growth import list_reseller_requests reqs = list_reseller_requests(status="pending", limit=20) or [] lines = ["🤝 درخواست‌های نمایندگی (در انتظار)\n"] rows = [] for r in reqs: lines.append( f"• #{r['id']} tg:{r.get('telegram_id')} " f"{(r.get('description') or '')[:40]}" ) rows.append([ InlineKeyboardButton(f"✅ #{r['id']}", callback_data=f"admin_rs_ok_{r['id']}"), InlineKeyboardButton(f"❌ #{r['id']}", callback_data=f"admin_rs_no_{r['id']}"), ]) if not reqs: lines.append("درخواستی در صف نیست.") rows.append([InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")]) await query.edit_message_text("\n".join(lines)[:3500], reply_markup=InlineKeyboardMarkup(rows), parse_mode="HTML") return ConversationHandler.END if data.startswith("admin_rs_ok_"): from db_growth import review_reseller_request, get_reseller_request rid = int(data.replace("admin_rs_ok_", "")) req = get_reseller_request(rid) ok = review_reseller_request(rid, "approved", reseller_type="reseller") if ok and req: try: await context.bot.send_message( int(req["telegram_id"]), "🎉 درخواست نمایندگی شما تایید شد!", ) except Exception: pass await query.answer("تایید شد" if ok else "خطا", show_alert=True) query.data = "admin_resellers" return await admin_callback(update, context) if data.startswith("admin_rs_no_"): from db_growth import review_reseller_request, get_reseller_request rid = int(data.replace("admin_rs_no_", "")) req = get_reseller_request(rid) ok = review_reseller_request(rid, "rejected") if ok and req: try: await context.bot.send_message( int(req["telegram_id"]), "❌ درخواست نمایندگی شما رد شد.", ) except Exception: pass await query.answer("رد شد" if ok else "خطا", show_alert=True) query.data = "admin_resellers" return await admin_callback(update, context) if data == "admin_tickets": from db_support import list_open_tickets tickets = list_open_tickets(limit=20) or [] lines = ["🎧 تیکت‌های باز\n"] rows = [] for t in tickets: lines.append( f"• #{t.get('id')} tg:{t.get('telegram_id')} " f"{(t.get('subject') or t.get('title') or '')[:40]}" ) rows.append([InlineKeyboardButton( f"#{t.get('id')} باز کردن", callback_data=f"admin_ticket_{t.get('id')}", )]) if not tickets: lines.append("تیکت بازی نیست.") rows.append([InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")]) await query.edit_message_text("\n".join(lines)[:3500], reply_markup=InlineKeyboardMarkup(rows), parse_mode="HTML") return ConversationHandler.END if data.startswith("admin_ticket_"): from db_support import get_ticket, get_ticket_messages tid = int(data.replace("admin_ticket_", "")) t = get_ticket(tid) if not t: await query.answer("یافت نشد", show_alert=True) return ConversationHandler.END msgs = get_ticket_messages(tid) or [] lines = [ f"🎧 تیکت #{tid}\n" f"کاربر: {t.get('telegram_id')}\n" f"موضوع: {t.get('subject') or t.get('title') or '—'}\n" f"وضعیت: {t.get('status')}\n" ] for m in msgs[-8:]: who = "ادمین" if (m.get("sender") == "admin" or m.get("is_admin") or m.get("from_admin")) else "کاربر" body = (m.get("message") or m.get("body") or "")[:120] lines.append(f"• [{who}] {body}") context.user_data["admin_reply_ticket"] = tid context.user_data["admin_input_mode"] = "ticket_reply" rows = [[InlineKeyboardButton("🔙 تیکت‌ها", callback_data="admin_tickets")]] await query.edit_message_text( "\n".join(lines)[:3500] + "\n\nپاسخ را همین‌جا بنویسید:", reply_markup=InlineKeyboardMarkup(rows), parse_mode="HTML", ) return WAITING_ADMIN_TEXT if data == "admin_loyalty": from database import get_setting_sync, set_setting_sync en = get_setting_sync("purchase_points_enabled", "1") == "1" unit = get_setting_sync("purchase_points_unit", "10000") or "10000" val = get_setting_sync("purchase_points_value", "1") or "1" textl = ( "⭐ امتیاز خرید (باشگاه)\n\n" f"وضعیت: {'🟢 فعال' if en else '🔴 خاموش'}\n" f"هر {unit} تومان → {val} امتیاز\n" ) rows = [ [InlineKeyboardButton( ("🔴 خاموش" if en else "🟢 روشن"), callback_data="admin_loyalty_toggle", )], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")], ] await query.edit_message_text(textl, reply_markup=InlineKeyboardMarkup(rows), parse_mode="HTML") return ConversationHandler.END if data == "admin_loyalty_toggle": from database import get_setting_sync, set_setting_sync en = get_setting_sync("purchase_points_enabled", "1") == "1" set_setting_sync("purchase_points_enabled", "0" if en else "1") await query.answer("ذخیره شد", show_alert=True) query.data = "admin_loyalty" return await admin_callback(update, context) if data == "admin_cards": from db_users import list_cards cards=list_cards() rows=[[InlineKeyboardButton("➕ افزودن کارت",callback_data="admin_card_add")]] lines=["💳 مدیریت کارت‌ها\n"] for c in cards: lines.append(f"• {c['card_number']} — {c['owner_name']} — {'فعال' if c['is_active'] else 'خاموش'}") rows.append([ InlineKeyboardButton(("خاموش" if c['is_active'] else "روشن"),callback_data=f"admin_card_toggle_{c['id']}_{0 if c['is_active'] else 1}"), InlineKeyboardButton("🗑 حذف",callback_data=f"admin_card_del_{c['id']}") ]) from database import get_setting_sync as _gs mins = _gs("card_auto_approve_minutes", "0") or "0" ausers = _gs("card_auto_approve_users", "") or "—" from database import get_setting_sync card_enabled = get_setting_sync("payment_method_card_enabled", "1") != "0" variza_enabled = get_setting_sync("variza_enabled", "0") == "1" variza_title = get_setting_sync("variza_title", "پرداخت واریزا") or "پرداخت واریزا" stars_enabled = get_setting_sync("stars_enabled", "0") == "1" stars_rate = get_setting_sync("stars_rate", "1000") or "1000" card_min = get_setting_sync("card_min_purchases", "0") or "0" lines.append("") lines.append(f"💳 کارت‌به‌کارت: {'🟢 فعال' if card_enabled else '🔴 خاموش'}") lines.append(f"🟣 {variza_title}: {'🟢 فعال' if variza_enabled else '🔴 خاموش'}") lines.append(f"⭐ استارز: {'🟢 فعال' if stars_enabled else '🔴 خاموش'} (نرخ: {stars_rate})") lines.append(f"🔒 حداقل خرید برای نمایش کارت: {card_min} (0=همیشه)") lines.append(f"⏱ تایید خودکار رسید: {mins} دقیقه") lines.append(f"👤 کاربران سفید: {ausers}") rows.append([InlineKeyboardButton("💳 روشن/خاموش کارت‌به‌کارت", callback_data="admin_card_system_toggle")]) rows.append([InlineKeyboardButton("⭐ روشن/خاموش استارز", callback_data="admin_stars_toggle")]) rows.append([InlineKeyboardButton("⭐ نرخ استارز (تومان)", callback_data="admin_stars_rate")]) rows.append([InlineKeyboardButton("🔒 حداقل خرید برای کارت", callback_data="admin_card_min_purchases")]) rows.append([InlineKeyboardButton("🟣 تنظیم واریزا", callback_data="admin_variza")]) rows.append([InlineKeyboardButton("✏️ نام دکمه کارت‌به‌کارت", callback_data="admin_card_title")]) rows.append([InlineKeyboardButton("⏱ دقیقه تایید خودکار", callback_data="admin_auto_mins")]) rows.append([InlineKeyboardButton("👤 کاربران تایید خودکار", callback_data="admin_auto_users")]) rows.append([InlineKeyboardButton("🔙 بازگشت",callback_data="admin_panel")]) await query.edit_message_text("\n".join(lines) if cards else "هنوز کارتی ثبت نشده.",reply_markup=InlineKeyboardMarkup(rows),parse_mode="HTML") return ConversationHandler.END if data == "admin_stars_toggle": from database import get_setting_sync, set_setting_sync from db_users import set_payment_method_state, ensure_stars_payment_method try: ensure_stars_payment_method() except Exception: pass enabled = get_setting_sync("stars_enabled", "0") == "1" set_setting_sync("stars_enabled", "0" if enabled else "1") try: set_payment_method_state("stars", not enabled) except Exception: pass await query.answer("استارز " + ("خاموش" if enabled else "روشن") + " شد", show_alert=True) query.data = "admin_cards" return await admin_callback(update, context) if data == "admin_stars_rate": context.user_data["admin_input_mode"] = "stars_rate" await query.edit_message_text( "نرخ تبدیل استارز را بفرستید (تومان به‌ازای هر استار).\nمثال: 1000\n/cancel انصراف" ) return WAITING_ADMIN_TEXT if data == "admin_card_min_purchases": context.user_data["admin_input_mode"] = "card_min_purchases" await query.edit_message_text( "حداقل تعداد خرید موفق برای نمایش شماره کارت را بفرستید.\n" "0 = همیشه نمایش داده شود\n" "1 = از خرید دوم به بعد\n" "/cancel انصراف" ) return WAITING_ADMIN_TEXT if data == "admin_antispam": from database import get_setting_sync en = get_setting_sync("antispam_enabled", "1") != "0" hits = get_setting_sync("antispam_max_hits", "8") or "8" win = get_setting_sync("antispam_window_sec", "5") or "5" ban = get_setting_sync("antispam_ban_sec", "300") or "300" msg = get_setting_sync("antispam_message", "") or "—" text = ( "🛡 آنتی‌اسپم\n\n" f"وضعیت: {'فعال' if en else 'خاموش'}\n" f"حداکثر پیام: {hits} در {win} ثانیه\n" f"مدت محدودیت: {ban} ثانیه\n" f"پیام: {msg[:80]}" ) rows = [ [InlineKeyboardButton("روشن/خاموش", callback_data="admin_as_toggle")], [InlineKeyboardButton("حداکثر پیام", callback_data="admin_as_hits")], [InlineKeyboardButton("بازه (ثانیه)", callback_data="admin_as_window")], [InlineKeyboardButton("مدت محدودیت (ثانیه)", callback_data="admin_as_ban")], [InlineKeyboardButton("متن پیام محدودیت", callback_data="admin_as_msg")], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")], ] await query.edit_message_text(text, reply_markup=InlineKeyboardMarkup(rows), parse_mode="HTML") return ConversationHandler.END if data == "admin_as_toggle": from database import get_setting_sync, set_setting_sync en = get_setting_sync("antispam_enabled", "1") != "0" set_setting_sync("antispam_enabled", "0" if en else "1") query.data = "admin_antispam" return await admin_callback(update, context) if data == "admin_as_hits": context.user_data["admin_input_mode"] = "as_hits" await query.edit_message_text("حداکثر تعداد پیام در بازه را بفرستید (مثال: 8):") return WAITING_ADMIN_TEXT if data == "admin_as_window": context.user_data["admin_input_mode"] = "as_window" await query.edit_message_text("بازه زمانی به ثانیه را بفرستید (مثال: 5):") return WAITING_ADMIN_TEXT if data == "admin_as_ban": context.user_data["admin_input_mode"] = "as_ban" await query.edit_message_text("مدت محدودیت به ثانیه را بفرستید (مثال: 300 برای ۵ دقیقه):") return WAITING_ADMIN_TEXT if data == "admin_as_msg": context.user_data["admin_input_mode"] = "as_msg" await query.edit_message_text("متن پیام هنگام محدودیت را بفرستید:") return WAITING_ADMIN_TEXT if data == "admin_card_system_toggle": from database import get_setting_sync, set_setting_sync enabled = get_setting_sync("payment_method_card_enabled", "1") != "0" set_setting_sync("payment_method_card_enabled", "0" if enabled else "1") try: from db_users import set_payment_method_state set_payment_method_state("card", not enabled) except Exception: pass query.data = "admin_cards" return await admin_callback(update, context) if data == "admin_card_title": context.user_data["admin_input_mode"] = "card_title" await query.edit_message_text("نام جدید دکمه کارت‌به‌کارت را بفرستید:") return WAITING_ADMIN_TEXT if data == "admin_variza": from database import get_setting_sync enabled = get_setting_sync("variza_enabled", "0") == "1" title = get_setting_sync("variza_title", "پرداخت واریزا") or "پرداخت واریزا" configured = bool(get_setting_sync("variza_api_key", "") and get_setting_sync("variza_webhook_secret", "") and get_setting_sync("public_base_url", "")) text_v = (f"🟣 واریزا\n\nوضعیت: {'🟢 فعال' if enabled else '🔴 خاموش'}\nنام دکمه: {title}\nاتصال API: {'✅ تنظیم شده' if configured else '❌ ناقص'}\nآدرس وب‌هوک: {(get_setting_sync('public_base_url','') or '') + '/webhooks/variza'}") rows = [[InlineKeyboardButton("روشن/خاموش", callback_data="admin_variza_toggle")], [InlineKeyboardButton("🔑 تنظیم API Key", callback_data="admin_variza_api")], [InlineKeyboardButton("🔐 تنظیم Webhook Secret", callback_data="admin_variza_secret")], [InlineKeyboardButton("🌐 تنظیم آدرس عمومی", callback_data="admin_public_url")], [InlineKeyboardButton("✏️ تغییر نام دکمه", callback_data="admin_variza_title")], [InlineKeyboardButton("🔙 کارت‌ها / پرداخت", callback_data="admin_cards")]] await query.edit_message_text(text_v, reply_markup=InlineKeyboardMarkup(rows), parse_mode="HTML") return ConversationHandler.END if data == "admin_variza_toggle": from database import get_setting_sync, set_setting_sync enabled = get_setting_sync("variza_enabled", "0") == "1" new = not enabled set_setting_sync("variza_enabled", "1" if new else "0") try: from db_users import set_payment_method_state set_payment_method_state("variza", new) except Exception: pass query.data = "admin_variza" return await admin_callback(update, context) if data in ("admin_variza_api", "admin_variza_secret", "admin_public_url", "admin_variza_title"): mode_map = {"admin_variza_api":"variza_api", "admin_variza_secret":"variza_secret", "admin_public_url":"public_url", "admin_variza_title":"variza_title"} context.user_data["admin_input_mode"] = mode_map[data] prompts = {"variza_api":"API Key واریزا را بفرستید:", "variza_secret":"Webhook Secret واریزا را بفرستید:", "public_url":"آدرس عمومی HTTPS سرور را بفرستید (مثال: https://example.com):", "variza_title":"نام جدید دکمه واریزا را بفرستید:"} await query.edit_message_text(prompts[mode_map[data]]) return WAITING_ADMIN_TEXT if data == "admin_auto_mins": context.user_data["admin_input_mode"] = "auto_approve_mins" await query.edit_message_text("تعداد دقیقه تا تایید خودکار رسید را بفرستید (0=خاموش):") return WAITING_ADMIN_TEXT if data == "admin_auto_users": context.user_data["admin_input_mode"] = "auto_approve_users" await query.edit_message_text("شناسه کاربران تایید خودکار را با کاما بفرستید (پاک کردن: -):") return WAITING_ADMIN_TEXT if data=="admin_card_add": context.user_data["admin_input_mode"]="card_add" await query.edit_message_text("شماره کارت | نام صاحب | نام بانک را در یک خط بفرستید.\nنمونه:\n6037... | Farnoud | Mellat") return WAITING_ADMIN_TEXT if data.startswith("admin_card_toggle_"): rest=data.replace("admin_card_toggle_","",1).split("_",1) cid,active=rest[0],rest[1] from db_users import toggle_card toggle_card(int(cid),active=="1") context.user_data["admin_input_mode"]=None query.data="admin_cards" return await admin_callback(update,context) if data.startswith("admin_card_del_"): from db_users import delete_card delete_card(int(data.replace("admin_card_del_",""))) query.data="admin_cards" return await admin_callback(update,context) if data == "admin_charges": from db_users import list_pending_charges pending = list_pending_charges() if not pending: await query.edit_message_text( "درخواست معلقی نیست.", reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")]]), ) return ConversationHandler.END rows = [] lines = ["🧾 در انتظار تایید:\n"] for ch in pending[:20]: lines.append(f"#{ch['id']} — کاربر {ch['telegram_id']} — {int(ch['amount']):,} تومان") rows.append([ InlineKeyboardButton(f"✅ #{ch['id']}", callback_data=f"adm_ch_ok_{ch['id']}"), InlineKeyboardButton(f"❌ #{ch['id']}", callback_data=f"adm_ch_no_{ch['id']}"), ]) rows.append([InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")]) await query.edit_message_text("\n".join(lines), reply_markup=InlineKeyboardMarkup(rows)) return ConversationHandler.END if data.startswith("adm_ch_ok_"): from db_users import approve_charge, render_template, user_vars, get_bot_user cid = int(data.replace("adm_ch_ok_", "")) user = approve_charge(cid) try: from handlers.group_reports import send_report await send_report(context.bot, "charges", f"✅ شارژ تأیید شد — charge #{cid}") except Exception: pass if user: try: from db_users import get_charge ch = get_charge(cid) vars_ = user_vars(user) vars_["amount"] = f"{int(ch['amount']):,}" vars_["balance"] = f"{int(user['balance']):,}" await context.bot.send_message(user["telegram_id"], render_template("charge_approved", vars_), parse_mode="HTML") except Exception: pass await query.answer("تایید شد", show_alert=True) await query.edit_message_text(f"✅ فاکتور #{cid} تایید شد.") else: await query.answer("ناموفق", show_alert=True) return ConversationHandler.END if data.startswith("adm_ch_no_"): from db_users import reject_charge, get_charge, render_template, user_vars, get_bot_user cid = int(data.replace("adm_ch_no_", "")) ch = get_charge(cid) if reject_charge(cid, "توسط ادمین"): try: u = get_bot_user(ch["telegram_id"]) vars_ = user_vars(u) vars_["amount"] = f"{int(ch['amount']):,}" vars_["reason"] = "توسط ادمین" await context.bot.send_message(ch["telegram_id"], render_template("charge_rejected", vars_), parse_mode="HTML") except Exception: pass await query.edit_message_text(f"❌ فاکتور #{cid} رد شد.") return ConversationHandler.END if data=="admin_welcome": from database import get_setting_sync context.user_data["admin_input_mode"]="welcome_all" await query.edit_message_text( "📝 پیام خوش‌آمدگویی /start را بفرستید.\nمتغیرها و کدهای premium مانند p_xxxxxxxx فعال هستند." ) return WAITING_ADMIN_TEXT if data == "admin_msgs": try: from db_users import list_templates tpls = list_templates() except Exception as e: await query.edit_message_text(f"خطا: {e}") return ConversationHandler.END lines = ["📝 تنظیم پیام‌ها و دکمه‌ها\n"] rows = [ [InlineKeyboardButton("⌨️ نام دکمه‌های منو", callback_data="admin_menu_labels")], [InlineKeyboardButton("📄 پیام‌های قالب", callback_data="admin_msgs_tpl")], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")], ] await query.edit_message_text("\n".join(lines), reply_markup=InlineKeyboardMarkup(rows), parse_mode="HTML") return ConversationHandler.END if data == "admin_msgs_tpl": try: from db_users import list_templates tpls = list_templates() except Exception as e: await query.edit_message_text(f"خطا: {e}") return ConversationHandler.END if not tpls: await query.edit_message_text( "قالب پیامی نیست.", reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🔙 بازگشت", callback_data="admin_msgs")]]), ) return ConversationHandler.END rows = [] for tp in tpls[:25]: rows.append([InlineKeyboardButton( (tp.get("title") or tp["key"])[:40], callback_data=f"admin_msg_{tp['key']}", )]) rows.append([InlineKeyboardButton("🔙 بازگشت", callback_data="admin_msgs")]) await query.edit_message_text("📄 قالب پیام را انتخاب کنید:", reply_markup=InlineKeyboardMarkup(rows)) return ConversationHandler.END if data == "admin_menu_labels": from db_extras import get_menu_buttons, strip_premium_codes items = get_menu_buttons() rows = [] for it in items: lab = strip_premium_codes((it.get("label") or it.get("key") or "?")[:40]) rows.append([InlineKeyboardButton( f"{'✅' if it.get('enabled', True) else '❌'} {lab}", callback_data=f"admin_mblabel_{it.get('key')}", )]) rows.append([InlineKeyboardButton("🔙 بازگشت", callback_data="admin_msgs")]) await query.edit_message_text( "⌨️ نام دکمه منو را برای ویرایش انتخاب کنید:\n" "(تغییر اینجا مثل وب‌پنل روی منوی کاربر اعمال می‌شود)", reply_markup=InlineKeyboardMarkup(rows), ) return ConversationHandler.END if data.startswith("admin_mblabel_"): key = data.replace("admin_mblabel_", "", 1) from db_extras import get_menu_buttons items = get_menu_buttons() item = next((x for x in items if x.get("key") == key), None) if not item: await query.edit_message_text("دکمه یافت نشد.", reply_markup=InlineKeyboardMarkup( [[InlineKeyboardButton("🔙 بازگشت", callback_data="admin_menu_labels")]] )) return ConversationHandler.END context.user_data["admin_input_mode"] = "menu_label" context.user_data["edit_menu_key"] = key await query.edit_message_text( f"✏️ نام جدید دکمه {key}\n" f"فعلی: {item.get('label')}\n\n" "متن جدید را بفرستید (می‌تواند شامل p_xxxxxxxx باشد).\n" "/cancel برای انصراف", parse_mode="HTML", ) return WAITING_ADMIN_TEXT if data.startswith("admin_msg_"): key = data[len("admin_msg_"):] from db_users import get_template body = get_template(key) or "(خالی)" context.user_data["edit_msg_key"] = key await query.edit_message_text( f"✏️ پیام {key}\n\n{body[:800]}\n\n———\nمتن جدید را بفرستید:\n" "متغیرها: [username] [balance] [invite_link] ...\n/cancel برای انصراف", parse_mode="HTML", ) return WAITING_WELCOME if data == "admin_products": try: from db_products import list_products, ROLE_OPTIONS products = list_products() except Exception as e: await query.edit_message_text( f"خطا در محصولات: {e}\nاز پنل وب هم می‌توانید مدیریت کنید.", reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")]]), ) return ConversationHandler.END lines = ["📦 محصولات\n"] for pr in products[:25]: lines.append(f"• #{pr['id']} {pr['name']} — {int(pr['price']):,} ت — {pr.get('volume_gb')}GB / {pr.get('duration_days')}روز") if not products: lines.append("محصولی نیست.") rows = [ [InlineKeyboardButton("➕ افزودن محصول", callback_data="admin_product_add")], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")], ] await query.edit_message_text( "\n".join(lines), reply_markup=InlineKeyboardMarkup(rows), parse_mode="HTML", ) return ConversationHandler.END if data == "admin_product_add": context.user_data["prod_new"] = {} context.user_data["admin_input_mode"] = "prod_name" await query.edit_message_text( "➕ محصول جدید — مرحله ۱/۴\n" "نام محصول را بفرستید:\n\n/cancel برای انصراف", ) return WAITING_ADMIN_TEXT if data.startswith("adm_ord_ok_"): from db_products import get_order, update_order from db_users import add_balance from services.provision import provision_order, send_service_to_user oid = int(data.replace("adm_ord_ok_", "")) order = get_order(oid) if not order: await query.answer("یافت نشد", show_alert=True) return ConversationHandler.END if order["status"] not in ("pending_review", "paid"): await query.answer(f"وضعیت: {order['status']}", show_alert=True) return ConversationHandler.END wu = int(order.get("wallet_used") or 0) if wu > 0: try: add_balance(order["telegram_id"], -wu, f"order#{oid}") except Exception as e: print("deduct", e) update_order(oid, status="paid") await query.edit_message_text(f"⏳ ساخت سرویس #{oid}...") result = provision_order(oid) if result.get("ok"): try: from db_growth import award_purchase_points award_purchase_points(order["telegram_id"], int(order.get("amount") or 0), oid) except Exception as e: print("admin purchase points:", e) try: await send_service_to_user(context.bot, order["telegram_id"], result) except Exception as e: print("send", e) if result.get("ok"): await query.edit_message_text(f"✅ سفارش #{oid} تایید و سرویس تحویل شد.") else: await query.edit_message_text(f"⚠️ پرداخت OK — خطای ساخت: {result.get('error')}") return ConversationHandler.END if data.startswith("adm_ord_no_"): from db_products import get_order, update_order oid = int(data.replace("adm_ord_no_", "")) order = get_order(oid) if order: update_order(oid, status="rejected") try: await context.bot.send_message(order["telegram_id"], f"❌ سفارش #{oid} رد شد.") except Exception: pass await query.edit_message_text(f"❌ سفارش #{oid} رد شد.") return ConversationHandler.END if data.startswith("adm_ref_ok_"): from db_products import get_order, update_order from db_users import add_balance from services.optimize import _delete_from_panel oid = int(data.replace("adm_ref_ok_", "")) order = get_order(oid) if not order: await query.answer("یافت نشد", show_alert=True) return ConversationHandler.END amount = int(order.get("amount") or 0) try: _delete_from_panel(order) except Exception as e: print("ref delete panel", e) update_order(oid, status="cancelled") if amount > 0: try: add_balance(order["telegram_id"], amount, f"refund_order#{oid}") except Exception as e: print("refund balance", e) try: await context.bot.send_message( order["telegram_id"], f"درخواست حذف سرویس #{oid} تایید شد. مبلغ {amount:,} تومان به کیف پول بازگشت." ) except Exception: pass await query.edit_message_text(f"حذف و بازگشت وجه سفارش #{oid} انجام شد ({amount:,} ت).") return ConversationHandler.END if data.startswith("adm_ref_no_"): from db_products import get_order, update_order oid = int(data.replace("adm_ref_no_", "")) order = get_order(oid) if order: # re-enable? leave disabled, mark paid/provisioned again if was update_order(oid, status="provisioned") try: await context.bot.send_message(order["telegram_id"], f"درخواست حذف سرویس #{oid} رد شد.") except Exception: pass await query.edit_message_text(f"درخواست حذف #{oid} رد شد.") return ConversationHandler.END # ---- سرویس‌های فروخته‌شده ---- if data == "admin_orders": from db_products import list_all_orders orders = list_all_orders(status="provisioned", limit=15) rows = [] for o in orders or []: label = f"#{o['id']} {o.get('vpn_username') or '—'} ({o.get('product_name') or ''})" rows.append([InlineKeyboardButton(label[:50], callback_data=f"admin_ord_{o['id']}")]) rows.append([InlineKeyboardButton("🔎 جستجوی سرویس", callback_data="admin_order_search")]) rows.append([InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")]) text = "📋 سرویس‌های فعال (آخرین ۱۵):" if orders else "سرویس فعالی نیست." await query.edit_message_text(text, reply_markup=InlineKeyboardMarkup(rows)) return ConversationHandler.END if data == "admin_order_search": context.user_data["admin_input_mode"] = "order_search" await query.edit_message_text( "🔎 جستجوی سرویس فروخته‌شده\n" "آیدی سفارش، یوزرنیم VPN، یا آیدی تلگرام کاربر را بفرستید:\n" "/cancel برای انصراف" ) return WAITING_ADMIN_TEXT if data.startswith("admin_ord_") and not data.startswith("admin_ordedit_"): from db_products import get_order_full oid = int(data.replace("admin_ord_", "")) o = get_order_full(oid) if not o: await query.edit_message_text("یافت نشد.") return ConversationHandler.END vol = o.get("volume_gb_override") or o.get("volume_gb") or "—" days = o.get("duration_days_override") or o.get("duration_days") or "—" text = ( f"📋 سرویس #{o['id']}\n" f"کاربر: {o.get('telegram_id')}\n" f"VPN: {o.get('vpn_username') or '—'}\n" f"محصول: {o.get('product_name') or '—'}\n" f"پنل: {o.get('panel_name') or '—'}\n" f"حجم: {vol} GB | مدت: {days} روز\n" f"ساعتی: {'بله' if o.get('is_hourly') else 'خیر'} | فعال: {o.get('hourly_active')}\n" f"وضعیت: {o.get('status')}" ) kb = InlineKeyboardMarkup([ [ InlineKeyboardButton("📦 حجم", callback_data=f"admin_ordedit_{oid}_vol"), InlineKeyboardButton("📅 روز", callback_data=f"admin_ordedit_{oid}_days"), ], [ InlineKeyboardButton("📱 HWID", callback_data=f"admin_ordedit_{oid}_hwid"), InlineKeyboardButton("⏯ وضعیت", callback_data=f"admin_ordedit_{oid}_status"), ], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_orders")], ]) await query.edit_message_text(text, reply_markup=kb, parse_mode="HTML") return ConversationHandler.END if data.startswith("admin_ordedit_"): # admin_ordedit_{oid}_{field} parts = data.replace("admin_ordedit_", "").split("_") if len(parts) < 2: return ConversationHandler.END oid, field = int(parts[0]), parts[1] context.user_data["ord_edit_id"] = oid context.user_data["ord_edit_field"] = field prompts = { "vol": "حجم جدید (گیگابایت) را بفرستید (۰ = نامحدود):", "days": "تعداد روز باقی‌مانده از الان را بفرستید:", "hwid": "محدودیت HWID را بفرستید (۰ = نامحدود):", "status": "وضعیت را بفرستید: active یا disabled", } await query.edit_message_text(prompts.get(field, "مقدار را بفرستید:")) return WAITING_USER_FIELD # ---- ایموجی پریمیوم ---- if data == "admin_premiji": from db_extras import list_premium_emojis items = list_premium_emojis() lines = ["✨ ایموجی‌های پریمیوم\n"] rows = [[InlineKeyboardButton("➕ افزودن", callback_data="admin_premiji_add")]] for e in items[:20]: lines.append(f"{e['code']} → {e['custom_emoji_id']}") rows.append([ InlineKeyboardButton(f"🗑 {e['code']}", callback_data=f"admin_premiji_del_{e['code']}"), ]) rows.append([InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")]) if len(lines) == 1: lines.append("هنوز چیزی ثبت نشده.") await query.edit_message_text("\n".join(lines), reply_markup=InlineKeyboardMarkup(rows), parse_mode="HTML") return ConversationHandler.END if data == "admin_premiji_add": context.user_data["premiji_step"] = "code" await query.edit_message_text( "کد را وارد کنید (باید با p_ شروع شود).\n" "یا خالی بفرستید تا کد تصادفی ساخته شود.", parse_mode="HTML", ) return WAITING_USER_FIELD if data.startswith("admin_premiji_del_"): from db_extras import delete_premium_emoji code = data.replace("admin_premiji_del_", "", 1) delete_premium_emoji(code) await query.edit_message_text(f"حذف شد: {code}", reply_markup=InlineKeyboardMarkup([ [InlineKeyboardButton("🔙 لیست", callback_data="admin_premiji")], ])) return ConversationHandler.END # ---- آمار ---- if data == "admin_stats": import time from db_stats import bot_full_stats, format_bot_stats_text t0 = time.perf_counter() stats = bot_full_stats() ping_ms = int((time.perf_counter() - t0) * 1000) text = format_bot_stats_text(stats, ping_ms=ping_ms) await query.edit_message_text( text, parse_mode="HTML", reply_markup=InlineKeyboardMarkup([ [InlineKeyboardButton("🔄 بروزرسانی", callback_data="admin_stats")], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")], ]), ) return ConversationHandler.END # ---- ادمین‌های ربات ---- if data == "admin_botadmins": from db_extras import list_bot_admins from config import ADMIN_ID as MAIN_ADMIN lines = ["👮 ادمین‌های ربات\n", f"⭐ ادمین اصلی: {MAIN_ADMIN}\n"] rows = [] for a in list_bot_admins(): lines.append(f"• {a['telegram_id']} {a.get('title') or ''}") rows.append([InlineKeyboardButton( f"🗑 حذف {a['telegram_id']}", callback_data=f"admin_badm_del_{a['telegram_id']}", )]) rows.insert(0, [InlineKeyboardButton("➕ افزودن ادمین", callback_data="admin_badm_add")]) rows.append([InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")]) await query.edit_message_text("\n".join(lines), parse_mode="HTML", reply_markup=InlineKeyboardMarkup(rows)) return ConversationHandler.END if data == "admin_badm_add": context.user_data["admin_input_mode"] = "bot_admin_add" await query.edit_message_text("آیدی عددی تلگرام ادمین جدید را بفرستید:") return WAITING_ADMIN_TEXT if data.startswith("admin_badm_del_"): from db_extras import remove_bot_admin tid = int(data.replace("admin_badm_del_", "")) remove_bot_admin(tid) await query.edit_message_text( f"✅ ادمین {tid} حذف شد.", parse_mode="HTML", reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🔙 لیست", callback_data="admin_botadmins")]]), ) return ConversationHandler.END # ---- منوی شیشه‌ای ---- if data == "admin_inline_menu": from database import get_setting_sync, set_setting_sync from handlers.wallet import main_user_keyboard from telegram import ReplyKeyboardRemove cur = get_setting_sync("inline_main_menu", "0") new = "0" if cur == "1" else "1" set_setting_sync("inline_main_menu", new) if new == "1": state = "شیشه‌ای (اینلاین) ✅\nکیبورد دکمه‌ای کاملاً حذف می‌شود." try: await context.bot.send_message(user.id, "⌨️ کیبورد دکمه‌ای حذف شد.", reply_markup=ReplyKeyboardRemove()) except Exception: pass else: state = "دکمه‌ای (ریپلای) ✅\nمنوی شیشه‌ای خاموش است." try: await context.bot.send_message( user.id, "⌨️ کیبورد دکمه‌ای فعال شد.", reply_markup=main_user_keyboard(is_admin=True, force_inline=False), ) except Exception: pass await query.edit_message_text( f"⌨️ منوی اصلی ربات:\n{state}\n\nکاربران با /start منوی جدید را می‌بینند.", reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")]]), parse_mode="HTML", ) return ConversationHandler.END # ---- ساعتی ---- if data == "admin_backup_cfg": from database import get_setting_sync from handlers.group_reports import get_backup_interval_seconds hours = get_backup_interval_seconds() / 3600.0 cur = get_setting_sync("backup_interval_hours", "2") await query.edit_message_text( f"💾 فاصله بکاپ دیتابیس\n" f"فعلی: هر {hours:g} ساعت (تنظیم: {cur})\n\n" f"یک گزینه را انتخاب کنید یا عدد ساعت را بفرستید.", reply_markup=InlineKeyboardMarkup([ [ InlineKeyboardButton("۱ ساعت", callback_data="admin_backup_set_1"), InlineKeyboardButton("۲ ساعت", callback_data="admin_backup_set_2"), InlineKeyboardButton("۶ ساعت", callback_data="admin_backup_set_6"), ], [ InlineKeyboardButton("۱۲ ساعت", callback_data="admin_backup_set_12"), InlineKeyboardButton("۲۴ ساعت", callback_data="admin_backup_set_24"), ], [ InlineKeyboardButton("▶️ بکاپ الان", callback_data="admin_backup_now"), InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel"), ], ]), parse_mode="HTML", ) return ConversationHandler.END if data.startswith("admin_backup_set_"): from database import set_setting_sync from handlers.group_reports import reschedule_backup_job raw = data.replace("admin_backup_set_", "") try: h = float(raw) except Exception: h = 2 h = max(1, min(h, 168)) set_setting_sync("backup_interval_hours", str(h)) try: reschedule_backup_job(context.application) except Exception as e: print("reschedule:", e) await query.answer(f"هر {h:g} ساعت") # refresh view data = "admin_backup_cfg" # fallthrough by re-dispatching - simpler message: await query.edit_message_text( f"✅ فاصله بکاپ روی هر {h:g} ساعت تنظیم شد.\nجاب زمان‌بندی دوباره ثبت شد.", reply_markup=InlineKeyboardMarkup([ [InlineKeyboardButton("💾 تنظیمات بکاپ", callback_data="admin_backup_cfg")], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")], ]), parse_mode="HTML", ) return ConversationHandler.END if data == "admin_backup_now": from handlers.group_reports import send_db_backup await query.answer("در حال بکاپ...") try: await send_db_backup(context.bot) msg = "✅ بکاپ ارسال شد (اگر گروه گزارش ست باشد)." except Exception as e: msg = f"❌ خطا: {e}" await query.edit_message_text( msg, reply_markup=InlineKeyboardMarkup([ [InlineKeyboardButton("💾 تنظیمات بکاپ", callback_data="admin_backup_cfg")], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")], ]), ) return ConversationHandler.END if data == "admin_optimize": from services.optimize import optimize_bot_data, format_optimize_report from database import get_setting_sync stats = optimize_bot_data() interval = get_setting_sync("optimize_interval_hours", "0") or "0" try: iv = float(interval) except Exception: iv = 0 schedule_line = ( f"\n\n⏱ زمان‌بندی خودکار: هر {iv:g} ساعت" if iv > 0 else "\n\n⏱ زمان‌بندی خودکار: خاموش" ) await query.edit_message_text( format_optimize_report(stats) + schedule_line + "\n\nبرای تغییر بازه، یکی از دکمه‌ها را بزنید (بعد از تغییر، یک‌بار ربات را ری‌استارت کنید).", reply_markup=InlineKeyboardMarkup([ [InlineKeyboardButton("🔄 دوباره همین الان", callback_data="admin_optimize")], [ InlineKeyboardButton("هر ۶س", callback_data="admin_opt_int_6"), InlineKeyboardButton("هر ۱۲س", callback_data="admin_opt_int_12"), InlineKeyboardButton("هر ۲۴س", callback_data="admin_opt_int_24"), ], [ InlineKeyboardButton("هر ۳روز", callback_data="admin_opt_int_72"), InlineKeyboardButton("هر ۷روز", callback_data="admin_opt_int_168"), InlineKeyboardButton("خاموش", callback_data="admin_opt_int_0"), ], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")], ]), parse_mode="HTML", ) return ConversationHandler.END if data.startswith("admin_opt_int_"): from database import set_setting_sync, get_setting_sync hours = data.replace("admin_opt_int_", "", 1) try: h = float(hours) except Exception: h = 0 set_setting_sync("optimize_interval_hours", str(h if h > 0 else 0)) label = f"هر {h:g} ساعت" if h > 0 else "خاموش" await query.edit_message_text( f"✅ زمان‌بندی بهینه‌سازی: {label}\n" "برای اعمال، سرویس ربات را یک‌بار ری‌استارت کنید.", reply_markup=InlineKeyboardMarkup([ [InlineKeyboardButton("🧹 بهینه‌سازی", callback_data="admin_optimize")], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")], ]), parse_mode="HTML", ) return ConversationHandler.END if data == "admin_hourly": from database import get_setting_sync, set_setting_sync cur = get_setting_sync("hourly_global_enabled", "0") await query.edit_message_text( f"⏱ سرویس ساعتی سراسری: {'فعال ✅' if cur == '1' else 'غیرفعال ❌'}\n\n" "می‌توانید برای هر محصول هم hourly را جداگانه در وب‌پنل فعال کنید.", reply_markup=InlineKeyboardMarkup([ [InlineKeyboardButton( "خاموش کردن" if cur == "1" else "روشن کردن", callback_data="admin_hourly_toggle", )], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")], ]), ) return ConversationHandler.END if data == "admin_hourly_toggle": from database import get_setting_sync, set_setting_sync cur = get_setting_sync("hourly_global_enabled", "0") set_setting_sync("hourly_global_enabled", "0" if cur == "1" else "1") # reuse data = "admin_hourly" # fall through by recursive style - just re-show cur2 = get_setting_sync("hourly_global_enabled", "0") await query.edit_message_text( f"⏱ سرویس ساعتی سراسری: {'فعال ✅' if cur2 == '1' else 'غیرفعال ❌'}", reply_markup=InlineKeyboardMarkup([ [InlineKeyboardButton( "خاموش کردن" if cur2 == "1" else "روشن کردن", callback_data="admin_hourly_toggle", )], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_panel")], ]), ) return ConversationHandler.END return ConversationHandler.END async def receive_admin_text(update: Update, context: ContextTypes.DEFAULT_TYPE): user=update.effective_user if not user or not is_admin(user.id): return ConversationHandler.END text=(update.message.text or "").strip() if text.lower() in ("/cancel", "cancel", "انصراف"): for k in list(context.user_data.keys()): if k.startswith("admin_") or k in ("edit_msg_key", "ord_edit_id", "ord_edit_field"): context.user_data.pop(k, None) await update.message.reply_text("❌ لغو شد.", reply_markup=main_keyboard()) return ConversationHandler.END mode=context.user_data.pop("admin_input_mode",None) if mode == "web_url": from database import set_setting_sync url = text.strip() if not url.startswith("http"): await update.message.reply_text("آدرس باید با http:// یا https:// شروع شود.") return WAITING_ADMIN_TEXT set_setting_sync("web_panel_url", url) await update.message.reply_text( f"✅ آدرس وب‌پنل ذخیره شد:\n{url}", parse_mode="HTML", reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🛠 وب‌پنل", callback_data="admin_web")]]), ) return ConversationHandler.END if mode == "trial_vol": from database import set_setting_sync try: val = float(text.replace(",", ".")) if val <= 0: raise ValueError() except Exception: await update.message.reply_text("عدد معتبر بفرستید.") context.user_data["admin_input_mode"] = "trial_vol" return WAITING_ADMIN_TEXT set_setting_sync("trial_volume_gb", str(val)) await update.message.reply_text( f"✅ حجم تست: {val} GB", reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🌱 رشد", callback_data="admin_growth")]]), ) return ConversationHandler.END if mode == "trial_days": from database import set_setting_sync try: val = int(float(text)) if val <= 0: raise ValueError() except Exception: await update.message.reply_text("عدد صحیح بفرستید.") context.user_data["admin_input_mode"] = "trial_days" return WAITING_ADMIN_TEXT set_setting_sync("trial_days", str(val)) await update.message.reply_text( f"✅ مدت تست: {val} روز", reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🌱 رشد", callback_data="admin_growth")]]), ) return ConversationHandler.END if mode == "gift_add": from db_users import create_gift_code parts = text.split() if len(parts) < 2: await update.message.reply_text("فرمت: کد مبلغ [حداکثر_استفاده]") context.user_data["admin_input_mode"] = "gift_add" return WAITING_ADMIN_TEXT code = parts[0].upper() try: amount = int(float(parts[1].replace(",", ""))) max_uses = int(parts[2]) if len(parts) > 2 else 1 except Exception: await update.message.reply_text("مبلغ/تعداد نامعتبر.") context.user_data["admin_input_mode"] = "gift_add" return WAITING_ADMIN_TEXT ok = create_gift_code(code, amount, max_uses) await update.message.reply_text( f"{'✅ ساخته شد' if ok else '❌ خطا (شاید کد تکراری)'}: {code} — {amount:,}", reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🏷 کدها", callback_data="admin_gifts")]]), ) return ConversationHandler.END if mode == "ticket_reply": tid = context.user_data.pop("admin_reply_ticket", None) if not tid: await update.message.reply_text("تیکت نامشخص.") return ConversationHandler.END try: from db_support import add_ticket_message, get_ticket add_ticket_message(tid, "admin", text) t = get_ticket(tid) or {} tg = t.get("telegram_id") if tg: try: await context.bot.send_message(int(tg), f"🎧 پاسخ پشتیبانی (تیکت #{tid}):\n{text}") except Exception: pass await update.message.reply_text( "✅ پاسخ ثبت و برای کاربر ارسال شد.", reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🎧 تیکت‌ها", callback_data="admin_tickets")]]), ) except Exception as e: await update.message.reply_text(f"خطا: {e}") return ConversationHandler.END if mode == "stars_rate": from database import set_setting_sync try: val = int(float(text.replace(",", "").replace("،", ""))) if val <= 0: raise ValueError() except Exception: await update.message.reply_text("عدد معتبر بفرستید (مثلاً 1000).") context.user_data["admin_input_mode"] = "stars_rate" return WAITING_ADMIN_TEXT set_setting_sync("stars_rate", str(val)) await update.message.reply_text( f"✅ نرخ استارز: هر استار ≈ {val:,} تومان", reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("💳 کارت‌ها", callback_data="admin_cards")]]), ) return ConversationHandler.END if mode == "card_min_purchases": from database import set_setting_sync try: val = int(text.strip()) if val < 0: raise ValueError() except Exception: await update.message.reply_text("عدد صحیح ≥ 0 بفرستید.") context.user_data["admin_input_mode"] = "card_min_purchases" return WAITING_ADMIN_TEXT set_setting_sync("card_min_purchases", str(val)) note = "همیشه نمایش داده می‌شود" if val == 0 else f"بعد از {val} خرید موفق" await update.message.reply_text( f"✅ حداقل خرید برای نمایش کارت: {val}\n({note})", reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("💳 کارت‌ها", callback_data="admin_cards")]]), ) return ConversationHandler.END if mode == "order_search": from db_products import list_all_orders orders = list_all_orders(search=text, limit=20) if not orders: await update.message.reply_text( "نتیجه‌ای یافت نشد.", reply_markup=InlineKeyboardMarkup([ [InlineKeyboardButton("🔎 دوباره", callback_data="admin_order_search")], [InlineKeyboardButton("🔙 بازگشت", callback_data="admin_orders")], ]), ) return ConversationHandler.END rows = [] lines = [f"🔎 نتیجه: {len(orders)} مورد\n"] for o in orders: lines.append( f"• #{o['id']} {o.get('vpn_username') or '—'} " f"| tg:{o.get('telegram_id')} | {o.get('product_name') or ''}" ) rows.append([InlineKeyboardButton( f"#{o['id']} {o.get('vpn_username') or ''}"[:40], callback_data=f"admin_ord_{o['id']}", )]) rows.append([InlineKeyboardButton("🔎 جستجوی دوباره", callback_data="admin_order_search")]) rows.append([InlineKeyboardButton("🔙 بازگشت", callback_data="admin_orders")]) await update.message.reply_text( "\n".join(lines)[:3500], reply_markup=InlineKeyboardMarkup(rows), ) return ConversationHandler.END if mode=="search_users": from db_users import list_bot_users, ROLE_LABELS users,total=list_bot_users(limit=15,search=text) rows=[] lines=[f"🔎 نتیجه جستجو: {total} کاربر\n"] for u in users: lines.append(f"• {u['telegram_id']} @{u.get('username') or '—'} — {int(u.get('balance') or 0):,}") rows.append([InlineKeyboardButton(f"👤 {u['telegram_id']}",callback_data=f"admin_bu_{u['telegram_id']}")]) rows.append([InlineKeyboardButton("🔎 جستجوی دوباره",callback_data="admin_user_search")]) rows.append([InlineKeyboardButton("🔙 مدیریت",callback_data="admin_panel")]) await update.message.reply_text("\n".join(lines),reply_markup=InlineKeyboardMarkup(rows),parse_mode="HTML") return ConversationHandler.END if mode=="welcome_all": from database import set_setting_sync set_setting_sync("welcome_message",text) await update.message.reply_text("✅ پیام خوش‌آمدگویی ذخیره شد.",reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("📝 پیام‌ها",callback_data="admin_msgs")]])) return ConversationHandler.END if mode and mode.startswith("ref_"): from database import set_setting_sync keymap={"pct":"referral_percent","signup":"referral_signup_bonus","min":"referral_min_amount","cap":"referral_monthly_cap"} key=keymap.get(mode[4:]) if not text.isdigit(): await update.message.reply_text("فقط عدد وارد کنید.") return ConversationHandler.END set_setting_sync(key,text) await update.message.reply_text("✅ تنظیم رفرال ذخیره شد.",reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🎁 رفرال",callback_data="admin_referral")]])) return ConversationHandler.END if mode=="panel_max": if not text.isdigit(): await update.message.reply_text("فقط عدد وارد کنید.") return ConversationHandler.END pid=int(context.user_data.pop("admin_panel_id",0)) from database import get_sync_connection conn=get_sync_connection() try: with conn.cursor() as cur: cur.execute("UPDATE vpn_panels SET max_sales=%s WHERE id=%s",(None if int(text)==0 else int(text),pid)) conn.commit() finally: conn.close() await update.message.reply_text("✅ سقف فروش ذخیره شد.",reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🖥 پنل‌ها",callback_data="admin_panels")]])) return ConversationHandler.END if mode == "menu_label": key = context.user_data.pop("edit_menu_key", None) from db_extras import get_menu_buttons, set_menu_buttons items = get_menu_buttons() found = False for it in items: if it.get("key") == key: it["label"] = text[:120] found = True break if found: set_menu_buttons(items) await update.message.reply_text( f"✅ نام دکمه {key} ذخیره شد.\nکاربر با /start منوی جدید را می‌بیند.", parse_mode="HTML", reply_markup=InlineKeyboardMarkup([ [InlineKeyboardButton("⌨️ دکمه‌ها", callback_data="admin_menu_labels")], [InlineKeyboardButton("🔙 مدیریت", callback_data="admin_panel")], ]), ) else: await update.message.reply_text("❌ دکمه یافت نشد.", reply_markup=main_keyboard()) return ConversationHandler.END # ---- افزودن محصول مرحله‌ای ---- if mode == "prod_name": context.user_data.setdefault("prod_new", {})["name"] = text[:120] context.user_data["admin_input_mode"] = "prod_price" await update.message.reply_text( "➕ مرحله ۲/۴ — قیمت (تومان) را فقط عدد بفرستید:\n/cancel برای انصراف" ) return WAITING_ADMIN_TEXT if mode == "prod_price": try: price = int(text.replace(",", "").replace("،", "")) if price < 0: raise ValueError except Exception: await update.message.reply_text("❌ قیمت نامعتبر. فقط عدد:\n/cancel انصراف") return WAITING_ADMIN_TEXT context.user_data.setdefault("prod_new", {})["price"] = price context.user_data["admin_input_mode"] = "prod_vol" await update.message.reply_text( "➕ مرحله ۳/۴ — حجم (گیگابایت) را بفرستید:\n" "/skip = نامحدود\n/cancel انصراف" ) return WAITING_ADMIN_TEXT if mode == "prod_vol": if text.lower() in ("/skip", "skip"): vol = 0 else: try: vol = float(text.replace(",", ".")) if vol < 0: raise ValueError except Exception: await update.message.reply_text("❌ حجم نامعتبر. عدد یا /skip:\n/cancel انصراف") return WAITING_ADMIN_TEXT context.user_data.setdefault("prod_new", {})["volume_gb"] = vol context.user_data["admin_input_mode"] = "prod_days" await update.message.reply_text( "➕ مرحله ۴/۴ — مدت (روز) را بفرستید:\n" "/skip = نامحدود\n/cancel انصراف" ) return WAITING_ADMIN_TEXT if mode == "prod_days": if text.lower() in ("/skip", "skip"): days = 0 else: try: days = int(text) if days < 0: raise ValueError except Exception: await update.message.reply_text("❌ روز نامعتبر. عدد یا /skip:\n/cancel انصراف") return WAITING_ADMIN_TEXT prod = context.user_data.pop("prod_new", {}) or {} context.user_data.pop("admin_input_mode", None) name = prod.get("name") or "محصول" price = int(prod.get("price") or 0) vol = float(prod.get("volume_gb") or 0) from db_products import create_product try: pid = create_product(name=name, price=price, volume_gb=vol, duration_days=days) await update.message.reply_text( f"✅ محصول #{pid} «{name}»\n" f"قیمت: {price:,} | حجم: {'∞' if vol<=0 else vol}GB | روز: {'∞' if days<=0 else days}", reply_markup=InlineKeyboardMarkup([ [InlineKeyboardButton("📦 محصولات", callback_data="admin_products")], [InlineKeyboardButton("➕ یکی دیگر", callback_data="admin_product_add")], [InlineKeyboardButton("🔙 مدیریت", callback_data="admin_panel")], ]), ) except Exception as e: await update.message.reply_text(f"❌ خطا: {e}", reply_markup=main_keyboard()) return ConversationHandler.END if mode == "product_add": # سازگاری قدیمی → هدایت به فلو مرحله‌ای context.user_data["prod_new"] = {} context.user_data["admin_input_mode"] = "prod_name" await update.message.reply_text("نام محصول را بفرستید:\n/cancel انصراف") return WAITING_ADMIN_TEXT if mode == "as_hits": from database import set_setting_sync try: v = int(text.strip()) if v < 1: v = 1 except Exception: await update.message.reply_text("عدد معتبر بفرستید.") return WAITING_ADMIN_TEXT set_setting_sync("antispam_max_hits", str(v)) await update.message.reply_text(f"حداکثر پیام: {v}") return ConversationHandler.END if mode == "as_window": from database import set_setting_sync try: v = int(text.strip()) if v < 1: v = 1 except Exception: await update.message.reply_text("عدد معتبر بفرستید.") return WAITING_ADMIN_TEXT set_setting_sync("antispam_window_sec", str(v)) await update.message.reply_text(f"بازه: {v} ثانیه") return ConversationHandler.END if mode == "as_ban": from database import set_setting_sync try: v = int(text.strip()) if v < 30: v = 30 except Exception: await update.message.reply_text("عدد معتبر بفرستید.") return WAITING_ADMIN_TEXT set_setting_sync("antispam_ban_sec", str(v)) await update.message.reply_text(f"مدت محدودیت: {v} ثانیه") return ConversationHandler.END if mode == "as_msg": from database import set_setting_sync set_setting_sync("antispam_message", text.strip()[:500]) await update.message.reply_text("پیام محدودیت ذخیره شد.") return ConversationHandler.END if mode == "card_title": from database import set_setting_sync title = text.strip()[:100] or "کارت به کارت" set_setting_sync("card_payment_title", title) try: from db_users import set_payment_method_title set_payment_method_title("card", title) except Exception: pass await update.message.reply_text("✅ نام دکمه کارت‌به‌کارت ذخیره شد.", reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("💳 کارت‌ها", callback_data="admin_cards")]])) return ConversationHandler.END if mode in ("variza_api", "variza_secret", "public_url", "variza_title"): from database import set_setting_sync key = {"variza_api":"variza_api_key", "variza_secret":"variza_webhook_secret", "public_url":"public_base_url", "variza_title":"variza_title"}[mode] val = text.strip() if mode == "public_url": val = val.rstrip("/") if val and not val.startswith("https://"): await update.message.reply_text("❌ آدرس باید با https:// شروع شود.") return WAITING_ADMIN_TEXT if mode == "variza_title": val = val[:100] or "پرداخت واریزا" set_setting_sync(key, val) if mode == "variza_title": try: from db_users import set_payment_method_title set_payment_method_title("variza", val) except Exception: pass await update.message.reply_text("✅ ذخیره شد.", reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🟣 تنظیمات واریزا", callback_data="admin_variza")]])) return ConversationHandler.END if mode == "auto_approve_mins": from database import set_setting_sync try: mins = int(text.strip()) if mins < 0: mins = 0 except Exception: await update.message.reply_text("عدد معتبر بفرستید (مثال: 30)") return WAITING_ADMIN_TEXT set_setting_sync("card_auto_approve_minutes", str(mins)) await update.message.reply_text( f"تایید خودکار روی {mins} دقیقه تنظیم شد." + (" (خاموش)" if mins == 0 else ""), reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("کارت‌ها", callback_data="admin_cards")]]), ) return ConversationHandler.END if mode == "auto_approve_users": from database import set_setting_sync val = text.strip() if val in ("-", "0", "none", "پاک"): val = "" # normalize parts = [p.strip() for p in val.replace(" ", "").split(",") if p.strip().isdigit()] set_setting_sync("card_auto_approve_users", ",".join(parts)) await update.message.reply_text( "کاربران تایید خودکار ذخیره شد: " + (",".join(parts) if parts else "خالی"), reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("کارت‌ها", callback_data="admin_cards")]]), ) return ConversationHandler.END if mode=="card_add": parts=[x.strip() for x in text.split("|")] if len(parts)<2 or not parts[0] or not parts[1]: await update.message.reply_text("فرمت نامعتبر است. شماره | صاحب | بانک") return ConversationHandler.END from db_users import add_card add_card(parts[0],parts[1],parts[2] if len(parts)>2 and parts[2] else None) await update.message.reply_text("✅ کارت اضافه شد.",reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("💳 کارت‌ها",callback_data="admin_cards")]])) return ConversationHandler.END if mode == "bot_admin_add": from db_extras import add_bot_admin tid = text.strip().lstrip("@") if not tid.isdigit(): await update.message.reply_text("❌ فقط آیدی عددی بفرستید (مثال: 123456789)") return WAITING_ADMIN_TEXT ok = add_bot_admin(int(tid)) msg = f"✅ ادمین {tid} اضافه شد." if ok else f"ℹ️ {tid} از قبل ادمین بود یا خطا رخ داد." await update.message.reply_text(msg, parse_mode="HTML", reply_markup=main_keyboard()) return ConversationHandler.END if mode=="web_user": from database import get_sync_connection new_user = (text or "").strip()[:50] if not new_user: await update.message.reply_text("❌ نام کاربری نمی‌تواند خالی باشد.") return WAITING_ADMIN_TEXT conn=get_sync_connection() ok = False try: with conn.cursor() as cur: cur.execute("UPDATE admins SET username=%s ORDER BY id LIMIT 1", (new_user,)) ok = cur.rowcount > 0 conn.commit() finally: conn.close() msg = "✅ نام کاربری وب‌پنل تغییر کرد." if ok else "❌ خطا در تغییر نام کاربری (ممکن است جدول admins خالی باشد)." await update.message.reply_text(msg, reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🔙 مدیریت",callback_data="admin_panel")]])) return ConversationHandler.END if mode=="web_pass": from database import set_admin_password pwd = (text or "").strip() if not pwd or len(pwd) < 4: await update.message.reply_text("❌ رمز باید حداقل ۴ کاراکتر باشد.\nدوباره بفرستید یا /cancel") return WAITING_ADMIN_TEXT ok = set_admin_password(pwd) msg = "✅ رمز وب‌پنل با موفقیت تغییر کرد." if ok else "❌ خطا در تغییر رمز (ممکن است جدول admins خالی باشد)." await update.message.reply_text(msg, reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🔙 مدیریت", callback_data="admin_panel")]])) return ConversationHandler.END if mode == "broadcast": if text.lower() in ("/cancel", "cancel", "انصراف"): context.user_data.pop("admin_input_mode", None) context.user_data.pop("admin_broadcast_mode", None) await update.message.reply_text( "❌ ارسال همگانی لغو شد.", reply_markup=main_keyboard(), ) return ConversationHandler.END context.user_data["admin_broadcast_text"] = text context.user_data.pop("admin_input_mode", None) await update.message.reply_text( "📌 آیا پیام پین شود؟", reply_markup=InlineKeyboardMarkup([ [ InlineKeyboardButton("✅ پین شود", callback_data="admin_bc_pin_yes"), InlineKeyboardButton("❌ پین نشود", callback_data="admin_bc_pin_no"), ], [InlineKeyboardButton("🔙 انصراف", callback_data="admin_panel")], ]), ) return ConversationHandler.END if mode == "broadcast_opts": # سازگاری با ورودی متنی قدیمی — هدایت به فلو دکمه‌ای context.user_data["admin_broadcast_text"] = context.user_data.get("admin_broadcast_text") or text context.user_data.pop("admin_input_mode", None) await update.message.reply_text( "📌 آیا پیام پین شود؟", reply_markup=InlineKeyboardMarkup([ [ InlineKeyboardButton("✅ پین شود", callback_data="admin_bc_pin_yes"), InlineKeyboardButton("❌ پین نشود", callback_data="admin_bc_pin_no"), ], [InlineKeyboardButton("🔙 انصراف", callback_data="admin_panel")], ]), ) return ConversationHandler.END await update.message.reply_text("ورودی نامعتبر است.") return ConversationHandler.END async def receive_welcome_message(update: Update, context: ContextTypes.DEFAULT_TYPE): user = update.effective_user if not user or not is_admin(user.id): return ConversationHandler.END new_message = (update.message.text or "").strip() if new_message.lower() in ("/cancel", "cancel", "انصراف"): context.user_data.pop("edit_msg_key", None) await update.message.reply_text("❌ لغو شد.", reply_markup=main_keyboard()) return ConversationHandler.END if not new_message: await update.message.reply_text("❌ پیام خالی است.\n/cancel برای انصراف") return WAITING_WELCOME edit_key = context.user_data.pop("edit_msg_key", None) if edit_key: from db_users import set_template set_template(edit_key, new_message) await update.message.reply_text(f"✅ پیام {edit_key} ذخیره شد.", reply_markup=main_keyboard(), parse_mode="HTML") return ConversationHandler.END await set_setting("welcome_message", new_message) await update.message.reply_text("✅ ذخیره شد.", reply_markup=main_keyboard(), parse_mode="HTML") return ConversationHandler.END async def receive_user_field(update: Update, context: ContextTypes.DEFAULT_TYPE): """جمع‌آوری فیلدهای ساخت/ویرایش کاربر VPN به‌صورت گفتگو + ادیت سفارش + ایموجی پریمیوم""" user = update.effective_user if not user or not is_admin(user.id): return ConversationHandler.END text = (update.message.text or "").strip() # ---- ادیت سرویس فروخته‌شده ---- if context.user_data.get("ord_edit_id") and context.user_data.get("ord_edit_field"): from services.service_edit import edit_sold_service oid = context.user_data.pop("ord_edit_id") field = context.user_data.pop("ord_edit_field") kwargs = {} try: if field == "vol": kwargs["volume_gb"] = float(text) elif field == "days": kwargs["duration_days"] = int(text) elif field == "hwid": kwargs["hwid_limit"] = int(text) elif field == "status": if text not in ("active", "disabled", "on_hold"): await update.message.reply_text("فقط active / disabled / on_hold") context.user_data["ord_edit_id"] = oid context.user_data["ord_edit_field"] = field return WAITING_USER_FIELD kwargs["status"] = text except ValueError: await update.message.reply_text("مقدار نامعتبر. دوباره بفرستید:") context.user_data["ord_edit_id"] = oid context.user_data["ord_edit_field"] = field return WAITING_USER_FIELD result = edit_sold_service(oid, **kwargs) if result.get("ok"): await update.message.reply_text(f"✅ سرویس #{oid} به‌روز شد و در پاسارگارد ثبت شد.", reply_markup=main_keyboard()) else: await update.message.reply_text(f"❌ خطا: {result.get('error')}", reply_markup=main_keyboard()) return ConversationHandler.END # ---- ایموجی پریمیوم ---- if context.user_data.get("premiji_step") == "code": from db_extras import gen_premium_code, add_premium_emoji code = text if text.startswith("p_") else (gen_premium_code() if not text else None) if not code or not code.startswith("p_"): await update.message.reply_text("کد باید با p_ شروع شود. دوباره:") return WAITING_USER_FIELD context.user_data["premiji_code"] = code context.user_data["premiji_step"] = "emoji" await update.message.reply_text( f"کد: {code}\n\nحالا یک پیام با ایموجی پریمیوم (کاستوم) بفرستید.", parse_mode="HTML", ) return WAITING_USER_FIELD if context.user_data.get("premiji_step") == "emoji": from db_extras import add_premium_emoji code = context.user_data.get("premiji_code") # استخراج custom_emoji_id از entities entities = update.message.entities or [] emoji_id = None for ent in entities: if getattr(ent, "type", None) == "custom_emoji": emoji_id = str(getattr(ent, "custom_emoji_id", "") or "") break if not emoji_id: # ممکن است فقط عدد فرستاده شود if text.isdigit(): emoji_id = text else: await update.message.reply_text("ایموجی پریمیوم یافت نشد. یک پیام با ایموجی کاستوم بفرستید یا شناسه عددی:") return WAITING_USER_FIELD ok = add_premium_emoji(code, emoji_id, created_by=user.id) context.user_data.pop("premiji_step", None) context.user_data.pop("premiji_code", None) if ok: await update.message.reply_text( f"✅ ثبت شد.\nکد: {code}\nID: {emoji_id}\n\n" f"هر جا از {code} استفاده کنید با parse_mode=HTML به ایموجی پریمیوم تبدیل می‌شود.", reply_markup=main_keyboard(), parse_mode="HTML", ) else: await update.message.reply_text("❌ خطا در ثبت.", reply_markup=main_keyboard()) return ConversationHandler.END step = context.user_data.get("vpn_step") mode = context.user_data.get("vpn_mode") pdata = context.user_data.setdefault("vpn_user", {}) pid = context.user_data.get("vpn_panel_id") panel = get_panel_by_id(pid) if pid else None if not panel: await update.message.reply_text("پنل نامعتبر. از /admin دوباره شروع کنید.") return ConversationHandler.END if step == "username": if len(text) < 3 or len(text) > 32: await update.message.reply_text("نام کاربری نامعتبر. دوباره بفرستید:") return WAITING_USER_FIELD pdata["username"] = text context.user_data["vpn_step"] = "status" await update.message.reply_text("وضعیت را بفرستید:\nactive یا on_hold", parse_mode="HTML") return WAITING_USER_FIELD if step == "status": if text not in ("active", "on_hold", "disabled"): await update.message.reply_text("فقط active / on_hold / disabled") return WAITING_USER_FIELD pdata["status"] = text if text == "on_hold": context.user_data["vpn_step"] = "on_hold_days" await update.message.reply_text("مدت on_hold به روز (مثلاً 30):") return WAITING_USER_FIELD context.user_data["vpn_step"] = "data_limit" await update.message.reply_text("حد حجم (گیگابایت) — 0 نامحدود:") return WAITING_USER_FIELD if step == "on_hold_days": try: days = int(text) if days <= 0: raise ValueError() pdata["on_hold_expire_duration"] = days * 86400 except ValueError: await update.message.reply_text("عدد روز معتبر بفرستید:") return WAITING_USER_FIELD context.user_data["vpn_step"] = "data_limit" await update.message.reply_text("حد حجم (گیگابایت) — 0 نامحدود:") return WAITING_USER_FIELD if step == "data_limit": if text != "-": try: pdata["data_limit_gb"] = float(text) except ValueError: await update.message.reply_text("عدد معتبر بفرستید:") return WAITING_USER_FIELD context.user_data["vpn_step"] = "expire" await update.message.reply_text( "تاریخ پایان (مثال 2026-12-31) یا 0 برای نامحدود:", parse_mode="HTML", ) return WAITING_USER_FIELD if step == "expire": if text not in ("0", "-"): pdata["expire"] = text else: pdata["expire"] = None context.user_data["vpn_step"] = "groups" # لیست گروه‌ها try: client = PasarGuardClient(panel["base_url"], panel["username"], panel["password"], verify_ssl=False) groups = client.get_groups() context.user_data["vpn_groups"] = groups if groups: lines = ["شناسه گروه‌ها را با ویرگول بفرستید (یا 0 برای هیچ):"] for g in groups[:30]: gid = g.get("id", g.get("id")) lines.append(f"• {g.get('name', '?')} → {gid}") await update.message.reply_text("\n".join(lines), parse_mode="HTML") else: await update.message.reply_text("گروهی نیست. 0 بفرستید:") except Exception as e: await update.message.reply_text(f"گروه دریافت نشد ({e}). 0 بفرستید:") return WAITING_USER_FIELD if step == "groups": if text not in ("0", "-"): ids = [int(x) for x in text.replace(" ", "").split(",") if x.isdigit()] pdata["group_ids"] = ids else: pdata["group_ids"] = [] context.user_data["vpn_step"] = "hwid" await update.message.reply_text("محدودیت HWID (تعداد دستگاه) یا 0 برای رد:") return WAITING_USER_FIELD if step == "hwid": if text not in ("0", "-"): try: pdata["hwid_limit"] = int(text) except ValueError: await update.message.reply_text("عدد معتبر:") return WAITING_USER_FIELD context.user_data["vpn_step"] = "note" await update.message.reply_text("توضیحات (یا - برای خالی):") return WAITING_USER_FIELD if step == "note": if text != "-": pdata["note"] = text # اجرا try: client = PasarGuardClient(panel["base_url"], panel["username"], panel["password"], verify_ssl=False) if mode == "create": payload = client.build_user_payload( username=pdata.get("username"), status=pdata.get("status", "active"), data_limit_gb=pdata.get("data_limit_gb", 0), expire=pdata.get("expire"), group_ids=pdata.get("group_ids", []), hwid_limit=pdata.get("hwid_limit"), note=pdata.get("note"), on_hold_expire_duration=pdata.get("on_hold_expire_duration"), for_create=True, ) u = client.create_user(payload) await update.message.reply_text( f"✅ کاربر {u.get('username', pdata.get('username'))} ساخته شد.", reply_markup=panel_menu_keyboard(pid), parse_mode="HTML", ) else: uname = context.user_data.get("vpn_edit_username") payload = client.build_user_payload( status=pdata.get("status"), data_limit_gb=pdata.get("data_limit_gb"), expire=pdata.get("expire"), group_ids=pdata.get("group_ids"), hwid_limit=pdata.get("hwid_limit"), note=pdata.get("note"), on_hold_expire_duration=pdata.get("on_hold_expire_duration"), for_create=False, ) client.modify_user(uname, payload) await update.message.reply_text( f"✅ کاربر {uname} ویرایش شد.", reply_markup=panel_menu_keyboard(pid), parse_mode="HTML", ) except Exception as e: await update.message.reply_text(f"❌ خطا: {e}", reply_markup=panel_menu_keyboard(pid)) context.user_data.pop("vpn_step", None) return ConversationHandler.END return ConversationHandler.END