Symfony Profiler

<?php
namespace Customize\Controller\Admin\Product;
use Customize\Service\ScraperService;
use Eccube\Controller\AbstractController;
use Sensio\Bundle\FrameworkExtraBundle\Configuration\Template;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\Routing\Annotation\Route;
/**
* Admin controller for launching scraper processes and monitoring progress.
*/
class SpreadsheetImportController extends AbstractController
{
/** @var ScraperService */
private $scraperService;
/** @var array */
private static $categoryLabels = [
'cp' => 'カーポート',
'cy' => 'サイクルポート',
'cg' => 'カーゲート',
'sh' => 'ガレージシャッター',
'wd' => 'ウッドデッキ',
'rs' => '立水栓・ガーデンシンク',
'gf' => 'ガーデンファニチャー',
'tf' => '人工芝・芝生',
'fe' => 'フェンス・柵・塀',
'ts' => '手すり',
'mp' => '門扉',
'fu' => 'ポスト・門柱・宅配ボックス',
'tr' => 'テラス屋根',
'tg' => 'テラス囲い・サンルーム',
'br' => 'バルコニー屋根',
'bl' => 'バルコニー・ベランダ',
'aw' => 'オーニング・日よけ',
'pg' => 'パーゴラ',
'mo' => '物置・収納・屋外倉庫',
'sy' => 'ストックヤード',
'gs' => 'ゴミステーション',
'wh' => '倉庫・ガレージ',
'um' => '二重窓（内窓）',
'ws' => '窓シャッター',
'mk' => '面格子・窓格子',
'fj' => '風除室・玄関フード',
'rd' => '玄関ドア',
'st' => '石材',
'sl' => '照明',
'dy' => 'DIY',
];
public function __construct(ScraperService $scraperService)
{
$this->scraperService = $scraperService;
}
/**
* Main page with buttons for product and price scraping.
*
* @Route("/%eccube_admin_route%/product/scraper", name="admin_product_scraper", methods={"GET"})
* @Template("@admin/Product/scraper.twig")
*/
public function index()
{
return [
'categories' => self::$categoryLabels,
'runningJobs' => $this->scraperService->getRunningJobs(),
'spreadsheetLinks' => $this->scraperService->getSpreadsheetLinks(),
];
}
/**
* Start product scraper (basic data).
*
* @Route("/%eccube_admin_route%/product/scraper/start_product", name="admin_product_scraper_start_product", methods={"POST"})
*/
public function startProduct(Request $request): JsonResponse
{
if (!$this->isTokenValid()) {
return $this->json(['error' => 'Invalid CSRF token'], 403);
}
if ($this->scraperService->isProductLocked()) {
return $this->json(['error' => '基本データ取込は既に実行中です'], 409);
}
$result = $this->scraperService->startProductScraper();
if ($result) {
return $this->json(['status' => 'started', 'message' => '基本データ取込を開始しました']);
}
return $this->json(['error' => '開始できませんでした'], 500);
}
/**
* Start price scraper for a specific category.
*
* @Route("/%eccube_admin_route%/product/scraper/start_price", name="admin_product_scraper_start_price", methods={"POST"})
*/
public function startPrice(Request $request): JsonResponse
{
if (!$this->isTokenValid()) {
return $this->json(['error' => 'Invalid CSRF token'], 403);
}
$category = $request->request->get('category', '');
if (!$category || !isset(self::$categoryLabels[$category])) {
return $this->json(['error' => '無効なカテゴリです'], 400);
}
if ($this->scraperService->isPriceLocked($category)) {
$label = self::$categoryLabels[$category];
return $this->json(['error' => "{$label} の価格マトリクス取込は既に実行中です"], 409);
}
$maker = $request->request->get('maker');
$result = $this->scraperService->startPriceScraper($category, $maker ?: null);
if ($result) {
$label = self::$categoryLabels[$category];
return $this->json(['status' => 'started', 'message' => "{$label} の価格マトリクス取込を開始しました"]);
}
return $this->json(['error' => '開始できませんでした'], 500);
}
/**
* Get current status of all scrapers (AJAX polling endpoint).
*
* @Route("/%eccube_admin_route%/product/scraper/status", name="admin_product_scraper_status", methods={"GET"})
*/
public function status(): JsonResponse
{
$product = $this->scraperService->getProductProgress();
$productLocked = $this->scraperService->isProductLocked();
// Collect price statuses for all categories
$priceStatuses = [];
foreach (self::$categoryLabels as $cat => $label) {
$locked = $this->scraperService->isPriceLocked($cat);
$progress = $this->scraperService->getPriceProgress($cat);
if ($locked || $progress) {
$priceStatuses[$cat] = [
'locked' => $locked,
'progress' => $progress,
];
}
}
return $this->json([
'product' => [
'locked' => $productLocked,
'progress' => $product,
],
'price' => $priceStatuses,
]);
}
/**
* Get execution log for a scraper (for debugging).
*
* @Route("/%eccube_admin_route%/product/scraper/log", name="admin_product_scraper_log", methods={"GET"})
*/
public function log(Request $request): JsonResponse
{
$type = $request->query->get('type', 'product');
$category = $request->query->get('category', '');
if ($type === 'product') {
return $this->json([
'log' => $this->scraperService->getProductLog(200),
'debug' => $this->scraperService->getDebugInfo(),
]);
}
if ($type === 'price' && $category) {
return $this->json([
'log' => $this->scraperService->getPriceLog($category, 200),
'debug' => $this->scraperService->getDebugInfo(),
]);
}
return $this->json(['error' => 'invalid type/category'], 400);
}
/**
* Cancel a running scraper.
*
* @Route("/%eccube_admin_route%/product/scraper/cancel", name="admin_product_scraper_cancel", methods={"POST"})
*/
public function cancel(Request $request): JsonResponse
{
if (!$this->isTokenValid()) {
return $this->json(['error' => 'Invalid CSRF token'], 403);
}
$type = $request->request->get('type', '');
$category = $request->request->get('category', '');
if ($type === 'product') {
$this->scraperService->cancelProduct();
return $this->json(['status' => 'cancelled', 'message' => '基本データ取込をキャンセルしました']);
}
if ($type === 'price' && $category) {
$this->scraperService->cancelPrice($category);
$label = self::$categoryLabels[$category] ?? $category;
return $this->json(['status' => 'cancelled', 'message' => "{$label} の価格マトリクス取込をキャンセルしました"]);
}
return $this->json(['error' => '無効なリクエスト'], 400);
}
}

app/Customize/Controller/Admin/Product/SpreadsheetImportController.php line 133