app/Customize/Controller/Admin/Order/OrderController.php line 291

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of EC-CUBE
  5.  *
  6.  * Copyright(c) EC-CUBE CO.,LTD. All Rights Reserved.
  7.  *
  8.  * http://www.ec-cube.co.jp/
  9.  *
  10.  * For the full copyright and license information, please view the LICENSE
  11.  * file that was distributed with this source code.
  12.  */
  14. namespace Customize\Controller\Admin\Order;
  16. use Eccube\Common\Constant;
  17. use Eccube\Controller\AbstractController;
  18. use Eccube\Entity\ExportCsvRow;
  19. use Eccube\Entity\Master\CsvType;
  20. use Eccube\Entity\Master\OrderStatus;
  21. use Eccube\Entity\OrderPdf;
  22. use Eccube\Entity\Shipping;
  23. use Eccube\Event\EccubeEvents;
  24. use Eccube\Event\EventArgs;
  25. use Eccube\Form\Type\Admin\OrderPdfType;
  26. use Eccube\Form\Type\Admin\SearchOrderType;
  27. use Eccube\Repository\CustomerRepository;
  28. use Eccube\Repository\Master\OrderStatusRepository;
  29. use Eccube\Repository\Master\PageMaxRepository;
  30. use Eccube\Repository\Master\ProductStatusRepository;
  31. use Eccube\Repository\Master\SexRepository;
  32. use Eccube\Repository\OrderPdfRepository;
  33. use Eccube\Repository\OrderRepository;
  34. use Eccube\Repository\ShippingRepository;
  35. use Eccube\Repository\PaymentRepository;
  36. use Eccube\Repository\ProductStockRepository;
  37. use Eccube\Service\CsvExportService;
  38. use Customize\Service\MailService;
  39. use Eccube\Service\OrderPdfService;
  40. use Eccube\Service\OrderStateMachine;
  41. use Eccube\Service\PurchaseFlow\PurchaseFlow;
  42. use Eccube\Util\FormUtil;
  43. use Knp\Component\Pager\PaginatorInterface;
  44. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Template;
  45. use Symfony\Component\Form\FormBuilder;
  46. use Symfony\Component\HttpFoundation\RedirectResponse;
  47. use Symfony\Component\HttpFoundation\Request;
  48. use Symfony\Component\HttpFoundation\Response;
  49. use Symfony\Component\HttpFoundation\StreamedResponse;
  50. use Symfony\Component\Routing\Annotation\Route;
  51. use Symfony\Component\Validator\Constraints as Assert;
  52. use Symfony\Component\Validator\Validator\ValidatorInterface;
  53. use Customize\Repository\SetProductRepository;
  54. use Eccube\Repository\ProductClassRepository;
  55. use Eccube\Entity\OrderItem;
  56. use Customize\Form\Type\Admin\CustomOrderMailType;
  57. use Eccube\Repository\MailTemplateRepository;
  58. use Symfony\Component\Routing\Generator\UrlGeneratorInterface;
  59. use Customize\Repository\Master\CsvTypeCustomRepository;
  60. use Customize\Repository\CsvCustomRepository;
  61. use Eccube\Repository\Master\CsvTypeRepository;
  62. use Eccube\Repository\CsvRepository;
  63. use Customize\Entity\CsvCustom;
  65. class OrderController extends AbstractController
  66. {
  67.     /**
  68.      * @var PurchaseFlow
  69.      */
  70.     protected $purchaseFlow;
  72.     /**
  73.      * @var CsvExportService
  74.      */
  75.     protected $csvExportService;
  77.     /**
  78.      * @var CustomerRepository
  79.      */
  80.     protected $customerRepository;
  82.     /**
  83.      * @var PaymentRepository
  84.      */
  85.     protected $paymentRepository;
  87.     /**
  88.      * @var SexRepository
  89.      */
  90.     protected $sexRepository;
  92.     /**
  93.      * @var OrderStatusRepository
  94.      */
  95.     protected $orderStatusRepository;
  97.     /**
  98.      * @var PageMaxRepository
  99.      */
  100.     protected $pageMaxRepository;
  102.     /**
  103.      * @var ProductStatusRepository
  104.      */
  105.     protected $productStatusRepository;
  107.     /**
  108.      * @var OrderRepository
  109.      */
  110.     protected $orderRepository;
  112.     /** @var OrderPdfRepository */
  113.     protected $orderPdfRepository;
  115.     /**
  116.      * @var ProductStockRepository
  117.      */
  118.     protected $productStockRepository;
  120.     /** @var OrderPdfService */
  121.     protected $orderPdfService;
  123.     /**
  124.      * @var ValidatorInterface
  125.      */
  126.     protected $validator;
  128.     /**
  129.      * @var OrderStateMachine
  130.      */
  131.     protected $orderStateMachine;
  133.     /**
  134.      * @var MailService
  135.      */
  136.     protected $mailService;
  138.     /**
  139.      * @var SetProductRepository
  140.      */
  141.     protected $setProductRepository;
  143.     /**
  144.      * @var ProductClassRepository
  145.      */
  146.     protected $productClassRepository;
  148.     /**
  149.      * @var MailTemplateRepository
  150.      */
  151.     protected $mailTemplateRepository;
  153.     /**
  154.      * @var ShippingRepository
  155.      */
  156.     protected $shippingRepository;
  158.     /**
  159.      * @var CsvTypeCustomRepository
  160.      */
  161.     protected $csvTypeCustomRepository;
  163.     /**
  164.      * @var CsvCustomRepository
  165.      */
  166.     protected $csvCustomRepository;
  168.     /**
  169.      * @var CsvTypeRepository
  170.      */
  171.     protected $csvTypeRepository;
  173.     /**
  174.      * @var CsvRepository
  175.      */
  176.     protected $csvRepository;
  178.     /**
  179.      * OrderController constructor.
  180.      *
  181.      * @param PurchaseFlow $orderPurchaseFlow
  182.      * @param CsvExportService $csvExportService
  183.      * @param CustomerRepository $customerRepository
  184.      * @param PaymentRepository $paymentRepository
  185.      * @param SexRepository $sexRepository
  186.      * @param OrderStatusRepository $orderStatusRepository
  187.      * @param PageMaxRepository $pageMaxRepository
  188.      * @param ProductStatusRepository $productStatusRepository
  189.      * @param ProductStockRepository $productStockRepository
  190.      * @param OrderRepository $orderRepository
  191.      * @param OrderPdfRepository $orderPdfRepository
  192.      * @param ValidatorInterface $validator
  193.      * @param OrderStateMachine $orderStateMachine
  194.      * @param SetProductRepository $setProductRepository
  195.      * @param ProductClassRepository $productClassRepository
  196.      * @param MailTemplateRepository $mailTemplateRepository
  197.      */
  198.     public function __construct(
  199.         PurchaseFlow $orderPurchaseFlow,
  200.         CsvExportService $csvExportService,
  201.         CustomerRepository $customerRepository,
  202.         PaymentRepository $paymentRepository,
  203.         SexRepository $sexRepository,
  204.         OrderStatusRepository $orderStatusRepository,
  205.         PageMaxRepository $pageMaxRepository,
  206.         ProductStatusRepository $productStatusRepository,
  207.         ProductStockRepository $productStockRepository,
  208.         OrderRepository $orderRepository,
  209.         OrderPdfRepository $orderPdfRepository,
  210.         ValidatorInterface $validator,
  211.         OrderStateMachine $orderStateMachine,
  212.         MailService $mailService,
  213.         SetProductRepository $setProductRepository,
  214.         ProductClassRepository $productClassRepository,
  215.         OrderPdfService $orderPdfService,
  216.         MailTemplateRepository $mailTemplateRepository,
  217.         ShippingRepository $shippingRepository,
  218.         CsvTypeCustomRepository $csvTypeCustomRepository,
  219.         CsvCustomRepository $csvCustomRepository,
  220.         CsvTypeRepository $csvTypeRepository,
  221.         CsvRepository $csvRepository
  222.     ) {
  223.         $this->purchaseFlow = $orderPurchaseFlow;
  224.         $this->csvExportService = $csvExportService;
  225.         $this->customerRepository = $customerRepository;
  226.         $this->paymentRepository = $paymentRepository;
  227.         $this->sexRepository = $sexRepository;
  228.         $this->orderStatusRepository = $orderStatusRepository;
  229.         $this->pageMaxRepository = $pageMaxRepository;
  230.         $this->productStatusRepository = $productStatusRepository;
  231.         $this->productStockRepository = $productStockRepository;
  232.         $this->orderRepository = $orderRepository;
  233.         $this->orderPdfRepository = $orderPdfRepository;
  234.         $this->validator = $validator;
  235.         $this->orderStateMachine = $orderStateMachine;
  236.         $this->mailService = $mailService;
  237.         $this->setProductRepository = $setProductRepository;
  238.         $this->productClassRepository = $productClassRepository;
  239.         $this->orderPdfService = $orderPdfService;
  240.         $this->mailTemplateRepository = $mailTemplateRepository;
  241.         $this->shippingRepository = $shippingRepository;
  242.         $this->csvTypeCustomRepository = $csvTypeCustomRepository;
  243.         $this->csvCustomRepository = $csvCustomRepository;
  244.         $this->csvTypeRepository = $csvTypeRepository;
  245.         $this->csvRepository = $csvRepository;
  246.     }
  248.     /**
  249.      * 受注一覧画面.
  250.      *
  251.      * - 検索条件, ページ番号, 表示件数はセッションに保持されます.
  252.      * - クエリパラメータでresume=1が指定された場合、検索条件, ページ番号, 表示件数をセッションから復旧します.
  253.      * - 各データの, セッションに保持するアクションは以下の通りです.
  254.      *   - 検索ボタン押下時
  255.      *      - 検索条件をセッションに保存します
  256.      *      - ページ番号は1で初期化し、セッションに保存します。
  257.      *   - 表示件数変更時
  258.      *      - クエリパラメータpage_countをセッションに保存します。
  259.      *      - ただし, mtb_page_maxと一致しない場合, eccube_default_page_countが保存されます.
  260.      *   - ページング時
  261.      *      - URLパラメータpage_noをセッションに保存します.
  262.      *   - 初期表示
  263.      *      - 検索条件は空配列, ページ番号は1で初期化し, セッションに保存します.
  264.      *
  265.      * @Route("/%eccube_admin_route%/order", name="admin_order", methods={"GET", "POST"})
  266.      * @Route("/%eccube_admin_route%/order/page/{page_no}", requirements={"page_no" = "\d+"}, name="admin_order_page", methods={"GET", "POST"})
  267.      * @Template("@admin/Order/index.twig")
  268.      */
  269.     public function index(Request $request, PaginatorInterface $paginator, $page_no = null)
  270.     {
  271.         $builder = $this->formFactory
  272.             ->createBuilder(SearchOrderType::class);
  274.         $event = new EventArgs(
  275.             [
  276.                 'builder' => $builder,
  277.             ],
  278.             $request
  279.         );
  280.         $this->eventDispatcher->dispatch($event, EccubeEvents::ADMIN_ORDER_INDEX_INITIALIZE);
  282.         $searchForm = $builder->getForm();
  284.         /**
  285.          * ページの表示件数は, 以下の順に優先される.
  286.          * - リクエストパラメータ
  287.          * - セッション
  288.          * - デフォルト値
  289.          * また, セッションに保存する際は mtb_page_maxと照合し, 一致した場合のみ保存する.
  290.          **/
  291.         $page_count = $this->session->get(
  292.             'eccube.admin.order.search.page_count',
  293.             $this->eccubeConfig->get('eccube_default_page_count')
  294.         );
  296.         $page_count_param = (int) $request->get('page_count');
  297.         $pageMaxis = $this->pageMaxRepository->findAll();
  299.         if ($page_count_param) {
  300.             foreach ($pageMaxis as $pageMax) {
  301.                 if ($page_count_param == $pageMax->getName()) {
  302.                     $page_count = $pageMax->getName();
  303.                     $this->session->set('eccube.admin.order.search.page_count', $page_count);
  304.                     break;
  305.                 }
  306.             }
  307.         }
  309.         if ('POST' === $request->getMethod()) {
  310.             $searchForm->handleRequest($request);
  312.             if ($searchForm->isValid()) {
  313.                 /**
  314.                  * 検索が実行された場合は, セッションに検索条件を保存する.
  315.                  * ページ番号は最初のページ番号に初期化する.
  316.                  */
  317.                 $page_no = 1;
  318.                 $searchData = $searchForm->getData();
  320.                 // 検索条件, ページ番号をセッションに保持.
  321.                 $this->session->set('eccube.admin.order.search', FormUtil::getViewData($searchForm));
  322.                 $this->session->set('eccube.admin.order.search.page_no', $page_no);
  323.             } else {
  324.                 // 検索エラーの際は, 詳細検索枠を開いてエラー表示する.
  325.                 return [
  326.                     'searchForm' => $searchForm->createView(),
  327.                     'pagination' => [],
  328.                     'pageMaxis' => $pageMaxis,
  329.                     'page_no' => $page_no,
  330.                     'page_count' => $page_count,
  331.                     'has_errors' => true,
  332.                 ];
  333.             }
  334.         } else {
  335.             if (null !== $page_no || $request->get('resume')) {
  336.                 /*
  337.                  * ページ送りの場合または、他画面から戻ってきた場合は, セッションから検索条件を復旧する.
  338.                  */
  339.                 if ($page_no) {
  340.                     // ページ送りで遷移した場合.
  341.                     $this->session->set('eccube.admin.order.search.page_no', (int) $page_no);
  342.                 } else {
  343.                     // 他画面から遷移した場合.
  344.                     $page_no = $this->session->get('eccube.admin.order.search.page_no', 1);
  345.                 }
  346.                 $viewData = $this->session->get('eccube.admin.order.search', []);
  347.                 $searchData = FormUtil::submitAndGetData($searchForm, $viewData);
  348.             } else {
  349.                 /**
  350.                  * 初期表示の場合.
  351.                  */
  352.                 $page_no = 1;
  353.                 $viewData = [];
  355.                 if ($statusId = (int) $request->get('order_status_id')) {
  356.                     $viewData = ['status' => [$statusId]];
  357.                 }
  359.                 $searchData = FormUtil::submitAndGetData($searchForm, $viewData);
  361.                 // セッション中の検索条件, ページ番号を初期化.
  362.                 $this->session->set('eccube.admin.order.search', $viewData);
  363.                 $this->session->set('eccube.admin.order.search.page_no', $page_no);
  364.             }
  365.         }
  366.         if (!empty($searchData['temp_order_date_start']) && $searchData['temp_order_date_start'] || !empty($searchData['temp_order_date_end']) && $searchData['temp_order_date_end']) {
  367.             $searchData['status'][] = $this->eccubeConfig['order_temporary'];
  368.         }
  369.         $qb = $this->orderRepository->getQueryBuilderBySearchDataForAdmin($searchData);
  371.         $event = new EventArgs(
  372.             [
  373.                 'qb' => $qb,
  374.                 'searchData' => $searchData,
  375.             ],
  376.             $request
  377.         );
  379.         $this->eventDispatcher->dispatch($event, EccubeEvents::ADMIN_ORDER_INDEX_SEARCH);
  380.         $sortKey = $searchData['sortkey'];
  382.         if (empty($this->orderRepository::COLUMNS[$sortKey]) || $sortKey == 'order_status') {
  383.             $pagination = $paginator->paginate(
  384.                 $qb,
  385.                 $page_no,
  386.                 $page_count
  387.             );
  388.         } else {
  389.             $pagination = $paginator->paginate(
  390.                 $qb,
  391.                 $page_no,
  392.                 $page_count,
  393.                 ['wrap-queries' => true]
  394.             );
  395.         }
  397.         $mailFormBuilder = $this->formFactory->createBuilder(CustomOrderMailType::class);
  398.         // $this->eventDispatcher->dispatch($event, EccubeEvents::ADMIN_ORDER_MAIL_INDEX_INITIALIZE);
  400.         $mailForm = $mailFormBuilder->getForm();
  401.         $csvTypeCustoms = $this->csvTypeCustomRepository->findAll();
  403.         return [
  404.             'searchForm' => $searchForm->createView(),
  405.             'pagination' => $pagination,
  406.             'pageMaxis' => $pageMaxis,
  407.             'page_no' => $page_no,
  408.             'page_count' => $page_count,
  409.             'has_errors' => false,
  410.             'OrderStatuses' => $this->orderStatusRepository->findBy([], ['sort_no' => 'ASC']),
  411.             'mailForm' => $mailForm->createView(),
  412.             'csvTypeCustoms' => $csvTypeCustoms
  413.         ];
  414.     }
  416.     /**
  417.      * @Route("/%eccube_admin_route%/order/bulk_delete", name="admin_order_bulk_delete", methods={"POST"})
  418.      */
  419.     public function bulkDelete(Request $request)
  420.     {
  421.         $this->isTokenValid();
  422.         $ids = $request->get('ids');
  423.         foreach ($ids as $order_id) {
  424.             $Order = $this->orderRepository
  425.                 ->find($order_id);
  426.             if ($Order) {
  427.                 $this->entityManager->remove($Order);
  428.                 log_info('受注削除', [$Order->getId()]);
  429.             }
  430.         }
  432.         $this->entityManager->flush();
  434.         $this->addSuccess('admin.common.delete_complete', 'admin');
  436.         return $this->redirect($this->generateUrl('admin_order', ['resume' => Constant::ENABLED]));
  437.     }
  439.     /**
  440.      * 受注CSVの出力.
  441.      *
  442.      * @Route("/%eccube_admin_route%/order/export/order", name="admin_order_export_order", methods={"GET"})
  443.      *
  444.      * @param Request $request
  445.      *
  446.      * @return StreamedResponse
  447.      */
  448.     public function exportOrder(Request $request)
  449.     {
  450.         $filename = 'order_' . (new \DateTime())->format('YmdHis') . '.csv';
  451.         $response = $this->exportCsv($request, CsvType::CSV_TYPE_ORDER, $filename);
  452.         log_info('受注CSV出力ファイル名', [$filename]);
  454.         return $response;
  455.     }
  457.     /**
  458.      * 配送CSVの出力.
  459.      *
  460.      * @Route("/%eccube_admin_route%/order/export/shipping", name="admin_order_export_shipping", methods={"GET"})
  461.      *
  462.      * @param Request $request
  463.      *
  464.      * @return StreamedResponse
  465.      */
  466.     public function exportShipping(Request $request)
  467.     {
  468.         $filename = 'shipping_' . (new \DateTime())->format('YmdHis') . '.csv';
  469.         $response = $this->exportCsv($request, CsvType::CSV_TYPE_SHIPPING, $filename);
  470.         log_info('配送CSV出力ファイル名', [$filename]);
  472.         return $response;
  473.     }
  475.     protected function prepareOrderItem(Request $request, $OrderItem, $Order, $Csvs, $Customer, $csvService, $ExportCsvRow, $SetProductOrderItem = null)
  476.     {
  477.         // CSV出力項目と合致するデータを取得.
  478.         foreach ($Csvs as $Csv) {
  479.             // 受注データを検索.
  480.             $ExportCsvRow->setData($csvService->getData($Csv, $Order));
  481.             $this->processCsvData($OrderItem, $Csv, $Customer, $csvService, $ExportCsvRow, $SetProductOrderItem);
  482.             $event = new EventArgs(
  483.                 [
  484.                     'csvService' => $csvService,
  485.                     'Csv' => $Csv,
  486.                     'OrderItem' => $OrderItem,
  487.                     'ExportCsvRow' => $ExportCsvRow,
  488.                 ],
  489.                 $request
  490.             );
  491.             $this->eventDispatcher->dispatch($event, EccubeEvents::ADMIN_ORDER_CSV_EXPORT_ORDER);
  493.             $ExportCsvRow->pushData();
  494.         }
  495.     }
  497.     /**
  498.      * @param Request $request
  499.      * @param $csvTypeId
  500.      * @param string $fileName
  501.      *
  502.      * @return StreamedResponse
  503.      */
  504.     protected function exportCsv(Request $request, $csvTypeId, $fileName)
  505.     {
  506.         // タイムアウトを無効にする.
  507.         set_time_limit(0);
  509.         // sql loggerを無効にする.
  510.         $em = $this->entityManager;
  511.         $em->getConfiguration()->setSQLLogger(null);
  512.         $response = new StreamedResponse();
  514.         $response->setCallback(function () use ($request, $csvTypeId) {
  515.             // CSV種別を元に初期化.
  516.             $this->csvExportService->initCsvType($csvTypeId);
  518.             // 受注データ検索用のクエリビルダを取得.
  519.             $qb = $this->csvExportService
  520.                 ->getOrderQueryBuilder($request);
  522.             // ヘッダ行の出力.
  523.             $this->csvExportService->exportHeader();
  525.             // データ行の出力.
  526.             $this->csvExportService->setExportQueryBuilder($qb);
  527.             $this->csvExportService->exportData(function ($entity, $csvService) use ($request) {
  528.                 $Csvs = $csvService->getCsvs();
  529.                 $Order = $entity;
  530.                 $OrderItems = $Order->getOrderItems();
  531.                 $Customer = $Order->getCustomer();
  533.                 foreach ($OrderItems as $OrderItem) {
  534.                     if ($OrderItem->isProduct()) {
  535.                         if ($OrderItem->getProduct()->getProductType() == 'set') {
  536.                             $set_product = $this->setProductRepository->find($OrderItem->getProduct()->getSetProductId());
  537.                             //Prepare OrderItem
  538.                             $inset_products = $set_product->getSetProductProduct();
  539.                             $inset_product_class_ids = $OrderItem->getSetProductClass();
  540.                             $inset_product_classes = array();
  541.                             foreach ($inset_product_class_ids as $ipci) {
  542.                                 if (!empty($ipci)) {
  543.                                     $ipc = $this->productClassRepository->find($ipci);
  544.                                     if ($ipc)
  545.                                         $inset_product_classes[$ipc->getProduct()->getId()] = $ipc;
  546.                                 }
  547.                             }
  548.                             $set_price = $OrderItem->getSetProductPrice();
  549.                             foreach ($inset_products as $isp) {
  550.                                 $isp_product = $isp->getProduct();
  551.                                 $InSetProductOrderItem = new OrderItem;
  552.                                 $InSetProductOrderItem->setOrder($Order)
  553.                                     ->setProduct($isp_product);
  554.                                 if (isset($inset_product_classes[$isp_product->getId()])) {
  555.                                     $inset_product_class = $inset_product_classes[$isp_product->getId()];
  556.                                     $InSetProductOrderItem->setProductClass($inset_product_class)
  557.                                         ->setProductCode($inset_product_class->getCode())
  558.                                         ->setPrice($set_price && isset($set_price[$isp_product->getId()]) ? $set_price[$isp_product->getId()] : $isp->getSetProductPrice());
  559.                                     $ClassCategory1 = $inset_product_class->getClassCategory1();
  560.                                     if (!is_null($ClassCategory1)) {
  561.                                         $InSetProductOrderItem->setClasscategoryName1($ClassCategory1->getName());
  562.                                         $InSetProductOrderItem->setClassName1($ClassCategory1->getClassName()->getName());
  563.                                     }
  564.                                     $ClassCategory2 = $inset_product_class->getClassCategory2();
  565.                                     if (!is_null($ClassCategory2)) {
  566.                                         $InSetProductOrderItem->setClasscategoryName2($ClassCategory2->getName());
  567.                                         $InSetProductOrderItem->setClassName2($ClassCategory2->getClassName()->getName());
  568.                                     }
  569.                                 }
  570.                                 $InSetProductOrderItem->setProductName($isp_product->getName())
  571.                                     ->setQuantity($OrderItem->getQuantity())
  572.                                     ->setOrderItemType($OrderItem->getOrderItemType())
  573.                                     ->setDeliveryPeriod($OrderItem->getDeliveryPeriod())
  574.                                     ->setSetProductClass($OrderItem->getSetProductClass());
  576.                                 $Shipping = $OrderItem->getShipping();
  577.                                 $InSetProductOrderItem->setShipping($Shipping);
  578.                                 $Brother = $OrderItem->getBrother();
  579.                                 $InSetProductOrderItem->setBrother($Brother);
  581.                                 $ExportCsvRow = new ExportCsvRow();
  582.                                 $this->prepareOrderItem($request, $InSetProductOrderItem, $Order, $Csvs, $Customer, $csvService, $ExportCsvRow, $OrderItem);
  584.                                 //$row[] = number_format(memory_get_usage(true));
  585.                                 // 出力.
  586.                                 $csvService->fputcsv($ExportCsvRow->getRow());
  587.                             }
  588.                         } else {
  589.                             $ExportCsvRow = new ExportCsvRow();
  590.                             $this->prepareOrderItem($request, $OrderItem, $Order, $Csvs, $Customer, $csvService, $ExportCsvRow);
  592.                             //$row[] = number_format(memory_get_usage(true));
  593.                             // 出力.
  594.                             $csvService->fputcsv($ExportCsvRow->getRow());
  595.                         }
  596.                     }
  597.                 }
  598.             });
  599.         });
  601.         $response->headers->set('Content-Type', 'application/octet-stream');
  602.         $response->headers->set('Content-Disposition', 'attachment; filename=' . $fileName);
  604.         return $response;
  605.     }
  607.     /**
  608.      * Update to order status
  609.      *
  610.      * @Route("/%eccube_admin_route%/shipping/{id}/order_status", requirements={"id" = "\d+"}, name="admin_shipping_update_order_status", methods={"PUT"})
  611.      *
  612.      * @param Request $request
  613.      * @param Shipping $Shipping
  614.      *
  615.      * @return \Symfony\Component\HttpFoundation\JsonResponse
  616.      */
  617.     public function updateOrderStatus(Request $request, Shipping $Shipping)
  618.     {
  619.         if (!($request->isXmlHttpRequest() && $this->isTokenValid())) {
  620.             return $this->json(['status' => 'NG'], 400);
  621.         }
  623.         $Order = $Shipping->getOrder();
  624.         $OrderStatus = $this->entityManager->find(OrderStatus::class, $request->get('order_status'));
  626.         if (!$OrderStatus) {
  627.             return $this->json(['status' => 'NG'], 400);
  628.         }
  630.         $result = [];
  631.         try {
  632.             if ($Order->getOrderStatus()->getId() == $OrderStatus->getId()) {
  633.                 log_info('対応状況一括変更スキップ');
  634.                 $result = ['message' => trans('admin.order.skip_change_status', ['%name%' => $Shipping->getId()])];
  635.             } else {
  636.                 if ($this->orderStateMachine->can($Order, $OrderStatus)) {
  637.                     if ($OrderStatus->getId() == OrderStatus::DELIVERED) {
  638.                         if (!$Shipping->isShipped()) {
  639.                             $Shipping->setShippingDate(new \DateTime());
  640.                         }
  641.                         $allShipped = true;
  642.                         foreach ($Order->getShippings() as $Ship) {
  643.                             if (!$Ship->isShipped()) {
  644.                                 $allShipped = false;
  645.                                 break;
  646.                             }
  647.                         }
  648.                         if ($allShipped) {
  649.                             $this->orderStateMachine->apply($Order, $OrderStatus);
  650.                         }
  651.                     } else {
  652.                         $this->orderStateMachine->apply($Order, $OrderStatus);
  653.                     }
  654.                     $pdfPath = null;
  655.                     if ($request->get('deliveryNote', false)) {
  656.                         $pdfPath = $this->createPdf($Shipping->getId());
  657.                     }
  658.                     if ($request->get('notificationMail')) { // for SimpleStatusUpdate
  659.                         $this->mailService->sendShippingNotifyMail($Shipping, $request->get('deliveryNote', false), $pdfPath);
  660.                         $Shipping->setMailSendDate(new \DateTime());
  661.                         $result['mail'] = true;
  662.                     } else {
  663.                         $result['mail'] = false;
  664.                     }
  665.                     // 対応中・キャンセルの更新時は商品在庫を増減させているので商品情報を更新
  666.                     if ($OrderStatus->getId() == OrderStatus::IN_PROGRESS || $OrderStatus->getId() == OrderStatus::CANCEL) {
  667.                         foreach ($Order->getOrderItems() as $OrderItem) {
  668.                             $ProductClass = $OrderItem->getProductClass();
  669.                             if ($OrderItem->isProduct() && !$ProductClass->isStockUnlimited()) {
  670.                                 $this->entityManager->persist($ProductClass);
  671.                                 $this->entityManager->flush();
  672.                                 $ProductStock = $this->productStockRepository->findOneBy(['ProductClass' => $ProductClass]);
  673.                                 $this->entityManager->persist($ProductStock);
  674.                                 $this->entityManager->flush();
  675.                             }
  676.                         }
  677.                     }
  678.                     $this->entityManager->persist($Order);
  679.                     $this->entityManager->persist($Shipping);
  680.                     $this->entityManager->flush();
  682.                     // 会員の場合、購入回数、購入金額などを更新
  683.                     if ($Customer = $Order->getCustomer()) {
  684.                         $this->orderRepository->updateOrderSummary($Customer);
  685.                         $this->entityManager->persist($Customer);
  686.                         $this->entityManager->flush();
  687.                     }
  688.                 } else {
  689.                     $from = $Order->getOrderStatus()->getName();
  690.                     $to = $OrderStatus->getName();
  691.                     $result = ['message' => trans('admin.order.failed_to_change_status', [
  692.                         '%name%' => $Shipping->getId(),
  693.                         '%from%' => $from,
  694.                         '%to%' => $to,
  695.                     ])];
  696.                 }
  698.                 log_info('対応状況一括変更処理完了', [$Order->getId()]);
  699.             }
  700.         } catch (\Exception $e) {
  701.             log_error('予期しないエラーです', [$e->getMessage()]);
  703.             return $this->json(['status' => 'NG'], 500);
  704.         }
  706.         return $this->json(array_merge(['status' => 'OK'], $result));
  707.     }
  709.     /**
  710.      * Update to Tracking number.
  711.      *
  712.      * @Route("/%eccube_admin_route%/shipping/{id}/tracking_number", requirements={"id" = "\d+"}, name="admin_shipping_update_tracking_number", methods={"PUT"})
  713.      *
  714.      * @param Request $request
  715.      * @param Shipping $shipping
  716.      *
  717.      * @return Response
  718.      */
  719.     public function updateTrackingNumber(Request $request, Shipping $shipping)
  720.     {
  721.         if (!($request->isXmlHttpRequest() && $this->isTokenValid())) {
  722.             return $this->json(['status' => 'NG'], 400);
  723.         }
  725.         $trackingNumber = mb_convert_kana($request->get('tracking_number'), 'a', 'utf-8');
  726.         /** @var \Symfony\Component\Validator\ConstraintViolationListInterface $errors */
  727.         $errors = $this->validator->validate(
  728.             $trackingNumber,
  729.             [
  730.                 new Assert\Length(['max' => $this->eccubeConfig['eccube_stext_len']]),
  731.                 new Assert\Regex(
  732.                     ['pattern' => '/^[0-9a-zA-Z-]+$/u', 'message' => trans('admin.order.tracking_number_error')]
  733.                 ),
  734.             ]
  735.         );
  737.         if ($errors->count() != 0) {
  738.             log_info('送り状番号入力チェックエラー');
  739.             $messages = [];
  740.             /** @var \Symfony\Component\Validator\ConstraintViolationInterface $error */
  741.             foreach ($errors as $error) {
  742.                 $messages[] = $error->getMessage();
  743.             }
  745.             return $this->json(['status' => 'NG', 'messages' => $messages], 400);
  746.         }
  748.         try {
  749.             $shipping->setTrackingNumber($trackingNumber);
  750.             $this->entityManager->persist($shipping);
  751.             $this->entityManager->flush();
  752.             log_info('送り状番号変更処理完了', [$shipping->getId()]);
  753.             $message = ['status' => 'OK', 'shipping_id' => $shipping->getId(), 'tracking_number' => $trackingNumber];
  755.             return $this->json($message);
  756.         } catch (\Exception $e) {
  757.             log_error('予期しないエラー', [$e->getMessage()]);
  759.             return $this->json(['status' => 'NG'], 500);
  760.         }
  761.     }
  763.     /**
  764.      * @Route("/%eccube_admin_route%/order/export/pdf", name="admin_order_export_pdf", methods={"GET", "POST"})
  765.      * @Template("@admin/Order/order_pdf.twig")
  766.      *
  767.      * @param Request $request
  768.      *
  769.      * @return array|RedirectResponse
  770.      */
  771.     public function exportPdf(Request $request)
  772.     {
  773.         // requestから出荷番号IDの一覧を取得する.
  774.         $ids = $request->get('ids', []);
  776.         if (count($ids) == 0) {
  777.             $this->addError('admin.order.delivery_note_parameter_error', 'admin');
  778.             log_info('The Order cannot found!');
  780.             return $this->redirectToRoute('admin_order');
  781.         }
  783.         /** @var OrderPdf $OrderPdf */
  784.         $OrderPdf = $this->orderPdfRepository->find($this->getUser());
  786.         if (!$OrderPdf) {
  787.             $OrderPdf = new OrderPdf();
  788.             $OrderPdf
  789.                 ->setTitle(trans('admin.order.delivery_note_title__default'))
  790.                 ->setMessage1(trans('admin.order.delivery_note_message__default1'))
  791.                 ->setMessage2(trans('admin.order.delivery_note_message__default2'))
  792.                 ->setMessage3(trans('admin.order.delivery_note_message__default3'));
  793.         }
  795.         /**
  796.          * @var FormBuilder
  797.          */
  798.         $builder = $this->formFactory->createBuilder(OrderPdfType::class, $OrderPdf);
  800.         /* @var \Symfony\Component\Form\Form $form */
  801.         $form = $builder->getForm();
  803.         // Formへの設定
  804.         $form->get('ids')->setData(implode(',', $ids));
  806.         return [
  807.             'form' => $form->createView(),
  808.         ];
  809.     }
  811.     /**
  812.      * @Route("/%eccube_admin_route%/order/export/pdf/download", name="admin_order_pdf_download", methods={"POST"})
  813.      * @Template("@admin/Order/order_pdf.twig")
  814.      *
  815.      * @param Request $request
  816.      *
  817.      * @return Response
  818.      */
  819.     public function exportPdfDownload(Request $request, OrderPdfService $orderPdfService)
  820.     {
  821.         /**
  822.          * @var FormBuilder
  823.          */
  824.         $builder = $this->formFactory->createBuilder(OrderPdfType::class);
  826.         /* @var \Symfony\Component\Form\Form $form */
  827.         $form = $builder->getForm();
  828.         $form->handleRequest($request);
  830.         // Validation
  831.         if (!$form->isValid()) {
  832.             log_info('The parameter is invalid!');
  834.             return $this->render('@admin/Order/order_pdf.twig', [
  835.                 'form' => $form->createView(),
  836.             ]);
  837.         }
  839.         $arrData = $form->getData();
  841.         // 購入情報からPDFを作成する
  842.         $status = $orderPdfService->makePdf($arrData);
  844.         // 異常終了した場合の処理
  845.         if (!$status) {
  846.             $this->addError('admin.order.export.pdf.download.failure', 'admin');
  847.             log_info('Unable to create pdf files! Process have problems!');
  849.             return $this->render('@admin/Order/order_pdf.twig', [
  850.                 'form' => $form->createView(),
  851.             ]);
  852.         }
  854.         // TCPDF::Outputを実行するとプロパティが初期化されるため、ファイル名を事前に取得しておく
  855.         $pdfFileName = $orderPdfService->getPdfFileName();
  857.         // ダウンロードする
  858.         $response = new Response(
  859.             $orderPdfService->outputPdf(),
  860.             200,
  861.             ['content-type' => 'application/pdf']
  862.         );
  864.         $downloadKind = $form->get('download_kind')->getData();
  866.         // レスポンスヘッダーにContent-Dispositionをセットし、ファイル名を指定
  867.         if ($downloadKind == 1) {
  868.             $response->headers->set('Content-Disposition', 'attachment; filename="' . $pdfFileName . '"');
  869.         } else {
  870.             $response->headers->set('Content-Disposition', 'inline; filename="' . $pdfFileName . '"');
  871.         }
  873.         log_info('OrderPdf download success!', ['Order ID' => implode(',', $request->get('ids', []))]);
  875.         $isDefault = isset($arrData['default']) ? $arrData['default'] : false;
  876.         if ($isDefault) {
  877.             // Save input to DB
  878.             $arrData['admin'] = $this->getUser();
  879.             $this->orderPdfRepository->save($arrData);
  880.         }
  882.         return $response;
  883.     }
  885.     private function createPdf($id)
  886.     {
  887.         /** @var OrderPdf $OrderPdf */
  888.         $OrderPdf = $this->orderPdfRepository->find($this->getUser());
  890.         if (!$OrderPdf) {
  891.             $OrderPdf = new OrderPdf();
  892.             $OrderPdf
  893.                 ->setTitle(trans('admin.order.delivery_note_title__default'))
  894.                 ->setMessage1(trans('admin.order.delivery_note_message__default1'))
  895.                 ->setMessage2(trans('admin.order.delivery_note_message__default2'))
  896.                 ->setMessage3(trans('admin.order.delivery_note_message__default3'));
  897.         }
  900.         $arrData = array();
  901.         $arrData['ids'] = $id;
  902.         $arrData['issue_date'] = new \DateTime();
  903.         $arrData['title'] = trans('admin.order.delivery_note_title__default');
  904.         $arrData['message1'] = trans('admin.order.delivery_note_message__default1');
  905.         $arrData['message2'] = trans('admin.order.delivery_note_message__default2');
  906.         $arrData['message3'] = trans('admin.order.delivery_note_message__default3');
  907.         $arrData['note1'] = '';
  908.         $arrData['note2'] = '';
  909.         $arrData['note3'] = '';
  911.         // 購入情報からPDFを作成する
  912.         $status = $this->orderPdfService->makePdf($arrData);
  914.         // 異常終了した場合の処理
  915.         if (!$status) {
  916.             $this->addError('admin.order.export.pdf.download.failure', 'admin');
  917.             log_info('Unable to create pdf files! Process have problems!');
  919.             return;
  920.         }
  922.         // TCPDF::Outputを実行するとプロパティが初期化されるため、ファイル名を事前に取得しておく
  923.         $pdfFileName = $this->orderPdfService->getPdfFileName();
  924.         $pdfPath = $this->eccubeConfig['eccube_theme_user_data_dir'] . '/order_pdf/' . $pdfFileName;
  925.         $this->orderPdfService->Output($pdfPath, 'F');
  927.         return $pdfPath;
  928.     }
  930.     /**
  931.      * @Route("/%eccube_admin_route%/order/mail/template/", name="admin_order_mail_templete", methods={"POST"})
  932.      */
  933.     public function getMailTemplate(Request $request)
  934.     {
  935.         if ($request->isXmlHttpRequest()) {
  936.             $template_id = $request->get('template_id', null);
  937.             $order_id = $request->get('order_id', null);
  938.             $shipping_id = $request->get('shipping_id', null);
  939.             if ($template_id) {
  940.                 $MailTemplate = $this->mailTemplateRepository->find($template_id);
  942.                 if ($MailTemplate) {
  943.                     $twig = $MailTemplate->getFileName();
  944.                     if (!$twig) {
  945.                         $twig = 'Mail/order.twig';
  946.                     }
  947.                     $Order = $this->orderRepository->find($order_id);
  948.                     $Shipping = $this->shippingRepository->find($shipping_id);
  949.                     $historyUrl = is_null($Order->getCustomer())
  950.                         ? null
  951.                         : $this->container->get('router')->generate('mypage_history', ['order_no' => $Order->getOrderNo()], UrlGeneratorInterface::ABSOLUTE_URL);
  952.                     $body = $this->renderView($twig, [
  953.                         'Order' => $Order,
  954.                         'Shipping' => $Shipping,
  955.                         'isCvsPay' => false,
  956.                         'historyUrl' => $historyUrl
  957.                     ]);
  958.                     // if(file_exists($this->getParameter('eccube_theme_front_dir') . '/' . $twig)) {
  959.                     //     $body = file_get_contents($this->getParameter('eccube_theme_front_dir') . '/' . $twig);
  960.                     // }
  961.                     // else {
  962.                     //     $body = file_get_contents($this->getParameter('eccube_theme_front_default_dir') . '/' . $twig);
  963.                     // }
  965.                     $subject = $MailTemplate->getMailSubject();
  967.                     // 本文確認用
  968.                     return $this->json([
  969.                         'done' => true,
  970.                         'body' => $body,
  971.                         'subject' => $subject
  972.                     ]);
  973.                 }
  974.             }
  975.         }
  976.         return $this->json([
  977.             'done' => false,
  978.             'body' => null
  979.         ]);
  980.     }
  982.     protected function processCsvData($OrderItem, $Csv, $Customer, $csvService, $ExportCsvRow, $SetProductOrderItem = null)
  983.     {
  984.         if ($ExportCsvRow->isDataNull()) {
  985.             // 受注データにない場合は, 受注明細を検索.
  986.             switch ($Csv->getFieldName()) {
  987.                 case 'School':
  988.                     $brother = $OrderItem->getBrother();
  989.                     if ($brother) {
  990.                         $brother_school = $brother->getSchool();
  991.                         if ($Csv->getReferenceFieldName() == 'school_id') {
  992.                             $ExportCsvRow->setData($brother_school ? $brother_school->getSchoolId() : '');
  993.                         } else if ($Csv->getReferenceFieldName() == 'school_name') {
  994.                             $ExportCsvRow->setData($brother_school ? $brother_school->getSchoolName() : '');
  995.                         } else {
  996.                             $ExportCsvRow->setData($csvService->getData($Csv, $OrderItem));
  997.                         }
  998.                     } else {
  999.                         $ExportCsvRow->setData($csvService->getData($Csv, $OrderItem));
  1000.                     }
  1001.                     break;
  1002.                 case 'class_category_internal_name1':
  1003.                     if ($OrderItem->isProduct()) {
  1004.                         $productClass = $OrderItem->getProductClass();
  1005.                         $ClassCategory1 = $productClass->getClassCategory1();
  1006.                         if ($ClassCategory1) {
  1007.                             $ExportCsvRow->setData($ClassCategory1->getInternalName());
  1008.                         }
  1009.                     }
  1010.                     break;
  1011.                 case 'class_category_internal_name2':
  1012.                     if ($OrderItem->isProduct()) {
  1013.                         $productClass = $OrderItem->getProductClass();
  1014.                         $ClassCategory2 = $productClass->getClassCategory2();
  1015.                         if ($ClassCategory2) {
  1016.                             $ExportCsvRow->setData($ClassCategory2->getInternalName());
  1017.                         }
  1018.                     }
  1019.                     break;
  1020.                 default:
  1021.                     if (
  1022.                         $Csv->getEntityName() == 'Eccube\\\\Entity\\\\OrderItem'
  1023.                         && $Csv->getFieldName() == 'id'
  1024.                         && $SetProductOrderItem
  1025.                     ) {
  1026.                         $ExportCsvRow->setData($SetProductOrderItem->getId());
  1027.                     } else {
  1028.                         $ExportCsvRow->setData($csvService->getData($Csv, $OrderItem));
  1029.                     }
  1030.                     break;
  1031.             }
  1032.         }
  1033.         if ($ExportCsvRow->isDataNull() && $Shipping = $OrderItem->getShipping()) {
  1034.             // 受注明細データにない場合は, 出荷を検索.
  1035.             $ExportCsvRow->setData($csvService->getData($Csv, $Shipping));
  1036.         }
  1037.         if ($ExportCsvRow->isDataNull() && $Customer) {
  1038.             // 会員情報を検索.
  1039.             switch ($Csv->getFieldName()) {
  1040.                 case 'prev_school_year':
  1041.                     $ExportCsvRow->setData($csvService->getData($Csv, $Customer) . '年 ' . $Customer->getPrevSchoolClass() . '組');
  1042.                     break;
  1044.                 case 'contractor_name01':
  1045.                     $ExportCsvRow->setData($csvService->getData($Csv, $Customer) . ' ' . $Customer->getContractorName02());
  1046.                     break;
  1048.                 case 'contractor_birth':
  1049.                     $ExportCsvRow->setData(date("Y-m-d", strtotime($csvService->getData($Csv, $Customer))));
  1050.                     break;
  1052.                 case 'school_year':
  1053.                     $ExportCsvRow->setData($csvService->getData($Csv, $Customer) . '年 ' . $Customer->getSchoolClass() . '組');
  1054.                     break;
  1055.                 case 'Apparel':
  1056.                     $apprel = $OrderItem->isProduct() ? $OrderItem->getProduct()->getApparel() : null;
  1057.                     if ($apprel) {
  1058.                         if ($Csv->getReferenceFieldName() == 'apparel_id') {
  1059.                             $ExportCsvRow->setData($apprel->getApparelId());
  1060.                         } else if ($Csv->getReferenceFieldName() == 'apparel_name') {
  1061.                             $ExportCsvRow->setData($apprel->getApparelName());
  1062.                         }
  1063.                     }
  1064.                     break;
  1065.                 default:
  1066.                     $ExportCsvRow->setData($csvService->getData($Csv, $Customer));
  1067.                     break;
  1068.             }
  1069.         }
  1070.     }
  1072.     protected function prepareOrderItemCustom($OrderItem, $Order, $CsvCustom, $Customer, $csvService, $ExportCsvRow, $SetProductOrderItem = null)
  1073.     {
  1074.         $itemFound = false;
  1075.         $CsvDefault = $CsvCustom->getCsvDefault();
  1076.         if ($SetProductOrderItem) {
  1077.             $ExportCsvRow->setData($csvService->getData($CsvDefault, $Order));
  1078.             $this->processCsvData($OrderItem, $CsvDefault, $Customer, $csvService, $ExportCsvRow, $SetProductOrderItem);
  1079.             $ExportCsvRow->pushData();
  1080.             $itemFound = true;
  1081.         } else {
  1082.             $ExportCsvRow->setData($csvService->getData($CsvDefault, $Order));
  1083.             $this->processCsvData($OrderItem, $CsvDefault, $Customer, $csvService, $ExportCsvRow, $SetProductOrderItem);
  1084.             $ExportCsvRow->pushData();
  1085.             $itemFound = true;
  1086.         }
  1088.         return $itemFound;
  1089.     }
  1091.     protected function prepareOrderCustom($Order, $CsvCustoms, $Customer, $ExportCsvRow)
  1092.     {
  1093.         $OrderItems = $Order->getOrderItems();
  1094.         $processed_items = [];
  1095.         // CSV出力項目と合致するデータを取得.
  1096.         foreach ($CsvCustoms as $index => $CsvCustom) {
  1097.             $CsvDefault = $CsvCustom->getCsvDefault();
  1098.             switch ($CsvCustom->getFieldType()) {
  1099.                 case 0:
  1100.                     if ($CsvCustom->getProduct()->isSetProduct()) {
  1101.                         continue;
  1102.                     }
  1103.                     $itemFound = false;
  1104.                     foreach ($OrderItems as $OrderItem) {
  1105.                         if ($OrderItem->isProduct()) {
  1106.                             if ($OrderItem->getProduct()->isSetProduct()) {
  1107.                                 $set_product = $this->setProductRepository->find($OrderItem->getProduct()->getSetProductId());
  1108.                                 $inset_products = $set_product->getSetProductProduct();
  1109.                                 $inset_product_class_ids = $OrderItem->getSetProductClass();
  1110.                                 $inset_product_classes = array();
  1111.                                 foreach ($inset_product_class_ids as $ipci) {
  1112.                                     if (!empty($ipci)) {
  1113.                                         $ipc = $this->productClassRepository->find($ipci);
  1114.                                         if ($ipc)
  1115.                                             $inset_product_classes[$ipc->getProduct()->getId()] = $ipc;
  1116.                                     }
  1117.                                 }
  1118.                                 $itemFoundInSet = false;
  1119.                                 if ($CsvCustom->getSetProduct() && $OrderItem->getProduct()->getSetProductId() == $CsvCustom->getSetProduct()->getId()) {
  1120.                                     $set_price = $OrderItem->getSetProductPrice();
  1121.                                     foreach ($inset_products as $inset_index => $isp) {
  1122.                                         $isp_product = $isp->getProduct();
  1123.                                         if ($isp_product == $CsvCustom->getProduct())
  1124.                                             $InSetProductOrderItem = new OrderItem;
  1125.                                         $InSetProductOrderItem->setOrder($Order)
  1126.                                             ->setProduct($isp_product);
  1127.                                         if (isset($inset_product_classes[$isp_product->getId()])) {
  1128.                                             $inset_product_class = $inset_product_classes[$isp_product->getId()];
  1129.                                             $InSetProductOrderItem->setProductClass($inset_product_class)
  1130.                                                 ->setProductCode($inset_product_class->getCode())
  1131.                                                 ->setPrice($set_price && isset($set_price[$isp_product->getId()]) ? $set_price[$isp_product->getId()] : $isp->getSetProductPrice());
  1132.                                             $ClassCategory1 = $inset_product_class->getClassCategory1();
  1133.                                             if (!is_null($ClassCategory1)) {
  1134.                                                 $InSetProductOrderItem->setClasscategoryName1($ClassCategory1->getName());
  1135.                                                 $InSetProductOrderItem->setClassName1($ClassCategory1->getClassName()->getName());
  1136.                                             }
  1137.                                             $ClassCategory2 = $inset_product_class->getClassCategory2();
  1138.                                             if (!is_null($ClassCategory2)) {
  1139.                                                 $InSetProductOrderItem->setClasscategoryName2($ClassCategory2->getName());
  1140.                                                 $InSetProductOrderItem->setClassName2($ClassCategory2->getClassName()->getName());
  1141.                                             }
  1142.                                         }
  1143.                                         $InSetProductOrderItem->setProductName($isp_product->getName())
  1144.                                             ->setQuantity($OrderItem->getQuantity())
  1145.                                             ->setOrderItemType($OrderItem->getOrderItemType())
  1146.                                             ->setDeliveryPeriod($OrderItem->getDeliveryPeriod())
  1147.                                             ->setSetProductClass($OrderItem->getSetProductClass());
  1149.                                         $Shipping = $OrderItem->getShipping();
  1150.                                         $InSetProductOrderItem->setShipping($Shipping);
  1151.                                         $Brother = $OrderItem->getBrother();
  1152.                                         $InSetProductOrderItem->setBrother($Brother);
  1154.                                         $processed = implode('_', [$CsvCustom->getDispName(), $OrderItem->getId(), $isp_product->getId(), $inset_index]);
  1155.                                         if (!in_array($processed, $processed_items)) {
  1156.                                             if ($isp_product == $CsvCustom->getProduct()) {
  1157.                                                 $this->prepareOrderItemCustom($InSetProductOrderItem, $Order, $CsvCustom, $Customer, $this->csvExportService, $ExportCsvRow, $OrderItem);
  1158.                                                 $itemFoundInSet = true;
  1159.                                             }
  1160.                                             $processed_items[] = $processed;
  1161.                                         }
  1162.                                         if ($itemFoundInSet) {
  1163.                                             break;
  1164.                                         }
  1165.                                     }
  1166.                                 }
  1167.                                 if ($itemFoundInSet) {
  1168.                                     $itemFound = true;
  1169.                                     break;
  1170.                                 }
  1171.                             } else {
  1172.                                 $processed = implode('_', [$CsvCustom->getDispName(), $OrderItem->getId(), $OrderItem->getProduct()->getId()]);
  1173.                                 if (!in_array($processed, $processed_items)) {
  1174.                                     if ($CsvCustom->getProduct() == $OrderItem->getProduct()) {
  1175.                                         $this->prepareOrderItemCustom($OrderItem, $Order, $CsvCustom, $Customer, $this->csvExportService, $ExportCsvRow, null);
  1176.                                         $itemFound = true;
  1177.                                     }
  1178.                                     $processed_items[] = $processed;
  1179.                                 }
  1180.                                 if ($itemFound) {
  1181.                                     break;
  1182.                                 }
  1183.                             }
  1184.                         }
  1185.                     }
  1186.                     if (!$itemFound) {
  1187.                         $ExportCsvRow->setData('');
  1188.                         $ExportCsvRow->pushData();
  1189.                     }
  1190.                     break;
  1191.                 case 1:
  1192.                     $ExportCsvRow->setData($CsvCustom->getFieldData());
  1193.                     $ExportCsvRow->pushData();
  1194.                     break;
  1195.                 case 2:
  1196.                     foreach ($OrderItems as $OrderItem) {
  1197.                         $ExportCsvRow->setData($this->csvExportService->getData($CsvDefault, $Order));
  1198.                         $this->processCsvData($OrderItem, $CsvDefault, $Customer, $this->csvExportService, $ExportCsvRow, null);
  1199.                     }
  1200.                     $ExportCsvRow->pushData();
  1201.                     break;
  1202.                 default:
  1203.                     break;
  1204.             }
  1205.         }
  1206.     }
  1208.     /**
  1209.      * @Route("/%eccube_admin_route%/order/export/csv_custom/{csvTypeId}", name="admin_order_export_csv_custom", methods={"GET"}, requirements={"id" = "\d+"})
  1210.      */
  1211.     public function exportCsvCustom(Request $request, $csvTypeId)
  1212.     {
  1213.         // タイムアウトを無効にする.
  1214.         set_time_limit(0);
  1216.         // sql loggerを無効にする.
  1217.         $em = $this->entityManager;
  1218.         $em->getConfiguration()->setSQLLogger(null);
  1219.         $response = new StreamedResponse();
  1220.         $csvTypeCustom = $this->csvTypeCustomRepository->find($csvTypeId);
  1221.         $csvCustoms = $this->csvCustomRepository->findBy(['CsvTypeCustom' => $csvTypeCustom]);
  1222.         $fileName = 'order_custom_' . (new \DateTime())->format('YmdHis') . '.csv';
  1224.         $response->setCallback(function () use ($request, $csvCustoms, $csvTypeCustom) {
  1225.             $handle = fopen('php://output', 'w');
  1226.             $qb = $this->csvExportService
  1227.                 ->getOrderQueryBuilder($request);
  1228.             $Orders = $qb
  1229.                 ->getQuery()
  1230.                 ->useResultCache(true, $this->eccubeConfig['eccube_result_cache_lifetime_short'])
  1231.                 ->getResult();
  1233.             $max_counts = [];
  1234.             foreach ($Orders as $Order) {
  1235.                 $OrderItems = $Order->getOrderItems();
  1236.                 $repeatCounts = [];
  1237.                 for ($idx = 0; $idx < count($OrderItems); $idx++) {
  1238.                     $OrderItem = $OrderItems[$idx];
  1239.                     if ($OrderItem->isProduct()) {
  1240.                         $Product = $OrderItem->getProduct();
  1241.                         $product_id = $Product->getId();
  1242.                         $repeatCounts = [];
  1243.                         $repeatCounts[$product_id] = 1;
  1244.                         $j = $idx + 1;
  1245.                         while (isset($OrderItems[$j]) && $OrderItems[$j]->getProduct() == $Product) {
  1246.                             $repeatCounts[$product_id] = $repeatCounts[$product_id] + 1;
  1247.                             $j++;
  1248.                         }
  1249.                         $idx = $j - 1;
  1250.                     }
  1251.                 }
  1252.                 foreach ($repeatCounts as $product_id => $r_count) {
  1253.                     if (!isset($max_counts[$product_id]) || isset($max_counts[$product_id]) && $max_counts[$product_id] < $r_count) {
  1254.                         $max_counts[$product_id] = $r_count;
  1255.                     }
  1256.                 }
  1257.             }
  1258.             $headerRow = [];
  1259.             $headerCsvs = [];
  1260.             for ($idx = 0; $idx < count($csvCustoms); $idx++) {
  1261.                 $csvCustom = $csvCustoms[$idx];
  1262.                 $Product = $csvCustom->getProduct();
  1263.                 if ($csvCustom->getFieldType() == 0) {
  1264.                     $repeatCount = isset($max_counts[$Product->getId()]) ? $max_counts[$Product->getId()] : 1;
  1265.                     for ($k = 0; $k < $repeatCount; $k++) {
  1266.                         $j = $idx;
  1267.                         do {
  1268.                             $csvCustoms[$j]->setDispName($csvCustoms[$j]->getDispName() . '@' . ($k + 1));
  1269.                             $headerCsvs[] = $csvCustoms[$j];
  1270.                             $j++;
  1271.                         } while (isset($csvCustoms[$j]) && $csvCustoms[$j]->getFieldType() == 0 && $csvCustom->getProduct() == $csvCustoms[$j]->getProduct());
  1272.                     }
  1273.                     $idx = $j - 1;
  1274.                 } else {
  1275.                     $headerCsvs[] = $csvCustom;
  1276.                 }
  1277.             }
  1278.             foreach ($headerCsvs as $hcsv) {
  1279.                 if ($hcsv->getFieldType() != 0 || $hcsv->getProduct() && !$hcsv->getProduct()->isSetProduct()) {
  1280.                     $headerRow[] = mb_convert_encoding(explode('@', $hcsv->getDispName())[0], 'SJIS-win');
  1281.                 }
  1282.             }
  1283.             $column_count = 0;
  1284.             $exportData = [];
  1285.             foreach ($Orders as $Order) {
  1286.                 $Customer = $Order->getCustomer();
  1287.                 $ExportCsvRow = new ExportCsvRow();
  1288.                 $this->prepareOrderCustom($Order, $headerCsvs, $Customer, $ExportCsvRow);
  1289.                 $dataRow = $ExportCsvRow->getRow();
  1290.                 if (count($dataRow) > $column_count) {
  1291.                     $column_count = count($dataRow);
  1292.                 }
  1293.                 $exportData[] = $ExportCsvRow;
  1294.             }
  1295.             for ($i = 0; $i < $column_count; $i++) {
  1296.                 $empty_fields[$i] = true;
  1297.             }
  1298.             foreach ($exportData as $ExportCsvRow) {
  1299.                 $dataRow = $ExportCsvRow->getRow();
  1300.                 foreach ($dataRow as $index => $csvData) {
  1301.                     if (!empty($csvData)) {
  1302.                         $empty_fields[$index] = false;
  1303.                     }
  1304.                 }
  1305.             }
  1306.             if ($csvTypeCustom->getSkipEmptyField()) {
  1307.                 $headerRowNew = [];
  1309.                 foreach ($headerRow as $index => $header) {
  1310.                     if (!$empty_fields[$index]) {
  1311.                         $headerRowNew[] = $headerRow[$index];
  1312.                     }
  1313.                 }
  1314.                 fputcsv($handle, $headerRowNew);
  1315.                 foreach ($exportData as $ExportCsvRow) {
  1316.                     $ExportCsvRowNew = new ExportCsvRow();
  1317.                     foreach ($ExportCsvRow->getRow() as $index => $csvData) {
  1318.                         if (!$empty_fields[$index]) {
  1319.                             $ExportCsvRowNew->setData($csvData);
  1320.                             $ExportCsvRowNew->pushData();
  1321.                         }
  1322.                     }
  1323.                     fputcsv($handle, array_map($this->csvExportService->getConvertEncodingCallback(), $ExportCsvRowNew->getRow()), $this->eccubeConfig['eccube_csv_export_separator']);
  1324.                 }
  1325.             } else {
  1326.                 fputcsv($handle, $headerRow);
  1327.                 foreach ($exportData as $ExportCsvRow) {
  1328.                     fputcsv($handle, array_map($this->csvExportService->getConvertEncodingCallback(), $ExportCsvRow->getRow()), $this->eccubeConfig['eccube_csv_export_separator']);
  1329.                 }
  1330.             }
  1331.             fclose($handle);
  1332.         });
  1334.         $response->headers->set('Content-Type', 'application/octet-stream');
  1335.         $response->headers->set('Content-Disposition', 'attachment; filename=' . $fileName);
  1337.         return $response;
  1338.     }
  1339. }