pagantisNotify

Complexity

Total Complexity

48

Size/Duplication

Total Lines	384
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

21 Methods

Rating	Name	Duplication	Size	Complexity
A	saveOrder()	0	13	2
A	getPagantisOrderId()	0	10	3
A	confirmPagantisOrder()	0	10	2
A	rollbackMerchantOrder()	0	3	1
A	checkConcurrency()	0	6	1
A	checkMerchantOrderStatus()	0	4	2
A	__callStatic()	0	2	1
A	__construct()	0	12	2
A	checkConcurrencyTable()	0	11	2
A	checkOrderStatus()	0	14	4
A	insertLog()	0	11	2
A	processMerchantOrder()	0	4	1
A	getMerchantOrder()	0	4	2
A	checkPagantisStatus()	0	19	5
A	unblockConcurrency()	0	12	4
A	getPagantisOrder()	0	9	2
A	updateBdInfo()	0	13	1
B	processInformation()	0	41	5
A	blockConcurrency()	0	7	2
A	validateAmount()	0	6	2
A	getQuoteId()	0	5	2

<?php

use Pagantis\OrdersApiClient\Client;
use Pagantis\ModuleUtils\Exception\AlreadyProcessedException;
use Pagantis\ModuleUtils\Exception\AmountMismatchException;
use Pagantis\ModuleUtils\Exception\MerchantOrderNotFoundException;
use Pagantis\ModuleUtils\Exception\NoIdentificationException;
use Pagantis\ModuleUtils\Exception\OrderNotFoundException;
use Pagantis\ModuleUtils\Exception\QuoteNotFoundException;
use Pagantis\ModuleUtils\Exception\UnknownException;
use Pagantis\ModuleUtils\Exception\WrongStatusException;
use Pagantis\ModuleUtils\Model\Response\JsonSuccessResponse;
use Pagantis\ModuleUtils\Model\Response\JsonExceptionResponse;
use Pagantis\ModuleUtils\Model\Log\LogEntry;

define('__ROOT__', dirname(dirname(__FILE__)));

define('TABLE_PAGANTIS', 'pagantis');
define('TABLE_PAGANTIS_LOG', 'pagantis_log');
define('TABLE_PAGANTIS_CONFIG', 'pagantis_config');
define('TABLE_PAGANTIS_ORDERS', 'pagantis_orders');
define('TABLE_PAGANTIS_CONCURRENCY', 'pagantis_concurrency');
chdir('../../../../');
require('includes/application_top.php');

class pagantisNotify
{
    /** @var mixed $pagantisOrder */
    protected $pagantisOrder;

    /** @var $string $origin */

The doc comment $string at position 0 could not be parsed: Unknown type name '$string' at position 0 in $string.

    public $origin;

    /** @var $string */

The doc comment $string at position 0 could not be parsed: Unknown type name '$string' at position 0 in $string.

    public $order;

    /** @var mixed $oscommerceOrderId */
    protected $oscommerceOrderId = '';

    /** @var mixed $cfg */
    protected $cfg;

    /** @var Client $orderClient */
    protected $orderClient;

    /** @var Order $oscommerceOrder */

The type Order was not found. Maybe you did not declare it correctly or list all dependencies?

    protected $oscommerceOrder;

    /** @var mixed $pagantisOrderId */
    protected $pagantisOrderId = '';


    /**
     * pagantisNotify constructor.
     */
    public function __construct()
    {
        $this->oscommerceOrderId = '7e93cd07dbeba82f6d77965f9bec2c7a';
        $this->getPagantisOrderId();
        $result = ($this->pagantisOrderId);
        $result = unserialize($result);
        foreach ($result as $var => $content) {
            $GLOBALS[$var] = unserialize($content);
            tep_session_register($var);

The function tep_session_register was not found. Maybe you did not declare it correctly or list all dependencies?

        }

        header("Location: http://oscommerce-dev.docker:8095/checkout_process.php");

    }

    public static function __callStatic($name, $arguments)
    {
        // TODO: Implement __callStatic() method.
    }

    /**
     * Validation vs PagantisClient
     *
     * @return array|Array_

The type Array_ was not found. Maybe you did not declare it correctly or list all dependencies?

     * @throws Exception
     */
    public function processInformation()
    {
        require_once(__ROOT__.'/pagantis/vendor/autoload.php');
        try {
            $this->checkConcurrency();
            $this->getMerchantOrder();
            $this->getPagantisOrderId();
            $this->getPagantisOrder();
            $this->checkOrderStatus();
            $this->checkMerchantOrderStatus();
            $this->validateAmount();
            $this->processMerchantOrder();
        } catch (\Exception $exception) {
            $jsonResponse = new JsonExceptionResponse();
            $jsonResponse->setMerchantOrderId($this->oscommerceOrderId);
            $jsonResponse->setPagantisOrderId($this->pagantisOrderId);
            $jsonResponse->setException($exception);
            $response = $jsonResponse->toJson();
            $this->insertLog($exception);
        }
        try {
            if (!isset($response)) {
                $this->confirmPagantisOrder();
                $jsonResponse = new JsonSuccessResponse();
                $jsonResponse->setMerchantOrderId($this->oscommerceOrderId);
                $jsonResponse->setPagantisOrderId($this->pagantisOrderId);
            }
        } catch (\Exception $exception) {
            $this->rollbackMerchantOrder();
            $jsonResponse = new JsonExceptionResponse();
            $jsonResponse->setMerchantOrderId($this->oscommerceOrderId);
            $jsonResponse->setPagantisOrderId($this->pagantisOrderId);
            $jsonResponse->setException($exception);
            $jsonResponse->toJson();
            $this->insertLog($exception);
        }

        if ($_SERVER['REQUEST_METHOD'] == 'POST') {
            $jsonResponse->printResponse();

The variable $jsonResponse does not seem to be defined for all execution paths leading up to this point.

        } else {
            return $jsonResponse;
        }
    }

    /**
     * COMMON FUNCTIONS
     */

    /**
     * @throws Exception
     */
    private function checkConcurrency()
    {
        $this->getQuoteId();
        $this->checkConcurrencyTable();
        $this->unblockConcurrency();
        $this->blockConcurrency();
    }

    /**
     * @throws MerchantOrderNotFoundException
     */
    private function getMerchantOrder()
    {
        if (!isset($this->oscommerceOrder)) {
            throw new MerchantOrderNotFoundException();
        }
    }

    /**
     * @throws NoIdentificationException
     */
    private function getPagantisOrderId()
    {
        $query = "select pmt_order_id from ".TABLE_PAGANTIS_ORDERS." where os_order_id='".$this->oscommerceOrderId."'";
        $resultsSelect = tep_db_query($query);

The function tep_db_query was not found. Maybe you did not declare it correctly or list all dependencies?

        while ($orderRow = tep_db_fetch_array($resultsSelect)) {

The function tep_db_fetch_array was not found. Maybe you did not declare it correctly or list all dependencies?

            $this->pagantisOrderId = $orderRow['pmt_order_id'];
        }

        if ($this->pagantisOrderId == '') {
            throw new NoIdentificationException();
        }
    }

    /**
     * @throws OrderNotFoundException
     */
    private function getPagantisOrder()
    {
        try {
            $publicKey     = trim(MODULE_PAYMENT_PAGANTIS_PK);

The constant MODULE_PAYMENT_PAGANTIS_PK was not found. Maybe you did not declare it correctly or list all dependencies?

            $secretKey     = trim(MODULE_PAYMENT_PAGANTIS_SK);

The constant MODULE_PAYMENT_PAGANTIS_SK was not found. Maybe you did not declare it correctly or list all dependencies?

            $this->orderClient   = new \Pagantis\OrdersApiClient\Client($publicKey, $secretKey);
            $this->pagantisOrder = $this->orderClient->getOrder($this->pagantisOrderId);
        } catch (\Exception $e) {
            throw new OrderNotFoundException();
        }
    }

    /**
     * @throws AlreadyProcessedException
     * @throws WrongStatusException
     */
    private function checkOrderStatus()
    {
        try {
            $this->checkPagantisStatus(array('AUTHORIZED'));
        } catch (\Exception $e) {
            if ($this->oscommerceOrderId!='') {
                throw new AlreadyProcessedException();
            } else {
                if ($this->pagantisOrder instanceof \Pagantis\OrdersApiClient\Model\Order) {
                    $status = $this->pagantisOrder->getStatus();
                } else {
                    $status = '-';
                }
                throw new WrongStatusException($status);
            }
        }
    }

    /**
     * @throws AlreadyProcessedException
     */
    private function checkMerchantOrderStatus()
    {
        if (!$this->oscommerceOrder->info['order_status']!=='1') {

The condition ! $this->oscommerceOrder->info['order_status'] !== '1' is always true.

            throw new AlreadyProcessedException();
        }
    }

    /**
     * @throws AmountMismatchException
     */
    private function validateAmount()
    {
        $pagantisAmount = $this->pagantisOrder->getShoppingCart()->getTotalAmount();
        $wcAmount = intval(strval(100 * $this->oscommerceOrder->get_total()));
        if ($pagantisAmount != $wcAmount) {
            throw new AmountMismatchException($pagantisAmount, $wcAmount);
        }
    }

    /**
     * @throws Exception
     */
    private function processMerchantOrder()
    {
        $this->saveOrder();
        $this->updateBdInfo();
    }

    /**
     * @return false|string
     * @throws UnknownException
     */
    private function confirmPagantisOrder()
    {
        try {
            $this->pagantisOrder = $this->orderClient->confirmOrder($this->pagantisOrderId);
        } catch (\Exception $e) {
            throw new UnknownException($e->getMessage());
        }

        $jsonResponse = new JsonSuccessResponse();
        return $jsonResponse->toJson();
    }
    /**
     * UTILS FUNCTIONS
     */

    /** STEP 1 CC - Check concurrency */

    /**
     * @throws QuoteNotFoundException
     */
    private function getQuoteId()
    {
        $this->oscommerceOrderId = $_GET['order_id'];
        if ($this->oscommerceOrderId == '') {
            throw new QuoteNotFoundException();
        }
    }

    /**
     * Check if concurrency table exists
     */
    private function checkConcurrencyTable()
    {
        $checkTable = tep_db_query("SHOW TABLES LIKE '".TABLE_PAGANTIS_CONCURRENCY."'");

The function tep_db_query was not found. Maybe you did not declare it correctly or list all dependencies?

        if (tep_db_num_rows($checkTable) == 0) {

The function tep_db_num_rows was not found. Maybe you did not declare it correctly or list all dependencies?

            $sql = "CREATE TABLE IF NOT EXISTS ".TABLE_PAGANTIS_CONCURRENCY." (
                            id int NOT NULL,
                            `timestamp` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
                            UNIQUE KEY id(id))";
            tep_db_query($sql);
        }
        return;
    }

    /**
     * Unlock the concurrency
     *
     * @param null $orderId

Are you sure the doc-type for parameter $orderId is correct as it would always require null to be passed?

     * @throws Exception
     */
    private function unblockConcurrency($orderId = null)
    {
        try {
            if ($orderId == null) {

The condition $orderId == null is always true.

                $query = "delete from ".TABLE_PAGANTIS_CONCURRENCY." where  timestamp<".(time() - 5);
                tep_db_query($query);

The function tep_db_query was not found. Maybe you did not declare it correctly or list all dependencies?

            } elseif ($this->$orderId!='') {
                $query = "delete from ".TABLE_PAGANTIS_CONCURRENCY." where id=".$this->$orderId;
                tep_db_query($query);
            }
        } catch (Exception $exception) {
            throw new ConcurrencyException();

The type ConcurrencyException was not found. Maybe you did not declare it correctly or list all dependencies?

        }
    }

    /**
     * @throws \Exception
     */
    private function blockConcurrency()
    {
        try {
            $query = "INSERT INTO ".TABLE_PAGANTIS_CONCURRENCY." (id) VALUES ('$this->oscommerceOrderId')";
            tep_db_query($query);

The function tep_db_query was not found. Maybe you did not declare it correctly or list all dependencies?

        } catch (Exception $exception) {
            throw new ConcurrencyException();
        }
    }

    /** STEP 2 GMO - Get Merchant Order */
    /** STEP 3 GPOI - Get Pagantis OrderId */
    /** STEP 4 GPO - Get Pagantis Order */
    /** STEP 5 COS - Check Order Status */
    /**
     * @param $statusArray
     *
     * @throws \Exception
     */
    private function checkPagantisStatus($statusArray)
    {
        $pagantisStatus = array();
        foreach ($statusArray as $status) {
            $pagantisStatus[] = constant("\Pagantis\OrdersApiClient\Model\Order::STATUS_$status");
        }

        if ($this->pagantisOrder instanceof \Pagantis\OrdersApiClient\Model\Order) {
            $payed = in_array($this->pagantisOrder->getStatus(), $pagantisStatus);
            if (!$payed) {
                if ($this->pagantisOrder instanceof \Pagantis\OrdersApiClient\Model\Order) {

$this->pagantisOrder is always a sub-type of Pagantis\OrdersApiClient\Model\Order.

                    $status = $this->pagantisOrder->getStatus();
                } else {
                    $status = '-';
                }
                throw new WrongStatusException($status);
            }
        } else {
            throw new OrderNotFoundException();
        }
    }
    /** STEP 6 CMOS - Check Merchant Order Status */
    /** STEP 7 VA - Validate Amount */
    /** STEP 8 PMO - Process Merchant Order */
    /**
     * @throws \Exception
     */
    private function saveOrder()
    {
        global $oscommerce;
        $paymentResult = $this->oscommerceOrder->payment_complete();
        if ($paymentResult) {
            $this->oscommerceOrder->add_order_note("Notification received via $this->origin");
            $this->oscommerceOrder->reduce_order_stock();
            $this->oscommerceOrder->save();

            $oscommerce->cart->empty_cart();
            sleep(3);
        } else {
            throw new UnknownException('Order can not be saved');
        }
    }

    /**
     * Save the merchant order_id with the related identification
     */
    private function updateBdInfo()
    {
        global $wpdb;

        $this->checkDbTable();

The method checkDbTable() does not exist on pagantisNotify.

        $tableName = $wpdb->prefix.self::ORDERS_TABLE;

The constant pagantisNotify::ORDERS_TABLE was not found. Maybe you did not declare it correctly or list all dependencies?

        $wpdb->update(
            $tableName,
            array('wc_order_id'=>$this->oscommerceOrderId),
            array('id' => $this->oscommerceOrderId),
            array('%s'),
            array('%d')
        );
    }

    /** STEP 9 CPO - Confirmation Pagantis Order */
    private function rollbackMerchantOrder()
    {
        $this->oscommerceOrder->update_status('pending', __('Pending payment', 'oscommerce'));

The function __ was not found. Maybe you did not declare it correctly or list all dependencies?

    }

    /**
     * @param $exceptionMessage
     *
     * @throws \Zend_Db_Exception
     */
    private function insertLog($exception)
    {
        global $wpdb;

        if ($exception instanceof \Exception) {
            $this->checkDbLogTable();

The method checkDbLogTable() does not exist on pagantisNotify.

            $logEntry= new LogEntry();
            $logEntryJson = $logEntry->error($exception)->toJson();

            $tableName = $wpdb->prefix.self::LOGS_TABLE;

The constant pagantisNotify::LOGS_TABLE was not found. Maybe you did not declare it correctly or list all dependencies?

            $wpdb->insert($tableName, array('log' => $logEntryJson));
        }
    }
}

$pgNotify = new pagantisNotify();
$pgNotify->processInformation();