app/Plugin/NZMailSystem42/Event.php line 63

Open in your IDE?
  1. <?php
  3. namespace Plugin\NZMailSystem42;
  5. use Eccube\Event\EccubeEvents;
  6. use Eccube\Event\EventArgs;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Eccube\Common\EccubeConfig;
  9. use Eccube\Repository\PaymentRepository;
  10. use Eccube\Service\MailService;
  11. use Eccube\Repository\OrderRepository;
  12. use Eccube\Repository\BaseInfoRepository;
  13. use Eccube\Repository\MailHistoryRepository;
  14. use Eccube\Entity\Order;
  15. use Eccube\Entity\MailHistory;
  16. use Eccube\Entity\Master\OrderStatus;
  17. use Doctrine\ORM\EntityManagerInterface;
  18. use Symfony\Component\DependencyInjection\ContainerInterface;
  19. use Twig\Environment;
  21. class Event implements EventSubscriberInterface
  22. {
  23.     /**
  24.      * @var MailService
  25.      */
  26.     protected $mailService;
  27.     
  28.     /**
  29.      * @var OrderRepository
  30.      */
  31.     protected $orderRepository;
  32.     
  33.     /**
  34.      * @var BaseInfoRepository
  35.      */
  36.     protected $baseInfoRepository;
  37.     
  38.     /**
  39.      * @var MailHistoryRepository
  40.      */
  41.     protected $mailHistoryRepository;
  42.     
  43.     /**
  44.      * @var PaymentRepository
  45.      */
  46.     protected $paymentRepository;
  47.     
  48.     /**
  49.      * @var EntityManagerInterface
  50.      */
  51.     protected $entityManager;
  52.     
  53.     /**
  54.      * @var Environment
  55.      */
  56.     protected $twig;
  57.     
  58.     /**
  59.      * @var EccubeConfig
  60.      */
  61.     protected $eccubeConfig;
  63.     public function __construct(
  64.         MailService $mailService,
  65.         OrderRepository $orderRepository,
  66.         BaseInfoRepository $baseInfoRepository,
  67.         MailHistoryRepository $mailHistoryRepository,
  68.         PaymentRepository $paymentRepository,
  69.         EntityManagerInterface $entityManager,
  70.         Environment $twig,
  71.         EccubeConfig $eccubeConfig
  72.     ) {
  73.         $this->mailService = $mailService;
  74.         $this->orderRepository = $orderRepository;
  75.         $this->baseInfoRepository = $baseInfoRepository;
  76.         $this->mailHistoryRepository = $mailHistoryRepository;
  77.         $this->paymentRepository = $paymentRepository;
  78.         $this->entityManager = $entityManager;
  79.         $this->twig = $twig;
  80.         $this->eccubeConfig = $eccubeConfig;
  81.     }
  83.     /**
  84.      * @return array
  85.      */
  86.     public static function getSubscribedEvents()
  87.     {
  88.         return [
  89.             // 注文完了時のイベント（購入完了画面表示前）
  90.             EccubeEvents::FRONT_SHOPPING_COMPLETE_INITIALIZE => 'onShoppingComplete',
  91.             
  92.             // 注文確定後のイベント
  93.             'eccube.event.order.complete' => 'onOrderComplete',
  94.             
  95.             // 管理画面の注文編集画面拡張
  96.             '@admin/Order/edit.twig' => 'onAdminOrderEditTwig',
  97.             
  98.             // 手動送信用のカスタムイベント
  99.             'nz.mail.payment.confirm' => 'sendPaymentConfirmMail',
  100.             'nz.mail.payment.received' => 'sendPaymentReceivedMail',
  101.             'nz.mail.order.cancel' => 'sendCancellationMail',
  102.         ];
  103.     }
  105.     /**
  106.      * 注文完了時の自動メール送信処理
  107.      * 銀行振込・代金引換以外の決済方法の場合に自動送信
  108.      */
  109.     public function onShoppingComplete(EventArgs $event)
  110.     {
  111.         $Order = $event->getArgument('Order');
  112.         
  113.         if (!$Order instanceof Order) {
  114.             return;
  115.         }
  117.         // 決済方法をチェック
  118.         if ($this->shouldSendAutoMail($Order)) {
  119.             // プラグイン設定を確認
  120.             $Config = $this->getPluginConfig();
  121.             if (!$Config || !$Config->isAutoSendEnabled()) {
  122.                 return;
  123.             }
  125.             // 決済完了メールを送信
  126.             $this->sendPaymentCompleteMail($Order);
  127.         }
  128.     }
  130.     /**
  131.      * 注文確定後の処理（別のタイミングでも送信可能にするため）
  132.      */
  133.     public function onOrderComplete(EventArgs $event)
  134.     {
  135.         if (!$event->hasArgument('Order')) {
  136.             return;
  137.         }
  138.         
  139.         $Order = $event->getArgument('Order');
  140.         
  141.         if (!$Order instanceof Order) {
  142.             return;
  143.         }
  145.         // 決済方法をチェックして必要なら送信
  146.         if ($this->shouldSendAutoMail($Order)) {
  147.             $Config = $this->getPluginConfig();
  148.             if ($Config && $Config->isAutoSendEnabled()) {
  149.                 // すでに送信済みかチェック
  150.                 if (!$this->isAlreadySent($Order, 'payment_complete')) {
  151.                     $this->sendPaymentCompleteMail($Order);
  152.                 }
  153.             }
  154.         }
  155.     }
  157.     /**
  158.      * 自動メール送信が必要かどうかを判定
  159.      */
  160.     private function shouldSendAutoMail(Order $Order)
  161.     {
  162.         $Payment = $Order->getPayment();
  163.         if (!$Payment) {
  164.             return false;
  165.         }
  167.         $paymentMethod = $Payment->getMethod();
  168.         
  169.         // 銀行振込、代金引換以外の場合はtrue
  170.         // ※決済方法名は環境により異なる可能性があるため、適宜調整してください
  171.         $excludedPayments = [
  172.             '銀行振込',
  173.             '銀行振込み',
  174.             'bank_transfer',
  175.             '代金引換',
  176.             '代引き',
  177.             'cod',
  178.             'cash_on_delivery'
  179.         ];
  181.         foreach ($excludedPayments as $excluded) {
  182.             if (stripos($paymentMethod, $excluded) !== false) {
  183.                 return false;
  184.             }
  185.         }
  187.         // クレジットカード、コンビニ決済、電子マネーなどの場合はtrue
  188.         return true;
  189.     }
  191.     /**
  192.      * 決済完了メール送信（クレジット等の即時決済用）
  193.      */
  194.     public function sendPaymentCompleteMail(Order $Order)
  195.     {
  196.         $Customer = $Order->getCustomer();
  197.         if (!$Customer) {
  198.             return false;
  199.         }
  201.         try {
  202.             $body = $this->renderMailTemplate('payment_complete', [
  203.                 'Order' => $Order,
  204.                 'Customer' => $Customer,
  205.                 'BaseInfo' => $this->baseInfoRepository->get()
  206.             ]);
  207.             
  208.             $message = (new \Swift_Message())
  209.                 ->setSubject($this->getMailSubject('payment_complete', $Order))
  210.                 ->setFrom($this->getFromAddress())
  211.                 ->setTo([$Customer->getEmail()])
  212.                 ->setBcc($this->getBccAddress())
  213.                 ->setBody($body);
  215.             $this->mailService->sendMail($message);
  216.             
  217.             // 送信履歴を保存
  218.             $this->saveMailHistory($Order, 'payment_complete', $body);
  219.             
  220.             // ログに記録
  221.             log_info('NZMailSystem42: 決済完了メール送信', [
  222.                 'order_id' => $Order->getId(),
  223.                 'order_no' => $Order->getOrderNo(),
  224.                 'payment' => $Order->getPayment()->getMethod()
  225.             ]);
  226.             
  227.             return true;
  228.         } catch (\Exception $e) {
  229.             log_error('NZMailSystem42: メール送信エラー', [$e->getMessage()]);
  230.             return false;
  231.         }
  232.     }
  234.     /**
  235.      * 決済確認メール送信（銀行振込等の手動確認用）
  236.      */
  237.     public function sendPaymentConfirmMail($Order)
  238.     {
  239.         if ($Order instanceof EventArgs) {
  240.             $Order = $Order->getArgument('Order');
  241.         }
  242.         
  243.         $Customer = $Order->getCustomer();
  244.         if (!$Customer) {
  245.             return false;
  246.         }
  248.         try {
  249.             $body = $this->renderMailTemplate('payment_confirm', [
  250.                 'Order' => $Order,
  251.                 'Customer' => $Customer,
  252.                 'BaseInfo' => $this->baseInfoRepository->get()
  253.             ]);
  254.             
  255.             $message = (new \Swift_Message())
  256.                 ->setSubject($this->getMailSubject('payment_confirm', $Order))
  257.                 ->setFrom($this->getFromAddress())
  258.                 ->setTo([$Customer->getEmail()])
  259.                 ->setBcc($this->getBccAddress())
  260.                 ->setBody($body);
  262.             $this->mailService->sendMail($message);
  263.             
  264.             // 送信履歴を保存
  265.             $this->saveMailHistory($Order, 'payment_confirm', $body);
  266.             
  267.             return true;
  268.         } catch (\Exception $e) {
  269.             log_error('NZMailSystem42: メール送信エラー', [$e->getMessage()]);
  270.             return false;
  271.         }
  272.     }
  274.     /**
  275.      * 入金確認済みメール送信
  276.      */
  277.     public function sendPaymentReceivedMail($Order)
  278.     {
  279.         if ($Order instanceof EventArgs) {
  280.             $Order = $Order->getArgument('Order');
  281.         }
  282.         
  283.         $Customer = $Order->getCustomer();
  284.         if (!$Customer) {
  285.             return false;
  286.         }
  288.         try {
  289.             $body = $this->renderMailTemplate('payment_received', [
  290.                 'Order' => $Order,
  291.                 'Customer' => $Customer,
  292.                 'BaseInfo' => $this->baseInfoRepository->get()
  293.             ]);
  294.             
  295.             $message = (new \Swift_Message())
  296.                 ->setSubject($this->getMailSubject('payment_received', $Order))
  297.                 ->setFrom($this->getFromAddress())
  298.                 ->setTo([$Customer->getEmail()])
  299.                 ->setBcc($this->getBccAddress())
  300.                 ->setBody($body);
  302.             $this->mailService->sendMail($message);
  303.             
  304.             // 送信履歴を保存
  305.             $this->saveMailHistory($Order, 'payment_received', $body);
  306.             
  307.             return true;
  308.         } catch (\Exception $e) {
  309.             log_error('NZMailSystem42: メール送信エラー', [$e->getMessage()]);
  310.             return false;
  311.         }
  312.     }
  314.     /**
  315.      * キャンセルメール送信
  316.      */
  317.     public function sendCancellationMail($Order)
  318.     {
  319.         if ($Order instanceof EventArgs) {
  320.             $Order = $Order->getArgument('Order');
  321.         }
  322.         
  323.         $Customer = $Order->getCustomer();
  324.         if (!$Customer) {
  325.             return false;
  326.         }
  328.         try {
  329.             $body = $this->renderMailTemplate('order_cancel', [
  330.                 'Order' => $Order,
  331.                 'Customer' => $Customer,
  332.                 'BaseInfo' => $this->baseInfoRepository->get()
  333.             ]);
  334.             
  335.             $message = (new \Swift_Message())
  336.                 ->setSubject($this->getMailSubject('order_cancel', $Order))
  337.                 ->setFrom($this->getFromAddress())
  338.                 ->setTo([$Customer->getEmail()])
  339.                 ->setBcc($this->getBccAddress())
  340.                 ->setBody($body);
  342.             $this->mailService->sendMail($message);
  343.             
  344.             // 送信履歴を保存
  345.             $this->saveMailHistory($Order, 'order_cancel', $body);
  346.             
  347.             return true;
  348.         } catch (\Exception $e) {
  349.             log_error('NZMailSystem42: メール送信エラー', [$e->getMessage()]);
  350.             return false;
  351.         }
  352.     }
  354.     /**
  355.      * 管理画面の注文編集画面にボタンを追加
  356.      */
  357.     public function onAdminOrderEditTwig(EventArgs $event)
  358.     {
  359.         $twig = '@NZMailSystem42/admin/order_extension.twig';
  360.         $event->addSnippet($twig);
  361.     }
  363.     /**
  364.      * メールテンプレートのレンダリング
  365.      */
  366.     private function renderMailTemplate($type, $params)
  367.     {
  368.         $template = '@NZMailSystem42/mail/' . $type . '.twig';
  369.         
  370.         // テンプレートが存在しない場合はデフォルトテキストを生成
  371.         try {
  372.             return $this->twig->render($template, $params);
  373.         } catch (\Exception $e) {
  374.             return $this->createDefaultMailBody($type, $params);
  375.         }
  376.     }
  378.     /**
  379.      * デフォルトのメール本文生成
  380.      */
  381.     private function createDefaultMailBody($type, $params)
  382.     {
  383.         $Order = $params['Order'];
  384.         $Customer = $params['Customer'];
  385.         $BaseInfo = $params['BaseInfo'];
  386.         
  387.         $body = "※このメールは自動配信メールです。\n\n";
  388.         $body .= "━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n";
  389.         
  390.         switch ($type) {
  391.             case 'payment_complete':
  392.                 $body .= "　ご注文ありがとうございます\n";
  393.                 break;
  394.             case 'payment_confirm':
  395.                 $body .= "　ご入金確認のお知らせ\n";
  396.                 break;
  397.             case 'payment_received':
  398.                 $body .= "　ご入金完了のお知らせ\n";
  399.                 break;
  400.             case 'order_cancel':
  401.                 $body .= "　ご注文キャンセルのお知らせ\n";
  402.                 break;
  403.         }
  404.         
  405.         $body .= "━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n\n";
  406.         
  407.         $body .= $Customer->getName01() . " " . $Customer->getName02() . " 様\n\n";
  408.         $body .= "この度は" . $BaseInfo->getShopName() . "をご利用いただき、誠にありがとうございます。\n\n";
  409.         
  410.         switch ($type) {
  411.             case 'payment_complete':
  412.                 $body .= "ご注文および決済が完了いたしました。\n";
  413.                 $body .= "商品の発送準備を進めさせていただきます。\n\n";
  414.                 break;
  415.             case 'payment_confirm':
  416.                 $body .= "お客様のご注文の決済処理を確認中です。\n";
  417.                 $body .= "入金確認が完了次第、商品の発送準備に入らせていただきます。\n\n";
  418.                 break;
  419.             case 'payment_received':
  420.                 $body .= "お客様のご入金を確認いたしました。\n";
  421.                 $body .= "商品の発送準備を進めさせていただきます。\n\n";
  422.                 break;
  423.             case 'order_cancel':
  424.                 $body .= "お客様のご注文をキャンセルいたしました。\n";
  425.                 $body .= "またのご利用を心よりお待ちしております。\n\n";
  426.                 
  427.                 // 返金に関する注意事項を追加
  428.                 $paymentMethod = $Order->getPayment()->getMethod();
  429.                 if (preg_match('/(クレジット|credit|card)/i', $paymentMethod)) {
  430.                     $body .= "【クレジットカード決済の場合】\n";
  431.                     $body .= "決済のキャンセル処理を行っております。\n";
  432.                     $body .= "カード会社によって返金のタイミングが異なりますので、\n";
  433.                     $body .= "詳細はご利用のカード会社にお問い合わせください。\n\n";
  434.                 } elseif (preg_match('/(銀行振込|振込|bank)/i', $paymentMethod)) {
  435.                     $body .= "【銀行振込の返金について】\n";
  436.                     $body .= "すでにお振込みいただいている場合は、返金手続きをさせていただきます。\n";
  437.                     $body .= "返金先口座情報をお知らせください。\n\n";
  438.                     $body .= "＜重要＞返金に関するご案内\n";
  439.                     $body .= "・お客様都合によるキャンセルの場合、返金額は銀行所定の振込手数料を\n";
  440.                     $body .= "　差し引かせていただいた金額となります。\n";
  441.                     $body .= "・お支払い金額と返金金額に差異がある場合は、上記の処理が行われて\n";
  442.                     $body .= "　いることをご了承ください。\n";
  443.                     $body .= "・振込手数料は各金融機関により異なりますが、通常220円～880円程度\n";
  444.                     $body .= "　となります。\n\n";
  445.                 }
  446.                 break;
  447.         }
  448.         
  449.         $body .= "【ご注文情報】\n";
  450.         $body .= "━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n";
  451.         $body .= "ご注文番号：" . $Order->getOrderNo() . "\n";
  452.         $body .= "ご注文日時：" . $Order->getOrderDate()->format('Y年m月d日 H:i') . "\n";
  453.         $body .= "お支払い金額：" . number_format($Order->getPaymentTotal()) . "円\n";
  454.         $body .= "お支払い方法：" . $Order->getPayment()->getMethod() . "\n\n";
  455.         
  456.         $body .= "【ご注文商品】\n";
  457.         foreach ($Order->getOrderItems() as $OrderItem) {
  458.             if ($OrderItem->isProduct()) {
  459.                 $body .= "・" . $OrderItem->getProductName() . " × " . $OrderItem->getQuantity() . "\n";
  460.                 $body .= "  " . number_format($OrderItem->getPrice()) . "円\n";
  461.             }
  462.         }
  463.         
  464.         $body .= "\n";
  465.         $body .= "━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n";
  466.         $body .= $BaseInfo->getShopName() . "\n";
  467.         $body .= "URL: https://noiezam.com\n";
  468.         $body .= "Email: " . $BaseInfo->getEmail01() . "\n";
  469.         
  470.         return $body;
  471.     }
  473.     /**
  474.      * メール件名の取得
  475.      */
  476.     private function getMailSubject($type, Order $Order)
  477.     {
  478.         $BaseInfo = $this->baseInfoRepository->get();
  479.         $shopName = $BaseInfo->getShopName();
  480.         
  481.         switch ($type) {
  482.             case 'payment_complete':
  483.                 return '[' . $shopName . '] ご注文ありがとうございます';
  484.             case 'payment_confirm':
  485.                 return '[' . $shopName . '] ご入金確認のお知らせ';
  486.             case 'payment_received':
  487.                 return '[' . $shopName . '] ご入金を確認いたしました';
  488.             case 'order_cancel':
  489.                 return '[' . $shopName . '] ご注文キャンセルのお知らせ';
  490.             default:
  491.                 return '[' . $shopName . '] ご注文について';
  492.         }
  493.     }
  495.     /**
  496.      * 送信元アドレスの取得
  497.      */
  498.     private function getFromAddress()
  499.     {
  500.         $BaseInfo = $this->baseInfoRepository->get();
  501.         return [$BaseInfo->getEmail01() => $BaseInfo->getShopName()];
  502.     }
  504.     /**
  505.      * BCCアドレスの取得
  506.      */
  507.     private function getBccAddress()
  508.     {
  509.         $BaseInfo = $this->baseInfoRepository->get();
  510.         return $BaseInfo->getEmail01();
  511.     }
  513.     /**
  514.      * メール送信履歴の保存
  515.      */
  516.     private function saveMailHistory(Order $Order, $mailType, $body)
  517.     {
  518.         $MailHistory = new MailHistory();
  519.         $MailHistory->setOrder($Order);
  520.         $MailHistory->setSendDate(new \DateTime());
  521.         $MailHistory->setSubject($this->getMailSubject($mailType, $Order));
  522.         $MailHistory->setMailBody($body);
  524.         $this->entityManager->persist($MailHistory);
  525.         $this->entityManager->flush();
  526.     }
  528.     /**
  529.      * 同じタイプのメールがすでに送信済みかチェック
  530.      */
  531.     private function isAlreadySent(Order $Order, $mailType)
  532.     {
  533.         $subject = $this->getMailSubject($mailType, $Order);
  534.         
  535.         $qb = $this->entityManager->createQueryBuilder();
  536.         $qb->select('COUNT(mh.id)')
  537.             ->from(MailHistory::class, 'mh')
  538.             ->where('mh.Order = :order')
  539.             ->andWhere('mh.subject = :subject')
  540.             ->setParameter('order', $Order)
  541.             ->setParameter('subject', $subject);
  542.         
  543.         $count = $qb->getQuery()->getSingleScalarResult();
  544.         
  545.         return $count > 0;
  546.     }
  548.     /**
  549.      * プラグイン設定の取得
  550.      */
  551.     private function getPluginConfig()
  552.     {
  553.         $qb = $this->entityManager->createQueryBuilder();
  554.         $qb->select('c')
  555.             ->from('Plugin\NZMailSystem42\Entity\Config', 'c')
  556.             ->where('c.id = :id')
  557.             ->setParameter('id', 1);
  558.         
  559.         try {
  560.             return $qb->getQuery()->getSingleResult();
  561.         } catch (\Exception $e) {
  562.             // デフォルト設定を返す
  563.             $Config = new \Plugin\NZMailSystem42\Entity\Config();
  564.             $Config->setAutoSendEnabled(true);
  565.             return $Config;
  566.         }
  567.     }
  568. }