Bavix\Wallet\Commands\RefreshBalance

Complexity

Total Complexity

5

Size/Duplication

Total Lines	72
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	multiUpdate()	0	20	1
A	singleUpdate()	0	4	1
A	handle()	0	10	3

<?php

namespace Bavix\Wallet\Commands;

use Bavix\Wallet\Models\Wallet;
use Bavix\Wallet\Services\DbService;
use Illuminate\Console\Command;
use Illuminate\Database\PostgresConnection;
use Illuminate\Database\Query\JoinClause;
use Illuminate\Database\SQLiteConnection;
use function config;

/**
 * Class RefreshBalance
 * @package Bavix\Wallet\Commands
 * @codeCoverageIgnore
 */
class RefreshBalance extends Command
{

    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'wallet:refresh';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Recalculates all wallets';

    /**
     * @return void
     * @throws
     */
    public function handle(): void
    {
        app(DbService::class)->transaction(function () {
            $connection = app(DbService::class)->connection();
            if ($connection instanceof SQLiteConnection || $connection instanceof PostgresConnection) {
                $wallet = config('wallet.wallet.table', 'wallets');
                $connection->table($wallet)->update(['balance' => 0]);
                $this->singleUpdate();
            } else {
                $this->multiUpdate();
            }
        });
    }

    /**
     * SQLite
     *
     * @return void
     */
    protected function singleUpdate(): void
    {
        Wallet::query()->each(static function (Wallet $wallet) {
            $wallet->refreshBalance();
        });
    }

    /**
     * MySQL/PgSQL
     *
     * @return void
     */
    protected function multiUpdate(): void
    {
        $wallet = config('wallet.wallet.table', 'wallets');
        $trans = config('wallet.transaction.table', 'transactions');
        $availableBalance = app(DbService::class)
            ->connection()
            ->table($trans)
            ->select('wallet_id', app(DbService::class)->raw('sum(amount) balance'))
            ->where('confirmed', true)
            ->groupBy('wallet_id');

        $joinClause = static function (JoinClause $join) use ($wallet) {
            $join->on("$wallet.id", '=', 'b.wallet_id');
        };

        app(DbService::class)
            ->connection()
            ->table($wallet)
            ->joinSub($availableBalance, 'b', $joinClause, null, null, 'left')
            ->update(["$wallet.balance" => app(DbService::class)->raw('ifnull(b.balance, 0)')]);
    }

}