Исправление кода

исправь ошибки и скинь мне полный код

2024-11-21 11:46:03,023 - apscheduler.scheduler - INFO - Adding job tentatively -- it will be properly scheduled when the scheduler starts
2024-11-21 11:46:03,023 - apscheduler.scheduler - INFO - Adding job tentatively -- it will be properly scheduled when the scheduler starts
2024-11-21 11:46:03,024 - apscheduler.scheduler - INFO - Added job "finalize_auctions" to job store "default"
2024-11-21 11:46:03,024 - apscheduler.scheduler - INFO - Added job "send_notifications" to job store "default"
2024-11-21 11:46:03,024 - apscheduler.scheduler - INFO - Scheduler started
2024-11-21 11:46:14,099 - telegram.vendor.ptb_urllib3.urllib3.connectionpool - WARNING - Retrying (Retry(total=2, connect=None, read=None, redirect=None)) after connection broken by 'NewConnectionError('<telegram.vendor.ptb_urllib3.urllib3.connection.VerifiedHTTPSConnection object at 0x000002097A85FF10>: Failed to establish a new connection: [Errno 11001] getaddrinfo failed')': /bot5614465516:AAGhnqGkgBXXFct-AWmLMOWZvO1UYvaCapk/getMe
2024-11-21 11:46:14,648 - telegram.ext.dispatcher - ERROR - An uncaught error was raised while handling the error.
Traceback (most recent call last):
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\site-packages\telegram\ext\dispatcher.py", line 557, in process_update
handler.handle_update(update, self, check, context)
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\site-packages\telegram\ext\handler.py", line 199, in handle_update
return self.callback(update, context)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\Desktop\race_bot_ai\bot.py", line 98, in wrapper
return asyncio.ensure_future(func(update, context, *args, **kwargs))
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\asyncio\tasks.py", line 659, in ensure_future
return _ensure_future(coro_or_future, loop=loop)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\asyncio\tasks.py", line 678, in _ensure_future
loop = events._get_event_loop(stacklevel=4)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\asyncio\events.py", line 681, in get_event_loop
raise RuntimeError('There is no current event loop in thread %r.'
RuntimeError: There is no current event loop in thread 'Bot:5614465516:dispatcher'.

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\site-packages\telegram\ext\dispatcher.py", line 569, in process_update
self.dispatch_error(update, exc)
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\site-packages\telegram\ext\dispatcher.py", line 813, in dispatch_error
callback(update, context)
File "C:\Users\Akio\Desktop\race_bot_ai\bot.py", line 98, in wrapper
return asyncio.ensure_future(func(update, context, *args, **kwargs))
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\asyncio\tasks.py", line 659, in ensure_future
return _ensure_future(coro_or_future, loop=loop)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\asyncio\tasks.py", line 678, in _ensure_future
loop = events._get_event_loop(stacklevel=4)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\asyncio\events.py", line 681, in get_event_loop
raise RuntimeError('There is no current event loop in thread %r.'
RuntimeError: There is no current event loop in thread 'Bot:5614465516:dispatcher'.
C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\site-packages\telegram\ext\dispatcher.py:575: RuntimeWarning: coroutine 'error_handler' was never awaited
self.logger.exception('An uncaught error was raised while handling the error.')
RuntimeWarning: Enable tracemalloc to get the object allocation traceback
C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\site-packages\telegram\ext\dispatcher.py:-1: RuntimeWarning: coroutine 'start' was never awaited
RuntimeWarning: Enable tracemalloc to get the object allocation traceback
2024-11-21 11:46:21,936 - telegram.ext.dispatcher - ERROR - An uncaught error was raised while handling the error.
Traceback (most recent call last):
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\site-packages\telegram\ext\dispatcher.py", line 557, in process_update
handler.handle_update(update, self, check, context)
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\site-packages\telegram\ext\handler.py", line 199, in handle_update
return self.callback(update, context)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\Desktop\race_bot_ai\bot.py", line 98, in wrapper
return asyncio.ensure_future(func(update, context, *args, **kwargs))
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\asyncio\tasks.py", line 659, in ensure_future
return _ensure_future(coro_or_future, loop=loop)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\asyncio\tasks.py", line 678, in _ensure_future
loop = events._get_event_loop(stacklevel=4)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\asyncio\events.py", line 681, in get_event_loop
raise RuntimeError('There is no current event loop in thread %r.'
RuntimeError: There is no current event loop in thread 'Bot:5614465516:dispatcher'.

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\site-packages\telegram\ext\dispatcher.py", line 569, in process_update
self.dispatch_error(update, exc)
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\site-packages\telegram\ext\dispatcher.py", line 813, in dispatch_error
callback(update, context)
File "C:\Users\Akio\Desktop\race_bot_ai\bot.py", line 98, in wrapper
return asyncio.ensure_future(func(update, context, *args, **kwargs))
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\asyncio\tasks.py", line 659, in ensure_future
return _ensure_future(coro_or_future, loop=loop)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\asyncio\tasks.py", line 678, in _ensure_future
loop = events._get_event_loop(stacklevel=4)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\asyncio\events.py", line 681, in get_event_loop
raise RuntimeError('There is no current event loop in thread %r.'
RuntimeError: There is no current event loop in thread 'Bot:5614465516:dispatcher'.
2024-11-21 11:46:25,550 - telegram.ext.dispatcher - ERROR - An uncaught error was raised while handling the error.
Traceback (most recent call last):
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\site-packages\telegram\ext\dispatcher.py", line 557, in process_update
handler.handle_update(update, self, check, context)
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\site-packages\telegram\ext\handler.py", line 199, in handle_update
return self.callback(update, context)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\Desktop\race_bot_ai\bot.py", line 98, in wrapper
return asyncio.ensure_future(func(update, context, *args, **kwargs))
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\asyncio\tasks.py", line 659, in ensure_future
return _ensure_future(coro_or_future, loop=loop)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\asyncio\tasks.py", line 678, in _ensure_future
loop = events._get_event_loop(stacklevel=4)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\asyncio\events.py", line 681, in get_event_loop
raise RuntimeError('There is no current event loop in thread %r.'
RuntimeError: There is no current event loop in thread 'Bot:5614465516:dispatcher'.

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\site-packages\telegram\ext\dispatcher.py", line 569, in process_update
self.dispatch_error(update, exc)
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\site-packages\telegram\ext\dispatcher.py", line 813, in dispatch_error
callback(update, context)
File "C:\Users\Akio\Desktop\race_bot_ai\bot.py", line 98, in wrapper
return asyncio.ensure_future(func(update, context, *args, **kwargs))
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\asyncio\tasks.py", line 659, in ensure_future
return _ensure_future(coro_or_future, loop=loop)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\asyncio\tasks.py", line 678, in _ensure_future
loop = events._get_event_loop(stacklevel=4)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Akio\AppData\Local\Programs\Python\Python311\Lib\asyncio\events.py", line 681, in get_event_loop
raise RuntimeError('There is no current event loop in thread %r.'
RuntimeError: There is no current event loop in thread 'Bot:5614465516:dispatcher'.

import os
import pickle
import logging
import random
import datetime
import asyncio
from telegram import Update
from telegram.ext import (
ApplicationBuilder,
CommandHandler,
ContextTypes,
ConversationHandler,
MessageHandler,
filters,
)

# Настройка логирования
logging.basicConfig(
format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
level=logging.INFO
)

logger = logging.getLogger(__name__)

# Путь к файлу для сохранения данных
DATA_FILE = 'user_data.pkl'

# Состояния для ConversationHandler
(UPGRADE, RACE, RACE_CONFIRM, TRADE, TRADE_CONFIRM, CLAN, CLAN_ACTION,
AUCTION, AUCTION_ACTION, GARAGE_UPGRADE, CLAN_RACE, CLAN_QUEST,
AUCTION_CANCEL, REFERRAL, AUTO_BID, BID_HISTORY) = range(16)

# Данные пользователей
if os.path.exists(DATA_FILE):
with open(DATA_FILE, 'rb') as f:
users = pickle.load(f)
else:
users = {}

# Доступные машины в автосалоне
cars = {
'Toyota': {'price': 5000, 'speed': 120, 'fuel_consumption': 5},
'BMW': {'price': 10000, 'speed': 160, 'fuel_consumption': 7},
'Ferrari': {'price': 20000, 'speed': 200, 'fuel_consumption': 10},
'Lamborghini': {'price': 30000, 'speed': 220, 'fuel_consumption': 12},
'Bugatti': {'price': 50000, 'speed': 250, 'fuel_consumption': 15},
'McLaren': {'price': 55000, 'speed': 255, 'fuel_consumption': 15},
'Porsche': {'price': 45000, 'speed': 240, 'fuel_consumption': 14},
'Audi': {'price': 15000, 'speed': 180, 'fuel_consumption': 8},
'Mercedes': {'price': 18000, 'speed': 185, 'fuel_consumption': 9},
'Nissan': {'price': 8000, 'speed': 130, 'fuel_consumption': 6},
'Honda': {'price': 7000, 'speed': 125, 'fuel_consumption': 6},
'Ford': {'price': 9000, 'speed': 135, 'fuel_consumption': 7},
'Chevrolet': {'price': 9500, 'speed': 140, 'fuel_consumption': 7},
'Tesla': {'price': 60000, 'speed': 260, 'fuel_consumption': 0},
'Aston Martin': {'price': 40000, 'speed': 230, 'fuel_consumption': 13},
'Jaguar': {'price': 35000, 'speed': 225, 'fuel_consumption': 12},
'Mazda': {'price': 8500, 'speed': 132, 'fuel_consumption': 6},
'Subaru': {'price': 12000, 'speed': 150, 'fuel_consumption': 8},
'Mitsubishi': {'price': 11000, 'speed': 145, 'fuel_consumption': 8},
'Kia': {'price': 6000, 'speed': 115, 'fuel_consumption': 5},
'Hyundai': {'price': 6500, 'speed': 118, 'fuel_consumption': 5}
}

# Категории предметов на аукционе
auction_categories = ['Машины', 'Улучшения', 'Аксессуары']

# Уровни улучшений
upgrades_list = ['engine', 'tires', 'aerodynamics', 'nitro', 'suspension']

# Уровни сложности виртуальных противников
opponents = {
'Легкий': {'speed': 130, 'reward': 3000},
'Средний': {'speed': 170, 'reward': 5000},
'Сложный': {'speed': 210, 'reward': 8000}
}

# Список клановых заданий
clan_quests = [
{'task': 'Выиграть 10 гонок всем кланом', 'type': 'clan_wins', 'target': 10, 'reward': 20000},
{'task': 'Накопить 100000 баланса всем кланом', 'type': 'clan_balance', 'target': 100000, 'reward': 30000},
{'task': 'Совершить 50 улучшений всем кланом', 'type': 'clan_upgrades', 'target': 50, 'reward': 25000}
]

# Клановые данные
clans = {}

# Аукционные лоты
auction_items = []

# Реферальные данные
referrals = {}

# Функция для сохранения данных
def save_data():
with open(DATA_FILE, 'wb') as f:
pickle.dump(users, f)

# Декоратор для асинхронных функций
def async_run(func):
@wraps(func)
def wrapper(update, context, *args, **kwargs):
return asyncio.ensure_future(func(update, context, *args, **kwargs))
return wrapper

# Команда /start
@async_run
async def start(update: Update, context: CallbackContext):
user_id = update.effective_user.id
username = update.effective_user.first_name
if user_id not in users:
users[user_id] = {
'username': username,
'balance': 10000,
'garage': [],
'active_car': None,
'fuel': 100,
'upgrades': {key: 1 for key in upgrades_list},
'wins': 0,
'losses': 0,
'achievements': [],
'daily_bonus_claimed': False,
'level': 1,
'experience': 0,
'inventory': {},
'clan': None,
'trade_requests': [],
'distance_driven': 0,
'garage_level': 1,
'notifications': [],
'referrals': [],
'referral_level': 1,
'referral_bonus_claimed': False,
'referrer': None
}
# Обработка реферальной системы
if context.args:
referrer_id = int(context.args[0])
if referrer_id in users and referrer_id != user_id:
users[user_id]['referrer'] = referrer_id
await update.message.reply_text(f"Вы указали реферальный код пользователя {users[referrer_id]['username']}.")
# Добавляем нового реферала к рефереру
add_referral(referrer_id, user_id)
save_data()
keyboard = [['Профиль', 'Автосалон'],
['Прокачка', 'Заправка'],
['Гонки', 'Ежедневный бонус'],
['Торговля', 'Ежедневное задание'],
['Клан', 'Гараж'],
['Аукцион', 'Прокачка гаража'],
['Реферальная ссылка']]
reply_markup = ReplyKeyboardMarkup(keyboard, resize_keyboard=True)
await update.message.reply_text('Добро пожаловать в гоночный бот!', reply_markup=reply_markup)

# Функция для добавления реферала
def add_referral(referrer_id, referral_id):
users[referrer_id].setdefault('referrals', []).append(referral_id)
# Проверяем уровни рефералов
current_level = users[referrer_id].get('referral_level', 1)
if len(users[referrer_id]['referrals']) >= 5 * current_level:
users[referrer_id]['referral_level'] += 1
users[referrer_id]['balance'] += 5000 * current_level # Награда за повышение уровня рефералов
users[referrer_id]['notifications'].append(f"Ваш уровень рефералов повышен до {users[referrer_id]['referral_level']}! Вы получили бонус {5000 * current_level}.")

# Просмотр профиля
@async_run
async def profile(update: Update, context: CallbackContext):
user_id = update.effective_user.id
user_data = users[user_id]
active_car = user_data['active_car'] if user_data['active_car'] else 'Нет'
speed = calculate_speed(user_id)
fuel = user_data['fuel']
upgrades = user_data['upgrades']
wins = user_data.get('wins', 0)
losses = user_data.get('losses', 0)
achievements = ', '.join(user_data.get('achievements', [])) or 'Нет'
level = user_data.get('level', 1)
experience = user_data.get('experience', 0)
clan = user_data.get('clan', 'Нет')
garage_level = user_data.get('garage_level', 1)
referrals_count = len(user_data.get('referrals', []))
referral_level = user_data.get('referral_level', 1)
message = (
f"*Баланс*: {user_data['balance']}\n"
f"*Уровень*: {level}\n"
f"*Опыт*: {experience}/{level * 100}\n"
f"*Активная машина*: {active_car}\n"
f"*Скорость*: {speed}\n"
f"*Топливо*: {fuel}\n"
f"*Клан*: {clan}\n"
f"*Уровень гаража*: {garage_level}\n"
f"*Рефералы*: {referrals_count}\n"
f"*Уровень рефералов*: {referral_level}\n"
f"*Улучшения*:\n"
)
for upgrade in upgrades_list:
message += f" {upgrade.capitalize()}: уровень {upgrades[upgrade]}\n"
message += (
f"*Победы*: {wins}\n"
f"*Поражения*: {losses}\n"
f"*Достижения*: {achievements}"
)
await update.message.reply_text(message, parse_mode='Markdown')

# Функция для расчета опыта и уровня
def add_experience(user_id, amount):
user_data = users[user_id]
user_data['experience'] += amount
level_up = False
while user_data['experience'] >= user_data['level'] * 100:
user_data['experience'] -= user_data['level'] * 100
user_data['level'] += 1
level_up = True
if level_up:
return True
return False

# Автосалон
@async_run
async def showroom(update: Update, context: CallbackContext):
user_id = update.effective_user.id
garage_capacity = users[user_id]['garage_level'] * 2 # Вместимость гаража зависит от уровня
if len(users[user_id]['garage']) >= garage_capacity:
await update.message.reply_text('Ваш гараж полон. Улучшите гараж, чтобы покупать больше машин.')
return
message = '*Доступные машины:*\n'
for car, info in cars.items():
message += (
f"{car}: Цена {info['price']}, "
f"Скорость {info['speed']}, "
f"Расход топлива {info['fuel_consumption']}\n"
)
await update.message.reply_text(message, parse_mode='Markdown')
await update.message.reply_text('Введите название машины, которую хотите купить.')

# Покупка машины
@async_run
async def buy_car(update: Update, context: CallbackContext):
user_id = update.effective_user.id
garage_capacity = users[user_id]['garage_level'] * 2
if len(users[user_id]['garage']) >= garage_capacity:
await update.message.reply_text('Ваш гараж полон. Улучшите гараж, чтобы покупать больше машин.')
return
car_name = update.message.text
if car_name in cars:
car_info = cars[car_name]
if users[user_id]['balance'] >= car_info['price']:
users[user_id]['balance'] -= car_info['price']
users[user_id]['garage'].append(car_name)
if not users[user_id]['active_car']:
users[user_id]['active_car'] = car_name
save_data()
await update.message.reply_text(f"Вы успешно купили {car_name}!")
await check_achievements(user_id, context)
else:
await update.message.reply_text('Недостаточно средств.')
else:
await update.message.reply_text('Такой машины нет в автосалоне.')

# Расчет текущей скорости с учетом улучшений
def calculate_speed(user_id):
if users[user_id]['active_car']:
base_speed = cars[users[user_id]['active_car']]['speed']
upgrades = users[user_id]['upgrades']
# Улучшения с уменьшающейся отдачей
speed = base_speed
speed += 10 * (upgrades['engine'] - 1)
speed += 5 * (upgrades['tires'] - 1)
speed += 7 * (upgrades['aerodynamics'] - 1)
speed += 15 * (upgrades['nitro'] - 1)
speed += 8 * (upgrades['suspension'] - 1)
return int(speed)
else:
return 0

# Прокачка машины
@async_run
async def upgrade_car_start(update: Update, context: CallbackContext):
user_id = update.effective_user.id
if users[user_id]['active_car']:
keyboard = [[upgrade.capitalize() for upgrade in upgrades_list], ['Отмена']]
reply_markup = ReplyKeyboardMarkup(keyboard, resize_keyboard=True)
await update.message.reply_text('Выберите часть машины для улучшения:', reply_markup=reply_markup)
return UPGRADE
else:
await update.message.reply_text('У вас нет активной машины для прокачки.')
return ConversationHandler.END

@async_run
async def upgrade_car_choice(update: Update, context: CallbackContext):
user_id = update.effective_user.id
choice = update.message.text.lower()
if choice in upgrades_list:
level = users[user_id]['upgrades'][choice]
upgrade_cost = 2000 * level # Стоимость увеличивается с уровнем
if users[user_id]['balance'] >= upgrade_cost:
users[user_id]['balance'] -= upgrade_cost
users[user_id]['upgrades'][choice] += 1
save_data()
await update.message.reply_text(
f"Вы улучшили {choice.capitalize()} до уровня {users[user_id]['upgrades'][choice]}!\n"
f"Новая скорость: {calculate_speed(user_id)}"
)
# Добавление опыта
leveled_up = add_experience(user_id, 50)
if leveled_up:
await update.message.reply_text(f"Поздравляем! Вы достигли уровня {users[user_id]['level']}!")
# Обновление прогресса кланового задания
await update_clan_quest_progress(user_id, 'clan_upgrades')
save_data()
else:
await update.message.reply_text('Недостаточно средств для улучшения.')
return ConversationHandler.END
elif choice == 'отмена':
await update.message.reply_text('Прокачка отменена.', reply_markup=ReplyKeyboardRemove())
return ConversationHandler.END
else:
await update.message.reply_text('Пожалуйста, выберите доступную опцию.')
return UPGRADE

# Заправка машины
@async_run
async def refuel_car(update: Update, context: CallbackContext):
user_id = update.effective_user.id
if users[user_id]['active_car']:
fuel_needed = 100 - users[user_id]['fuel']
if fuel_needed == 0:
await update.message.reply_text('У вас полный бак.')
return
fuel_cost_per_unit = 50 # Цена за единицу топлива
total_cost = fuel_needed * fuel_cost_per_unit
if users[user_id]['balance'] >= total_cost:
users[user_id]['balance'] -= total_cost
users[user_id]['fuel'] = 100
save_data()
await update.message.reply_text(f"Вы заправили машину до полного бака. Топливо: {users[user_id]['fuel']}")
else:
affordable_fuel = users[user_id]['balance'] // fuel_cost_per_unit
users[user_id]['balance'] -= affordable_fuel * fuel_cost_per_unit
users[user_id]['fuel'] += affordable_fuel
save_data()
await update.message.reply_text(f"Вы заправили {affordable_fuel} единиц топлива. Топливо: {users[user_id]['fuel']}")
else:
await update.message.reply_text('У вас нет активной машины для заправки.')

# Ежедневный бонус
@async_run
async def daily_bonus(update: Update, context: CallbackContext):
user_id = update.effective_user.id
today = datetime.date.today()
last_claim_date = users[user_id].get('last_bonus_date', None)
if last_claim_date != today:
bonus_amount = 2000 + users[user_id]['level'] * 100 # Бонус зависит от уровня
users[user_id]['balance'] += bonus_amount
users[user_id]['last_bonus_date'] = today
save_data()
await update.message.reply_text(f"Вы получили ежедневный бонус: {bonus_amount}!")
else:
await update.message.reply_text("Вы уже получали ежедневный бонус сегодня. Приходите завтра!")

# Ежедневные задания
@async_run
async def daily_quest(update: Update, context: CallbackContext):
user_id = update.effective_user.id
today = datetime.date.today()
last_quest_date = users[user_id].get('last_quest_date', None)
if last_quest_date != today:
# Генерируем задание
quest_options = [
{'task': 'Выиграйте 3 гонки', 'reward': 7000, 'type': 'wins', 'target': 3},
{'task': 'Совершите 5 улучшений', 'reward': 5000, 'type': 'upgrades', 'target': 5},
{'task': 'Пробегите 100 км', 'reward': 6000, 'type': 'distance', 'target': 100},
{'task': 'Улучшите гараж', 'reward': 8000, 'type': 'garage_upgrade', 'target': 1}
]
quest = random.choice(quest_options)
users[user_id]['daily_quest'] = quest
users[user_id]['last_quest_date'] = today
users[user_id]['quest_progress'] = 0
save_data()
await update.message.reply_text(f"Ваше сегодняшнее задание: {quest['task']}")
else:
quest = users[user_id].get('daily_quest', None)
if quest:
progress = users[user_id].get('quest_progress', 0)
if progress >= quest['target']:
users[user_id]['balance'] += quest['reward']
del users[user_id]['daily_quest']
del users[user_id]['quest_progress']
save_data()
await update.message.reply_text(f"Вы выполнили задание и получили награду: {quest['reward']}!")
else:
await update.message.reply_text(f"Прогресс задания: {progress}/{quest['target']}")
else:
await update.message.reply_text("Вы уже выполнили сегодняшнее задание.")

# Гонки
@async_run
async def race_start(update: Update, context: CallbackContext):
keyboard = [['С виртуальным противником', 'С другим игроком'], ['Клановая гонка'], ['Отмена']]
reply_markup = ReplyKeyboardMarkup(keyboard, resize_keyboard=True)
await update.message.reply_text('Выберите тип гонки:', reply_markup=reply_markup)
return RACE

@async_run
async def race_choice(update: Update, context: CallbackContext):
choice = update.message.text
if choice == 'С виртуальным противником':
await race_virtual_start(update, context)
return ConversationHandler.END
elif choice == 'С другим игроком':
await race_multiplayer(update, context)
return ConversationHandler.END
elif choice == 'Клановая гонка':
await race_clan_start(update, context)
return ConversationHandler.END
elif choice == 'Отмена':
await update.message.reply_text('Гонка отменена.', reply_markup=ReplyKeyboardRemove())
return ConversationHandler.END
else:
await update.message.reply_text('Пожалуйста, выберите доступную опцию.')
return RACE

# Гонки с виртуальным противником с выбором уровня сложности
@async_run
async def race_virtual_start(update: Update, context: CallbackContext):
keyboard = [['Легкий', 'Средний', 'Сложный'], ['Отмена']]
reply_markup = ReplyKeyboardMarkup(keyboard, resize_keyboard=True)
await update.message.reply_text('Выберите уровень сложности противника:', reply_markup=reply_markup)
return RACE_CONFIRM

@async_run
async def race_virtual_confirm(update: Update, context: CallbackContext):
difficulty = update.message.text
if difficulty in opponents:
await race_virtual(update, context, difficulty)
return ConversationHandler.END
elif difficulty == 'Отмена':
await update.message.reply_text('Гонка отменена.', reply_markup=ReplyKeyboardRemove())
return ConversationHandler.END
else:
await update.message.reply_text('Пожалуйста, выберите доступную сложность.')
return RACE_CONFIRM

@async_run
async def race_virtual(update: Update, context: CallbackContext, difficulty):
user_id = update.effective_user.id
if users[user_id]['active_car']:
fuel_consumption = cars[users[user_id]['active_car']]['fuel_consumption'] * 2 # Расход топлива на гонку
if users[user_id]['fuel'] >= fuel_consumption:
users[user_id]['fuel'] -= fuel_consumption
user_speed = calculate_speed(user_id)
opponent_info = opponents[difficulty]
opponent_speed = opponent_info['speed']
reward = opponent_info['reward']
if user_speed > opponent_speed:
total_reward = reward + get_clan_bonus(user_id)
users[user_id]['balance'] += total_reward
users[user_id]['wins'] += 1
users[user_id]['distance_driven'] += 10 # Добавляем пройденное расстояние
await update.message.reply_text(f"Вы выиграли гонку! Награда: {total_reward}")
# Добавление опыта
leveled_up = add_experience(user_id, 100)
if leveled_up:
await update.message.reply_text(f"Поздравляем! Вы достигли уровня {users[user_id]['level']}!")
# Проверка достижений
await check_achievements(user_id, context)
# Обновление прогресса ежедневного задания
await update_daily_quest_progress(user_id, 'wins')
await update_daily_quest_progress(user_id, 'distance', 10)
# Обновление прогресса кланового задания
await update_clan_quest_progress(user_id, 'clan_wins')
# Бонус рефереру за активность реферала
await referral_activity_bonus(user_id, 100)
else:
users[user_id]['losses'] += 1
await update.message.reply_text("Вы проиграли гонку.")
save_data()
else:
await update.message.reply_text('Недостаточно топлива для гонки.')
else:
await update.message.reply_text('У вас нет активной машины для участия в гонке.')

# Обновление прогресса ежедневного задания
async def update_daily_quest_progress(user_id, quest_type, amount=1):
quest = users[user_id].get('daily_quest')
if quest and quest['type'] == quest_type:
users[user_id]['quest_progress'] += amount
save_data()

# Обновление прогресса кланового задания
async def update_clan_quest_progress(user_id, quest_type, amount=1):
clan_name = users[user_id].get('clan')
if clan_name:
clan = clans.get(clan_name)
if clan and clan.get('clan_quest') and clan['clan_quest']['type'] == quest_type:
clan['progress'] += amount
# Проверка выполнения задания
if clan['progress'] >= clan['clan_quest']['target']:
reward = clan['clan_quest']['reward']
# Распределение награды между членами клана
members = clan['members']
per_member_reward = reward // len(members)
for member_id in members:
users[member_id]['balance'] += per_member_reward
await context.bot.send_message(chat_id=member_id, text=f"Ваш клан выполнил задание и вы получили {per_member_reward}!")
# Сброс кланового задания
clan['clan_quest'] = None
clan['progress'] = 0
save_data()

# Бонус за активность рефералов
async def referral_activity_bonus(user_id, activity_points):
referrer_id = users[user_id].get('referrer')
if referrer_id and referrer_id in users:
bonus_amount = activity_points * users[referrer_id]['referral_level'] * 0.1
users[referrer_id]['balance'] += bonus_amount
users[referrer_id]['notifications'].append(f"Ваш реферал {users[user_id]['username']} был активен! Вы получили бонус {bonus_amount:.2f}!")
save_data()

# Мультиплеерные гонки с улучшенной очередью
race_waiting_users = {}

@async_run
async def race_multiplayer(update: Update, context: CallbackContext):
user_id = update.effective_user.id
username = update.effective_user.first_name
if users[user_id]['active_car']:
fuel_consumption = cars[users[user_id]['active_car']]['fuel_consumption'] * 2
if users[user_id]['fuel'] < fuel_consumption:
await update.message.reply_text('Недостаточно топлива для гонки.')
return
users[user_id]['fuel'] -= fuel_consumption
save_data()
# Добавляем пользователя в очередь
race_waiting_users[user_id] = {
'username': username,
'speed': calculate_speed(user_id),
'update': update
}
await update.message.reply_text('Ожидание другого игрока для гонки...')
# Проверяем, есть ли другой игрок в очереди
if len(race_waiting_users) >= 2:
players = list(race_waiting_users.items())[:2]
user1_id, user1_data = players[0]
user2_id, user2_data = players[1]
# Удаляем игроков из очереди
del race_waiting_users[user1_id]
del race_waiting_users[user2_id]
# Определяем победителя
if user1_data['speed'] > user2_data['speed']:
winner_id, loser_id = user1_id, user2_id
elif user1_data['speed'] < user2_data['speed']:
winner_id, loser_id = user2_id, user1_id
else:
winner_id = loser_id = None
# Обновляем статистику и отправляем сообщения
reward = 10000
if winner_id:
total_reward = reward + get_clan_bonus(winner_id)
users[winner_id]['balance'] += total_reward
users[winner_id]['wins'] += 1
users[loser_id]['losses'] += 1
users[winner_id]['distance_driven'] += 10
users[loser_id]['distance_driven'] += 10
await context.bot.send_message(chat_id=winner_id, text=f"Вы выиграли гонку! Награда: {total_reward}")
await context.bot.send_message(chat_id=loser_id, text="Вы проиграли гонку.")
# Добавление опыта и проверка достижений
leveled_up = add_experience(winner_id, 150)
if leveled_up:
await context.bot.send_message(chat_id=winner_id, text=f"Поздравляем! Вы достигли уровня {users[winner_id]['level']}!")
await check_achievements(winner_id, context)
# Обновление прогресса ежедневного задания
await update_daily_quest_progress(winner_id, 'wins')
await update_daily_quest_progress(winner_id, 'distance', 10)
await update_daily_quest_progress(loser_id, 'distance', 10)
# Обновление прогресса кланового задания
await update_clan_quest_progress(winner_id, 'clan_wins')
# Бонус рефереру за активность реферала
await referral_activity_bonus(winner_id, 150)
else:
users[user1_id]['distance_driven'] += 10
users[user2_id]['distance_driven'] += 10
await context.bot.send_message(chat_id=user1_id, text="Гонка завершилась ничьей!")
await context.bot.send_message(chat_id=user2_id, text="Гонка завершилась ничьей!")
save_data()
else:
await update.message.reply_text('У вас нет активной машины для участия в гонке.')

# Клановые гонки
@async_run
async def race_clan_start(update: Update, context: CallbackContext):
user_id = update.effective_user.id
clan_name = users[user_id].get('clan')
if clan_name:
# Добавляем пользователя в очередь клановых гонок
if 'clan_race_waiting' not in clans[clan_name]:
clans[clan_name]['clan_race_waiting'] = []
clans[clan_name]['clan_race_waiting'].append(user_id)
await update.message.reply_text('Вы присоединились к клановой гонке. Ожидание других участников...')
# Если в клане есть достаточно участников, запускаем гонку
if len(clans[clan_name]['clan_race_waiting']) >= 2:
participants = clans[clan_name]['clan_race_waiting']
clans[clan_name]['clan_race_waiting'] = []
# Здесь можно реализовать логику клановой гонки между участниками
await update.message.reply_text('Клановая гонка началась!')
# Для простоты определим победителя случайно
winner_id = random.choice(participants)
users[winner_id]['balance'] += 15000
users[winner_id]['wins'] += 1
await context.bot.send_message(chat_id=winner_id, text="Вы выиграли клановую гонку и получили 15000!")
# Обновление прогресса кланового задания
await update_clan_quest_progress(winner_id, 'clan_wins')
save_data()
else:
await update.message.reply_text('Вы не состоите в клане.')

# Система клановых бонусов
def get_clan_bonus(user_id):
clan_name = users[user_id].get('clan')
if clan_name and clan_name in clans:
bonus = clans[clan_name].get('bonus_level', 0) * 500 # Каждое улучшение бонуса дает +500
return bonus
return 0

# Система рейтингов кланов
def update_clan_rankings():
clan_scores = {}
for clan_name, clan_data in clans.items():
members = clan_data.get('members', [])
total_wins = sum(users[uid].get('wins', 0) for uid in members)
total_balance = sum(users[uid].get('balance', 0) for uid in members)
total_upgrades = sum(sum(users[uid]['upgrades'].values()) for uid in members)
# Комбинированный рейтинг
score = total_wins * 2 + total_balance * 0.001 + total_upgrades * 5
clan_scores[clan_name] = score
sorted_clans = sorted(clan_scores.items(), key=lambda x: x[1], reverse=True)
return sorted_clans

# Проверка достижений
@async_run
async def check_achievements(user_id, context):
user_data = users[user_id]
achievements = user_data.get('achievements', [])
messages = []
# Достижение за 10 побед
if user_data['wins'] >= 10 and 'Победитель' not in achievements:
achievements.append('Победитель')
users[user_id]['balance'] += 5000 # Награда за достижение
messages.append("Вы получили достижение 'Победитель' и награду 5000!")
# Достижение за покупку Bugatti
if 'Bugatti' in user_data['garage'] and 'Элитный гонщик' not in achievements:
achievements.append('Элитный гонщик')
users[user_id]['balance'] += 10000
messages.append("Вы получили достижение 'Элитный гонщик' и награду 10000!")
# Достижение за достижение 5 уровня
if user_data['level'] >= 5 and 'Опытный гонщик' not in achievements:
achievements.append('Опытный гонщик')
users[user_id]['balance'] += 8000
messages.append("Вы получили достижение 'Опытный гонщик' и награду 8000!")
# Достижение за вступление в клан
if user_data['clan'] and 'Клановый боец' not in achievements:
achievements.append('Клановый боец')
users[user_id]['balance'] += 7000
messages.append("Вы получили достижение 'Клановый боец' и награду 7000!")
# Достижение за 1000 км пробега
if user_data.get('distance_driven', 0) >= 1000 and 'Путешественник' not in achievements:
achievements.append('Путешественник')
users[user_id]['balance'] += 9000
messages.append("Вы получили достижение 'Путешественник' и награду 9000!")
# Достижение за покупку 5 машин
if len(user_data['garage']) >= 5 and 'Коллекционер' not in achievements:
achievements.append('Коллекционер')
users[user_id]['balance'] += 12000
messages.append("Вы получили достижение 'Коллекционер' и награду 12000!")
# Достижение за улучшение гаража до 5 уровня
if user_data.get('garage_level', 1) >= 5 and 'Владелец автопарка' not in achievements:
achievements.append('Владелец автопарка')
users[user_id]['balance'] += 15000
messages.append("Вы получили достижение 'Владелец автопарка' и награду 15000!")
# Достижение за 5 рефералов
if len(user_data.get('referrals', [])) >= 5 and 'Реферальный мастер' not in achievements:
achievements.append('Реферальный мастер')
users[user_id]['balance'] += 10000
messages.append("Вы получили достижение 'Реферальный мастер' и награду 10000!")
users[user_id]['achievements'] = achievements
save_data()
for msg in messages:
await context.bot.send_message(chat_id=user_id, text=msg)

# Торговля между игроками
trade_offers = {}

@async_run
async def trade_start(update: Update, context: CallbackContext):
keyboard = [['Предложить обмен', 'Просмотреть предложения'], ['Отмена']]
reply_markup = ReplyKeyboardMarkup(keyboard, resize_keyboard=True)
await update.message.reply_text('Выберите действие для торговли:', reply_markup=reply_markup)
return TRADE

@async_run
async def trade_choice(update: Update, context: CallbackContext):
user_id = update.effective_user.id
choice = update.message.text
if choice == 'Предложить обмен':
await update.message.reply_text('Введите ID пользователя, которому хотите предложить обмен:')
return TRADE_CONFIRM
elif choice == 'Просмотреть предложения':
offers = users[user_id].get('trade_requests', [])
if offers:
for offer in offers:
await update.message.reply_text(f"Предложение от {offer['from_username']}: {offer['offer']}")
# Здесь можно добавить логику для принятия или отклонения предложения
users[user_id]['trade_requests'] = []
save_data()
else:
await update.message.reply_text('У вас нет новых предложений.')
return ConversationHandler.END
elif choice == 'Отмена':
await update.message.reply_text('Торговля отменена.', reply_markup=ReplyKeyboardRemove())
return ConversationHandler.END
else:
await update.message.reply_text('Пожалуйста, выберите доступную опцию.')
return TRADE

@async_run
async def trade_confirm(update: Update, context: CallbackContext):
user_id = update.effective_user.id
target_id = int(update.message.text)
if target_id in users and target_id != user_id:
await update.message.reply_text('Введите ваше предложение (машины, улучшения, деньги):')
context.user_data['trade_target'] = target_id
return TRADE_CONFIRM
else:
await update.message.reply_text('Пользователь не найден или ID некорректен.')
return ConversationHandler.END

@async_run
async def trade_offer(update: Update, context: CallbackContext):
user_id = update.effective_user.id
target_id = context.user_data.get('trade_target')
offer = update.message.text
if target_id in users:
users[target_id].setdefault('trade_requests', []).append({
'from_user_id': user_id,
'from_username': users[user_id]['username'],
'offer': offer
})
save_data()
await update.message.reply_text('Ваше предложение отправлено.')
return ConversationHandler.END
else:
await update.message.reply_text('Пользователь не найден.')
return ConversationHandler.END

# Аукцион или рынок

# Время в секундах, через которое лот завершится
AUCTION_DURATION = 3600 # 1 час

@async_run
async def auction_start(update: Update, context: CallbackContext):
keyboard = [['Выставить на аукцион', 'Просмотреть лоты'], ['Мои лоты', 'Отмена']]
reply_markup = ReplyKeyboardMarkup(keyboard, resize_keyboard=True)
await update.message.reply_text('Добро пожаловать на аукцион!', reply_markup=reply_markup)
return AUCTION

@async_run
async def auction_choice(update: Update, context: CallbackContext):
user_id = update.effective_user.id
choice = update.message.text
if choice == 'Выставить на аукцион':
keyboard = [auction_categories, ['Отмена']]
reply_markup = ReplyKeyboardMarkup(keyboard, resize_keyboard=True)
await update.message.reply_text('Выберите категорию предмета:', reply_markup=reply_markup)
return AUCTION_ACTION
elif choice == 'Просмотреть лоты':
if auction_items:
message = 'Текущие лоты на аукционе:\n'
for idx, item in enumerate(auction_items):
remaining_time = int((item['end_time'] - datetime.datetime.now()).total_seconds() / 60)
message += f"{idx + 1}. [{item['category']}] {item['item']} - Текущая цена: {item['highest_bid']} (Продавец: {item['seller_username']}, Осталось времени: {remaining_time} мин)\n"
await update.message.reply_text(message)
keyboard = [['Поставить ставку', 'История ставок'], ['Отмена']]
reply_markup = ReplyKeyboardMarkup(keyboard, resize_keyboard=True)
await update.message.reply_text('Выберите действие:', reply_markup=reply_markup)
return AUCTION_ACTION
else:
await update.message.reply_text('На аукционе пока нет лотов.')
return ConversationHandler.END
elif choice == 'Мои лоты':
user_lots = [item for item in auction_items if item['seller_id'] == user_id]
if user_lots:
message = 'Ваши лоты на аукционе:\n'
for idx, item in enumerate(user_lots):
remaining_time = int((item['end_time'] - datetime.datetime.now()).total_seconds() / 60)
message += f"{idx + 1}. {item['item']} - Текущая цена: {item['highest_bid']} (Осталось времени: {remaining_time} мин)\n"
await update.message.reply_text(message)
await update.message.reply_text('Введите номер лота для отмены или "Отмена":')
context.user_data['auction_state'] = 'canceling'
return AUCTION_CANCEL
else:
await update.message.reply_text('У вас нет активных лотов на аукционе.')
return ConversationHandler.END
elif choice == 'Отмена':
await update.message.reply_text('Действие отменено.', reply_markup=ReplyKeyboardRemove())
return ConversationHandler.END
else:
await update.message.reply_text('Пожалуйста, выберите доступную опцию.')
return AUCTION

@async_run
async def auction_action(update: Update, context: CallbackContext):
user_id = update.effective_user.id
input_text = update.message.text
if input_text in auction_categories:
context.user_data['auction_category'] = input_text
await update.message.reply_text('Введите название предмета для продажи:')
context.user_data['auction_state'] = 'listing'
return AUCTION_ACTION
elif input_text == 'Поставить ставку':
await update.message.reply_text('Введите номер лота для ставки или "Отмена":')
context.user_data['auction_state'] = 'bidding_selection'
return AUCTION_ACTION
elif input_text == 'История ставок':
await update.message.reply_text('Введите номер лота для просмотра истории или "Отмена":')
context.user_data['auction_state'] = 'viewing_history'
return AUCTION_ACTION
elif context.user_data.get('auction_state') == 'listing':
item_name = input_text
category = context.user_data.get('auction_category')
# Проверяем наличие предмета у пользователя
if category == 'Машины' and item_name in users[user_id]['garage']:
# Комиссия за выставление лота
commission = 500
if users[user_id]['balance'] >= commission:
users[user_id]['balance'] -= commission
await update.message.reply_text(f'Комиссия за выставление лота: {commission}')
await update.message.reply_text('Введите начальную цену:')
context.user_data['auction_item'] = item_name
context.user_data['auction_state'] = 'pricing'
save_data()
return AUCTION_ACTION
else:
await update.message.reply_text('Недостаточно средств для оплаты комиссии.')
return ConversationHandler.END
else:
await update.message.reply_text('У вас нет такого предмета.')
return ConversationHandler.END
elif context.user_data.get('auction_state') == 'pricing':
price = int(input_text)
item_name = context.user_data.get('auction_item')
category = context.user_data.get('auction_category')
auction_items.append({
'item': item_name,
'category': category,
'price': price,
'seller_id': user_id,
'seller_username': users[user_id]['username'],
'highest_bid': price,
'highest_bidder': None,
'end_time': datetime.datetime.now() + datetime.timedelta(seconds=AUCTION_DURATION),
'bidders': [],
'bid_history': [], # История ставок
'auto_bids': {} # Автоматические ставки
})
await update.message.reply_text('Ваш лот добавлен на аукцион.')
context.user_data['auction_state'] = None
# Удаляем предмет из гаража продавца
if category == 'Машины':
users[user_id]['garage'].remove(item_name)
save_data()
return ConversationHandler.END
elif context.user_data.get('auction_state') == 'bidding_selection' and input_text.isdigit():
lot_number = int(input_text) - 1
if 0 <= lot_number < len(auction_items):
lot = auction_items[lot_number]
await update.message.reply_text(f"Введите вашу ставку (текущая ставка: {lot['highest_bid']}). Если хотите использовать автоторги, введите 'Авто':")
context.user_data['auction_lot'] = lot_number
context.user_data['auction_state'] = 'bidding'
return AUCTION_ACTION
else:
await update.message.reply_text('Неверный номер лота.')
return ConversationHandler.END
elif context.user_data.get('auction_state') == 'viewing_history' and input_text.isdigit():
lot_number = int(input_text) - 1
if 0 <= lot_number < len(auction_items):
lot = auction_items[lot_number]
if lot['bid_history']:
message = f"История ставок для лота {lot['item']}:\n"
for bid in lot['bid_history']:
bidder_name = users[bid['user_id']]['username']
message += f"{bidder_name}: {bid['bid']}\n"
await update.message.reply_text(message)
else:
await update.message.reply_text('Для этого лота еще нет ставок.')
return ConversationHandler.END
else:
await update.message.reply_text('Неверный номер лота.')
return ConversationHandler.END
elif context.user_data.get('auction_state') == 'bidding':
lot_number = context.user_data.get('auction_lot')
lot = auction_items[lot_number]
if input_text.lower() == 'авто':
await update.message.reply_text('Введите максимальную сумму, до которой вы готовы повышать ставку автоматически:')
context.user_data['auction_state'] = 'auto_bidding'
return AUCTION_ACTION
else:
bid = int(input_text)
if bid > lot['highest_bid'] and bid <= users[user_id]['balance']:
previous_bidder = lot.get('highest_bidder')
lot['highest_bid'] = bid
lot['highest_bidder'] = user_id
lot['bidders'].append(user_id)
lot['bid_history'].append({'user_id': user_id, 'bid': bid})
await update.message.reply_text('Ваша ставка принята.')
# Уведомление предыдущего участника
if previous_bidder and previous_bidder != user_id:
users[previous_bidder]['notifications'].append(f"Ваша ставка на лот {lot['item']} была перебита.")
save_data()
return ConversationHandler.END
else:
await update.message.reply_text('Ставка недостаточна или у вас недостаточно средств.')
return ConversationHandler.END
elif context.user_data.get('auction_state') == 'auto_bidding':
max_bid = int(input_text)
lot_number = context.user_data.get('auction_lot')
lot = auction_items[lot_number]
if max_bid > lot['highest_bid'] and max_bid <= users[user_id]['balance']:
lot['auto_bids'][user_id] = max_bid
await update.message.reply_text('Автоматическое повышение ставки установлено.')
save_data()
return ConversationHandler.END
else:
await update.message.reply_text('Недопустимая максимальная ставка.')
return ConversationHandler.END
else:
await update.message.reply_text('Действие отменено.')
return ConversationHandler.END

# Отмена лота продавцом
@async_run
async def auction_cancel(update: Update, context: CallbackContext):
user_id = update.effective_user.id
input_text = update.message.text
if input_text.isdigit():
lot_number = int(input_text) - 1
user_lots = [item for item in auction_items if item['seller_id'] == user_id]
if 0 <= lot_number < len(user_lots):
lot = user_lots[lot_number]
auction_items.remove(lot)
# Возвращаем предмет продавцу
if lot['category'] == 'Машины':
users[user_id]['garage'].append(lot['item'])
await update.message.reply_text(f"Вы отменили лот {lot['item']}.")
# Уведомляем участников
for bidder_id in lot['bidders']:
if bidder_id != user_id:
users[bidder_id]['notifications'].append(f"Лот {lot['item']} был отменен продавцом.")
save_data()
return ConversationHandler.END
else:
await update.message.reply_text('Неверный номер лота.')
return ConversationHandler.END
else:
await update.message.reply_text('Действие отменено.')
return ConversationHandler.END

# Автоматическое завершение лотов по таймеру и обработка автоторгов
async def finalize_auctions(context: CallbackContext):
current_time = datetime.datetime.now()
completed_lots = [lot for lot in auction_items if lot['end_time'] <= current_time]
for lot in completed_lots:
# Обработка автоторгов
auto_bidders = lot['auto_bids']
while auto_bidders:
max_bidder = max(auto_bidders, key=auto_bidders.get)
max_bid = auto_bidders[max_bidder]
if max_bid > lot['highest_bid'] and users[max_bidder]['balance'] >= max_bid:
previous_bidder = lot.get('highest_bidder')
lot['highest_bid'] = lot['highest_bid'] + 100 # Шаг ставки
if lot['highest_bid'] > max_bid:
lot['highest_bid'] = max_bid
lot['highest_bidder'] = max_bidder
lot['bidders'].append(max_bidder)
lot['bid_history'].append({'user_id': max_bidder, 'bid': lot['highest_bid']})
# Уведомление предыдущего участника
if previous_bidder and previous_bidder != max_bidder:
users[previous_bidder]['notifications'].append(f"Ваша ставка на лот {lot['item']} была перебита.")
# Проверяем, достигли ли максимальной ставки
if lot['highest_bid'] >= max_bid:
del auto_bidders[max_bidder]
else:
del auto_bidders[max_bidder]
if lot['highest_bidder']:
buyer_id = lot['highest_bidder']
seller_id = lot['seller_id']
# Перевод денег
users[buyer_id]['balance'] -= lot['highest_bid']
users[seller_id]['balance'] += lot['highest_bid']
# Передача предмета
if lot['category'] == 'Машины':
users[buyer_id]['garage'].append(lot['item'])
# Отправка уведомлений
await context.bot.send_message(chat_id=buyer_id, text=f"Вы выиграли лот {lot['item']} за {lot['highest_bid']}!")
await context.bot.send_message(chat_id=seller_id, text=f"Ваш лот {lot['item']} был продан за {lot['highest_bid']}!")
# Уведомление другим участникам
for bidder_id in lot['bidders']:
if bidder_id != buyer_id:
await context.bot.send_message(chat_id=bidder_id, text=f"Лот {lot['item']} был продан другому участнику.")
else:
# Возвращаем предмет продавцу
if lot['category'] == 'Машины':
users[lot['seller_id']]['garage'].append(lot['item'])
await context.bot.send_message(chat_id=lot['seller_id'], text=f"Ваш лот {lot['item']} не был продан.")
auction_items.remove(lot)
save_data()

# Проверка и отправка уведомлений
async def send_notifications(context: CallbackContext):
for user_id, user_data in users.items():
notifications = user_data.get('notifications', [])
if notifications:
for notification in notifications:
await context.bot.send_message(chat_id=user_id, text=notification)
user_data['notifications'] = []
save_data()

# Запуск таймера для проверки аукциона и уведомлений
def schedule_jobs(updater: Updater):
job_queue = updater.job_queue
job_queue.run_repeating(finalize_auctions, interval=60, first=0)
job_queue.run_repeating(send_notifications, interval=60, first=0)

# Гараж
@async_run
async def garage(update: Update, context: CallbackContext):
user_id = update.effective_user.id
garage = users[user_id]['garage']
if garage:
message = 'Ваш гараж:\n'
for idx, car in enumerate(garage):
if car == users[user_id]['active_car']:
message += f"{idx + 1}. {car} (Активная)\n"
else:
message += f"{idx + 1}. {car}\n"
await update.message.reply_text(message)
await update.message.reply_text('Введите номер машины, которую хотите сделать активной, или "Отмена":')
context.user_data['garage_state'] = 'choosing'
return GARAGE_UPGRADE
else:
await update.message.reply_text('Ваш гараж пуст.')

@async_run
async def garage_choice(update: Update, context: CallbackContext):
user_id = update.effective_user.id
input_text = update.message.text
if input_text.isdigit():
car_number = int(input_text) - 1
if 0 <= car_number < len(users[user_id]['garage']):
users[user_id]['active_car'] = users[user_id]['garage'][car_number]
save_data()
await update.message.reply_text(f"Вы выбрали {users[user_id]['active_car']} в качестве активной машины.")
else:
await update.message.reply_text('Неверный номер машины.')
else:
await update.message.reply_text('Действие отменено.')

# Прокачка гаража
@async_run
async def garage_upgrade_start(update: Update, context: CallbackContext):
user_id = update.effective_user.id
garage_level = users[user_id].get('garage_level', 1)
upgrade_cost = 10000 * garage_level # Стоимость увеличивается с уровнем
await update.message.reply_text(f"Текущий уровень гаража: {garage_level}")
await update.message.reply_text(f"Стоимость улучшения до уровня {garage_level + 1}: {upgrade_cost}")
await update.message.reply_text('Хотите улучшить гараж? (Да/Нет)')
return GARAGE_UPGRADE

@async_run
async def garage_upgrade_confirm(update: Update, context: CallbackContext):
user_id = update.effective_user.id
choice = update.message.text.lower()
if choice == 'да':
garage_level = users[user_id]['garage_level']
upgrade_cost = 10000 * garage_level
if users[user_id]['balance'] >= upgrade_cost:
users[user_id]['balance'] -= upgrade_cost
users[user_id]['garage_level'] += 1
save_data()
await update.message.reply_text(f"Вы улучшили гараж до уровня {users[user_id]['garage_level']}!")
# Обновление прогресса ежедневного задания
await update_daily_quest_progress(user_id, 'garage_upgrade')
# Проверка достижений
await check_achievements(user_id, context)
else:
await update.message.reply_text('Недостаточно средств для улучшения.')
else:
await update.message.reply_text('Улучшение гаража отменено.')
return ConversationHandler.END

# Система кланов
@async_run
async def clan_start(update: Update, context: CallbackContext):
keyboard = [['Создать клан', 'Вступить в клан'], ['Покинуть клан', 'Список кланов'],
['Рейтинг кланов', 'Клановые задания'], ['Улучшить клановый бонус'], ['Отмена']]
reply_markup = ReplyKeyboardMarkup(keyboard, resize_keyboard=True)
await update.message.reply_text('Выберите действие для клана:', reply_markup=reply_markup)
return CLAN

@async_run
async def clan_choice(update: Update, context: CallbackContext):
user_id = update.effective_user.id
choice = update.message.text
if choice == 'Создать клан':
await update.message.reply_text('Стоимость создания клана: 50000. Введите название для вашего клана:')
context.user_data['clan_action'] = 'Создать клан'
return CLAN_ACTION
elif choice == 'Вступить в клан':
await update.message.reply_text('Введите название клана, в который хотите вступить:')
context.user_data['clan_action'] = 'Вступить в клан'
return CLAN_ACTION
elif choice == 'Покинуть клан':
if users[user_id]['clan']:
clan_name = users[user_id]['clan']
users[user_id]['clan'] = None
clans[clan_name]['members'].remove(user_id)
save_data()
await update.message.reply_text(f"Вы покинули клан {clan_name}.")
else:
await update.message.reply_text('Вы не состоите в клане.')
return ConversationHandler.END
elif choice == 'Список кланов':
clan_names = list(clans.keys())
if clan_names:
await update.message.reply_text('Список кланов:\n' + '\n'.join(clan_names))
else:
await update.message.reply_text('Кланов пока нет.')
return ConversationHandler.END
elif choice == 'Рейтинг кланов':
rankings = update_clan_rankings()
if rankings:
message = 'Рейтинг кланов:\n'
for idx, (clan, score) in enumerate(rankings):
message += f"{idx + 1}. {clan} - Рейтинг: {score:.2f}\n"
await update.message.reply_text(message)
else:
await update.message.reply_text('Рейтинг кланов пуст.')
return ConversationHandler.END
elif choice == 'Клановые задания':
await clan_quest_start(update, context)
return ConversationHandler.END
elif choice == 'Улучшить клановый бонус':
await clan_bonus_upgrade(update, context)
return ConversationHandler.END
elif choice == 'Отмена':
await update.message.reply_text('Действие отменено.', reply_markup=ReplyKeyboardRemove())
return ConversationHandler.END
else:
await update.message.reply_text('Пожалуйста, выберите доступную опцию.')
return CLAN

@async_run
async def clan_action(update: Update, context: CallbackContext):
user_id = update.effective_user.id
action = context.user_data.get('clan_action')
clan_name = update.message.text
if action == 'Создать клан':
if clan_name not in clans:
creation_cost = 50000
if users[user_id]['balance'] >= creation_cost:
users[user_id]['balance'] -= creation_cost
clans[clan_name] = {
'members': [user_id],
'bonus_level': 0,
'clan_quest': None,
'progress': 0,
'clan_race_waiting': []
}
users[user_id]['clan'] = clan_name
save_data()
await update.message.reply_text(f"Вы создали и вступили в клан {clan_name}.")
await check_achievements(user_id, context)
else:
await update.message.reply_text('Недостаточно средств для создания клана.')
else:
await update.message.reply_text('Клан с таким названием уже существует.')
elif action == 'Вступить в клан':
if clan_name in clans:
clans[clan_name]['members'].append(user_id)
users[user_id]['clan'] = clan_name
save_data()
await update.message.reply_text(f"Вы вступили в клан {clan_name}.")
await check_achievements(user_id, context)
else:
await update.message.reply_text('Клан с таким названием не найден.')
return ConversationHandler.END

# Клановые задания
@async_run
async def clan_quest_start(update: Update, context: CallbackContext):
user_id = update.effective_user.id
clan_name = users[user_id].get('clan')
if clan_name:
clan = clans[clan_name]
if not clan.get('clan_quest'):
quest = random.choice(clan_quests)
clan['clan_quest'] = quest
clan['progress'] = 0
save_data()
await update.message.reply_text(f"Ваш клан получил задание: {quest['task']}")
else:
quest = clan['clan_quest']
progress = clan['progress']
await update.message.reply_text(f"Текущее клановое задание: {quest['task']}\nПрогресс: {progress}/{quest['target']}")
else:
await update.message.reply_text('Вы не состоите в клане.')

# Улучшение кланового бонуса
@async_run
async def clan_bonus_upgrade(update: Update, context: CallbackContext):
user_id = update.effective_user.id
clan_name = users[user_id].get('clan')
if clan_name:
clan = clans[clan_name]
bonus_level = clan.get('bonus_level', 0)
upgrade_cost = 50000 * (bonus_level + 1)
await update.message.reply_text(f"Текущий уровень кланового бонуса: {bonus_level}")
await update.message.reply_text(f"Стоимость улучшения до уровня {bonus_level + 1}: {upgrade_cost}")
if users[user_id]['balance'] >= upgrade_cost:
users[user_id]['balance'] -= upgrade_cost
clan['bonus_level'] += 1
save_data()
await update.message.reply_text(f"Вы улучшили клановый бонус до уровня {clan['bonus_level']}!")
else:
await update.message.reply_text('Недостаточно средств для улучшения.')
else:
await update.message.reply_text('Вы не состоите в клане.')

# Реферальная система
@async_run
async def referral_link(update: Update, context: CallbackContext):
user_id = update.effective_user.id
referral_code = str(user_id)
bot_username = context.bot.username
await update.message.reply_text(f"Ваша реферальная ссылка: https://t.me/{bot_username}?start={referral_code}")

# Обработчик текстовых сообщений
@async_run
async def text_handler(update: Update, context: CallbackContext):
user_id = update.effective_user.id
text = update.message.text

# Защита от спама: ограничение на количество запросов
if 'last_message_time' in users[user_id]:
if (update.message.date - users[user_id]['last_message_time']).total_seconds() < 1:
await update.message.reply_text('Пожалуйста, не спамьте.')
return
users[user_id]['last_message_time'] = update.message.date

if text == 'Профиль':
await profile(update, context)
elif text == 'Автосалон':
await showroom(update, context)
elif text == 'Прокачка':
return await upgrade_car_start(update, context)
elif text == 'Заправка':
await refuel_car(update, context)
elif text == 'Гонки':
return await race_start(update, context)
elif text == 'Ежедневный бонус':
await daily_bonus(update, context)
elif text == 'Ежедневное задание':
await daily_quest(update, context)
elif text == 'Торговля':
return await trade_start(update, context)
elif text == 'Клан':
return await clan_start(update, context)
elif text == 'Гараж':
return await garage(update, context)
elif text == 'Аукцион':
return await auction_start(update, context)
elif text == 'Прокачка гаража':
return await garage_upgrade_start(update, context)
elif text == 'Реферальная ссылка':
await referral_link(update, context)
else:
await buy_car(update, context)

# Обработчик ошибок
@async_run
async def error_handler(update: Update, context: CallbackContext):
logger.error(msg="Произошла ошибка", exc_info=context.error)
await update.message.reply_text('Произошла ошибка. Пожалуйста, попробуйте еще раз.')

# Основная функция
# Основная функция
def main():
application = ApplicationBuilder().token('YOUR_BOT_TOKEN').build()

conv_handler = ConversationHandler(
entry_points=[CommandHandler('start', start)],
states={
STATE1: [MessageHandler(filters.TEXT & ~filters.COMMAND, state1_handler)],
STATE2: [MessageHandler(filters.TEXT & ~filters.COMMAND, state1_handler)],
},
fallbacks=[CommandHandler('cancel', cancel)],
)

application.add_handler(conv_handler)

# ConversationHandler для прокачки
conv_handler_upgrade = ConversationHandler(
entry_points=[MessageHandler(Filters.regex('^Прокачка$'), upgrade_car_start)],
states={
UPGRADE: [MessageHandler(Filters.text & ~Filters.command, upgrade_car_choice)]
},
fallbacks=[MessageHandler(Filters.regex('^Отмена$'), upgrade_car_choice)]
)
dp.add_handler(conv_handler_upgrade)

# ConversationHandler для гонок
conv_handler_race = ConversationHandler(
entry_points=[MessageHandler(Filters.regex('^Гонки$'), race_start)],
states={
RACE: [MessageHandler(Filters.text & ~Filters.command, race_choice)],
RACE_CONFIRM: [MessageHandler(Filters.text & ~Filters.command, race_virtual_confirm)]
},
fallbacks=[MessageHandler(Filters.regex('^Отмена$'), race_choice)]
)
dp.add_handler(conv_handler_race)

# ConversationHandler для торговли
conv_handler_trade = ConversationHandler(
entry_points=[MessageHandler(Filters.regex('^Торговля$'), trade_start)],
states={
TRADE: [MessageHandler(Filters.text & ~Filters.command, trade_choice)],
TRADE_CONFIRM: [MessageHandler(Filters.text & ~Filters.command, trade_offer)]
},
fallbacks=[MessageHandler(Filters.regex('^Отмена$'), trade_choice)]
)
dp.add_handler(conv_handler_trade)

# ConversationHandler для кланов
conv_handler_clan = ConversationHandler(
entry_points=[MessageHandler(Filters.regex('^Клан$'), clan_start)],
states={
CLAN: [MessageHandler(Filters.text & ~Filters.command, clan_choice)],
CLAN_ACTION: [MessageHandler(Filters.text & ~Filters.command, clan_action)]
},
fallbacks=[MessageHandler(Filters.regex('^Отмена$'), clan_choice)]
)
dp.add_handler(conv_handler_clan)

# ConversationHandler для аукциона
conv_handler_auction = ConversationHandler(
entry_points=[MessageHandler(Filters.regex('^Аукцион$'), auction_start)],
states={
AUCTION: [MessageHandler(Filters.text & ~Filters.command, auction_choice)],
AUCTION_ACTION: [MessageHandler(Filters.text & ~Filters.command, auction_action)],
AUCTION_CANCEL: [MessageHandler(Filters.text & ~Filters.command, auction_cancel)]
},
fallbacks=[MessageHandler(Filters.regex('^Отмена$'), auction_choice)]
)
dp.add_handler(conv_handler_auction)

# ConversationHandler для прокачки гаража
conv_handler_garage_upgrade = ConversationHandler(
entry_points=[MessageHandler(Filters.regex('^Прокачка гаража$'), garage_upgrade_start)],
states={
GARAGE_UPGRADE: [MessageHandler(Filters.text & ~Filters.command, garage_upgrade_confirm)]
},
fallbacks=[MessageHandler(Filters.regex('^Отмена$'), garage_upgrade_confirm)]
)
dp.add_handler(conv_handler_garage_upgrade)

# Обработчики сообщений
dp.add_handler(MessageHandler(Filters.text & ~Filters.command, text_handler))

# Запуск таймеров для аукциона и уведомлений
schedule_jobs(updater)

# Запуск бота
application.run_polling()
updater.idle()


# Определение состояний для ConversationHandler
STATE1 = 1
STATE2 = 2

# Обёртка для асинхронных обработчиков
def async_handler(func):
async def wrapper(update: Update, context: ContextTypes.DEFAULT_TYPE):
return await func(update, context)
return wrapper

# Обработчик команды /cancel
@async_handler
async def cancel(update: Update, context: ContextTypes.DEFAULT_TYPE):
await update.message.reply_text('Диалог отменен.')
return ConversationHandler.END

# Команда /start
@async_handler
async def start(update: Update, context: ContextTypes.DEFAULT_TYPE):
await update.message.reply_text('Привет! Это стартовое сообщение.')
return STATE1

# Обработчик сообщений в состоянии STATE1
@async_handler
async def state1_handler(update: Update, context: ContextTypes.DEFAULT_TYPE):
user_text = update.message.text
await update.message.reply_text(f'Вы ввели: {user_text}')
return STATE2

# Запуск бота
if __name__ == '__main__':
main()


Traceback (most recent call last):
File "C:\Users\Akio\Desktop\race_bot_ai\bot.py", line 36, in <module>
users = pickle.load(f)
^^^^^^^^^^^^^^
EOFError: Ran out of input

Исправь ошибки и скинь мне полный код

Traceback (most recent call last):
File "C:\Users\Akio\Desktop\race_bot_ai\bot.py", line 224, in <module>
async def showroom(update: Update, context: CallbackContext):
^^^^^^^^^^^^^^^
NameError: name 'CallbackContext' is not defined