diff --git a/BybitBot_API.py b/BybitBot_API.py index 7ead8b1..0f844e5 100644 --- a/BybitBot_API.py +++ b/BybitBot_API.py @@ -1,7 +1,7 @@ import asyncio import logging.config from aiogram import Bot, Dispatcher -from aiogram.fsm.storage.redis import RedisStorage + from app.services.Bybit.functions.bybit_ws import get_or_create_event_loop, set_event_loop from app.telegram.database.models import async_main from app.telegram.handlers.handlers import router @@ -17,9 +17,8 @@ from config import TOKEN_TG_BOT_1 logging.config.dictConfig(LOGGING_CONFIG) logger = logging.getLogger("main") -storage = RedisStorage.from_url("redis://localhost:6379/0") bot = Bot(token=TOKEN_TG_BOT_1) -dp = Dispatcher(storage=storage) +dp = Dispatcher() async def main() -> None: diff --git a/app/services/Bybit/functions/functions.py b/app/services/Bybit/functions/functions.py index d03999f..b5b2911 100644 --- a/app/services/Bybit/functions/functions.py +++ b/app/services/Bybit/functions/functions.py @@ -73,7 +73,7 @@ async def start_bybit_trade_message(message: Message) -> None: text = ( f"💎 Торговля на Bybit\n\n" - f"⚖️ Ваш баланс (USDT): {balance}\n" + f"⚖️ Ваш баланс (USDT): {float(balance):.2f}\n" f"📊 Текущая торговая пара: {symbol}\n" f"$$$ Цена: {price}\n\n" "Как начать торговлю?\n\n" @@ -155,7 +155,7 @@ async def entry_order_type_callback(callback: CallbackQuery, state: FSMContext) reply_markup=inline_markup.start_trading_markup) await callback.answer() except Exception as e: - logger.error(f"Произошла ошибка при обновлении типа входа в позицию: {e}") + logger.error("Произошла ошибка при обновлении типа входа в позицию: %s", e) await callback.message.answer("Произошла ошибка при обновлении типа входа в позицию", reply_markup=inline_markup.back_to_main) await state.clear() @@ -272,10 +272,10 @@ async def show_my_trades(callback: CallbackQuery) -> None: """ await callback.answer() try: - await callback.message.answer(f"Выберите тип сделки:", + await callback.message.answer("Выберите тип сделки:", reply_markup=inline_markup.my_deals_select_markup) except Exception as e: - logger.error(f"Произошла ошибка при выборе типа сделки: {e}") + logger.error("Произошла ошибка при выборе типа сделки: %s", e) @router_functions_bybit_trade.callback_query(F.data == "clb_open_deals") @@ -288,7 +288,7 @@ async def show_my_trades_callback(callback: CallbackQuery): try: await get_active_positions(callback.from_user.id, message=callback.message) except Exception as e: - logger.error(f"Произошла ошибка при выборе сделки: {e}") + logger.error("Произошла ошибка при выборе сделки: %s", e) await callback.message.answer("Произошла ошибка при выборе сделки", reply_markup=inline_markup.back_to_main) @@ -304,7 +304,7 @@ async def show_deal_callback(callback_query: CallbackQuery) -> None: tg_id = callback_query.from_user.id await get_active_positions_by_symbol(tg_id, symbol, message=callback_query.message) except Exception as e: - logger.error(f"Произошла ошибка при выборе сделки: {e}") + logger.error("Произошла ошибка при выборе сделки: %s", e) await callback_query.message.answer("Произошла ошибка при выборе сделки", reply_markup=inline_markup.back_to_main) @@ -319,7 +319,7 @@ async def show_my_orders_callback(callback: CallbackQuery) -> None: try: await get_active_orders(callback.from_user.id, message=callback.message) except Exception as e: - logger.error(f"Произошла ошибка при выборе ордера: {e}") + logger.error("Произошла ошибка при выборе ордера: %s", e) await callback.message.answer("Произошла ошибка при выборе ордера", reply_markup=inline_markup.back_to_main) @@ -335,7 +335,7 @@ async def show_limit_callback(callback_query: CallbackQuery) -> None: tg_id = callback_query.from_user.id await get_active_orders_by_symbol(tg_id, symbol, message=callback_query.message) except Exception as e: - logger.error(f"Произошла ошибка при выборе сделки: {e}") + logger.error("Произошла ошибка при выборе сделки: %s", e) await callback_query.message.answer("Произошла ошибка при выборе сделки", reply_markup=inline_markup.back_to_main) @@ -554,6 +554,9 @@ async def cancel(callback: CallbackQuery, state: FSMContext) -> None: """ Отменяет текущее состояние FSM и сообщает пользователю об отмене. """ - await state.clear() - await callback.message.answer("Отменено!", reply_markup=inline_markup.back_to_main) - await callback.answer() + try: + await state.clear() + await callback.message.answer("Отменено!", reply_markup=inline_markup.back_to_main) + await callback.answer() + except Exception as e: + logger.error("Ошибка при обработке отмены: %s", e) diff --git a/app/telegram/functions/main_settings/settings.py b/app/telegram/functions/main_settings/settings.py index 1f94590..00192e2 100644 --- a/app/telegram/functions/main_settings/settings.py +++ b/app/telegram/functions/main_settings/settings.py @@ -128,7 +128,7 @@ async def state_trading_mode(callback: CallbackQuery, state): await state.clear() except Exception as e: - logger.error(e) + logger.error("Ошибка при обновлении режима торговли: %s", e) async def switch_mode_enabled_message(message, state): @@ -235,8 +235,9 @@ async def state_martingale_factor(message: Message, state): await state.clear() else: + val = data['martingale_factor'] await message.answer( - f'⛔️ Ошибка: ваше значение ({data['martingale_factor']}) или выше лимита (100) или вы вводите неверные символы') + f"⛔️ Ошибка: ваше значение ({val}) или выше лимита (100) или вы вводите неверные символы") await main_settings_message(message.from_user.id, message) @@ -276,7 +277,7 @@ async def state_margin_type(callback: CallbackQuery, state): positions = active_positions.get('result', {}).get('list', []) except Exception as e: - logger.error(f"error: {e}") + logger.error("Ошибка при получении активных позиций: %s", e) positions = [] for pos in positions: @@ -306,7 +307,7 @@ async def state_margin_type(callback: CallbackQuery, state): await state.clear() except Exception as e: - logger.error(f"error: {e}") + logger.error("Ошибка при изменении типа маржи: %s", e) else: await callback.answer() await main_settings_message(callback.from_user.id, callback.message) @@ -336,7 +337,7 @@ async def state_starting_quantity(message: Message, state): await state.clear() else: - await message.answer(f'⛔️ Ошибка: вы вводите неверные символы') + await message.answer("⛔️ Ошибка: вы вводите неверные символы") await main_settings_message(message.from_user.id, message) @@ -344,7 +345,7 @@ async def state_starting_quantity(message: Message, state): async def maximum_quantity_message(message, state): await state.set_state(update_main_settings.maximal_quantity) - await message.edit_text("Введите максимальное количество серии ставок:", parse_mode='html', + await message.edit_text("Введите максимальное количество серии ставок:", reply_markup=inline_markup.back_btn_list_settings_markup) @@ -363,7 +364,9 @@ async def state_maximal_quantity(message: Message, state): await state.clear() else: + val = data['maximal_quantity'] await message.answer( - f'⛔️ Ошибка: ваше значение ({data['maximal_quantity']}) или выше лимита (100) или вы вводите неверные символы') + f'⛔️ Ошибка: ваше значение ({val}) или выше лимита (100) или вы вводите неверные символы') + logger.error(f'⛔️ Ошибка: ваше значение ({val}) или выше лимита (100) или вы вводите неверные символы') await main_settings_message(message.from_user.id, message) diff --git a/app/telegram/functions/risk_management_settings/settings.py b/app/telegram/functions/risk_management_settings/settings.py index 5d0b32d..6d1b731 100644 --- a/app/telegram/functions/risk_management_settings/settings.py +++ b/app/telegram/functions/risk_management_settings/settings.py @@ -56,8 +56,9 @@ async def state_price_profit(message: Message, state): await state.clear() else: + val = data['price_profit'] await message.answer( - f'⛔️ Ошибка: ваше значение ({data['price_profit']}%) или выше лимита (100) или вы вводите неверные символы') + f'⛔️ Ошибка: ваше значение ({val}%) или выше лимита (100) или вы вводите неверные символы') await main_settings_message(message.from_user.id, message) @@ -107,8 +108,9 @@ async def state_price_loss(message: Message, state): await main_settings_message(message.from_user.id, message) await state.clear() else: + val = data['price_loss'] await message.answer( - f'⛔️ Ошибка: ваше значение ({data["price_loss"]}%) выше лимита (100) или содержит неверные символы') + f'⛔️ Ошибка: ваше значение ({val}%) выше лимита (100) или содержит неверные символы') await main_settings_message(message.from_user.id, message) @@ -135,8 +137,9 @@ async def state_max_risk_deal(message: Message, state): await state.clear() else: + val = data['max_risk_deal'] await message.answer( - f'⛔️ Ошибка: ваше значение ({data['max_risk_deal']}%) или выше лимита (100) или вы вводите неверные символы') + f'⛔️ Ошибка: ваше значение ({val}%) или выше лимита (100) или вы вводите неверные символы') await main_settings_message(message.from_user.id, message) diff --git a/app/telegram/handlers/handlers.py b/app/telegram/handlers/handlers.py index aad7e65..b9efe3a 100644 --- a/app/telegram/handlers/handlers.py +++ b/app/telegram/handlers/handlers.py @@ -211,7 +211,7 @@ async def clb_main_settings_msg(callback: CallbackQuery, state: FSMContext) -> N case 'clb_change_maximum_quantity': await func_main_settings.maximum_quantity_message(callback.message, state) except Exception as e: - logger.error(f"Error callback in main_settings match-case: {e}") + logger.error("Error callback in main_settings match-case: %s", e) list_risk_management_settings = ['clb_change_price_profit', @@ -243,7 +243,7 @@ async def clb_risk_management_settings_msg(callback: CallbackQuery, state: FSMCo case 'commission_fee': await func_rmanagement_settings.commission_fee_message(callback.message, state) except Exception as e: - logger.error(f"Error callback in risk_management match-case: {e}") + logger.error("Error callback in risk_management match-case: %s", e) list_condition_settings = ['clb_change_mode', @@ -284,7 +284,7 @@ async def clb_condition_settings_msg(callback: CallbackQuery, state: FSMContext) case 'clb_change_ai_analytics': await func_condition_settings.ai_analytics_message(callback.message, state) except Exception as e: - logger.error(f"Error callback in main_settings match-case: {e}") + logger.error("Error callback in main_settings match-case: %s", e) list_additional_settings = ['clb_change_save_pattern', @@ -313,4 +313,4 @@ async def clb_additional_settings_msg(callback: CallbackQuery, state: FSMContext case 'clb_change_notifications': await func_additional_settings.notifications_message(callback.message, state) except Exception as e: - logger.error(f"Error callback in additional_settings match-case: {e}") + logger.error("Error callback in additional_settings match-case: %s", e)