commitcd99a6489bMerge:ebcbbb1e63a036Author: ncoronel <ncoronel@quo.ar> Date: Wed Aug 26 10:12:44 2026 -0300 Merge branch 'fix/simplify_stock_reservations' of https://gitea.quo.ar/tbianchini/shopit-back into fix/simplify_stock_reservations commitebcbbb1774Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 16:33:39 2026 -0300 fix(cart): reconcile expired cart mutations commit3dd378ed06Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 16:10:15 2026 -0300 docs(stock): describe associated entity expiration commit4f705175bdAuthor: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 16:10:14 2026 -0300 test(stock): cover propagated reservation expiration commit82570fe941Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 16:09:52 2026 -0300 refactor(stock): propagate reservation expiration commitd2a2b323e0Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:58:47 2026 -0300 docs(stock): document terminal reservation recovery commitec67623b7bAuthor: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:58:47 2026 -0300 test(stock): cover terminal reservation lifecycle commitf6f138e180Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:58:41 2026 -0300 refactor(stock): make expired reservations terminal commitd612b7a118Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:28:30 2026 -0300 docs(stock): describe unified expiration ownership commit49f42d4507Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:28:23 2026 -0300 test(stock): cover authoritative reservation expiration commit1881cc1d4bAuthor: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:28:17 2026 -0300 refactor(stock): make reservation expiration authoritative commit00ec37d8a0Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:05:34 2026 -0300 docs(stock): document centralized reservation flow commitd9f374c718Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:05:29 2026 -0300 test(stock): cover aggregate reservation lifecycle commitbbfdf8f342Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:05:23 2026 -0300 refactor(stock): centralize reservation aggregate commit8a0f29bdaeAuthor: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 16:33:39 2026 -0300 fix(cart): reconcile expired cart mutations commit198ed400a9Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 16:10:15 2026 -0300 docs(stock): describe associated entity expiration commit23d83166e6Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 16:10:14 2026 -0300 test(stock): cover propagated reservation expiration commitcb090402d0Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 16:09:52 2026 -0300 refactor(stock): propagate reservation expiration commitc120b6f7c0Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:58:47 2026 -0300 docs(stock): document terminal reservation recovery commit1106fa28b4Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:58:47 2026 -0300 test(stock): cover terminal reservation lifecycle commit896fb81bcfAuthor: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:58:41 2026 -0300 refactor(stock): make expired reservations terminal commit8545fbc645Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:28:30 2026 -0300 docs(stock): describe unified expiration ownership commitdd6dcb708aAuthor: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:28:23 2026 -0300 test(stock): cover authoritative reservation expiration commit624b246ff5Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:28:17 2026 -0300 refactor(stock): make reservation expiration authoritative commit007b95b904Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:05:34 2026 -0300 docs(stock): document centralized reservation flow commit0b3c8c93beAuthor: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:05:29 2026 -0300 test(stock): cover aggregate reservation lifecycle commitede718e448Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:05:23 2026 -0300 refactor(stock): centralize reservation aggregate commite63a03601aAuthor: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 16:33:39 2026 -0300 fix(cart): reconcile expired cart mutations commit389373ad8cAuthor: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 16:10:15 2026 -0300 docs(stock): describe associated entity expiration commitace02a3133Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 16:10:14 2026 -0300 test(stock): cover propagated reservation expiration commitd69a6210f6Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 16:09:52 2026 -0300 refactor(stock): propagate reservation expiration commit3c0b43fea3Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:58:47 2026 -0300 docs(stock): document terminal reservation recovery commit9b0008626bAuthor: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:58:47 2026 -0300 test(stock): cover terminal reservation lifecycle commit61861e331aAuthor: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:58:41 2026 -0300 refactor(stock): make expired reservations terminal commit2cc9d7dd97Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:28:30 2026 -0300 docs(stock): describe unified expiration ownership commitf982bcead1Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:28:23 2026 -0300 test(stock): cover authoritative reservation expiration commit7a85e1731dAuthor: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:28:17 2026 -0300 refactor(stock): make reservation expiration authoritative commit6db99e775aAuthor: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:05:34 2026 -0300 docs(stock): document centralized reservation flow commite5f7ba3615Author: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:05:29 2026 -0300 test(stock): cover aggregate reservation lifecycle commit24bfef431bAuthor: ncoronel <ncoronel@quo.ar> Date: Tue Aug 25 15:05:23 2026 -0300 refactor(stock): centralize reservation aggregate
160 lines
6.4 KiB
PHP
160 lines
6.4 KiB
PHP
<?php
|
|
|
|
namespace App\Domains\Purchase\Services;
|
|
|
|
use App\Domains\Purchase\Models\Purchase;
|
|
use Illuminate\Database\Query\Builder;
|
|
use Illuminate\Support\Collection;
|
|
use Illuminate\Support\Facades\DB;
|
|
use InvalidArgumentException;
|
|
|
|
class TenantTransactionResetService
|
|
{
|
|
/** @return array<string, int> */
|
|
public function preview(string $tenantCode): array
|
|
{
|
|
$this->ensureTenantExists($tenantCode);
|
|
$scope = $this->scope($tenantCode);
|
|
|
|
return [
|
|
'users_preserved' => DB::table('users')->where('tenant_codigo', $tenantCode)->count(),
|
|
'purchases' => $scope['purchase_ids']->count(),
|
|
'purchase_items' => DB::table('compra_items')->whereIn('compra_id', $scope['purchase_ids'])->count(),
|
|
'telepagos_payments' => DB::table('telepagos_payments')->whereIn('compra_id', $scope['purchase_ids'])->count(),
|
|
'telepagos_qr' => DB::table('telepagos_qr')->whereIn('compra_id', $scope['purchase_ids'])->count(),
|
|
'carts' => $scope['cart_ids']->count(),
|
|
'cart_items' => $scope['cart_item_ids']->count(),
|
|
'tickets' => DB::table('tickets')->where('tenant_code', $tenantCode)->count(),
|
|
'stock_reservations' => $this->reservationQuery($scope)->count(),
|
|
'purchase_changes' => DB::table('value_changes')
|
|
->where('tenant_code', $tenantCode)
|
|
->where('trackable_type', Purchase::class)
|
|
->count(),
|
|
'inventories' => $scope['inventory_ids']->count(),
|
|
];
|
|
}
|
|
|
|
/** @return array<string, int> */
|
|
public function reset(string $tenantCode): array
|
|
{
|
|
$this->ensureTenantExists($tenantCode);
|
|
|
|
return DB::transaction(function () use ($tenantCode): array {
|
|
$scope = $this->scope($tenantCode);
|
|
$purchaseItems = DB::table('compra_items')->whereIn('compra_id', $scope['purchase_ids'])->count();
|
|
$cartItems = $scope['cart_item_ids']->count();
|
|
$telepagosPayments = DB::table('telepagos_payments')->whereIn('compra_id', $scope['purchase_ids'])->count();
|
|
$telepagosQr = DB::table('telepagos_qr')->whereIn('compra_id', $scope['purchase_ids'])->count();
|
|
$summary = [
|
|
'stock_reservations_deleted' => $this->reservationQuery($scope)->delete(),
|
|
'tickets_deleted' => DB::table('tickets')->where('tenant_code', $tenantCode)->delete(),
|
|
'purchase_changes_deleted' => DB::table('value_changes')
|
|
->where('tenant_code', $tenantCode)
|
|
->where('trackable_type', Purchase::class)
|
|
->delete(),
|
|
'purchases_deleted' => DB::table('compras')->whereIn('id', $scope['purchase_ids'])->delete(),
|
|
'purchase_items_deleted' => $purchaseItems,
|
|
'telepagos_payments_deleted' => $telepagosPayments,
|
|
'telepagos_qr_deleted' => $telepagosQr,
|
|
'carts_deleted' => DB::table('carritos')->whereIn('id', $scope['cart_ids'])->delete(),
|
|
'cart_items_deleted' => $cartItems,
|
|
'inventories_reset' => $scope['inventory_ids']->count(),
|
|
'users_preserved' => DB::table('users')->where('tenant_codigo', $tenantCode)->count(),
|
|
];
|
|
|
|
DB::table('inventories')
|
|
->whereIn('id', $scope['inventory_ids'])
|
|
->update([
|
|
'real_stock' => DB::raw('real_stock + sold_units'),
|
|
'reserved_stock' => 0,
|
|
'sold_units' => 0,
|
|
]);
|
|
|
|
return $summary;
|
|
});
|
|
}
|
|
|
|
private function ensureTenantExists(string $tenantCode): void
|
|
{
|
|
if (! DB::table('tenants')->where('codigo', $tenantCode)->exists()) {
|
|
throw new InvalidArgumentException("El tenant {$tenantCode} no existe.");
|
|
}
|
|
}
|
|
|
|
/**
|
|
* @return array{
|
|
* purchase_ids: Collection<int, int>,
|
|
* cart_ids: Collection<int, int>,
|
|
* cart_item_ids: Collection<int, int>,
|
|
* inventory_ids: Collection<int, int>
|
|
* }
|
|
*/
|
|
private function scope(string $tenantCode): array
|
|
{
|
|
$catalogItemIds = DB::table('catalog_items')
|
|
->where('tenant_code', $tenantCode)
|
|
->pluck('id');
|
|
$purchaseIds = DB::table('compras')
|
|
->where('tenant_codigo', $tenantCode)
|
|
->pluck('id');
|
|
$cartIds = DB::table('carritos')
|
|
->where('tenant_codigo', $tenantCode)
|
|
->pluck('id');
|
|
$cartItemIds = DB::table('carrito_items')
|
|
->whereIn('cart_id', $cartIds)
|
|
->pluck('id');
|
|
$inventoryIds = DB::table('variantes')
|
|
->whereIn('catalog_item_id', $catalogItemIds)
|
|
->whereNotNull('inventory_id')
|
|
->pluck('inventory_id')
|
|
->merge(
|
|
DB::table('catalog_items')
|
|
->whereIn('id', $catalogItemIds)
|
|
->whereNotNull('inventory_id')
|
|
->pluck('inventory_id'),
|
|
)
|
|
->map(fn ($id): int => (int) $id)
|
|
->unique()
|
|
->values();
|
|
|
|
return [
|
|
'purchase_ids' => $purchaseIds->map(fn ($id): int => (int) $id),
|
|
'cart_ids' => $cartIds->map(fn ($id): int => (int) $id),
|
|
'cart_item_ids' => $cartItemIds->map(fn ($id): int => (int) $id),
|
|
'inventory_ids' => $inventoryIds,
|
|
];
|
|
}
|
|
|
|
/**
|
|
* @param array{
|
|
* purchase_ids: Collection<int, int>,
|
|
* cart_ids: Collection<int, int>,
|
|
* cart_item_ids: Collection<int, int>,
|
|
* inventory_ids: Collection<int, int>
|
|
* } $scope
|
|
*/
|
|
private function reservationQuery(array $scope): Builder
|
|
{
|
|
$reservationIds = DB::table('carritos')
|
|
->whereIn('id', $scope['cart_ids'])
|
|
->whereNotNull('current_stock_reservation_id')
|
|
->pluck('current_stock_reservation_id')
|
|
->merge(
|
|
DB::table('compras')
|
|
->whereIn('id', $scope['purchase_ids'])
|
|
->whereNotNull('stock_reservation_id')
|
|
->pluck('stock_reservation_id'),
|
|
)
|
|
->merge(
|
|
DB::table('stock_reservation_lines')
|
|
->whereIn('inventory_id', $scope['inventory_ids'])
|
|
->pluck('stock_reservation_id'),
|
|
)
|
|
->unique()
|
|
->values();
|
|
|
|
return DB::table('stock_reservations')
|
|
->whereIn('id', $reservationIds);
|
|
}
|
|
}
|