<?php

/**
 * FixAccountTypes.php
 * Copyright (c) 2020 james@firefly-iii.org
 *
 * This file is part of Firefly III (https://github.com/firefly-iii).
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as
 * published by the Free Software Foundation, either version 3 of the
 * License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <https://www.gnu.org/licenses/>.
 */

declare(strict_types=1);

namespace FireflyIII\Console\Commands\Correction;

use FireflyIII\Console\Commands\ShowsFriendlyMessages;
use FireflyIII\Enums\AccountTypeEnum;
use FireflyIII\Enums\TransactionTypeEnum;
use FireflyIII\Exceptions\FireflyException;
use FireflyIII\Factory\AccountFactory;
use FireflyIII\Models\Account;
use FireflyIII\Models\Transaction;
use FireflyIII\Models\TransactionJournal;
use FireflyIII\Models\TransactionType;
use FireflyIII\Repositories\Account\AccountRepositoryInterface;
use Illuminate\Console\Command;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Database\Query\JoinClause;
use Illuminate\Support\Facades\Log;

class CorrectsAccountTypes extends Command
{
    use ShowsFriendlyMessages;

    protected $description = 'Make sure all journals have the correct from/to account types.';
    protected $signature   = 'correction:account-types';
    private int            $count;
    private array          $expected;
    private AccountFactory $factory;
    private AccountRepositoryInterface $repository;

    /**
     * Execute the console command.
     *
     * @throws FireflyException
     */
    public function handle(): int
    {
        $this->stupidLaravel();
        $this->factory  = app(AccountFactory::class);
        $this->expected = config('firefly.source_dests');
        $expected       = config('firefly.source_dests');

        $query          = TransactionJournal::leftJoin('transaction_types', 'transaction_journals.transaction_type_id', '=', 'transaction_types.id')
            ->leftJoin(
                'transactions as source',
                static function (JoinClause $join): void {
                    $join->on('transaction_journals.id', '=', 'source.transaction_journal_id')->where('source.amount', '<', 0);
                }
            )
            ->leftJoin(
                'transactions as destination',
                static function (JoinClause $join): void {
                    $join->on('transaction_journals.id', '=', 'destination.transaction_journal_id')->where('destination.amount', '>', 0);
                }
            )
            ->leftJoin('accounts as source_account', 'source.account_id', '=', 'source_account.id')
            ->leftJoin('accounts as destination_account', 'destination.account_id', '=', 'destination_account.id')
            ->leftJoin('account_types as source_account_type', 'source_account.account_type_id', '=', 'source_account_type.id')
            ->leftJoin('account_types as destination_account_type', 'destination_account.account_type_id', '=', 'destination_account_type.id')
        ;

        // list all valid combinations, those are allowed. So we select those which are broken.
        $query->where(static function (Builder $q) use ($expected): void {
            foreach ($expected as $transactionType => $info) {
                foreach ($info as $source => $destinations) {
                    foreach ($destinations as $destination) {
                        $q->whereNot(static function (Builder $q1) use ($transactionType, $source, $destination): void {
                            $q1->where('transaction_types.type', $transactionType);
                            $q1->where('source_account_type.type', $source);
                            $q1->where('destination_account_type.type', $destination);
                        });
                    }
                }
            }
        });

        $resultSet      = $query->get(
            [
                'transaction_journals.id',
                // 'transaction_type_id as type_id',
                'transaction_types.type as journal_type',
                // 'source.id as source_transaction_id',
                // 'source_account.id as source_account_id',
                // 'source_account_type.id as source_account_type_id',
                'source_account_type.type as source_account_type',
                // 'destination.id as destination_transaction_id',
                // 'destination_account.id as destination_account_id',
                // 'destination_account_type.id as destination_account_type_id',
                'destination_account_type.type as destination_account_type',
            ]
        );
        if ($resultSet->count() > 0) {
            $this->friendlyLine(sprintf('Found %d journals that need to be fixed.', $resultSet->count()));
            foreach ($resultSet as $entry) {
                Log::debug(sprintf('Now fixing journal #%d', $entry->id));

                /** @var null|TransactionJournal $journal */
                $journal = TransactionJournal::find($entry->id);
                if (null !== $journal) {
                    $this->inspectJournal($journal);
                }
            }
        }
        if (0 !== $this->count) {
            Log::debug(sprintf('%d journals had to be fixed.', $this->count));
            $this->friendlyInfo(sprintf('Acted on %d transaction(s)', $this->count));
        }

        return 0;
    }

    private function stupidLaravel(): void
    {
        $this->count = 0;
    }

    private function inspectJournal(TransactionJournal $journal): void
    {
        Log::debug(sprintf('Now inspecting journal #%d', $journal->id));
        $transactions      = $journal->transactions()->count();
        if (2 !== $transactions) {
            Log::debug(sprintf('Journal has %d transactions, so can\'t fix.', $transactions));
            $this->friendlyError(sprintf('Cannot inspect transaction journal #%d because it has %d transaction(s) instead of 2.', $journal->id, $transactions));

            return;
        }
        $type              = $journal->transactionType->type;
        $sourceTransaction = $this->getSourceTransaction($journal);
        $destTransaction   = $this->getDestinationTransaction($journal);
        $sourceAccount     = $sourceTransaction->account;
        $sourceAccountType = $sourceAccount->accountType->type;
        $destAccount       = $destTransaction->account;
        $destAccountType   = $destAccount->accountType->type;

        if (!array_key_exists($type, $this->expected)) {
            Log::info(sprintf('No source/destination info for transaction type %s.', $type));
            $this->friendlyError(sprintf('No source/destination info for transaction type %s.', $type));

            return;
        }
        if (!array_key_exists($sourceAccountType, $this->expected[$type])) {
            Log::debug(sprintf('[a] Going to fix journal #%d', $journal->id));
            $this->fixJournal($journal, $type, $sourceTransaction, $destTransaction);

            return;
        }
        $expectedTypes     = $this->expected[$type][$sourceAccountType];
        if (!in_array($destAccountType, $expectedTypes, true)) {
            Log::debug(sprintf('[b] Going to fix journal #%d', $journal->id));
            $this->fixJournal($journal, $type, $sourceTransaction, $destTransaction);
        }
    }

    private function getSourceTransaction(TransactionJournal $journal): Transaction
    {
        return $journal->transactions->firstWhere('amount', '<', 0);
    }

    private function getDestinationTransaction(TransactionJournal $journal): Transaction
    {
        return $journal->transactions->firstWhere('amount', '>', 0);
    }

    private function fixJournal(TransactionJournal $journal, string $transactionType, Transaction $source, Transaction $dest): void
    {
        Log::debug(sprintf('Going to fix journal #%d', $journal->id));
        $this->repository       = app(AccountRepositoryInterface::class);
        $this->repository->setUser($journal->user);
        ++$this->count;
        // variables:
        $sourceType             = $source->account->accountType->type;
        $destinationType        = $dest->account->accountType->type;
        $combination            = sprintf('%s%s%s', $transactionType, $source->account->accountType->type, $dest->account->accountType->type);
        Log::debug(sprintf('Combination is "%s"', $combination));

        if ($this->shouldBeTransfer($transactionType, $sourceType, $destinationType)) {
            $this->makeTransfer($journal);

            return;
        }
        if ($this->shouldBeDeposit($transactionType, $sourceType, $destinationType)) {
            $this->makeDeposit($journal);

            return;
        }
        if ($this->shouldGoToExpenseAccount($transactionType, $sourceType, $destinationType)) {
            $this->makeExpenseDestination($journal, $dest);

            return;
        }
        if ($this->shouldComeFromRevenueAccount($transactionType, $sourceType, $destinationType)) {
            $this->makeRevenueSource($journal, $source);

            return;
        }

        // transaction has no valid source.
        $validSources           = array_keys($this->expected[$transactionType]);
        $canCreateSource        = $this->canCreateSource($validSources);
        $hasValidSource         = $this->hasValidAccountType($validSources, $sourceType);
        if (!$hasValidSource && $canCreateSource) {
            $this->giveNewRevenue($journal, $source);

            return;
        }
        if (!$canCreateSource && !$hasValidSource) {
            Log::debug('This transaction type has no source we can create. Just give error.');
            $message = sprintf('The source account of %s #%d cannot be of type "%s". Firefly III cannot fix this. You may have to remove the transaction yourself.', $transactionType, $journal->id, $source->account->accountType->type);
            $this->friendlyError($message);
            Log::debug($message);

            return;
        }

        /** @var array $validDestinations */
        $validDestinations      = $this->expected[$transactionType][$sourceType] ?? [];
        $canCreateDestination   = $this->canCreateDestination($validDestinations);
        $hasValidDestination    = $this->hasValidAccountType($validDestinations, $destinationType);
        $alternativeDestination = $this->repository->findByName($dest->account->name, $validDestinations);
        if (!$hasValidDestination && $canCreateDestination) {
            $this->giveNewExpense($journal, $dest);

            return;
        }
        if (!$canCreateDestination && !$hasValidDestination && null === $alternativeDestination) {
            Log::debug('This transaction type has no destination we can create. Just give error.');
            $message = sprintf('The destination account of %s #%d cannot be of type "%s". Firefly III cannot fix this. You may have to remove the transaction yourself.', $transactionType, $journal->id, $dest->account->accountType->type);
            $this->friendlyError($message);
            Log::debug($message);
        }
        if (!$canCreateDestination && !$hasValidDestination && null !== $alternativeDestination) {
            Log::debug('This transaction type has no destination we can create, but found alternative with the same name.');
            $message = sprintf('The destination account of %s #%d cannot be of type "%s". Firefly III found an alternative account. Please make sure this transaction is correct.', $transactionType, $journal->transaction_group_id, $dest->account->accountType->type);
            $this->friendlyInfo($message);
            Log::debug($message);
            $this->giveNewDestinationAccount($journal, $alternativeDestination);
        }
    }

    private function shouldBeTransfer(string $transactionType, string $sourceType, string $destinationType): bool
    {
        return TransactionTypeEnum::TRANSFER->value === $transactionType && AccountTypeEnum::ASSET->value === $sourceType && $this->isLiability($destinationType);
    }

    private function isLiability(string $destinationType): bool
    {
        return AccountTypeEnum::LOAN->value === $destinationType || AccountTypeEnum::DEBT->value === $destinationType || AccountTypeEnum::MORTGAGE->value === $destinationType;
    }

    private function makeTransfer(TransactionJournal $journal): void
    {
        // from an asset to a liability should be a withdrawal:
        $withdrawal = TransactionType::whereType(TransactionTypeEnum::WITHDRAWAL->value)->first();
        $journal->transactionType()->associate($withdrawal);
        $journal->save();
        $message    = sprintf('Converted transaction #%d from a transfer to a withdrawal.', $journal->id);
        $this->friendlyInfo($message);
        Log::debug($message);
        // check it again:
        $this->inspectJournal($journal);
    }

    private function shouldBeDeposit(string $transactionType, string $sourceType, string $destinationType): bool
    {
        return TransactionTypeEnum::TRANSFER->value === $transactionType && $this->isLiability($sourceType) && AccountTypeEnum::ASSET->value === $destinationType;
    }

    private function makeDeposit(TransactionJournal $journal): void
    {
        // from a liability to an asset should be a deposit.
        $deposit = TransactionType::whereType(TransactionTypeEnum::DEPOSIT->value)->first();
        $journal->transactionType()->associate($deposit);
        $journal->save();
        $message = sprintf('Converted transaction #%d from a transfer to a deposit.', $journal->id);
        $this->friendlyInfo($message);
        Log::debug($message);
        // check it again:
        $this->inspectJournal($journal);
    }

    private function shouldGoToExpenseAccount(string $transactionType, string $sourceType, string $destinationType): bool
    {
        return TransactionTypeEnum::WITHDRAWAL->value === $transactionType && AccountTypeEnum::ASSET->value === $sourceType && AccountTypeEnum::REVENUE->value === $destinationType;
    }

    private function makeExpenseDestination(TransactionJournal $journal, Transaction $destination): void
    {
        // withdrawals with a revenue account as destination instead of an expense account.
        $this->factory->setUser($journal->user);
        $oldDest = $destination->account;
        $result  = $this->factory->findOrCreate($destination->account->name, AccountTypeEnum::EXPENSE->value);
        $destination->account()->associate($result);
        $destination->save();
        $message = sprintf(
            'Transaction journal #%d, destination account changed from #%d ("%s") to #%d ("%s").',
            $journal->id,
            $oldDest->id,
            $oldDest->name,
            $result->id,
            $result->name
        );
        $this->friendlyWarning($message);
        Log::debug($message);
        $this->inspectJournal($journal);
    }

    private function shouldComeFromRevenueAccount(string $transactionType, string $sourceType, string $destinationType): bool
    {
        return TransactionTypeEnum::DEPOSIT->value === $transactionType && AccountTypeEnum::EXPENSE->value === $sourceType && AccountTypeEnum::ASSET->value === $destinationType;
    }

    private function makeRevenueSource(TransactionJournal $journal, Transaction $source): void
    {
        // deposits with an expense account as source instead of a revenue account.
        // find revenue account.
        $this->factory->setUser($journal->user);
        $result    = $this->factory->findOrCreate($source->account->name, AccountTypeEnum::REVENUE->value);
        $oldSource = $source->account;
        $source->account()->associate($result);
        $source->save();
        $message   = sprintf(
            'Transaction journal #%d, source account changed from #%d ("%s") to #%d ("%s").',
            $journal->id,
            $oldSource->id,
            $oldSource->name,
            $result->id,
            $result->name
        );
        $this->friendlyWarning($message);
        Log::debug($message);
        $this->inspectJournal($journal);
    }

    /**
     * Can only create revenue accounts out of the blue.
     */
    private function canCreateSource(array $validSources): bool
    {
        return in_array(AccountTypeEnum::REVENUE->value, $validSources, true);
    }

    private function hasValidAccountType(array $validTypes, string $accountType): bool
    {
        return in_array($accountType, $validTypes, true);
    }

    private function giveNewRevenue(TransactionJournal $journal, Transaction $source): void
    {
        Log::debug(sprintf('An account of type "%s" could be a valid source.', AccountTypeEnum::REVENUE->value));
        $this->factory->setUser($journal->user);
        $name      = $source->account->name;
        $newSource = $this->factory->findOrCreate($name, AccountTypeEnum::REVENUE->value);
        $source->account()->associate($newSource);
        $source->save();
        $this->friendlyPositive(sprintf('Firefly III gave transaction #%d a new source %s: #%d ("%s").', $journal->transaction_group_id, AccountTypeEnum::REVENUE->value, $newSource->id, $newSource->name));
        Log::debug(sprintf('Associated account #%d with transaction #%d', $newSource->id, $source->id));
        $this->inspectJournal($journal);
    }

    private function canCreateDestination(array $validDestinations): bool
    {
        return in_array(AccountTypeEnum::EXPENSE->value, $validDestinations, true);
    }

    private function giveNewExpense(TransactionJournal $journal, Transaction $destination): void
    {
        Log::debug(sprintf('An account of type "%s" could be a valid destination.', AccountTypeEnum::EXPENSE->value));
        $this->factory->setUser($journal->user);
        $name           = $destination->account->name;
        $newDestination = $this->factory->findOrCreate($name, AccountTypeEnum::EXPENSE->value);
        $destination->account()->associate($newDestination);
        $destination->save();
        $this->friendlyPositive(sprintf('Firefly III gave transaction #%d a new destination %s: #%d ("%s").', $journal->transaction_group_id, AccountTypeEnum::EXPENSE->value, $newDestination->id, $newDestination->name));
        Log::debug(sprintf('Associated account #%d with transaction #%d', $newDestination->id, $destination->id));
        $this->inspectJournal($journal);
    }

    private function giveNewDestinationAccount(TransactionJournal $journal, Account $newDestination): void
    {
        $destTransaction             = $this->getDestinationTransaction($journal);
        $oldDest                     = $destTransaction->account;
        $destTransaction->account_id = $newDestination->id;
        $destTransaction->save();
        $message                     = sprintf(
            'Transaction journal #%d, destination account changed from #%d ("%s") to #%d ("%s").',
            $journal->id,
            $oldDest->id,
            $oldDest->name,
            $newDestination->id,
            $newDestination->name
        );
        $this->friendlyInfo($message);
        $journal->refresh();
        Log::debug($message);
    }
}
