Fixed the budget calculation function
This commit is contained in:
@@ -46,7 +46,9 @@ class WebSocketBot:
|
|||||||
self.user_sockets.clear()
|
self.user_sockets.clear()
|
||||||
self.user_messages.clear()
|
self.user_messages.clear()
|
||||||
self.user_keys.clear()
|
self.user_keys.clear()
|
||||||
logger.info("Closed old websocket for user %s due to key change", tg_id)
|
logger.info(
|
||||||
|
"Closed old websocket for user %s due to key change", tg_id
|
||||||
|
)
|
||||||
|
|
||||||
success = await self.try_connect_user(api_key, api_secret, tg_id)
|
success = await self.try_connect_user(api_key, api_secret, tg_id)
|
||||||
if success:
|
if success:
|
||||||
|
@@ -158,7 +158,7 @@ async def get_liquidation_price(
|
|||||||
|
|
||||||
|
|
||||||
async def calculate_total_budget(
|
async def calculate_total_budget(
|
||||||
quantity, martingale_factor, max_steps, commission_fee_percent
|
quantity, martingale_factor, max_steps
|
||||||
) -> float:
|
) -> float:
|
||||||
"""
|
"""
|
||||||
Calculate the total budget for a series of trading steps.
|
Calculate the total budget for a series of trading steps.
|
||||||
@@ -167,7 +167,6 @@ async def calculate_total_budget(
|
|||||||
quantity (float): The initial quantity of the asset.
|
quantity (float): The initial quantity of the asset.
|
||||||
martingale_factor (float): The factor by which the quantity is multiplied for each step.
|
martingale_factor (float): The factor by which the quantity is multiplied for each step.
|
||||||
max_steps (int): The maximum number of trading steps.
|
max_steps (int): The maximum number of trading steps.
|
||||||
commission_fee_percent (float): The commission fee percentage.
|
|
||||||
|
|
||||||
Returns:
|
Returns:
|
||||||
float: The total budget for the series of trading steps.
|
float: The total budget for the series of trading steps.
|
||||||
@@ -175,12 +174,8 @@ async def calculate_total_budget(
|
|||||||
total = 0
|
total = 0
|
||||||
for step in range(max_steps):
|
for step in range(max_steps):
|
||||||
set_quantity = quantity * (martingale_factor**step)
|
set_quantity = quantity * (martingale_factor**step)
|
||||||
if commission_fee_percent == 0:
|
|
||||||
# Commission fee is not added to the position size
|
r_quantity = set_quantity
|
||||||
r_quantity = set_quantity
|
|
||||||
else:
|
|
||||||
# Commission fee is added to the position size
|
|
||||||
r_quantity = set_quantity * (1 + 2 * commission_fee_percent)
|
|
||||||
|
|
||||||
total += r_quantity
|
total += r_quantity
|
||||||
return total
|
return total
|
||||||
|
@@ -6,7 +6,6 @@ from aiogram.types import CallbackQuery
|
|||||||
|
|
||||||
import app.telegram.keyboards.inline as kbi
|
import app.telegram.keyboards.inline as kbi
|
||||||
import database.request as rq
|
import database.request as rq
|
||||||
from app.bybit import get_bybit_client
|
|
||||||
|
|
||||||
from app.helper_functions import calculate_total_budget, safe_float
|
from app.helper_functions import calculate_total_budget, safe_float
|
||||||
from logger_helper.logger_helper import LOGGING_CONFIG
|
from logger_helper.logger_helper import LOGGING_CONFIG
|
||||||
@@ -26,7 +25,6 @@ async def additional_settings(callback_query: CallbackQuery, state: FSMContext)
|
|||||||
try:
|
try:
|
||||||
await state.clear()
|
await state.clear()
|
||||||
tg_id = callback_query.from_user.id
|
tg_id = callback_query.from_user.id
|
||||||
symbol = await rq.get_user_symbol(tg_id=tg_id)
|
|
||||||
additional_data = await rq.get_user_additional_settings(tg_id=tg_id)
|
additional_data = await rq.get_user_additional_settings(tg_id=tg_id)
|
||||||
|
|
||||||
if not additional_data:
|
if not additional_data:
|
||||||
@@ -64,30 +62,15 @@ async def additional_settings(callback_query: CallbackQuery, state: FSMContext)
|
|||||||
max_bets = additional_data.max_bets_in_series
|
max_bets = additional_data.max_bets_in_series
|
||||||
quantity = f(additional_data.order_quantity)
|
quantity = f(additional_data.order_quantity)
|
||||||
trigger_price = f(additional_data.trigger_price) or 0
|
trigger_price = f(additional_data.trigger_price) or 0
|
||||||
risk_management_data = await rq.get_user_risk_management(tg_id=tg_id)
|
|
||||||
commission_fee = risk_management_data.commission_fee
|
|
||||||
client = await get_bybit_client(tg_id=tg_id)
|
|
||||||
fee_info = client.get_fee_rates(category="linear", symbol=symbol)
|
|
||||||
|
|
||||||
if commission_fee == "Yes_commission_fee":
|
|
||||||
commission_fee_percent = safe_float(
|
|
||||||
fee_info["result"]["list"][0]["takerFeeRate"]
|
|
||||||
)
|
|
||||||
|
|
||||||
else:
|
|
||||||
commission_fee_percent = 0.0
|
|
||||||
|
|
||||||
switch_side_mode = ""
|
switch_side_mode = ""
|
||||||
if trade_mode == "Switch":
|
if trade_mode == "Switch":
|
||||||
switch_side_mode = f"- Направление первой сделки: {switch_side}\n"
|
switch_side_mode = f"- Направление первой сделки: {switch_side}\n"
|
||||||
|
|
||||||
quantity_price = quantity * trigger_price
|
|
||||||
total_commission = quantity_price * commission_fee_percent
|
|
||||||
total_budget = await calculate_total_budget(
|
total_budget = await calculate_total_budget(
|
||||||
quantity=quantity,
|
quantity=quantity,
|
||||||
martingale_factor=martingale,
|
martingale_factor=martingale,
|
||||||
max_steps=max_bets,
|
max_steps=max_bets,
|
||||||
commission_fee_percent=total_commission,
|
|
||||||
)
|
)
|
||||||
text = (
|
text = (
|
||||||
f"Основные настройки:\n\n"
|
f"Основные настройки:\n\n"
|
||||||
@@ -99,7 +82,7 @@ async def additional_settings(callback_query: CallbackQuery, state: FSMContext)
|
|||||||
f"- Коэффициент мартингейла: {martingale:.2f}\n"
|
f"- Коэффициент мартингейла: {martingale:.2f}\n"
|
||||||
f"- Триггер цена: {trigger_price:.4f} USDT\n"
|
f"- Триггер цена: {trigger_price:.4f} USDT\n"
|
||||||
f"- Максимальное кол-во ставок в серии: {max_bets}\n\n"
|
f"- Максимальное кол-во ставок в серии: {max_bets}\n\n"
|
||||||
f"- Бюджет серии: {total_budget:.4f} USDT\n"
|
f"- Бюджет серии: {total_budget:.2f} USDT\n"
|
||||||
)
|
)
|
||||||
|
|
||||||
keyboard = kbi.get_additional_settings_keyboard(mode=trade_mode)
|
keyboard = kbi.get_additional_settings_keyboard(mode=trade_mode)
|
||||||
|
@@ -1,8 +1,10 @@
|
|||||||
from aiogram.types import KeyboardButton, ReplyKeyboardMarkup
|
from aiogram.types import KeyboardButton, ReplyKeyboardMarkup
|
||||||
|
|
||||||
profile = ReplyKeyboardMarkup(
|
profile = ReplyKeyboardMarkup(
|
||||||
keyboard=[[KeyboardButton(text="Панель Bybit"), KeyboardButton(text="Профиль")],
|
keyboard=[
|
||||||
[KeyboardButton(text="Подключить платформу Bybit")]],
|
[KeyboardButton(text="Панель Bybit"), KeyboardButton(text="Профиль")],
|
||||||
|
[KeyboardButton(text="Подключить платформу Bybit")],
|
||||||
|
],
|
||||||
resize_keyboard=True,
|
resize_keyboard=True,
|
||||||
one_time_keyboard=True,
|
one_time_keyboard=True,
|
||||||
input_field_placeholder="Выберите пункт меню...",
|
input_field_placeholder="Выберите пункт меню...",
|
||||||
|
Reference in New Issue
Block a user