Compare commits
4 Commits
245cadf650
...
a7a23a4662
| Author | SHA1 | Date | |
|---|---|---|---|
| a7a23a4662 | |||
|
|
78f21e6718 | ||
|
|
6416bd6dc9 | ||
|
|
29c168e31d |
@@ -107,7 +107,8 @@ async def start_trading_cycle(
|
|||||||
"position idx not match position mode",
|
"position idx not match position mode",
|
||||||
"Qty invalid",
|
"Qty invalid",
|
||||||
"The number of contracts exceeds maximum limit allowed",
|
"The number of contracts exceeds maximum limit allowed",
|
||||||
"The number of contracts exceeds minimum limit allowed"
|
"The number of contracts exceeds minimum limit allowed",
|
||||||
|
"Order placement failed as your position may exceed the max",
|
||||||
}
|
}
|
||||||
else None
|
else None
|
||||||
)
|
)
|
||||||
@@ -193,6 +194,7 @@ async def trading_cycle_profit(
|
|||||||
"ab not enough for new order",
|
"ab not enough for new order",
|
||||||
"InvalidRequestError",
|
"InvalidRequestError",
|
||||||
"The number of contracts exceeds maximum limit allowed",
|
"The number of contracts exceeds maximum limit allowed",
|
||||||
|
"Order placement failed as your position may exceed the max",
|
||||||
}
|
}
|
||||||
else None
|
else None
|
||||||
)
|
)
|
||||||
@@ -293,6 +295,7 @@ async def trading_cycle(
|
|||||||
"ab not enough for new order",
|
"ab not enough for new order",
|
||||||
"InvalidRequestError",
|
"InvalidRequestError",
|
||||||
"The number of contracts exceeds maximum limit allowed",
|
"The number of contracts exceeds maximum limit allowed",
|
||||||
|
"Order placement failed as your position may exceed the max",
|
||||||
}
|
}
|
||||||
else None
|
else None
|
||||||
)
|
)
|
||||||
@@ -363,6 +366,7 @@ async def open_positions(
|
|||||||
"Qty invalid": "Qty invalid",
|
"Qty invalid": "Qty invalid",
|
||||||
"The number of contracts exceeds maximum limit allowed": "The number of contracts exceeds maximum limit allowed",
|
"The number of contracts exceeds maximum limit allowed": "The number of contracts exceeds maximum limit allowed",
|
||||||
"The number of contracts exceeds minimum limit allowed": "The number of contracts exceeds minimum limit allowed",
|
"The number of contracts exceeds minimum limit allowed": "The number of contracts exceeds minimum limit allowed",
|
||||||
|
"Order placement failed as your position may exceed the max": "Order placement failed as your position may exceed the max",
|
||||||
}
|
}
|
||||||
for key, msg in known_errors.items():
|
for key, msg in known_errors.items():
|
||||||
if key in error_text:
|
if key in error_text:
|
||||||
|
|||||||
@@ -64,6 +64,14 @@ class TelegramMessageHandler:
|
|||||||
exec_fees = format_value(execution.get("execFee"))
|
exec_fees = format_value(execution.get("execFee"))
|
||||||
fee_rate = format_value(execution.get("feeRate"))
|
fee_rate = format_value(execution.get("feeRate"))
|
||||||
side = format_value(execution.get("side"))
|
side = format_value(execution.get("side"))
|
||||||
|
|
||||||
|
user_auto_trading = await rq.get_user_auto_trading(
|
||||||
|
tg_id=tg_id, symbol=symbol
|
||||||
|
)
|
||||||
|
auto_trading = (
|
||||||
|
user_auto_trading.auto_trading if user_auto_trading else False
|
||||||
|
)
|
||||||
|
|
||||||
side_rus = (
|
side_rus = (
|
||||||
"Покупка"
|
"Покупка"
|
||||||
if side == "Buy"
|
if side == "Buy"
|
||||||
@@ -81,10 +89,6 @@ class TelegramMessageHandler:
|
|||||||
tg_id=tg_id, symbol=symbol, fee=safe_float(exec_fee)
|
tg_id=tg_id, symbol=symbol, fee=safe_float(exec_fee)
|
||||||
)
|
)
|
||||||
|
|
||||||
user_auto_trading = await rq.get_user_auto_trading(
|
|
||||||
tg_id=tg_id, symbol=symbol
|
|
||||||
)
|
|
||||||
|
|
||||||
get_total_fee = user_auto_trading.total_fee
|
get_total_fee = user_auto_trading.total_fee
|
||||||
total_fee = safe_float(exec_fee) + safe_float(get_total_fee)
|
total_fee = safe_float(exec_fee) + safe_float(get_total_fee)
|
||||||
|
|
||||||
@@ -96,15 +100,11 @@ class TelegramMessageHandler:
|
|||||||
"Сделка закрыта:" if safe_float(closed_size) > 0 else "Сделка открыта:"
|
"Сделка закрыта:" if safe_float(closed_size) > 0 else "Сделка открыта:"
|
||||||
)
|
)
|
||||||
text = f"{header}\n" f"Торговая пара: {symbol}\n"
|
text = f"{header}\n" f"Торговая пара: {symbol}\n"
|
||||||
|
|
||||||
auto_trading = (
|
|
||||||
user_auto_trading.auto_trading if user_auto_trading else False
|
|
||||||
)
|
|
||||||
user_deals_data = await rq.get_user_deal_by_symbol(
|
user_deals_data = await rq.get_user_deal_by_symbol(
|
||||||
tg_id=tg_id, symbol=symbol
|
tg_id=tg_id, symbol=symbol
|
||||||
)
|
)
|
||||||
commission_fee = user_deals_data.commission_fee
|
commission_fee = user_deals_data.commission_fee or "Yes_commission_fee"
|
||||||
commission_place = user_deals_data.commission_place
|
commission_place = user_deals_data.commission_place or "Commission_for_qty"
|
||||||
current_series = user_deals_data.current_series
|
current_series = user_deals_data.current_series
|
||||||
current_step = user_deals_data.current_step
|
current_step = user_deals_data.current_step
|
||||||
order_quantity = user_deals_data.order_quantity
|
order_quantity = user_deals_data.order_quantity
|
||||||
@@ -175,26 +175,34 @@ class TelegramMessageHandler:
|
|||||||
take_profit_price = max(take_profit_price, 0)
|
take_profit_price = max(take_profit_price, 0)
|
||||||
stop_loss_price = max(stop_loss_price, 0)
|
stop_loss_price = max(stop_loss_price, 0)
|
||||||
|
|
||||||
await set_tp_sl_for_position(tg_id=tg_id,
|
ress = await set_tp_sl_for_position(tg_id=tg_id,
|
||||||
symbol=symbol,
|
symbol=symbol,
|
||||||
take_profit_price=take_profit_price,
|
take_profit_price=take_profit_price,
|
||||||
stop_loss_price=stop_loss_price,
|
stop_loss_price=stop_loss_price,
|
||||||
position_idx=0)
|
position_idx=0)
|
||||||
|
if ress:
|
||||||
take_profit_truncated = await truncate_float(take_profit_price, 4)
|
take_profit_truncated = await truncate_float(take_profit_price, 6)
|
||||||
stop_loss_truncated = await truncate_float(stop_loss_price, 4)
|
stop_loss_truncated = await truncate_float(stop_loss_price, 6)
|
||||||
|
|
||||||
text += (f"Движение: {side_rus}\n"
|
text += (f"Движение: {side_rus}\n"
|
||||||
f"Тейк-профит: {take_profit_truncated}\n"
|
f"Тейк-профит: {take_profit_truncated}\n"
|
||||||
f"Стоп-лосс: {stop_loss_truncated}\n"
|
f"Стоп-лосс: {stop_loss_truncated}\n"
|
||||||
)
|
)
|
||||||
else:
|
else:
|
||||||
|
text += (f"Движение: {side_rus}\n"
|
||||||
|
"Не удалось установить ТП и СЛ\n")
|
||||||
|
|
||||||
|
else:
|
||||||
|
if auto_trading:
|
||||||
new_pnl = safe_float(pnl_series) + total_pnl
|
new_pnl = safe_float(pnl_series) + total_pnl
|
||||||
await rq.set_pnl_series_by_symbol(
|
await rq.set_pnl_series_by_symbol(
|
||||||
tg_id=tg_id, symbol=symbol, pnl_series=new_pnl)
|
tg_id=tg_id, symbol=symbol, pnl_series=new_pnl)
|
||||||
text += f"\nДоход: {ex_pnl:.4f}\n"
|
text += f"\nПрибыль без комиссии: {ex_pnl:.4f}\n"
|
||||||
text += f"Реализованный PNL: {total_pnl:.4f}\n"
|
text += f"Реализованная прибыль: {total_pnl:.4f}\n"
|
||||||
text += f"Прибыль серии: {safe_float(new_pnl):.4f}\n"
|
text += f"Прибыль серии: {safe_float(new_pnl):.4f}\n"
|
||||||
|
else:
|
||||||
|
text += f"\nПрибыль без комиссии: {ex_pnl:.4f}\n"
|
||||||
|
text += f"Реализованная прибыль: {total_pnl:.4f}\n"
|
||||||
|
|
||||||
await self.telegram_bot.send_message(
|
await self.telegram_bot.send_message(
|
||||||
chat_id=tg_id, text=text, reply_markup=kbi.profile_bybit
|
chat_id=tg_id, text=text, reply_markup=kbi.profile_bybit
|
||||||
@@ -240,6 +248,7 @@ class TelegramMessageHandler:
|
|||||||
"ab not enough for new order": "❗️ Недостаточно средств для продолжения торговли",
|
"ab not enough for new order": "❗️ Недостаточно средств для продолжения торговли",
|
||||||
"InvalidRequestError": "❗️ Недостаточно средств для размещения нового ордера с заданным количеством и плечом.",
|
"InvalidRequestError": "❗️ Недостаточно средств для размещения нового ордера с заданным количеством и плечом.",
|
||||||
"The number of contracts exceeds maximum limit allowed": "❗️ Превышен максимальный лимит ставки",
|
"The number of contracts exceeds maximum limit allowed": "❗️ Превышен максимальный лимит ставки",
|
||||||
|
"Order placement failed as your position may exceed the max": "❗️ Превышен максимальный лимит ставки",
|
||||||
}
|
}
|
||||||
error_text = errors.get(
|
error_text = errors.get(
|
||||||
res, "❗️ Не удалось открыть новую сделку"
|
res, "❗️ Не удалось открыть новую сделку"
|
||||||
@@ -283,6 +292,7 @@ class TelegramMessageHandler:
|
|||||||
"ab not enough for new order": "❗️ Недостаточно средств для продолжения торговли",
|
"ab not enough for new order": "❗️ Недостаточно средств для продолжения торговли",
|
||||||
"InvalidRequestError": "❗️ Недостаточно средств для размещения нового ордера с заданным количеством и плечом.",
|
"InvalidRequestError": "❗️ Недостаточно средств для размещения нового ордера с заданным количеством и плечом.",
|
||||||
"The number of contracts exceeds maximum limit allowed": "❗️ Превышен максимальный лимит ставки",
|
"The number of contracts exceeds maximum limit allowed": "❗️ Превышен максимальный лимит ставки",
|
||||||
|
"Order placement failed as your position may exceed the max": "❗️ Превышен максимальный лимит ставки",
|
||||||
}
|
}
|
||||||
error_text = errors.get(
|
error_text = errors.get(
|
||||||
res, "❗️ Не удалось открыть новую сделку"
|
res, "❗️ Не удалось открыть новую сделку"
|
||||||
@@ -302,6 +312,5 @@ class TelegramMessageHandler:
|
|||||||
text=error_text,
|
text=error_text,
|
||||||
reply_markup=kbi.profile_bybit,
|
reply_markup=kbi.profile_bybit,
|
||||||
)
|
)
|
||||||
|
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.error("Error in telegram_message_handler: %s", e, exc_info=True)
|
logger.error("Error in telegram_message_handler: %s", e, exc_info=True)
|
||||||
|
|||||||
@@ -97,7 +97,8 @@ async def start_trading(callback_query: CallbackQuery, state: FSMContext) -> Non
|
|||||||
"Limit price is out min price": "Цена лимитного ордера меньше допустимого",
|
"Limit price is out min price": "Цена лимитного ордера меньше допустимого",
|
||||||
"Limit price is out max price": "Цена лимитного ордера больше допустимого",
|
"Limit price is out max price": "Цена лимитного ордера больше допустимого",
|
||||||
"Risk is too high for this trade": "Риск сделки превышает допустимый убыток",
|
"Risk is too high for this trade": "Риск сделки превышает допустимый убыток",
|
||||||
"estimated will trigger liq": "Лимитный ордер может вызвать мгновенную ликвидацию. Проверьте параметры ордера.",
|
"estimated will trigger liq": "Лимитный ордер может вызвать мгновенную ликвидацию. "
|
||||||
|
"Проверьте параметры ордера.",
|
||||||
"ab not enough for new order": "Недостаточно средств для создания нового ордера",
|
"ab not enough for new order": "Недостаточно средств для создания нового ордера",
|
||||||
"InvalidRequestError": "Произошла ошибка при запуске торговли.",
|
"InvalidRequestError": "Произошла ошибка при запуске торговли.",
|
||||||
"Order does not meet minimum order value": "Сумма ставки меньше допустимого для запуска торговли. "
|
"Order does not meet minimum order value": "Сумма ставки меньше допустимого для запуска торговли. "
|
||||||
@@ -106,6 +107,9 @@ async def start_trading(callback_query: CallbackQuery, state: FSMContext) -> Non
|
|||||||
"Qty invalid": "Некорректное значение ставки для данного инструмента",
|
"Qty invalid": "Некорректное значение ставки для данного инструмента",
|
||||||
"The number of contracts exceeds maximum limit allowed": "️️Превышен максимальный лимит ставки",
|
"The number of contracts exceeds maximum limit allowed": "️️Превышен максимальный лимит ставки",
|
||||||
"The number of contracts exceeds minimum limit allowed": "️️Лимит ставки меньше минимально допустимого",
|
"The number of contracts exceeds minimum limit allowed": "️️Лимит ставки меньше минимально допустимого",
|
||||||
|
"Order placement failed as your position may exceed the max":
|
||||||
|
"Не удалось разместить ордер, так как ваша позиция может превышать максимальный лимит."
|
||||||
|
"Пожалуйста, уменьшите кредитное плечо, чтобы увеличить максимальное значение"
|
||||||
}
|
}
|
||||||
|
|
||||||
if res == "OK":
|
if res == "OK":
|
||||||
|
|||||||
Reference in New Issue
Block a user