Revise paste بوت 1

# -*- coding: utf-8 -*-
import logging
import pyfiglet
import requests
import re
import time
import random
import string
from colorama import init, Fore
from bs4 import BeautifulSoup
from datetime import datetime
import telebot
from telebot import types
from threading import Thread
import json
import os

# إعدادات التسجيل
logging.basicConfig(level=logging.INFO)

# تفعيل colorama
init(autoreset=False)

# توكن البوت
TELEGRAM_BOT_TOKEN = "6636872139:AAGfjgkKTirnN3ZJ6k0ylTDYZBp9tQ2M6-U"

# تهيئة البوت
bot = telebot.TeleBot(TELEGRAM_BOT_TOKEN, parse_mode="HTML")

# تعريف ألوان
RED = '\x1b[1;31m'
GREEN = '\x1b[1;32m'
YELLOW = '\x1b[1;33m'
BLUE = '\x1b[1;34m'
PURPLE = '\x1b[1;35m'
CYAN = '\x1b[1;36m'
WHITE = '\x1b[1;37m'
RESET = '\x1b[0m'

# ملف تخزين المستخدمين
USERS_FILE = 'registered_users.json'
user_data = {}
registered_users = {}

# تحميل المستخدمين
def load_users():
    global registered_users
    try:
        if os.path.exists(USERS_FILE):
            with open(USERS_FILE, 'r', encoding='utf-8') as f:
                registered_users = json.load(f)
    except Exception as e:
        print(f"Error loading users: {e}")
        registered_users = {}

def save_users():
    try:
        with open(USERS_FILE, 'w', encoding='utf-8') as f:
            json.dump(registered_users, f, ensure_ascii=False, indent=2)
    except Exception as e:
        print(f"Error saving users: {e}")

load_users()

# ===== الدوال المساعدة =====
def get_nonce():
    return ''.join(random.choice(string.ascii_lowercase) for _ in range(10))

def unified_login(number, password):
    """دالة تسجيل دخول موحدة"""
    with requests.Session() as session:
        try:
            base_url = 'https://web.vodafone.com.eg/auth/realms/vf-realm/protocol/openid-connect/auth'
            redirect_uri = 'https://web.vodafone.com.eg/ar/KClogin'
            nonce = get_nonce()
            url_action = f"{base_url}?client_id=website&redirect_uri={redirect_uri}&state=random_state&response_mode=query&response_type=code&scope=openid&nonce={nonce}&kc_locale=ar"

response_url_action = session.get(url_action)
            soup = BeautifulSoup(response_url_action.content, 'html.parser')
            form_action = soup.find('form').get('action')

data = {'username': number, 'password': password}
            response_login = session.post(form_action, data=data)

if "KClogin" in response_login.url:
                code = response_login.url.split('code=')[1]
                data_token = {
                    'code': code,
                    'grant_type': 'authorization_code',
                    'client_id': 'website',
                    'redirect_uri': redirect_uri
                }
                token_response = session.post(
                    'https://web.vodafone.com.eg/auth/realms/vf-realm/protocol/openid-connect/token',
                    data=data_token
                )
                return token_response.json().get('access_token')
            return None
        except Exception as e:
            return None

# ===== نظام التسجيل الدائم =====
def register_user(chat_id, phone, password):
    """تسجيل مستخدم جديد بشكل دائم"""
    registered_users[str(chat_id)] = {
        'phone': phone,
        'password': password,
        'registration_date': datetime.now().strftime("%Y-%m-%d %H:%M:%S")
    }
    save_users()
    return True

def is_user_registered(chat_id):
    """التحقق إذا كان المستخدم مسجل"""
    return str(chat_id) in registered_users

def get_user_credentials(chat_id):
    """الحصول على بيانات المستخدم المسجل"""
    user = registered_users.get(str(chat_id))
    if user:
        return user['phone'], user['password']
    return None, None

def delete_user(chat_id):
    """حذف مستخدم (لعملية إعادة التسجيل)"""
    if str(chat_id) in registered_users:
        del registered_users[str(chat_id)]
        save_users()
        return True
    return False

# ===== دوال الخدمات الأساسية =====
def process_vodafone_family_info(username, password, chat_id):
    try:
        token = unified_login(username, password)
        if not token:
            bot.send_message(chat_id, "❌ فشل تسجيل الدخول - تأكد من صحة الرقم وكلمة المرور")
            return

url2 = 'https://mobile.vodafone.com.eg/services/dxl/cg/customerGroupAPI/customerGroup?type=Family'
        headers2 = {
            'channel': 'MOBILE',
            'useCase': 'Promo',
            'Authorization': f'Bearer {token}',
            'api-version': 'v2',
            'x-agent-operatingsystem': '11',
            'clientId': 'AnaVodafoneAndroid',
            'x-agent-device': 'OPPO CPH2059',
            'x-agent-version': '2024.3.3',
            'x-agent-build': '593',
            'msisdn': username,
            'Content-Type': 'application/json',
            'Accept': 'application/json',
            'Accept-Language': 'ar',
            'Host': 'mobile.vodafone.com.eg',
            'Connection': 'Keep-Alive',
            'Accept-Encoding': 'gzip',
            'User-Agent': 'okhttp/4.11.0',
        }

r2 = requests.get(url2, headers=headers2, timeout=10)
        if r2.status_code != 200:
            bot.send_message(chat_id, f"❌ خطأ في الخدمة: {r2.status_code}")
            return

data_resp = r2.json()
        members = []
        if isinstance(data_resp, list) and len(data_resp) > 0:
            parts = data_resp[0].get('parts', {}) if isinstance(data_resp[0], dict) else {}
            members = parts.get('member', []) if isinstance(parts, dict) else []
        else:
            if isinstance(data_resp, dict):
                parts = data_resp.get('parts', {})
                members = parts.get('member', [])
            else:
                members = []

owner_number = None
        member_numbers = []

for member in members:
            if not isinstance(member, dict):
                continue
            member_type = member.get('type')
            member_id = None
            try:
                id_field = member.get('id')
                if isinstance(id_field, list) and len(id_field) > 0 and isinstance(id_field[0], dict):
                    member_id = id_field[0].get('value')
                elif isinstance(id_field, dict):
                    member_id = id_field.get('value')
                elif isinstance(id_field, str):
                    member_id = id_field
            except Exception:
                member_id = None

if member_type == 'Owner':
                owner_number = member_id
            elif member_type == 'Member' and member_id:
                member_numbers.append(member_id)

result_message = "🎯 نتائج مجموعة العائلة:\n\n"
        if owner_number:
            result_message += f'👑 المالك (Owner): {owner_number}\n\n'

if member_numbers:
            result_message += '👥 الأعضاء (Members):\n' + '\n'.join([f'• {num}' for num in member_numbers]) + "\n"

if not owner_number and not member_numbers:
            result_message = "❌ لم يتم العثور على أي بيانات للمجموعة."

bot.send_message(chat_id, result_message)

except Exception as e:
        bot.send_message(chat_id, f"❌ حدث خطأ: {str(e)}")

def process_line_info(number, password, chat_id):
    token = unified_login(number, password)
    if not token:
        bot.send_message(chat_id, "❌ فشل تسجيل الدخول - تأكد من صحة الرقم وكلمة المرور")
        return

url2 = f'https://web.vodafone.com.eg/services/dxl/sam/serviceAccountManagement/v1/serviceAccount?@type=Profile&$.resources[?(@resourceType%3D%3D%27MSISDN%27)].IDs[0].value={number}'
    headers2 = {
        'channel': 'MOBILE',
        'useCase': 'Promo',
        'Authorization': f'Bearer {token}',
        'api-version': 'v2',
        'x-agent-operatingsystem': '11',
        'clientId': 'AnaVodafoneAndroid',
        'x-agent-device': 'OPPO CPH2059',
        'x-agent-version': '2024.3.3',
        'x-agent-build': '593',
        'msisdn': number,
        'Content-Type': 'application/json',
        'Accept': 'application/json',
        'Accept-Language': 'ar',
        'User-Agent': 'okhttp/4.11.0'
    }

try:
        r2 = requests.get(url2, headers=headers2).json()
        user_info = r2[0]

contact = user_info['contact'][0]
        billing_account = user_info['billingAccount']
        subscriptions = user_info.get('subscriptions', [])
        categories = user_info.get('categories', [])
        contract_id = user_info['IDs'][0]['value']
        status_history = user_info.get('statusHistory', [])

result = f"👤 الاسم: {contact['contactFirstName']} {contact['contactLastName']}\n"
        result += f"🆔 الرقم القومي: {contact.get('nationalID', 'غير متوفر')}\n"
        result += f"🏙️ المدينة: {contact['contactMedium'][0]['city']}\n"
        result += f"💳 رقم الحساب: {billing_account['IDs'][1]['value']}\n"
        result += f"🧾 كود العميل: {billing_account['IDs'][0]['value']}\n"
        result += f"📄 رقم العقد: {contract_id}\n\n"

if categories:
            result += "📌 التصنيفات:\n"
            for cat in categories:
                result += f" - {cat['listHirarchyId']} : {cat['value']}\n"

if subscriptions:
            result += "\n📜 الاشتراكات:\n"
            for sub in subscriptions:
                result += f" - {sub['name']}\n"

if status_history:
            result += "\n📶 حالة الخط:\n"
            for st in status_history:
                status_text = "نشط" if st['status'] == "Active" else "موقوف"
                result += f" - {status_text} (السبب: {st['statusReason']})\n"

bot.send_message(chat_id, result)

except Exception as e:
        bot.send_message(chat_id, f"❌ فشل في جلب البيانات: {e}")

def get_flex_balance(token, number, chat_id):
    """دالة الحصول على نسبة الفليكس"""
    headers = {
        'Accept': 'application/json',
        'Accept-Language': 'EN',
        'Authorization': f"Bearer {token}",
        'Connection': 'keep-alive',
        'Content-Type': 'application/json',
        'Referer': 'https://web.vodafone.com.eg/spa/familySharing',
        'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36',
        'clientId': 'WebsiteConsumer',
        'msisdn': number,
    }

try:
        response = requests.get(
            f'https://web.vodafone.com.eg/services/dxl/usage/usageConsumptionReport?bucket.product.publicIdentifier={number}&@type=aggregated',
            headers=headers,
        )
        
        if response.status_code == 200:
            data = response.json()
            for item in data:
                if item.get("@type") == "OTHERS":
                    for bucket in item.get("bucket", []):
                        if bucket.get("usageType") == "limit":
                            for balance in bucket.get("bucketBalance", []):
                                if balance.get("@type") == "Remaining" and balance["remainingValue"]["units"] == "FLEX":
                                    return balance["remainingValue"]["amount"]
            return None
        else:
            return None
    except Exception:
        return None

def process_flex_info(number, password, chat_id):
    token = unified_login(number, password)
    if not token:
        bot.send_message(chat_id, "❌ فشل تسجيل الدخول - تأكد من صحة الرقم وكلمة المرور")
        return

flex_balance = get_flex_balance(token, number, chat_id)
    current_time = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
    
    if flex_balance is not None:
        result_message = f"🎯 نسبة الفليكس الحالية: {flex_balance} فليكس\n"
        result_message += f"🕒 وقت الاستعلام: {current_time}\n"
        if flex_balance < 1000:
            result_message += "⚠️النسبه فوق 30لاف"
        bot.send_message(chat_id, result_message)
    else:
        bot.send_message(chat_id, "❌ لم يتم العثور على بيانات الفليكس")

# ===== دوال إرسال الدعوة والقبول =====
def addMember(owner_number, member_number, token, value=10):
    """إرسال دعوة انضمام للعائلة"""
    headers = {
        'Accept': 'application/json',
        'Accept-Language': 'EN',
        'Authorization': token,
        'Connection': 'keep-alive',
        'Content-Type': 'application/json',
        'Origin': 'https://web.vodafone.com.eg',
        'Referer': 'https://web.vodafone.com.eg/spa/familySharing/manageFamily',
        'Sec-Fetch-Dest': 'empty',
        'Sec-Fetch-Mode': 'cors',
        'Sec-Fetch-Site': 'same-origin',
        "User-Agent": "okhttp/4.11.0",
        "x-agent-operatingsystem": "11",
        "clientId": "AnaVodafoneAndroid",
        "x-agent-device": "Samsung_Galaxy_A52",
        "x-agent-version": "2024.7.1",
        "x-agent-build": "600",
        'msisdn': owner_number,
        'sec-ch-ua': '"Not)A;Brand";v="8", "Chromium";v="138", "Google Chrome";v="138"',
        'sec-ch-ua-mobile': '?0',
    }

json_data = {
        'name': 'FlexFamily',
        'type': 'SendInvitation',
        'category': [
            {
                'value': '523',
                'listHierarchyId': 'PackageID',
            },
            {
                'value': '47',
                'listHierarchyId': 'TemplateID',
            },
            {
                'value': '523',
                'listHierarchyId': 'TierID',
            },
            {
                'value': 'percentage',
                'listHierarchyId': 'familybehavior',
            },
        ],
        'parts': {
            'member': [
                {
                    'id': [
                        {
                            'value': owner_number,
                            'schemeName': 'MSISDN',
                        },
                    ],
                    'type': 'Owner',
                },
                {
                    'id': [
                        {
                            'value': member_number,
                            'schemeName': 'MSISDN',
                        },
                    ],
                    'type': 'Member',
                },
            ],
            'characteristicsValue': {
                'characteristicsValue': [
                    {
                        'characteristicName': 'quotaDist1',
                        'value': value,
                        'type': 'percentage',
                    },
                ],
            },
        },
    }

response = requests.patch(
        'https://mobile.vodafone.com.eg/services/dxl/cg/customerGroupAPI/customerGroup',
        headers=headers,
        json=json_data,
    )
    
    if response.status_code in [200, 201]:
        return True, f"✅ تم إرسال الدعوة إلى ({member_number}) بنجاح - النسبة: {value}%"
    else:
        return False, f"❌ فشل إرسال الدعوة إلى ({member_number}) - الكود: {response.status_code}"

def accept_invitation(owner_number, member_number, token):
    """قبول دعوة الانضمام للعائلة"""
    if token == "error":
        return False, "❌ توكن غير صالح"

url = "https://mobile.vodafone.com.eg/services/dxl/cg/customerGroupAPI/customerGroup"
    headers = {
        "api-host": "ProductOrderingManagement",
        "useCase": "MIProfile",
        "Authorization": token,
        "api-version": "v2",
        "x-agent-operatingsystem": "11",
        "clientId": "AnaVodafoneAndroid",
        "x-agent-device": "Samsung_Galaxy_A52",
        "x-agent-version": "2024.7.1",
        "x-agent-build": "600",
        "msisdn": member_number,
        "Accept": "application/json",
        "Accept-Language": "ar",
        "Content-Type": "application/json; charset=UTF-8",
        "Host": "mobile.vodafone.com.eg",
        "Connection": "Keep-Alive",
        "Accept-Encoding": "gzip",
        "User-Agent": "okhttp/4.11.0"
    }
    
    data = {
        "category": [{"listHierarchyId": "TemplateID", "value": "47"}],
        "name": "FlexFamily",
        "parts": {
            "member": [
                {"id": [{"schemeName": "MSISDN", "value": owner_number}], "type": "Owner"},
                {"id": [{"schemeName": "MSISDN", "value": member_number}], "type": "Member"}
            ]
        },
        "type": "AcceptInvitation"
    }
    
    response = requests.patch(url, headers=headers, json=data)
    response_text = response.text
    
    if response.status_code in [200, 201] or response_text == '{}':
        return True, f"✅ تم قبول الدعوة بنجاح"
    elif "Customer not eligible-Family member" in response_text:
        return True, f"⚠️ ({member_number}) موجود بالفعل في عائلة"
    else:
        return False, f"❌ خطأ في قبول الدعوة - الاستجابة: {response_text}"

def انتظار(ثواني, chat_id=None, نص="جاري الانتظار"):
    """دالة الانتظار مع إمكانية إرسال تحديثات للتلجرام"""
    if chat_id:
        bot.send_message(chat_id, f"⏳ {نص} {ثواني} ثانية...")
    
    for متبقي in range(ثواني, 0, -1):
        دقائق, ثواني_متبقية = divmod(متبقي, 60)
        time.sleep(1)
    
    return True

def محاولة_إرسال_الدعوة(رقم_الأونر, رقم_الفرد, توكن_الأونر, النسبة, chat_id, عدد_المحاولات=3):
    """محاولة إرسال الدعوة مع إعادة المحاولة"""
    if chat_id:
        bot.send_message(chat_id, f"🚀 بدء محاولات إرسال الدعوة ({عدد_المحاولات} محاولات)...")
    
    for محاولة in range(1, عدد_المحاولات + 1):
        if chat_id:
            bot.send_message(chat_id, f"📤 المحاولة رقم {محاولة} لإرسال الدعوة...")
        
        نجاح, رسالة = addMember(رقم_الأونر, رقم_الفرد, توكن_الأونر, النسبة)
        
        if نجاح:
            if chat_id:
                bot.send_message(chat_id, f"✅ نجحت المحاولة رقم {محاولة} في إرسال الدعوة")
            return True, رسالة
        else:
            if محاولة < عدد_المحاولات:
                if chat_id:
                    bot.send_message(chat_id, f"⏳ فشلت المحاولة رقم {محاولة}، جاري الانتظار 60 ثانية للمحاولة التالية...")
                انتظار(60, chat_id, "انتظار لإعادة إرسال الدعوة")
            else:
                if chat_id:
                    bot.send_message(chat_id, f"❌ فشلت جميع محاولات إرسال الدعوة بعد {عدد_المحاولات} محاولات")
    
    return False, رسالة

def محاولة_قبول_الدعوة(رقم_الأونر, رقم_الفرد, توكن_الفرد, chat_id, عدد_المحاولات=3):
    """محاولة قبول الدعوة مع إعادة المحاولة"""
    if chat_id:
        bot.send_message(chat_id, f"🤝 بدء محاولات قبول الدعوة ({عدد_المحاولات} محاولات)...")
    
    for محاولة in range(1, عدد_المحاولات + 1):
        if chat_id:
            bot.send_message(chat_id, f"✅ المحاولة رقم {محاولة} لقبول الدعوة...")
        
        نجاح, رسالة = accept_invitation(رقم_الأونر, رقم_الفرد, توكن_الفرد)
        
        if نجاح:
            if chat_id:
                bot.send_message(chat_id, f"✅ نجحت المحاولة رقم {محاولة} في قبول الدعوة")
            return True, رسالة
        else:
            if محاولة < عدد_المحاولات:
                if chat_id:
                    bot.send_message(chat_id, f"⏳ فشلت المحاولة رقم {محاولة}، جاري الانتظار 60 ثانية للمحاولة التالية...")
                انتظار(60, chat_id, "انتظار لإعادة قبول الدعوة")
            else:
                if chat_id:
                    bot.send_message(chat_id, f"❌ فشلت جميع محاولات قبول الدعوة بعد {عدد_المحاولات} محاولات")
    
    return False, رسالة

def process_invitation_accept(owner_number, owner_password, member_number, member_password, percentage, chat_id):
    """معالجة عملية إرسال الدعوة والقبول"""
    try:
        bot.send_message(chat_id, "🔐 جاري تسجيل دخول الأونر...")
        owner_token = unified_login(owner_number, owner_password)
        
        if not owner_token:
            bot.send_message(chat_id, "❌ فشل تسجيل دخول الأونر! تأكد من صحة الرقم وكلمة المرور")
            return
        
        bot.send_message(chat_id, "🔐 جاري تسجيل دخول الفرد...")
        member_token = unified_login(member_number, member_password)
        
        if not member_token:
            bot.send_message(chat_id, "❌ فشل تسجيل دخول الفرد! تأكد من صحة الرقم وكلمة المرور")
            return
        
        # إرسال الدعوة
        success_send, send_message = محاولة_إرسال_الدعوة(owner_number, member_number, f"Bearer {owner_token}", percentage, chat_id)
        
        if not success_send:
            bot.send_message(chat_id, "❌ توقف العملية بسبب فشل إرسال الدعوة")
            return
        
        bot.send_message(chat_id, send_message)
        
        # انتظار قبل القبول
        bot.send_message(chat_id, "⏳ جاري الانتظار قبل قبول الدعوة...")
        انتظار(10, chat_id, "انتظار قبل القبول")
        
        # قبول الدعوة
        success_accept, accept_message = محاولة_قبول_الدعوة(owner_number, member_number, f"Bearer {member_token}", chat_id)
        
        bot.send_message(chat_id, accept_message)
        
        if success_accept:
            bot.send_message(chat_id, f"🎉 تمت العملية بنجاح!\n\n"
                                     f"✅ الأونر: {owner_number}\n"
                                     f"✅ الفرد: {member_number}\n"
                                     f"✅ النسبة: {percentage}%\n"
                                     f"✅ الوقت: {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}")
        else:
            bot.send_message(chat_id, f"⚠️ تم إرسال الدعوة ولكن فشل قبولها\n"
                                     f"📱 يمكن للفرد قبول الدعوة يدوياً")
            
    except Exception as e:
        bot.send_message(chat_id, f"❌ حدث خطأ غير متوقع: {str(e)}")

# ===== نظام البوت الرئيسي مع التسجيل الدائم =====
@bot.message_handler(commands=['start'])
def send_welcome(message):
    try:
        chat_id = message.chat.id
        
        if is_user_registered(chat_id):
            # إذا كان المستخدم مسجل - عرض القائمة الرئيسية مباشرة
            show_main_menu(message)
        else:
            # إذا لم يكن مسجل - طلب التسجيل
            show_registration_welcome(message)
            
    except Exception as e:
        bot.reply_to(message, f"❌ حدث خطأ: {str(e)}")

def show_registration_welcome(message):
    """عرض رسالة ترحيب وطلب التسجيل"""
    welcome_text = "🎯 أهلاً بك في البوت المتكامل لفودافون!\n\n"
    welcome_text += "🔐 يبدو أن هذا هو أول استخدام لك.\n"
    welcome_text += "يجب التسجيل مرة واحدة فقط لاستخدام جميع الخدمات.\n\n"
    welcome_text += "📝 سيتم حفظ بياناتك بشكل آمن ولن تحتاج للتسجيل مرة أخرى."
    
    markup = types.ReplyKeyboardMarkup(resize_keyboard=True, row_width=2)
    btn1 = types.KeyboardButton("📝 التسجيل الآن")
    btn2 = types.KeyboardButton("ℹ️ معلومات عن البوت")
    markup.add(btn1, btn2)
    
    bot.send_message(message.chat.id, welcome_text, reply_markup=markup)

@bot.message_handler(func=lambda m: m.text == "📝 التسجيل الآن")
def start_registration(message):
    """بدء عملية التسجيل"""
    msg = bot.send_message(message.chat.id, "📱 يرجى إدخال رقم الهاتف (11 رقم):")
    bot.register_next_step_handler(msg, process_registration_phone)

def process_registration_phone(message):
    """معالجة رقم الهاتف للتسجيل"""
    try:
        chat_id = message.chat.id
        phone = message.text.strip()
        
        # التحقق من صحة الرقم
        if not re.match(r'^01[0-9]{9}$', phone):
            msg = bot.send_message(chat_id, "❌ رقم الهاتف غير صحيح. يرجى إدخال رقم مصري صحيح (11 رقم):")
            bot.register_next_step_handler(msg, process_registration_phone)
            return
        
        user_data[chat_id] = {'phone': phone}
        msg = bot.send_message(chat_id, "🔑 يرجى إدخال كلمة المرور:")
        bot.register_next_step_handler(msg, process_registration_password)
        
    except Exception as e:
        bot.send_message(chat_id, f"❌ حدث خطأ: {str(e)}")

def process_registration_password(message):
    """معالجة كلمة المرور للتسجيل"""
    try:
        chat_id = message.chat.id
        password = message.text.strip()
        
        if chat_id not in user_data:
            bot.send_message(chat_id, "❌ لم يتم إدخال رقم الهاتف. أرسل /start للبدء من جديد.")
            return
        
        phone = user_data[chat_id]['phone']
        
        # محاولة تسجيل الدخول للتحقق من صحة البيانات
        bot.send_message(chat_id, "⏳ جاري التحقق من بياناتك...")
        token = unified_login(phone, password)
        
        if token:
            # التسجيل ناجح - حفظ البيانات بشكل دائم
            register_user(chat_id, phone, password)
            bot.send_message(chat_id, "✅ تم التسجيل بنجاح!\n\n"
                                     "🔐 تم حفظ بياناتك بشكل آمن.\n"
                                     "⚠️ لن تحتاج للتسجيل مرة أخرى في المستقبل.\n\n"
                                     "يمكنك الآن استخدام جميع الخدمات مباشرة.")
            show_main_menu(message)
        else:
            bot.send_message(chat_id, "❌ بيانات الدخول غير صحيحة. يرجى المحاولة مرة أخرى بأرسال /start")
            
    except Exception as e:
        bot.send_message(chat_id, f"❌ حدث خطأ: {str(e)}")

def show_main_menu(message):
    """عرض القائمة الرئيسية للمستخدمين المسجلين"""
    chat_id = message.chat.id
    
    # الحصول على بيانات المستخدم لعرضها
    phone, _ = get_user_credentials(chat_id)
    
    welcome_text = f"🚀 أهلاً بك مرة أخرى!\n\n"
    welcome_text += f"📱 رقمك المسجل: {phone}\n\n"
    welcome_text += "🔍 الخدمات المتاحة:\n\n"
    welcome_text += "📊 بيانات الخط - معلومات الحساب والاشتراكات\n"
    welcome_text += "👥 معرفة الأونر - بيانات مجموعة العائلة\n"
    welcome_text += "💳 نسبة الفليكس - معرفة رصيد الفليكس المتبقي\n"
    welcome_text += "📨 إرسال دعوة - إرسال دعوة انضمام للعائلة\n"
    welcome_text += "👤 إدارة الحساب - تحديث أو حذف البيانات\n\n"
    welcome_text += "اختر الخدمة التي تريدها:"
    
    markup = types.ReplyKeyboardMarkup(resize_keyboard=True, row_width=2)
    btn1 = types.KeyboardButton("📊 بيانات الخط")
    btn2 = types.KeyboardButton("👥 معرفة الأونر")
    btn3 = types.KeyboardButton("💳 نسبة الفليكس")
    btn4 = types.KeyboardButton("📨 إرسال دعوة")
    btn5 = types.KeyboardButton("👤 إدارة الحساب")
    btn6 = types.KeyboardButton("🆘 المساعدة")
    markup.add(btn1, btn2, btn3, btn4, btn5, btn6)
    
    bot.send_message(chat_id, welcome_text, reply_markup=markup)

# ===== معالجة الخدمات للمستخدمين المسجلين =====
@bot.message_handler(func=lambda m: m.text in ["📊 بيانات الخط", "👥 معرفة الأونر", "💳 نسبة الفليكس"])
def handle_services(message):
    chat_id = message.chat.id
    
    if not is_user_registered(chat_id):
        bot.send_message(chat_id, "❌ يجب التسجيل أولاً. أرسل /start")
        return
    
    # استخدام البيانات المسجلة مسبقاً
    phone, password = get_user_credentials(chat_id)
    
    service_type = message.text
    bot.send_message(chat_id, "⏳ جاري معالجة طلبك، يرجى الانتظار...")
    
    if service_type == "📊 بيانات الخط":
        thread = Thread(target=process_line_info, args=(phone, password, chat_id))
    elif service_type == "👥 معرفة الأونر":
        thread = Thread(target=process_vodafone_family_info, args=(phone, password, chat_id))
    elif service_type == "💳 نسبة الفليكس":
        thread = Thread(target=process_flex_info, args=(phone, password, chat_id))
    else:
        bot.send_message(chat_id, "❌ خدمة غير معروفة.")
        return
        
    thread.start()

@bot.message_handler(func=lambda m: m.text == "📨 إرسال دعوة")
def start_invitation_process(message):
    """بدء عملية إرسال الدعوة"""
    chat_id = message.chat.id
    
    if not is_user_registered(chat_id):
        bot.send_message(chat_id, "❌ يجب التسجيل أولاً. أرسل /start")
        return
    
    msg = bot.send_message(chat_id, "👑 أدخل رقم الأونر:")
    bot.register_next_step_handler(msg, process_owner_number)

def process_owner_number(message):
    """معالجة رقم الأونر"""
    chat_id = message.chat.id
    owner_number = message.text.strip()
    
    if not re.match(r'^01[0-9]{9}$', owner_number):
        msg = bot.send_message(chat_id, "❌ رقم الأونر غير صحيح. يرجى إدخال رقم مصري صحيح (11 رقم):")
        bot.register_next_step_handler(msg, process_owner_number)
        return
    
    user_data[chat_id] = {'owner_number': owner_number}
    msg = bot.send_message(chat_id, "🔑 أدخل كلمة سر الأونر:")
    bot.register_next_step_handler(msg, process_owner_password)

def process_owner_password(message):
    """معالجة كلمة سر الأونر"""
    chat_id = message.chat.id
    owner_password = message.text.strip()
    
    user_data[chat_id]['owner_password'] = owner_password
    msg = bot.send_message(chat_id, "👤 أدخل رقم الفرد المراد إرسال الدعوة له:")
    bot.register_next_step_handler(msg, process_member_number)

def process_member_number(message):
    """معالجة رقم الفرد"""
    chat_id = message.chat.id
    member_number = message.text.strip()
    
    if not re.match(r'^01[0-9]{9}$', member_number):
        msg = bot.send_message(chat_id, "❌ رقم الفرد غير صحيح. يرجى إدخال رقم مصري صحيح (11 رقم):")
        bot.register_next_step_handler(msg, process_member_number)
        return
    
    user_data[chat_id]['member_number'] = member_number
    msg = bot.send_message(chat_id, "🔑 أدخل كلمة سر الفرد:")
    bot.register_next_step_handler(msg, process_member_password)

def process_member_password(message):
    """معالجة كلمة سر الفرد"""
    chat_id = message.chat.id
    member_password = message.text.strip()
    
    user_data[chat_id]['member_password'] = member_password
    
    # اختيار النسبة
    markup = types.ReplyKeyboardMarkup(resize_keyboard=True, row_width=3)
    btn1 = types.KeyboardButton("10%")
    btn2 = types.KeyboardButton("20%")
    btn3 = types.KeyboardButton("40%")
    markup.add(btn1, btn2, btn3)
    
    msg = bot.send_message(chat_id, "📊 اختر نسبة التوزيع:", reply_markup=markup)
    bot.register_next_step_handler(msg, process_percentage_selection)

def process_percentage_selection(message):
    """معالجة اختيار النسبة"""
    chat_id = message.chat.id
    percentage_text = message.text.strip()
    
    percentage_map = {"10%": 10, "20%": 20, "40%": 40}
    percentage = percentage_map.get(percentage_text, 10)
    
    user_data[chat_id]['percentage'] = percentage
    
    # استعادة القائمة الرئيسية
    show_main_menu(message)
    
    # بدء عملية الإرسال والقبول
    owner_number = user_data[chat_id]['owner_number']
    owner_password = user_data[chat_id]['owner_password']
    member_number = user_data[chat_id]['member_number']
    member_password = user_data[chat_id]['member_password']
    
    bot.send_message(chat_id, f"🎬 بدء عملية إرسال الدعوة والقبول بنسبة {percentage}%...")
    
    # تشغيل في thread منفصل
    thread = Thread(target=process_invitation_accept, 
                   args=(owner_number, owner_password, member_number, member_password, percentage, chat_id))
    thread.start()

@bot.message_handler(func=lambda m: m.text == "👤 إدارة الحساب")
def manage_account(message):
    """إدارة حساب المستخدم"""
    chat_id = message.chat.id
    
    if not is_user_registered(chat_id):
        bot.send_message(chat_id, "❌ يجب التسجيل أولاً. أرسل /start")
        return
    
    user_info = registered_users.get(str(chat_id), {})
    phone = user_info.get('phone', 'غير معروف')
    reg_date = user_info.get('registration_date', 'غير معروف')
    
    account_text = f"👤 معلومات حسابك:\n\n"
    account_text += f"📱 رقم الهاتف: {phone}\n"
    account_text += f"📅 تاريخ التسجيل: {reg_date}\n\n"
    account_text += "اختر الإجراء المطلوب:"
    
    markup = types.ReplyKeyboardMarkup(resize_keyboard=True, row_width=2)
    btn1 = types.KeyboardButton("🔄 إعادة التسجيل")
    btn2 = types.KeyboardButton("🗑️ حذف الحساب")
    btn3 = types.KeyboardButton("🔙 القائمة الرئيسية")
    markup.add(btn1, btn2, btn3)
    
    bot.send_message(chat_id, account_text, reply_markup=markup)

@bot.message_handler(func=lambda m: m.text == "🔄 إعادة التسجيل")
def re_register_account(message):
    """إعادة تسجيل الحساب"""
    chat_id = message.chat.id
    delete_user(chat_id)
    bot.send_message(chat_id, "🔓 تم حذف بياناتك القديمة. يمكنك الآن التسجيل مرة أخرى.")
    show_registration_welcome(message)

@bot.message_handler(func=lambda m: m.text == "🗑️ حذف الحساب")
def delete_account(message):
    """حذف حساب المستخدم"""
    chat_id = message.chat.id
    
    if delete_user(chat_id):
        bot.send_message(chat_id, "✅ تم حذف حسابك بنجاح. يمكنك التسجيل مرة أخرى بأرسال /start")
    else:
        bot.send_message(chat_id, "❌ حسابك غير موجود.")

@bot.message_handler(func=lambda m: m.text == "🔙 القائمة الرئيسية")
def back_to_main(message):
    """العودة للقائمة الرئيسية"""
    show_main_menu(message)

@bot.message_handler(func=lambda m: m.text == "ℹ️ معلومات عن البوت")
def bot_info(message):
    """عرض معلومات عن البوت"""
    info_text = "🤖 البوت المتكامل لفودافون\n\n"
    info_text += "🔍 الخدمات المتاحة:\n"
    info_text += "• بيانات الخط والاشتراكات\n"
    info_text += "• معرفة مالك مجموعة العائلة\n"
    info_text += "• نسبة رصيد الفليكس\n"
    info_text += "• إرسال دعوة انضمام للعائلة\n\n"
    info_text += "🔐 نظام التسجيل:\n"
    info_text += "• تسجيل مرة واحدة فقط\n"
    info_text += "• بيانات آمنة ومشفرة\n"
    info_text += "• لا حاجة لإعادة التسجيل\n\n"
    info_text += "📞 الدعم: 01017143221\n\n"
    info_text += "🔒 نضمن خصوصية وأمان بياناتك"
    
    markup = types.ReplyKeyboardMarkup(resize_keyboard=True, row_width=2)
    btn1 = types.KeyboardButton("📝 التسجيل الآن")
    btn2 = types.KeyboardButton("🔙 الرجوع")
    markup.add(btn1, btn2)
    
    bot.send_message(message.chat.id, info_text, reply_markup=markup)

@bot.message_handler(func=lambda m: m.text == "🆘 المساعدة")
def send_help(message):
    help_text = "📖 أوامر البوت:\n\n"
    help_text += "📊 بيانات الخط - معلومات الحساب والاشتراكات\n"
    help_text += "👥 معرفة الأونر - بيانات مجموعة العائلة\n"
    help_text += "💳 نسبة الفليكس - معرفة رصيد الفليكس المتبقي\n"
    help_text += "📨 إرسال دعوة - إرسال دعوة انضمام للعائلة\n"
    help_text += "👤 إدارة الحساب - تحديث أو حذف البيانات\n"
    help_text += "🆘 المساعدة - عرض هذه الرسالة\n\n"
    help_text += "🔐 نظام التسجيل:\n"
    help_text += "• تسجيل مرة واحدة فقط عند أول استخدام\n"
    help_text += "• استخدام الخدمات مباشرة بعد التسجيل\n"
    help_text += "• إعادة التسجيل متاحة من إدارة الحساب\n\n"
    help_text += "📞 للتواصل: 01017143221"
    bot.reply_to(message, help_text)

@bot.message_handler(func=lambda m: m.text == "🔙 الرجوع")
def back_command(message):
    if is_user_registered(message.chat.id):
        show_main_menu(message)
    else:
        show_registration_welcome(message)

@bot.message_handler(func=lambda message: True)
def handle_message(message):
    if message.text.startswith('/'):
        bot.send_message(message.chat.id, "❌ أمر غير معروف. اختر من القائمة أو أرسل /help للمساعدة.")
    else:
        bot.send_message(message.chat.id, "🔍 اختر الخدمة التي تريدها من القائمة:")

# تشغيل البوت
if __name__ == '__main__':
    print("✅ تم تشغيل البوت المتكامل بنجاح...")
    print("🤖 البوت يدعم الآن نظام التسجيل الدائم")
    print("   🔐 تسجيل مرة واحدة فقط")
    print("   📊 بيانات الخط")
    print("   👥 معرفة الأونر") 
    print("   💳 نسبة الفليكس")
    print("   📨 إرسال دعوة")
    bot.infinity_polling()