Compare commits
6 Commits
0.1.0
...
751cde86f9
Author | SHA1 | Date | |
---|---|---|---|
![]() |
751cde86f9 | ||
![]() |
1b95992297 | ||
![]() |
d8bb3fda82 | ||
![]() |
4704d4a486 | ||
![]() |
c7b3ae7876 | ||
![]() |
6fb876ade2 |
@@ -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:
|
||||
|
@@ -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()
|
||||
@@ -275,7 +275,7 @@ async def show_my_trades(callback: CallbackQuery) -> None:
|
||||
await callback.message.answer(f"Выберите тип сделки:",
|
||||
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)
|
||||
|
||||
|
@@ -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("Введите <b>максимальное количество серии ставок:</b>", 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)
|
||||
|
@@ -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)
|
||||
|
||||
|
@@ -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)
|
||||
|
Reference in New Issue
Block a user