Реализация множественных тейк-профитов в торговом боте

import ccxt

exchange = ccxt.binance({
 'apiKey': 'YOUR_API_KEY',
 'secret': 'YOUR_SECRET',
 'enableRateLimit': True,
})

# Пример расчета цен тейк-профитов
tp1_price = entry_price * 1.05 # +5% от входа
tp2_price = entry_price * 1.10 # +10% от входа
tp3_price = entry_price * 1.15 # +15% от входа

# Расчет объемов для частичного выхода
total_amount = 0.1 # 0.1 BTC
tp1_amount = total_amount * 0.3 # 30% позиции
tp2_amount = total_amount * 0.4 # 40% позиции
tp3_amount = total_amount * 0.3 # 30% позиции

take_profit_orders = [
 {
 'symbol': 'BTC/USDT',
 'type': 'limit',
 'side': 'sell',
 'amount': tp1_amount,
 'price': tp1_price,
 'params': {'timeInForce': 'GTC'}
 },
 {
 'symbol': 'BTC/USDT',
 'type': 'limit',
 'side': 'sell',
 'amount': tp2_amount,
 'price': tp2_price,
 'params': {'timeInForce': 'GTC'}
 },
 {
 'symbol': 'BTC/USDT',
 'type': 'limit',
 'side': 'sell',
 'amount': tp3_amount,
 'price': tp3_price,
 'params': {'timeInForce': 'GTC'}
 }
]

import ccxt
import time

def execute_multiple_take_profit(symbol, amount, entry_price, tp_ratios=[1.05, 1.10, 1.15], tp_percentages=[0.3, 0.4, 0.3]):
 """
 Открывает позицию и устанавливает несколько тейк-профитов
 
 Args:
 symbol: Торговая пара (например, 'BTC/USDT')
 amount: Объем позиции
 entry_price: Цена входа в позицию
 tp_ratios: Список соотношений для тейк-профитов (по умолчанию [1.05, 1.10, 1.15])
 tp_percentages: Список процентных долей для каждого тейк-профита (должны суммироваться до 1)
 
 Returns:
 Словарь с результатами выполнения
 """
 try:
 # Инициализация биржи
 exchange = ccxt.binance({
 'apiKey': 'YOUR_API_KEY',
 'secret': 'YOUR_SECRET',
 'enableRateLimit': True,
 })
 
 # Проверка, что проценты тейк-профитов суммируются до 1
 if sum(tp_percentages) != 1.0:
 raise ValueError("Сумма процентов тейк-профитов должна быть равна 1.0")
 
 # Открытие позиции (покупка)
 print(f"Открываем позицию {amount} {symbol.split('/')[0]} по цене {entry_price}")
 buy_order = exchange.create_order(
 symbol=symbol,
 type='market',
 side='buy',
 amount=amount
 )
 
 # Расчет цен и объемов для тейк-профитов
 tp_prices = [entry_price * ratio for ratio in tp_ratios]
 tp_amounts = [amount * percentage for percentage in tp_percentages]
 
 # Формирование списка тейк-профитов
 take_profit_orders = []
 for i, (price, amount) in enumerate(zip(tp_prices, tp_amounts)):
 tp_order = {
 'symbol': symbol,
 'type': 'limit',
 'side': 'sell',
 'amount': exchange.amount_to_precision(symbol, amount),
 'price': exchange.price_to_precision(symbol, price),
 'params': {
 'timeInForce': 'GTC',
 # Для некоторых бирж может потребоваться дополнительная настройка
 # 'stopPrice': price, # для некоторых бирж
 }
 }
 take_profit_orders.append(tp_order)
 
 # Установка тейк-профитов
 print("Устанавливаем тейк-профиты:")
 for i, tp in enumerate(take_profit_orders):
 print(f"TP{i+1}: Цена={tp['price']}, Объем={tp['amount']}")
 
 # Пакетная установка ордеров (если биржа поддерживает)
 if hasattr(exchange, 'create_orders'):
 tp_results = exchange.create_orders(take_profit_orders)
 else:
 # Поочередная установка для бирж без поддержки пакетных ордеров
 tp_results = []
 for tp in take_profit_orders:
 tp_order = exchange.create_order(**tp)
 tp_results.append(tp_order)
 
 return {
 'success': True,
 'buy_order': buy_order,
 'take_profit_orders': tp_results,
 'tp_prices': tp_prices,
 'tp_amounts': tp_amounts
 }
 
 except Exception as e:
 print(f"Ошибка при выполнении: {str(e)}")
 return {
 'success': False,
 'error': str(e)
 }

# Пример использования
if __name__ == "__main__":
 result = execute_multiple_take_profit(
 symbol='BTC/USDT',
 amount=0.1,
 entry_price=50000,
 tp_ratios=[1.05, 1.10, 1.15],
 tp_percentages=[0.3, 0.4, 0.3]
 )
 
 if result['success']:
 print("Позиция успешно открыта с тейк-профитами")
 else:
 print("Ошибка выполнения:", result['error'])

# Пример адаптации для разных бирж
def create_take_profit_orders(exchange, symbol, tp_configs):
 """Создает тейк-профиты с учетом особенностей конкретной биржи"""
 orders = []
 
 for tp in tp_configs:
 order = {
 'symbol': symbol,
 'type': 'limit',
 'side': 'sell',
 'amount': tp['amount'],
 'price': tp['price'],
 }
 
 # Особенности для Binance
 if exchange.id == 'binance':
 order['reduceOnly'] = True
 order['params'] = {'timeInForce': 'GTC'}
 
 # Особенности для Bybit
 elif exchange.id == 'bybit':
 order['params'] = {'takeProfit': tp['price']}
 
 orders.append(order)
 
 return orders

def calculate_tp_percentages(strategy='conservative'):
 """Рассчитывает процентные доли тейк-профитов в зависимости от стратегии"""
 if strategy == 'conservative':
 return [0.4, 0.3, 0.3] # Больше маленькой прибыли
 elif strategy == 'moderate':
 return [0.3, 0.4, 0.3] # Сбалансированный подход
 elif strategy == 'aggressive':
 return [0.2, 0.3, 0.5] # Больший акцент на максимальную прибыль
 else:
 return [0.3, 0.4, 0.3] # По умолчанию умеренный

def dynamic_tp_adjustment(exchange, symbol, current_price, tp_prices):
 """Динамическая корректировка тейк-профитов в зависимости от движения рынка"""
 # Если цена выросла на 5% от входа, сдвигаем тейк-профиты вверх
 if current_price > tp_prices[0] * 1.05:
 shift_ratio = current_price / tp_prices[0]
 return [price * shift_ratio for price in tp_prices]
 return tp_prices

def monitor_take_profit_orders(exchange, symbol, tp_orders):
 """Мониторинг статуса тейк-профитов"""
 active_orders = []
 executed_orders = []
 
 for order_id in tp_orders:
 order = exchange.fetch_order(order_id, symbol)
 if order['status'] == 'open':
 active_orders.append(order)
 else:
 executed_orders.append(order)
 
 return active_orders, executed_orders

def backtest_take_profit_strategy(historical_data, tp_ratios, tp_percentages):
 """Бэктестирование стратегии множественных тейк-профитов"""
 results = []
 
 for i in range(len(historical_data) - 1):
 entry_price = historical_data[i]['close']
 high_prices = [candle['high'] for candle in historical_data[i+1:i+100]]
 
 # Проверяем достижение цен тейк-профитов
 tp_reached = []
 for j, ratio in enumerate(tp_ratios):
 tp_price = entry_price * ratio
 if max(high_prices) >= tp_price:
 tp_reached.append(j)
 
 # Расчет прибыли
 profit = 0
 for j, percentage in enumerate(tp_percentages):
 if j in tp_reached:
 profit += percentage * (tp_ratios[j] - 1)
 
 results.append(profit)
 
 return results

def optimize_tp_parameters(historical_data, tp_ratios_range, tp_percentages_options):
 """Оптимизация параметров тейк-профитов"""
 best_profit = -float('inf')
 best_params = None
 
 for ratios in tp_ratios_range:
 for percentages in tp_percentages_options:
 results = backtest_take_profit_strategy(historical_data, ratios, percentages)
 avg_profit = sum(results) / len(results)
 
 if avg_profit > best_profit:
 best_profit = avg_profit
 best_params = {
 'tp_ratios': ratios,
 'tp_percentages': percentages
 }
 
 return best_params

def test_on_testnet(exchange, symbol, amount, tp_ratios, tp_percentages):
 """Тестирование стратегии на тестовом сетке биржи"""
 # Переключение на тестовый сеток
 exchange.set_sandbox_mode(True)
 
 try:
 # Используем тестовые средства
 test_balance = exchange.fetch_balance()
 print(f"Тестовый баланс: {test_balance}")
 
 # Тестовое открытие позиции и установка тейк-профитов
 result = execute_multiple_take_profit(
 symbol=symbol,
 amount=amount,
 entry_price=50000, # тестовая цена
 tp_ratios=tp_ratios,
 tp_percentages=tp_percentages
 )
 
 return result
 
 finally:
 # Возврат к реальному режиму
 exchange.set_sandbox_mode(False)

def monitor_strategy_performance(exchange, symbol, start_time):
 """Мониторинг производительности стратегии"""
 current_time = time.time()
 time_elapsed = current_time - start_time
 
 # Получение истории сделок
 trades = exchange.fetch_my_trades(symbol, since=start_time * 1000)
 
 # Расчет статистики
 total_trades = len(trades)
 profitable_trades = sum(1 for trade in trades if float(trade['info']['realizedPnl']) > 0)
 win_rate = profitable_trades / total_trades if total_trades > 0 else 0
 
 # Расчет общей прибыли
 total_profit = sum(float(trade['info']['realizedPnl']) for trade in trades)
 
 return {
 'time_elapsed': time_elapsed,
 'total_trades': total_trades,
 'profitable_trades': profitable_trades,
 'win_rate': win_rate,
 'total_profit': total_profit
 }