app/Plugin/VeriTrans4G2/Service/Payment/PaymentRecvService.php line 1672

Open in your IDE?
  1. <?php
  2. /*
  3.  * Copyright (c) 2018 VeriTrans Inc., a Digital Garage company. All rights reserved.
  4.  * http://www.veritrans.co.jp/
  5.  */
  7. namespace Plugin\VeriTrans4G2\Service\Payment;
  9. use Doctrine\DBAL\Exception\DriverException;
  10. use Doctrine\DBAL\Exception\LockWaitTimeoutException;
  11. use Eccube\Entity\BaseInfo;
  12. use Eccube\Entity\Order;
  13. use Eccube\Entity\Master\OrderStatus;
  14. use Eccube\Entity\Cart;
  15. use Eccube\Entity\MailTemplate;
  16. use Eccube\Service\PurchaseFlow\PurchaseContext;
  17. use Plugin\VeriTrans4G2\Entity\Vt4gOrderPayment;
  18. use Plugin\VeriTrans4G2\Entity\Vt4gSubscOrder;
  19. use Plugin\VeriTrans4G2\Entity\Vt4gSubscOrderItem;
  20. use Plugin\VeriTrans4G2\Entity\Master\Vt4gSubscSaleType;
  21. use Symfony\Component\Mime\Address;
  22. use Symfony\Component\Mime\Email;
  23. use Symfony\Component\Routing\Generator\UrlGeneratorInterface;
  24. use tgMdk\TGMDK_MerchantUtility;
  26. /**
  27.  * 結果(入金)通知受信処理クラス
  28.  */
  29. class PaymentRecvService extends BaseService
  30. {
  31.     /**
  32.      * 速報確報フラグ
  33.      */
  34.     private $fixed;
  36.     /**
  37.      * ネットバンク決済 注文完了メール送信タイミング
  38.      */
  39.     private $bankOrderMailSetting = null;
  41.     /**
  42.      * 楽天ペイ 要求結果メール送信対象
  43.      */
  44.     private $rakutenMailSetting = null;
  46.     /**
  47.      * 楽天ペイ 要求結果メールメッセージ
  48.      */
  49.     public $rakutenMailMsg;
  51.     /**
  52.      * 結果通知エラー報知メールメッセージ
  53.      */
  54.     public $errorMailMsg;
  56.     /**
  57.      * 入金報知メール 注文番号格納用配列
  58.      */
  59.     public $paymentInfoOrderNo;
  61.     /**
  62.      * 入金報知メール 設定値格納用配列
  63.      */
  64.     public $paymentInfoValues;
  66.     /**
  67.      * 結果通知前に想定されるorderstatusの値
  68.      */
  69.     const BEFORE_PUSH_RESULT_ORDER_STATUS = [
  70.         'id' => [
  71.             OrderStatus::NEW,
  72.             OrderStatus::PENDING
  73.         ]
  74.     ];
  76.     /**
  77.      * ヘッダーのチェックを行います。
  78.      *
  79.      * @param array $requestHeaders リクエストヘッダ情報の配列
  80.      * @return boolean true:チェックOK false:チェックNG
  81.      */
  82.     public function checkHeader($requestHeaders)
  83.     {
  84.         // ベリトランスペイメントゲートウェイからの通知電文を取得
  85.         $headers = [];
  86.         foreach ($requestHeaders as $header => $value) {
  87.             $headers[$header] = $value[0];
  88.             $this->mdkLogger->debug("$header: $value[0]");
  89.         }
  91.         $headers = array_change_key_case($headers,CASE_LOWER);
  93.         if(!array_key_exists('content-length', $headers) || $headers['content-length'] <= 0){
  94.             // 読み込めないので 500 を応答
  95.             $this->mdkLogger->error(trans('vt4g_plugin.payment.recv.not.exist.length'));
  96.             return false;
  97.         }
  99.         $body = "";
  100.         $fp = fopen("php://input", "r");
  101.         if ($fp == false) {
  102.             $this->mdkLogger->error(trans('vt4g_plugin.payment.recv.recv.failed'));
  103.             // 読み込めないので 500 を応答
  104.             return false;
  105.         }
  107.         while (!feof($fp)) {
  108.             $body .= fgets($fp);
  109.         }
  110.         fclose($fp);
  111.         $this->mdkLogger->debug("Body: $body");
  113.         // Content-HMAC を利用して電文の改竄チェックを行う
  114.         $hmac = array_key_exists('content-hmac', $headers) ? $headers['content-hmac'] : "";
  115.         if (strlen($hmac) <= 0) {
  116.             // Content-HMACがない 500 を応答
  117.             $this->mdkLogger->error(trans('vt4g_plugin.payment.recv.not.exist.hmac'));
  118.             return false;
  119.         }
  121.         if (!TGMDK_MerchantUtility::checkMessage($body, $hmac)) {
  122.             $this->mdkLogger->error(trans('vt4g_plugin.payment.recv.valid.failed'));
  123.             // 改竄の疑いあり 500 を応答
  124.             return false;
  125.         }
  127.         $this->mdkLogger->info(trans('vt4g_plugin.payment.recv.valid.success'));
  128.         return true;
  129.     }
  131.     /**
  132.      * 結果(入金)通知データを取得します。
  133.      *
  134.      * @param array $arrPost
  135.      * @return array
  136.      */
  137.     public function getRecord($arrPost)
  138.     {
  139.         $arrRecord = [];
  140.         $arrHead   = [];
  142.         // ヘッダー情報の取得
  143.         foreach ($this->vt4gConst['VT4G_RECV_RECODE_HEAD'] as $val){
  144.             if (array_key_exists($val, $arrPost)){
  145.                 $arrHead[$val] = $arrPost[$val];
  146.             }else{
  147.                 // ヘッダー情報なし
  148.                 return [[],[]];
  149.             }
  150.         }
  152.         $this->fixed = array_key_exists('fixed', $arrPost) ? $arrPost['fixed'] : null;
  154.         // 明細情報
  155.         foreach ($arrPost as $key => $val) {
  156.             // 連番がついている項目のフィールド名と連番を取得する
  157.             // [ orderId0000=>123, total0000=>10 ]、[ orderId0001=>456 total0001=>20 ] という形で受信するので、
  158.             // [ 0 => [orderId => 123, total=>10 ], 1 => [orderId => 456, total=>20 ] ] という形にする。
  159.             $match = [];
  160.             if (preg_match('/^([a-zA-Z0-9]+)([0-9]{4})$/', $key, $match) == false) {
  161.                 continue;
  162.             }
  164.             $arrRecord[(int)$match[2]][$match[1]] = $val;
  165.         }
  167.         return [$arrHead, $arrRecord];
  168.     }
  170.     /**
  171.      * 結果(入金)通知情報の反映を行います。
  172.      * @param array $arrRecord
  173.      */
  174.     public function saveRecvData($arrRecord)
  175.     {
  176.         foreach ($arrRecord as $key => $record){
  178.             $count = $key + 1;
  179.             $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.data.count'),$count) . print_r($record, true));
  181.             // 結果通知の項目から決済内部IDを取得する
  182.             $payTypeId = $this->getPayTypeId($record);
  184.             // 注文情報とそれに紐付く決済情報を取得する
  185.             $orderPayment = $this->em->getRepository(Vt4gOrderPayment::class)->findOneBy(['memo01'=> $record['orderId']]);
  186.             if (empty($orderPayment)) {
  187.                 $order = '';
  188.             } else {
  189.                 try {
  190.                     list($order, $orderPayment) = $this->getLockedOrder($orderPayment->getOrderId());
  191.                 } catch (LockWaitTimeoutException $e) {
  192.                     throw $e;
  193.                 } catch (DriverException $e) {
  194.                     throw $e;
  195.                 }
  196.             }
  198.             // どちらかとれない場合はエラーメール対象。
  199.             // 申込結果の失敗通知ならメールは出さない。
  200.             if (empty($order) || empty($orderPayment)) {
  202.                 if ($this->checkAuthFailure($payTypeId, $record)) {
  203.                     $this->mdkLogger->info(trans('vt4g_plugin.payment.recv.order.auth.failure'));
  204.                 } else {
  205.                     $this->mdkLogger->warn(trans('vt4g_plugin.payment.recv.order.not.exist'));
  206.                     $this->errorMailMsg[] = $this->makeErrorPushResult($record,trans('vt4g_plugin.payment.recv.order.not.exist'),'');
  207.                 }
  209.                 $this->em->rollback();
  210.                 continue;
  211.             }
  213.             if (empty($payTypeId)) {
  214.                 $this->mdkLogger->warn(trans('vt4g_plugin.payment.recv.order.not.payment'));
  215.                 $this->em->rollback();
  216.                 continue;
  217.             }
  219.             // 決済ごとの通知受信処理
  220.             $method = "exec{$this->vt4gConst['VT4G_CODE_PAYTYPEID_'.$payTypeId]}RecvProcess";
  221.             $error = $this->$method($order, $orderPayment, $record, $payTypeId);
  222.             if (!empty($error)) {
  223.                 $this->errorMailMsg[] = $error;
  224.             }
  226.             $this->em->commit();
  227.         }
  228.     }
  231.     /**
  232.      * 結果通知の項目から決済内部IDを取得します。
  233.      *
  234.      * @param  array   $record 結果通知の項目
  235.      * @return string          決済内部ID 一致するものがない場合は空文字
  236.      */
  237.     private function getPayTypeId($record)
  238.     {
  239.         foreach ($this->vt4gConst['VT4G_RECV_RECODE_BODY'] as $key => $params) {
  240.             if ($this->arrayKeysExists($params, $record)) {
  241.                 return $this->vt4gConst["$key"];
  242.             }
  243.         }
  245.         return '';
  246.     }
  248.     /**
  249.      * array_key_existsの配列版
  250.      *
  251.      * @param array $arrFormat
  252.      * @param array $arrRecord
  253.      * @return boolean
  254.      */
  255.     private function arrayKeysExists($arrFormat, $arrRecord)
  256.     {
  257.         foreach ($arrFormat as $key){
  258.             if (!array_key_exists($key, $arrRecord)){
  259.                 return false;
  260.             }
  261.         }
  262.         return true;
  263.     }
  265.     /**
  266.      * 決済申込の失敗結果通知であるかを調べます。
  267.      * @param  string $payTypeId 決済方法内部ID
  268.      * @param  array  $record    結果通知の項目
  269.      * @return bool   $isValid   決済申込の失敗結果通知ならtrue、異なるならfalse
  270.      */
  271.     private function checkAuthFailure($payTypeId, $record)
  272.     {
  273.         $isValid = false;
  275.         switch ($payTypeId) {
  276.             case $this->vt4gConst['VT4G_PAYTYPEID_CREDIT']:
  278.                 if (   $record['mpiMstatus']  != $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']
  279.                     || $record['cardMstatus'] != $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']){
  281.                     $isValid = true;
  282.                 }
  283.                 break;
  285.             case $this->vt4gConst['VT4G_PAYTYPEID_UPOP']:
  286.             case $this->vt4gConst['VT4G_PAYTYPEID_ALIPAY']:
  288.                 if (   $record['txnType'] == $this->vt4gConst['VT4G_RECV_TXN_TYPE_AUTH']
  289.                     && $record['mstatus'] != $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  291.                     $isValid = true;
  292.                 }
  293.                 break;
  295.             case $this->vt4gConst['VT4G_PAYTYPEID_RAKUTEN_V2']:
  296.                 $vResultCodes = str_split($record['vResultCode'], 4);
  297.                 foreach ($vResultCodes as $vResultCode) {
  298.                     if ($vResultCode == $this->vt4gConst['VT4G_RESPONSE']['V_RESULT_CODE']['RAKUTEN']['REQUEST_TIMEOUT']) {
  299.                         $isValid = true;
  300.                     }
  301.                 }
  302.                 break;
  304.             case $this->vt4gConst['VT4G_PAYTYPEID_PAYPAL']:
  306.                 if (   $record['txnType'] == $this->vt4gConst['VT4G_RECV_TXN_TYPE_CAPTURE']
  307.                     && $this->fixed       == $this->vt4gConst['VT4G_RECV_PAYPAL_FIXED']
  308.                     && $record['mstatus'] != $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK'] ) {
  310.                     $isValid = true;
  311.                 }
  312.                 break;
  314.             default:
  315.                 break;
  316.         }
  318.         return $isValid;
  319.     }
  321.     /**
  322.      * 本人認証の結果通知処理
  323.      * @param Order            $order        注文情報
  324.      * @param Vt4gOrderPayment $orderPayment 決済情報
  325.      * @param array            $record       結果通知の項目
  326.      * @param string           $payTypeId    決済方法内部ID
  327.      */
  328.     private function execCreditRecvProcess($order, $orderPayment, $record, $payTypeId)
  329.     {
  330.         // 本人認証はトランザクションタイプが本人認証結果(3Dセキュア2.0を含む)の場合、処理する
  331.         if (!in_array($record['txnType'], $this->vt4gConst['VT4G_RECV_TXN_TYPE_CREDIT'])) {
  332.             $this->mdkLogger->warn(sprintf(trans('vt4g_plugin.payment.recv.not.txn_type'),$record['txnType']));
  333.             return '';
  334.         }
  336.         $shouldSendMail = false;
  338.         $payName = $this->vt4gConst['VT4G_PAYNAME_PAYTYPEID_12'];
  340.         // 申込時の処理区分から与信/売上の通知区分を判定
  341.         $withCapture  = $this->getWithCapture($order);
  342.         $recvType     = $withCapture === 1
  343.                       ? $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE'] // 売上結果
  344.                       : $this->vt4gConst['VT4G_PAY_STATUS']['AUTH'];   // 申込結果
  345.         $newPayStatus = $recvType['VALUE'];
  347.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.start'),$recvType['RECV_NAME'],$payName));
  349.         // 結果通知の処理結果
  350.         // MPI 単体サービスの通知はcardMstatusが空ですが、MPI 単体サービスは設定できないので考慮しません
  351.         if (   $record['mpiMstatus']  != $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']
  352.             || $record['cardMstatus'] != $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  354.             $status = 'mpiMstatus:'.$record['mpiMstatus'].' cardMstatus:'.$record['cardMstatus'];
  355.             $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.mstatus.error'),$recvType['RECV_NAME'],$status));
  356.             // 結果通知項目の登録
  357.             $this->registPushRecord($orderPayment, $record);
  359.         } else {
  360.             $memo10 = unserialize($orderPayment->getMemo10());
  361.             if (array_key_exists('sentOrderMail', $memo10) && $memo10['sentOrderMail'] === false) {
  362.                 $shouldSendMail = true;
  363.             }
  365.             $this->clearCartByOrder($order);
  366.             $this->updateMpiPushResult($order, $orderPayment, $record, $newPayStatus, $withCapture);
  367.             // 継続課金注文の登録
  368.             $this->saveSubscOrder($order);
  369.             if ($shouldSendMail) {
  370.                 $this->sendOrderMail($order);
  371.                 $this->updateSentOrderMailToSent($orderPayment);
  372.             }
  373.         }
  375.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.end'),$recvType['RECV_NAME'],$payName));
  377.         return '';
  378.     }
  380.     /**
  381.      * コンビニ決済の結果通知処理
  382.      * @param Order            $order        注文情報
  383.      * @param Vt4gOrderPayment $orderPayment 決済情報
  384.      * @param array            $record       結果通知の項目
  385.      * @param string           $payTypeId    決済方法内部ID
  386.      */
  387.     private function execCVSRecvProcess($order, $orderPayment, $record, $payTypeId)
  388.     {
  389.         $error = '';
  390.         $payName = $this->vt4gConst['VT4G_PAYNAME_PAYTYPEID_'.$payTypeId];
  392.         $recvType       = $this->vt4gConst['VT4G_PAY_STATUS']['DEPOSIT']; // 入金結果
  393.         $newPayStatus   = $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE']['VALUE'];
  394.         $newOrderStatus = OrderStatus::PAID;
  395.         $payStatuses    = [ $this->vt4gConst['VT4G_PAY_STATUS']['REQUEST']['VALUE'] ];
  397.         $memo05 = $this->util->getPaymentMethodInfo($order->getPayment()->getId());
  399.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.start'),$recvType['RECV_NAME'],$payName));
  401.         // 決済ログ作成
  402.         $this->setLogHeadPushResult($record, $payTypeId, $recvType);
  403.         $this->setLogInfo('お支払店舗' , $this->getPayConveni($record['cvsType']));
  404.         $this->setLogInfo('受付番号'   , $record['receiptNo']);
  405.         $this->setLogInfo('受付日付'   , $this->util->toDate($record['receiptDate']));
  406.         $this->setLogInfo('入金金額'   , preg_match('/^[0-9]+$/', $record['rcvAmount']) ? number_format($record['rcvAmount']) : $record['rcvAmount']);
  408.         // 現在の支払方法検証
  409.         $error .= $this->checkPaymentTypeIDPushResult($order, $orderPayment, $newPayStatus, $newOrderStatus);
  411.         // 決済ステータス検証
  412.         $error .= $this->checkPaymentStatusPushResult($orderPayment, $payStatuses, $newPayStatus, $newOrderStatus);
  414.         // 注文ステータス検証
  415.         $error .= $this->checkOrderStatusPushResult($order, self::BEFORE_PUSH_RESULT_ORDER_STATUS, $newOrderStatus);
  417.         $this->updatePushResult($order, $orderPayment, $newPayStatus, $newOrderStatus, $record);
  419.         if (!empty($error)) {
  420.             $error = $this->makeErrorPushResult($record, $error, $order->getOrderNo());
  421.         } elseif(!empty($memo05['send_payment_info_mail'])){
  422.             $this->paymentInfoOrderNo[] = $order->getOrderNo();
  423.             $this->paymentInfoValues[$order->getOrderNo()] = $memo05['send_payment_info_mail'];
  424.         }
  426.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.end'),$recvType['RECV_NAME'],$payName));
  428.         return $error;
  429.     }
  431.     /**
  432.      * ネットバンク・ATM決済の結果通知処理
  433.      * @param Order            $order        注文情報
  434.      * @param Vt4gOrderPayment $orderPayment 決済情報
  435.      * @param array            $record       結果通知の項目
  436.      * @param string           $payTypeId    決済方法内部ID
  437.      */
  438.     private function execBankRecvProcess($order, $orderPayment, $record, $payTypeId)
  439.     {
  440.         $error = '';
  441.         $shouldSendMail = false;
  443.         $memo05 = $this->util->getPaymentMethodInfo($order->getPayment()->getId());
  445.         // ネットバンクとATMの通知は同じ項目なのでテーブルデータで判定
  446.         if ($orderPayment->getMemo03() == $this->vt4gConst['VT4G_PAYTYPEID_ATM']) {
  447.             $payTypeId = $this->vt4gConst['VT4G_PAYTYPEID_ATM'];
  448.             $paymentMethod = $this->util->getPaymentMethod($order->getPayment()->getId());
  449.             $payName = $paymentMethod->getPaymentMethod();
  450.         } else {
  451.             // テーブルデータもネットバンクなら注文完了メール送信の判定
  452.             if (is_null($this->bankOrderMailSetting)) {
  454.                 if (is_array($memo05) && array_key_exists('mailTiming',$memo05)) {
  455.                     $this->bankOrderMailSetting = $memo05['mailTiming'];
  456.                 } else {
  457.                     // 未登録の場合は設定画面の初期値と同じ値とする
  458.                     $this->bankOrderMailSetting = $this->vt4gConst['VT4G_MAIL_TIMING']['BANK']['ON_PAYMENT'];
  459.                 }
  460.             }
  462.             $shouldSendMail = $this->bankOrderMailSetting == $this->vt4gConst['VT4G_MAIL_TIMING']['BANK']['ON_RECEIVE'];
  463.             $payName = $this->vt4gConst['VT4G_PAYNAME_PAYTYPEID_'.$payTypeId];
  464.         }
  466.         $recvType       = $this->vt4gConst['VT4G_PAY_STATUS']['DEPOSIT']; // 入金結果
  467.         $newPayStatus   = $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE']['VALUE'];
  468.         $newOrderStatus = OrderStatus::PAID;
  469.         $payStatuses    = [ '', $this->vt4gConst['VT4G_PAY_STATUS']['REQUEST']['VALUE'] ];
  471.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.start'),$recvType['RECV_NAME'],$payName));
  473.         // 決済ログ作成
  474.         $this->setLogHeadPushResult($record, $payTypeId, $recvType, $payName);
  476.         $this->setLogInfo('収納機関コード' , $record['kikanNo']);
  477.         $this->setLogInfo('収納企業コード' , $record['kigyoNo']);
  478.         $this->setLogInfo('収納日時'       , $this->util->toDate($record['rcvDate']));
  479.         $this->setLogInfo('お客様番号'     , $record['customerNo']);
  480.         $this->setLogInfo('確認番号'       , $record['confNo']);
  481.         $this->setLogInfo('入金金額'       , preg_match('/^[0-9]+$/', $record['rcvAmount']) ? number_format($record['rcvAmount']) : $record['rcvAmount']);
  483.         // 現在の支払方法検証
  484.         $error .= $this->checkPaymentTypeIDPushResult($order, $orderPayment, $newPayStatus, $newOrderStatus);
  486.         // 決済ステータス検証
  487.         $error .= $this->checkPaymentStatusPushResult($orderPayment, $payStatuses, $newPayStatus, $newOrderStatus);
  489.         // 注文ステータス検証
  490.         $error .= $this->checkOrderStatusPushResult($order, self::BEFORE_PUSH_RESULT_ORDER_STATUS, $newOrderStatus);
  491.         if (!empty($error)) {
  492.             $error = $this->makeErrorPushResult($record, $error, $order->getOrderNo());
  493.         } else {
  495.             if(!empty($memo05['send_payment_info_mail']) && $payTypeId == $this->vt4gConst['VT4G_PAYTYPEID_ATM']){
  496.                 $this->paymentInfoOrderNo[] = $order->getOrderNo();
  497.                 $this->paymentInfoValues[$order->getOrderNo()] = $memo05['send_payment_info_mail'];
  498.             }
  499.         }
  501.         $this->updatePushResult($order, $orderPayment, $newPayStatus, $newOrderStatus, $record);
  503.         if (empty($error) && $shouldSendMail) {
  504.             $this->sendOrderMail($order);
  505.             $this->updateSentOrderMailToSent($orderPayment);
  506.         }
  508.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.end'),$recvType['RECV_NAME'],$payName));
  510.         return $error;
  511.     }
  513.     /**
  514.      * 銀聯ネット決済の結果通知処理
  515.      * @param Order            $order        注文情報
  516.      * @param Vt4gOrderPayment $orderPayment 決済情報
  517.      * @param array            $record       結果通知の項目
  518.      * @param string           $payTypeId    決済方法内部ID
  519.      */
  520.     private function execUPOPRecvProcess($order, $orderPayment, $record, $payTypeId)
  521.     {
  522.         $error = '';
  523.         $payName = $this->vt4gConst['VT4G_PAYNAME_PAYTYPEID_'.$payTypeId];
  524.         $shouldSendMail = false;
  525.         $payStatuses = [];
  527.         switch ($record['txnType']) {
  528.             case $this->vt4gConst['VT4G_RECV_TXN_TYPE_AUTH']:
  529.                 // 申込時の処理区分から与信/売上の通知区分を判定
  530.                 $withCapture    = $this->getWithCapture($order);
  531.                 $recvType       = $withCapture === 1
  532.                                 ? $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE'] // 売上結果
  533.                                 : $this->vt4gConst['VT4G_PAY_STATUS']['AUTH'];   // 申込結果
  534.                 $newPayStatus   = $recvType['VALUE'];
  535.                 $newOrderStatus = $withCapture === 1 ? OrderStatus::PAID : OrderStatus::NEW;
  536.                 $payStatuses    = [ '', $recvType['VALUE'] ];
  538.                 $memo10 = unserialize($orderPayment->getMemo10());
  539.                 if (array_key_exists('sentOrderMail', $memo10) && $memo10['sentOrderMail'] === false) {
  540.                     $shouldSendMail = true;
  541.                 }
  543.                 break;
  544.             case $this->vt4gConst['VT4G_RECV_TXN_TYPE_CAPTURE']:
  545.                 $recvType       = $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE']; // 売上結果
  546.                 $newPayStatus   = '';
  547.                 $newOrderStatus = '';
  548.                 break;
  549.             case $this->vt4gConst['VT4G_RECV_TXN_TYPE_REFUND']:
  550.                 // 返金の場合、現在の決済ステータスで判別する
  551.                 $recvType       = $this->getRefundRecvSetting($orderPayment);
  552.                 $newPayStatus   = '';
  553.                 $newOrderStatus = '';
  554.                 break;
  555.             case $this->vt4gConst['VT4G_RECV_TXN_TYPE_CANCEL']:
  556.                 $recvType       = $this->vt4gConst['VT4G_PAY_STATUS']['CANCEL'];  // 取消結果
  557.                 $newPayStatus   = '';
  558.                 $newOrderStatus = '';
  559.                 break;
  560.             default:
  561.                 $this->mdkLogger->warn(sprintf(trans('vt4g_plugin.payment.recv.not.txn_type'),$record['txnType']));
  562.                 return '';
  563.         }
  565.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.start'),$recvType['RECV_NAME'],$payName));
  567.         // 決済ログ作成
  568.         $this->setLogHeadPushResult($record, $payTypeId, $recvType);
  569.         $this->setLogInfo('システム追跡番号' , $record['traceNumber']);
  570.         $this->setLogInfo('認証サービス日時' , $this->util->toDateMMDD($record['traceTime']) . '(中国時間)');
  571.         $this->setLogInfo('精算金額'         , preg_match('/^[0-9]+$/', $record['settleAmount']) ? number_format($record['settleAmount']) : $record['settleAmount']);
  572.         $this->setLogInfo('精算日付'         , $this->util->toDateMMDD($record['settleDate']));
  573.         if (!(empty($record['settleRate']) || $record['settleRate'] == 'null')){
  574.             $this->setLogInfo('精算レート'   , $record['settleRate']);
  575.         }
  577.         if ($record['mstatus'] != $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  578.             $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.mstatus.error'),$recvType['RECV_NAME'],$record['mstatus']));
  579.             $newPayStatus   = '';
  580.             $newOrderStatus = '';
  581.             $shouldSendMail = false;
  582.         }
  584.         // 現在の支払方法検証
  585.         $error .= $this->checkPaymentTypeIDPushResult($order, $orderPayment, $newPayStatus, $newOrderStatus);
  587.         // 決済ステータス検証
  588.         $error .= $this->checkPaymentStatusPushResult($orderPayment, $payStatuses, $newPayStatus, $newOrderStatus);
  590.         // 過去の受信情報と比較
  591.         $memo09 = $orderPayment->getmemo09();
  592.         if (!empty($memo09)) {
  593.             $oldRecords = unserialize($memo09);
  595.             foreach ($oldRecords as $oldRecord ) {
  597.                 if (   $oldRecord['txnType']     == $record['txnType']
  598.                     && $oldRecord['traceNumber'] == $record['traceNumber'] ) {
  600.                     $diff = array_diff(
  601.                         [
  602.                             $oldRecord['mstatus'],
  603.                             $oldRecord['traceTime'],
  604.                             $oldRecord['settleAmount'],
  605.                             $oldRecord['settleDate'],
  606.                             $oldRecord['settleRate'],
  607.                         ],
  608.                         [
  609.                             $record['mstatus'],
  610.                             $record['traceTime'],
  611.                             $record['settleAmount'],
  612.                             $record['settleDate'],
  613.                             $record['settleRate'],
  614.                         ]);
  616.                     if (!empty($diff)) {
  617.                         $error .= $this->makeErrorMsg(trans('vt4g_plugin.payment.recv.result.different'));
  618.                         $newPayStatus   = '';
  619.                         $newOrderStatus = '';
  620.                         break;
  621.                     }
  622.                 }
  623.             }
  625.         }
  627.         if (!empty($error)) {
  628.             $error = $this->makeErrorPushResult($record, $error, $order->getOrderNo());
  629.         } else {
  630.             if (   $record['txnType'] == $this->vt4gConst['VT4G_RECV_TXN_TYPE_AUTH']
  631.                 && $record['mstatus'] == $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  633.                 $this->clearCartByOrder($order);
  634.             }
  635.         }
  637.         $this->updatePushResult($order, $orderPayment, $newPayStatus, $newOrderStatus, $record);
  639.         if (empty($error) && $shouldSendMail) {
  640.             $this->sendOrderMail($order);
  641.             $this->updateSentOrderMailToSent($orderPayment);
  642.         }
  644.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.end'),$recvType['RECV_NAME'],$payName));
  646.         return $error;
  647.     }
  649.     /**
  650.      * Alipayの結果通知処理
  651.      * @param Order            $order        注文情報
  652.      * @param Vt4gOrderPayment $orderPayment 決済情報
  653.      * @param array            $record       結果通知の項目
  654.      * @param string           $payTypeId    決済方法内部ID
  655.      */
  656.     private function execAlipayRecvProcess($order, $orderPayment, $record, $payTypeId)
  657.     {
  658.         $error = '';
  659.         $payName = $this->vt4gConst['VT4G_PAYNAME_PAYTYPEID_'.$payTypeId];
  660.         $shouldSendMail = false;
  661.         $payStatuses = [];
  663.         switch ($record['txnType']) {
  664.             case $this->vt4gConst['VT4G_RECV_TXN_TYPE_AUTH']:
  665.                 // Alipayは与信同時売上のみ
  666.                 $recvType       = $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE']; // 売上結果
  667.                 $newPayStatus   = $recvType['VALUE'];
  668.                 $newOrderStatus = OrderStatus::PAID;
  669.                 $payStatuses    = [ '', $recvType['VALUE'] ];
  671.                 $memo10 = unserialize($orderPayment->getMemo10());
  672.                 if (array_key_exists('sentOrderMail', $memo10) && $memo10['sentOrderMail'] === false) {
  673.                     $shouldSendMail = true;
  674.                 }
  676.                 break;
  677.             case $this->vt4gConst['VT4G_RECV_TXN_TYPE_REFUND']:
  678.                 // 返金の場合、現在の決済ステータスで判別する
  679.                 $recvType       = $this->getRefundRecvSetting($orderPayment);
  680.                 $newPayStatus   = '';
  681.                 $newOrderStatus = '';
  682.                 break;
  683.             default:
  684.                 $this->mdkLogger->warn(sprintf(trans('vt4g_plugin.payment.recv.not.txn_type'),$record['txnType']));
  685.                 return '';
  686.         }
  688.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.start'),$recvType['RECV_NAME'],$payName));
  690.         // 決済ログ作成
  691.         $this->setLogHeadPushResult($record, $payTypeId, $recvType);
  692.         $this->setLogInfo('決済センターとの取引ID', $record['centerTradeId']);
  694.         if ($record['mstatus'] != $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  695.             $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.mstatus.error'),$recvType['RECV_NAME'],$record['mstatus']));
  696.             $newPayStatus   = '';
  697.             $newOrderStatus = '';
  698.             $shouldSendMail = false;
  699.         }
  701.         // 現在の支払方法検証
  702.         $error .= $this->checkPaymentTypeIDPushResult($order, $orderPayment, $newPayStatus, $newOrderStatus);
  704.         // 決済ステータス検証
  705.         $error .= $this->checkPaymentStatusPushResult($orderPayment, $payStatuses, $newPayStatus, $newOrderStatus);
  707.         // 過去の受信情報と比較
  708.         $memo09 = $orderPayment->getmemo09();
  709.         if (!empty($memo09)) {
  710.             $oldRecords = unserialize($memo09);
  712.             foreach ($oldRecords as $oldRecord ) {
  714.                 if (   $oldRecord['txnType']       == $record['txnType']
  715.                     && $oldRecord['centerTradeId'] == $record['centerTradeId']
  716.                     && $oldRecord['mstatus']       != $record['mstatus']) {
  718.                     $error .= $this->makeErrorMsg(trans('vt4g_plugin.payment.recv.result.different'));
  719.                     $newPayStatus   = '';
  720.                     $newOrderStatus = '';
  721.                     break;
  722.                 }
  723.             }
  724.         }
  726.         if (!empty($error)) {
  727.             $error = $this->makeErrorPushResult($record, $error, $order->getOrderNo());
  728.         } else {
  730.             if (   $record['txnType'] == $this->vt4gConst['VT4G_RECV_TXN_TYPE_AUTH']
  731.                 && $record['mstatus'] == $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  733.                 $this->clearCartByOrder($order);
  734.             }
  735.         }
  737.         $this->updatePushResult($order, $orderPayment, $newPayStatus, $newOrderStatus, $record);
  739.         if (empty($error) && $shouldSendMail) {
  740.             $this->sendOrderMail($order);
  741.             $this->updateSentOrderMailToSent($orderPayment);
  742.         }
  744.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.end'),$recvType['RECV_NAME'],$payName));
  746.         return $error;
  747.     }
  749.     /**
  750.      * 楽天ペイの結果通知処理
  751.      * @param Order            $order        注文情報
  752.      * @param Vt4gOrderPayment $orderPayment 決済情報
  753.      * @param array            $record       結果通知の項目
  754.      * @param string           $payTypeId    決済方法内部ID
  755.      */
  756.     private function execRakutenRecvProcess($order, $orderPayment, $record, $payTypeId)
  757.     {
  758.         $error = '';
  759.         $payName = $this->vt4gConst['VT4G_PAYNAME_PAYTYPEID_'.$payTypeId];
  760.         $shouldSendMail  = false;
  761.         $isRequest = false;
  763.         switch ($record['txnType']) {
  764.             case $this->vt4gConst['VT4G_RECV_TXN_TYPE_AUTH']:
  765.                 // 申込時の処理区分から与信/売上の通知区分を判定
  766.                 $withCapture    = $this->getWithCapture($order);
  767.                 $recvType       = $withCapture === 1
  768.                                 ? $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE'] // 売上結果
  769.                                 : $this->vt4gConst['VT4G_PAY_STATUS']['AUTH'];   // 申込結果
  770.                 $newPayStatus   = $recvType['VALUE'];
  771.                 $newOrderStatus = $withCapture === 1 ? OrderStatus::PAID : OrderStatus::NEW;
  772.                 $payStatuses    = [ '', $recvType['VALUE'] ];
  774.                 $memo10 = unserialize($orderPayment->getMemo10());
  775.                 if (array_key_exists('sentOrderMail', $memo10) && $memo10['sentOrderMail'] === false) {
  776.                     $shouldSendMail = true;
  777.                 }
  779.                 break;
  780.             case $this->vt4gConst['VT4G_RECV_TXN_TYPE_CAPTURE']:
  781.                 $recvType       = $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE']; // 売上結果
  782.                 $newPayStatus   = $recvType['VALUE'];
  783.                 $newOrderStatus = $order->getOrderStatus()->getId() === OrderStatus::NEW ? OrderStatus::PAID : '';
  784.                 $payStatuses    = [ $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE_REQUEST']['VALUE'] ];
  785.                 $isRequest      = true;
  786.                 break;
  787.             case $this->vt4gConst['VT4G_RECV_TXN_TYPE_CANCEL']:
  788.                 // 取消の場合、現在の決済ステータスで判別する
  789.                 $recvType       = $this->getRefundRecvSetting($orderPayment);
  790.                 $newPayStatus   = $recvType['VALUE'] == $this->vt4gConst['VT4G_PAY_STATUS']['REFUND']['VALUE']
  791.                                 ? $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE']['VALUE']
  792.                                 : $this->vt4gConst['VT4G_PAY_STATUS']['CANCEL']['VALUE'];
  793.                 $newOrderStatus = '';
  794.                 $payStatuses    = $recvType['VALUE'] == $this->vt4gConst['VT4G_PAY_STATUS']['REFUND']['VALUE']
  795.                                 ? [ $this->vt4gConst['VT4G_PAY_STATUS']['REDUCTION_REQUEST']['VALUE'] ]
  796.                                 : [ $this->vt4gConst['VT4G_PAY_STATUS']['CANCEL_REQUEST']['VALUE'] ];
  797.                 $isRequest      = true;
  798.                 break;
  799.             default:
  800.                 $this->mdkLogger->warn(sprintf(trans('vt4g_plugin.payment.recv.not.txn_type'),$record['txnType']));
  801.                 return '';
  802.         }
  804.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.start'),$recvType['RECV_NAME'],$payName));
  806.         // 決済ログ作成
  807.         $this->setLogHeadPushResult($record, $payTypeId, $recvType);
  808.         $this->setLogInfo('処理日時'                   , $this->util->toDate($record['txnTime']));
  809.         $this->setLogInfo('楽天スーパーポイント利用額' , preg_match('/^[0-9]+$/', $record['usedPoint']) ? number_format($record['usedPoint']) : $record['usedPoint']);
  810.         if (array_key_exists('rakutenOrderId', $record)) {
  811.             $this->setLogInfo('楽天取引ID' , $record['rakutenOrderId']);
  812.         }
  813.         if (array_key_exists('balance', $record)) {
  814.             $this->setLogInfo('残高' , preg_match('/^[0-9]+$/', $record['balance']) ? number_format($record['balance']) : $record['balance']);
  815.         }
  816.         if (array_key_exists('rakutenApiErrorCode', $record)) {
  817.             $this->setLogInfo('楽天API エラーコード' , $record['rakutenApiErrorCode']);
  818.         }
  819.         if (array_key_exists('rakutenOrderErrorCode', $record)) {
  820.             $this->setLogInfo('楽天取引エラーコード' , $record['rakutenOrderErrorCode']);
  821.         }
  823.         if ($record['mstatus'] != $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  824.             $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.mstatus.error'),$recvType['RECV_NAME'],$record['mstatus']));
  825.             $newPayStatus   = '';
  826.             $newOrderStatus = '';
  827.             $shouldSendMail = false;
  828.         }
  830.         // 現在の支払方法検証
  831.         $error .= $this->checkPaymentTypeIDPushResult($order, $orderPayment, $newPayStatus, $newOrderStatus);
  833.         // 決済ステータス検証
  834.         $error .= $this->checkPaymentStatusPushResult($orderPayment, $payStatuses, $newPayStatus, $newOrderStatus);
  836.         if (!empty($error)) {
  837.             $error = $this->makeErrorPushResult($record, $error, $order->getOrderNo());
  838.         } else {
  840.             // 売上と取消の結果通知の場合はメール本文の作成と処理結果コードをチェック
  841.             if ($isRequest) {
  842.                 if (is_null($this->rakutenMailSetting)) {
  843.                     $memo05 = $this->util->getPaymentMethodInfo($order->getPayment()->getId());
  844.                     if (is_array($memo05) && array_key_exists('result_mail_target',$memo05)) {
  845.                         $this->rakutenMailSetting = $memo05['result_mail_target'];
  846.                     } else {
  847.                         // 未登録の場合は設定画面の初期値と同じ値とする
  848.                         $this->rakutenMailSetting = $this->vt4gConst['VT4G_MAIL_TARGET']['RAKUTEN']['FAILURE'];
  849.                     }
  850.                 }
  852.                 // 要求結果メールのメッセージを設定
  853.                 if ($this->rakutenMailSetting == $this->vt4gConst['VT4G_MAIL_TARGET']['RAKUTEN']['ALL']) {
  854.                     $this->rakutenMailMsg[] .= $this->makeRakutenReqMsg($record, $order->getOrderNo(), $recvType);
  855.                 } elseif (   $this->rakutenMailSetting == $this->vt4gConst['VT4G_MAIL_TARGET']['RAKUTEN']['FAILURE']
  856.                     && $record['mstatus'] != $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  857.                         $this->rakutenMailMsg[] .= $this->makeRakutenReqMsg($record, $order->getOrderNo(), $recvType);
  858.                 }
  860.                 // 減額の通知で成功以外なら決済失敗にする。それ以外の通知で成功以外なら元の決済ステータスに戻す。
  861.                 if ($record['mstatus'] != $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  862.                     if ($recvType['VALUE'] == $this->vt4gConst['VT4G_PAY_STATUS']['REFUND']['VALUE']) {
  863.                         $newPayStatus = $this->vt4gConst['VT4G_PAY_STATUS']['FAILURE']['VALUE'];
  864.                     } else {
  865.                         $memo10 = unserialize($orderPayment->getMemo10());
  866.                         $newPayStatus = $memo10['lastPayStatus'];
  867.                     }
  868.                 } else {
  869.                     // 処理成功で取消なら決済情報の決済金額を0にする。
  870.                     if ($recvType['VALUE'] == $this->vt4gConst['VT4G_PAY_STATUS']['CANCEL']['VALUE']) {
  871.                         $memo10 = unserialize($orderPayment->getMemo10());
  872.                         $memo10['captureTotal'] = 0;
  873.                         $orderPayment->setMemo10(serialize($memo10));
  874.                     }
  875.                 }
  876.             }
  878.             // 先に結果通知が届くケースがあるので処理が成功した注文に紐付くカートをクリア
  879.             if (   $record['txnType'] == $this->vt4gConst['VT4G_RECV_TXN_TYPE_AUTH']
  880.                 && $record['mstatus'] == $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  882.                 $this->clearCartByOrder($order);
  883.             }
  884.         }
  886.         $this->updatePushResult($order, $orderPayment, $newPayStatus, $newOrderStatus, $record);
  888.         if (empty($error) && $shouldSendMail) {
  889.             $this->sendOrderMail($order);
  890.             $this->updateSentOrderMailToSent($orderPayment);
  891.         }
  893.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.end'),$recvType['RECV_NAME'],$payName));
  895.         return $error;
  896.     }
  898.     /**
  899.      * 楽天ペイV2の結果通知処理
  900.      * @param Order            $order        注文情報
  901.      * @param Vt4gOrderPayment $orderPayment 決済情報
  902.      * @param array            $record       結果通知の項目
  903.      * @param string           $payTypeId    決済方法内部ID
  904.      */
  905.     private function execRakutenV2RecvProcess($order, $orderPayment, $record, $payTypeId)
  906.     {
  907.         $error = '';
  908.         $payName = $this->vt4gConst['VT4G_PAYNAME_PAYTYPEID_'.$payTypeId];
  909.         $shouldSendMail  = false;
  910.         $payStatuses = [];
  912.         switch ($record['txnType']) {
  913.             case $this->vt4gConst['VT4G_RECV_TXN_TYPE_AUTH']:
  914.                 // 申込時の処理区分から与信/売上の通知区分を判定
  915.                 $withCapture    = $this->getWithCapture($order);
  916.                 $recvType       = $withCapture === 1
  917.                                 ? $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE'] // 売上結果
  918.                                 : $this->vt4gConst['VT4G_PAY_STATUS']['AUTH'];   // 申込結果
  919.                 $newPayStatus   = $recvType['VALUE'];
  920.                 $newOrderStatus = $withCapture === 1 ? OrderStatus::PAID : OrderStatus::NEW;
  921.                 $payStatuses    = [ '', $recvType['VALUE'] ];
  923.                 $memo10 = unserialize($orderPayment->getMemo10());
  924.                 if (array_key_exists('sentOrderMail', $memo10) && $memo10['sentOrderMail'] === false) {
  925.                     $shouldSendMail = true;
  926.                 }
  928.                 break;
  929.             case $this->vt4gConst['VT4G_RECV_TXN_TYPE_CAPTURE']:
  930.                 $recvType       = $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE']; // 売上結果
  931.                 $newPayStatus   = '';
  932.                 $newOrderStatus = '';
  933.                 break;
  934.             case $this->vt4gConst['VT4G_RECV_TXN_TYPE_CANCEL']:
  935.                 $recvType       = $this->vt4gConst['VT4G_PAY_STATUS']['CANCEL'];  // 取消結果
  936.                 $newPayStatus   = '';
  937.                 $newOrderStatus = '';
  938.                 break;
  939.             default:
  940.                 $this->mdkLogger->warn(sprintf(trans('vt4g_plugin.payment.recv.not.txn_type'),$record['txnType']));
  941.                 return '';
  942.         }
  944.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.start'),$recvType['RECV_NAME'],$payName));
  946.         // 決済ログ作成
  947.         $this->setLogHeadPushResult($record, $payTypeId, $recvType);
  948.         if ($record['txnType'] === $this->vt4gConst['VT4G_RECV_TXN_TYPE_AUTH']) {
  949.             $this->setLogInfo('処理日時' , $this->util->toDate($record['txnTime']));
  950.             $this->setLogInfo('楽天取引ID' , $record['rakutenOrderId']);
  951.             $this->setLogInfo('ゲートウェイ決済取引ID' , $record['gatewayOrderId']);
  952.             $this->setLogInfo('楽天ポイント利用額' , preg_match('/^[0-9]+$/', $record['usedPoint']) ? number_format($record['usedPoint']) : $record['usedPoint']);
  953.             $this->setLogInfo('クレジットカードのブランド' , $record['cardBrand']);
  954.             $this->setLogInfo('クレジットカード番号の下4桁' , $record['cardLast4']);
  955.             $this->setLogInfo('分割払いの回数' , $record['cardInstallments']);
  956.             $this->setLogInfo('セキュリティコード認証利用有無' , $record['cardCvc']);
  957.             $this->setLogInfo('3Dセキュア認証利用有無' , $record['card3ds']);
  958.             $this->setLogInfo('取消受付期限' , $this->util->toDate($record['cancelExpirationTime']));
  959.             if (!empty($record['captureExpirationTime'])) {
  960.                 $this->setLogInfo('売上受付期限' , $this->util->toDate($record['captureExpirationTime']));
  961.             }
  962.             if (!empty($record['extendAuthExpirationTime'])) {
  963.                 $this->setLogInfo('与信延長受付期限' , $this->util->toDate($record['extendAuthExpirationTime']));
  964.             }
  965.             $this->setLogInfo('金額変更受付期限' , $this->util->toDate($record['updateExpirationTime']));
  967.             if (array_key_exists('rakutenApiErrorCode', $record)) {
  968.                 $this->setLogInfo('楽天APIエラーコード' , $record['rakutenApiErrorCode']);
  969.             }
  970.             if (array_key_exists('rakutenApiErrorType', $record)) {
  971.                 $this->setLogInfo('楽天APIエラータイプ' , $record['rakutenApiErrorType']);
  972.             }
  974.         } else if ($record['txnType'] === $this->vt4gConst['VT4G_RECV_TXN_TYPE_CAPTURE'] || $record['txnType'] === $this->vt4gConst['VT4G_RECV_TXN_TYPE_CANCEL']) {
  975.             $this->setLogInfo('※' , '売上や取消の結果通知には対応していないため、データの更新は行いません。');
  976.         }
  978.         if ($record['mstatus'] != $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  979.             $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.mstatus.error'),$recvType['RECV_NAME'],$record['mstatus']));
  980.             $newPayStatus   = '';
  981.             $newOrderStatus = '';
  982.             $shouldSendMail = false;
  983.         }
  985.         // 現在の支払方法検証
  986.         $error .= $this->checkPaymentTypeIDPushResult($order, $orderPayment, $newPayStatus, $newOrderStatus);
  988.         // 決済ステータス検証
  989.         $error .= $this->checkPaymentStatusPushResult($orderPayment, $payStatuses, $newPayStatus, $newOrderStatus);
  991.         if (!empty($error)) {
  992.             $error = $this->makeErrorPushResult($record, $error, $order->getOrderNo());
  993.         } else {
  994.             // 先に結果通知が届くケースがあるので処理が成功した注文に紐付くカートをクリア
  995.             if (   $record['txnType'] == $this->vt4gConst['VT4G_RECV_TXN_TYPE_AUTH']
  996.                 && $record['mstatus'] == $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  997.                 $this->clearCartByOrder($order);
  998.             }
  999.         }
  1001.         $this->updatePushResult($order, $orderPayment, $newPayStatus, $newOrderStatus, $record);
  1003.         if (empty($error) && $shouldSendMail) {
  1004.             $this->sendOrderMail($order);
  1005.             $this->updateSentOrderMailToSent($orderPayment);
  1006.         }
  1008.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.end'),$recvType['RECV_NAME'],$payName));
  1010.         return $error;
  1011.     }
  1013.     /**
  1014.      * リクルートかんたん支払いの結果通知処理
  1015.      * @param Order            $order        注文情報
  1016.      * @param Vt4gOrderPayment $orderPayment 決済情報
  1017.      * @param array            $record       結果通知の項目
  1018.      * @param string           $payTypeId    決済方法内部ID
  1019.      */
  1020.     private function execRecruitRecvProcess($order, $orderPayment, $record, $payTypeId)
  1021.     {
  1022.         $error = '';
  1023.         $payName = $this->vt4gConst['VT4G_PAYNAME_PAYTYPEID_'.$payTypeId];
  1024.         $shouldSendMail = false;
  1026.         switch ($record['txnType']) {
  1027.             case $this->vt4gConst['VT4G_RECV_TXN_TYPE_AUTH']:
  1028.                 // 申込時の処理区分から与信/売上の通知区分を判定
  1029.                 $withCapture    = $this->getWithCapture($order);
  1030.                 $recvType       = $withCapture === 1
  1031.                                 ? $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE'] // 売上結果
  1032.                                 : $this->vt4gConst['VT4G_PAY_STATUS']['AUTH'];   // 申込結果
  1033.                 $newPayStatus   = $recvType['VALUE'];
  1034.                 $newOrderStatus = $withCapture === 1 ? OrderStatus::PAID : OrderStatus::NEW;
  1035.                 $payStatuses    = [ '', $recvType['VALUE']];
  1037.                 $memo10 = unserialize($orderPayment->getMemo10());
  1038.                 if (array_key_exists('sentOrderMail', $memo10) && $memo10['sentOrderMail'] === false) {
  1039.                     $shouldSendMail = true;
  1040.                 }
  1042.                 break;
  1043.             default:
  1044.                 $this->mdkLogger->warn(sprintf(trans('vt4g_plugin.payment.recv.not.txn_type'),$record['txnType']));
  1045.                 return '';
  1046.         }
  1048.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.start'),$recvType['RECV_NAME'],$payName));
  1050.         // 決済ログ作成
  1051.         $this->setLogHeadPushResult($record, $payTypeId, $recvType);
  1052.         $this->setLogInfo('処理日時'             , $this->util->toDate($record['txnTime']));
  1053.         $this->setLogInfo('リクルート取引ID'     , $record['recruitOrderId']);
  1054.         $this->setLogInfo('利用ポイント'         , preg_match('/^[0-9]+$/', $record['usePoint']) ? number_format($record['usePoint']) : $record['usePoint']);
  1055.         $this->setLogInfo('付与ポイント'         , preg_match('/^[0-9]+$/', $record['givePoint']) ? number_format($record['givePoint']) : $record['givePoint']);
  1056.         $this->setLogInfo('リクルートクーポン'   , preg_match('/^[0-9]+$/', $record['recruitCoupon']) ? number_format($record['recruitCoupon']) : $record['recruitCoupon']);
  1057.         $this->setLogInfo('マーチャントクーポン' , preg_match('/^[0-9]+$/', $record['merchantCoupon']) ? number_format($record['merchantCoupon']) : $record['merchantCoupon']);
  1059.         if ($record['mstatus'] != $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  1060.             $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.mstatus.error'),$recvType['RECV_NAME'],$record['mstatus']));
  1061.             $newPayStatus   = '';
  1062.             $newOrderStatus = '';
  1063.         }
  1065.         // 現在の支払方法検証
  1066.         $error .= $this->checkPaymentTypeIDPushResult($order, $orderPayment, $newPayStatus, $newOrderStatus);
  1068.         // 決済ステータス検証
  1069.         $error .= $this->checkPaymentStatusPushResult($orderPayment, $payStatuses, $newPayStatus, $newOrderStatus);
  1071.         if (!empty($error)) {
  1072.             $error = $this->makeErrorPushResult($record, $error, $order->getOrderNo());
  1073.         } else {
  1074.             // 先に結果通知が届くケースがあるので処理が成功した注文に紐付くカートをクリア
  1075.             if ($record['mstatus'] == $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  1076.                 $this->clearCartByOrder($order);
  1077.             }
  1078.         }
  1080.         $this->updatePushResult($order, $orderPayment, $newPayStatus, $newOrderStatus, $record);
  1082.         if (empty($error) && $shouldSendMail) {
  1083.             $this->sendOrderMail($order);
  1084.             $this->updateSentOrderMailToSent($orderPayment);
  1085.         }
  1087.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.end'),$recvType['RECV_NAME'],$payName));
  1089.         return $error;
  1090.     }
  1092.     /**
  1093.      * LINE Payの結果通知処理
  1094.      * @param Order            $order        注文情報
  1095.      * @param Vt4gOrderPayment $orderPayment 決済情報
  1096.      * @param array            $record       結果通知の項目
  1097.      * @param string           $payTypeId    決済方法内部ID
  1098.      */
  1099.     private function execLINEPayRecvProcess($order, $orderPayment, $record, $payTypeId)
  1100.     {
  1101.         $error = '';
  1102.         $payName = $this->vt4gConst['VT4G_PAYNAME_PAYTYPEID_'.$payTypeId];
  1103.         $shouldSendMail = false;
  1105.         switch ($record['txnType']) {
  1106.             case $this->vt4gConst['VT4G_RECV_TXN_TYPE_AUTH']:
  1107.                 // 申込時の処理区分から与信/売上の通知区分を判定
  1108.                 $withCapture    = $this->getWithCapture($order);
  1109.                 $recvType       = $withCapture === 1
  1110.                                 ? $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE'] // 売上結果
  1111.                                 : $this->vt4gConst['VT4G_PAY_STATUS']['AUTH'];   // 申込結果
  1112.                 $newPayStatus   = $recvType['VALUE'];
  1113.                 $newOrderStatus = $withCapture === 1 ? OrderStatus::PAID : OrderStatus::NEW;
  1114.                 $payStatuses    = [ '', $recvType['VALUE']];
  1116.                 $memo10 = unserialize($orderPayment->getMemo10());
  1117.                 if (array_key_exists('sentOrderMail', $memo10) && $memo10['sentOrderMail'] === false) {
  1118.                     $shouldSendMail = true;
  1119.                 }
  1121.                 break;
  1122.             default:
  1123.                 $this->mdkLogger->warn(sprintf(trans('vt4g_plugin.payment.recv.not.txn_type'),$record['txnType']));
  1124.                 return '';
  1125.         }
  1127.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.start'),$recvType['RECV_NAME'],$payName));
  1129.         // 決済ログ作成
  1130.         $this->setLogHeadPushResult($record, $payTypeId, $recvType);
  1131.         $this->setLogInfo('処理日時'         , $this->util->toDate($record['txnTime']));
  1132.         $this->setLogInfo('LINE Pay 取引番号', $record['linepayOrderId']);
  1134.         if ($record['mstatus'] != $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  1135.             $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.mstatus.error'),$recvType['RECV_NAME'],$record['mstatus']));
  1136.             $newPayStatus   = '';
  1137.             $newOrderStatus = '';
  1138.             $shouldSendMail = false;
  1139.         }
  1141.         // 現在の支払方法検証
  1142.         $error .= $this->checkPaymentTypeIDPushResult($order, $orderPayment, $newPayStatus, $newOrderStatus);
  1144.         // 決済ステータス検証
  1145.         $error .= $this->checkPaymentStatusPushResult($orderPayment, $payStatuses, $newPayStatus, $newOrderStatus);
  1147.         if (!empty($error)) {
  1148.             $error = $this->makeErrorPushResult($record, $error, $order->getOrderNo());
  1149.         } else {
  1150.             // 先に結果通知が届くケースがあるので処理が成功した注文に紐付くカートをクリア
  1151.             if ($record['mstatus'] == $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  1152.                 $this->clearCartByOrder($order);
  1153.             }
  1154.         }
  1156.         $this->updatePushResult($order, $orderPayment, $newPayStatus, $newOrderStatus, $record);
  1158.         if (empty($error) && $shouldSendMail) {
  1159.             $this->sendOrderMail($order);
  1160.             $this->updateSentOrderMailToSent($orderPayment);
  1161.         }
  1163.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.end'),$recvType['RECV_NAME'],$payName));
  1165.         return $error;
  1166.     }
  1168.     /**
  1169.      * PayPal決済の結果通知処理
  1170.      * @param Order            $order        注文情報
  1171.      * @param Vt4gOrderPayment $orderPayment 決済情報
  1172.      * @param array            $record       結果通知の項目
  1173.      * @param string           $payTypeId    決済方法内部ID
  1174.      */
  1175.     private function execPayPalRecvProcess($order, $orderPayment, $record, $payTypeId)
  1176.     {
  1177.         $error = '';
  1178.         $payName = $this->vt4gConst['VT4G_PAYNAME_PAYTYPEID_'.$payTypeId];
  1179.         $shouldSendMail = false;
  1180.         $payStatuses = [];
  1181.         // 速報確報フラグをレコードに持たせる
  1182.         $record['fixed'] = $this->fixed;
  1184.         switch ($record['txnType']) {
  1185.             case $this->vt4gConst['VT4G_RECV_TXN_TYPE_CAPTURE']:
  1186.                 $recvType       = $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE']; // 売上結果
  1188.                 if ($record['fixed'] != $this->vt4gConst['VT4G_RECV_PAYPAL_FIXED']) {
  1189.                     $newPayStatus   = $recvType['VALUE'];
  1190.                     $newOrderStatus = $order->getOrderStatus()->getId() == (OrderStatus::NEW || OrderStatus::PENDING) ? OrderStatus::PAID : '';
  1191.                     $payStatuses    = [
  1192.                                         '',
  1193.                                         $this->vt4gConst['VT4G_PAY_STATUS']['AUTH']['VALUE'],
  1194.                                         $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE']['VALUE'],
  1195.                                     ];
  1196.                     $memo10 = unserialize($orderPayment->getMemo10());
  1197.                     if (array_key_exists('sentOrderMail', $memo10) && $memo10['sentOrderMail'] === false) {
  1198.                         $shouldSendMail = true;
  1199.                     }
  1201.                 } else {
  1202.                     $newPayStatus = '';
  1203.                     $newOrderStatus = '';
  1204.                 }
  1206.                 break;
  1207.             case $this->vt4gConst['VT4G_RECV_TXN_TYPE_REFUND']:
  1208.                 // 返金の場合、現在の決済ステータスで判別する
  1209.                 $recvType       = $this->getRefundRecvSetting($orderPayment);
  1210.                 $newPayStatus   = '';
  1211.                 $newOrderStatus = '';
  1212.                 break;
  1213.             default:
  1214.                 $this->mdkLogger->warn(sprintf(trans('vt4g_plugin.payment.recv.not.txn_type'),$record['txnType']));
  1215.                 return '';
  1216.         }
  1218.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.start'),$recvType['RECV_NAME'],$payName));
  1220.         // 決済ログ作成
  1221.         $this->setLogHeadPushResult($record, $payTypeId, $recvType);
  1222.         $this->setLogInfo('受付日時'  , $this->util->toDate($record['receivedDatetime']));
  1223.         $this->setLogInfo('金額'      , preg_match('/^[0-9]+$/', $record['amount']) ? number_format($record['amount']) : $record['amount']);
  1224.         $this->setLogInfo('お客様番号', $record['payerId']);
  1225.         $this->setLogInfo('取引識別子', $record['centerTxnId']);
  1227.         if ($record['mstatus'] != $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  1228.             $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.mstatus.error'),$recvType['RECV_NAME'],$record['mstatus']));
  1229.             $newPayStatus   = '';
  1230.             $newOrderStatus = '';
  1231.             $shouldSendMail = false;
  1232.         }
  1234.         // 現在の支払方法検証
  1235.         $error .= $this->checkPaymentTypeIDPushResult($order, $orderPayment, $newPayStatus, $newOrderStatus);
  1237.         // 決済ステータス検証
  1238.         $error .= $this->checkPaymentStatusPushResult($orderPayment, $payStatuses, $newPayStatus, $newOrderStatus);
  1240.         // 過去の受信情報と比較
  1241.         $memo09 = $orderPayment->getmemo09();
  1242.         if (!empty($memo09)) {
  1243.             $oldRecords  = unserialize($memo09);
  1244.             $promptCnt   = 0;
  1245.             $diffRecode  = false;
  1246.             $failerFixed = false;
  1248.             foreach ($oldRecords as $oldRecord ) {
  1249.                 // payerId、centerTxnId、fixedが同じで、異なる結果を受信したらエラーメール
  1250.                 // 一つでも見つかればエラーメールなので、発見済みならスキップ
  1251.                 if (   $oldRecord['payerId']     == $record['payerId']
  1252.                     && $oldRecord['centerTxnId'] == $record['centerTxnId']
  1253.                     && $oldRecord['fixed']       == $record['fixed']
  1254.                     && !$diffRecode) {
  1256.                     $diff = array_diff(
  1257.                         [
  1258.                             $oldRecord['mstatus'],
  1259.                             $oldRecord['receivedDatetime'],
  1260.                             $oldRecord['amount'],
  1261.                         ],
  1262.                         [
  1263.                             $record['mstatus'],
  1264.                             $record['receivedDatetime'],
  1265.                             $record['amount'],
  1266.                         ]);
  1268.                     $diffRecode = !empty($diff);
  1269.                 }
  1271.                 // 今回が確報なら速報の結果を確認
  1272.                 if ($record['fixed'] == $this->vt4gConst['VT4G_RECV_PAYPAL_FIXED']) {
  1273.                     if (   $oldRecord['payerId']     == $record['payerId']
  1274.                         && $oldRecord['centerTxnId'] == $record['centerTxnId']
  1275.                         && $oldRecord['fixed']       != $this->vt4gConst['VT4G_RECV_PAYPAL_FIXED'] ) {
  1277.                         $promptCnt++;
  1279.                         // 過去に成功の速報を受信していて、今回が成功以外の確報ならエラーメール対象
  1280.                         if (   $oldRecord['mstatus'] == $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']
  1281.                             && $record['mstatus']    != $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  1283.                             $failerFixed = true;
  1284.                         }
  1285.                     }
  1286.                 }
  1288.             }
  1290.             // 過去の受信結果と異なる結果だった場合
  1291.             if ($diffRecode) {
  1292.                 $error .= $this->makeErrorMsg(trans('vt4g_plugin.payment.recv.result.different'));
  1293.                 $newPayStatus   = '';
  1294.                 $newOrderStatus = '';
  1295.             }
  1297.             if ($record['fixed'] == $this->vt4gConst['VT4G_RECV_PAYPAL_FIXED']) {
  1298.                 if ($failerFixed) {
  1299.                     $error .= $this->makeErrorMsg(trans('vt4g_plugin.payment.recv.paypal.fixed.failure'));
  1300.                 }
  1301.                 // 速報がないのに確報の成功結果が届いたらエラーメール
  1302.                 if ($promptCnt == 0 && $record['mstatus'] == $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  1303.                     $error .= $this->makeErrorMsg(trans('vt4g_plugin.payment.recv.paypal.fixed.not.prompt'));
  1304.                 }
  1305.             }
  1307.         } else {
  1308.             // 受信結果がないのに確報の成功結果が届いたらエラーメール
  1309.             if (   $record['fixed']   == $this->vt4gConst['VT4G_RECV_PAYPAL_FIXED']
  1310.                 && $record['mstatus'] == $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  1312.                 $error .= $this->makeErrorMsg(trans('vt4g_plugin.payment.recv.paypal.fixed.not.prompt'));
  1313.             }
  1314.         }
  1316.         if (!empty($error)) {
  1317.             $error = $this->makeErrorPushResult($record, $error, $order->getOrderNo());
  1318.         } else {
  1319.             if (   $record['txnType'] == $this->vt4gConst['VT4G_RECV_TXN_TYPE_CAPTURE']
  1320.                 && $record['fixed']   != $this->vt4gConst['VT4G_RECV_PAYPAL_FIXED']
  1321.                 && $record['mstatus'] == $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  1323.                 $this->clearCartByOrder($order);
  1324.             }
  1325.         }
  1327.         $this->updatePushResult($order, $orderPayment, $newPayStatus, $newOrderStatus, $record);
  1329.         if (empty($error) && $shouldSendMail) {
  1330.             $this->sendOrderMail($order);
  1331.             $this->updateSentOrderMailToSent($orderPayment);
  1332.         }
  1334.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.end'),$recvType['RECV_NAME'],$payName));
  1336.         return $error;
  1337.     }
  1339.     /**
  1340.      * PayPayの結果通知処理
  1341.      * @param Order            $order        注文情報
  1342.      * @param Vt4gOrderPayment $orderPayment 決済情報
  1343.      * @param array            $record       結果通知の項目
  1344.      * @param string           $payTypeId    決済方法内部ID
  1345.      */
  1346.     private function execPayPayRecvProcess($order, $orderPayment, $record, $payTypeId)
  1347.     {
  1348.         $error = '';
  1349.         $payName = $this->vt4gConst['VT4G_PAYNAME_PAYTYPEID_'.$payTypeId];
  1350.         $shouldSendMail = false;
  1351.         $payStatuses = [];
  1353.         switch ($record['txnType']) {
  1354.             case $this->vt4gConst['VT4G_RECV_TXN_TYPE_AUTH']:
  1355.                 // 申込時の処理区分から与信/売上の通知区分を判定
  1356.                 $withCapture    = $this->getWithCapture($order);
  1357.                 $recvType       = $withCapture === 1
  1358.                                 ? $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE'] // 売上結果
  1359.                                 : $this->vt4gConst['VT4G_PAY_STATUS']['AUTH'];   // 申込結果
  1360.                 $newPayStatus   = $recvType['VALUE'];
  1361.                 $newOrderStatus = $withCapture === 1 ? OrderStatus::PAID : OrderStatus::NEW;
  1362.                 $payStatuses    = [ '', $recvType['VALUE']];
  1364.                 $memo10 = unserialize($orderPayment->getMemo10());
  1365.                 if (array_key_exists('sentOrderMail', $memo10) && $memo10['sentOrderMail'] === false) {
  1366.                     $shouldSendMail = true;
  1367.                 }
  1368.                 break;
  1369.             default:
  1370.                 $this->mdkLogger->warn(sprintf(trans('vt4g_plugin.payment.recv.not.txn_type'),$record['txnType']));
  1371.                 return '';
  1372.         }
  1374.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.start'),$recvType['RECV_NAME'],$payName));
  1376.         // 決済ログ作成
  1377.         $this->setLogHeadPushResult($record, $payTypeId, $recvType);
  1378.         $this->setLogInfo('処理日時'      , $this->util->toDate($record['txnTime']));
  1379.         $this->setLogInfo('PayPay 取引ID' , $record['paypayOrderId']);
  1381.         if ($record['mstatus'] != $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  1382.             $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.mstatus.error'),$recvType['RECV_NAME'],$record['mstatus']));
  1383.             $newPayStatus   = '';
  1384.             $newOrderStatus = '';
  1385.             $shouldSendMail = false;
  1386.         }
  1388.         // 現在の支払方法検証
  1389.         $error .= $this->checkPaymentTypeIDPushResult($order, $orderPayment, $newPayStatus, $newOrderStatus);
  1391.         // 決済ステータス検証
  1392.         $error .= $this->checkPaymentStatusPushResult($orderPayment, $payStatuses, $newPayStatus, $newOrderStatus);
  1394.         if (!empty($error)) {
  1395.             $error = $this->makeErrorPushResult($record, $error, $order->getOrderNo());
  1396.         } else {
  1397.             // 先に結果通知が届くケースがあるので処理が成功した注文に紐付くカートをクリア
  1398.             if ($record['mstatus'] == $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  1399.                 $this->clearCartByOrder($order);
  1400.             }
  1401.         }
  1403.         $this->updatePushResult($order, $orderPayment, $newPayStatus, $newOrderStatus, $record);
  1405.         if (empty($error) && $shouldSendMail) {
  1406.             $this->sendOrderMail($order);
  1407.             $this->updateSentOrderMailToSent($orderPayment);
  1408.         }
  1411.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.save.end'),$recvType['RECV_NAME'],$payName));
  1413.         return $error;
  1414.     }
  1416.     /**
  1417.      * 結果通知の決済ログヘッダ部分の作成
  1418.      *
  1419.      * @param array   $record       通知レコード
  1420.      * @param integer $payTypeId    支払方法内部ID
  1421.      * @param array   $recvType     通知ごとの設定値
  1422.      * @param string  $payName      支払方法の名称
  1423.      */
  1424.     private function setLogHeadPushResult($record, $payTypeId, $recvType, $payName = null)
  1425.     {
  1426.         $statusLabel = $recvType['LABEL'] == $this->vt4gConst['VT4G_PAY_STATUS']['DEPOSIT']['LABEL']
  1427.                     ? $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE']['LABEL']
  1428.                     : $recvType['LABEL'];
  1430.         // ログの共通ヘッダの作成
  1431.         $this->logData = [];
  1432.         $log_message  = '';
  1434.         $log_message .= "[{$statusLabel}] ";
  1435.         $log_message .= "{$recvType['RECV_NAME']}通知受信";
  1437.         // PayPalの通知は速報、確報を付けて表示する
  1438.         if ($payTypeId == $this->vt4gConst['VT4G_PAYTYPEID_PAYPAL']){
  1439.             $log_message .= $record['fixed'] == $this->vt4gConst['VT4G_RECV_PAYPAL_FIXED'] ? '(確報)' : '(速報)';
  1440.         }
  1442.         // 入金済みにする入金通知に成功、失敗はないので飛ばす
  1443.         if ($recvType['VALUE'] != $this->vt4gConst['VT4G_PAY_STATUS']['DEPOSIT']['VALUE']){
  1445.             if ($record['mstatus'] == $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  1446.                 $msg = '成功';
  1447.             } elseif ($record['mstatus'] == $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['PENDING']) {
  1448.                 $msg = '保留';
  1449.             } else {
  1450.                 $msg = '失敗';
  1451.             }
  1453.             $log_message .= ' ' . $msg;
  1454.         }
  1456.         $this->setLogInfo('決済取引ID', $record['orderId']);
  1457.         $this->setLogInfo($payName ?? $this->vt4gConst['VT4G_PAYNAME_PAYTYPEID_'.$payTypeId], $log_message);
  1459.     }
  1461.     /**
  1462.      * 入金通知上のコンビニ名を取得します。
  1463.      *
  1464.      * @param  string $cvsType CVSタイプ
  1465.      * @return string          コンビニ名
  1466.      */
  1467.     private function getPayConveni($cvsType)
  1468.     {
  1469.         $arrConveni = $this->vt4gConst['VT4G_RECV_CVS_TYPE'];
  1471.         if (array_key_exists($cvsType, $arrConveni)) {
  1472.             return $arrConveni[$cvsType];
  1473.         } else {
  1474.             return '不明';
  1475.         }
  1476.     }
  1478.     /**
  1479.      * 注文と支払方法設定データの支払方法内部IDをチェックします。
  1480.      *
  1481.      * @param  Order             $order          注文情報
  1482.      * @param  Vt4gOrderPayment  $orderPayment   決済情報
  1483.      * @param  string           &$newPayStatus   更新予定の決済ステータス
  1484.      * @param  string           &$newOrderStatus 更新予定の注文ステータス
  1485.      * @return string            $error          エラーのときはメッセージ、それ以外は空文字
  1486.      */
  1487.     private function checkPaymentTypeIDPushResult($order, $orderPayment, &$newPayStatus, &$newOrderStatus)
  1488.     {
  1489.         $paymentMethod = $this->util->getPaymentMethod($order->getPayment()->getId());
  1491.         if(!empty($paymentMethod->getMemo03()) && $paymentMethod->getMemo03() == $orderPayment->getMemo03()) {
  1492.             return '';
  1493.         }
  1495.         // 以下エラーの場合
  1496.         $msg = sprintf(trans('vt4g_plugin.payment.recv.payment_type_id.error'),$orderPayment->getMemo03(),$paymentMethod->getMemo03());
  1497.         $error = $this->makeErrorMsg($msg);
  1498.         $newPayStatus = '';
  1499.         $newOrderStatus = '';
  1500.         return $error;
  1501.     }
  1503.     /**
  1504.      * 通知受信前の決済ステータスが想定通りであるかをチェックします。
  1505.      * チェックNGの場合は更新予定の決済ステータスと注文ステータスを空にします。
  1506.      * 更新予定の決済ステータスが空で渡された場合はOKとします。
  1507.      * @param  Vt4gOrderPayment $orderPayment   決済情報
  1508.      * @param  array            $payStatuses    想定される決済ステータスの配列
  1509.      * @param  string          &$newPayStatus   更新予定の決済ステータス
  1510.      * @param  string          &$newOrderStatus 更新予定の注文ステータス
  1511.      * @return string           $error          エラーのときはメッセージ、それ以外は空文字
  1512.      */
  1513.     private function checkPaymentStatusPushResult($orderPayment, $payStatuses, &$newPayStatus, &$newOrderStatus)
  1514.     {
  1515.         if (empty($newPayStatus) || in_array($orderPayment->getMemo04(), $payStatuses)) {
  1516.             return '';
  1517.         }
  1519.         // 以下エラーの場合
  1520.         $names = [];
  1521.         foreach ($payStatuses as $payStatus) {
  1522.             $names[] = empty($payStatus) ? '値なし' : $this->util->getPaymentStatusName($payStatus);
  1523.         }
  1525.         $msg = sprintf(trans('vt4g_plugin.payment.recv.payment_status.error'),
  1526.                         $this->util->getPaymentStatusName($orderPayment->getMemo04()),
  1527.                         implode(' ',$names));
  1528.         $error = $this->makeErrorMsg($msg);
  1529.         $newPayStatus   = '';
  1530.         $newOrderStatus = '';
  1531.         return $error;
  1532.     }
  1534.     /**
  1535.      * 通知受信前の注文ステータスが想定通りであるかをチェックします。
  1536.      * チェックNGの場合は更新予定の注文ステータスを空にします。
  1537.      * 更新予定の注文ステータスが空で渡された場合はOKとします。
  1538.      * @param  Order   $Order          注文情報
  1539.      * @param  array   $orderStatus    想定される注文ステータス
  1540.      * @param  string  $newOrderStatus 更新予定の注文ステータス
  1541.      * @return string  $error          エラーのときはメッセージ、それ以外は空文字
  1542.      */
  1543.     private function checkOrderStatusPushResult($order, $orderStatus, &$newOrderStatus)
  1544.     {
  1546.         if (empty($newOrderStatus) || in_array($order->getOrderStatus()->getId(),$orderStatus['id'])) {
  1547.             return '';
  1548.         }
  1550.         // 以下エラーの場合
  1551.         $statusArray = [];
  1552.         $beforePushResultOrderStatus = $this->em->getRepository(OrderStatus::class)->findBy($orderStatus);
  1553.         foreach($beforePushResultOrderStatus as $status ){
  1554.             $statusArray[] = $status->getName();
  1555.         }
  1557.         $msg = sprintf(trans('vt4g_plugin.payment.recv.order_status.error'),
  1558.                         $order->getOrderStatus()->getName(),
  1559.                         implode(' ',$statusArray));
  1560.         $error = $this->makeErrorMsg($msg);
  1561.         $newOrderStatus = '';
  1562.         return $error;
  1563.     }
  1565.     /**
  1566.      * 本人認証結果通知の情報で受注を更新します。
  1567.      * @param Order            $order        注文情報
  1568.      * @param Vt4gOrderPayment $orderPayment 決済情報
  1569.      * @param array            $recode       結果通知の項目
  1570.      * @param integer          $newPayStatus 通知受信後の決済ステータス
  1571.      * @param integer          $withCapture  決済申込時点の処理区分
  1572.      * @param array $record 通知レコード
  1573.      */
  1574.     private function updateMpiPushResult($order, $orderPayment, $record, $newPayStatus, $withCapture)
  1575.     {
  1576.         $creditService = $this->container->get('vt4g_plugin.service.payment_credit');
  1577.         $creditService->logData = [];
  1579.         $creditService->paymentResult['isOK']         = true;
  1580.         $creditService->paymentResult['vResultCode']  = $record['vResultCode'];
  1581.         $creditService->paymentResult['mErrMsg']      = "";
  1582.         $creditService->paymentResult['mStatus']      = $record['cardMstatus'];
  1583.         $creditService->paymentResult['orderId']      = $orderPayment->getMemo01();
  1585.         $memo10 = unserialize($orderPayment->getMemo10());
  1586.         $creditService->paymentResult['paymentType']  = substr($memo10['card_type'], 0, 2);
  1587.         $creditService->paymentResult['paymentCount'] = substr($memo10['card_type'], 2);
  1589.         $creditService->paymentResult['payStatus']    = $newPayStatus;
  1590.         $creditService->paymentResult['mpiHosting']   = true;
  1591.         $creditService->paymentResult['withCapture']  = $withCapture;
  1593.         // フラグをオンにしてcompleteOrderでメール送信とappendOrderMessageをやらない
  1594.         $creditService->isPaymentRecv = true;
  1595.         $creditService->completeCreditOrder($order, $orderPayment);
  1597.         // 結果通知項目の登録
  1598.         $this->registPushRecord($orderPayment, $record);
  1600.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.order.update'), $order->getId()));
  1601.     }
  1603.     /**
  1604.      * ステータスの更新、結果通知項目の登録、決済ログの登録を行います。<br>
  1605.      * $newOrderStatusに値がある場合はdtb_orderの更新を行います。<br>
  1606.      * $newPayStatusに値がある場合はplg_vt4g_order_paymentの更新を行います。
  1607.      * @param Order            $order          注文情報
  1608.      * @param Vt4gOrderPayment $orderPayment   決済情報
  1609.      * @param integer          $newPayStatus   更新予定の決済ステータス
  1610.      * @param integer          $newOrderStatus 更新予定の注文ステータス
  1611.      * @param array            $record         結果通知の項目
  1612.      */
  1613.     private function updatePushResult($order, $orderPayment, $newPayStatus, $newOrderStatus, $record)
  1614.     {
  1615.         $orderId = $order->getId();
  1617.         // 注文ステータスの更新
  1618.         if (!empty($newOrderStatus)) {
  1620.             if (empty($orderPayment->getMemo04())) {
  1621.                 $this->purchaseFlow->commit($order, new PurchaseContext());
  1622.             }
  1624.             $orderStatus = $this->em->getRepository(OrderStatus::class)->find($newOrderStatus);
  1625.             $this->em->getRepository(Order::class)->changeStatus($orderId, $orderStatus);
  1626.         }
  1628.         // 決済ステータスの更新
  1629.         if (!empty($newPayStatus)) {
  1630.             $orderPayment->setMemo04($newPayStatus);
  1631.             $this->em->persist($orderPayment);
  1632.             $this->em->flush();
  1633.         }
  1635.         // 結果通知項目の登録
  1636.         $this->registPushRecord($orderPayment, $record);
  1638.         // 決済ログテーブルにログを追加
  1639.         $this->setOrderLog($order);
  1641.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.order.update'), $orderId));
  1642.     }
  1644.     /**
  1645.      * エラー出力
  1646.      *
  1647.      * @param  array  $record    結果通知の項目
  1648.      * @param  string $error     メッセージ
  1649.      * @param  string $orderNo   注文番号
  1650.      * @return string $new_error エラーメッセージ
  1651.      */
  1652.     private function makeErrorPushResult($record, $error, $orderNo = '')
  1653.     {
  1654.         $orderId = $record['orderId'];
  1655.         $newError = <<<__EOS__
  1656. 決済取引ID : $orderId
  1657.   注文番号 : $orderNo
  1658. エラー原因 : $error
  1660. __EOS__;
  1662.         return $newError;
  1663.     }
  1665.     /**
  1666.      * 楽天ペイ 要求結果メッセージ作成
  1667.      * @param  array  $record   結果通知の項目
  1668.      * @param  string $orderNo  注文番号
  1669.      * @param  array  $recvType 結果通知ごとの設定値
  1670.      * @return string $payLabel 決済方法の名称
  1671.      */
  1672.     private function makeRakutenReqMsg($record, $orderNo = '', $recvType)
  1673.     {
  1674.         $orderId = $record['orderId'];
  1675.         $ret  = $recvType['VALUE'] == $this->vt4gConst['VT4G_PAY_STATUS']['REFUND']['VALUE']
  1676.                 ? $this->vt4gConst['VT4G_LABEL_RENAME']['RAKUTEN']['REFUND']
  1677.                 : $recvType['LABEL'];
  1678.         $ret .= $record['mstatus'] == $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK'] ? '成立' : '不成立';
  1680.         if (   $recvType['VALUE'] == $this->vt4gConst['VT4G_PAY_STATUS']['REFUND']['VALUE']
  1681.             && $record['mstatus'] != $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
  1683.             $ret .= sprintf('(%s)',trans('vt4g_plugin.payment.recv.order.retry'));
  1684.         }
  1686.         $msg = <<<__EOS__
  1687. 決済取引ID : $orderId
  1688.   注文番号 : $orderNo
  1689.   要求結果 : $ret
  1691. __EOS__;
  1693.         return $msg;
  1694.     }
  1696.     /**
  1697.      * エラーとなった情報をメールで送信します。
  1698.      * @param array $arrHead 結果通知ヘッダー情報
  1699.      */
  1700.     public function sendErrorMail($arrHead)
  1701.     {
  1702.         $pushDateTime = $this->util->toDate($arrHead['pushTime']);
  1703.         $errors = implode(LF, $this->errorMailMsg);
  1705.         $content = $this->container->get('twig')->render(
  1706.             "VeriTrans4G2/Resource/template/default/Mail/vt4g_payment_recv_error.twig",
  1707.             [
  1708.                 'pluginName' => $this->vt4gConst['VT4G_SERVICE_NAME'],
  1709.                 'pushDateTime' => $pushDateTime,
  1710.                 'pushId' => $arrHead['pushId'],
  1711.                 'errors' => $errors
  1712.             ],
  1713.             'text/html'
  1714.             );
  1716.         $this->mdkLogger->debug(trans('vt4g_plugin.payment.recv.show.error_mail') .LF. $content);
  1717.         $this->sendMail($this->vt4gConst['VT4G_SERVICE_NAME'] . $this->vt4gConst['VT4G_RECV_MAIL_SUBJECT']['ERROR'], $content);
  1718.         $this->mdkLogger->info(trans('vt4g_plugin.payment.recv.send.error_mail'));
  1719.     }
  1721.     /**
  1722.      * 楽天ペイの要求結果メールを送信します。
  1723.      * @param array $arrHead 結果通知ヘッダー情報
  1724.      */
  1725.     public function sendRakutenReqMail($arrHead)
  1726.     {
  1727.         $pushDateTime = $this->util->toDate($arrHead['pushTime']);
  1728.         $msg = implode(LF, $this->rakutenMailMsg);
  1730.         $content = $this->container->get('twig')->render(
  1731.             "VeriTrans4G2/Resource/template/default/Mail/vt4g_payment_recv_request_result.twig",
  1732.             [
  1733.                 'paymentName' => $this->vt4gConst['VT4G_PAYNAME_PAYTYPEID_60'],
  1734.                 'pushDateTime' => $pushDateTime,
  1735.                 'pushId' => $arrHead['pushId'],
  1736.                 'msg' => $msg
  1737.             ],
  1738.             'text/html'
  1739.             );
  1741.         $subject = $this->vt4gConst['VT4G_SERVICE_NAME']
  1742.                   . '- '
  1743.                   . $this->vt4gConst['VT4G_PAYNAME_PAYTYPEID_60']
  1744.                   . $this->vt4gConst['VT4G_RECV_MAIL_SUBJECT']['RESULT'];
  1746.         $this->sendMail($subject, $content);
  1747.         $this->mdkLogger->info(trans('vt4g_plugin.payment.recv.send.request_mail'));
  1748.     }
  1750.     /**
  1751.      * コンビニ・ATM決済で入金となった注文をメール送信します。
  1752.      *
  1753.      */
  1754.     public function sendPaymentInfoMail()
  1755.     {
  1756.         $orders = $this->em->getRepository(Order::class)->findBy(['order_no'=> $this->paymentInfoOrderNo]);
  1757.         $baseInfo = $this->em->getRepository(BaseInfo::class)->get();
  1758.         $mailTemplate = $this->em->getRepository(MailTemplate::class)->findOneBy(['name'=> $this->vt4gConst['VT4G_DTB_MAIL_TEMPLATE']['PAYMENT_INFO']['NAME']]);
  1759.         $htmlFileName = $this->mailService->getHtmlTemplate($mailTemplate->getFileName());
  1760.         $configService = $this->container->get('vt4g_plugin.service.admin.plugin.config');
  1761.         $subData = $configService->getSubData();
  1763.         $subject = '['.$baseInfo->getShopName().'] '.$mailTemplate->getMailSubject();
  1765.         foreach ($orders as $order) {
  1766.             $historyUrl = is_null($order->getCustomer())
  1767.                         ? null
  1768.                         : $this->container->get('router')->generate('mypage_history',['order_no' => $order->getOrderNo()],UrlGeneratorInterface::ABSOLUTE_URL);
  1770.             $body = $this->twig->render($mailTemplate->getFileName(), [
  1771.                 'Order' => $order,
  1772.                 'historyUrl' => $historyUrl
  1773.             ]);
  1775.             if (!is_null($htmlFileName)) {
  1776.                 $htmlBody = $this->twig->render($htmlFileName, [
  1777.                     'Order' => $order,
  1778.                     'historyUrl' => $historyUrl
  1779.                 ]);
  1780.             } else {
  1781.                 $htmlBody = null;
  1782.             }
  1784.             $to = $this->paymentInfoValues[$order->getOrderNo()] == $this->vt4gConst['VT4G_PAYMENT_INFO_MAIL']['TO']['CUSTOMER']
  1785.                 ? $order->getEmail()
  1786.                 : null;
  1788.             $this->mdkLogger->debug(trans('vt4g_plugin.payment.recv.show.payment_info') .LF. $body);
  1789.             $this->sendMail($subject, $body, $htmlBody, $baseInfo, $subData, $to);
  1790.             $this->mdkLogger->info(trans('vt4g_plugin.payment.recv.send.payment_info'));
  1791.         }
  1792.     }
  1794.     /**
  1795.      * メールを送信します。
  1796.      * @param string   $subject  件名
  1797.      * @param string   $body     本文(テキスト)
  1798.      * @param string   $htmlBody 本文(HTML)
  1799.      * @param array    $baseInfo 店舗情報
  1800.      * @param array    $subData  プラグイン設定情報
  1801.      * @param string   $to       送信先メールアドレス
  1802.      */
  1803.     private function sendMail($subject, $body, $htmlBody = null, $baseInfo = null, $subData = null, $to = null)
  1804.     {
  1805.         // 基本情報取得
  1806.         if (is_null($baseInfo)) {
  1807.             $baseInfo = $this->em->getRepository(BaseInfo::class)->get();
  1808.         }
  1810.         // メール送信クラス生成
  1811.         $message = (new Email())
  1812.         ->subject($subject)
  1813.         ->from(New Address($baseInfo->getEmail03(), $baseInfo->getShopName()))
  1814.         ->replyTo($baseInfo->getEmail04())
  1815.         ->returnPath($baseInfo->getEmail04())
  1816.         ->text($body);
  1818.         if (!is_null($htmlBody)) {
  1819.             $message->html($htmlBody);
  1820.         }
  1822.         if (is_null($subData)) {
  1823.             $configService = $this->container->get('vt4g_plugin.service.admin.plugin.config');
  1824.             $subData = $configService->getSubData();
  1825.         }
  1826.         $shopMail = !empty($subData['vt4g_email']) ? $subData['vt4g_email'] : $baseInfo->getEmail01();
  1828.         if (!is_null($to)) {
  1829.             $message->to($to)
  1830.             ->bcc($shopMail);
  1831.         } else {
  1832.             $message->to($shopMail);
  1833.         }
  1835.         $this->mailer->send($message);
  1837.     }
  1839.     /**
  1840.      * 注文情報に紐付くカート情報を削除します。
  1841.      * @param Order $order 注文情報
  1842.      */
  1843.     private function clearCartByOrder($order)
  1844.     {
  1845.         $cart = $this->em
  1846.                 ->getRepository(Cart::class)
  1847.                 ->findOneBy(['Customer' => $order->getCustomer(),'pre_order_id' => $order->getPreOrderId()]);
  1849.         if (!empty($cart)) {
  1850.             $this->em->remove($cart);
  1851.             $this->em->flush($cart);
  1852.         }
  1854.     }
  1856.     /**
  1857.      * 決済情報に結果通知項目を登録します。
  1858.      * @param Vt4gOrderPayment $orderPayment 決済情報
  1859.      * @param array            $record       結果通知の項目
  1860.      */
  1861.     private function registPushRecord($orderPayment, $record)
  1862.     {
  1863.         $memo09 = [];
  1864.         $records = $orderPayment->getmemo09();
  1865.         if (!empty($records)) {
  1866.             $memo09 = unserialize($records);
  1867.         }
  1869.         $memo09[] = $record;
  1870.         $orderPayment->setmemo09(serialize($memo09));
  1871.         $this->em->persist($orderPayment);
  1872.         $this->em->flush();
  1873.     }
  1875.     /**
  1876.      * 返金結果通知の設定値を取得します。
  1877.      *
  1878.      * @param  Vt4gOrderPayment $orderPayment 決済情報
  1879.      * @return array                          通知ごとの設定値
  1880.      */
  1881.     private function getRefundRecvSetting($orderPayment)
  1882.     {
  1883.         // 売上か減額要求中で返金、削除通知が来た場合は「返金通知」
  1884.         // それ以外で返金、削除通知が来た場合は「取消通知」とする
  1885.         switch ($orderPayment->getMemo04()) {
  1886.             case $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE']['VALUE']:
  1887.             case $this->vt4gConst['VT4G_PAY_STATUS']['REDUCTION_REQUEST']['VALUE']:
  1888.                 return $this->vt4gConst['VT4G_PAY_STATUS']['REFUND']; // 返金結果
  1889.             default:
  1890.                 return $this->vt4gConst['VT4G_PAY_STATUS']['CANCEL']; // 取消結果
  1891.         }
  1892.     }
  1894.     /**
  1895.      * 決済ログとエラーメール用のメッセージを作成します。
  1896.      * @param  string $msg メッセージ
  1897.      * @return string      エラーメール用メッセージ
  1898.      */
  1899.     private function makeErrorMsg($msg)
  1900.     {
  1901.         $this->setLogInfo('結果通知エラー', $msg);
  1902.         $this->mdkLogger->info(sprintf(trans('vt4g_plugin.payment.recv.reason.error_mail'),$msg));
  1903.         return $msg.PHP_EOL;
  1904.     }
  1906.     /**
  1907.      * 継続課金注文・明細データの保存
  1908.      * @param  Object   $order  注文
  1909.      *
  1910.      * @return boolean
  1911.      */
  1912.     public function saveSubscOrder($order)
  1913.     {
  1914.         // 注文明細
  1915.         $order_items = $order->getOrderItems();
  1916.         // 継続課金の販売種別の場合のみ保存
  1917.         $saleTypeId = $order->getSaleTypes()[0]->getId();
  1918.         $subscSaleType = $this->em->getRepository(Vt4gSubscSaleType::class)->findOneBy(['sale_type_id' => $saleTypeId]);
  1920.         if (is_null($subscSaleType)) {
  1921.             // 継続課金の販売種別でない場合は登録しない
  1922.             return false;
  1923.         }
  1925.         $order_id = $order->getId();
  1926.         $customer_id = $order->getCustomer()->getId();
  1928.         // 継続課金注文データが登録済みならスキップ
  1929.         $subscOrder = $this->em->getRepository(Vt4gSubscOrder::class)->find($order_id);
  1930.         if (!empty($subscOrder)){
  1931.             return false;
  1932.         }
  1934.         // 決済センター戻りと結果通知を同時受信してデッドロックが発生したら、
  1935.         // 一方の通信の処理でデータが登録されるはずなので、次の処理に進む
  1936.         try {
  1937.             // 継続課金注文データの保存
  1938.             $subscOrder = new Vt4gSubscOrder();
  1939.             $subscOrder ->setOrderId($order_id)
  1940.                         ->setCustomerId($customer_id)
  1941.                         ->setSubscSaleTypeId($saleTypeId);
  1942.             $this->em->persist($subscOrder);
  1943.             $this->em->flush();
  1945.             // 継続課金注文明細データの保存
  1946.             $idxSubscOrderItem = [];
  1947.             foreach ($order_items as $oder_item) {
  1948.                 // 商品マスタ情報を保持している注文明細のみ保存する（送料などを除外する）
  1949.                 if ($puroduct = $oder_item->getProduct()) {
  1950.                     $subscOrder = new Vt4gSubscOrderItem();
  1951.                     $puroduct_id = $puroduct->getId();
  1952.                     $prod_class_id = $oder_item->getProductClass()->getId();
  1953.                     $shipping_id = $oder_item->getShipping()->getId();
  1954.                     $idx = sprintf('%s-%s-%s-%s', $order_id, $puroduct_id, $prod_class_id, $shipping_id);
  1955.                     if (in_array($idx, $idxSubscOrderItem)) continue; // 重複した商品は登録しない
  1956.                     $idxSubscOrderItem[] = $idx;
  1957.                     $subscOrder ->setOrderId($order_id)
  1958.                                 ->setProductId($puroduct_id)
  1959.                                 ->setProductClassId($prod_class_id)
  1960.                                 ->setShippingId($shipping_id)
  1961.                                 ->setSubscStatus($this->vt4gConst['VTG4_SUBSC_STATUS_SUBSC']); // 継続
  1962.                     $this->em->persist($subscOrder);
  1963.                 }
  1964.             }
  1965.             $this->em->flush();
  1966.             $this->mdkLogger->info(sprintf(trans('vt4g_plugin.shopping.credit.saved.subsc.order'),$order_id));
  1968.         } catch (\Doctrine\DBAL\Exception $e) {
  1970.             $msg = $e->getMessage();
  1971.             if(strpos($msg,'deadlock') !== false || strpos($msg,'Deadlock') !== false) {
  1972.                 $this->mdkLogger->info(sprintf(trans('vt4g_plugin.db.deadlock'),'結果通知の継続課金注文保存処理'));
  1973.             } else {
  1974.                 $this->mdkLogger->error($e->getMessage());
  1975.                 throw $e;
  1976.             }
  1978.         }
  1980.     }
  1981. }