67 lines
1.9 KiB
PHP
67 lines
1.9 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace App\Infrastructure\Persistence\Repository;
|
|
|
|
use App\Domain\Article\Article;
|
|
use App\Domain\Article\ArticleStatus;
|
|
use App\Domain\Article\Repository\ArticleRepositoryInterface;
|
|
use Doctrine\ORM\EntityManagerInterface;
|
|
use Symfony\Component\Uid\Uuid;
|
|
|
|
final class DoctrineArticleRepository implements ArticleRepositoryInterface
|
|
{
|
|
public function __construct(private readonly EntityManagerInterface $em) {}
|
|
|
|
public function findById(Uuid $id): ?Article
|
|
{
|
|
return $this->em->find(Article::class, $id);
|
|
}
|
|
|
|
public function findBySku(string $sku): ?Article
|
|
{
|
|
return $this->em->getRepository(Article::class)->findOneBy(['sku' => $sku]);
|
|
}
|
|
|
|
public function findByInventoryNumber(string $inventoryNumber): ?Article
|
|
{
|
|
return $this->em->getRepository(Article::class)->findOneBy(['inventoryNumber' => $inventoryNumber]);
|
|
}
|
|
|
|
/** @return list<Article> */
|
|
public function findByStatus(ArticleStatus $status): array
|
|
{
|
|
/** @var list<Article> */
|
|
return $this->em->getRepository(Article::class)->findBy(['status' => $status]);
|
|
}
|
|
|
|
public function decrementStockAtomic(Uuid $articleId): bool
|
|
{
|
|
$affected = $this->em->getConnection()->executeStatement(
|
|
'UPDATE app.articles SET stock = stock - 1 WHERE id = :id AND stock > 0',
|
|
['id' => $articleId->toRfc4122()],
|
|
);
|
|
|
|
if ($affected > 0) {
|
|
$article = $this->em->find(Article::class, $articleId);
|
|
if (null !== $article) {
|
|
$this->em->refresh($article);
|
|
}
|
|
}
|
|
|
|
return $affected > 0;
|
|
}
|
|
|
|
public function save(Article $article): void
|
|
{
|
|
$this->em->persist($article);
|
|
$this->em->flush();
|
|
}
|
|
|
|
public function remove(Article $article): void
|
|
{
|
|
$this->em->remove($article);
|
|
$this->em->flush();
|
|
}
|
|
}
|