invoiceninja/app/Services/Payment/RefundPayment.php

<?php
/**
 * Invoice Ninja (https://invoiceninja.com).
 *
 * @link https://github.com/invoiceninja/invoiceninja source repository
 *
 * @copyright Copyright (c) 2020. Invoice Ninja LLC (https://invoiceninja.com)
 *
 * @license https://opensource.org/licenses/AAL
 */

namespace App\Services\Payment;

use App\Exceptions\PaymentRefundFailed;
use App\Factory\CreditFactory;
use App\Factory\InvoiceItemFactory;
use App\Models\Activity;
use App\Models\CompanyGateway;
use App\Models\Credit;
use App\Models\Invoice;
use App\Models\Payment;
use App\Repositories\ActivityRepository;
use App\Utils\Ninja;

class RefundPayment
{
    public $payment;

    public $refund_data;

    private $credit_note;

    private $total_refund;

    private $gateway_refund_status;

    private $activity_repository;

    public function __construct($payment, $refund_data)
    {
        $this->payment = $payment;

        $this->refund_data = $refund_data;

        $this->total_refund = 0;

        $this->gateway_refund_status = false;

        $this->activity_repository = new ActivityRepository();
    }

    public function run()
    {
        return $this->calculateTotalRefund() //sets amount for the refund (needed if we are refunding multiple invoices in one payment)
            ->setStatus() //sets status of payment
            //->reversePayment()
            //->buildCreditNote() //generate the credit note
            //->buildCreditLineItems() //generate the credit note items
            ->updateCreditables() //return the credits first
            ->updatePaymentables() //update the paymentable items
            ->adjustInvoices()
            ->processGatewayRefund() //process the gateway refund if needed
            ->save();
    }

    /**
     * Process the refund through the gateway.
     *
     * @return $this
     */
    private function processGatewayRefund()
    {
        if ($this->refund_data['gateway_refund'] !== false && $this->total_refund > 0) {
            if ($this->payment->company_gateway) {
                $response = $gateway->driver($this->payment->client)->refund($this->payment, $this->total_refund);

                if ($response['success']) {
                    throw new PaymentRefundFailed();
                }

                $this->payment->refunded += $this->total_refund;

                $this
                    ->createActivity($gateway)
                    ->updateCreditNoteBalance();
            }
        } else {
            $this->payment->refunded += $this->total_refund;
        }

        return $this;
    }

    /**
     * Create the payment activity.
     *
     * @param  json $notes gateway_transaction
     * @return $this
     */
    private function createActivity($notes)
    {
        $fields = new \stdClass;
        $activity_repo = new ActivityRepository();

        $fields->payment_id = $this->payment->id;
        $fields->user_id = $this->payment->user_id;
        $fields->company_id = $this->payment->company_id;
        $fields->activity_type_id = Activity::REFUNDED_PAYMENT;
        $fields->credit_id = $this->credit_note->id;
        $fields->notes = json_encode($notes);

        if (isset($this->refund_data['invoices'])) {
            foreach ($this->refund_data['invoices'] as $invoice) {
                $fields->invoice_id = $invoice['invoice_id'];
                $activity_repo->save($fields, $this->payment, Ninja::eventVars());
            }
        } else {
            $activity_repo->save($fields, $this->payment, Ninja::eventVars());
        }

        return $this;
    }

    /**
     * Determine the amount of refund.
     *
     * @return $this
     */
    private function calculateTotalRefund()
    {
        if (array_key_exists('invoices', $this->refund_data) && count($this->refund_data['invoices']) > 0) {
            $this->total_refund = collect($this->refund_data['invoices'])->sum('amount');
        } else {
            $this->total_refund = $this->refund_data['amount'];
        }

        return $this;
    }

    /**
     * Set the payment status.
     */
    private function setStatus()
    {
        if ($this->refund_data['amount'] == $this->payment->amount) {
            $this->payment->status_id = Payment::STATUS_REFUNDED;
        } else {
            $this->payment->status_id = Payment::STATUS_PARTIALLY_REFUNDED;
        }

        return $this;
    }

    /**
     * Update the paymentable records.
     *
     * @return $this
     */
    private function updatePaymentables()
    {
        if (isset($this->refund_data['invoices']) && count($this->refund_data['invoices']) > 0) {
            $this->payment->invoices->each(function ($paymentable_invoice) {
                collect($this->refund_data['invoices'])->each(function ($refunded_invoice) use ($paymentable_invoice) {
                    if ($refunded_invoice['invoice_id'] == $paymentable_invoice->id) {
                        $paymentable_invoice->pivot->refunded += $refunded_invoice['amount'];
                        $paymentable_invoice->pivot->save();
                    }
                });
            });
        }

        return $this;
    }

    /**
     * If credits have been bundled in this payment, we
     * need to reverse these.
     *
     * @return $this
     */
    private function updateCreditables()
    {
        if ($this->payment->credits()->exists()) {
            //Adjust credits first!!!
            foreach ($this->payment->credits as $paymentable_credit) {
                $available_credit = $paymentable_credit->pivot->amount - $paymentable_credit->pivot->refunded;

                if ($available_credit > $this->total_refund) {
                    $paymentable_credit->pivot->refunded += $this->total_refund;
                    $paymentable_credit->pivot->save();
                    $paymentable_credit->balance += $this->total_refund;
                    $paymentable_credit->service()->setStatus(Credit::STATUS_SENT)->save();
                    //$paymentable_credit->save();

                    $this->total_refund = 0;
                } else {
                    $paymentable_credit->pivot->refunded += $available_credit;
                    $paymentable_credit->pivot->save();

                    $paymentable_credit->balance += $available_credit;
                    $paymentable_credit->service()->setStatus(Credit::STATUS_SENT)->save();
//                    $paymentable_credit->save();

                    $this->total_refund -= $available_credit;
                }

                if ($this->total_refund == 0) {
                    break;
                }
            }
        }

        return $this;
    }

    /**
     * Reverse the payments made on invoices.
     *
     * @return $this
     */
    private function adjustInvoices()
    {
        $adjustment_amount = 0;

        if (isset($this->refund_data['invoices']) && count($this->refund_data['invoices']) > 0) {
            foreach ($this->refund_data['invoices'] as $refunded_invoice) {
                $invoice = Invoice::find($refunded_invoice['invoice_id']);

                $invoice->service()->updateBalance($refunded_invoice['amount'])->save();
                $invoice->ledger()->updateInvoiceBalance($refunded_invoice['amount'], "Refund of payment # {$this->payment->number}")->save();

                if ($invoice->amount == $invoice->balance) {
                    $invoice->service()->setStatus(Invoice::STATUS_SENT);
                } else {
                    $invoice->service()->setStatus(Invoice::STATUS_PARTIAL);
                }

                $invoice->save();

                $client = $invoice->client;

                $adjustment_amount += $refunded_invoice['amount'];
                $client->balance += $refunded_invoice['amount'];
                $client->save();

                //todo adjust ledger balance here? or after and reference the credit and its total
            }

            // $ledger_string = "Refund for Invoice {$invoice->number} for amount " . $refunded_invoice['amount']; //todo

            // $this->credit_note->ledger()->updateCreditBalance($adjustment_amount, $ledger_string);

            $client = $this->payment->client->fresh();
            $client->service()->updatePaidToDate(-1 * $this->total_refund)->save();
        }

        return $this;
    }

    /**
     * Saves the payment.
     *
     * @return Payment $payment
     */
    private function save()
    {
        $this->payment->save();

        return $this->payment;
    }

    // public function updateCreditNoteBalance()
    // {
    //     $this->credit_note->balance -= $this->total_refund;
    //     $this->credit_note->status_id = Credit::STATUS_APPLIED;

    //     $this->credit_note->balance === 0
    //         ? $this->credit_note->status_id = Credit::STATUS_APPLIED
    //         : $this->credit_note->status_id = Credit::STATUS_PARTIAL;

    //     $this->credit_note->save();

    //     return $this;
    // }

    // private function buildCreditNote()
    // {
    //     $this->credit_note = CreditFactory::create($this->payment->company_id, $this->payment->user_id);
    //     $this->credit_note->assigned_user_id = isset($this->payment->assigned_user_id) ?: null;
    //     $this->credit_note->date = $this->refund_data['date'];
    //     $this->credit_note->status_id = Credit::STATUS_SENT;
    //     $this->credit_note->client_id = $this->payment->client->id;
    //     $this->credit_note->amount = $this->total_refund;
    //     $this->credit_note->balance = $this->total_refund;

    //     $this->credit_note->save();
    //     $this->credit_note->number = $this->payment->client->getNextCreditNumber($this->payment->client);
    //     $this->credit_note->save();

    //     return $this;
    // }

    // private function buildCreditLineItems()
    // {
    //     $ledger_string = '';

    //     if (isset($this->refund_data['invoices']) && count($this->refund_data['invoices']) > 0) {
    //         foreach ($this->refund_data['invoices'] as $invoice) {

    //             $inv = Invoice::find($invoice['invoice_id']);

    //             $credit_line_item = InvoiceItemFactory::create();
    //             $credit_line_item->quantity = 1;
    //             $credit_line_item->cost = $invoice['amount'];
    //             $credit_line_item->product_key = ctrans('texts.invoice');
    //             $credit_line_item->notes = ctrans('texts.refund_body', ['amount' => $invoice['amount'], 'invoice_number' => $inv->number]);
    //             $credit_line_item->line_total = $invoice['amount'];
    //             $credit_line_item->date = $this->refund_data['date'];

    //             $ledger_string .= $credit_line_item->notes . ' ';

    //             $line_items[] = $credit_line_item;
    //         }
    //     } else {

    //         $credit_line_item = InvoiceItemFactory::create();
    //         $credit_line_item->quantity = 1;
    //         $credit_line_item->cost = $this->refund_data['amount'];
    //         $credit_line_item->product_key = ctrans('texts.credit');
    //         $credit_line_item->notes = ctrans('texts.credit_created_by', ['transaction_reference' => $this->payment->number]);
    //         $credit_line_item->line_total = $this->refund_data['amount'];
    //         $credit_line_item->date = $this->refund_data['date'];

    //         $line_items = [];
    //         $line_items[] = $credit_line_item;
    //     }

    //     $this->credit_note->line_items = $line_items;
    //     $this->credit_note->save();

    //     return $this;
    // }
}