Merge pull request #22 from yoomoney/release/v2.2.3

* Добавлен функционал настройки и отправки второго чека
* Исправлена ошибка при создании заказа гостем

CHANGELOG.md

@@ -1,3 +1,7 @@
+### v2.2.3 от 29.12.2021
+* Добавлен функционал настройки и отправки второго чека
+* Исправлена ошибка при создании заказа гостем
+
 ### v2.2.2 от 21.12.2021
 * Исправлены ошибки при добавлении платежного шлюза
 

src/EventSubscriber/YooKassaEventSubscriber.php

@@ -0,0 +1,248 @@
+<?php
+
+namespace Drupal\yookassa\EventSubscriber;
+
+use Drupal;
+use Drupal\commerce_log\LogStorageInterface;
+use Drupal\commerce_order\Entity\Order;
+use Drupal\commerce_order\Event\OrderEvent;
+use Drupal\Component\Plugin\Exception\InvalidPluginDefinitionException;
+use Drupal\Component\Plugin\Exception\PluginNotFoundException;
+use Drupal\Core\Entity\EntityStorageException;
+use Drupal\Core\Entity\EntityTypeManagerInterface;
+use Drupal\user\Entity\User;
+use Drupal\yookassa\Plugin\Commerce\PaymentGateway\YooKassa;
+use Exception;
+use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+use YooKassa\Client;
+use YooKassa\Common\Exceptions\ApiException;
+use YooKassa\Common\Exceptions\ExtensionNotFoundException;
+use YooKassa\Model\Receipt\PaymentMode;
+use YooKassa\Model\ReceiptCustomer;
+use YooKassa\Model\ReceiptItem;
+use YooKassa\Model\ReceiptType;
+use YooKassa\Model\Settlement;
+use YooKassa\Request\Receipts\CreatePostReceiptRequest;
+use YooKassa\Request\Receipts\PaymentReceiptResponse;
+use YooKassa\Request\Receipts\ReceiptResponseInterface;
+use YooKassa\Request\Receipts\ReceiptResponseItemInterface;
+
+/**
+ * Send Second Receipt when the order transitions to Fulfillment.
+ */
+class YooKassaEventSubscriber implements EventSubscriberInterface
+{
+
+    /**
+     * The log storage.
+     *
+     * @var LogStorageInterface
+     */
+    protected $logStorage;
+
+    /**
+     * @var YooKassa apiClient
+     */
+    public $apiClient;
+
+    protected $config;
+
+    /**
+     * Constructor for OrderWorkflowSubscriber.
+     */
+    public function __construct(EntityTypeManagerInterface $entity_type_manager) {
+        $yookassaConfig = \Drupal::config('commerce_payment.commerce_payment_gateway.yookassa')->getOriginal('configuration');
+        $yookassaClient = new Client();
+        $yookassaClient->setAuth($yookassaConfig['shop_id'], $yookassaConfig['secret_key']);
+        $userAgent = $yookassaClient->getApiClient()->getUserAgent();
+        $userAgent->setCms('Drupal', Drupal::VERSION);
+        $userAgent->setModule('yoomoney-cms', YooKassa::YOOMONEY_MODULE_VERSION);
+        $this->apiClient = $yookassaClient;
+        $this->logStorage = Drupal::entityTypeManager()->getStorage('commerce_log');
+        $this->config = $yookassaConfig;
+    }
+
+    /**
+     * @return string[]
+     */
+    public static function getSubscribedEvents(): array
+    {
+        return [
+            'commerce_order.commerce_order.presave' => 'onSendSecondReceipt'
+        ];
+    }
+
+    /**
+     * @param $message
+     * @param $type
+     */
+    private function log($message, $type)
+    {
+        Drupal::logger('yookassa')->$type($message);
+    }
+
+    /**
+     * Send Second Receipt.
+     *
+     * @param OrderEvent $event
+     * @return void|null
+     */
+    public function onSendSecondReceipt(OrderEvent $event)
+    {
+        /** @var Order $order */
+        $order = $event->getOrder();
+        $isSentSecondReceipt = $order->getData('send_second_receipt');
+        $state = $order->getState()->getValue();
+
+        if (
+            !$isSentSecondReceipt
+            && $this->config['second_receipt_enabled']
+            && $state['value'] == $this->config['second_receipt_status']
+        ) {
+            $client = $this->apiClient;
+            $order->setData('send_second_receipt', true);
+
+            $orderId = $order->get('order_id')->getString();
+            $payments = \Drupal::entityTypeManager()->getStorage('commerce_payment')->loadByProperties(['order_id' => $orderId]);
+            $paymentId = !empty($payments) ? array_shift($payments)->getRemoteId() : null;
+            $amount = $order->getTotalPrice()->getNumber();
+            $profile = $order->getCustomer();
+
+            if (!$lastReceipt = $this->getLastReceipt($paymentId)) {
+                $this->log('LastReceipt is empty!', 'error');
+                return null;
+            }
+
+            if ($receiptRequest = $this->buildSecondReceipt($lastReceipt, $paymentId, $profile)) {
+
+                try {
+                    $client->createReceipt($receiptRequest);
+                    $this->logStorage->generate($order, 'order_sent_second_reciept', ['amount' => number_format((float)$amount, 2, '.', '')])->save();
+                    $this->log('SecondReceipt Send: ' . json_encode($receiptRequest), 'info');
+                } catch (ApiException $e) {
+                    $this->log('SecondReceipt Error: ' . json_encode([
+                            'error' => $e->getMessage(),
+                            'request' => $receiptRequest->toArray(),
+                            'lastReceipt' => $lastReceipt->toArray(),
+                            'paymentId' => $paymentId,
+                            'customEmail' => $profile->getEmail()
+                        ]), 'error');
+                }
+            }
+        }
+    }
+
+    /**
+     * @param $paymentId
+     * @return mixed|null
+     */
+    private function getLastReceipt($paymentId)
+    {
+        $receipts = $this->apiClient->getReceipts(array('payment_id' => $paymentId))->getItems();
+
+        return array_pop($receipts);
+    }
+
+    /**
+     * @param PaymentReceiptResponse $lastReceipt
+     * @param string $paymentId
+     * @param User $profile
+     * @return mixed|null
+     */
+    private function buildSecondReceipt(PaymentReceiptResponse $lastReceipt, string $paymentId, User $profile)
+    {
+        if ($lastReceipt->getType() === "refund") {
+            $this->log('Last receipt is refund', 'error');
+            return null;
+        }
+
+        $resendItems = $this->getResendItems($lastReceipt->getItems());
+
+        if (!count($resendItems['items'])) {
+            $this->log('Second receipt is not required', 'error');
+            return null;
+        }
+
+        try {
+            $customer = new ReceiptCustomer();
+            $customer->setEmail($profile->getEmail());
+
+            if (empty($customer)) {
+                $this->log('Customer email for second receipt are empty', 'error');
+                return null;
+            }
+
+            $settlement = new Settlement([
+                'type' => 'prepayment',
+                'amount' => [
+                    'value' => $resendItems['amount'],
+                    'currency' => 'RUB',
+                ],
+            ]);
+            $receiptBuilder = CreatePostReceiptRequest::builder();
+            $receiptBuilder->setObjectId($paymentId)
+                ->setType(ReceiptType::PAYMENT)
+                ->setItems($resendItems['items'])
+                ->setSettlements([$settlement])
+                ->setCustomer($customer)
+                ->setSend(true);
+
+            return $receiptBuilder->build();
+
+        } catch (Exception $e) {
+            $this->log('Build second receipt error: ' . json_encode([
+                    'message' => $e->getMessage()
+                ]), 'error');
+        }
+
+        return null;
+    }
+
+    /**
+     * @param ReceiptResponseItemInterface[] $items
+     *
+     * @return array
+     */
+    private function getResendItems(array $items): array
+    {
+        $result = array(
+            'items' => array(),
+            'amount' => 0,
+        );
+
+        foreach ($items as $item) {
+            if ($this->isNeedResendItem($item->getPaymentMode())) {
+                $item->setPaymentMode(PaymentMode::FULL_PAYMENT);
+                $result['items'][] = new ReceiptItem($item->toArray());
+                $result['amount'] += $item->getAmount() / 100.0;
+            }
+        }
+
+        return $result;
+    }
+
+    /**
+     * @param string $paymentMode
+     *
+     * @return bool
+     */
+    private function isNeedResendItem(string $paymentMode): bool
+    {
+        return in_array($paymentMode, self::getValidPaymentMode());
+    }
+
+    /**
+     * @return array
+     */
+    private static function getValidPaymentMode(): array
+    {
+        return array(
+            PaymentMode::FULL_PREPAYMENT,
+            PaymentMode::PARTIAL_PREPAYMENT,
+            PaymentMode::ADVANCE,
+            PaymentMode::PARTIAL_PAYMENT,
+            PaymentMode::CREDIT,
+            PaymentMode::CREDIT_PAYMENT
+        );
+    }
+}