Merge branch 'refactor/inventory_stock' into homo

2026-10-01 10:00:41 -03:00
parent c7fc867905 fb5221854c
commit e2cf53eacc
36 changed files with 841 additions and 179 deletions
--- a/database/migrations/2026_09_25_000000_generate_available_inventory_stock.php
+++ b/database/migrations/2026_09_25_000000_generate_available_inventory_stock.php
@@ -0,0 +1,89 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    public $withinTransaction = false;
+
+    private const FORMULA = 'CAST(real_stock AS SIGNED) - CAST(sold_units AS SIGNED) - CAST(reserved_stock AS SIGNED) - CAST(entry_reserved_stock AS SIGNED) + CAST(refunded_units AS SIGNED)';
+
+    public function up(): void
+    {
+        $conversion = 'CAST(real_stock AS SIGNED) + CAST(sold_units AS SIGNED) - CAST(refunded_units AS SIGNED)';
+        $this->assertNonNegative($conversion, 'la conversión produciría un stock real negativo');
+        $this->assertNonNegative(
+            "({$conversion}) - CAST(sold_units AS SIGNED) - CAST(reserved_stock AS SIGNED) - CAST(entry_reserved_stock AS SIGNED) + CAST(refunded_units AS SIGNED)",
+            'el stock disponible actual es negativo',
+        );
+
+        if (DB::getDriverName() === 'sqlite') {
+            Schema::table('inventories', function (Blueprint $table): void {
+                $table->bigInteger('available_stock')->virtualAs(self::FORMULA);
+            });
+            DB::table('inventories')->update(['real_stock' => DB::raw($conversion)]);
+        } else {
+            Schema::table('inventories', function (Blueprint $table): void {
+                $table->unsignedBigInteger('real_stock')->default(0)->change();
+                $table->bigInteger('available_stock')->storedAs(self::FORMULA);
+            });
+            DB::table('inventories')->update(['real_stock' => DB::raw($conversion)]);
+        }
+    }
+
+    public function down(): void
+    {
+        $conversion = 'CAST(real_stock AS SIGNED) - CAST(sold_units AS SIGNED) + CAST(refunded_units AS SIGNED)';
+        $this->assertNonNegative($conversion, 'el rollback produciría un stock real negativo');
+
+        if (DB::getDriverName() === 'sqlite') {
+            DB::table('inventories')->update(['real_stock' => DB::raw($conversion)]);
+            Schema::table('inventories', fn (Blueprint $table) => $table->dropColumn('available_stock'));
+
+            return;
+        }
+
+        DB::table('inventories')->update(['real_stock' => DB::raw($conversion)]);
+        Schema::table('inventories', fn (Blueprint $table) => $table->dropColumn('available_stock'));
+    }
+
+    private function assertNonNegative(string $expression, string $reason): void
+    {
+        $invalidInventories = DB::table('inventories')
+            ->select([
+                'id',
+                'real_stock',
+                'sold_units',
+                'refunded_units',
+                'reserved_stock',
+                'entry_reserved_stock',
+            ])
+            ->selectRaw("({$expression}) as calculated_stock")
+            ->whereRaw("({$expression}) < 0")
+            ->orderBy('id')
+            ->limit(20)
+            ->get();
+
+        if ($invalidInventories->isNotEmpty()) {
+            $details = $invalidInventories
+                ->map(static fn (object $inventory): string => sprintf(
+                    'id=%d [real=%d, vendidas=%d, reintegradas=%d, reservadas=%d, reservas_entradas=%d, resultado=%d]',
+                    $inventory->id,
+                    $inventory->real_stock,
+                    $inventory->sold_units,
+                    $inventory->refunded_units,
+                    $inventory->reserved_stock,
+                    $inventory->entry_reserved_stock,
+                    $inventory->calculated_stock,
+                ))
+                ->implode('; ');
+
+            throw new RuntimeException(
+                "Hay inventarios inconsistentes: {$reason}. Inventarios detectados (máximo 20): {$details}."
+            );
+        }
+    }
+};
--- a/database/migrations/2026_09_25_010000_create_inventory_movements_table.php
+++ b/database/migrations/2026_09_25_010000_create_inventory_movements_table.php
@@ -0,0 +1,33 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    public function up(): void
+    {
+        Schema::create('inventory_movements', function (Blueprint $table): void {
+            $table->id();
+            $table->foreignId('inventory_id')->constrained('inventories')->restrictOnDelete();
+            $table->string('operation', 40);
+            $table->bigInteger('available_stock_delta');
+            $table->bigInteger('available_stock_before');
+            $table->bigInteger('available_stock_after');
+            $table->json('counter_deltas');
+            $table->foreignId('responsible_user_id')->nullable()->constrained('users')->restrictOnDelete();
+            $table->uuid('idempotency_key')->nullable();
+            $table->timestamps();
+
+            $table->unique(['inventory_id', 'idempotency_key']);
+            $table->index(['inventory_id', 'created_at']);
+            $table->index(['operation', 'created_at']);
+        });
+    }
+
+    public function down(): void
+    {
+        Schema::dropIfExists('inventory_movements');
+    }
+};