app/Plugin/PiaHistory/EventSubscriber/ProductEditEventSubscriber.php line 158

Open in your IDE?
  1. <?php
  3. namespace Plugin\PiaHistory\EventSubscriber;
  5. use Eccube\Entity\Product;
  6. use Eccube\Repository\ProductRepository;
  7. use Eccube\Repository\MemberRepository;
  8. use Doctrine\ORM\EntityManagerInterface;
  9. use Plugin\PiaHistory\Entity\PiaHistory;
  10. use Plugin\PiaHistory\Entity\PiaHisProduct;
  11. use Plugin\PiaHistory\Entity\PiaHisProductClass;
  12. use Plugin\PiaHistory\Entity\PiaHisProductCategory;
  13. use Plugin\PiaHistory\Entity\PiaHisProductImage;
  14. use Plugin\PiaHistory\Entity\PiaHisProductStock;
  15. use Plugin\PiaHistory\Entity\PiaHisProductTag;
  16. use Plugin\PiaHistory\Entity\PiaHisProductAdd;
  17. use Plugin\PiaHistory\Entity\PiaHisRankPrice;
  18. use Plugin\PiaHistory\Entity\PiaHisCustomerClass;
  19. use Plugin\PiaHistory\Entity\PiaHisPoint;
  20. use Plugin\PiaHistory\Entity\PiaHisMeyasu;
  21. use Plugin\PiaHistory\Repository\PiaHistoryRepository;
  22. use Plugin\PiaHistory\Repository\PiaHisProductRepository;
  23. use Plugin\PiaHistory\Repository\PiaHisProductClassRepository;
  24. use Plugin\PiaHistory\Repository\PiaHisProductCategoryRepository;
  25. use Plugin\PiaHistory\Repository\PiaHisProductImageRepository;
  26. use Plugin\PiaHistory\Repository\PiaHisProductStockRepository;
  27. use Plugin\PiaHistory\Repository\PiaHisProductTagRepository;
  28. use Plugin\PiaHistory\Repository\PiaHisProductAddRepository;
  29. use Plugin\PiaHistory\Repository\PiaHisRankPriceRepository;
  30. use Plugin\PiaHistory\Repository\PiaHisCustomerClassRepository;
  31. use Plugin\PiaHistory\Repository\PiaHisPointRepository;
  32. use Plugin\PiaHistory\Repository\PiaHisMeyasuRepository;
  33. use Eccube\Event\EccubeEvents;
  34. use Eccube\Event\EventArgs;
  35. use Symfony\Component\HttpFoundation\RequestStack;
  36. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  37. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  38. use Symfony\Component\HttpKernel\Event\RequestEvent;
  40. class ProductEditEventSubscriber implements EventSubscriberInterface
  41. {
  42.     private $piaHistoryRepository;
  43.     private $piaHisProductRepository;
  44.     private $piaHisProductClassRepository;
  45.     private $piaHisProductCategoryRepository;
  46.     private $piaHisProductImageRepository;
  47.     private $piaHisProductStockRepository;
  48.     private $piaHisProductTagRepository;
  49.     private $piaHisProductAddRepository;
  50.     private $piaHisRankPriceRepository;
  51.     private $piaHisCustomerClassRepository;
  52.     private $piaHisPointRepository;
  53.     private $piaHisMeyasuRepository;
  54.     private $productRepository;
  55.     private $memberRepository;
  56.     private $tokenStorage;
  57.     private $entityManager;
  58.     private $requestStack;
  60.     // 商品基本情報のフィールドラベル（updateNote生成用）
  61.     private static $basicFieldLabels = [
  62.         'name'               => '商品名',
  63.         'note'               => 'ショップ用メモ欄',
  64.         'description_list'   => '商品一覧コメント',
  65.         'description_detail' => '商品説明',
  66.         'search_word'        => '検索ワード',
  67.         'free_area'          => 'フリーエリア',
  68.         'status'             => '商品ステータス',
  69.         'datetime_start'     => '表示設定日時（開始）',
  70.         'datetime_end'       => '表示設定日時（終了）',
  71.     ];
  73.     // 商品規格フィールドのラベル（updateNote生成用）
  74.     private static $classFieldLabels = [
  75.         'price02' => '販売価格',
  76.         'price01' => '通常価格',
  77.         'stock'   => '在庫',
  78.     ];
  80.     public function __construct(
  81.         PiaHistoryRepository $piaHistoryRepository,
  82.         PiaHisProductRepository $piaHisProductRepository,
  83.         PiaHisProductClassRepository $piaHisProductClassRepository,
  84.         PiaHisProductCategoryRepository $piaHisProductCategoryRepository,
  85.         PiaHisProductImageRepository $piaHisProductImageRepository,
  86.         PiaHisProductStockRepository $piaHisProductStockRepository,
  87.         PiaHisProductTagRepository $piaHisProductTagRepository,
  88.         PiaHisProductAddRepository $piaHisProductAddRepository,
  89.         PiaHisRankPriceRepository $piaHisRankPriceRepository,
  90.         PiaHisCustomerClassRepository $piaHisCustomerClassRepository,
  91.         PiaHisPointRepository $piaHisPointRepository,
  92.         PiaHisMeyasuRepository $piaHisMeyasuRepository,
  93.         ProductRepository $productRepository,
  94.         MemberRepository $memberRepository,
  95.         TokenStorageInterface $tokenStorage,
  96.         EntityManagerInterface $entityManager,
  97.         RequestStack $requestStack
  98.     ) {
  99.         $this->piaHistoryRepository = $piaHistoryRepository;
  100.         $this->piaHisProductRepository = $piaHisProductRepository;
  101.         $this->piaHisProductClassRepository = $piaHisProductClassRepository;
  102.         $this->piaHisProductCategoryRepository = $piaHisProductCategoryRepository;
  103.         $this->piaHisProductImageRepository = $piaHisProductImageRepository;
  104.         $this->piaHisProductStockRepository = $piaHisProductStockRepository;
  105.         $this->piaHisProductTagRepository = $piaHisProductTagRepository;
  106.         $this->piaHisProductAddRepository = $piaHisProductAddRepository;
  107.         $this->piaHisRankPriceRepository = $piaHisRankPriceRepository;
  108.         $this->piaHisCustomerClassRepository = $piaHisCustomerClassRepository;
  109.         $this->piaHisPointRepository = $piaHisPointRepository;
  110.         $this->piaHisMeyasuRepository = $piaHisMeyasuRepository;
  111.         $this->productRepository = $productRepository;
  112.         $this->memberRepository = $memberRepository;
  113.         $this->tokenStorage = $tokenStorage;
  114.         $this->entityManager = $entityManager;
  115.         $this->requestStack = $requestStack;
  116.     }
  118.     public static function getSubscribedEvents()
  119.     {
  120.         return [
  121.             'kernel.request' => ['onKernelRequest', 0],
  122.             EccubeEvents::ADMIN_PRODUCT_EDIT_COMPLETE => ['onProductEditComplete', -1000],
  123.         ];
  124.     }
  126.     /**
  127.      * 商品編集画面のPOSTリクエストを検知して変更前の値を保存
  128.      */
  129.     public function onKernelRequest(RequestEvent $event)
  130.     {
  131.         $request = $event->getRequest();
  133.         if ($request->isMethod('POST') &&
  134.             $request->attributes->get('_route') === 'admin_product_product_edit') {
  136.             $productId = $request->get('id');
  137.             error_log('PiaHistory: onKernelRequest - Product ID: ' . $productId);
  139.             if ($productId) {
  140.                 $this->saveProductBeforeData($productId);
  141.             }
  142.         }
  143.     }
  145.     public function onProductEditComplete(EventArgs $event)
  146.     {
  147.         error_log('PiaHistory: onProductEditComplete called');
  148.         $Product = $event->getArgument('Product');
  149.         if ($Product && $Product->getId()) {
  150.             $this->saveProductHistory($Product->getId());
  151.         }
  152.     }
  154.     // -------------------------------------------------------------------------
  155.     // 変更前データをセッションに保存
  156.     // -------------------------------------------------------------------------
  158.     private function saveProductBeforeData($productId)
  159.     {
  160.         try {
  161.             $product = $this->productRepository->find($productId);
  162.             if (!$product) {
  163.                 return;
  164.             }
  166.             $request = $this->requestStack->getCurrentRequest();
  167.             if (!$request) {
  168.                 return;
  169.             }
  171.             $session = $request->getSession();
  173.             $beforeData = [
  174.                 'product'            => $this->buildProductSnapshot($product),
  175.                 'product_classes'    => $this->buildProductClassesSnapshot($product),
  176.                 'product_categories' => $this->buildProductCategoriesSnapshot($product),
  177.                 'product_images'     => $this->buildProductImagesSnapshot($product),
  178.                 'product_tags'       => $this->buildProductTagsSnapshot($product),
  179.                 'rank_prices'        => $this->buildRankPricesSnapshot($product),
  180.                 'product_add'        => $this->buildProductAddSnapshot($product),
  181.             ];
  183.             $session->set('pia_history_before_data_' . $productId, $beforeData);
  185.         } catch (\Exception $e) {
  186.             error_log('PiaHistory: 変更前データ保存エラー - ' . $e->getMessage());
  187.         }
  188.     }
  190.     /** 商品基本情報スナップショット */
  191.     private function buildProductSnapshot(Product $product): array
  192.     {
  193.         return [
  194.             'id'                 => $product->getId(),
  195.             'name'               => $product->getName(),
  196.             'note'               => $product->getNote(),
  197.             'description_list'   => $product->getDescriptionList(),
  198.             'description_detail' => $product->getDescriptionDetail(),
  199.             'search_word'        => $product->getSearchWord(),
  200.             'free_area'          => $product->getFreeArea(),
  201.             'status'             => $product->getStatus() ? $product->getStatus()->getId() : null,
  202.             'datetime_start'     => $this->getDisplayStartDate($product),
  203.             'datetime_end'       => $this->getDisplayEndDate($product),
  204.         ];
  205.     }
  207.     /**
  208.      * 商品規格スナップショット（変更検知で比較するフィールドのみ）
  209.      *
  210.      * price01/price02 は会員別価格（buildRankPricesSnapshot）と同じ理由で、
  211.      * DBから読み込んだ直後と同一リクエスト内でセットされた直後とで小数点以下の表記が
  212.      * 食い違うことがあるため、normalizePriceString() で正規化してから比較する（2026-08-28）。
  213.      */
  214.     private function buildProductClassesSnapshot(Product $product): array
  215.     {
  216.         $data = [];
  217.         foreach ($product->getProductClasses() as $pc) {
  218.             $data[] = [
  219.                 'id'       => $pc->getId(),
  220.                 'code'     => $pc->getCode(),
  221.                 'price01'  => $this->normalizePriceString($pc->getPrice01()),
  222.                 'price02'  => $this->normalizePriceString($pc->getPrice02()),
  223.                 'stock'    => $pc->isStockUnlimited() ? null : (string)$pc->getStock(),
  224.             ];
  225.         }
  226.         return $data;
  227.     }
  229.     /**
  230.      * 商品カテゴリースナップショット（比較用）
  231.      *
  232.      * EC-CUBE4の ProductCategory には並び順を保持するカラムが無く
  233.      * getProductCategories() の取得順序は保存の度に入れ替わりうる。
  234.      * 取得順インデックスを比較に使うと、実際は同じカテゴリー構成でも
  235.      * 「変更あり」に誤検知するため、category_id をソートした集合として比較する
  236.      * （2026-08-28修正）。
  237.      */
  238.     private function buildProductCategoriesSnapshot(Product $product): array
  239.     {
  240.         $ids = [];
  241.         foreach ($product->getProductCategories() as $pc) {
  242.             $ids[] = $pc->getCategory()->getId();
  243.         }
  244.         sort($ids);
  245.         return $ids;
  246.     }
  248.     /** 商品画像スナップショット */
  249.     private function buildProductImagesSnapshot(Product $product): array
  250.     {
  251.         $data = [];
  252.         foreach ($product->getProductImage() as $i => $img) {
  253.             $data[] = [
  254.                 'file_name' => $img->getFileName(),
  255.                 'rank'      => $img->getSortNo() ?: ($i + 1),
  256.             ];
  257.         }
  258.         return $data;
  259.     }
  261.     /** 商品タグスナップショット */
  262.     private function buildProductTagsSnapshot(Product $product): array
  263.     {
  264.         $data = [];
  265.         foreach ($product->getProductTag() as $pt) {
  266.             $data[] = ['tag_id' => $pt->getTag()->getId()];
  267.         }
  268.         return $data;
  269.     }
  271.     /** 会員別価格スナップショット（CustomerRank42） */
  272.     private function buildRankPricesSnapshot(Product $product): array
  273.     {
  274.         $data = [];
  275.         if (!class_exists('Plugin\CustomerRank42\Entity\CustomerPrice')) {
  276.             return $data;
  277.         }
  278.         try {
  279.             $repo = $this->entityManager->getRepository('Plugin\CustomerRank42\Entity\CustomerPrice');
  280.             foreach ($product->getProductClasses() as $pc) {
  281.                 $prices = $repo->findBy(['ProductClass' => $pc]);
  282.                 foreach ($prices as $cp) {
  283.                     $data[] = [
  284.                         'product_class_id' => $pc->getId(),
  285.                         'product_code'     => $pc->getCode(),
  286.                         'rank_id'          => $cp->getCustomerRank()->getId(),
  287.                         'rank_name'        => $cp->getCustomerRank()->getName(),
  288.                         // DBから読み込んだ直後は "17523.00"、同一リクエスト内でフォーム経由で
  289.                         // セットされた直後は "17523" のように小数点以下の表記が食い違うことがあり、
  290.                         // 単純な文字列比較では実際は無変更なのに「変更あり」と誤検知していた。
  291.                         // 数値として正規化してから文字列化することで表記を統一する（2026-08-28）。
  292.                         'price'            => $this->normalizePriceString($cp->getPrice()),
  293.                     ];
  294.                 }
  295.             }
  296.         } catch (\Exception $e) {
  297.             error_log('PiaHistory: 会員別価格スナップショットエラー - ' . $e->getMessage());
  298.         }
  299.         return $data;
  300.     }
  302.     /**
  303.      * 金額の比較用正規化。
  304.      *
  305.      * Doctrineの decimal 型は、DBから読み込んだ直後（例: "17523.00"）と、
  306.      * 同一リクエスト内でフォーム処理等により新たにセットされた直後（例: "17523"）とで
  307.      * 小数点以下の桁数表記が食い違うことがある。数値としては同じでも文字列としては
  308.      * 別物になり、厳密比較で誤検知する原因になっていた（2026-08-28）。
  309.      */
  310.     private function normalizePriceString($value): ?string
  311.     {
  312.         if ($value === null || $value === '') {
  313.             return null;
  314.         }
  315.         return number_format((float)$value, 2, '.', '');
  316.     }
  318.     /** 商品追加項目スナップショット（ProductPlus42） */
  319.     private function buildProductAddSnapshot(Product $product): array
  320.     {
  321.         $data = [];
  322.         if (!class_exists('Plugin\ProductPlus42\Entity\ProductData')) {
  323.             return $data;
  324.         }
  325.         try {
  326.             $repo = $this->entityManager->getRepository('Plugin\ProductPlus42\Entity\ProductData');
  327.             $productDatas = $repo->findBy(['Product' => $product]);
  328.             foreach ($productDatas as $pd) {
  329.                 $item = $pd->getProductItem();
  330.                 if (!$item) {
  331.                     continue;
  332.                 }
  333.                 $data[] = [
  334.                     'item_id'   => $item->getId(),
  335.                     'item_name' => $item->getName(),
  336.                     'value'     => $pd->getDataValue(),
  337.                 ];
  338.             }
  339.         } catch (\Exception $e) {
  340.             error_log('PiaHistory: 商品追加項目スナップショットエラー - ' . $e->getMessage());
  341.         }
  342.         return $data;
  343.     }
  345.     // -------------------------------------------------------------------------
  346.     // 履歴保存メイン
  347.     // -------------------------------------------------------------------------
  349.     private function saveProductHistory($productId)
  350.     {
  351.         try {
  352.             error_log('PiaHistory: saveProductHistory called for Product ID: ' . $productId);
  354.             if (!$this->entityManager->isOpen()) {
  355.                 error_log('PiaHistory: EntityManager is closed, skipping history save');
  356.                 return;
  357.             }
  359.             $product = $this->productRepository->find($productId);
  360.             if (!$product) {
  361.                 return;
  362.             }
  364.             $request = $this->requestStack->getCurrentRequest();
  365.             if (!$request) {
  366.                 return;
  367.             }
  369.             $session  = $request->getSession();
  370.             $beforeData = $session->get('pia_history_before_data_' . $productId);
  372.             if (!$beforeData) {
  373.                 return;
  374.             }
  376.             // 変更検知
  377.             $changes = $this->detectDetailedChanges($product, $beforeData);
  378.             error_log('PiaHistory: Changes detected: ' . (empty($changes) ? 'NO' : 'YES'));
  380.             if (empty($changes)) {
  381.                 $session->remove('pia_history_before_data_' . $productId);
  382.                 return;
  383.             }
  385.             // updateNote / updateNum を生成
  386.             ['num' => $num, 'note' => $note] = $this->generateUpdateNote($changes);
  388.             // 管理者情報を取得
  389.             [$adminId, $adminName, $adminDepartment] = $this->getAdminInfo();
  391.             $this->entityManager->beginTransaction();
  393.             // 履歴メイン登録
  394.             $history = new PiaHistory();
  395.             $history->setProductId($productId);
  396.             $history->setUpdateId($adminId);
  397.             $history->setUpdateName($adminName);
  398.             $history->setUpdateDepartment($adminDepartment);
  399.             $history->setUpdateNum($num);
  400.             $history->setUpdateNote($note);
  401.             $history->setCreateDate(new \DateTime());
  402.             $history->setUpdateDate(new \DateTime());
  403.             $history->setDelFlg(0);
  405.             $this->entityManager->persist($history);
  406.             $this->entityManager->flush();
  408.             $historyId = $history->getId();
  410.             // 各詳細テーブルへの保存
  411.             // 商品基本情報＋カテゴリー変更（カテゴリーの前後は詳細画面表示用にJSONへ同梱する。
  412.             // 2026-08-28: カテゴリーは1つ前の履歴レコードとの突き合わせが不確実なため、
  413.             // 商品基本情報と同じ「保存時点でbefore/afterを直接保存」方式に統一した）
  414.             $basicChangedFields = $changes['product'] ?? [];
  415.             if (isset($changes['product_categories'])) {
  416.                 $basicChangedFields['__categories'] = [
  417.                     'before' => $changes['product_categories']['before'],
  418.                     'after'  => $changes['product_categories']['after'],
  419.                 ];
  420.             }
  421.             if (!empty($basicChangedFields)) {
  422.                 $this->saveProductBasicHistory($historyId, $product, $basicChangedFields);
  423.             }
  425.             if (isset($changes['product_classes'])) {
  426.                 $this->saveProductClassHistory($historyId, $product);
  427.             }
  429.             if (isset($changes['product_categories'])) {
  430.                 $this->saveProductCategoryHistory($historyId, $product);
  431.             }
  433.             if (isset($changes['product_images'])) {
  434.                 $this->saveProductImageHistory($historyId, $product);
  435.             }
  437.             if (isset($changes['product_tags'])) {
  438.                 $this->saveProductTagHistory($historyId, $product);
  439.             }
  441.             // 在庫は常に現状を保存
  442.             $this->saveProductStockHistory($historyId, $product);
  444.             // 会員別価格（変更があった場合のみ。判定・updateNote生成と同じ$currentRankPricesを使う）
  445.             if (isset($changes['rank_prices'])) {
  446.                 $this->saveRankPriceHistory($historyId, $beforeData['rank_prices'] ?? [], $changes['rank_prices']['after']);
  447.             }
  449.             // 商品追加項目（変更があった場合のみ）
  450.             if (isset($changes['product_add'])) {
  451.                 $this->saveProductAddHistory($historyId, $product);
  452.             }
  454.             // 目安価格
  455.             $this->saveMeyasuHistory($historyId, $product);
  457.             $this->entityManager->flush();
  458.             $this->entityManager->commit();
  460.             $session->remove('pia_history_before_data_' . $productId);
  462.         } catch (\Throwable $e) {
  463.             if ($this->entityManager->getConnection()->isTransactionActive()) {
  464.                 $this->entityManager->rollback();
  465.             }
  466.             error_log('PiaHistory: 商品履歴保存エラー - ' . $e->getMessage());
  467.         }
  468.     }
  470.     // -------------------------------------------------------------------------
  471.     // 変更検知
  472.     // -------------------------------------------------------------------------
  474.     private function detectDetailedChanges(Product $product, array $beforeData): array
  475.     {
  476.         $changes = [];
  478.         // 基本情報
  479.         // null と空文字、改行コードの違いだけの「実質的に変更なし」を誤検知しないよう、
  480.         // 比較は正規化した値で行う（status/日時は元の値のまま比較）（2026-08-28修正）
  481.         $currentProduct = $this->buildProductSnapshot($product);
  482.         $diffFields = [];
  483.         foreach (array_keys(self::$basicFieldLabels) as $field) {
  484.             $beforeVal = $beforeData['product'][$field] ?? null;
  485.             $afterVal  = $currentProduct[$field] ?? null;
  487.             $beforeCmp = in_array($field, ['status', 'datetime_start', 'datetime_end'], true)
  488.                 ? $beforeVal
  489.                 : $this->normalizeTextForCompare($beforeVal);
  490.             $afterCmp = in_array($field, ['status', 'datetime_start', 'datetime_end'], true)
  491.                 ? $afterVal
  492.                 : $this->normalizeTextForCompare($afterVal);
  494.             if ($beforeCmp !== $afterCmp) {
  495.                 $diffFields[$field] = [
  496.                     'before' => $beforeVal,
  497.                     'after'  => $afterVal,
  498.                 ];
  499.             }
  500.         }
  501.         if (!empty($diffFields)) {
  502.             $changes['product'] = $diffFields;
  503.         }
  505.         // 商品規格（同一フィールド構造で比較）
  506.         $currentClasses = $this->buildProductClassesSnapshot($product);
  507.         if ($currentClasses !== ($beforeData['product_classes'] ?? [])) {
  508.             $changes['product_classes'] = [
  509.                 'before' => $beforeData['product_classes'] ?? [],
  510.                 'after'  => $currentClasses,
  511.             ];
  512.         }
  514.         // カテゴリー
  515.         $currentCategories = $this->buildProductCategoriesSnapshot($product);
  516.         if ($currentCategories !== ($beforeData['product_categories'] ?? [])) {
  517.             $changes['product_categories'] = [
  518.                 'before' => $beforeData['product_categories'] ?? [],
  519.                 'after'  => $currentCategories,
  520.             ];
  521.         }
  523.         // 画像
  524.         $currentImages = $this->buildProductImagesSnapshot($product);
  525.         if ($currentImages !== ($beforeData['product_images'] ?? [])) {
  526.             $changes['product_images'] = [
  527.                 'before' => $beforeData['product_images'] ?? [],
  528.                 'after'  => $currentImages,
  529.             ];
  530.         }
  532.         // タグ
  533.         $currentTags = $this->buildProductTagsSnapshot($product);
  534.         if ($currentTags !== ($beforeData['product_tags'] ?? [])) {
  535.             $changes['product_tags'] = [
  536.                 'before' => $beforeData['product_tags'] ?? [],
  537.                 'after'  => $currentTags,
  538.             ];
  539.         }
  541.         // 会員別価格（CustomerRank42）
  542.         // 「現在の会員別価格」は判定・updateNote生成・保存の3箇所で使うため、ここで1回だけ取得して
  543.         // 使い回す（2026-08-28）。
  544.         $currentRankPrices = $this->buildRankPricesSnapshot($product);
  545.         $changedRankPrices = $this->detectRankPriceChanges($beforeData['rank_prices'] ?? [], $currentRankPrices);
  546.         if (!empty($changedRankPrices)) {
  547.             $changes['rank_prices'] = [
  548.                 'before'  => $beforeData['rank_prices'] ?? [],
  549.                 'after'   => $currentRankPrices,
  550.                 'changed' => $changedRankPrices,
  551.             ];
  552.         }
  554.         // 商品追加項目（ProductPlus42）
  555.         $changedProductAdd = $this->detectProductAddChanges($product, $beforeData['product_add'] ?? []);
  556.         if (!empty($changedProductAdd)) {
  557.             $changes['product_add'] = [
  558.                 'before'  => $beforeData['product_add'] ?? [],
  559.                 'after'   => $this->buildProductAddSnapshot($product),
  560.                 'changed' => $changedProductAdd,
  561.             ];
  562.         }
  564.         return $changes;
  565.     }
  567.     /**
  568.      * テキスト系フィールドの比較用正規化
  569.      *
  570.      * null と空文字は同じ「未入力」として扱い、改行コード（\r\n / \r）は \n に統一する。
  571.      * これを行わずに厳密比較すると、フォーム送信時に null が空文字として保存される等の
  572.      * 型の違いだけで「変更あり」と誤検知してしまう（2026-08-28、商品説明・ショップ用メモ欄等で確認）。
  573.      */
  574.     private function normalizeTextForCompare($value): string
  575.     {
  576.         if ($value === null) {
  577.             return '';
  578.         }
  579.         $value = str_replace(["\r\n", "\r"], "\n", (string)$value);
  580.         return trim($value);
  581.     }
  583.     /**
  584.      * 会員別価格の変更検知
  585.      *
  586.      * $currentRankPrices は呼び出し側（detectDetailedChanges）で1回だけ取得したものを渡す
  587.      * （保存処理・updateNote生成と同じ値を必ず使うため。2026-08-28）。
  588.      */
  589.     private function detectRankPriceChanges(array $beforeRankPrices, array $currentRankPrices): array
  590.     {
  591.         // [rank_id_productClassId] => price のマップで比較
  592.         $beforeMap = [];
  593.         foreach ($beforeRankPrices as $rp) {
  594.             $key = $rp['rank_id'] . '_' . $rp['product_class_id'];
  595.             $beforeMap[$key] = $rp;
  596.         }
  597.         $afterMap = [];
  598.         foreach ($currentRankPrices as $rp) {
  599.             $key = $rp['rank_id'] . '_' . $rp['product_class_id'];
  600.             $afterMap[$key] = $rp;
  601.         }
  603.         $changed = [];
  605.         foreach ($afterMap as $key => $after) {
  606.             $before = $beforeMap[$key] ?? null;
  607.             if (!$before || $before['price'] !== $after['price']) {
  608.                 $changed[] = [
  609.                     'rank_name'    => $after['rank_name'],
  610.                     'product_code' => $after['product_code'],
  611.                     'before_price' => $before ? $before['price'] : null,
  612.                     'after_price'  => $after['price'],
  613.                 ];
  614.             }
  615.         }
  617.         foreach ($beforeMap as $key => $before) {
  618.             if (!isset($afterMap[$key])) {
  619.                 $changed[] = [
  620.                     'rank_name'    => $before['rank_name'],
  621.                     'product_code' => $before['product_code'],
  622.                     'before_price' => $before['price'],
  623.                     'after_price'  => null,
  624.                 ];
  625.             }
  626.         }
  628.         return $changed;
  629.     }
  631.     /** 商品追加項目の変更検知 */
  632.     private function detectProductAddChanges(Product $product, array $beforeProductAdd): array
  633.     {
  634.         if (!class_exists('Plugin\ProductPlus42\Entity\ProductData')) {
  635.             return [];
  636.         }
  638.         $currentProductAdd = $this->buildProductAddSnapshot($product);
  640.         $beforeMap = [];
  641.         foreach ($beforeProductAdd as $pa) {
  642.             $beforeMap[$pa['item_id']] = $pa;
  643.         }
  644.         $afterMap = [];
  645.         foreach ($currentProductAdd as $pa) {
  646.             $afterMap[$pa['item_id']] = $pa;
  647.         }
  649.         $changed = [];
  651.         // 「beforeにデータ行が無い＝未入力」と「値が空文字/null」を同じ扱いで比較する。
  652.         // 行の有無だけで判定すると、フォーム送信時に空値のProductDataが新規作成されただけの
  653.         // ケースまで「変更あり」と誤検知してしまう（2026-08-28修正）。
  654.         foreach ($afterMap as $itemId => $after) {
  655.             $before = $beforeMap[$itemId] ?? null;
  656.             $beforeVal = $before ? $before['value'] : null;
  657.             if ($this->normalizeTextForCompare($beforeVal) !== $this->normalizeTextForCompare($after['value'])) {
  658.                 $changed[] = [
  659.                     'item_name'    => $after['item_name'],
  660.                     'before_value' => $beforeVal,
  661.                     'after_value'  => $after['value'],
  662.                 ];
  663.             }
  664.         }
  666.         return $changed;
  667.     }
  669.     // -------------------------------------------------------------------------
  670.     // updateNote / updateNum の生成（EC-CUBE3準拠形式）
  671.     // -------------------------------------------------------------------------
  673.     private function generateUpdateNote(array $changes): array
  674.     {
  675.         $logs = [];
  676.         $num  = 0;
  678.         // 商品基本情報
  679.         if (isset($changes['product'])) {
  680.             foreach (array_keys($changes['product']) as $field) {
  681.                 $label = self::$basicFieldLabels[$field] ?? $field;
  682.                 $logs[] = "「{$label}」";
  683.                 $num++;
  684.             }
  685.         }
  687.         // 商品規格（価格・在庫）フィールド単位でログ
  688.         if (isset($changes['product_classes'])) {
  689.             $beforeMap = [];
  690.             foreach ($changes['product_classes']['before'] as $bc) {
  691.                 if (isset($bc['code'])) {
  692.                     $beforeMap[$bc['code']] = $bc;
  693.                 }
  694.             }
  695.             foreach ($changes['product_classes']['after'] as $ac) {
  696.                 $code = $ac['code'] ?? '';
  697.                 $bc   = $beforeMap[$code] ?? null;
  698.                 if (!$bc) {
  699.                     continue;
  700.                 }
  701.                 foreach (self::$classFieldLabels as $field => $label) {
  702.                     if (array_key_exists($field, $ac) && array_key_exists($field, $bc) &&
  703.                         $ac[$field] !== $bc[$field]) {
  704.                         $logs[] = "「{$code}の{$label}」";
  705.                         $num++;
  706.                     }
  707.                 }
  708.             }
  709.         }
  711.         // 会員別価格
  712.         if (isset($changes['rank_prices']['changed'])) {
  713.             foreach ($changes['rank_prices']['changed'] as $rp) {
  714.                 $code = $rp['product_code'] ?? '';
  715.                 $label = $code ? "{$code}の会員価格：{$rp['rank_name']}" : "会員価格：{$rp['rank_name']}";
  716.                 $logs[] = "「{$label}」";
  717.                 $num++;
  718.             }
  719.         }
  721.         // 商品追加項目
  722.         if (isset($changes['product_add']['changed'])) {
  723.             foreach ($changes['product_add']['changed'] as $pa) {
  724.                 $logs[] = "「拡張項目：{$pa['item_name']}」";
  725.                 $num++;
  726.             }
  727.         }
  729.         // カテゴリー
  730.         if (isset($changes['product_categories'])) {
  731.             $logs[] = '「カテゴリー」';
  732.             $num++;
  733.         }
  735.         // 画像
  736.         if (isset($changes['product_images'])) {
  737.             $logs[] = '「商品画像」';
  738.             $num++;
  739.         }
  741.         // タグ
  742.         if (isset($changes['product_tags'])) {
  743.             $logs[] = '「商品タグ」';
  744.             $num++;
  745.         }
  747.         $note = !empty($logs)
  748.             ? implode('、', $logs) . 'を更新しました。'
  749.             : '変更箇所無し';
  751.         return ['num' => $num, 'note' => $note];
  752.     }
  754.     // -------------------------------------------------------------------------
  755.     // 各詳細テーブルへの保存
  756.     // -------------------------------------------------------------------------
  758.     private function saveProductBasicHistory(int $historyId, Product $product, array $changedFields)
  759.     {
  760.         $productHistory = new PiaHisProduct();
  761.         $productHistory->setHisId($historyId);
  762.         $productHistory->setProductId($product->getId());
  763.         $productHistory->setStatus($product->getStatus() ? $product->getStatus()->getId() : 0);
  764.         $productHistory->setName($product->getName());
  765.         $productHistory->setNote($product->getNote());
  766.         $productHistory->setDescriptionList($product->getDescriptionList());
  767.         $productHistory->setDescriptionDetail($product->getDescriptionDetail());
  768.         $productHistory->setSearchWord($product->getSearchWord());
  769.         $productHistory->setFreeArea($product->getFreeArea());
  770.         $productHistory->setDatetimeStart($this->getDisplayStartDate($product));
  771.         $productHistory->setDatetimeEnd($this->getDisplayEndDate($product));
  772.         $productHistory->setDelFlg(0);
  773.         $productHistory->setChangeData(json_encode($changedFields, JSON_UNESCAPED_UNICODE));
  775.         $this->entityManager->persist($productHistory);
  776.     }
  778.     private function saveProductClassHistory(int $historyId, Product $product)
  779.     {
  780.         foreach ($product->getProductClasses() as $pc) {
  781.             $classHistory = new PiaHisProductClass();
  782.             $classHistory->setHisId($historyId);
  783.             $classHistory->setProductId($product->getId());
  784.             $classHistory->setProductTypeId(null);
  785.             $classHistory->setClassCategoryId1($pc->getClassCategory1() ? $pc->getClassCategory1()->getId() : null);
  786.             $classHistory->setClassCategoryId2($pc->getClassCategory2() ? $pc->getClassCategory2()->getId() : null);
  787.             $classHistory->setDeliveryDateId($pc->getDeliveryDuration() ? $pc->getDeliveryDuration()->getId() : null);
  788.             $classHistory->setProductCode($pc->getCode());
  789.             $classHistory->setStock($pc->getStock());
  790.             $classHistory->setStockUnlimited($pc->isStockUnlimited());
  791.             $classHistory->setSaleLimit($pc->getSaleLimit());
  792.             $classHistory->setPrice01($pc->getPrice01());
  793.             $classHistory->setPrice02($pc->getPrice02());
  794.             $classHistory->setDeliveryFee($pc->getDeliveryFee());
  796.             $this->entityManager->persist($classHistory);
  797.         }
  798.     }
  800.     private function saveProductCategoryHistory(int $historyId, Product $product)
  801.     {
  802.         foreach ($product->getProductCategories() as $i => $productCategory) {
  803.             $categoryHistory = new PiaHisProductCategory();
  804.             $categoryHistory->setHisId($historyId);
  805.             $categoryHistory->setProductId($product->getId());
  806.             $categoryHistory->setCategoryId($productCategory->getCategory()->getId());
  807.             $categoryHistory->setRank($i + 1);
  809.             $this->entityManager->persist($categoryHistory);
  810.         }
  811.     }
  813.     private function saveProductImageHistory(int $historyId, Product $product)
  814.     {
  815.         foreach ($product->getProductImage() as $i => $productImage) {
  816.             $imageHistory = new PiaHisProductImage();
  817.             $imageHistory->setHisId($historyId);
  818.             $imageHistory->setProductId($product->getId());
  819.             $imageHistory->setFileName($productImage->getFileName());
  820.             $imageHistory->setRank($productImage->getSortNo() ?: ($i + 1));
  822.             $this->entityManager->persist($imageHistory);
  823.         }
  824.     }
  826.     private function saveProductStockHistory(int $historyId, Product $product)
  827.     {
  828.         foreach ($product->getProductClasses() as $pc) {
  829.             $stockHistory = new PiaHisProductStock();
  830.             $stockHistory->setHisId($historyId);
  831.             $stockHistory->setProductClassId($pc->getId());
  832.             $stockHistory->setStock($pc->isStockUnlimited() ? null : $pc->getStock());
  834.             $this->entityManager->persist($stockHistory);
  835.         }
  836.     }
  838.     private function saveProductTagHistory(int $historyId, Product $product)
  839.     {
  840.         foreach ($product->getProductTag() as $productTag) {
  841.             $tagHistory = new PiaHisProductTag();
  842.             $tagHistory->setHisId($historyId);
  843.             $tagHistory->setProductId($product->getId());
  844.             $tagHistory->setTag($productTag->getTag()->getId());
  846.             $this->entityManager->persist($tagHistory);
  847.         }
  848.     }
  850.     /**
  851.      * 会員別価格履歴を保存（CustomerRank42）
  852.      *
  853.      * 詳細画面で「1つ前の履歴レコード」を探して突き合わせる方式は、
  854.      * 直前の履歴にそのランクの価格が保存されているとは限らず食い違いの原因になっていたため、
  855.      * 保存時点で確定している変更前価格（$beforeRankPrices）をこの履歴の行に直接持たせる
  856.      * 方式に変更した（2026-08-28）。
  857.      *
  858.      * $currentRankPrices は独自にDBへ再クエリせず、判定・updateNote生成で使ったのと
  859.      * 同じ配列（buildRankPricesSnapshot()の戻り値、$changes['rank_prices']['after']）を
  860.      * 呼び出し側から受け取る。別々に再取得すると、取得タイミングのズレで判定結果と
  861.      * 保存内容が食い違う不具合があったため（2026-08-28、R-TRUST社員様/ご紹介会員で発覚）。
  862.      * $beforeRankPrices・$currentRankPrices とも同じ形式の配列
  863.      * （rank_id, product_class_id, rank_name, product_code, price を持つ連想配列のリスト）。
  864.      */
  865.     private function saveRankPriceHistory(int $historyId, array $beforeRankPrices, array $currentRankPrices)
  866.     {
  867.         $beforeMap = [];
  868.         foreach ($beforeRankPrices as $rp) {
  869.             $key = $rp['rank_id'] . '_' . $rp['product_class_id'];
  870.             $beforeMap[$key] = $rp['price'];
  871.         }
  873.         foreach ($currentRankPrices as $rp) {
  874.             $key = $rp['rank_id'] . '_' . $rp['product_class_id'];
  876.             $rankHistory = new PiaHisRankPrice();
  877.             $rankHistory->setHisId($historyId);
  878.             $rankHistory->setCustomerRankId($rp['rank_id']);
  879.             $rankHistory->setProductClassId($rp['product_class_id']);
  880.             $rankHistory->setPrice($rp['price']);
  881.             $rankHistory->setBeforePrice($beforeMap[$key] ?? null);
  883.             $this->entityManager->persist($rankHistory);
  884.         }
  885.     }
  887.     /** 商品追加項目履歴を保存（ProductPlus42） */
  888.     private function saveProductAddHistory(int $historyId, Product $product)
  889.     {
  890.         if (!class_exists('Plugin\ProductPlus42\Entity\ProductData')) {
  891.             return;
  892.         }
  893.         try {
  894.             $repo = $this->entityManager->getRepository('Plugin\ProductPlus42\Entity\ProductData');
  895.             $productDatas = $repo->findBy(['Product' => $product]);
  896.             foreach ($productDatas as $pd) {
  897.                 $item = $pd->getProductItem();
  898.                 if (!$item) {
  899.                     continue;
  900.                 }
  901.                 $addHistory = new PiaHisProductAdd();
  902.                 $addHistory->setHisId($historyId);
  903.                 $addHistory->setProductId($product->getId());
  904.                 $addHistory->setColumnId($item->getId());
  905.                 $addHistory->setValue($pd->getDataValue());
  907.                 $this->entityManager->persist($addHistory);
  908.             }
  909.         } catch (\Exception $e) {
  910.             error_log('PiaHistory: 商品追加項目履歴保存エラー - ' . $e->getMessage());
  911.         }
  912.     }
  914.     /** 目安価格履歴を保存（PiaMeyasu） */
  915.     private function saveMeyasuHistory(int $historyId, Product $product)
  916.     {
  917.         try {
  918.             if (!class_exists('Plugin\PiaMeyasu\Entity\PiaMeyasu')) {
  919.                 return;
  920.             }
  921.             $meyasuRepo = $this->entityManager->getRepository('Plugin\PiaMeyasu\Entity\PiaMeyasu');
  922.             $meyasuData = $meyasuRepo->findOneBy(['product_id' => $product->getId()]);
  924.             if ($meyasuData) {
  925.                 $meyasuHistory = new PiaHisMeyasu();
  926.                 $meyasuHistory->setHisId($historyId);
  927.                 $meyasuHistory->setProductId($product->getId());
  928.                 $meyasuHistory->setCoinCost($meyasuData->getCoinCost());
  929.                 $meyasuHistory->setExTypeId($meyasuData->getExTypeId());
  930.                 $meyasuHistory->setCommission($meyasuData->getCommission());
  931.                 $meyasuHistory->setEsDispPrice($meyasuData->getEsDispPrice());
  933.                 $this->entityManager->persist($meyasuHistory);
  934.             }
  935.         } catch (\Exception $e) {
  936.             error_log('PiaHistory: 目安価格履歴保存エラー - ' . $e->getMessage());
  937.         }
  938.     }
  940.     // -------------------------------------------------------------------------
  941.     // ユーティリティ
  942.     // -------------------------------------------------------------------------
  944.     /** ログイン管理者情報を取得 */
  945.     private function getAdminInfo(): array
  946.     {
  947.         $adminId         = 1;
  948.         $adminName       = '管理者';
  949.         $adminDepartment = '';
  951.         if ($this->tokenStorage->getToken() && $this->tokenStorage->getToken()->getUser()) {
  952.             $admin   = $this->tokenStorage->getToken()->getUser();
  953.             $adminId = $admin->getId();
  955.             $member = $this->memberRepository->find($adminId);
  956.             if ($member) {
  957.                 $adminName = $member->getName();
  958.                 if (method_exists($member, 'getDepartment')) {
  959.                     $adminDepartment = $member->getDepartment() ?: '';
  960.                 }
  961.             }
  962.         }
  964.         return [$adminId, $adminName, $adminDepartment];
  965.     }
  967.     /** PiaProductDispプラグインから表示開始日を取得 */
  968.     private function getDisplayStartDate(Product $product): ?string
  969.     {
  970.         try {
  971.             if (class_exists('Plugin\PiaProductDisp\Entity\ProductDisplayPeriod')) {
  972.                 $repo = $this->entityManager->getRepository('Plugin\PiaProductDisp\Entity\ProductDisplayPeriod');
  973.                 $dp   = $repo->findOneBy(['Product' => $product]);
  974.                 if ($dp && $dp->getDisplayStartDate()) {
  975.                     return $dp->getDisplayStartDate()->format('Y-m-d H:i:s');
  976.                 }
  977.             }
  978.         } catch (\Exception $e) {
  979.             error_log('PiaHistory: 表示開始日取得エラー - ' . $e->getMessage());
  980.         }
  981.         return null;
  982.     }
  984.     /** PiaProductDispプラグインから表示終了日を取得 */
  985.     private function getDisplayEndDate(Product $product): ?string
  986.     {
  987.         try {
  988.             if (class_exists('Plugin\PiaProductDisp\Entity\ProductDisplayPeriod')) {
  989.                 $repo = $this->entityManager->getRepository('Plugin\PiaProductDisp\Entity\ProductDisplayPeriod');
  990.                 $dp   = $repo->findOneBy(['Product' => $product]);
  991.                 if ($dp && $dp->getDisplayEndDate()) {
  992.                     return $dp->getDisplayEndDate()->format('Y-m-d H:i:s');
  993.                 }
  994.             }
  995.         } catch (\Exception $e) {
  996.             error_log('PiaHistory: 表示終了日取得エラー - ' . $e->getMessage());
  997.         }
  998.         return null;
  999.     }
  1000. }