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

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;
  39. use Plugin\PiaProductDisp\Entity\ProductDisplayPeriod;
  41. class ProductEditEventSubscriber implements EventSubscriberInterface
  42. {
  43.     /**
  44.      * @var PiaHistoryRepository
  45.      */
  46.     private $piaHistoryRepository;
  48.     /**
  49.      * @var PiaHisProductRepository
  50.      */
  51.     private $piaHisProductRepository;
  53.     /**
  54.      * @var PiaHisProductClassRepository
  55.      */
  56.     private $piaHisProductClassRepository;
  58.     /**
  59.      * @var PiaHisProductCategoryRepository
  60.      */
  61.     private $piaHisProductCategoryRepository;
  63.     /**
  64.      * @var PiaHisProductImageRepository
  65.      */
  66.     private $piaHisProductImageRepository;
  68.     /**
  69.      * @var PiaHisProductStockRepository
  70.      */
  71.     private $piaHisProductStockRepository;
  73.     /**
  74.      * @var PiaHisProductTagRepository
  75.      */
  76.     private $piaHisProductTagRepository;
  78.     /**
  79.      * @var PiaHisProductAddRepository
  80.      */
  81.     private $piaHisProductAddRepository;
  83.     /**
  84.      * @var PiaHisRankPriceRepository
  85.      */
  86.     private $piaHisRankPriceRepository;
  88.     /**
  89.      * @var PiaHisCustomerClassRepository
  90.      */
  91.     private $piaHisCustomerClassRepository;
  93.     /**
  94.      * @var PiaHisPointRepository
  95.      */
  96.     private $piaHisPointRepository;
  98.     /**
  99.      * @var PiaHisMeyasuRepository
  100.      */
  101.     private $piaHisMeyasuRepository;
  103.     /**
  104.      * @var ProductRepository
  105.      */
  106.     private $productRepository;
  108.     /**
  109.      * @var MemberRepository
  110.      */
  111.     private $memberRepository;
  113.     /**
  114.      * @var TokenStorageInterface
  115.      */
  116.     private $tokenStorage;
  118.     /**
  119.      * @var EntityManagerInterface
  120.      */
  121.     private $entityManager;
  123.     /**
  124.      * @var RequestStack
  125.      */
  126.     private $requestStack;
  128.     /**
  129.      * ProductEditEventSubscriber constructor.
  130.      */
  131.     public function __construct(
  132.         PiaHistoryRepository $piaHistoryRepository,
  133.         PiaHisProductRepository $piaHisProductRepository,
  134.         PiaHisProductClassRepository $piaHisProductClassRepository,
  135.         PiaHisProductCategoryRepository $piaHisProductCategoryRepository,
  136.         PiaHisProductImageRepository $piaHisProductImageRepository,
  137.         PiaHisProductStockRepository $piaHisProductStockRepository,
  138.         PiaHisProductTagRepository $piaHisProductTagRepository,
  139.         PiaHisProductAddRepository $piaHisProductAddRepository,
  140.         PiaHisRankPriceRepository $piaHisRankPriceRepository,
  141.         PiaHisCustomerClassRepository $piaHisCustomerClassRepository,
  142.         PiaHisPointRepository $piaHisPointRepository,
  143.         PiaHisMeyasuRepository $piaHisMeyasuRepository,
  144.         ProductRepository $productRepository,
  145.         MemberRepository $memberRepository,
  146.         TokenStorageInterface $tokenStorage,
  147.         EntityManagerInterface $entityManager,
  148.         RequestStack $requestStack
  149.     ) {
  150.         $this->piaHistoryRepository = $piaHistoryRepository;
  151.         $this->piaHisProductRepository = $piaHisProductRepository;
  152.         $this->piaHisProductClassRepository = $piaHisProductClassRepository;
  153.         $this->piaHisProductCategoryRepository = $piaHisProductCategoryRepository;
  154.         $this->piaHisProductImageRepository = $piaHisProductImageRepository;
  155.         $this->piaHisProductStockRepository = $piaHisProductStockRepository;
  156.         $this->piaHisProductTagRepository = $piaHisProductTagRepository;
  157.         $this->piaHisProductAddRepository = $piaHisProductAddRepository;
  158.         $this->piaHisRankPriceRepository = $piaHisRankPriceRepository;
  159.         $this->piaHisCustomerClassRepository = $piaHisCustomerClassRepository;
  160.         $this->piaHisPointRepository = $piaHisPointRepository;
  161.         $this->piaHisMeyasuRepository = $piaHisMeyasuRepository;
  162.         $this->productRepository = $productRepository;
  163.         $this->memberRepository = $memberRepository;
  164.         $this->tokenStorage = $tokenStorage;
  165.         $this->entityManager = $entityManager;
  166.         $this->requestStack = $requestStack;
  167.     }
  169.     /**
  170.      * @return array
  171.      */
  172.     public static function getSubscribedEvents()
  173.     {
  174.         return [
  175.             'kernel.request' => ['onKernelRequest', 0],
  176.             EccubeEvents::ADMIN_PRODUCT_EDIT_COMPLETE => ['onProductEditComplete', -1000], // 優先度をさらに下げる
  177.         ];
  178.     }
  180.     /**
  181.      * 商品編集画面のリクエストを検知して変更前の値を保存
  182.      *
  183.      * @param RequestEvent $event
  184.      */
  185.     public function onKernelRequest(RequestEvent $event)
  186.     {
  187.         $request = $event->getRequest();
  188.         
  189.         // 商品編集画面のPOSTリクエストのみ処理
  190.         if ($request->isMethod('POST') && 
  191.             $request->attributes->get('_route') === 'admin_product_product_edit') {
  192.             
  193.             $productId = $request->get('id');
  194.             error_log('PiaHistory: onKernelRequest - Product ID: ' . $productId);
  195.             
  196.             if ($productId) {
  197.                 $this->saveProductBeforeData($productId);
  198.                 error_log('PiaHistory: Before data saved for Product ID: ' . $productId);
  199.             }
  200.         }
  201.     }
  203.     /**
  204.      * @param EventArgs $event
  205.      */
  206.     public function onProductEditComplete(EventArgs $event)
  207.     {
  208.         error_log('PiaHistory: onProductEditComplete called');
  209.         $Product = $event->getArgument('Product');
  210.         if ($Product && $Product->getId()) {
  211.             error_log('PiaHistory: Product ID: ' . $Product->getId());
  212.             $this->saveProductHistory($Product->getId());
  213.         } else {
  214.             error_log('PiaHistory: No product or product ID found');
  215.         }
  216.     }
  218.     /**
  219.      * リクエスト終了時の処理
  220.      *
  221.      * @param \Symfony\Component\HttpKernel\Event\TerminateEvent $event
  222.      */
  223.     public function onKernelTerminate(\Symfony\Component\HttpKernel\Event\TerminateEvent $event)
  224.     {
  225.         $request = $event->getRequest();
  226.         
  227.         // デバッグログ
  228.         error_log('PiaHistory: onKernelTerminate called - Route: ' . $request->attributes->get('_route') . ', Method: ' . $request->getMethod());
  229.         
  230.         // 商品編集画面のPOSTリクエストの場合のみ処理
  231.         if ($request->isMethod('POST') && 
  232.             $request->attributes->get('_route') === 'admin_product_product_edit') {
  233.             
  234.             $productId = $request->get('id');
  235.             error_log('PiaHistory: Product edit detected - Product ID: ' . $productId);
  236.             
  237.             if ($productId) {
  238.                 $this->saveProductHistory($productId);
  239.             }
  240.         }
  241.     }
  243.     /**
  244.      * 商品編集前のデータをセッションに保存
  245.      *
  246.      * @param int $productId
  247.      */
  248.     private function saveProductBeforeData($productId)
  249.     {
  250.         try {
  251.             $product = $this->productRepository->find($productId);
  252.             if (!$product) {
  253.                 return;
  254.             }
  256.             $request = $this->requestStack->getCurrentRequest();
  257.             if (!$request) {
  258.                 return;
  259.             }
  261.             $session = $request->getSession();
  262.             
  263.             // 変更前の商品データをセッションに保存
  264.             $beforeData = [
  265.                 'product' => [
  266.                     'id' => $product->getId(),
  267.                     'name' => $product->getName(),
  268.                     'note' => $product->getNote(),
  269.                     'description_list' => $product->getDescriptionList(),
  270.                     'description_detail' => $product->getDescriptionDetail(),
  271.                     'search_word' => $product->getSearchWord(),
  272.                     'free_area' => $product->getFreeArea(),
  273.                     'status' => $product->getStatus() ? $product->getStatus()->getId() : null,
  274.                     'datetime_start' => $this->getDisplayStartDate($product),
  275.                     'datetime_end' => $this->getDisplayEndDate($product),
  276.                 ],
  277.                 'product_classes' => [],
  278.                 'product_categories' => [],
  279.                 'product_images' => [],
  280.                 'product_tags' => [],
  281.             ];
  283.             // 商品規格データ
  284.             foreach ($product->getProductClasses() as $productClass) {
  285.                 $beforeData['product_classes'][] = [
  286.                     'id' => $productClass->getId(),
  287.                     'product_type_id' => null, // EC-CUBE4では商品規格タイプが存在しない
  288.                     'class_category_id1' => $productClass->getClassCategory1() ? $productClass->getClassCategory1()->getId() : null,
  289.                     'class_category_id2' => $productClass->getClassCategory2() ? $productClass->getClassCategory2()->getId() : null,
  290.                     'delivery_date_id' => $productClass->getDeliveryDuration() ? $productClass->getDeliveryDuration()->getId() : null,
  291.                     'code' => $productClass->getCode(),
  292.                     'stock' => $productClass->getStock(),
  293.                     'stock_unlimited' => $productClass->isStockUnlimited(),
  294.                     'sale_limit' => $productClass->getSaleLimit(),
  295.                     'price01' => $productClass->getPrice01(),
  296.                     'price02' => $productClass->getPrice02(),
  297.                     'delivery_fee' => $productClass->getDeliveryFee(),
  298.                 ];
  299.             }
  301.             // 商品カテゴリーデータ
  302.             foreach ($product->getProductCategories() as $index => $productCategory) {
  303.                 $beforeData['product_categories'][] = [
  304.                     'category_id' => $productCategory->getCategory()->getId(),
  305.                     'rank' => $index + 1, // EC-CUBE4では順序を配列のインデックスで管理
  306.                 ];
  307.             }
  309.             // 商品画像データ
  310.             foreach ($product->getProductImage() as $index => $productImage) {
  311.                 $beforeData['product_images'][] = [
  312.                     'file_name' => $productImage->getFileName(),
  313.                     'rank' => $productImage->getSortNo() ?: ($index + 1), // EC-CUBE4ではgetSortNo()を使用
  314.                 ];
  315.             }
  317.             // 商品タグデータ
  318.             foreach ($product->getProductTag() as $productTag) {
  319.                 $beforeData['product_tags'][] = [
  320.                     'tag_id' => $productTag->getTag()->getId(),
  321.                 ];
  322.             }
  324.             $session->set('pia_history_before_data_' . $productId, $beforeData);
  326.         } catch (\Exception $e) {
  327.             error_log('PiaHistory: 変更前データ保存エラー - ' . $e->getMessage());
  328.         }
  329.     }
  331.     /**
  332.      * 商品履歴を保存
  333.      *
  334.      * @param int $productId
  335.      */
  336.     private function saveProductHistory($productId)
  337.     {
  338.         try {
  339.             error_log('PiaHistory: saveProductHistory called for Product ID: ' . $productId);
  340.             
  341.             // EntityManagerの状態をチェック
  342.             if (!$this->entityManager->isOpen()) {
  343.                 error_log('PiaHistory: EntityManager is closed, skipping history save');
  344.                 return;
  345.             }
  346.             
  347.             error_log('PiaHistory: EntityManager is open, proceeding with history save');
  349.             $product = $this->productRepository->find($productId);
  350.             if (!$product) {
  351.                 return;
  352.             }
  354.             $request = $this->requestStack->getCurrentRequest();
  355.             if (!$request) {
  356.                 return;
  357.             }
  359.             $session = $request->getSession();
  360.             $beforeData = $session->get('pia_history_before_data_' . $productId);
  361.             
  362.             // 変更前のデータがない場合はスキップ
  363.             if (!$beforeData) {
  364.                 return;
  365.             }
  367.             // 変更があったかチェック
  368.             $hasChanges = $this->checkProductChanges($product, $beforeData);
  369.             error_log('PiaHistory: Changes detected: ' . ($hasChanges ? 'YES' : 'NO'));
  370.             
  371.             if (!$hasChanges) {
  372.                 // 変更がない場合はセッションをクリアして終了
  373.                 error_log('PiaHistory: No changes detected, skipping history save');
  374.                 $session->remove('pia_history_before_data_' . $productId);
  375.                 return;
  376.             }
  378.             // トランザクション開始
  379.             $this->entityManager->beginTransaction();
  381.             // 管理者情報を取得
  382.             $adminId = 1;
  383.             $adminName = '管理者';
  384.             $adminDepartment = '未設定';
  385.             if ($this->tokenStorage->getToken() && $this->tokenStorage->getToken()->getUser()) {
  386.                 $admin = $this->tokenStorage->getToken()->getUser();
  387.                 $adminId = $admin->getId();
  388.                 $adminName = $admin->getUsername();
  389.                 
  390.                 // 管理者の詳細情報を取得
  391.                 $member = $this->memberRepository->find($adminId);
  392.                 if ($member) {
  393.                     $adminName = $member->getName();
  394.                     // 所属情報を取得（Memberエンティティに所属フィールドがある場合）
  395.                     if (method_exists($member, 'getDepartment')) {
  396.                         $adminDepartment = $member->getDepartment() ?: '未設定';
  397.                     }
  398.                 }
  399.             }
  401.             // 履歴メイン情報を作成
  402.             $history = new PiaHistory();
  403.             $history->setProductId($productId);
  404.             $history->setUpdateId($adminId);
  405.             $history->setUpdateName($adminName);
  406.             $history->setUpdateDepartment($adminDepartment);
  407.             $history->setUpdateNum(1); // 更新回数（仮）
  408.             $history->setUpdateNote('商品情報を更新しました');
  409.             $history->setCreateDate(new \DateTime());
  410.             $history->setUpdateDate(new \DateTime());
  411.             $history->setDelFlg(0);
  413.             $this->entityManager->persist($history);
  414.             $this->entityManager->flush();
  416.             $historyId = $history->getId();
  418.             // 変更箇所を詳細に検知
  419.             $changes = $this->detectDetailedChanges($product, $beforeData);
  420.             
  421.             // 変更があった項目のみ履歴を保存
  422.             if (isset($changes['product'])) {
  423.                 $this->saveProductBasicHistory($historyId, $product, $beforeData['product'], $changes['product']);
  424.             }
  425.             
  426.             if (isset($changes['product_classes'])) {
  427.                 $this->saveProductClassHistory($historyId, $product, $beforeData['product_classes'], $changes['product_classes']);
  428.             }
  429.             
  430.             if (isset($changes['product_categories'])) {
  431.                 $this->saveProductCategoryHistory($historyId, $product, $beforeData['product_categories'], $changes['product_categories']);
  432.             }
  433.             
  434.             if (isset($changes['product_images'])) {
  435.                 $this->saveProductImageHistory($historyId, $product, $beforeData['product_images'], $changes['product_images']);
  436.             }
  437.             
  438.             if (isset($changes['product_tags'])) {
  439.                 $this->saveProductTagHistory($historyId, $product, $beforeData['product_tags'], $changes['product_tags']);
  440.             }
  441.             
  442.             // その他の履歴保存（変更検知は別途実装）
  443.             $this->saveProductStockHistory($historyId, $product);
  444.             $this->saveProductAddHistory($historyId, $product);
  445.             $this->saveRankPriceHistory($historyId, $product);
  446.             $this->saveCustomerClassHistory($historyId, $product);
  447.             $this->savePointHistory($historyId, $product);
  448.             $this->saveMeyasuHistory($historyId, $product);
  449.             
  450.             // 最後にまとめてflush
  451.             $this->entityManager->flush();
  452.             
  453.             // トランザクションコミット
  454.             $this->entityManager->commit();
  456.             // セッションをクリア
  457.             $session->remove('pia_history_before_data_' . $productId);
  459.         } catch (\Exception $e) {
  460.             // トランザクションロールバック
  461.             if ($this->entityManager->getConnection()->isTransactionActive()) {
  462.                 $this->entityManager->rollback();
  463.             }
  464.             
  465.             // エラーログを出力
  466.             error_log('PiaHistory: 商品履歴保存エラー - ' . $e->getMessage());
  467.         }
  468.     }
  470.     /**
  471.      * 商品の変更をチェック
  472.      *
  473.      * @param Product $product
  474.      * @param array $beforeData
  475.      * @return bool
  476.      */
  477.     private function checkProductChanges(Product $product, array $beforeData)
  478.     {
  479.         $beforeProduct = $beforeData['product'];
  480.         
  481.         // 基本情報の変更チェック
  482.         if ($product->getName() !== $beforeProduct['name'] ||
  483.             $product->getNote() !== $beforeProduct['note'] ||
  484.             $product->getDescriptionList() !== $beforeProduct['description_list'] ||
  485.             $product->getDescriptionDetail() !== $beforeProduct['description_detail'] ||
  486.             $product->getSearchWord() !== $beforeProduct['search_word'] ||
  487.             $product->getFreeArea() !== $beforeProduct['free_area'] ||
  488.             ($product->getStatus() ? $product->getStatus()->getId() : null) !== $beforeProduct['status']) {
  489.             return true;
  490.         }
  492.         // 日時の変更チェック（PiaProductDispプラグインとの連携）
  493.         $currentStart = $this->getDisplayStartDate($product);
  494.         $currentEnd = $this->getDisplayEndDate($product);
  495.         
  496.         if ($currentStart !== $beforeProduct['datetime_start'] || $currentEnd !== $beforeProduct['datetime_end']) {
  497.             return true;
  498.         }
  500.         // 商品規格の変更チェック
  501.         $currentClasses = [];
  502.         foreach ($product->getProductClasses() as $productClass) {
  503.             $currentClasses[] = [
  504.                 'id' => $productClass->getId(),
  505.                 'code' => $productClass->getCode(),
  506.                 'stock' => $productClass->getStock(),
  507.                 'price01' => $productClass->getPrice01(),
  508.                 'price02' => $productClass->getPrice02(),
  509.             ];
  510.         }
  511.         
  512.         if ($currentClasses !== $beforeData['product_classes']) {
  513.             return true;
  514.         }
  516.         return false;
  517.     }
  519.     /**
  520.      * 変更箇所を詳細に検知
  521.      *
  522.      * @param Product $product
  523.      * @param array $beforeData
  524.      * @return array
  525.      */
  526.     private function detectDetailedChanges(Product $product, array $beforeData)
  527.     {
  528.         $changes = [];
  529.         $beforeProduct = $beforeData['product'];
  530.         
  531.         // 基本情報の変更検知
  532.         if ($product->getName() !== $beforeProduct['name']) {
  533.             $changes['product']['name'] = [
  534.                 'before' => $beforeProduct['name'],
  535.                 'after' => $product->getName()
  536.             ];
  537.         }
  538.         
  539.         if ($product->getNote() !== $beforeProduct['note']) {
  540.             $changes['product']['note'] = [
  541.                 'before' => $beforeProduct['note'],
  542.                 'after' => $product->getNote()
  543.             ];
  544.         }
  545.         
  546.         if ($product->getDescriptionList() !== $beforeProduct['description_list']) {
  547.             $changes['product']['description_list'] = [
  548.                 'before' => $beforeProduct['description_list'],
  549.                 'after' => $product->getDescriptionList()
  550.             ];
  551.         }
  552.         
  553.         if ($product->getDescriptionDetail() !== $beforeProduct['description_detail']) {
  554.             $changes['product']['description_detail'] = [
  555.                 'before' => $beforeProduct['description_detail'],
  556.                 'after' => $product->getDescriptionDetail()
  557.             ];
  558.         }
  559.         
  560.         if ($product->getSearchWord() !== $beforeProduct['search_word']) {
  561.             $changes['product']['search_word'] = [
  562.                 'before' => $beforeProduct['search_word'],
  563.                 'after' => $product->getSearchWord()
  564.             ];
  565.         }
  566.         
  567.         if ($product->getFreeArea() !== $beforeProduct['free_area']) {
  568.             $changes['product']['free_area'] = [
  569.                 'before' => $beforeProduct['free_area'],
  570.                 'after' => $product->getFreeArea()
  571.             ];
  572.         }
  573.         
  574.         $currentStatus = $product->getStatus() ? $product->getStatus()->getId() : null;
  575.         if ($currentStatus !== $beforeProduct['status']) {
  576.             $changes['product']['status'] = [
  577.                 'before' => $beforeProduct['status'],
  578.                 'after' => $currentStatus
  579.             ];
  580.         }
  582.         // 日時の変更検知
  583.         $currentStart = $this->getDisplayStartDate($product);
  584.         $currentEnd = $this->getDisplayEndDate($product);
  585.         
  586.         if ($currentStart !== $beforeProduct['datetime_start']) {
  587.             $changes['product']['datetime_start'] = [
  588.                 'before' => $beforeProduct['datetime_start'],
  589.                 'after' => $currentStart
  590.             ];
  591.         }
  592.         
  593.         if ($currentEnd !== $beforeProduct['datetime_end']) {
  594.             $changes['product']['datetime_end'] = [
  595.                 'before' => $beforeProduct['datetime_end'],
  596.                 'after' => $currentEnd
  597.             ];
  598.         }
  600.         // 商品規格の変更検知
  601.         $currentClasses = [];
  602.         foreach ($product->getProductClasses() as $productClass) {
  603.             $currentClasses[] = [
  604.                 'id' => $productClass->getId(),
  605.                 'code' => $productClass->getCode(),
  606.                 'stock' => $productClass->getStock(),
  607.                 'price01' => $productClass->getPrice01(),
  608.                 'price02' => $productClass->getPrice02(),
  609.             ];
  610.         }
  611.         
  612.         if ($currentClasses !== $beforeData['product_classes']) {
  613.             $changes['product_classes'] = [
  614.                 'before' => $beforeData['product_classes'],
  615.                 'after' => $currentClasses
  616.             ];
  617.         }
  619.         // 商品カテゴリーの変更検知
  620.         $currentCategories = [];
  621.         foreach ($product->getProductCategories() as $index => $productCategory) {
  622.             $currentCategories[] = [
  623.                 'category_id' => $productCategory->getCategory()->getId(),
  624.                 'rank' => $index + 1,
  625.             ];
  626.         }
  627.         
  628.         if ($currentCategories !== $beforeData['product_categories']) {
  629.             $changes['product_categories'] = [
  630.                 'before' => $beforeData['product_categories'],
  631.                 'after' => $currentCategories
  632.             ];
  633.         }
  635.         // 商品画像の変更検知
  636.         $currentImages = [];
  637.         foreach ($product->getProductImage() as $index => $productImage) {
  638.             $currentImages[] = [
  639.                 'file_name' => $productImage->getFileName(),
  640.                 'rank' => $productImage->getSortNo() ?: ($index + 1),
  641.             ];
  642.         }
  643.         
  644.         if ($currentImages !== $beforeData['product_images']) {
  645.             $changes['product_images'] = [
  646.                 'before' => $beforeData['product_images'],
  647.                 'after' => $currentImages
  648.             ];
  649.         }
  651.         // 商品タグの変更検知
  652.         $currentTags = [];
  653.         foreach ($product->getProductTag() as $productTag) {
  654.             $currentTags[] = [
  655.                 'tag_id' => $productTag->getTag()->getId(),
  656.             ];
  657.         }
  658.         
  659.         if ($currentTags !== $beforeData['product_tags']) {
  660.             $changes['product_tags'] = [
  661.                 'before' => $beforeData['product_tags'],
  662.                 'after' => $currentTags
  663.             ];
  664.         }
  666.         return $changes;
  667.     }
  669.     /**
  670.      * 商品基本情報履歴を保存
  671.      *
  672.      * @param int $historyId
  673.      * @param Product $product
  674.      * @param array $beforeProduct
  675.      * @param array $changes
  676.      */
  677.     private function saveProductBasicHistory($historyId, Product $product, array $beforeProduct, array $changes = [])
  678.     {
  679.         $productHistory = new PiaHisProduct();
  680.         $productHistory->setHisId($historyId);
  681.         $productHistory->setProductId($product->getId());
  682.         $productHistory->setStatus($product->getStatus()->getId());
  683.         $productHistory->setName($product->getName());
  684.         $productHistory->setNote($product->getNote());
  685.         $productHistory->setDescriptionList($product->getDescriptionList());
  686.         $productHistory->setDescriptionDetail($product->getDescriptionDetail());
  687.         $productHistory->setSearchWord($product->getSearchWord());
  688.         $productHistory->setFreeArea($product->getFreeArea());
  689.         $productHistory->setDatetimeStart($this->getDisplayStartDate($product));
  690.         $productHistory->setDatetimeEnd($this->getDisplayEndDate($product));
  691.         $productHistory->setDelFlg(0);
  692.         
  693.         // 変更情報をJSONで保存
  694.         if (!empty($changes)) {
  695.             $productHistory->setChangeData(json_encode($changes, JSON_UNESCAPED_UNICODE));
  696.         }
  698.         $this->entityManager->persist($productHistory);
  699.     }
  701.     /**
  702.      * 商品規格履歴を保存
  703.      *
  704.      * @param int $historyId
  705.      * @param Product $product
  706.      * @param array $beforeClasses
  707.      */
  708.     private function saveProductClassHistory($historyId, Product $product, array $beforeClasses)
  709.     {
  710.         foreach ($product->getProductClasses() as $productClass) {
  711.             $classHistory = new PiaHisProductClass();
  712.             $classHistory->setHisId($historyId);
  713.             $classHistory->setProductId($product->getId());
  714.             $classHistory->setProductTypeId(null); // EC-CUBE4では商品規格タイプが存在しない
  715.             $classHistory->setClassCategoryId1($productClass->getClassCategory1() ? $productClass->getClassCategory1()->getId() : null);
  716.             $classHistory->setClassCategoryId2($productClass->getClassCategory2() ? $productClass->getClassCategory2()->getId() : null);
  717.             $classHistory->setDeliveryDateId($productClass->getDeliveryDuration() ? $productClass->getDeliveryDuration()->getId() : null);
  718.             $classHistory->setProductCode($productClass->getCode());
  719.             $classHistory->setStock($productClass->getStock());
  720.             $classHistory->setStockUnlimited($productClass->isStockUnlimited());
  721.             $classHistory->setSaleLimit($productClass->getSaleLimit());
  722.             $classHistory->setPrice01($productClass->getPrice01());
  723.             $classHistory->setPrice02($productClass->getPrice02());
  724.             $classHistory->setDeliveryFee($productClass->getDeliveryFee());
  726.             $this->entityManager->persist($classHistory);
  727.         }
  728.     }
  730.     /**
  731.      * 商品カテゴリー履歴を保存
  732.      *
  733.      * @param int $historyId
  734.      * @param Product $product
  735.      * @param array $beforeCategories
  736.      */
  737.     private function saveProductCategoryHistory($historyId, Product $product, array $beforeCategories)
  738.     {
  739.         foreach ($product->getProductCategories() as $index => $productCategory) {
  740.             $categoryHistory = new PiaHisProductCategory();
  741.             $categoryHistory->setHisId($historyId);
  742.             $categoryHistory->setProductId($product->getId());
  743.             $categoryHistory->setCategoryId($productCategory->getCategory()->getId());
  744.             $categoryHistory->setRank($index + 1); // EC-CUBE4では順序を配列のインデックスで管理
  746.             $this->entityManager->persist($categoryHistory);
  747.         }
  748.     }
  750.     /**
  751.      * 商品画像履歴を保存
  752.      *
  753.      * @param int $historyId
  754.      * @param Product $product
  755.      * @param array $beforeImages
  756.      */
  757.     private function saveProductImageHistory($historyId, Product $product, array $beforeImages)
  758.     {
  759.         foreach ($product->getProductImage() as $index => $productImage) {
  760.             $imageHistory = new PiaHisProductImage();
  761.             $imageHistory->setHisId($historyId);
  762.             $imageHistory->setProductId($product->getId());
  763.             $imageHistory->setFileName($productImage->getFileName());
  764.             $imageHistory->setRank($productImage->getSortNo() ?: ($index + 1)); // EC-CUBE4ではgetSortNo()を使用
  766.             $this->entityManager->persist($imageHistory);
  767.         }
  768.     }
  770.     /**
  771.      * 商品在庫履歴を保存
  772.      *
  773.      * @param int $historyId
  774.      * @param Product $product
  775.      */
  776.     private function saveProductStockHistory($historyId, Product $product)
  777.     {
  778.         foreach ($product->getProductClasses() as $productClass) {
  779.             $stockHistory = new PiaHisProductStock();
  780.             $stockHistory->setHisId($historyId);
  781.             $stockHistory->setProductClassId($productClass->getId());
  782.             $stockHistory->setStock($productClass->getStock());
  784.             $this->entityManager->persist($stockHistory);
  785.         }
  786.     }
  788.     /**
  789.      * 商品タグ履歴を保存
  790.      *
  791.      * @param int $historyId
  792.      * @param Product $product
  793.      * @param array $beforeTags
  794.      */
  795.     private function saveProductTagHistory($historyId, Product $product, array $beforeTags)
  796.     {
  797.         foreach ($product->getProductTag() as $productTag) {
  798.             $tagHistory = new PiaHisProductTag();
  799.             $tagHistory->setHisId($historyId);
  800.             $tagHistory->setProductId($product->getId());
  801.             $tagHistory->setTag($productTag->getTag()->getId());
  803.             $this->entityManager->persist($tagHistory);
  804.         }
  805.     }
  807.     /**
  808.      * 商品追加項目履歴を保存
  809.      *
  810.      * @param int $historyId
  811.      * @param Product $product
  812.      */
  813.     private function saveProductAddHistory($historyId, Product $product)
  814.     {
  815.         // 商品追加項目の履歴保存処理
  816.         // 他のプラグインとの連携が必要な場合はここで実装
  817.     }
  819.     /**
  820.      * 商品ランク価格履歴を保存
  821.      *
  822.      * @param int $historyId
  823.      * @param Product $product
  824.      */
  825.     private function saveRankPriceHistory($historyId, Product $product)
  826.     {
  827.         // 商品ランク価格の履歴保存処理
  828.         // 他のプラグインとの連携が必要な場合はここで実装
  829.         foreach ($product->getProductClasses() as $productClass) {
  830.             // ランク価格の取得と保存処理
  831.             // 例: CustomerRankプラグインとの連携
  832.         }
  833.     }
  835.     /**
  836.      * 閲覧可能会員種別履歴を保存
  837.      *
  838.      * @param int $historyId
  839.      * @param Product $product
  840.      */
  841.     private function saveCustomerClassHistory($historyId, Product $product)
  842.     {
  843.         // EC-CUBE4では閲覧可能会員種別の管理が削除されているためスキップ
  844.         // 必要に応じて他のプラグインとの連携で実装
  845.         return;
  846.     }
  848.     /**
  849.      * ポイント付与率履歴を保存
  850.      *
  851.      * @param int $historyId
  852.      * @param Product $product
  853.      */
  854.     private function savePointHistory($historyId, Product $product)
  855.     {
  856.         // ポイント付与率の履歴保存処理
  857.         // 他のプラグインとの連携が必要な場合はここで実装
  858.     }
  860.     /**
  861.      * 目安価格履歴を保存
  862.      *
  863.      * @param int $historyId
  864.      * @param Product $product
  865.      */
  866.     private function saveMeyasuHistory($historyId, Product $product)
  867.     {
  868.         // PiaMeyasuプラグインとの連携
  869.         try {
  870.             // PiaMeyasuプラグインのEntityが存在するかチェック
  871.             if (class_exists('Plugin\PiaMeyasu\Entity\PiaMeyasu')) {
  872.                 $meyasuRepository = $this->entityManager->getRepository('Plugin\PiaMeyasu\Entity\PiaMeyasu');
  873.                 $meyasuData = $meyasuRepository->findOneBy(['product_id' => $product->getId()]);
  874.                 
  875.                 if ($meyasuData) {
  876.                     $meyasuHistory = new PiaHisMeyasu();
  877.                     $meyasuHistory->setHisId($historyId);
  878.                     $meyasuHistory->setProductId($product->getId());
  879.                     $meyasuHistory->setCoinCost($meyasuData->getCoinCost());
  880.                     $meyasuHistory->setExTypeId($meyasuData->getExTypeId());
  881.                     $meyasuHistory->setCommission($meyasuData->getCommission());
  882.                     $meyasuHistory->setEsDispPrice($meyasuData->getEsDispPrice());
  884.                     $this->entityManager->persist($meyasuHistory);
  885.                 }
  886.             }
  887.         } catch (\Exception $e) {
  888.             // エラーログを出力
  889.             error_log('PiaHistory: 目安価格履歴保存エラー - ' . $e->getMessage());
  890.         }
  891.     }
  893.     /**
  894.      * PiaProductDispプラグインから表示開始日を取得
  895.      *
  896.      * @param Product $product
  897.      * @return string|null
  898.      */
  899.     private function getDisplayStartDate(Product $product)
  900.     {
  901.         try {
  902.             if (class_exists('Plugin\PiaProductDisp\Entity\ProductDisplayPeriod')) {
  903.                 $displayPeriodRepository = $this->entityManager->getRepository('Plugin\PiaProductDisp\Entity\ProductDisplayPeriod');
  904.                 $displayPeriod = $displayPeriodRepository->findOneBy(['Product' => $product]);
  905.                 
  906.                 if ($displayPeriod && $displayPeriod->getDisplayStartDate()) {
  907.                     return $displayPeriod->getDisplayStartDate()->format('Y-m-d H:i:s');
  908.                 }
  909.             }
  910.         } catch (\Exception $e) {
  911.             error_log('PiaHistory: 表示開始日取得エラー - ' . $e->getMessage());
  912.         }
  913.         
  914.         return null;
  915.     }
  917.     /**
  918.      * PiaProductDispプラグインから表示終了日を取得
  919.      *
  920.      * @param Product $product
  921.      * @return string|null
  922.      */
  923.     private function getDisplayEndDate(Product $product)
  924.     {
  925.         try {
  926.             if (class_exists('Plugin\PiaProductDisp\Entity\ProductDisplayPeriod')) {
  927.                 $displayPeriodRepository = $this->entityManager->getRepository('Plugin\PiaProductDisp\Entity\ProductDisplayPeriod');
  928.                 $displayPeriod = $displayPeriodRepository->findOneBy(['Product' => $product]);
  929.                 
  930.                 if ($displayPeriod && $displayPeriod->getDisplayEndDate()) {
  931.                     return $displayPeriod->getDisplayEndDate()->format('Y-m-d H:i:s');
  932.                 }
  933.             }
  934.         } catch (\Exception $e) {
  935.             error_log('PiaHistory: 表示終了日取得エラー - ' . $e->getMessage());
  936.         }
  937.         
  938.         return null;
  939.     }
  940. }