kodorvan/stcs
6
0
Fork 2
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request 'develops' (#6) from Alex/stcs:develops into stable

Browse Source 
Reviewed-on: #6
This commit is contained in:
Arsen Mirzaev Tatyano-Muradovich
2025-09-12 23:52:03 +07:00
parent 82d875136b 0de3b17d1d
commit 05e8005ec9
6 changed files with 83 additions and 65 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
BybitBot_API.py
View File

@@ -1,7 +1,7 @@
import asyncio import asyncio
import logging.config import logging.config
from aiogram import Bot, Dispatcher 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.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.database.models import async_main
from app.telegram.handlers.handlers import router from app.telegram.handlers.handlers import router
@@ -17,9 +17,8 @@ from config import TOKEN_TG_BOT_1
logging.config.dictConfig(LOGGING_CONFIG) logging.config.dictConfig(LOGGING_CONFIG)
logger = logging.getLogger("main") logger = logging.getLogger("main")
storage = RedisStorage.from_url("redis://localhost:6379/0")
bot = Bot(token=TOKEN_TG_BOT_1) bot = Bot(token=TOKEN_TG_BOT_1)
dp = Dispatcher(storage=storage) dp = Dispatcher()
async def main() -> None: async def main() -> None:

25
app/services/Bybit/functions/functions.py
View File

@@ -73,7 +73,7 @@ async def start_bybit_trade_message(message: Message) -> None:
text = ( text = (
f"💎 Торговля на Bybit\n\n" f"💎 Торговля на Bybit\n\n"
f"⚖️ Ваш баланс (USDT): {balance}\n" f"⚖️ Ваш баланс (USDT): {float(balance):.2f}\n"
f"📊 Текущая торговая пара: {symbol}\n" f"📊 Текущая торговая пара: {symbol}\n"
f"$$$ Цена: {price}\n\n" f"$$$ Цена: {price}\n\n"
"Как начать торговлю?\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) reply_markup=inline_markup.start_trading_markup)
await callback.answer() await callback.answer()
except Exception as e: except Exception as e:
logger.error(f"Произошла ошибка при обновлении типа входа в позицию: {e}") logger.error("Произошла ошибка при обновлении типа входа в позицию: %s", e)
await callback.message.answer("Произошла ошибка при обновлении типа входа в позицию", await callback.message.answer("Произошла ошибка при обновлении типа входа в позицию",
reply_markup=inline_markup.back_to_main) reply_markup=inline_markup.back_to_main)
await state.clear() await state.clear()
@@ -272,10 +272,10 @@ async def show_my_trades(callback: CallbackQuery) -> None:
""" """
await callback.answer() await callback.answer()
try: try:
await callback.message.answer(f"Выберите тип сделки:", await callback.message.answer("Выберите тип сделки:",
reply_markup=inline_markup.my_deals_select_markup) reply_markup=inline_markup.my_deals_select_markup)
except Exception as e: except Exception as e:
logger.error(f"Произошла ошибка при выборе типа сделки: {e}") logger.error("Произошла ошибка при выборе типа сделки: %s", e)
@router_functions_bybit_trade.callback_query(F.data == "clb_open_deals") @router_functions_bybit_trade.callback_query(F.data == "clb_open_deals")
@@ -288,7 +288,7 @@ async def show_my_trades_callback(callback: CallbackQuery):
try: try:
await get_active_positions(callback.from_user.id, message=callback.message) await get_active_positions(callback.from_user.id, message=callback.message)
except Exception as e: except Exception as e:
logger.error(f"Произошла ошибка при выборе сделки: {e}") logger.error("Произошла ошибка при выборе сделки: %s", e)
await callback.message.answer("Произошла ошибка при выборе сделки", reply_markup=inline_markup.back_to_main) 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 tg_id = callback_query.from_user.id
await get_active_positions_by_symbol(tg_id, symbol, message=callback_query.message) await get_active_positions_by_symbol(tg_id, symbol, message=callback_query.message)
except Exception as e: except Exception as e:
logger.error(f"Произошла ошибка при выборе сделки: {e}") logger.error("Произошла ошибка при выборе сделки: %s", e)
await callback_query.message.answer("Произошла ошибка при выборе сделки", await callback_query.message.answer("Произошла ошибка при выборе сделки",
reply_markup=inline_markup.back_to_main) reply_markup=inline_markup.back_to_main)
@@ -319,7 +319,7 @@ async def show_my_orders_callback(callback: CallbackQuery) -> None:
try: try:
await get_active_orders(callback.from_user.id, message=callback.message) await get_active_orders(callback.from_user.id, message=callback.message)
except Exception as e: except Exception as e:
logger.error(f"Произошла ошибка при выборе ордера: {e}") logger.error("Произошла ошибка при выборе ордера: %s", e)
await callback.message.answer("Произошла ошибка при выборе ордера", reply_markup=inline_markup.back_to_main) 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 tg_id = callback_query.from_user.id
await get_active_orders_by_symbol(tg_id, symbol, message=callback_query.message) await get_active_orders_by_symbol(tg_id, symbol, message=callback_query.message)
except Exception as e: except Exception as e:
logger.error(f"Произошла ошибка при выборе сделки: {e}") logger.error("Произошла ошибка при выборе сделки: %s", e)
await callback_query.message.answer("Произошла ошибка при выборе сделки", await callback_query.message.answer("Произошла ошибка при выборе сделки",
reply_markup=inline_markup.back_to_main) reply_markup=inline_markup.back_to_main)
@@ -554,6 +554,9 @@ async def cancel(callback: CallbackQuery, state: FSMContext) -> None:
""" """
Отменяет текущее состояние FSM и сообщает пользователю об отмене. Отменяет текущее состояние FSM и сообщает пользователю об отмене.
""" """
await state.clear() try:
await callback.message.answer("Отменено!", reply_markup=inline_markup.back_to_main) await state.clear()
await callback.answer() await callback.message.answer("Отменено!", reply_markup=inline_markup.back_to_main)
await callback.answer()
except Exception as e:
logger.error("Ошибка при обработке отмены: %s", e)

19
app/telegram/functions/main_settings/settings.py
View File

@@ -128,7 +128,7 @@ async def state_trading_mode(callback: CallbackQuery, state):
await state.clear() await state.clear()
except Exception as e: except Exception as e:
logger.error(e) logger.error("Ошибка при обновлении режима торговли: %s", e)
async def switch_mode_enabled_message(message, state): async def switch_mode_enabled_message(message, state):
@@ -235,8 +235,9 @@ async def state_martingale_factor(message: Message, state):
await state.clear() await state.clear()
else: else:
val = data['martingale_factor']
await message.answer( await message.answer(
f'⛔️ Ошибка: ваше значение ({data['martingale_factor']}) или выше лимита (100) или вы вводите неверные символы') f"⛔️ Ошибка: ваше значение ({val}) или выше лимита (100) или вы вводите неверные символы")
await main_settings_message(message.from_user.id, message) 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', []) positions = active_positions.get('result', {}).get('list', [])
except Exception as e: except Exception as e:
logger.error(f"error: {e}") logger.error("Ошибка при получении активных позиций: %s", e)
positions = [] positions = []
for pos in positions: for pos in positions:
@@ -306,7 +307,7 @@ async def state_margin_type(callback: CallbackQuery, state):
await state.clear() await state.clear()
except Exception as e: except Exception as e:
logger.error(f"error: {e}") logger.error("Ошибка при изменении типа маржи: %s", e)
else: else:
await callback.answer() await callback.answer()
await main_settings_message(callback.from_user.id, callback.message) 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() await state.clear()
else: else:
await message.answer(f'⛔️ Ошибка: вы вводите неверные символы') await message.answer("⛔️ Ошибка: вы вводите неверные символы")
await main_settings_message(message.from_user.id, message) 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): async def maximum_quantity_message(message, state):
await state.set_state(update_main_settings.maximal_quantity) 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) reply_markup=inline_markup.back_btn_list_settings_markup)
@@ -363,7 +364,9 @@ async def state_maximal_quantity(message: Message, state):
await state.clear() await state.clear()
else: else:
val = data['maximal_quantity']
await message.answer( 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) await main_settings_message(message.from_user.id, message)

11
app/telegram/functions/risk_management_settings/settings.py
View File

@@ -56,8 +56,9 @@ async def state_price_profit(message: Message, state):
await state.clear() await state.clear()
else: else:
val = data['price_profit']
await message.answer( await message.answer(
f'⛔️ Ошибка: ваше значение ({data['price_profit']}%) или выше лимита (100) или вы вводите неверные символы') f'⛔️ Ошибка: ваше значение ({val}%) или выше лимита (100) или вы вводите неверные символы')
await main_settings_message(message.from_user.id, message) 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 main_settings_message(message.from_user.id, message)
await state.clear() await state.clear()
else: else:
val = data['price_loss']
await message.answer( await message.answer(
f'⛔️ Ошибка: ваше значение ({data["price_loss"]}%) выше лимита (100) или содержит неверные символы') f'⛔️ Ошибка: ваше значение ({val}%) выше лимита (100) или содержит неверные символы')
await main_settings_message(message.from_user.id, message) 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() await state.clear()
else: else:
val = data['max_risk_deal']
await message.answer( await message.answer(
f'⛔️ Ошибка: ваше значение ({data['max_risk_deal']}%) или выше лимита (100) или вы вводите неверные символы') f'⛔️ Ошибка: ваше значение ({val}%) или выше лимита (100) или вы вводите неверные символы')
await main_settings_message(message.from_user.id, message) await main_settings_message(message.from_user.id, message)
@@ -154,4 +157,4 @@ async def process_commission_fee_callback(callback: CallbackQuery, state):
await callback.message.answer(f"✅ Изменено: {val}") await callback.message.answer(f"✅ Изменено: {val}")
await callback.answer() await callback.answer()
await main_settings_message(callback.from_user.id, callback.message) await main_settings_message(callback.from_user.id, callback.message)
await state.clear() await state.clear()

8
app/telegram/handlers/handlers.py
View File

@@ -211,7 +211,7 @@ async def clb_main_settings_msg(callback: CallbackQuery, state: FSMContext) -> N
case 'clb_change_maximum_quantity': case 'clb_change_maximum_quantity':
await func_main_settings.maximum_quantity_message(callback.message, state) await func_main_settings.maximum_quantity_message(callback.message, state)
except Exception as e: 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', 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': case 'commission_fee':
await func_rmanagement_settings.commission_fee_message(callback.message, state) await func_rmanagement_settings.commission_fee_message(callback.message, state)
except Exception as e: 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', 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': case 'clb_change_ai_analytics':
await func_condition_settings.ai_analytics_message(callback.message, state) await func_condition_settings.ai_analytics_message(callback.message, state)
except Exception as e: 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', 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': case 'clb_change_notifications':
await func_additional_settings.notifications_message(callback.message, state) await func_additional_settings.notifications_message(callback.message, state)
except Exception as e: 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)

80
logger_helper/loggers/app.log
View File

@@ -1,35 +1,45 @@
2025-08-23 12:57:26 - main - INFO - Bot is off 2025-09-12 10:09:21 - main - INFO - Bot is on
2025-08-23 13:04:01 - main - INFO - Bot is off 2025-09-12 11:34:46 - main - INFO - Bot is on
2025-08-23 13:25:04 - main - INFO - Bot is off 2025-09-12 11:34:56 - requests - INFO - Получение риск-менеджмента настроек пользователя 899674724
2025-08-23 13:26:24 - main - INFO - Bot is off 2025-09-12 11:35:56 - requests - INFO - Получение риск-менеджмента настроек пользователя 899674724
2025-08-23 13:28:36 - main - INFO - Bot is off 2025-09-12 11:36:40 - bybit_ws - INFO - WebSocket для пользователя 899674724 запущен.
2025-08-23 13:29:29 - main - INFO - Bot is off 2025-09-12 11:38:54 - main - INFO - Bot is on
2025-08-23 13:30:48 - main - INFO - Bot is off 2025-09-12 11:40:57 - main - INFO - Bot is on
2025-08-23 13:31:43 - main - INFO - Bot is off 2025-09-12 11:42:06 - main - INFO - Bot is on
2025-08-23 13:33:10 - main - INFO - Bot is off 2025-09-12 11:42:47 - main - INFO - Bot is on
2025-08-23 13:34:59 - main - INFO - Bot is off 2025-09-12 11:43:01 - bybit_ws - INFO - WebSocket для пользователя 899674724 запущен.
2025-08-23 13:36:15 - main - INFO - Bot is off 2025-09-12 11:46:11 - main - INFO - Bot is on
2025-08-23 13:49:17 - main - INFO - Bot is off 2025-09-12 11:46:20 - requests - INFO - Получение риск-менеджмента настроек пользователя 899674724
2025-08-23 13:50:22 - main - INFO - Bot is on 2025-09-12 12:35:06 - main - INFO - Bot is on
2025-08-23 13:51:30 - main - INFO - Bot is off 2025-09-12 12:35:07 - models - INFO - Заполение таблицы режима торговли
2025-08-23 13:51:37 - main - INFO - Bot is on 2025-09-12 12:35:07 - models - INFO - Заполение таблицы режима торговли
2025-08-23 13:52:12 - main - INFO - Bot is off 2025-09-12 12:35:07 - models - INFO - Заполение таблицы режима торговли
2025-08-23 13:57:48 - main - INFO - Bot is on 2025-09-12 12:35:07 - models - INFO - Заполение таблицы режима торговли
2025-08-23 14:05:36 - main - INFO - Bot is off 2025-09-12 12:35:07 - models - INFO - Заполение таблицы типов маржи
2025-08-23 14:05:43 - main - INFO - Bot is on 2025-09-12 12:35:07 - models - INFO - Заполение таблицы типов маржи
2025-08-23 14:06:03 - main - INFO - Bot is off 2025-09-12 12:35:07 - models - INFO - Заполение таблицы последнего направления
2025-08-23 14:06:46 - main - INFO - Bot is on 2025-09-12 12:35:07 - models - INFO - Заполение таблицы последнего направления
2025-08-23 14:07:04 - requests - INFO - Bybit был успешно подключен 2025-09-12 12:36:00 - main_settings - ERROR - Authenticated endpoints require keys: Authenticated endpoints require keys.
2025-08-23 14:07:43 - requests - INFO - Новый пользователь был добавлен в бд 2025-09-12 12:36:24 - requests - INFO - Добавлен новый пользователь 899674724 с ключами
2025-08-23 14:07:43 - requests - INFO - Основные настройки нового пользователя были заполнены 2025-09-12 12:36:25 - requests - INFO - Symbol был успешно добавлен 899674724
2025-08-23 14:07:43 - requests - INFO - Риск-Менеджмент настройки нового пользователя были заполнены 2025-09-12 12:36:25 - requests - INFO - Новый пользователь был добавлен в бд 899674724
2025-08-23 14:07:43 - requests - INFO - Условные настройки нового пользователя были заполнены 2025-09-12 12:36:25 - requests - INFO - Основные настройки нового пользователя были заполнены899674724
2025-08-23 14:07:43 - requests - INFO - Дополнительные настройки нового пользователя были заполнены 2025-09-12 12:36:25 - requests - INFO - Риск-Менеджмент настройки нового пользователя были заполнены 899674724
2025-08-23 14:23:31 - main - INFO - Bot is off 2025-09-12 12:36:25 - requests - INFO - Условные настройки нового пользователя были заполнены 899674724
2025-08-23 14:23:39 - main - INFO - Bot is on 2025-09-12 12:36:25 - requests - INFO - Дополнительные настройки нового пользователя были заполнены 899674724
2025-08-23 14:28:13 - main - INFO - Bot is off 2025-09-12 12:36:26 - bybit_ws - INFO - WebSocket для пользователя 899674724 запущен.
2025-08-23 14:28:19 - main - INFO - Bot is on 2025-09-12 12:38:00 - main - INFO - Bot is on
2025-08-23 14:28:26 - requests - INFO - Получение риск-менеджмента настроек пользователя 899674724 2025-09-12 12:38:54 - bybit_ws - INFO - WebSocket для пользователя 899674724 запущен.
2025-08-23 14:28:26 - requests - INFO - Получение риск-менеджмента настроек пользователя 899674724 2025-09-12 12:40:53 - requests - INFO - Получение риск-менеджмента настроек пользователя 899674724
2025-08-23 14:29:12 - requests - INFO - Получение риск-менеджмента настроек пользователя 899674724 2025-09-12 12:41:07 - requests - INFO - Получение риск-менеджмента настроек пользователя 899674724
2025-08-23 14:29:34 - main - INFO - Bot is off 2025-09-12 13:43:39 - main - INFO - Bot is on
2025-09-12 18:13:40 - main - INFO - Bot is on
2025-09-12 18:13:52 - requests - INFO - Получение риск-менеджмента настроек пользователя 899674724
2025-09-12 18:19:38 - main - INFO - Bot is on
2025-09-12 18:19:52 - bybit_ws - INFO - WebSocket для пользователя 899674724 запущен.
2025-09-12 18:20:01 - requests - INFO - Получение риск-менеджмента настроек пользователя 899674724
2025-09-12 18:20:27 - requests - INFO - Получение риск-менеджмента настроек пользователя 899674724
2025-09-12 18:22:37 - main - INFO - Bot is on
2025-09-12 18:22:37 - requests - INFO - Получение риск-менеджмента настроек пользователя 899674724
2025-09-12 18:22:48 - requests - INFO - Получение риск-менеджмента настроек пользователя 899674724
2025-09-12 18:23:21 - bybit_ws - INFO - WebSocket для пользователя 899674724 запущен.