Symfony Profiler

<?php
/*
* Copyright (c) 2018 VeriTrans Inc., a Digital Garage company. All rights reserved.
* http://www.veritrans.co.jp/
*/
namespace Plugin\VeriTrans4G2\Service\Payment;
use Eccube\Entity\Customer;
use Eccube\Entity\Order;
use Plugin\VeriTrans4G2\Entity\Vt4gOrderPayment;
use Plugin\VeriTrans4G2\Entity\Vt4gSubscOrder;
use Plugin\VeriTrans4G2\Entity\Vt4gSubscOrderItem;
use Plugin\VeriTrans4G2\Entity\Master\Vt4gSubscSaleType;
use Plugin\VeriTrans4G2\Entity\Master\Vt4gSubscProductOrderCmpMailInfo;
use Plugin\VeriTrans4G2\Form\Type\Shopping\PaymentCreditType;
use Plugin\VeriTrans4G2\Form\Type\Shopping\PaymentCreditAccountType;
use Plugin\VeriTrans4G2\Form\Type\Shopping\PaymentCreditOneClickType;
use tgMdk\TGMDK_Transaction;
use tgMdk\dto\MpiGetResultRequestDto;
use tgMdk\dto\CardCaptureRequestDto;
use tgMdk\dto\CardAuthorizeRequestDto;
use tgMdk\dto\CardReAuthorizeRequestDto;
use tgMdk\dto\MpiAuthorizeRequestDto;
use tgMdk\dto\MpiReAuthorizeRequestDto;
use tgMdk\dto\CardRetryRequestDto;
// クレジットカード決済関連処理
class CreditService extends BaseService
{
/**
* クレジットカード情報入力フォームを生成
* @param array $paymentInfo クレジットカード決済設定
* @return object クレジットカード情報入力フォーム
*/
public function createCreditForm($paymentInfo)
{
return $this->container->get('form.factory')
->create(PaymentCreditType::class, compact('paymentInfo'));
}
/**
* ベリトランス会員ID決済用の入力フォームを生成
*
* @param array $paymentInfo クレジットカード決済設定
* @return object ベリトランス会員ID決済用入力フォーム
*/
public function createAccountForm($paymentInfo)
{
return $this->container->get('form.factory')
->create(PaymentCreditAccountType::class, compact('paymentInfo'));
}
/**
* 再取引用の入力フォームを生成
*
* @param array $paymentInfo クレジットカード決済設定
* @return object 再取引用入力フォーム
*/
public function createOneClickForm($paymentInfo)
{
return $this->container->get('form.factory')
->create(PaymentCreditOneClickType::class, compact('paymentInfo'));
}
/**
* クレジットカード決済処理
* (MDKトークン利用・再取引)
*
* @param array $inputs フォーム入力データ
* @param array $payload 追加参照データ
* @param array &$error エラー
* @return boolean 決済が正常終了したか
*/
public function commitNormalPayment($inputs, $payload, &$error)
{
// 本人認証フラグ
$isMpi = $payload['paymentInfo']['mpi_flg'];
// ベリトランス会員ID決済の有効設定フラグ
$useAccountPayment = $payload['paymentInfo']['one_click_flg'] === $this->vt4gConst['VT4G_CREDIT_ONE_CLICK']['VERITRANS_ID'];
// かんたん決済の有効設定フラグ
$useReTradePayment = $payload['paymentInfo']['one_click_flg'] === $this->vt4gConst['VT4G_CREDIT_ONE_CLICK']['RETRADE'];
// ベリトランス会員ID決済フラグ
$isAccountPayment = $payload['mode'] === 'account';
// 再取引フラグ
$isReTrade = $payload['mode'] === 'retrade';
// 本人認証後フラグ
$isAfterAuth = false;
// カード名義人名
switch ($payload['mode']) {
case 'token':
$cardName = !empty($inputs['payment_credit']['card_name']) ? $inputs['payment_credit']['card_name'] : null;
break;
case 'retrade':
$cardName = !empty($inputs['payment_credit_one_click']['card_name']) ? $inputs['payment_credit_one_click']['card_name'] : null;
break;
case 'account':
$cardName = !empty($inputs['payment_credit_account']['card_name']) ? $inputs['payment_credit_account']['card_name'] : null;
break;
default:
$cardName = null;
break;
}
// 2023/1から3Dセキュアのバージョン切り替えを廃止。本人認証ありの場合は3Dセキュア2.0を利用。
$deviceChannel = $this->vt4gConst['VT4G_CREDIT_DEVICE_CHANNEL'];
// 決済金額 (整数値で設定するため小数点以下切り捨て)
$amount = floor($payload['order']->getPaymentTotal());
// 継続課金商品の判別
$subscSaleType = $this->util->checkSubscriptionOrder($payload['order']); // 継続課金商品の判断 $subscSaleTypeがnullでなかったら継続課金商品
// 少額与信を使用の判別
$useFewCredit = $this->util->checkFewCreditSaleType($subscSaleType); // 少額与信対象を判別
if ($subscSaleType) {
if ($useFewCredit) {
// 継続課金商品かつ小額与信の場合は「与信のみ」設定に強制
$payload['paymentInfo']['withCapture'] = 0;
}
}
if ($useFewCredit) {
// 少額与信を使用する場合は設定値で上書き
$amount = $this->vt4gConst['VT4G_FEW_CREDIT_AMOUNT'];
}
// カード情報登録フラグ
$doRegistCardinfo = $isAccountPayment || (isset($inputs['payment_credit']['cardinfo_regist']) && $inputs['payment_credit']['cardinfo_regist'] === '1');
// カード情報登録フラグ(再取引)
$doRegistReTradeCardinfo = $isReTrade || (isset($inputs['payment_credit']['cardinfo_retrade']) && $inputs['payment_credit']['cardinfo_retrade'] === '1');
// 再取引決済の場合に元取引IDのバリデーションを行う
if ($isReTrade && !$this->isValidReTradeOrder($inputs['payment_order_id'], $payload['user']->getid())) {
$error['payment'] = trans('vt4g_plugin.shopping.credit.mErrMsg.retrade').'<br/>';
return false;
}
// MDKリクエスト生成・レスポンスのハンドリングに使用するデータ
$sources = array_merge(
compact('isMpi'),
compact('useAccountPayment'),
compact('useReTradePayment'),
compact('isReTrade'),
compact('isAfterAuth'),
compact('amount'),
compact('inputs'),
compact('doRegistCardinfo'),
compact('doRegistReTradeCardinfo'),
compact('cardName'),
compact('deviceChannel'),
$payload
);
// MDKリクエストを生成
$mdkRequest = $this->makeMdkRequest($sources);
$orderId = $mdkRequest->getOrderId();
$sources['orderid'] = $orderId;
$cardType = $inputs['payment_credit']['payment_type'] ?? '';
if ($isAccountPayment) {
$cardType = $inputs['payment_credit_account']['payment_type'] ?? '';
}
if ($isReTrade) {
$cardType = $inputs['payment_credit_one_click']['payment_type'] ?? '';
}
// 決済データを登録
$payment = [
'orderId' => $orderId,
'payStatus' => '',
'cardType' => $cardType,
'cardAmount' => $amount,
'withCapture' => $payload['paymentInfo']['withCapture'],
'useFewCredit' => $useFewCredit, // 少額与信の使用有無
'doRegistReTradeCardinfo' => $doRegistReTradeCardinfo,
'orderCompleteFlg' => false,
'sentOrderMail' => false,
];
//本人認証ありの場合のみ、cardNameを登録する。
if($isMpi){
$payment['cardName'] = $cardName;
}
$this->setOrderPayment($payload['order'], $payload['orderPayment'], $payment, [], [], $inputs['token_id'] ?? '');
$this->em->commit();
$this->mdkLogger->info(
sprintf(
$isMpi ? trans('vt4g_plugin.payment.shopping.mdk.start.mpi') : trans('vt4g_plugin.payment.shopping.mdk.start'),
$this->vt4gConst['VT4G_PAYNAME_PAYTYPEID_10']
)
);
$mdkTransaction = new TGMDK_Transaction();
$mdkResponse = $mdkTransaction->execute($mdkRequest);
return $this->handleMdkResponse($mdkResponse, $sources, $error);
}
/**
* クレジットカード決済処理
* (本人認証リダイレクト)
*
* @param object $request リクエストデータ
* @param array $payload 追加参照データ
* @param array &$error エラー
* @return boolean 決済が正常終了したか
*/
public function commitMpiPayment($request, $payload, &$error)
{
// ベリトランス会員ID決済フラグ
$useAccountPayment = $payload['paymentInfo']['one_click_flg'] === $this->vt4gConst['VT4G_CREDIT_ONE_CLICK']['VERITRANS_ID'];
// オーダーID
$orderId = htmlspecialchars($request->get('OrderId'));
if (empty($orderId)) {
$this->mdkLogger->fatal(trans('vt4g_plugin.shopping.credit.fatal.request.id'));
$error['payment'] = $this->getErrorMessage();
return false;
}
$mdkRequest = new MpiGetResultRequestDto();
// リクエスト実行
$mdkRequest->setOrderId($orderId);
$this->mdkLogger->info(trans('vt4g_plugin.payment.shopping.mpi.payment.start'));
$mdkTransaction = new TGMDK_Transaction();
$mdkResponse = $mdkTransaction->execute($mdkRequest);
$sources = [
'isMpi' => true,
'useAccountPayment' => $useAccountPayment,
'isAfterAuth' => true,
'order' => $payload['order'],
'paymentInfo' => $payload['paymentInfo'],
'user' => $payload['user'],
'orderPayment' => $payload['orderPayment'],
];
return $this->handleMdkResponse($mdkResponse, $sources, $error);
}
/**
* 売上処理
*
* @param array $payload 売上処理に使用するデータ
* @return array 売上処理結果データ
*/
public function operateCapture($payload)
{
// 注文ステータス
$orderStatus = $payload['order']->getOrderStatus()['id'];
// 決済ステータス
$paymentStatus = $payload['orderPayment']->getMemo04();
// 決済申込時のレスポンス
$prevPaymentResult = unserialize($payload['orderPayment']->getMemo05());
// レスポンス初期化
$authOperationResult = $this->initPaymentResult();
// 決済ステータスが売上の場合
if ($paymentStatus == $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE']['VALUE']) {
// 現在の取引ID
$originPaymentOrderId = $payload['orderPayment']->getMemo01();
// 決済ログ情報を初期化
$this->logData = [];
// 再決済
$authOperationResult = $this->operateAuth($payload, $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE']['VALUE']);
if (!$authOperationResult['isOK']) {
$authOperationResult['message'] = $authOperationResult['vResultCode'].':'.$authOperationResult['mErrMsg'];
$this->mdkLogger->info(print_r($authOperationResult, true));
return $authOperationResult;
}
// 更新処理
$this->updateByAdmin($payload['orderPayment'], $authOperationResult, $orderStatus);
$this->em->flush();
$this->logData = [];
// 再決済後の取引ID
$newPaymentOrderId = $authOperationResult['orderId'];
// 再決済前の取引を取消
$payload['orderPayment']->setMemo01($originPaymentOrderId);
$cancelOperationResult = $this->operateCancel($payload);
// 再決済後の取引IDを再設定
$payload['orderPayment']->setMemo01($newPaymentOrderId);
// memo10更新
$memo10 = unserialize($payload['orderPayment']->getMemo10());
$memo10['card_amount'] = floor($payload['order']->getPaymentTotal());
$payload['orderPayment']->setMemo10(serialize($memo10));
// キャンセル処理が異常終了の場合
if (!$cancelOperationResult['isOK']) {
$this->mdkLogger->info(print_r($cancelOperationResult, true));
return $cancelOperationResult;
}
$this->mdkLogger->info(print_r($authOperationResult, true));
return $authOperationResult;
}
$payId = $payload['orderPayment']->getMemo03();
$payName = $this->util->getPayName($payId);
$this->mdkLogger->info(
sprintf(
trans('vt4g_plugin.admin.order.credit.capture.start'),
$payName
)
);
// レスポンス初期化
$operationResult = $this->initPaymentResult();
// 取引ID
$paymentOrderId = $payload['orderPayment']->getMemo01();
// memo01から取得できない場合
if (empty($paymentOrderId)) {
// 決済申込時のレスポンスから取得できない場合
if (empty($prevPaymentResult['orderId'])) {
$this->mdkLogger->fatal(trans('vt4g_plugin.shopping.credit.fatal.order.id'));
$operationResult['message'] = trans('vt4g_plugin.payment.shopping.error');
return $operationResult;
}
// 決済申込時の結果から取得
$paymentOrderId = $prevPaymentResult['orderId'];
}
$mdkRequest = new CardCaptureRequestDto();
// 取引ID
$mdkRequest->setOrderId($paymentOrderId);
// 決済金額
$mdkRequest->setAmount(floor($payload['order']->getPaymentTotal()));
$mdkTransaction = new TGMDK_Transaction();
$mdkResponse = $mdkTransaction->execute($mdkRequest);
// レスポンス検証
if (!isset($mdkResponse)) {
$this->mdkLogger->fatal(trans('vt4g_plugin.payment.shopping.mdk.error'));
$operationResult['message'] = trans('vt4g_plugin.payment.shopping.error');
$this->mdkLogger->info(print_r($operationResult, true));
return $operationResult;
}
// 結果コード
$operationResult['mStatus'] = $mdkResponse->getMStatus();
// 詳細コード
$operationResult['vResultCode'] = $mdkResponse->getVResultCode();
// エラーメッセージ
$operationResult['mErrMsg'] = $mdkResponse->getMErrMsg();
// 異常終了レスポンスの場合
if ($operationResult['mStatus'] === $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['NG']) {
$operationResult['message'] = $operationResult['vResultCode'].':';
$operationResult['message'] .= $operationResult['mErrMsg'];
$this->mdkLogger->info(print_r($operationResult, true));
return $operationResult;
}
$operationResult['isOK'] = true;
// 取引ID
$operationResult['orderId'] = $mdkResponse->getOrderId();
// 決済サービスタイプ
$operationResult['payStatus'] = $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE']['VALUE'];
// 売上金額
$amount = floor($payload['order']->getPaymentTotal());
$operationResult['card_amount'] = $amount;
// 決済変更ログ情報を設定
$this->logData = [];
$this->setLog($payload['order'], $operationResult);
// 変更後の金額をログ出力
$amount = number_format($amount);
$this->setLogInfo('売上確定金額', $amount);
$this->mdkLogger->info(trans('vt4g_plugin.shopping.credit.order.id'). $operationResult['orderId']);
$this->mdkLogger->info(trans('vt4g_plugin.shopping.credit.capture.amount'). $amount);
// ログの出力
$this->mdkLogger->info(print_r($operationResult, true));
return $operationResult;
}
/**
* 決済処理の実行
*
* @param array $payload 決済に使用するデータ
* @return array 決済結果データ
*/
public function operateNewly($payload)
{
$payId = $payload['orderPayment']->getMemo03();
$payName = $this->util->getPayName($payId);
$accountCardId = $payload['inputs']->get('accountCardId');
$reTradeOrderId = $payload['inputs']->get('reTradeOrderId');
$jpo = $payload['inputs']->get('jpo');
$withCapture = $payload['inputs']->get('withCapture');
$this->mdkLogger->info(
sprintf(
trans('vt4g_plugin.admin.order.credit.newly.start'),
$payName
)
);
// レスポンス初期化
$operationResult = $this->initPaymentResult();
if ((empty($accountCardId) && empty($reTradeOrderId)) || (!empty($accountCardId) && !empty($reTradeOrderId))
|| empty($jpo) || !($withCapture === '0' || $withCapture === '1')) {
$this->mdkLogger->fatal(
sprintf(
trans('vt4g_plugin.admin.order.credit.param.error'),
$accountCardId,
$reTradeOrderId,
$jpo,
$withCapture
)
);
$operationResult['message'] = trans('vt4g_plugin.admin.order.update_payment_status.error');
return $operationResult;
}
$mdkRequest = ($accountCardId) ? new CardAuthorizeRequestDto() : new CardReAuthorizeRequestDto();
$mdkRequest->setOrderId($this->getMdkOrderId($payload['order']->getid()));
$mdkRequest->setAmount(floor($payload['order']->getPaymentTotal()));
$mdkRequest->setJpo($jpo);
$mdkRequest->setWithCapture($withCapture ? 'true' : 'false');
if ($accountCardId) {
$mdkRequest->setCardId($accountCardId);
$mdkRequest->setAccountId($payload['order']->getCustomer()->vt4g_account_id);
} else {
$mdkRequest->setOriginalOrderId($reTradeOrderId);
}
$mdkTransaction = new TGMDK_Transaction();
$mdkResponse = $mdkTransaction->execute($mdkRequest);
// レスポンス検証
if (!isset($mdkResponse)) {
$this->mdkLogger->fatal(trans('vt4g_plugin.payment.shopping.mdk.error'));
$operationResult['message'] = trans('vt4g_plugin.payment.shopping.error');
return $operationResult;
}
// 結果コード
$operationResult['mStatus'] = $mdkResponse->getMStatus();
// 詳細コード
$operationResult['vResultCode'] = $mdkResponse->getVResultCode();
// エラーメッセージ
$operationResult['mErrMsg'] = $mdkResponse->getMErrMsg();
// 異常終了レスポンスの場合
if ($operationResult['mStatus'] !== $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
$operationResult['message'] = $operationResult['vResultCode'].':';
$operationResult['message'] .= $operationResult['mErrMsg'];
return $operationResult;
}
// 通常クレジットカード決済の正常終了
$operationResult['isOK'] = true;
// 取引ID取得
$operationResult['orderId'] = $mdkResponse->getOrderId();
// マスクされたクレジットカード番号
$operationResult['cardNumber'] = null;
// 入力したカード名義
$operationResult['lastName'] = null;
$operationResult['firstName'] = null;
$operationResult['paymentType'] = substr($jpo, 0, 2);
$operationResult['paymentCount'] = substr($jpo, 2);
// memo10
$operationResult['card_amount'] = floor($payload['order']->getPaymentTotal());
$operationResult['card_type'] = $jpo;
// memo02
$operationResult['customerId'] = $payload['order']->getCustomer()->getId();
// 決済状態を保持
$operationResult['payStatus'] = $withCapture
? $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE']['VALUE']
: $this->vt4gConst['VT4G_PAY_STATUS']['AUTH']['VALUE'];
$operationResult['mpiHosting'] = false;
$operationResult['withCapture'] = $withCapture;
// 決済変更ログ情報を設定
$this->logData = [];
$this->setLog($payload['order'], $operationResult);
// 変更後の金額をログ出力
$amount = number_format(floor($payload['order']->getPaymentTotal()));
$this->setLogInfo('売上確定金額', $amount);
// ログの出力
$this->mdkLogger->info(print_r($operationResult, true));
return $operationResult;
}
/**
* キャンセル処理
*
* @param array $payload キャンセル処理に使用するデータ
* @return array キャンセル処理結果データ
*/
public function operateCancel($payload)
{
// キャンセル共通処理
list($operationResult, $mdkResponse) = parent::operateCancel($payload);
// 取消処理の場合、継続課金ステータスを解約にする（再売上時の前決済取消時は決済ステータスは売上のままなのでスキップ）
// 取消操作の場合
if ($this->vt4gConst['VT4G_OPERATION_CANCEL'] === $payload['mode']) {
// 継続課金ステータスを解約に更新
$subscOrderItems = $this->em->getRepository(Vt4gSubscOrderItem::class)->findBy(['order_id' => $payload['order']->getId()]);
if (count($subscOrderItems) > 0) {
// 継続課金の注文の場合(ここではflushしない)
foreach ($subscOrderItems as $item) {
$item->setSubscStatus($this->vt4gConst['VTG4_SUBSC_STATUS_CANCEL']);
}
}
}
// ログの出力
$this->mdkLogger->info(print_r($operationResult, true));
if ($operationResult['isOK']) {
$amount = number_format($mdkResponse->getReqAmount());
$this->setLogInfo('取消金額', $amount);
$this->mdkLogger->info(trans('vt4g_plugin.shopping.credit.order.id'). $operationResult['orderId']);
$this->mdkLogger->info(trans('vt4g_plugin.shopping.credit.cancel.amount'). $amount);
}
return $operationResult;
}
/**
* 再決済処理
*
* @param array $payload 再決済処理に使用するデータ
* @param integer $paymentStatus 決済ステータス
* @return array 再決済処理結果データ
*/
public function operateAuth($payload, $paymentStatus)
{
$paymentId = $payload['order']->getPayment()->getId();
$payId = $payload['orderPayment']->getMemo03();
$payName = $this->util->getPayName($payId);
$paymentInfo = $this->util->getPaymentMethodInfo($paymentId);
// 決済申込時のレスポンス
$prevPaymentResult = unserialize($payload['orderPayment']->getMemo05());
// レスポンス初期化
$operationResult = $this->initPaymentResult();
$this->mdkLogger->info(
sprintf(
trans('vt4g_plugin.admin.order.credit.again.start'),
$payName
)
);
// 再決済対象の取引ID
$paymentOrderId = $payload['orderPayment']->getMemo01();
// memo01から取得できない場合
if (empty($paymentOrderId)) {
// 決済申込時のレスポンスから取得できない場合
if (empty($prevPaymentResult['orderId'])) {
$this->mdkLogger->fatal(trans('vt4g_plugin.shopping.credit.fatal.order.id'));
$operationResult['message'] = trans('vt4g_plugin.payment.shopping.error');
return $operationResult;
}
// 決済申込時の結果から取得
$paymentOrderId = $prevPaymentResult['orderId'];
}
// 支払回数
$memo10 = unserialize($payload['orderPayment']->getMemo10());
$cardType = $memo10['card_type'];
$mdkRequest = new CardReAuthorizeRequestDto();
// 取引ID
$mdkRequest->setOrderId($this->getMdkOrderId($payload['order']->getid()));
// 再決済対象の取引ID
$mdkRequest->setOriginalOrderId($paymentOrderId);
// 決済金額
$mdkRequest->setAmount(floor($payload['order']->getPaymentTotal()));
// 支払回数
$mdkRequest->setJpo($cardType);
// 売上フラグ
if ($paymentStatus == $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE']['VALUE']) {
$mdkRequest->setWithCapture('true');
} else {
$mdkRequest->setWithCapture($paymentInfo['withCapture'] ? 'true' : 'false');
}
$mdkTransaction = new TGMDK_Transaction();
$mdkResponse = $mdkTransaction->execute($mdkRequest);
$operationResult['payStatus'] = $paymentStatus;
// レスポンス検証
if (!isset($mdkResponse)) {
$this->mdkLogger->fatal(trans('vt4g_plugin.payment.shopping.mdk.error'));
$operationResult['message'] = trans('vt4g_plugin.payment.shopping.error');
return $operationResult;
}
// 結果コード
$operationResult['mStatus'] = $mdkResponse->getMStatus();
// 詳細コード
$operationResult['vResultCode'] = $mdkResponse->getVResultCode();
// エラーメッセージ
$operationResult['mErrMsg'] = $mdkResponse->getMErrMsg();
// 異常終了レスポンスの場合
if ($operationResult['mStatus'] === $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['NG']) {
$operationResult['message'] = $operationResult['vResultCode'].':';
$operationResult['message'] .= $operationResult['mErrMsg'];
$this->mdkLogger->info(print_r($operationResult, true));
return $operationResult;
}
$operationResult['isOK'] = true;
// 取引ID
$operationResult['orderId'] = $mdkResponse->getOrderId();
// 決済サービスタイプ
$operationResult['serviceType'] = $mdkResponse->getServiceType();
// 決済ステータス
$operationResult['payStatus'] = $paymentStatus;
// 決済金額
$amount = floor($payload['order']->getPaymentTotal());
$operationResult['card_amount'] = $amount;
// 取引IDを更新
$orderPayment = $this->em->getRepository(vt4gOrderPayment::class)->find($payload['order']->getId());
$orderPayment->setMemo01($operationResult['orderId']);
$this->em->flush();
// 決済変更ログ情報を設定
$this->setLog($payload['order'], $operationResult);
// 変更後の金額をログ出力
$amount = number_format($amount);
$this->setLogInfo('再取引金額', $amount);
$this->mdkLogger->info(trans('vt4g_plugin.shopping.credit.order.id'). $operationResult['orderId']);
$this->mdkLogger->info(trans('vt4g_plugin.shopping.credit.again.amount'). $amount);
$this->mdkLogger->info(print_r($operationResult, true));
return $operationResult;
}
/**
* MDKリクエストを生成
*
* @param array &$sources リクエスト生成に必要なデータ
* @return object MDKリクエストオブジェクト
*/
private function makeMdkRequest(&$sources)
{
if ($sources['isMpi']) {
$request = $sources['isReTrade']
? new MpiReAuthorizeRequestDto() // 本人認証あり (再取引)
: new MpiAuthorizeRequestDto(); // 本人認証あり
} else {
$request = $sources['isReTrade']
? new CardReAuthorizeRequestDto() // 本人認証なし (再取引)
: new CardAuthorizeRequestDto(); // 本人認証なし
}
// 受注番号
$request->setOrderId($this->getMdkOrderId($sources['order']->getId()));
$request->setAmount($sources['amount']);
// 再取引の場合
if ($sources['isReTrade']) {
// 元取引ID
$request->setOriginalOrderId($sources['inputs']['payment_order_id']);
// 支払い方法
$request->setJpo($sources['inputs']['payment_credit_one_click']['payment_type']);
} else {
// ベリトランス会員ID決済利用の場合
if ($sources['useAccountPayment'] && !empty($sources['user']) && $sources['doRegistCardinfo']) {
$accountId = $this->getAccountId($sources['user'], $sources['order']->getPayment()->getId());
// ベリトランス会員ID情報をログ出力
$this->mdkLogger->info((empty($sources['user']->vt4g_account_id)
? trans('vt4g_plugin.shopping.credit.account.payment.new')
: trans('vt4g_plugin.shopping.credit.account.payment')
)
.$accountId);
// ベリトランス会員ID
$request->setAccountId($accountId);
// 仮登録フラグによりMPIのレスポンスは会員情報が空になるので、MPIのときはここの値を使用する
$sources['accountId'] = $accountId;
}
// 登録済みのカードを使用する場合
if ($sources['mode'] === 'account') {
$cardId = $sources['inputs']['card_id'];
$this->mdkLogger->info(trans('vt4g_plugin.shopping.credit.account.card').$cardId);
// カードID
$request->setCardId($cardId);
// 支払い方法
$request->setJpo($sources['inputs']['payment_credit_account']['payment_type']);
} else {
// トークン情報をログ出力
$this->mdkLogger->info(
sprintf(
trans('vt4g_plugin.shopping.credit.token'),
$sources['inputs']['token_id'],
$sources['inputs']['token_expire_date']
)
);
// MDKトークン
$request->setToken($sources['inputs']['token_id']);
// 支払い方法
$request->setJpo($sources['inputs']['payment_credit']['payment_type']);
}
}
// 決済種別
$request->setWithCapture($sources['paymentInfo']['withCapture'] ? 'true' : 'false');
// 本人認証の場合
if ($sources['isMpi']) {
$request->setServiceOptionType($sources['paymentInfo']['mpi_option']);
// URL設定
$redirectionUri = $this->util->generateUrl(
'vt4g_shopping_payment',
['mode' => 'comp']
);
$request->setRedirectionUri($redirectionUri);
$pluginSetting = $this->util->getPluginSetting();
if(!empty($pluginSetting["push_url_auto_setting"])){
$request->setPushUrl($this->util->generateUrl('vt4g_plugin_shopping_payment_recv'));
}
$request->setHttpUserAgent($_SERVER['HTTP_USER_AGENT']);
$request->setHttpAccept($_SERVER['HTTP_ACCEPT']);
$request->setVerifyTimeout($this->vt4gConst['VT4G_CREDIT_VERIFY_TIMEOUT']);
$request->setCardholderName($sources['cardName']);
$request->setDeviceChannel($sources['deviceChannel']);
$request->setVerifyResultLink($this->vt4gConst['VT4G_CREDIT_VERIFY_RESULT_LINK']);
// 仮登録フラグの設定
if ($sources['useAccountPayment'] && !empty($sources['user']) && $sources['mode'] != 'account') {
$request->setTempRegistration($this->vt4gConst['VT4G_CREDIT_PAYNOWID_TEMP_REG']);
}
}
return $request;
}
/**
* MDKリクエストのレスポンスのハンドリング
* (各パターン共通処理)
*
* @param object $response MDKリクエストのレスポンス
* @param array $sources ハンドリングに必要なデータ
* @param array &$error エラー表示用配列
* @return boolean レスポンスを正常に処理したかどうか
*/
private function handleMdkResponse($response, $sources, &$error)
{
// レスポンス初期化
$this->initPaymentResult();
// レスポンス検証
if (!isset($response)) {
// システムエラー
$this->mdkLogger->fatal(trans('vt4g_plugin.payment.shopping.mdk.error'));
$error['payment'] = $this->getErrorMessage();
return false;
}
// 結果コード
$this->paymentResult['mStatus'] = $response->getMStatus();
// 詳細コード
$this->paymentResult['vResultCode'] = $response->getVResultCode();
// エラーメッセージ
$this->paymentResult['mErrMsg'] = $response->getMerrMsg();
// 異常終了レスポンスの場合
if ($this->paymentResult['mStatus'] === $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['NG']) {
$this->mdkLogger->fatal(trans('vt4g_plugin.shopping.credit.fatal.payment'));
$this->mdkLogger->fatal(print_r($this->paymentResult, true));
$error['payment'] = $this->getErrorMessage();
return false;
}
// 本人認証なしかつ保留レスポンスの場合
if (!$sources['isMpi'] && $this->paymentResult['mStatus'] === $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['PENDING']) {
// リトライを実行
$retryResult = $this->retryMdkRequest($sources['orderId'], $error);
if (!$retryResult) {
$error['payment'] = $this->getErrorMessage();
return false;
}
// リトライのレスポンスを使用
$response = $retryResult;
}
// 本人認証ありの場合
if ($sources['isMpi']) {
return $sources['isAfterAuth']
? $this->handleMpiAfterAuthResponse($response, $sources, $error)
: $this->handleMpiBeforeAuthResponse($response, $sources);
}
// 本人認証なしの場合
return $this->handleNormalResponse($response, $sources, $error);
}
/**
* MDKリクエストのレスポンスのハンドリング
* (本人認証なしパターン)
*
* @param object $response MDKリクエストのレスポンス
* @param array $sources ハンドリングに必要なデータ
* @param array &$error エラー表示用配列
* @return boolean レスポンスを正常に処理したかどうか
*/
private function handleNormalResponse($response, $sources, &$error)
{
// 通常クレジットカード決済の正常終了
$this->paymentResult['isOK'] = true;
// 取引ID取得
$this->paymentResult['orderId'] = $response->getOrderId();
// マスクされたクレジットカード番号
$this->paymentResult['cardNumber'] = $response->getReqCardNumber();
// 支払い方法・支払い回数
$jpo = $response->getReqJpoInformation();
$this->paymentResult['paymentType'] = substr($jpo, 0, 2);
$this->paymentResult['paymentCount'] = substr($jpo, 2);
// 決済状態を保持
$this->paymentResult['payStatus'] = $sources['paymentInfo']['withCapture']
? $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE']['VALUE']
: $this->vt4gConst['VT4G_PAY_STATUS']['AUTH']['VALUE'];
$this->paymentResult['mpiHosting'] = false;
$this->paymentResult['withCapture'] = $sources['paymentInfo']['withCapture'];
$this->mdkLogger->info(print_r($this->paymentResult, true));
// 正常終了の場合
if ($this->paymentResult['isOK']) {
// 継続課金注文・明細データの保存
$this->saveSubscOrder($sources);
// ベリトランス会員ID決済の場合
if ($sources['useAccountPayment'] && !empty($sources['user']) && $sources['doRegistCardinfo']) {
// ベリトランス会員IDをテーブルに保存
$accountId = $response->getPayNowIdResponse()->getAccount()->getAccountId();
$this->saveAccountId($sources['user']->getId(), $accountId);
}
if (!$sources['doRegistReTradeCardinfo']) {
// ベリトランスID決済, 利用無し, かんたん決済にて「利用しない」選択時にカード番号を未登録とする
$this->paymentResult['cardNumber'] = null;
}
$isCompleted = $this->completeCreditOrder($sources['order'], $sources['orderPayment']);
// 受注完了処理
if (!$isCompleted) {
$this->mdkLogger->fatal(trans('vt4g_plugin.shopping.credit.fatal.complete'));
$error['payment'] = $this->defaultErrorMessage;
return false;
}
}
return true;
}
/**
* MDKリクエストのレスポンスのハンドリング
* (本人認証あり・認証ページへのリダイレクト前処理)
*
* @param object $response MDKリクエストのレスポンス
* @param array $sources ハンドリングに必要なデータ
* @return void
*/
private function handleMpiBeforeAuthResponse($response, $sources)
{
// ベリトランス会員ID決済の場合
if ($sources['useAccountPayment'] && !empty($sources['user']) && !empty($sources['accountId'])) {
// ベリトランス会員IDをセッションに保存
$accountId = $sources['accountId'];
$this->container->get('session')->set(
$this->vt4gConst['VT4G_CREDIT_VERITRANS_ID_SESSION_KEY'],
$accountId
);
}
$limitDate = new \DateTime();
$limitDate = $limitDate->modify(sprintf('+%s minutes', $this->vt4gConst['VT4G_CREDIT_VERIFY_TIMEOUT']));
$rollbackDate = $this->util->getRollbackDate($limitDate->format('Y-m-d H:i:s'), $this->vt4gConst['VT4G_PAYTYPEID_CREDIT']);
$orderPayment = $sources['orderPayment'];
$orderPayment->setRollbackDate($rollbackDate);
//カード情報の登録
if($sources['doRegistReTradeCardinfo']){
$orderPayment->setMemo07($response->getReqCardNumber());
}
$this->paymentResult['isOK'] = true;
$this->paymentResult['orderId'] = $response->getOrderId();
$this->paymentResult['cardNumber'] = $response->getReqCardNumber();
$jpo = $response->getReqJpoInformation();
$this->paymentResult['paymentType'] = substr($jpo, 0, 2);
$this->paymentResult['paymentCount'] = substr($jpo, 2);
$this->paymentResult['mpiHosting'] = 1;
$this->paymentResult['isMpi'] = true;
$this->paymentResult['withCapture'] = $sources['paymentInfo']['withCapture'];
$this->paymentResult['resResponseContents'] = $response->getResResponseContents();
$this->paymentResult['rollbackDate'] = $rollbackDate;
$this->mdkLogger->info(print_r($this->paymentResult, true));
// データ登録時にrollbackDateのタイムゾーンが変更されるので、ログ出力後にデータ登録を実行
// @see https://doc4.ec-cube.net/i18n_timezone
$this->em->persist($orderPayment);
$this->em->flush();
$this->em->commit();
// 認証ページ用レスポンスを表示して処理を終了
echo $this->paymentResult['resResponseContents'];
exit;
}
/**
* MDKリクエストのレスポンスのハンドリング
* (本人認証あり・認証ページからのリダイレクト後処理)
*
* @param object $response MDKリクエストのレスポンス
* @param array $sources ハンドリングに必要なデータ
* @param array &$error エラー表示用配列
* @return boolean レスポンスを正常に処理したかどうか
*/
private function handleMpiAfterAuthResponse($response, $sources, &$error)
{
// 対象が見つからなかった場合
if (is_null($response)) {
$this->initPaymentResult();
$this->paymentResult['mErrMsg'] = trans('vt4g_plugin.shopping.credit.mErrMsg.transaction');
$this->mdkLogger->fatal(trans('vt4g_plugin.shopping.credit.fatal.mpi.payment'));
$error['payment'] = $this->getErrorMessage();
return false;
}
// 結果コード
$this->paymentResult['mStatus'] = $response->getMStatus();
// 詳細コード決済の詳細結果コードに応じたエラーメッセージを出力のために一時的に変える
$this->paymentResult['vResultCode'] = $response->getMpiVResultCode();
// カード結果コード
$this->paymentResult['cardMstatus'] = $response->getCardMstatus();
// MPI 結果コード
$this->paymentResult['mpiMstatus'] = $response->getMpiMstatus();
// MPI 詳細コード
$this->paymentResult['mpiVresultCode'] = $response->getMpiVResultCode();
// 本人認証の結果検証
if ($this->paymentResult['mpiMstatus'] !== $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
$this->paymentResult['mErrMsg'] = trans('vt4g_plugin.shopping.credit.mErrMsg.mpi.payment');
$this->mdkLogger->fatal(trans('vt4g_plugin.shopping.credit.fatal.mpi.payment'));
$error['payment'] = $this->getErrorMessage();
return false;
}
// カード決済の結果検証
if ($this->paymentResult['cardMstatus'] !== $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
$this->paymentResult['mErrMsg'] = trans('vt4g_plugin.shopping.credit.mErrMsg.credit.payment');
$this->mdkLogger->fatal(trans('vt4g_plugin.shopping.credit.fatal.credit.payment'));
$error['payment'] = $this->getErrorMessage();
return false;
}
// 詳細コード一時的に変更していたものを元に戻す
$this->paymentResult['vResultCode'] = $response->getVResultCode();
$withCapture = $this->getWithCapture($sources['order']);
// プラグインver.1.0.0で登録した決済が本人認証から戻ってきた場合は
// 決済情報に処理区分が無いので、代わりに設定画面の値を使用する
if (is_null($withCapture)) {
$withCapture = $sources['paymentInfo']['withCapture'];
}
// 正常終了
$this->paymentResult['isOK'] = true;
$this->paymentResult['mErrMsg'] = '';
$this->paymentResult['orderId'] = $response->getOrderId();
$orderPayment = $sources['orderPayment'];
$memo10 = unserialize($orderPayment->getMemo10());
$card_type = $memo10['card_type'];
$this->paymentResult['paymentType'] = substr($card_type, 0, 2);
$this->paymentResult['paymentCount'] = substr($card_type, 2);
$this->paymentResult['payStatus'] = $withCapture
? $this->vt4gConst['VT4G_PAY_STATUS']['CAPTURE']['VALUE']
: $this->vt4gConst['VT4G_PAY_STATUS']['AUTH']['VALUE'];
$this->paymentResult['mpiHosting'] = true;
$this->paymentResult['withCapture'] = $withCapture;
$this->mdkLogger->info(print_r($this->paymentResult, true));
// 正常終了の場合
if ($this->paymentResult['isOK']) {
// 継続課金注文・明細データの保存
$this->saveSubscOrder($sources);
// ベリトランス会員ID決済の場合
if ($sources['useAccountPayment']) {
$session = $this->container->get('session');
$sessionKey = $this->vt4gConst['VT4G_CREDIT_VERITRANS_ID_SESSION_KEY'];
// セッションにベリトランス会員IDが保存されている場合
if ($session->has($sessionKey)) {
// ベリトランス会員IDをテーブルに保存
$this->saveAccountId($sources['user']->getId(), $session->get($sessionKey));
// セッションから削除
$session->remove($sessionKey);
}
}
$isCompleted = $this->completeCreditOrder($sources['order'], $orderPayment);
// 受注完了処理
if (!$isCompleted) {
$this->mdkLogger->fatal(trans('vt4g_plugin.shopping.credit.fatal.complete'));
$error['payment'] = $this->getErrorMessage();
return false;
}
}
return true;
}
/**
* MDKリクエストのリトライを実行
*
* @param string $orderId 取引ID
* @param array &$error 画面表示用エラー配列
* @return object|null リトライレスポンス(異常終了の場合にnull)
*/
private function retryMdkRequest($orderId, &$error)
{
$isSucceeeded = false;
for ($count = 0; $count < $this->vt4gConst['VT4G_REQUEST']['CREDIT']['RETRY_LIMIT']; $count++) {
// インターバル
sleep($this->vt4gConst['VT4G_REQUEST']['CREDIT']['RETRY_WAIT']);
$this->mdkLogger->info(trans('vt4g_plugin.payment.shopping.mdk.restart'));
$mdkRequest = new CardRetryRequestDto();
$mdkRequest->setOrderId($orderId);
$mdkTransaction = new TGMDK_Transaction();
$mdkResponse = $mdkTransaction->execute($mdkRequest);
// 異常終了の場合
if (!isset($mdkResponse)) {
$this->mdkLogger->fatal(trans('vt4g_plugin.shopping.credit.fatal.restart'));
$error['payment'] = $this->getErrorMessage();
return null;
}
$this->paymentResult['mStatus'] = $mdkResponse->getMStatus();
$this->paymentResult['vResultCode'] = $mdkResponse->getVResultCode();
$this->paymentResult['mErrMsg'] = $mdkResponse->getMerrMsg();
// 正常終了の場合
if ($mdkResponse->getMStatus() === $this->vt4gConst['VT4G_RESPONSE']['MSTATUS']['OK']) {
$isSucceeeded = true;
break;
}
}
// リトライが全部失敗した場合
if (!$isSucceeeded) {
$this->mdkLogger->fatal(trans('vt4g_plugin.shopping.credit.fatal.restart.end'));
$error['payment'] = $this->getErrorMessage();
return null;
}
return $mdkResponse;
}
/**
* ベリトランス会員IDを会員テーブルに保存
*
* @param integer $customerId 加盟店会員ID
* @param string $accountId ベリトランス会員ID
* @return void
*/
private function saveAccountId($customerId, $accountId)
{
$customer = $this->em->getRepository(Customer::class)->find($customerId);
// ベリトランス会員IDが未設定の場合に保存
if (empty($customer->vt4g_account_id)) {
$customer->vt4g_account_id = $accountId;
$this->em->flush();
}
}
/**
* 受注完了処理
*
* @param Order $order 注文情報
* @param Vt4gOrderPayment $orderPayment 注文に紐づく決済情報
* @return void
*/
public function completeCreditOrder($order, $orderPayment)
{
if (!$this->paymentResult['isOK']) {
return false;
}
// 決済情報 (memo05)
$payment = $this->paymentResult;
// メール情報 (memo06)
$this->mailData = [];
$this->setMailTitle($this->vt4gConst['VT4G_PAYNAME_PAYTYPEID_10']);
$this->setMailInfo('決済取引ID', $this->paymentResult['orderId']);
$paymentMethod = $this->util->getPaymentMethod($order->getPayment()->getId());
$this->setMailAdminSetting($paymentMethod);
$subscSaleType = $this->util->checkSubscriptionOrder($order); // 継続課金商品の判断 $subscSaleTypeがnullでなかったら継続課金商品
$subscMailInfoRepos = $this->em->getRepository(Vt4gSubscProductOrderCmpMailInfo::class);
if (isset($subscSaleType)) {
$processedList = [];
foreach ($order->getOrderItems() as $item) {
$product_id = $this->util->getProductIdByOrderItem($item->getId());
// メッセージ追加済みの商品IDはスキップする
if (!in_array($product_id, $processedList) ) {
$info = $subscMailInfoRepos->findOneBy(['product_id' => $product_id]);
if (isset($info)) {
$this->setMailInfo($info->getOrderCmpMailTitle(), $info->getOrderCompMailBody());
$processedList[] = $product_id;
}
}
}
}
// 決済変更ログ情報 (plg_vt4g_order_logテーブル)
$this->setLog($order);
// 注文ステータス更新
if (!$this->setNewOrderStatus($order,$payment['withCapture'])) {
return false;
}
// 受注完了処理
$this->completeOrder($order, $orderPayment, $payment, $this->logData, $this->mailData);
return true;
}
/**
* 再取引決済元取引IDのバリデーション
*
* @param integer $paymentOrderId 元取引ID
* @param integer $customerId 会員ID
* @return boolean 元取引が存在するか
*/
private function isValidReTradeOrder($paymentOrderId, $customerId)
{
$limitDate = date(
$this->vt4gConst['VT4G_CREDIT_RETRADE']['DATETIME_FORMAT'],
strtotime(sprintf('- %d month', $this->vt4gConst['VT4G_CREDIT_RETRADE']['VALID_MONTH']))
);
return $this->em->getRepository(Vt4gOrderPayment::class)->existsReTradeOrder(
$customerId,
$this->vt4gConst['VT4G_PAYTYPEID_CREDIT'],
$limitDate,
$paymentOrderId
);
}
/**
* ベリトランス会員IDを取得
* (登録されていない場合は新しく採番)
*
* @param object $customer 会員情報
* @param integer $paymentId 決済方法ID
* @return string ベリトランス会員ID
*/
private function getAccountId($customer, $paymentId)
{
return empty($customer->vt4g_account_id)
? $this->generateAccountId($customer, $paymentId)
: $customer->vt4g_account_id;
}
/**
* ベリトランスIDを新規採番
*
* @param object $customer 会員情報
* @param integer $paymentId 決済方法ID
* @return string ベリトランス会員ID
*/
private function generateAccountId($customer, $paymentId)
{
$paymentInfo = $this->util->getPaymentMethodInfo($paymentId);
$prefix = $paymentInfo['veritrans_id_prefix'];
$customerId = $this->util->zeroPadding($customer->getId(), $this->vt4gConst['VT4G_CUSTOMER_ID_DIGITS']);
$hash = md5($customer->getEmail());
$now = date("YmdHis");
return "{$prefix}{$customerId}@{$hash}{$now}";
}
/**
* メール内容の設定と完了画面の内容設定
*
* @param object $order 注文データ
* @param array $paymentResult 決済レスポンスデータ
* @return array $mailData メールの説明文
*/
public function setMail($order, $paymentResult = null)
{
if (is_null($paymentResult)) {
$paymentResult = $this->paymentResult;
}
$this->mailData = [];
$this->setMailTitle($this->vt4gConst['VT4G_PAYNAME_PAYTYPEID_10']);
$this->setMailInfo('決済取引ID', $paymentResult['orderId']);
$paymentMethod = $this->util->getPaymentMethod($order->getPayment()->getId());
$this->setMailAdminSetting($paymentMethod);
return $this->mailData;
}
/**
* ログ出力内容を設定
*
* @param object $order Orderクラスインスタンス
* @return void
*/
private function setLog($order, $paymentResult = null)
{
if (is_null($paymentResult)) {
$paymentResult = $this->paymentResult;
}
$this->timeKey = '';
$payId = $this->util->getPayId($order->getPayment()->getId());
$payName = $this->util->getPayName($payId);
$payStatusName = $this->util->getPaymentStatusName($paymentResult['payStatus']);
$this->setLogInfo('決済取引ID', $paymentResult['orderId']);
$this->setLogInfo($payName, sprintf(
$this->isPaymentRecv ? trans('vt4g_plugin.shopping.credit.recv.status') : trans('vt4g_plugin.shopping.credit.payment.status'),
$payStatusName
));
}
/**
* レスポンスを元にエラーメッセージを取得
*
* @return string エラーメッセージ
*/
private function getErrorMessage()
{
$defaultMessage = $this->defaultErrorMessage;
if (!empty($this->paymentResult['vResultCode'])) {
$defaultMessage .= '[' . $this->paymentResult['vResultCode'] . ']';
}
$vResultCode = $this->paymentResult['vResultCode'];
if (empty($vResultCode)) {
return $defaultMessage;
}
$extendMessage = '';
foreach (str_split($vResultCode, 4) as $code) {
if ($code === '0000') {
continue;
}
$transKey = $this->vt4gConst['VT4G_CREDIT_ERR_TRANS_PREFIX'] . $code;
$transMessage = trans($transKey);
if ($transMessage !== $transKey) {
$extendMessage .= '<br />' . $transMessage;
}
}
if (empty($extendMessage)) {
$extendMessage = '<br />' . trans($this->vt4gConst['VT4G_CREDIT_ERR_TRANS_PREFIX'].'DEFAULT');
}
return $defaultMessage . $extendMessage;
}
/**
* ダミーモードを判定します。
* @return boolean||null trueとnull:ダミーモード、false:本番モード
*/
protected function isDummyMode()
{
$subData = $this->util->getPluginSetting();
if (isset($subData)) {
return $subData['dummy_mode_flg'] == '1';
} else {
return true;
}
}
/**
* 継続課金注文・明細データの保存
* @param array $sources 保存する元データ
*
* @return boolean
*/
public function saveSubscOrder($sources)
{
// 継続課金の販売種別が確認
$saleTypeId = $sources['order']->getSaleTypes()[0]->getId();
$subscSaleType = $this->em->getRepository(Vt4gSubscSaleType::class)
->findOneBy(['sale_type_id' => $saleTypeId]);
if (is_null($subscSaleType)) {
// 継続課金の販売種別でない場合は登録しない
return false;
}
$order_id = $sources['order']->getId();
$customer_id = null;
if (isset($sources['user'])){
$customer_id = $sources['user']->getId();
} else {
$customer_id = $this->em->getRepository(Order::class)
->findOneBy(['id' => $order_id])->getCustomer()->getId();
}
// 継続課金注文データが登録済みならスキップ
$subscOrder = $this->em->getRepository(Vt4gSubscOrder::class)->find($order_id);
if (!empty($subscOrder)){
return false;
}
// 決済センター戻りと結果通知を同時受信してデッドロックが発生したら、
// 一方の通信の処理でデータが登録されるはずなので、次の処理に進む
try {
// 継続課金注文データの保存
$subscOrder = new Vt4gSubscOrder();
$subscOrder ->setOrderId($order_id)
->setCustomerId($customer_id)
->setSubscSaleTypeId($sources['order']->getSaleTypes()[0]->getId());
$this->em->persist($subscOrder);
$this->em->flush();
// 継続課金注文明細データの保存
$oder_items = $sources['order']->getOrderItems();
$idxSubscOrderItem = [];
foreach ($oder_items as $oder_item) {
// 商品マスタ情報を保持している注文明細のみ保存する（送料などを除外する）
if ($puroduct = $oder_item->getProduct()) {
$subscOrder = new Vt4gSubscOrderItem();
$puroduct_id = $puroduct->getId();
$prod_class_id = $oder_item->getProductClass()->getId();
$shipping_id = $oder_item->getShipping()->getId();
$idx = sprintf('%s-%s-%s-%s', $order_id, $puroduct_id, $prod_class_id, $shipping_id);
if (in_array($idx, $idxSubscOrderItem)) continue;
$idxSubscOrderItem[] = $idx;
$subscOrder ->setOrderId($order_id)
->setProductId($puroduct_id)
->setProductClassId($prod_class_id)
->setShippingId($shipping_id)
->setSubscStatus($this->vt4gConst['VTG4_SUBSC_STATUS_SUBSC']); // 継続
$this->em->persist($subscOrder);
}
}
$this->em->flush();
$this->mdkLogger->info(sprintf(trans('vt4g_plugin.shopping.credit.saved.subsc.order'),$order_id));
} catch (\Doctrine\DBAL\Exception $e) {
$msg = $e->getMessage();
if(strpos($msg,'deadlock') !== false || strpos($msg,'Deadlock') !== false) {
$this->mdkLogger->info(sprintf(trans('vt4g_plugin.db.deadlock'),'決済センター戻りの継続課金注文保存処理'));
} else {
$this->mdkLogger->error($e->getMessage());
throw $e;
}
}
}
}

app/Plugin/VeriTrans4G2/Service/Payment/CreditService.php line 39