шаг 4 завершен

app/Repositories/ProductRepository.php

@@ -40,7 +40,107 @@ final class ProductRepository extends BaseRepository
         return $this->attachPriceTiers($statement->fetchAll());
     }
 
-    private function previewSelectSql(string $orderBy, int $limit): string
+    /**
+     * @return array<int, array<string, mixed>>
+     */
+    public function forCategory(int $categoryId, int $limit = 48): array
+    {
+        $limit = max(1, min($limit, 96));
+        $categoryIds = (new CategoryRepository())->descendantIds($categoryId);
+        $placeholders = implode(',', array_fill(0, count($categoryIds), '?'));
+        $sql = $this->previewSelectSql(
+            'AND p.category_id IN (' . $placeholders . ') ORDER BY p.sort_order, p.name',
+            $limit
+        );
+
+        $statement = $this->pdo()->prepare($sql);
+        $statement->execute($categoryIds);
+
+        return $this->attachPriceTiers($statement->fetchAll());
+    }
+
+    /**
+     * @return array<int, array<string, mixed>>
+     */
+    public function adminLatest(int $limit = 30): array
+    {
+        $limit = max(1, min($limit, 100));
+        $statement = $this->pdo()->query(
+            'SELECT p.id, p.name, p.slug, p.is_published, c.name AS category_name, p.created_at
+             FROM products p
+             LEFT JOIN categories c ON c.id = p.category_id
+             ORDER BY p.created_at DESC, p.id DESC
+             LIMIT ' . $limit
+        );
+
+        return $statement->fetchAll();
+    }
+
+    /**
+     * @param array<string, mixed> $data
+     */
+    public function createWithVariant(array $data): int
+    {
+        if (($data['name'] ?? '') === '' || ($data['slug'] ?? '') === '') {
+            throw new \InvalidArgumentException('Название и slug обязательны.');
+        }
+
+        $pdo = $this->pdo();
+        $pdo->beginTransaction();
+
+        try {
+            $statement = $pdo->prepare(
+                'INSERT INTO products
+                    (category_id, name, slug, short_description, seo_title, seo_description, seo_keywords, base_unit, is_published, is_available, published_at)
+                 VALUES
+                    (:category_id, :name, :slug, :short_description, :seo_title, :seo_description, :seo_keywords, :base_unit, :is_published, 1, :published_at)'
+            );
+            $statement->execute([
+                'category_id' => $data['category_id'],
+                'name' => $data['name'],
+                'slug' => $data['slug'],
+                'short_description' => $data['short_description'] ?: null,
+                'seo_title' => $data['seo_title'] ?: null,
+                'seo_description' => $data['seo_description'] ?: null,
+                'seo_keywords' => $data['seo_keywords'] ?: null,
+                'base_unit' => $data['base_unit'] ?: 'kg',
+                'is_published' => $data['is_published'] ?? 0,
+                'published_at' => !empty($data['is_published']) ? date('Y-m-d H:i:s') : null,
+            ]);
+
+            $productId = (int) $pdo->lastInsertId();
+
+            if (($data['variant_name'] ?? '') !== '' && (float) ($data['package_price'] ?? 0) > 0) {
+                $variantStatement = $pdo->prepare(
+                    'INSERT INTO product_variants
+                        (product_id, name, unit, package_quantity, step_quantity, price_per_unit, package_price, old_package_price, discount_type, discount_percent, is_default, is_published, is_available)
+                     VALUES
+                        (:product_id, :name, :unit, :package_quantity, :step_quantity, :price_per_unit, :package_price, :old_package_price, :discount_type, :discount_percent, 1, 1, 1)'
+                );
+                $variantStatement->execute([
+                    'product_id' => $productId,
+                    'name' => $data['variant_name'],
+                    'unit' => $data['base_unit'] ?: 'kg',
+                    'package_quantity' => $data['package_quantity'] ?: 1,
+                    'step_quantity' => $data['step_quantity'] ?: ($data['package_quantity'] ?: 1),
+                    'price_per_unit' => $data['price_per_unit'],
+                    'package_price' => $data['package_price'],
+                    'old_package_price' => $data['old_package_price'] ?? null,
+                    'discount_type' => $data['discount_type'] ?? 'none',
+                    'discount_percent' => $data['discount_percent'] ?? null,
+                ]);
+            }
+
+            $pdo->commit();
+
+            return $productId;
+        } catch (\Throwable $exception) {
+            $pdo->rollBack();
+            throw $exception;
+        }
+    }
+
+    private function previewSelectSql(string $tailSql, int $limit): string
     {
         return 'SELECT
                     p.id,
@@ -62,7 +162,10 @@ final class ProductRepository extends BaseRepository
                     v.unit,
                     v.package_quantity,
                     v.price_per_unit,
-                    v.package_price
+                    v.package_price,
+                    v.old_package_price,
+                    v.discount_type,
+                    v.discount_percent
                 FROM products p
                 LEFT JOIN categories c ON c.id = p.category_id
                 LEFT JOIN product_variants v
@@ -77,7 +180,7 @@ final class ProductRepository extends BaseRepository
                     )
                 WHERE p.is_published = 1
                   AND p.is_available = 1
-                ' . $orderBy . '
+                ' . $tailSql . '
                 LIMIT ' . $limit;
     }