add refresh balance

Author: Babichev Maxim

src/Commands/RefreshBalance.php

@@ -0,0 +1,52 @@
+<?php
+
+namespace Bavix\Commands;
+
+use Illuminate\Database\Query\JoinClause;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Console\Command;
+use function config;
+
+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
+     */
+    public function handle(): void
+    {
+        DB::transaction(function () {
+            $wallet = config('wallet.wallet.table');
+            $trans = config('wallet.transaction.table');
+
+            $availableBalance = DB::table($trans)
+                ->select('wallet_id', DB::raw('sum(amount) balance'))
+                ->where('confirmed', true)
+                ->groupBy('wallet_id');
+
+            $joinClause = function (JoinClause $join) use ($wallet) {
+                $join->on("$wallet.id", '=', 'b.wallet_id');
+            };
+
+            DB::table($wallet)->update(['balance' => 0]);
+            DB::table($wallet)
+                ->joinSub($availableBalance, 'b', $joinClause, null, null, 'left')
+                ->update(['balance' => DB::raw('b.balance')]);
+        });
+    }
+
+}

src/WalletServiceProvider.php

@@ -2,6 +2,7 @@
 
 namespace Bavix\Wallet;
 
+use Bavix\Commands\RefreshBalance;
 use Bavix\Wallet\Models\Transaction;
 use Bavix\Wallet\Models\Transfer;
 use Bavix\Wallet\Models\Wallet;
@@ -33,6 +34,8 @@ public function boot(): void
             return;
         }
 
+        $this->commands([RefreshBalance::class]);
+
         $this->loadMigrationsFrom([
             __DIR__ . '/../database/migrations_v1',
             __DIR__ . '/../database/migrations_v2',