handler.php

См. документацию.

<?php
 
namespace Sale\Handlers\PaySystem;
 
use Bitrix\Main;
use Bitrix\Main\Error;
use Bitrix\Main\Request;
use Bitrix\Main\Type\DateTime;
use Bitrix\Main\Localization\Loc;
use Bitrix\Sale;
use Bitrix\Sale\PaymentCollection;
use Bitrix\Sale\PaySystem;
use Bitrix\Sale\Payment;
use Bitrix\Sale\PriceMaths;

class LiqPayHandler extends PaySystem\ServiceHandler
{
    public function initiatePay(Payment $payment, Request $request = null)
    {
        $busValues = $this->getParamsBusValue($payment);
        $busValues['LIQPAY_PATH_TO_RESULT_URL'] = $this->getPathResultUrl($payment);
 
        $xml = "<request>
            <version>1.2</version>
            <result_url>".$busValues['LIQPAY_PATH_TO_RESULT_URL']."</result_url>
            <server_url>".$busValues['LIQPAY_PATH_TO_SERVER_URL']."</server_url>
            <merchant_id>".$busValues['LIQPAY_MERCHANT_ID']."</merchant_id>
            <order_id>PAYMENT_".$busValues['PAYMENT_ID']."</order_id>
            <amount>".$busValues["PAYMENT_SHOULD_PAY"]."</amount>
            <currency>".$busValues['PAYMENT_CURRENCY']."</currency>
            <description>".$this->getPaymentDescription($payment)."</description>
            <default_phone>".$busValues['BUYER_PERSON_PHONE']."</default_phone>
            <pay_way>".$busValues['LIQPAY_PAY_METHOD']."</pay_way>
            </request>";
 
        $signature = base64_encode(sha1($busValues['LIQPAY_SIGN'].$xml.$busValues['LIQPAY_SIGN'], 1));
 
        $params = array(
            'URL' => $this->getUrl($payment, 'pay'),
            'OPERATION_XML' => base64_encode($xml),
            'SIGNATURE' => $signature,
        );
 
        if ($busValues['PAYMENT_CURRENCY'] == "RUB")
            $params['PAYMENT_CURRENCY'] = "RUR";
 
        $this->setExtraParams($params);
 
        return $this->showTemplate($payment, "template");
    }

    public static function getIndicativeFields()
    {
        return array('operation_xml', 'signature');
    }
 
    protected static function isMyResponseExtended(Request $request, $paySystemId)
    {
        $paymentId = self::getValueByTag(self::getOperationXml($request), 'order_id');
        $paymentId = (int)str_replace("PAYMENT_", "", $paymentId);
        $payment = Sale\Repository\PaymentRepository::getInstance()->getById($paymentId);
 
        $merchantId = Sale\BusinessValue::get(
            'LIQPAY_MERCHANT_ID', PaySystem\Service::PAY_SYSTEM_PREFIX . $paySystemId, $payment
        );
        $merchantIdFromRequest = self::getValueByTag(self::getOperationXml($request), 'merchant_id');
 
        return $merchantId === $merchantIdFromRequest;
    }

    private function isCorrectHash(Payment $payment, Request $request)
    {
        if ($request->get('operation_xml') !== null)
        {
            $sign = $this->getBusinessValue($payment, 'LIQPAY_SIGN');
            if ($sign)
            {
                $hash = base64_encode(sha1($sign.self::getOperationXml($request).$sign, 1));
                return $request->get('signature') == $hash;
            }
        }
 
        return false;
    }

    private function isCorrectSum(Payment $payment, Request $request)
    {
        $sum = self::getValueByTag(self::getOperationXml($request), 'amount');
        $paymentSum = $this->getBusinessValue($payment, 'PAYMENT_SHOULD_PAY');
 
        return PriceMaths::roundPrecision($paymentSum) === PriceMaths::roundPrecision($sum);
    }

    public function getPaymentIdFromRequest(Request $request)
    {
        $orderId = self::getValueByTag(self::getOperationXml($request), 'order_id');
        return str_replace("PAYMENT_", "", $orderId);
    }

    protected function getUrlList()
    {
        return array(
            'pay' => array(
                self::ACTIVE_URL => 'https://www.liqpay.ua/?do=clickNbuy'
            )
        );
    }

    public function processRequest(Payment $payment, Request $request)
    {
        $result = new PaySystem\ServiceResult();
 
        if ($request->get('signature') === null || $request->get('operation_xml') === null)
        {
            $errorMessage = Loc::getMessage('SALE_HPS_LIQPAY_POST_ERROR');
            $result->addError(new Error($errorMessage));
 
            PaySystem\Logger::addError('LiqPay: processRequest: '.$errorMessage);
        }
 
        $status = self::getValueByTag(self::getOperationXml($request), 'status');
 
        if ($this->isCorrectHash($payment, $request))
        {
            if ($status === 'success' || $status === 'wait_reserve')
            {
                return $this->processNoticeAction($payment, $request);
            }
 
            if ($status === 'wait_secure')
            {
                return new PaySystem\ServiceResult();
            }
        }
        else
        {
            PaySystem\Logger::addError('LiqPay: processRequest: Incorrect hash');
            $result->addError(new Error('Incorrect hash'));
        }
 
        return $result;
    }

    private function processNoticeAction(Payment $payment, Request $request)
    {
        $result = new PaySystem\ServiceResult();
 
        $response = self::getOperationXml($request);
 
        $description = 'sender phone: '.self::getValueByTag($response, 'sender_phone').'; ';
        $description .= 'amount: '.self::getValueByTag($response, 'amount').'; ';
        $description .= 'currency: '.self::getValueByTag($response, 'currency').'; ';
 
        $statusMessage = 'status: '.self::getValueByTag($response, 'status').'; ';
        $statusMessage .= 'transaction_id: '.self::getValueByTag($response, 'transaction_id').'; ';
        $statusMessage .= 'pay_way: '.self::getValueByTag($response, 'pay_way').'; ';
        $statusMessage .= 'payment_id: '.self::getValueByTag($response, 'order_id').'; ';
 
 
        $fields = array(
            "PS_STATUS" => "Y",
            "PS_STATUS_CODE" => mb_substr(self::getValueByTag($response, 'status'), 0, 5),
            "PS_STATUS_DESCRIPTION" => $description,
            "PS_STATUS_MESSAGE" => $statusMessage,
            "PS_SUM" => self::getValueByTag($response, 'amount'),
            "PS_CURRENCY" => self::getValueByTag($response, 'currency'),
            "PS_RESPONSE_DATE" => new DateTime(),
        );
 
        $result->setPsData($fields);
 
        if ($this->isCorrectSum($payment, $request))
        {
            $result->setOperationType(PaySystem\ServiceResult::MONEY_COMING);
        }
        else
        {
            PaySystem\Logger::addError('LiqPay: processNoticeAction: Incorrect sum');
            $result->addError(new Error('Incorrect sum'));
        }
 
        return $result;
    }

    public function getCurrencyList()
    {
        return ['RUB', 'USD', 'EUR', 'UAH'];
    }

    private static function getValueByTag($string, $tag)
    {
        $string = str_replace("\n", "", str_replace("\r", "", $string));
        $open = '<'.$tag.'>';
        $close = '</'.$tag;
        $start = mb_strpos($string, $open) + mb_strlen($open);
        $end = mb_strpos($string, $close);
 
        return mb_substr($string, $start, ($end - $start));
    }

    private static function getOperationXml(Request $request)
    {
        static $operationXml = '';
 
        if ($operationXml === '')
            $operationXml = base64_decode($request->get('operation_xml'));
 
        return $operationXml;
    }

    private function getPaymentDescription(Payment $payment)
    {
        $collection = $payment->getCollection();
        $order = $collection->getOrder();
        $userEmail = $order->getPropertyCollection()->getUserEmail();
 
        return str_replace(
            [
                '#PAYMENT_NUMBER#',
                '#ORDER_NUMBER#',
                '#PAYMENT_ID#',
                '#ORDER_ID#',
                '#USER_EMAIL#'
            ],
            [
                $payment->getField('ACCOUNT_NUMBER'),
                $order->getField('ACCOUNT_NUMBER'),
                $payment->getId(),
                $order->getId(),
                ($userEmail) ? $userEmail->getValue() : ''
            ],
            $this->getBusinessValue($payment, 'LIQPAY_PAYMENT_DESCRIPTION')
        );
    }

    private function getPathResultUrl(Payment $payment)
    {
        $url = $this->getBusinessValue($payment, 'LIQPAY_PATH_TO_RESULT_URL') ?: $this->service->getContext()->getUrl();
 
        return str_replace('&', '&amp;', $url);
    }
}