From ba7d823a911b70940516f49e2d5f64f3c7e2e576 Mon Sep 17 00:00:00 2001 From: Kavinkumar <33546454+mkavinkumar1@users.noreply.github.com> Date: Sun, 27 Feb 2022 12:28:38 +0530 Subject: [PATCH] rpc fix --- freqtrade/freqtradebot.py | 5 +++- freqtrade/persistence/models.py | 42 ++++++++++++++++++--------------- 2 files changed, 27 insertions(+), 20 deletions(-) diff --git a/freqtrade/freqtradebot.py b/freqtrade/freqtradebot.py index 44ca3f3d6..83cf6f113 100644 --- a/freqtrade/freqtradebot.py +++ b/freqtrade/freqtradebot.py @@ -1259,7 +1259,10 @@ class FreqtradeBot(LoggingMixin): amount = order.get('filled') or order.get('amount') or 0 profit_rate = order.get('average') or order.get('price') or 0 profit_ratio = trade.close_profit - profit = trade.close_profit_abs + profit = (trade.close_profit_abs if fill + else trade.process_sell_sub_trade(order, isclosed=False)) + logger.info(order) + open_rate = trade.get_open_rate(profit, profit_rate, amount) else: profit_rate = trade.close_rate if trade.close_rate else trade.close_rate_requested diff --git a/freqtrade/persistence/models.py b/freqtrade/persistence/models.py index 47b0cddb5..18cba7a68 100644 --- a/freqtrade/persistence/models.py +++ b/freqtrade/persistence/models.py @@ -491,7 +491,7 @@ class LocalTrade(): raise ValueError(f'Unknown order type: {order_type}') Trade.commit() - def process_sell_sub_trade(self, order: Dict) -> float: + def process_sell_sub_trade(self, order: Dict, is_closed: bool = True) -> float: orders = (self.select_filled_orders('buy')) if len(orders)<1: @@ -503,10 +503,11 @@ class LocalTrade(): sell_amount = order.get('filled') or order.get('amount') sell_rate = order.get('average') or order.get('price') sell_stake_amount = sell_rate * sell_amount * (1 - self.fee_close) - if sell_amount == self.amount: - self.close(sell_rate) - Trade.commit() - return + if is_closed: + if sell_amount == self.amount: + self.close(sell_rate) + Trade.commit() + return profit = 0.0 idx = -1 while sell_amount: @@ -515,25 +516,28 @@ class LocalTrade(): buy_rate = b_order.average or b_order.price if sell_amount < buy_amount: amount = sell_amount - b_order.filled -= amount + if is_closed: + b_order.filled -= amount else: - b_order.is_fully_realized = True - b_order.order_update_date = datetime.now(timezone.utc) - self.update_order(b_order) + if is_closed: + b_order.is_fully_realized = True + b_order.order_update_date = datetime.now(timezone.utc) + self.update_order(b_order) idx -= 1 amount = buy_amount sell_amount -= amount profit += self.calc_profit2(buy_rate, sell_rate, amount) - b_order2 = orders[idx] - amount2 = b_order2.filled or b_order2.amount - b_order2.average = (b_order2.average * amount2 - profit) / amount2 - b_order2.order_update_date = datetime.now(timezone.utc) - self.update_order(b_order2) - Order.query.session.commit() - self.recalc_trade_from_orders() - self.close_profit_abs = profit - self.close_profit = sell_stake_amount / (sell_stake_amount - profit) -1 - Trade.commit() + if is_closed: + b_order2 = orders[idx] + amount2 = b_order2.filled or b_order2.amount + b_order2.average = (b_order2.average * amount2 - profit) / amount2 + b_order2.order_update_date = datetime.now(timezone.utc) + self.update_order(b_order2) + Order.query.session.commit() + self.recalc_trade_from_orders() + self.close_profit_abs = profit + self.close_profit = sell_stake_amount / (sell_stake_amount - profit) -1 + Trade.commit() return profit def calc_profit2(self, open_rate: float, close_rate: float,