added sharing feature to Parsian Adapter

Author: samuraee

database/migrations/create_larapay_transaction_table.php.stub

@@ -41,6 +41,7 @@ class CreateLarapayTransactionTable extends Migration
             $table->bigInteger('amount')->default(0);
             $table->jsonb('extra_params')->nullable()->default('{}');
             $table->jsonb('additional_data')->nullable()->default('{}');
+            $table->jsonb('sharing')->nullable()->default('{}');
 
             $table->dateTime('paid_at')->nullable();
             $table->timestamps();

src/Adapter/Parsian.php

@@ -55,21 +55,40 @@ protected function requestToken()
             throw new Exception('larapay::larapay.could_not_request_payment');
         }
 
+
         $this->checkRequiredParameters([
             'pin',
             'order_id',
             'amount',
             'redirect_url',
         ]);
 
+
         $sendParams = [
             'LoginAccount'   => $this->pin,
             'Amount'         => intval($this->amount),
             'OrderId'        => intval($this->order_id),
             'CallBackUrl'    => $this->redirect_url,
-            'AdditionalData' => $this->additional_data ? $this->additional_data : '',
+            'AdditionalData' => $this->additional_data ?? '',
+            'Originator'     => $this->originator ?? '',
         ];
 
+
+        if (is_array($this->sharing) && !empty($this->sharing)) {
+            return $this->requestTokenWithoutSharing($sendParams);
+        } else {
+            return $this->requestTokenWithSharing($sendParams);
+        }
+    }
+
+    /**
+     * @param array $sendParams
+     *
+     * @return mixed
+     * @throws Exception
+     */
+    private function requestTokenWithoutSharing($sendParams)
+    {
         try {
             $this->requestType = 'request';
             $soapClient        = $this->getSoapClient();
@@ -96,6 +115,60 @@ protected function requestToken()
         }
     }
 
+    /**
+     * @param array $sendParams
+     *
+     * @return mixed
+     * @throws Exception
+     */
+    private function requestTokenWithSharing($sendParams)
+    {
+        foreach ($this->sharing as $item) {
+            if (isset($item->IBAN)) {
+                // dynamic sharing
+                $method = 'MultiplexedSaleWithIBANPaymentRequest';
+                $respo = 'MultiplexedSaleWithIBANPaymentResult';
+                $sendParams['MultiplexedAccounts']['Account'][] = [
+                    'Amount' => $item->share,
+                    'PayId'  => $item->pay_id ?? '',
+                    'IBAN'   => $item->iban
+                ];
+            } else {
+                // fix sharing
+                $method = 'MultiplexedSalePaymentRequest';
+                $respo = 'MultiplexedSalePaymentResult';
+                $sendParams['MultiplexedAccounts']['Account'][] = [
+                    'Amount' => $item->share,
+                    'PayId'  => $item->pay_id ?? '',
+                ];
+            }
+        }
+
+        try {
+            $this->requestType = 'request';
+            $soapClient        = $this->getSoapClient();
+
+            XLog::debug("{$method} call", $sendParams);
+
+            $response = $soapClient->$method(array("requestData" => $sendParams));
+
+            XLog::debug("{$method} response", $this->obj2array($response));
+
+            if (isset($response->$respo->Status, $response->$respo->Token)) {
+                if ($response->$respo->Status == 0) {
+                    $this->getTransaction()->setGatewayToken(strval($response->$respo->Token)); // update transaction reference id
+
+                    return $response->$respo->Token;
+                } else {
+                    throw new Exception($this->$respo->Status);
+                }
+            } else {
+                throw new Exception('larapay::parsian.errors.invalid_response');
+            }
+        } catch (SoapFault $e) {
+            throw new Exception('SoapFault: ' . $e->getMessage() . ' #' . $e->getCode(), $e->getCode());
+        }
+    }
     /**
      * @return mixed
      * @throws Exception

src/Models/LarapayTransaction.php

@@ -37,6 +37,7 @@ class LarapayTransaction extends Model implements TransactionInterface
         'extra_params',
         'model',
         'additional_data',
+        'sharing',
     ];
 
     protected $dates = [
@@ -92,7 +93,6 @@ public function reverseTransaction()
 
     public function generateForm($autoSubmit = false, $callback = null, $adapterConfig = [])
     {
-
         $paymentGatewayHandler = $this->gatewayHandler($adapterConfig);
 
         $callbackRoute = route(config("larapay.payment_callback"), [
@@ -111,12 +111,13 @@ public function generateForm($autoSubmit = false, $callback = null, $adapterConf
             'order_id'     => $this->getBankOrderId(),
             'redirect_url' => $callbackRoute,
             'amount'       => $this->amount,
+            'sharing'      => json_decode($this->sharing, true),
             'submit_label' => trans('larapay::larapay.goto_gate'),
         ];
 
         try {
             if ($autoSubmit) {
-                $paymentGatewayHandler->setParameters(['auto_submit' => true]);
+                $paymentParams['auto_submit'] = true;
             }
 
             $form = $paymentGatewayHandler->form($paymentParams);
@@ -150,6 +151,7 @@ public function formParams($callback = null, $adapterConfig = []): array
             'order_id'     => $this->getBankOrderId(),
             'redirect_url' => $callbackRoute,
             'amount'       => $this->amount,
+            'sharing'      => json_decode($this->sharing, true),
             'submit_label' => trans('larapay::larapay.goto_gate'),
         ];
 

src/Payable.php

@@ -45,7 +45,8 @@ public function createTransaction(
         $paymentGateway,
         $amount = null,
         $description = null,
-        array $additionalData = []
+        array $additionalData = [],
+        array $sharing = []
     ) {
 
         $transactionData = [];
@@ -67,6 +68,7 @@ public function createTransaction(
         $transactionData['bank_order_id'] = $this->generateBankOrderId($paymentGateway);
         $transactionData['payment_method'] = 'ONLINE';
         $transactionData['additional_data'] = json_encode($additionalData, JSON_UNESCAPED_UNICODE);
+        $transactionData['sharing'] = json_encode($sharing, JSON_UNESCAPED_UNICODE);
 
         return  $this->transactions()->create($transactionData);
     }