Fixed
This commit is contained in:
@@ -472,7 +472,7 @@ async def stop_immediately(callback: CallbackQuery):
|
|||||||
tg_id = callback.from_user.id
|
tg_id = callback.from_user.id
|
||||||
|
|
||||||
await rq.update_trigger(tg_id, "Ручной")
|
await rq.update_trigger(tg_id, "Ручной")
|
||||||
await callback.message.answer("Торговля остановлена.", reply_markup=inline_markup.back_to_main)
|
await callback.message.answer("Автоматическая торговля остановлена.", reply_markup=inline_markup.back_to_main)
|
||||||
await callback.answer()
|
await callback.answer()
|
||||||
|
|
||||||
|
|
||||||
@@ -482,13 +482,13 @@ async def stop_with_timer_start(callback: CallbackQuery, state: FSMContext):
|
|||||||
Запускает диалог с пользователем для задания задержки перед остановкой торговли.
|
Запускает диалог с пользователем для задания задержки перед остановкой торговли.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
await state.set_state(CloseTradeTimerState.waiting_for_delay)
|
await state.set_state(CloseTradeTimerState.waiting_for_trade)
|
||||||
await callback.message.answer("Введите задержку в минутах перед остановкой торговли:",
|
await callback.message.answer("Введите задержку в минутах перед остановкой торговли:",
|
||||||
reply_markup=inline_markup.cancel)
|
reply_markup=inline_markup.cancel)
|
||||||
await callback.answer()
|
await callback.answer()
|
||||||
|
|
||||||
|
|
||||||
@router_functions_bybit_trade.message(CloseTradeTimerState.waiting_for_delay)
|
@router_functions_bybit_trade.message(CloseTradeTimerState.waiting_for_trade)
|
||||||
async def process_stop_delay(message: Message, state: FSMContext):
|
async def process_stop_delay(message: Message, state: FSMContext):
|
||||||
"""
|
"""
|
||||||
Обрабатывает ввод задержки и запускает задачу остановки торговли с задержкой.
|
Обрабатывает ввод задержки и запускает задачу остановки торговли с задержкой.
|
||||||
@@ -505,11 +505,10 @@ async def process_stop_delay(message: Message, state: FSMContext):
|
|||||||
tg_id = message.from_user.id
|
tg_id = message.from_user.id
|
||||||
delay_seconds = delay_minutes * 60
|
delay_seconds = delay_minutes * 60
|
||||||
|
|
||||||
await message.answer(f"Торговля будет остановлена через {delay_minutes} минут.",
|
await message.answer(f"Торговля будет остановлена через {delay_minutes} минут.")
|
||||||
reply_markup=inline_markup.back_to_main)
|
|
||||||
await asyncio.sleep(delay_seconds)
|
await asyncio.sleep(delay_seconds)
|
||||||
await rq.update_trigger(tg_id, "Ручной")
|
await rq.update_trigger(tg_id, "Ручной")
|
||||||
await message.answer("Торговля по таймеру остановлена.")
|
await message.answer("Автоматическая торговля остановлена.", reply_markup=inline_markup.back_to_main)
|
||||||
|
|
||||||
await state.clear()
|
await state.clear()
|
||||||
|
|
||||||
|
@@ -25,6 +25,7 @@ class state_limit_price(StatesGroup):
|
|||||||
class CloseTradeTimerState(StatesGroup):
|
class CloseTradeTimerState(StatesGroup):
|
||||||
"""FSM состояние ожидания задержки перед закрытием сделки."""
|
"""FSM состояние ожидания задержки перед закрытием сделки."""
|
||||||
waiting_for_delay = State()
|
waiting_for_delay = State()
|
||||||
|
waiting_for_trade = State()
|
||||||
|
|
||||||
|
|
||||||
class SetTP_SL_State(StatesGroup):
|
class SetTP_SL_State(StatesGroup):
|
||||||
|
Reference in New Issue
Block a user