Доставка и перевозки Россия – Грузия

async def main(): # Очищаем старую сессию при запуске clear_session() client = TelegramClient(SESSION_NAME, api_id, api_hash) try: await client.start(phone=phone) print("✅ Авторизация успешна!") me = await client.get_me() print(f"👤 Аккаунт: {me.first_name} (@{me.username if me.username else 'нет username'})") print(f"📊 Всего групп для вступления: {len(GROUP_LINKS)}") print(f"⏰ Рабочее время: {START_HOUR}:00 - {END_HOUR}:00") print(f"⏱️ Задержка между вступлениями: {MIN_DELAY}-{MAX_DELAY} сек\n") success_count = 0 already_member = 0 failed_count = 0 flood_waits = 0 pending_count = 0 # Добавляем счетчик ожидающих index = 0 # Создаем случайный порядок групп shuffled_groups = GROUP_LINKS.copy() random.shuffle(shuffled_groups) while index < len(shuffled_groups): # Проверяем рабочие часы if not is_working_hours(): current_time = datetime.now().strftime("%H:%M") print(f"\n⏰ Текущее время {current_time}. Рабочие часы: {START_HOUR}:00-{END_HOUR}:00") print("💤 Ожидание до начала следующего рабочего дня...") now = datetime.now() next_start = now.replace(hour=START_HOUR, minute=0, second=0, microsecond=0) if now.hour >= END_HOUR: next_start += timedelta(days=1) wait_seconds = (next_start - now).total_seconds() wait_hours = wait_seconds / 3600 print(f"⏳ Ожидание {wait_hours:.1f} часов до {START_HOUR}:00") await asyncio.sleep(wait_seconds) continue link = shuffled_groups[index] index += 1 print(f"[{index}/{len(shuffled_groups)}] {link}") await asyncio.sleep(random.uniform(0.5, 2.0)) status, message = await join_group(client, link) if status == "success": print(f" ✅ {message}") success_count += 1 elif status == "already": print(f" ℹ️ {message}") already_member += 1 elif status == "pending": print(f" ⏳ {message}") pending_count += 1 elif status == "flood": print(f" ⚠️ {message}") flood_waits += 1 wait_seconds = 30 try: import re seconds_match = re.search(r'(\d+)с', message) if seconds_match: wait_seconds = int(seconds_match.group(1)) except: pass wait_seconds = min(wait_seconds, 300) print(f" ⏳ Ожидание {wait_seconds} секунд из-за флуда...") await asyncio.sleep(wait_seconds) else: print(f" ❌ {message}") failed_count += 1 delay = random.uniform(MIN_DELAY, MAX_DELAY) if index % 10 == 0: elapsed_time = (index / len(shuffled_groups)) * 100 print(f"\n📊 Прогресс: {elapsed_time:.1f}% ({index}/{len(shuffled_groups)})") print(f"⏱️ Следующая группа через {delay:.0f} секунд\n") else: print(f" ⏱️ Следующая группа через {delay:.0f} сек") await asyncio.sleep(delay) # Итоговая статистика print("\n" + "="*60) print("📊 ИТОГОВАЯ СТАТИСТИКА:") print(f"✅ Успешно вступил: {success_count}") print(f"ℹ️ Уже был участником: {already_member}") print(f"⏳ Ожидает модерации: {pending_count}") print(f"⚠️ Ожидание из-за флуда: {flood_waits}") print(f"❌ Не удалось вступить: {failed_count}") print(f"📊 Всего обработано: {len(shuffled_groups)}") print("="*60) with open('join_results.txt', 'w', encoding='utf-8') as f: f.write(f"Аккаунт: {me.first_name} (@{me.username if me.username else 'нет username'})\n") f.write(f"Дата запуска: {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}\n") f.write(f"Успешно вступил: {success_count}\n") f.write(f"Уже был участником: {already_member}\n") f.write(f"Ожидает модерации: {pending_count}\n") f.write(f"Не удалось вступить: {failed_count}\n") f.write(f"Всего обработано: {len(shuffled_groups)}\n") print("\n✅ Результаты сохранены в файл join_results.txt") except KeyboardInterrupt: print("\n\n🛑 Программа остановлена пользователем") print(f"📊 Обработано групп: {index}") except Exception as e: print(f"❌ Критическая ошибка: {e}") finally: await client.disconnect() print("\n👋 Сессия завершена") if name == 'main': try: asyncio.run(main()) except KeyboardInterrupt: print("\n\n🛑 Программа завершена")