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]); } public function findByEbayListingId(string $ebayListingId): ?Article { return $this->em->getRepository(Article::class)->findOneBy(['ebayListingId' => $ebayListingId]); } /** @return list

*/ public function findByStatus(ArticleStatus $status): array { /** @var list

*/ 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(); } }