src/Controller/AdminController.php line 156

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Controller\Catalog\CatalogRepository;
  6. use App\Controller\Catalog\CatalogSteamEnricher;
  7. use App\Controller\Catalog\GalaxyLinkCatalogProvider;
  8. use Doctrine\DBAL\Connection;
  9. use Symfony\Component\HttpFoundation\JsonResponse;
  10. use Symfony\Component\HttpFoundation\RedirectResponse;
  11. use Symfony\Component\HttpFoundation\Request;
  12. use Symfony\Component\HttpFoundation\Response;
  13. use Symfony\Component\Routing\Annotation\Route;
  15. class AdminController extends BaseController
  16. {
  17.     /**
  18.      * @Route("/admin", name="admin_dashboard", methods={"GET"})
  19.      */
  20.     public function dashboard(Request $request, Connection $db, CatalogRepository $catalog): Response
  21.     {
  22.         $catalog->ensureSchema();
  24.         $filters = [
  25.             'q' => trim((string) $request->query->get('q', '')),
  26.             'source' => trim((string) $request->query->get('source', '')),
  27.             'category' => trim((string) $request->query->get('category', '')),
  28.             'active' => trim((string) $request->query->get('active', '')),
  29.             'stock' => trim((string) $request->query->get('stock', '')),
  30.             'discount' => trim((string) $request->query->get('discount', '')),
  31.             'page' => max(1, (int) $request->query->get('page', 1)),
  32.         ];
  34.         $products = $this->fetchProducts($db, $filters, 50);
  35.         $steamEnrichmentReport = null;
  36.         if ($request->hasSession()) {
  37.             $steamEnrichmentReport = $request->getSession()->get('admin_steam_enrichment_report');
  38.             $request->getSession()->remove('admin_steam_enrichment_report');
  39.         }
  41.         return $this->render('admin/dashboard.html.twig', $this->adminView($request, $db, [
  42.             'stats' => $this->dashboardStats($db),
  43.             'sources' => $this->fetchSources($db),
  44.             'categories' => $this->fetchCategories($db),
  45.             'products' => $products['items'],
  46.             'pagination' => $products['pagination'],
  47.             'filters' => $filters,
  48.             'steam_enrichment_report' => $steamEnrichmentReport,
  49.             'steam_background_status' => $this->steamBackgroundStatus(),
  50.             'current_section' => 'dashboard',
  51.         ]));
  52.     }
  54.     /**
  55.      * @Route("/admin/references", name="admin_references", methods={"GET"})
  56.      */
  57.     public function references(Request $request, Connection $db, CatalogRepository $catalog): Response
  58.     {
  59.         $catalog->ensureSchema();
  61.         return $this->render('admin/references.html.twig', $this->adminView($request, $db, [
  62.             'sources' => $this->fetchSources($db),
  63.             'categories' => $this->fetchCategories($db),
  64.             'empty_source' => $this->emptySource(),
  65.             'empty_category' => $this->emptyCategory(),
  66.             'current_section' => 'references',
  67.         ]));
  68.     }
  70.     /**
  71.      * @Route("/admin/users", name="admin_users", methods={"GET"})
  72.      */
  73.     public function users(Request $request, Connection $db): Response
  74.     {
  75.         $this->ensureUsersSchema($db);
  77.         $filters = [
  78.             'q' => trim((string) $request->query->get('q', '')),
  79.             'page' => max(1, (int) $request->query->get('page', 1)),
  80.         ];
  81.         $users = $this->fetchUsers($db, $filters, 40);
  83.         return $this->render('admin/users.html.twig', $this->adminView($request, $db, [
  84.             'users' => $users['items'],
  85.             'pagination' => $users['pagination'],
  86.             'filters' => $filters,
  87.             'current_section' => 'users',
  88.         ]));
  89.     }
  91.     /**
  92.      * @Route("/admin/products/new", name="admin_product_new", methods={"GET", "POST"})
  93.      */
  94.     public function newProduct(Request $request, Connection $db, CatalogRepository $catalog): Response
  95.     {
  96.         $catalog->ensureSchema();
  98.         if ($request->isMethod('POST')) {
  99.             try {
  100.                 $id = $this->saveProduct($request, $db, null);
  101.                 $this->addFlash('success', 'Товар создан.');
  103.                 return $this->redirectToRoute('admin_product_edit', ['id' => $id]);
  104.             } catch (\Throwable $error) {
  105.                 $this->addFlash('danger', $error->getMessage());
  106.             }
  107.         }
  109.         return $this->render('admin/product_form.html.twig', $this->adminView($request, $db, [
  110.             'product' => $this->emptyProduct(),
  111.             'variants' => [],
  112.             'categories' => $this->fetchCategories($db),
  113.             'sources' => $this->fetchSources($db),
  114.             'mode' => 'new',
  115.             'current_section' => 'products',
  116.         ]));
  117.     }
  119.     /**
  120.      * @Route("/admin/products/{id}/edit", name="admin_product_edit", methods={"GET", "POST"}, requirements={"id"="\d+"})
  121.      */
  122.     public function editProduct(int $id, Request $request, Connection $db, CatalogRepository $catalog): Response
  123.     {
  124.         $catalog->ensureSchema();
  126.         $product = $this->fetchProduct($db, $id);
  127.         if (!$product) {
  128.             throw $this->createNotFoundException('Product not found.');
  129.         }
  131.         if ($request->isMethod('POST')) {
  132.             try {
  133.                 $this->saveProduct($request, $db, $id);
  134.                 $this->addFlash('success', 'Товар сохранен.');
  136.                 return $this->redirectToRoute('admin_product_edit', ['id' => $id]);
  137.             } catch (\Throwable $error) {
  138.                 $this->addFlash('danger', $error->getMessage());
  139.                 $product = array_merge($product, $request->request->all());
  140.             }
  141.         }
  143.         return $this->render('admin/product_form.html.twig', $this->adminView($request, $db, [
  144.             'product' => $this->decorateProduct($product),
  145.             'variants' => $this->fetchProductVariants($db, $product),
  146.             'categories' => $this->fetchCategories($db),
  147.             'sources' => $this->fetchSources($db),
  148.             'mode' => 'edit',
  149.             'current_section' => 'products',
  150.         ]));
  151.     }
  153.     /**
  154.      * @Route("/admin/users/{id}/edit", name="admin_user_edit", methods={"GET", "POST"}, requirements={"id"="\d+"})
  155.      */
  156.     public function editUser(int $id, Request $request, Connection $db): Response
  157.     {
  158.         $this->ensureUsersSchema($db);
  160.         $user = $this->fetchUser($db, $id);
  161.         if (!$user) {
  162.             throw $this->createNotFoundException('User not found.');
  163.         }
  165.         if ($request->isMethod('POST')) {
  166.             try {
  167.                 $this->saveUser($request, $db, $id);
  168.                 $this->addFlash('success', 'Пользователь сохранен.');
  170.                 return $this->redirectToRoute('admin_user_edit', ['id' => $id]);
  171.             } catch (\Throwable $error) {
  172.                 $this->addFlash('danger', $error->getMessage());
  173.                 $user = array_merge($user, $request->request->all());
  174.             }
  175.         }
  177.         return $this->render('admin/user_form.html.twig', $this->adminView($request, $db, [
  178.             'user' => $this->decorateUser($user),
  179.             'current_section' => 'users',
  180.         ]));
  181.     }
  183.     /**
  184.      * @Route("/admin/products/bulk", name="admin_products_bulk", methods={"POST"})
  185.      */
  186.     public function bulkProducts(Request $request, Connection $db, CatalogRepository $catalog): RedirectResponse
  187.     {
  188.         $catalog->ensureSchema();
  190.         $ids = array_values(array_filter(array_map('intval', (array) $request->request->get('ids', []))));
  191.         $action = (string) $request->request->get('action', '');
  192.         if (count($ids) === 0) {
  193.             $this->addFlash('warning', 'Выберите товары для массового действия.');
  195.             return $this->redirectToRoute('admin_dashboard', $request->query->all());
  196.         }
  198.         $placeholders = implode(',', array_fill(0, count($ids), '?'));
  199.         $now = $this->now();
  201.         if ($action === 'activate') {
  202.             $db->executeStatement("UPDATE catalog_products SET is_active = 1, updated_at = ? WHERE id IN ({$placeholders})", array_merge([$now], $ids));
  203.             $this->addFlash('success', 'Выбранные товары включены.');
  204.         } elseif ($action === 'deactivate') {
  205.             $db->executeStatement("UPDATE catalog_products SET is_active = 0, updated_at = ? WHERE id IN ({$placeholders})", array_merge([$now], $ids));
  206.             $this->addFlash('success', 'Выбранные товары скрыты.');
  207.         } elseif ($action === 'stock_on') {
  208.             $db->executeStatement("UPDATE catalog_products SET in_stock = 1, updated_at = ? WHERE id IN ({$placeholders})", array_merge([$now], $ids));
  209.             $this->addFlash('success', 'Наличие включено.');
  210.         } elseif ($action === 'stock_off') {
  211.             $db->executeStatement("UPDATE catalog_products SET in_stock = 0, updated_at = ? WHERE id IN ({$placeholders})", array_merge([$now], $ids));
  212.             $this->addFlash('success', 'Наличие выключено.');
  213.         } elseif ($action === 'clear_discount') {
  214.             $db->executeStatement("UPDATE catalog_products SET discount_percent = NULL, updated_at = ? WHERE id IN ({$placeholders})", array_merge([$now], $ids));
  215.             $this->addFlash('success', 'Скидки очищены.');
  216.         } elseif ($action === 'set_discount') {
  217.             $discount = $this->normalizeDiscount($request->request->get('discount_percent'));
  218.             $db->executeStatement("UPDATE catalog_products SET discount_percent = ?, updated_at = ? WHERE id IN ({$placeholders})", array_merge([$discount, $now], $ids));
  219.             $this->addFlash('success', $discount === null ? 'Скидки очищены.' : 'Скидка применена.');
  220.         } else {
  221.             $this->addFlash('warning', 'Неизвестное массовое действие.');
  222.         }
  224.         return $this->redirectToRoute('admin_dashboard', $request->query->all());
  225.     }
  227.     /**
  228.      * @Route("/admin/products/{id}/toggle", name="admin_product_toggle", methods={"POST"}, requirements={"id"="\d+"})
  229.      */
  230.     public function toggleProduct(int $id, Request $request, Connection $db, CatalogRepository $catalog): RedirectResponse
  231.     {
  232.         $catalog->ensureSchema();
  234.         $field = (string) $request->request->get('field', '');
  235.         if (!in_array($field, ['is_active', 'in_stock'], true)) {
  236.             $this->addFlash('warning', 'Нельзя изменить это поле.');
  238.             return $this->redirectToRoute('admin_dashboard');
  239.         }
  241.         $value = (int) $db->fetchOne("SELECT {$field} FROM catalog_products WHERE id = ? LIMIT 1", [$id]);
  242.         $db->update('catalog_products', [
  243.             $field => $value ? 0 : 1,
  244.             'updated_at' => $this->now(),
  245.         ], ['id' => $id]);
  247.         $this->addFlash('success', $field === 'is_active' ? 'Видимость обновлена.' : 'Наличие обновлено.');
  249.         return $this->redirect($request->headers->get('referer') ?: $this->generateUrl('admin_dashboard'));
  250.     }
  252.     /**
  253.      * @Route("/admin/sync/galaxylink", name="admin_sync_galaxylink", methods={"POST"})
  254.      */
  255.     public function syncGalaxyLink(GalaxyLinkCatalogProvider $provider): RedirectResponse
  256.     {
  257.         @set_time_limit(1200);
  258.         @ini_set('memory_limit', '512M');
  260.         try {
  261.             $giftResult = $provider->sync([
  262.                 'types' => [GalaxyLinkCatalogProvider::KEY_GIFT_TYPE],
  263.                 'categories' => ['STEAM_GIFTS'],
  264.                 'rows' => 500,
  265.                 'region' => 'RU',
  266.                 'limit_products' => 0,
  267.                 'lang' => 'russian',
  268.                 'cc' => 'us',
  269.                 'image_limit' => 0,
  270.                 'enrich_steam' => false,
  271.                 'dry_run' => false,
  272.             ]);
  274.             $keyCategories = array_values(array_filter(
  275.                 GalaxyLinkCatalogProvider::STEAM_CATALOG_CATEGORIES,
  276.                 function (string $category): bool {
  277.                     return $category !== 'STEAM_GIFTS';
  278.                 }
  279.             ));
  280.             $keyResult = $provider->sync([
  281.                 'types' => [GalaxyLinkCatalogProvider::KEY_GIFT_TYPE],
  282.                 'categories' => $keyCategories,
  283.                 'rows' => 500,
  284.                 'region' => 'RU',
  285.                 'limit_products' => 0,
  286.                 'lang' => 'russian',
  287.                 'cc' => 'us',
  288.                 'image_limit' => 0,
  289.                 'enrich_steam' => false,
  290.                 'dry_run' => false,
  291.             ]);
  293.             $warnings = array_merge($giftResult->warnings, $keyResult->warnings);
  294.             $errors = array_merge($giftResult->errors, $keyResult->errors);
  295.             $message = sprintf(
  296.                 'GalaxyLink синхронизирован: Steam Gifts %d, Steam Keys %d, категорий %d, предупреждений %d.',
  297.                 $giftResult->products,
  298.                 $keyResult->products,
  299.                 $giftResult->categories + $keyResult->categories,
  300.                 count($warnings)
  301.             );
  302.             $this->addFlash(count($errors) > 0 ? 'warning' : 'success', $message);
  303.         } catch (\Throwable $error) {
  304.             $this->addFlash('danger', 'Ошибка синхронизации GalaxyLink: ' . $error->getMessage());
  305.         }
  307.         return $this->redirectToRoute('admin_dashboard');
  308.     }
  310.     /**
  311.      * @Route("/admin/sync/steam-content", name="admin_sync_steam_content", methods={"POST"})
  312.      */
  313.     public function syncSteamContent(Request $request, CatalogRepository $catalog, CatalogSteamEnricher $enricher): RedirectResponse
  314.     {
  315.         @set_time_limit(1200);
  316.         @ini_set('memory_limit', '512M');
  317.         $catalog->ensureSchema();
  319.         try {
  320.             $report = $enricher->enrichMissing([
  321.                 'lang' => 'russian',
  322.                 'cc' => 'us',
  323.                 'image_limit' => 0,
  324.                 'limit' => 300,
  325.                 'batch_size' => 80,
  326.             ]);
  328.             if ($request->hasSession()) {
  329.                 $request->getSession()->set('admin_steam_enrichment_report', $report);
  330.             }
  332.             $message = sprintf(
  333.                 'Steam-дозаполнение завершено: обновлено товаров %d, игровых групп %d, не получилось %d.',
  334.                 (int) $report['updated_products'],
  335.                 (int) $report['updated_games'],
  336.                 (int) $report['failed_count']
  337.             );
  338.             $this->addFlash((int) $report['failed_count'] > 0 ? 'warning' : 'success', $message);
  339.         } catch (\Throwable $error) {
  340.             $this->addFlash('danger', 'Ошибка Steam-дозаполнения: ' . $error->getMessage());
  341.         }
  343.         return $this->redirectToRoute('admin_dashboard');
  344.     }
  346.     /**
  347.      * @Route("/admin/sync/steam-content/background/start", name="admin_sync_steam_background_start", methods={"POST"})
  348.      */
  349.     public function startSteamBackgroundSync(CatalogRepository $catalog): RedirectResponse
  350.     {
  351.         $catalog->ensureSchema();
  352.         $status = $this->steamBackgroundStatus();
  353.         if (!empty($status['running'])) {
  354.             $this->addFlash('warning', 'Фоновое Steam-дозаполнение уже идет.');
  356.             return $this->redirectToRoute('admin_dashboard');
  357.         }
  359.         try {
  360.             $paths = $this->steamBackgroundPaths();
  361.             if (!is_dir($paths['dir'])) {
  362.                 @mkdir($paths['dir'], 0775, true);
  363.             }
  364.             if (is_file($paths['stop'])) {
  365.                 @unlink($paths['stop']);
  366.             }
  368.             $projectDir = (string) $this->getParameter('kernel.project_dir');
  369.             $arguments = [
  370.                 '/usr/bin/env',
  371.                 'APP_ENV=prod',
  372.                 'APP_DEBUG=0',
  373.                 PHP_BINARY,
  374.                 '-d',
  375.                 'memory_limit=512M',
  376.                 $projectDir . '/bin/console',
  377.                 '--env=prod',
  378.                 '--no-debug',
  379.                 'app:catalog:enrich-steam',
  380.                 '--continuous',
  381.                 '--limit=300',
  382.                 '--batch-size=80',
  383.                 '--lang=russian',
  384.                 '--cc=us',
  385.                 '--image-limit=0',
  386.                 '--status-file=' . $paths['status'],
  387.                 '--stop-file=' . $paths['stop'],
  388.                 '--rate-limit-sleep=90',
  389.             ];
  391.             $command = implode(' ', array_map('escapeshellarg', $arguments)) . ' >> ' . escapeshellarg($paths['log']) . ' 2>&1 & echo $!';
  392.             $output = [];
  393.             $exitCode = 0;
  394.             exec($command, $output, $exitCode);
  395.             $pid = isset($output[0]) ? (int) trim((string) $output[0]) : 0;
  396.             if ($exitCode !== 0 || $pid <= 0) {
  397.                 throw new \RuntimeException('Не удалось запустить фоновый процесс Steam-дозаполнения.');
  398.             }
  400.             $now = $this->nowIso();
  401.             $this->writeSteamBackgroundStatus([
  402.                 'state' => 'running',
  403.                 'running' => true,
  404.                 'requested_stop' => false,
  405.                 'pid' => $pid,
  406.                 'started_at' => $now,
  407.                 'updated_at' => $now,
  408.                 'finished_at' => null,
  409.                 'pass' => 0,
  410.                 'message' => 'Фоновое Steam-дозаполнение запускается.',
  411.                 'totals' => $this->emptySteamBackgroundReport(),
  412.                 'last_report' => $this->emptySteamBackgroundReport(),
  413.             ]);
  415.             $this->addFlash('success', 'Фоновое Steam-дозаполнение запущено. Страницу можно закрыть.');
  416.         } catch (\Throwable $error) {
  417.             $this->addFlash('danger', 'Не удалось запустить фоновое Steam-дозаполнение: ' . $error->getMessage());
  418.         }
  420.         return $this->redirectToRoute('admin_dashboard');
  421.     }
  423.     /**
  424.      * @Route("/admin/sync/steam-content/background/stop", name="admin_sync_steam_background_stop", methods={"POST"})
  425.      */
  426.     public function stopSteamBackgroundSync(): RedirectResponse
  427.     {
  428.         $status = $this->steamBackgroundStatus();
  429.         if (empty($status['running'])) {
  430.             $this->addFlash('warning', 'Фоновое Steam-дозаполнение сейчас не запущено.');
  432.             return $this->redirectToRoute('admin_dashboard');
  433.         }
  435.         $paths = $this->steamBackgroundPaths();
  436.         if (!is_dir($paths['dir'])) {
  437.             @mkdir($paths['dir'], 0775, true);
  438.         }
  439.         file_put_contents($paths['stop'], $this->nowIso(), LOCK_EX);
  441.         $status['state'] = 'stopping';
  442.         $status['requested_stop'] = true;
  443.         $status['message'] = 'Остановка запрошена. Процесс завершит текущую операцию и остановится.';
  444.         $status['updated_at'] = $this->nowIso();
  445.         $this->writeSteamBackgroundStatus($status);
  447.         $this->addFlash('success', 'Остановка фонового Steam-дозаполнения запрошена.');
  449.         return $this->redirectToRoute('admin_dashboard');
  450.     }
  452.     /**
  453.      * @Route("/admin/sync/steam-content/background/status", name="admin_sync_steam_background_status", methods={"GET"})
  454.      */
  455.     public function steamBackgroundSyncStatus(): JsonResponse
  456.     {
  457.         return new JsonResponse($this->steamBackgroundStatus());
  458.     }
  460.     /**
  461.      * @Route("/admin/references/sources/save", name="admin_source_save", methods={"POST"})
  462.      */
  463.     public function saveSource(Request $request, Connection $db, CatalogRepository $catalog): RedirectResponse
  464.     {
  465.         $catalog->ensureSchema();
  467.         try {
  468.             $this->persistSource($request, $db);
  469.             $this->addFlash('success', 'Источник сохранен.');
  470.         } catch (\Throwable $error) {
  471.             $this->addFlash('danger', $error->getMessage());
  472.         }
  474.         return $this->redirectToRoute('admin_references');
  475.     }
  477.     /**
  478.      * @Route("/admin/references/sources/{id}/toggle", name="admin_source_toggle", methods={"POST"}, requirements={"id"="\d+"})
  479.      */
  480.     public function toggleSource(int $id, Connection $db, CatalogRepository $catalog): RedirectResponse
  481.     {
  482.         $catalog->ensureSchema();
  484.         $value = $db->fetchOne('SELECT enabled FROM catalog_sources WHERE id = ? LIMIT 1', [$id]);
  485.         if ($value === false) {
  486.             $this->addFlash('warning', 'Источник не найден.');
  488.             return $this->redirectToRoute('admin_references');
  489.         }
  491.         $db->update('catalog_sources', [
  492.             'enabled' => (int) $value ? 0 : 1,
  493.             'updated_at' => $this->now(),
  494.         ], ['id' => $id]);
  495.         $this->addFlash('success', 'Статус источника обновлен.');
  497.         return $this->redirectToRoute('admin_references');
  498.     }
  500.     /**
  501.      * @Route("/admin/references/categories/save", name="admin_category_save", methods={"POST"})
  502.      */
  503.     public function saveCategory(Request $request, Connection $db, CatalogRepository $catalog): RedirectResponse
  504.     {
  505.         $catalog->ensureSchema();
  507.         try {
  508.             $this->persistCategory($request, $db);
  509.             $this->addFlash('success', 'Категория сохранена.');
  510.         } catch (\Throwable $error) {
  511.             $this->addFlash('danger', $error->getMessage());
  512.         }
  514.         return $this->redirectToRoute('admin_references');
  515.     }
  517.     /**
  518.      * @Route("/admin/references/categories/{id}/toggle", name="admin_category_toggle", methods={"POST"}, requirements={"id"="\d+"})
  519.      */
  520.     public function toggleCategory(int $id, Connection $db, CatalogRepository $catalog): RedirectResponse
  521.     {
  522.         $catalog->ensureSchema();
  524.         $value = $db->fetchOne('SELECT is_active FROM catalog_categories WHERE id = ? LIMIT 1', [$id]);
  525.         if ($value === false) {
  526.             $this->addFlash('warning', 'Категория не найдена.');
  528.             return $this->redirectToRoute('admin_references');
  529.         }
  531.         $db->update('catalog_categories', [
  532.             'is_active' => (int) $value ? 0 : 1,
  533.             'updated_at' => $this->now(),
  534.         ], ['id' => $id]);
  535.         $this->addFlash('success', 'Статус категории обновлен.');
  537.         return $this->redirectToRoute('admin_references');
  538.     }
  540.     private function adminView(Request $request, Connection $db, array $params): array
  541.     {
  542.         try {
  543.             $user = $this->getAuthorizedUser($request, $db);
  544.         } catch (\Throwable $error) {
  545.             $user = null;
  546.         }
  548.         $params['admin_user'] = [
  549.             'id' => $user ? (int) $user['id'] : 0,
  550.             'login' => $user ? (string) $user['login'] : 'Admin',
  551.             'img' => $user && !empty($user['img']) ? (string) $user['img'] : '/assets/profile.svg',
  552.         ];
  554.         return $params;
  555.     }
  557.     private function steamBackgroundPaths(): array
  558.     {
  559.         $projectDir = rtrim((string) $this->getParameter('kernel.project_dir'), DIRECTORY_SEPARATOR);
  560.         $dir = $projectDir . '/var/admin-steam-enrichment';
  562.         return [
  563.             'dir' => $dir,
  564.             'status' => $dir . '/status.json',
  565.             'stop' => $dir . '/stop.flag',
  566.             'log' => $dir . '/steam-enrichment.log',
  567.         ];
  568.     }
  570.     private function steamBackgroundStatus(): array
  571.     {
  572.         $paths = $this->steamBackgroundPaths();
  573.         $status = $this->readSteamBackgroundStatus($paths['status']);
  574.         $state = (string) ($status['state'] ?? 'idle');
  575.         $pid = (int) ($status['pid'] ?? 0);
  576.         $running = $pid > 0 && $this->processIsRunning($pid);
  577.         $requestedStop = is_file($paths['stop']);
  579.         if (in_array($state, ['running', 'stopping'], true) && !$running) {
  580.             $state = $requestedStop ? 'stopped' : 'error';
  581.             $status['state'] = $state;
  582.             $status['running'] = false;
  583.             $status['finished_at'] = $status['finished_at'] ?? $this->nowIso();
  584.             $status['updated_at'] = $this->nowIso();
  585.             if (empty($status['message']) || $state === 'error') {
  586.                 $status['message'] = $state === 'error'
  587.                     ? 'Фоновый процесс завершился без финального статуса. Проверьте лог.'
  588.                     : 'Фоновое Steam-дозаполнение остановлено.';
  589.             }
  590.             $this->writeSteamBackgroundStatus($status);
  591.         }
  593.         $status = array_merge([
  594.             'state' => 'idle',
  595.             'running' => false,
  596.             'requested_stop' => false,
  597.             'pid' => 0,
  598.             'started_at' => null,
  599.             'updated_at' => null,
  600.             'finished_at' => null,
  601.             'pass' => 0,
  602.             'message' => 'Фоновое Steam-дозаполнение ещё не запускалось.',
  603.             'totals' => $this->emptySteamBackgroundReport(),
  604.             'last_report' => $this->emptySteamBackgroundReport(),
  605.         ], $status);
  607.         $status['state'] = $state;
  608.         $status['running'] = $running && in_array($state, ['running', 'stopping'], true);
  609.         $status['requested_stop'] = $requestedStop;
  610.         $status['state_label'] = $this->steamBackgroundStateLabel($state);
  611.         $status['state_class'] = $this->steamBackgroundStateClass($state);
  612.         $status['failed'] = array_slice((array) ($status['totals']['failed'] ?? []), 0, 20);
  613.         $status['failed_truncated'] = max(
  614.             (int) ($status['totals']['failed_truncated'] ?? 0),
  615.             max(0, (int) ($status['totals']['failed_count'] ?? 0) - count((array) ($status['totals']['failed'] ?? [])))
  616.         );
  618.         return $status;
  619.     }
  621.     private function readSteamBackgroundStatus(string $path): array
  622.     {
  623.         if (!is_file($path)) {
  624.             return [];
  625.         }
  627.         $contents = file_get_contents($path);
  628.         if (!is_string($contents) || trim($contents) === '') {
  629.             return [];
  630.         }
  632.         $decoded = json_decode($contents, true);
  634.         return is_array($decoded) ? $decoded : [];
  635.     }
  637.     private function writeSteamBackgroundStatus(array $status): void
  638.     {
  639.         $paths = $this->steamBackgroundPaths();
  640.         if (!is_dir($paths['dir'])) {
  641.             @mkdir($paths['dir'], 0775, true);
  642.         }
  644.         $json = json_encode($status, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES | JSON_PRETTY_PRINT);
  645.         if ($json === false) {
  646.             return;
  647.         }
  649.         file_put_contents($paths['status'], $json, LOCK_EX);
  650.     }
  652.     private function emptySteamBackgroundReport(): array
  653.     {
  654.         return [
  655.             'scanned_products' => 0,
  656.             'scanned_games' => 0,
  657.             'updated_products' => 0,
  658.             'updated_games' => 0,
  659.             'failed_count' => 0,
  660.             'failed' => [],
  661.             'failed_ids' => [],
  662.             'failed_truncated' => 0,
  663.             'stopped' => false,
  664.         ];
  665.     }
  667.     private function processIsRunning(int $pid): bool
  668.     {
  669.         if ($pid <= 0) {
  670.             return false;
  671.         }
  673.         if (function_exists('posix_kill')) {
  674.             return @posix_kill($pid, 0);
  675.         }
  677.         $exitCode = 1;
  678.         exec('kill -0 ' . (int) $pid . ' 2>/dev/null', $output, $exitCode);
  680.         return $exitCode === 0;
  681.     }
  683.     private function steamBackgroundStateLabel(string $state): string
  684.     {
  685.         switch ($state) {
  686.             case 'running':
  687.                 return 'Идёт';
  688.             case 'stopping':
  689.                 return 'Останавливается';
  690.             case 'completed':
  691.                 return 'Завершено';
  692.             case 'stopped':
  693.                 return 'Остановлено';
  694.             case 'error':
  695.                 return 'Ошибка';
  696.             default:
  697.                 return 'Ожидает';
  698.         }
  699.     }
  701.     private function steamBackgroundStateClass(string $state): string
  702.     {
  703.         switch ($state) {
  704.             case 'running':
  705.                 return 'primary';
  706.             case 'stopping':
  707.                 return 'warning';
  708.             case 'completed':
  709.                 return 'success';
  710.             case 'stopped':
  711.                 return 'secondary';
  712.             case 'error':
  713.                 return 'danger';
  714.             default:
  715.                 return 'secondary';
  716.         }
  717.     }
  719.     private function isSteamCatalogCategory(string $category): bool
  720.     {
  721.         $category = strtoupper(trim($category));
  723.         return $category === 'STEAM_GIFTS' || $category === 'OTHERS' || strpos($category, 'STEAM_KEYS') === 0;
  724.     }
  726.     private function dashboardStats(Connection $db): array
  727.     {
  728.         $rows = $db->fetchAllAssociative('SELECT id, name, provider, provider_category_code, appid, is_active, in_stock, is_manual, discount_percent, price_amount, price_currency FROM catalog_products');
  729.         $groups = [];
  730.         $delivery = [
  731.             'gifts' => 0,
  732.             'keys' => 0,
  733.             'other' => 0,
  734.         ];
  735.         $active = 0;
  736.         $stock = 0;
  737.         $manual = 0;
  738.         $discounted = 0;
  739.         $sumUsd = 0.0;
  741.         foreach ($rows as $row) {
  742.             $category = strtoupper((string) ($row['provider_category_code'] ?? ''));
  743.             $groups[$this->productStatsGroupKey($row)] = true;
  745.             if (!empty($row['is_active'])) {
  746.                 $active++;
  747.             }
  749.             if (!empty($row['in_stock'])) {
  750.                 $stock++;
  751.             }
  753.             if (!empty($row['is_manual'])) {
  754.                 $manual++;
  755.             }
  757.             if ((float) ($row['discount_percent'] ?? 0) > 0) {
  758.                 $discounted++;
  759.             }
  761.             if ((string) ($row['price_currency'] ?? '') === 'USD') {
  762.                 $sumUsd += (float) ($row['price_amount'] ?? 0);
  763.             }
  765.             if (strpos($category, 'GIFT') !== false) {
  766.                 $delivery['gifts']++;
  767.             } elseif (strpos($category, 'KEY') !== false || $category === 'OTHERS') {
  768.                 $delivery['keys']++;
  769.             } else {
  770.                 $delivery['other']++;
  771.             }
  772.         }
  774.         return [
  775.             'raw_products' => count($rows),
  776.             'catalog_products' => count($groups),
  777.             'active_products' => $active,
  778.             'in_stock' => $stock,
  779.             'manual_products' => $manual,
  780.             'discounted_products' => $discounted,
  781.             'sources' => (int) $db->fetchOne('SELECT COUNT(*) FROM catalog_sources'),
  782.             'categories' => (int) $db->fetchOne('SELECT COUNT(*) FROM catalog_categories'),
  783.             'users' => $this->safeCount($db, 'users'),
  784.             'usd_inventory' => $this->formatMoney($sumUsd, 'USD'),
  785.             'delivery' => $delivery,
  786.         ];
  787.     }
  789.     private function fetchProducts(Connection $db, array $filters, int $perPage): array
  790.     {
  791.         $where = ['1 = 1'];
  792.         $params = [];
  794.         if ($filters['q'] !== '') {
  795.             $where[] = '(LOWER(p.name) LIKE ? OR LOWER(p.external_code) LIKE ? OR p.appid LIKE ?)';
  796.             $needle = '%' . strtolower($filters['q']) . '%';
  797.             $params[] = $needle;
  798.             $params[] = $needle;
  799.             $params[] = '%' . $filters['q'] . '%';
  800.         }
  802.         if ($filters['source'] !== '') {
  803.             $where[] = 'p.source_id = ?';
  804.             $params[] = (int) $filters['source'];
  805.         }
  807.         if ($filters['category'] !== '') {
  808.             $where[] = 'p.category_id = ?';
  809.             $params[] = (int) $filters['category'];
  810.         }
  812.         if ($filters['active'] !== '') {
  813.             $where[] = 'p.is_active = ?';
  814.             $params[] = (int) $filters['active'];
  815.         }
  817.         if ($filters['stock'] !== '') {
  818.             $where[] = 'p.in_stock = ?';
  819.             $params[] = (int) $filters['stock'];
  820.         }
  822.         if ($filters['discount'] === 'yes') {
  823.             $where[] = 'p.discount_percent IS NOT NULL AND p.discount_percent > 0';
  824.         } elseif ($filters['discount'] === 'no') {
  825.             $where[] = '(p.discount_percent IS NULL OR p.discount_percent <= 0)';
  826.         }
  828.         $whereSql = implode(' AND ', $where);
  829.         $total = (int) $db->fetchOne(
  830.             "SELECT COUNT(*) FROM catalog_products p
  831.              LEFT JOIN catalog_categories c ON c.id = p.category_id
  832.              LEFT JOIN catalog_sources s ON s.id = p.source_id
  833.              WHERE {$whereSql}",
  834.             $params
  835.         );
  837.         $page = max(1, (int) $filters['page']);
  838.         $totalPages = max(1, (int) ceil($total / $perPage));
  839.         $page = min($page, $totalPages);
  840.         $offset = ($page - 1) * $perPage;
  842.         $rows = $db->fetchAllAssociative(
  843.             "SELECT p.*, c.name AS category_name, c.type_code AS category_type_code, c.external_code AS category_external_code, s.code AS source_code, s.name AS source_name
  844.              FROM catalog_products p
  845.              LEFT JOIN catalog_categories c ON c.id = p.category_id
  846.              LEFT JOIN catalog_sources s ON s.id = p.source_id
  847.              WHERE {$whereSql}
  848.              ORDER BY p.updated_at DESC, p.id DESC
  849.              LIMIT {$perPage} OFFSET {$offset}",
  850.             $params
  851.         );
  853.         return [
  854.             'items' => array_map([$this, 'decorateProduct'], $rows),
  855.             'pagination' => [
  856.                 'total' => $total,
  857.                 'page' => $page,
  858.                 'per_page' => $perPage,
  859.                 'total_pages' => $totalPages,
  860.                 'from' => $total === 0 ? 0 : $offset + 1,
  861.                 'to' => min($offset + $perPage, $total),
  862.             ],
  863.         ];
  864.     }
  866.     private function fetchProduct(Connection $db, int $id): ?array
  867.     {
  868.         $row = $db->fetchAssociative(
  869.             'SELECT p.*, c.name AS category_name, c.type_code AS category_type_code, c.external_code AS category_external_code, s.code AS source_code, s.name AS source_name
  870.              FROM catalog_products p
  871.              LEFT JOIN catalog_categories c ON c.id = p.category_id
  872.              LEFT JOIN catalog_sources s ON s.id = p.source_id
  873.              WHERE p.id = ? LIMIT 1',
  874.             [$id]
  875.         );
  877.         return $row ?: null;
  878.     }
  880.     private function fetchProductVariants(Connection $db, array $product): array
  881.     {
  882.         $appid = trim((string) ($product['appid'] ?? ''));
  883.         if ($appid !== '') {
  884.             $rows = $db->fetchAllAssociative(
  885.                 'SELECT p.*, c.name AS category_name, s.code AS source_code
  886.                  FROM catalog_products p
  887.                  LEFT JOIN catalog_categories c ON c.id = p.category_id
  888.                  LEFT JOIN catalog_sources s ON s.id = p.source_id
  889.                  WHERE p.appid = ? AND p.id <> ?
  890.                  ORDER BY p.in_stock DESC, p.price_amount ASC, p.id ASC',
  891.                 [$appid, (int) $product['id']]
  892.             );
  894.             return array_map([$this, 'decorateProduct'], $rows);
  895.         }
  897.         $category = (string) ($product['provider_category_code'] ?? $product['category_external_code'] ?? '');
  898.         $titleKey = $this->steamTitleGroupKey((string) ($product['name'] ?? ''));
  899.         if (!$this->isSteamCatalogCategory($category) || $titleKey === '') {
  900.             return [];
  901.         }
  903.         $rows = $db->fetchAllAssociative(
  904.             'SELECT p.*, c.name AS category_name, s.code AS source_code
  905.              FROM catalog_products p
  906.              LEFT JOIN catalog_categories c ON c.id = p.category_id
  907.              LEFT JOIN catalog_sources s ON s.id = p.source_id
  908.              WHERE LOWER(TRIM(p.name)) = ? AND p.id <> ?
  909.                AND (p.provider_category_code = ? OR p.provider_category_code = ? OR p.provider_category_code LIKE ?)
  910.              ORDER BY p.in_stock DESC, p.price_amount ASC, p.id ASC',
  911.             [$titleKey, (int) $product['id'], 'STEAM_GIFTS', 'OTHERS', 'STEAM_KEYS%']
  912.         );
  914.         return array_map([$this, 'decorateProduct'], $rows);
  915.     }
  917.     private function fetchSources(Connection $db): array
  918.     {
  919.         return $db->fetchAllAssociative(
  920.             'SELECT s.*, COALESCE(pc.products_count, 0) AS products_count
  921.              FROM catalog_sources s
  922.              LEFT JOIN (
  923.                  SELECT source_id, COUNT(*) AS products_count
  924.                  FROM catalog_products
  925.                  GROUP BY source_id
  926.              ) pc ON pc.source_id = s.id
  927.              ORDER BY s.name ASC'
  928.         );
  929.     }
  931.     private function fetchCategories(Connection $db): array
  932.     {
  933.         return $db->fetchAllAssociative(
  934.             'SELECT c.*, s.name AS source_name, COALESCE(pc.products_count, 0) AS products_count
  935.              FROM catalog_categories c
  936.              LEFT JOIN catalog_sources s ON s.id = c.source_id
  937.              LEFT JOIN (
  938.                  SELECT category_id, COUNT(*) AS products_count
  939.                  FROM catalog_products
  940.                  GROUP BY category_id
  941.              ) pc ON pc.category_id = c.id
  942.              ORDER BY c.name ASC'
  943.         );
  944.     }
  946.     private function fetchUsers(Connection $db, array $filters, int $perPage): array
  947.     {
  948.         $where = ['1 = 1'];
  949.         $params = [];
  951.         if ($filters['q'] !== '') {
  952.             $where[] = '(LOWER(login) LIKE ? OR LOWER(email) LIKE ? OR LOWER(hash) LIKE ? OR ip LIKE ?)';
  953.             $needle = '%' . strtolower($filters['q']) . '%';
  954.             $params[] = $needle;
  955.             $params[] = $needle;
  956.             $params[] = $needle;
  957.             $params[] = '%' . $filters['q'] . '%';
  958.         }
  960.         $whereSql = implode(' AND ', $where);
  961.         $total = (int) $db->fetchOne("SELECT COUNT(*) FROM users WHERE {$whereSql}", $params);
  962.         $page = max(1, (int) $filters['page']);
  963.         $totalPages = max(1, (int) ceil($total / $perPage));
  964.         $page = min($page, $totalPages);
  965.         $offset = ($page - 1) * $perPage;
  967.         $rows = $db->fetchAllAssociative(
  968.             "SELECT id, login, email, balance, hash, img, auth_token_hash, ip, ref_id, refs, created_at
  969.              FROM users
  970.              WHERE {$whereSql}
  971.              ORDER BY id DESC
  972.              LIMIT {$perPage} OFFSET {$offset}",
  973.             $params
  974.         );
  976.         return [
  977.             'items' => array_map([$this, 'decorateUser'], $rows),
  978.             'pagination' => [
  979.                 'total' => $total,
  980.                 'page' => $page,
  981.                 'per_page' => $perPage,
  982.                 'total_pages' => $totalPages,
  983.                 'from' => $total === 0 ? 0 : $offset + 1,
  984.                 'to' => min($offset + $perPage, $total),
  985.             ],
  986.         ];
  987.     }
  989.     private function fetchUser(Connection $db, int $id): ?array
  990.     {
  991.         $row = $db->fetchAssociative(
  992.             'SELECT id, login, email, balance, hash, img, auth_token_hash, ip, ref_id, refs, created_at
  993.              FROM users
  994.              WHERE id = ? LIMIT 1',
  995.             [$id]
  996.         );
  998.         return $row ?: null;
  999.     }
  1001.     private function saveProduct(Request $request, Connection $db, ?int $id): int
  1002.     {
  1003.         $data = $request->request;
  1004.         $now = $this->now();
  1005.         $price = $this->nullableNumber($data->get('price_amount'));
  1006.         $discount = $this->normalizeDiscount($data->get('discount_percent'));
  1007.         $galleryJson = trim((string) $data->get('gallery_json', ''));
  1008.         $formsJson = trim((string) $data->get('forms_json', ''));
  1009.         $metadataJson = trim((string) $data->get('metadata_json', ''));
  1011.         $this->assertJson($galleryJson, 'Галерея');
  1012.         $this->assertJson($formsJson, 'Формы');
  1013.         $this->assertJson($metadataJson, 'Метаданные');
  1015.         $sourceId = $this->nullableInt($data->get('source_id'));
  1016.         if ($sourceId === null) {
  1017.             $sourceId = $this->ensureManualSource($db);
  1018.         }
  1020.         $categoryId = $this->nullableInt($data->get('category_id'));
  1021.         if ($categoryId === null) {
  1022.             $categoryId = $this->ensureManualCategory($db, $sourceId);
  1023.         }
  1025.         $payload = [
  1026.             'source_id' => $sourceId,
  1027.             'category_id' => $categoryId,
  1028.             'provider' => trim((string) $data->get('provider', 'manual')) ?: 'manual',
  1029.             'provider_type' => trim((string) $data->get('provider_type', 'manual')) ?: null,
  1030.             'provider_category_code' => trim((string) $data->get('provider_category_code', 'MANUAL')) ?: null,
  1031.             'name' => trim((string) $data->get('name', 'Товар PlayPapa')),
  1032.             'short_description_html' => trim((string) $data->get('short_description_html', '')) ?: null,
  1033.             'description_html' => trim((string) $data->get('description_html', '')) ?: null,
  1034.             'image_url' => trim((string) $data->get('image_url', '')) ?: null,
  1035.             'gallery_json' => $galleryJson !== '' ? $galleryJson : '[]',
  1036.             'price_amount' => $price,
  1037.             'price_currency' => strtoupper(trim((string) $data->get('price_currency', 'USD'))) ?: 'USD',
  1038.             'region' => strtoupper(trim((string) $data->get('region', ''))) ?: null,
  1039.             'appid' => trim((string) $data->get('appid', '')) ?: null,
  1040.             'in_stock' => $data->has('in_stock') ? 1 : 0,
  1041.             'stock_quantity' => $this->nullableInt($data->get('stock_quantity')),
  1042.             'promo' => $discount !== null ? 1 : 0,
  1043.             'discount_percent' => $discount,
  1044.             'forms_json' => $formsJson !== '' ? $formsJson : '[]',
  1045.             'metadata_json' => $metadataJson !== '' ? $metadataJson : '[]',
  1046.             'is_active' => $data->has('is_active') ? 1 : 0,
  1047.             'updated_at' => $now,
  1048.         ];
  1050.         if ($id !== null) {
  1051.             $db->update('catalog_products', $payload, ['id' => $id]);
  1053.             return $id;
  1054.         }
  1056.         $externalCode = trim((string) $data->get('external_code', ''));
  1057.         if ($externalCode === '') {
  1058.             $externalCode = 'manual_' . strtolower(bin2hex(random_bytes(5)));
  1059.         }
  1061.         $payload['external_code'] = $externalCode;
  1062.         $payload['slug'] = $this->uniqueSlug($db, (string) $payload['name'] . '-' . $externalCode);
  1063.         $payload['raw_json'] = '[]';
  1064.         $payload['is_manual'] = 1;
  1065.         $payload['is_active'] = $payload['is_active'];
  1066.         $payload['last_synced_at'] = null;
  1067.         $payload['created_at'] = $now;
  1069.         $db->insert('catalog_products', $payload);
  1071.         return (int) $db->lastInsertId();
  1072.     }
  1074.     private function saveUser(Request $request, Connection $db, int $id): void
  1075.     {
  1076.         $data = $request->request;
  1077.         $login = trim((string) $data->get('login', ''));
  1078.         $email = trim((string) $data->get('email', ''));
  1079.         $password = trim((string) $data->get('password', ''));
  1081.         if (mb_strlen($login) < 3 || mb_strlen($login) > 50) {
  1082.             throw new \InvalidArgumentException('Логин должен быть от 3 до 50 символов.');
  1083.         }
  1085.         if (!filter_var($email, FILTER_VALIDATE_EMAIL)) {
  1086.             throw new \InvalidArgumentException('Некорректный e-mail.');
  1087.         }
  1089.         if ($password !== '' && mb_strlen($password) < 6) {
  1090.             throw new \InvalidArgumentException('Новый пароль должен быть не короче 6 символов.');
  1091.         }
  1093.         $duplicate = $db->fetchOne(
  1094.             'SELECT id FROM users WHERE (login = ? OR email = ?) AND id <> ? LIMIT 1',
  1095.             [$login, $email, $id]
  1096.         );
  1097.         if ($duplicate) {
  1098.             throw new \InvalidArgumentException('Такой логин или e-mail уже занят.');
  1099.         }
  1101.         $payload = [
  1102.             'login' => $login,
  1103.             'email' => $email,
  1104.             'balance' => $this->nullableNumber($data->get('balance')) ?? 0,
  1105.             'img' => trim((string) $data->get('img', '')) ?: '/assets/profile.svg',
  1106.             'ip' => trim((string) $data->get('ip', '')),
  1107.             'ref_id' => $this->nullableInt($data->get('ref_id')) ?? 0,
  1108.             'refs' => $this->nullableInt($data->get('refs')) ?? 0,
  1109.         ];
  1111.         if ($password !== '') {
  1112.             $payload['password_hash'] = password_hash($password, PASSWORD_DEFAULT);
  1113.         }
  1115.         if ($data->has('clear_session')) {
  1116.             $payload['auth_token_hash'] = null;
  1117.         }
  1119.         $db->update('users', $payload, ['id' => $id]);
  1120.     }
  1122.     private function persistSource(Request $request, Connection $db): void
  1123.     {
  1124.         $data = $request->request;
  1125.         $id = $this->nullableInt($data->get('id'));
  1126.         $code = strtolower(trim((string) $data->get('code', '')));
  1127.         $code = trim((string) preg_replace('/[^a-z0-9_-]+/', '-', $code), '-');
  1128.         $name = trim((string) $data->get('name', ''));
  1129.         $provider = trim((string) $data->get('provider', ''));
  1130.         $settingsJson = trim((string) $data->get('settings_json', ''));
  1132.         if ($code === '') {
  1133.             $code = $this->slugify($name ?: $provider ?: 'source');
  1134.         }
  1136.         if ($name === '' || $provider === '') {
  1137.             throw new \InvalidArgumentException('У источника должны быть название и provider.');
  1138.         }
  1140.         $this->assertJson($settingsJson, 'Настройки источника');
  1142.         $duplicate = $db->fetchAssociative('SELECT id FROM catalog_sources WHERE code = ? LIMIT 1', [$code]);
  1143.         if ($duplicate && (!$id || (int) $duplicate['id'] !== $id)) {
  1144.             throw new \InvalidArgumentException('Источник с таким code уже существует.');
  1145.         }
  1147.         $payload = [
  1148.             'code' => $code,
  1149.             'name' => $name,
  1150.             'provider' => $provider,
  1151.             'enabled' => $data->has('enabled') ? 1 : 0,
  1152.             'settings_json' => $settingsJson !== '' ? $settingsJson : '[]',
  1153.             'updated_at' => $this->now(),
  1154.         ];
  1156.         if ($id) {
  1157.             $db->update('catalog_sources', $payload, ['id' => $id]);
  1159.             return;
  1160.         }
  1162.         $payload['created_at'] = $this->now();
  1163.         $db->insert('catalog_sources', $payload);
  1164.     }
  1166.     private function persistCategory(Request $request, Connection $db): void
  1167.     {
  1168.         $data = $request->request;
  1169.         $id = $this->nullableInt($data->get('id'));
  1170.         $name = trim((string) $data->get('name', ''));
  1171.         $sourceId = $this->nullableInt($data->get('source_id'));
  1172.         $typeCode = trim((string) $data->get('type_code', '')) ?: 'manual';
  1173.         $externalCode = trim((string) $data->get('external_code', '')) ?: strtoupper($this->slugify($name ?: 'manual'));
  1174.         $slugInput = trim((string) $data->get('slug', ''));
  1176.         if ($name === '') {
  1177.             throw new \InvalidArgumentException('У категории должно быть название.');
  1178.         }
  1180.         $existing = $id ? $db->fetchAssociative('SELECT * FROM catalog_categories WHERE id = ? LIMIT 1', [$id]) : null;
  1181.         $slug = $slugInput !== '' ? $this->slugify($slugInput) : $this->slugify($name . '-' . $typeCode . '-' . $externalCode);
  1182.         if (!$existing || $slug !== (string) $existing['slug']) {
  1183.             $slug = $this->uniqueSlugFor($db, $slug, null, $id);
  1184.         }
  1186.         $payload = [
  1187.             'source_id' => $sourceId,
  1188.             'type_code' => $typeCode,
  1189.             'external_code' => $externalCode,
  1190.             'name' => $name,
  1191.             'slug' => $slug,
  1192.             'description_html' => trim((string) $data->get('description_html', '')) ?: null,
  1193.             'image_url' => trim((string) $data->get('image_url', '')) ?: null,
  1194.             'is_active' => $data->has('is_active') ? 1 : 0,
  1195.             'updated_at' => $this->now(),
  1196.         ];
  1198.         if ($id) {
  1199.             $db->update('catalog_categories', $payload, ['id' => $id]);
  1201.             return;
  1202.         }
  1204.         $payload['raw_json'] = '[]';
  1205.         $payload['is_manual'] = 1;
  1206.         $payload['last_synced_at'] = null;
  1207.         $payload['created_at'] = $this->now();
  1208.         $db->insert('catalog_categories', $payload);
  1209.     }
  1211.     private function decorateProduct(array $row): array
  1212.     {
  1213.         $price = $row['price_amount'] !== null ? (float) $row['price_amount'] : null;
  1214.         $discount = $this->normalizeDiscount($row['discount_percent'] ?? null);
  1215.         $row['price_label'] = $this->formatMoney($price, (string) ($row['price_currency'] ?? 'USD'));
  1216.         $row['discount_label'] = $discount === null ? '' : '−' . rtrim(rtrim(number_format($discount, 2, ',', ' '), '0'), ',') . '%';
  1217.         $row['delivery_label'] = $this->deliveryLabel($row);
  1218.         $row['forms_count'] = count($this->decodeJson((string) ($row['forms_json'] ?? '[]')));
  1219.         $row['gallery_count'] = count($this->decodeJson((string) ($row['gallery_json'] ?? '[]')));
  1220.         $row['product_url'] = '/product?slug=' . rawurlencode((string) ($row['slug'] ?? ''));
  1222.         return $row;
  1223.     }
  1225.     private function decorateUser(array $row): array
  1226.     {
  1227.         $balance = (float) ($row['balance'] ?? 0);
  1228.         $img = trim((string) ($row['img'] ?? ''));
  1229.         $row['img_url'] = $img !== '' ? $img : '/assets/profile.svg';
  1230.         $row['balance_label'] = number_format($balance, 2, ',', ' ');
  1231.         $row['has_session'] = !empty($row['auth_token_hash']);
  1233.         return $row;
  1234.     }
  1236.     private function deliveryLabel(array $row): string
  1237.     {
  1238.         $forms = array_map('strtolower', array_map('strval', $this->decodeJson((string) ($row['forms_json'] ?? '[]'))));
  1239.         $category = strtoupper((string) ($row['provider_category_code'] ?? $row['category_external_code'] ?? ''));
  1240.         $categoryName = strtoupper((string) ($row['category_name'] ?? ''));
  1241.         $text = $category . ' ' . $categoryName;
  1243.         if (in_array('invite_url', $forms, true) || strpos($text, 'GIFT') !== false) {
  1244.             return 'Подарок Steam';
  1245.         }
  1247.         if (strpos($text, 'STEAM') !== false && strpos($text, 'KEY') !== false) {
  1248.             return 'Ключ Steam';
  1249.         }
  1251.         if (strpos($text, 'KEY') !== false) {
  1252.             return 'Цифровой ключ';
  1253.         }
  1255.         if (strpos($text, 'TOPUP') !== false || strpos($text, 'WALLET') !== false) {
  1256.             return 'Пополнение';
  1257.         }
  1259.         return 'Цифровой товар';
  1260.     }
  1262.     private function productStatsGroupKey(array $row): string
  1263.     {
  1264.         $category = (string) ($row['provider_category_code'] ?? '');
  1265.         if (!$this->isSteamCatalogCategory($category)) {
  1266.             return 'product:' . (string) $row['id'];
  1267.         }
  1269.         $appid = trim((string) ($row['appid'] ?? ''));
  1270.         if ($appid !== '') {
  1271.             return 'steam:' . $appid;
  1272.         }
  1274.         $titleKey = $this->steamTitleGroupKey((string) ($row['name'] ?? ''));
  1275.         if ($titleKey !== '') {
  1276.             return 'steam-title:' . $titleKey;
  1277.         }
  1279.         return 'product:' . (string) $row['id'];
  1280.     }
  1282.     private function steamTitleGroupKey(string $name): string
  1283.     {
  1284.         $name = html_entity_decode($name, ENT_QUOTES | ENT_HTML5, 'UTF-8');
  1285.         $name = trim((string) preg_replace('/\s+/', ' ', $name));
  1287.         return $name === '' ? '' : mb_strtolower($name, 'UTF-8');
  1288.     }
  1290.     private function ensureManualSource(Connection $db): int
  1291.     {
  1292.         $existing = $db->fetchOne('SELECT id FROM catalog_sources WHERE code = ? LIMIT 1', ['manual']);
  1293.         if ($existing) {
  1294.             return (int) $existing;
  1295.         }
  1297.         $now = $this->now();
  1298.         $db->insert('catalog_sources', [
  1299.             'code' => 'manual',
  1300.             'name' => 'Manual',
  1301.             'provider' => 'manual',
  1302.             'enabled' => 1,
  1303.             'settings_json' => '[]',
  1304.             'created_at' => $now,
  1305.             'updated_at' => $now,
  1306.         ]);
  1308.         return (int) $db->lastInsertId();
  1309.     }
  1311.     private function ensureManualCategory(Connection $db, int $sourceId): int
  1312.     {
  1313.         $existing = $db->fetchOne('SELECT id FROM catalog_categories WHERE source_id = ? AND external_code = ? LIMIT 1', [$sourceId, 'MANUAL']);
  1314.         if ($existing) {
  1315.             return (int) $existing;
  1316.         }
  1318.         $now = $this->now();
  1319.         $db->insert('catalog_categories', [
  1320.             'source_id' => $sourceId,
  1321.             'type_code' => 'manual',
  1322.             'external_code' => 'MANUAL',
  1323.             'name' => 'Ручные товары',
  1324.             'slug' => $this->uniqueSlug($db, 'manual-products'),
  1325.             'description_html' => null,
  1326.             'image_url' => null,
  1327.             'raw_json' => '[]',
  1328.             'is_manual' => 1,
  1329.             'is_active' => 1,
  1330.             'created_at' => $now,
  1331.             'updated_at' => $now,
  1332.         ]);
  1334.         return (int) $db->lastInsertId();
  1335.     }
  1337.     private function uniqueSlug(Connection $db, string $base): string
  1338.     {
  1339.         return $this->uniqueSlugFor($db, $base, null, null);
  1340.     }
  1342.     private function uniqueSlugFor(Connection $db, string $base, ?int $ignoreProductId, ?int $ignoreCategoryId): string
  1343.     {
  1344.         $slug = $this->slugify($base);
  1345.         $candidate = $slug;
  1346.         $index = 2;
  1348.         while ($this->slugExists($db, $candidate, $ignoreProductId, $ignoreCategoryId)) {
  1349.             $candidate = substr($slug, 0, 245) . '-' . $index;
  1350.             $index++;
  1351.         }
  1353.         return $candidate;
  1354.     }
  1356.     private function slugExists(Connection $db, string $slug, ?int $ignoreProductId, ?int $ignoreCategoryId): bool
  1357.     {
  1358.         $productSql = 'SELECT 1 FROM catalog_products WHERE slug = ?';
  1359.         $productParams = [$slug];
  1360.         if ($ignoreProductId !== null) {
  1361.             $productSql .= ' AND id <> ?';
  1362.             $productParams[] = $ignoreProductId;
  1363.         }
  1365.         if ($db->fetchOne($productSql . ' LIMIT 1', $productParams)) {
  1366.             return true;
  1367.         }
  1369.         $categorySql = 'SELECT 1 FROM catalog_categories WHERE slug = ?';
  1370.         $categoryParams = [$slug];
  1371.         if ($ignoreCategoryId !== null) {
  1372.             $categorySql .= ' AND id <> ?';
  1373.             $categoryParams[] = $ignoreCategoryId;
  1374.         }
  1376.         return (bool) $db->fetchOne($categorySql . ' LIMIT 1', $categoryParams);
  1377.     }
  1379.     private function slugify(string $value): string
  1380.     {
  1381.         $converted = @iconv('UTF-8', 'ASCII//TRANSLIT//IGNORE', $value);
  1382.         $value = is_string($converted) && $converted !== '' ? $converted : $value;
  1383.         $value = strtolower($value);
  1384.         $value = preg_replace('/[^a-z0-9]+/', '-', $value);
  1385.         $value = trim((string) $value, '-');
  1387.         return $value === '' ? 'item' : substr($value, 0, 250);
  1388.     }
  1390.     private function nullableNumber($value): ?float
  1391.     {
  1392.         $value = str_replace(',', '.', trim((string) $value));
  1393.         if ($value === '') {
  1394.             return null;
  1395.         }
  1397.         return round((float) $value, 2);
  1398.     }
  1400.     private function nullableInt($value): ?int
  1401.     {
  1402.         $value = trim((string) $value);
  1404.         return $value === '' ? null : (int) $value;
  1405.     }
  1407.     private function normalizeDiscount($value): ?float
  1408.     {
  1409.         $value = str_replace(',', '.', trim((string) $value));
  1410.         if ($value === '') {
  1411.             return null;
  1412.         }
  1414.         $discount = (float) $value;
  1415.         if ($discount <= 0) {
  1416.             return null;
  1417.         }
  1419.         return min(100.0, round($discount, 2));
  1420.     }
  1422.     private function formatMoney(?float $amount, string $currency): string
  1423.     {
  1424.         if ($amount === null) {
  1425.             return 'Цена уточняется';
  1426.         }
  1428.         $suffix = $currency === 'RUB' ? ' ₽' : ($currency === 'USD' ? ' $' : ' ' . $currency);
  1430.         return number_format($amount, 2, ',', ' ') . $suffix;
  1431.     }
  1433.     private function assertJson(string $value, string $label): void
  1434.     {
  1435.         if ($value === '') {
  1436.             return;
  1437.         }
  1439.         json_decode($value, true);
  1440.         if (json_last_error() !== JSON_ERROR_NONE) {
  1441.             throw new \InvalidArgumentException($label . ': некорректный JSON.');
  1442.         }
  1443.     }
  1445.     private function decodeJson(string $json): array
  1446.     {
  1447.         $decoded = json_decode($json, true);
  1449.         return is_array($decoded) ? $decoded : [];
  1450.     }
  1452.     private function safeCount(Connection $db, string $table): int
  1453.     {
  1454.         try {
  1455.             return (int) $db->fetchOne('SELECT COUNT(*) FROM ' . $table);
  1456.         } catch (\Throwable $error) {
  1457.             return 0;
  1458.         }
  1459.     }
  1461.     private function ensureUsersSchema(Connection $db): void
  1462.     {
  1463.         $platform = $db->getDatabasePlatform()->getName();
  1465.         if (strpos($platform, 'mysql') !== false) {
  1466.             $db->executeStatement(
  1467.                 "CREATE TABLE IF NOT EXISTS users (
  1468.                     id INT AUTO_INCREMENT NOT NULL,
  1469.                     login VARCHAR(50) NOT NULL,
  1470.                     email VARCHAR(180) NOT NULL,
  1471.                     password_hash VARCHAR(255) NOT NULL,
  1472.                     balance DECIMAL(10, 2) NOT NULL DEFAULT 0,
  1473.                     hash VARCHAR(50) NOT NULL,
  1474.                     img VARCHAR(512) NOT NULL DEFAULT '/assets/profile.svg',
  1475.                     auth_token VARCHAR(225) DEFAULT NULL,
  1476.                     auth_token_hash VARCHAR(64) DEFAULT NULL,
  1477.                     ip VARCHAR(50) DEFAULT '',
  1478.                     ref_id INT NOT NULL DEFAULT 0,
  1479.                     refs INT NOT NULL DEFAULT 0,
  1480.                     created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
  1481.                     UNIQUE INDEX uniq_users_login (login),
  1482.                     UNIQUE INDEX uniq_users_email (email),
  1483.                     UNIQUE INDEX uniq_users_hash (hash),
  1484.                     UNIQUE INDEX uniq_users_auth_token_hash (auth_token_hash),
  1485.                     PRIMARY KEY(id)
  1486.                 ) DEFAULT CHARACTER SET utf8mb4 COLLATE `utf8mb4_unicode_ci` ENGINE = InnoDB"
  1487.             );
  1489.             return;
  1490.         }
  1492.         $db->executeStatement(
  1493.             "CREATE TABLE IF NOT EXISTS users (
  1494.                 id INTEGER PRIMARY KEY AUTOINCREMENT,
  1495.                 login VARCHAR(50) NOT NULL UNIQUE,
  1496.                 email VARCHAR(180) NOT NULL UNIQUE,
  1497.                 password_hash VARCHAR(255) NOT NULL,
  1498.                 balance NUMERIC NOT NULL DEFAULT 0,
  1499.                 hash VARCHAR(50) NOT NULL UNIQUE,
  1500.                 img VARCHAR(512) NOT NULL DEFAULT '/assets/profile.svg',
  1501.                 auth_token VARCHAR(225) DEFAULT NULL,
  1502.                 auth_token_hash VARCHAR(64) DEFAULT NULL UNIQUE,
  1503.                 ip VARCHAR(50) DEFAULT '',
  1504.                 ref_id INTEGER NOT NULL DEFAULT 0,
  1505.                 refs INTEGER NOT NULL DEFAULT 0,
  1506.                 created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP
  1507.             )"
  1508.         );
  1509.     }
  1511.     private function emptySource(): array
  1512.     {
  1513.         return [
  1514.             'id' => '',
  1515.             'code' => '',
  1516.             'name' => '',
  1517.             'provider' => 'manual',
  1518.             'enabled' => 1,
  1519.             'settings_json' => '[]',
  1520.             'products_count' => 0,
  1521.         ];
  1522.     }
  1524.     private function emptyCategory(): array
  1525.     {
  1526.         return [
  1527.             'id' => '',
  1528.             'source_id' => '',
  1529.             'type_code' => 'manual',
  1530.             'external_code' => '',
  1531.             'name' => '',
  1532.             'slug' => '',
  1533.             'description_html' => '',
  1534.             'image_url' => '',
  1535.             'is_active' => 1,
  1536.             'products_count' => 0,
  1537.         ];
  1538.     }
  1540.     private function emptyProduct(): array
  1541.     {
  1542.         return [
  1543.             'id' => null,
  1544.             'source_id' => null,
  1545.             'category_id' => null,
  1546.             'external_code' => '',
  1547.             'provider' => 'manual',
  1548.             'provider_type' => 'manual',
  1549.             'provider_category_code' => 'MANUAL',
  1550.             'name' => '',
  1551.             'slug' => '',
  1552.             'short_description_html' => '',
  1553.             'description_html' => '',
  1554.             'image_url' => '',
  1555.             'gallery_json' => '[]',
  1556.             'price_amount' => '',
  1557.             'price_currency' => 'USD',
  1558.             'region' => '',
  1559.             'appid' => '',
  1560.             'in_stock' => 1,
  1561.             'stock_quantity' => '',
  1562.             'discount_percent' => '',
  1563.             'forms_json' => '[]',
  1564.             'metadata_json' => '[]',
  1565.             'is_active' => 1,
  1566.             'is_manual' => 1,
  1567.             'category_name' => 'Ручные товары',
  1568.             'source_name' => 'Manual',
  1569.             'delivery_label' => 'Цифровой товар',
  1570.             'price_label' => 'Цена уточняется',
  1571.             'discount_label' => '',
  1572.             'gallery_count' => 0,
  1573.             'forms_count' => 0,
  1574.         ];
  1575.     }
  1577.     private function now(): string
  1578.     {
  1579.         return (new \DateTimeImmutable())->format('Y-m-d H:i:s');
  1580.     }
  1582.     private function nowIso(): string
  1583.     {
  1584.         return (new \DateTimeImmutable())->format(\DateTimeInterface::ATOM);
  1585.     }
  1586. }