una/modules/boonex/payment/classes/BxPaymentModule.php

<?php defined('BX_DOL') or die('hack attempt');
/**
 * Copyright (c) UNA, Inc - https://una.io
 * MIT License - https://opensource.org/licenses/MIT
 *
 * @defgroup    Payment Payment
 * @ingroup     UnaModules
 *
 * @{
 */

define('BX_PAYMENT_ORDERS_TYPE_PENDING', 'pending');
define('BX_PAYMENT_ORDERS_TYPE_PROCESSED', 'processed');
define('BX_PAYMENT_ORDERS_TYPE_SUBSCRIPTION', 'subscription');
define('BX_PAYMENT_ORDERS_TYPE_HISTORY', 'history');

define('BX_PAYMENT_RESULT_SUCCESS', 0);

/*
 * Subscriptions: statuses.
 */
define('BX_PAYMENT_SBS_STATUS_SCHEDULED', 'scheduled');
define('BX_PAYMENT_SBS_STATUS_TRIAL', 'trial');
define('BX_PAYMENT_SBS_STATUS_ACTIVE', 'active');
define('BX_PAYMENT_SBS_STATUS_UNPAID', 'unpaid');
define('BX_PAYMENT_SBS_STATUS_PAUSED', 'paused');
define('BX_PAYMENT_SBS_STATUS_CANCELED', 'canceled');
define('BX_PAYMENT_SBS_STATUS_UNKNOWN', 'unknown');

/*
 * Subscriptions: period units.
 */
define('BX_PAYMENT_SBS_PU_YEAR', 'year');
define('BX_PAYMENT_SBS_PU_MONTH', 'month');
define('BX_PAYMENT_SBS_PU_WEEK', 'week');
define('BX_PAYMENT_SBS_PU_DAY', 'day');
define('BX_PAYMENT_SBS_PU_HOUR', 'hour');
define('BX_PAYMENT_SBS_PU_MINUTE', 'minute');


/**
 * Payment module by BoonEx
 *
 * This module is needed to work with payment providers and organize the process
 * of some item purchasing. Shopping Cart and Orders Manager are included.
 *
 * Integration notes:
 * To integrate your module with this one, you need:
 * 1. Get 'Add To Cart' button using serviceGetAddToCartLink service.
 * 2. Add info about your module in the 'bx_pmt_modules' table.
 * 3. Realize the following service methods in your Module class.
 *   a. serviceGetItems($iSellerId) - Is used in Orders Administration to get all products of the requested seller(vendor).
 *   b. serviceGetCartItem($iClientId, $iItemId) - Is used in Shopping Cart to get one product by specified id.
 *   c. serviceRegisterCartItem($iClientId, $iSellerId, $iItemId, $iItemCount, $sOrderId) - Register purchased product.
 *   d. serviceUnregisterCartItem($iClientId, $iSellerId, $iItemId, $iItemCount, $sOrderId) - Unregister the product purchased earlier.
 * @see You may see an example of integration in Membership module.
 *
 *
 * Profile's Wall:
 * no spy events
 *
 *
 *
 * Spy:
 * no spy events
 *
 *
 *
 * Memberships/ACL:
 * Doesn't depend on user's membership.
 *
 *
 *
 * Service methods:
 *
 * Is used to get "Add to cart" link for some item(s) in your module.
 * @see BxPmtModule::serviceGetAddToCartLink
 * BxDolService::call('payment', 'get_add_to_cart_link', array($iSellerId, $mixedModuleId, $iItemId, $iItemCount));
 *
 * Check transaction(s) in database which satisty all conditions.
 * @see BxPmtModule::serviceGetOrdersInfo
 * BxDolService::call('payment', 'get_orders_info', array($aConditions), 'Orders');
 *
 * Get total count of items in Shopping Cart.
 * @see BxPmtModule::serviceGetCartItemsCount
 * BxDolService::call('payment', 'get_cart_items_count', array($iUserId, $iOldCount));
 * @note is needed for internal usage(integration with member tool bar).
 *
 * Get Shopping cart content.
 * @see BxPmtModule::serviceGetCartItems
 * BxDolService::call('payment', 'get_cart_items');
 * @note is needed for internal usage(integration with member tool bar).
 *
 *
 * Alerts:
 * no alerts available
 *
 */
class BxPaymentModule extends BxBaseModPaymentModule
{
    protected $_iUserId;

    protected $_aOrderTypes;

    function __construct($aModule)
    {
        parent::__construct($aModule);

        $this->_iUserId = $this->getProfileId();

        $this->_aOrderTypes = array(
            BX_PAYMENT_ORDERS_TYPE_PENDING, 
            BX_PAYMENT_ORDERS_TYPE_PROCESSED, 
            BX_PAYMENT_ORDERS_TYPE_SUBSCRIPTION, 
            BX_PAYMENT_ORDERS_TYPE_HISTORY
        );
    }

    /**
     * Manage Orders Methods
     */
    public function actionGetClients()
    {
        $sTerm = bx_get('term');

        $aResult = BxDolService::call('system', 'profiles_search', array($sTerm), 'TemplServiceProfiles');

        echoJson($aResult);
    }

    public function actionGetItems($sType, $iModuleId)
    {
    	$iSellerId = $this->getProfileId();
        $aItems = $this->callGetCartItems((int)$iModuleId, array($iSellerId));

        echoJson(array(
            'code' => 0, 
            'eval' => $this->_oConfig->getJsObject('processed') . '.onSelectModule(oData);', 
            'data' => $this->_oTemplate->displayItems($sType, $aItems)
        ));
    }

    public function actionGetFilterValuesItem($iSellerId, $iModuleId)
    {
        $sItems = '<option value="">' . _t('_bx_payment_txt_all_items') . '</option>';

        if(empty($iSellerId) || empty($iModuleId))
            return echoJson(array('code' => 1, 'content' => $sItems));

        $aItems = $this->callGetCartItems((int)$iModuleId, array($iSellerId));

        $this->_oConfig->sortByColumn('title', $aItems);

        foreach($aItems as $aItem)
            $sItems .= '<option value="' . $aItem['id'] . '">' . $aItem['title'] . '</option>';

        echoJson(array('code' => 0, 'content' => $sItems));
    }

    public function serviceGetSafeServices()
    {
        $a = parent::serviceGetSafeServices();
        return array_merge($a, array (
            'GetBlockJoin' => 'BxPaymentJoin',
            'GetBlockCarts' => 'BxPaymentCart',
            'GetBlockCart' => 'BxPaymentCart',
            'GetBlockCartHistory' => 'BxPaymentCart',
            'GetBlockListMy' => 'BxPaymentSubscriptions',
            'GetBlockHistory' => 'BxPaymentSubscriptions',
        ));
    }

    /**
     * @page service Service Calls
     * @section bx_payment Payment
     * @subsection bx_payment-purchase_processing Purchase Processing
     * @subsubsection bx_payment-is_credits_only is_credits_only
     * 
     * @code bx_srv('bx_payment', 'is_credits_only'); @endcode
     * 
     * Check whether the 'Credits Only' mode is enabled or not.
     *
     * @return boolean value determining the result of checking.
     * 
     * @see BxPaymentModule::serviceIsCreditsOnly
     */
    /** 
     * @ref bx_payment-is_credits_only "is_credits_only"
     */
    public function serviceIsCreditsOnly()
    {
        return $this->_oConfig->isCreditsOnly();
    }

    /**
     * @page service Service Calls
     * @section bx_payment Payment
     * @subsection bx_payment-purchase_processing Purchase Processing
     * @subsubsection bx_payment-is_accepting_payments is_accepting_payments
     * 
     * @code bx_srv('bx_payment', 'is_accepting_payments', [...]); @endcode
     * 
     * Check whether the specified vendor has a configured payment provider or not.
     *
     * @param $iVendorId integer value with vendor ID.
     * @param $sPaymentType (optional) string value with payment type. If specified then the vendor will be checked for having the payment provider of the requested type.
     * @return boolean value determining the result of checking.
     * 
     * @see BxPaymentModule::serviceIsAcceptingPayments
     */
    /** 
     * @ref bx_payment-is_accepting_payments "is_accepting_payments"
     */
    public function serviceIsAcceptingPayments($iVendorId, $sPaymentType = '')
    {
    	$bResult = false;

    	switch($sPaymentType) {
    		case BX_PAYMENT_TYPE_SINGLE:
    			$aProvidersCart = $this->_oDb->getVendorInfoProvidersSingle($iVendorId);
    			$bResult = !empty($aProvidersCart);
    			break;

    		case BX_PAYMENT_TYPE_RECURRING:
    			$aProvidersSubscription = $this->_oDb->getVendorInfoProvidersRecurring($iVendorId);
    			$bResult = !empty($aProvidersSubscription);
    			break;

    		default:
    			$aProviders = $this->_oDb->getVendorInfoProviders($iVendorId);
    			$bResult = !empty($aProviders);
    	}

		return $bResult;
    }

    /** 
     * @deprecated since version 11.0.0
     * 
     * @see BxPaymentModule::serviceIsProviderOptions
     */
    public function serviceIsPaymentProvider($iVendorId, $sVendorProvider, $sPaymentType = '')
    {
    	return $this->serviceIsProviderOptions($iVendorId, $sVendorProvider, $sPaymentType);
    }

    /** 
     * @deprecated since version 11.0.0
     * 
     * @see BxPaymentModule::serviceGetProviderOptions
     */
    public function serviceGetPaymentProvider($iVendorId, $sVendorProvider, $sPaymentType = '')
    {
    	return $this->serviceGetProviderOptions($iVendorId, $sVendorProvider, $sPaymentType);
    }

    /**
     * @page service Service Calls
     * @section bx_payment Payment
     * @subsection bx_payment-purchase_processing Purchase Processing
     * @subsubsection bx_payment-is_provider_options is_provider_options
     * 
     * @code bx_srv('bx_payment', 'is_provider_options', [...]); @endcode
     * 
     * Check whether the specified vendor has configured the specified payment provider or not.
     *
     * @param $iVendorId integer value with vendor ID.
     * @param $sVendorProvider string value with payment provider name.
     * @param $sPaymentType (optional) string value with payment type. If specified then the vendor will be checked for having the payment provider of the requested type.
     * @return boolean value determining the result of checking.
     * 
     * @see BxPaymentModule::serviceIsProviderOptions
     */
    /** 
     * @ref bx_payment-is_provider_options "is_provider_options"
     */
    public function serviceIsProviderOptions($iVendorId, $sVendorProvider, $sPaymentType = '')
    {
    	$aProvider = $this->serviceGetProviderOptions($iVendorId, $sVendorProvider, $sPaymentType);
    	return $aProvider !== false;
    }

    /**
     * @page service Service Calls
     * @section bx_payment Payment
     * @subsection bx_payment-purchase_processing Purchase Processing
     * @subsubsection bx_payment-get_provider_options get_provider_options
     * 
     * @code bx_srv('bx_payment', 'get_provider_options', [...]); @endcode
     * 
     * Get configuration settings for the payment provider entered by the specified vendor.
     *
     * @param $iVendorId integer value with vendor ID.
     * @param $sVendorProvider string value with payment provider name.
     * @param $sPaymentType (optional) string value with payment type. If specified then the vendor will be checked for having the payment provider of the requested type.
     * @return an array with special format describing the payment provider or false value if something is wrong.
     * 
     * @see BxPaymentModule::serviceGetProviderOptions
     */
    /** 
     * @ref bx_payment-get_provider_options "get_provider_options"
     */
    public function serviceGetProviderOptions($iVendorId, $sVendorProvider, $sPaymentType = '')
    {
    	$aProviders = array();
    	switch($sPaymentType) {
            case BX_PAYMENT_TYPE_SINGLE:
                $aProviders = $this->_oDb->getVendorInfoProvidersSingle($iVendorId);
                break;

            case BX_PAYMENT_TYPE_RECURRING:
                $aProviders = $this->_oDb->getVendorInfoProvidersRecurring($iVendorId);
                break;

            default:
                $aProviders = $this->_oDb->getVendorInfoProviders($iVendorId);
    	}

    	return !empty($aProviders) && !empty($aProviders[$sVendorProvider]) && is_array(($aProviders[$sVendorProvider])) ? $aProviders[$sVendorProvider] : false;
    }

    /**
     * @page service Service Calls
     * @section bx_payment Payment
     * @subsection bx_payment-other Other
     * @subsubsection bx_payment-get_options_default_currency_code get_options_default_currency_code
     * 
     * @code bx_srv('bx_payment', 'get_options_default_currency_code', [...]); @endcode
     * 
     * Get an array with available currencies. Is used in forms.
     *
     * @return an array with available currencies represented as key => value pairs.
     * 
     * @see BxPaymentModule::serviceGetOptionsDefaultCurrencyCode
     */
    /** 
     * @ref bx_payment-get_options_default_currency_code "get_options_default_currency_code"
     */
    public function serviceGetOptionsDefaultCurrencyCode()
    {
        $CNF = &$this->_oConfig->CNF;

        $aCurrencies = BxDolForm::getDataItems($CNF['OBJECT_FORM_PRELISTS_CURRENCIES']);

        $aResult = array();
        foreach($aCurrencies as $sKey => $sValue)
            $aResult[] = array(
                'key' => $sKey,
                'value' => $sValue
            );

        return $aResult;
    }

    /**
     * @page service Service Calls
     * @section bx_payment Payment
     * @subsection bx_payment-other Other
     * @subsubsection bx_payment-get_options_site_admin get_options_site_admin
     * 
     * @code bx_srv('bx_payment', 'get_options_site_admin', [...]); @endcode
     * 
     * Get an array with profiles which can be used as 'Site Admin (Owner)'. 'Site Admin' is a person who will be displayed to buyers when something is selling on behalf of the site.
     *
     * @return an array with profiles represented as key => value pairs.
     * 
     * @see BxPaymentModule::serviceGetOptionsSiteAdmin
     */
    /** 
     * @ref bx_payment-get_options_site_admin "get_options_site_admin"
     */
    public function serviceGetOptionsSiteAdmin()
    {
        $aResult = array(
            array('key' => '', 'value' => _t('_Select_one'))
        );

        $aIds = $this->_oDb->getAdminsIds();
        foreach($aIds as $iId) {
            $aUser = $this->getProfileInfo($iId);

            $aResult[] = array(
                'key' => $iId,
                'value' => $aUser['name']
            );
        }

        return $aResult;
    }

    /**
     * Cart Processing Methods
     */
    public function actionAddToCart($iSellerId, $iModuleId, $iItemId, $iItemCount, $sCustom = '')
    {
        if(empty($sCustom) && bx_get('custom') !== false)
            $sCustom = bx_process_input(bx_get('custom'));

        $aCustom = array();
        if(!empty($sCustom)) {
            $aCustom = unserialize(base64_decode($sCustom));
            if(empty($aCustom) || !is_array($aCustom))
                $aCustom = array();
        }

        $aResult = $this->getObjectCart()->serviceAddToCart($iSellerId, $iModuleId, $iItemId, $iItemCount, $aCustom);
		echoJson($aResult);
    }

    /**
     * Isn't used yet.
     */
    public function actionDeleteFromCart($iSellerId, $iModuleId, $iItemId)
    {
        echoJson($this->getObjectCart()->serviceDeleteFromCart($iSellerId, $iModuleId, $iItemId));
    }

    /**
     * Isn't used yet.
     */
    public function actionEmptyCart($iSellerId)
    {
        echoJson($this->getObjectCart()->serviceDeleteFromCart($iSellerId));
    }

    public function actionSubscribe()
    {
    	$iSellerId = bx_process_input(bx_get('seller_id'), BX_DATA_INT);
    	$sSellerProvider = bx_process_input(bx_get('seller_provider'));
    	$iModuleId = bx_process_input(bx_get('module_id'), BX_DATA_INT);
    	$iItemId = bx_process_input(bx_get('item_id'), BX_DATA_INT);
    	$iItemCount = bx_process_input(bx_get('item_count'), BX_DATA_INT);
    	if(empty($iItemCount))
    		$iItemCount = 1;

        $sRedirect = bx_process_input(bx_get('redirect'));
        $sCustom = bx_process_input(bx_get('custom'));

        $aCustom = array();
        if(!empty($sCustom)) {
            $aCustom = unserialize(base64_decode($sCustom));
            if(empty($aCustom) || !is_array($aCustom))
                $aCustom = array();
        }

        $aResult = $this->getObjectSubscriptions()->serviceSubscribe($iSellerId, $sSellerProvider, $iModuleId, $iItemId, $iItemCount, $sRedirect, $aCustom);
        $bRedirect = !empty($aResult['redirect']);

        if(!empty($aResult['popup'])) {
            $sContent = '';
            $sContent .= $this->_oTemplate->displayCartJs(BX_PAYMENT_TYPE_RECURRING, $iSellerId);
            $sContent .= !empty($aResult['popup']['html']) ? $aResult['popup']['html'] : $aResult['popup'];

			return $this->_oTemplate->displayPageCodeResponse($sContent, false, true);
        }

		if(!empty($aResult['code']))
			return $this->_oTemplate->displayPageCodeError($aResult['message']);

		if(!empty($aResult['message']) && !$bRedirect)
			return $this->_oTemplate->displayPageCodeResponse($aResult['message']);

        if($bRedirect) {
    		header('Location: ' . $aResult['redirect']);
            exit;
        }
    }

    public function actionSubscribeJson()
    {
    	$iSellerId = bx_process_input(bx_get('seller_id'), BX_DATA_INT);
    	$sSellerProvider = bx_process_input(bx_get('seller_provider'));
    	$iModuleId = bx_process_input(bx_get('module_id'), BX_DATA_INT);
    	$iItemId = bx_process_input(bx_get('item_id'), BX_DATA_INT);

    	$iItemCount = bx_process_input(bx_get('item_count'), BX_DATA_INT);
    	if(empty($iItemCount))
            $iItemCount = 1;

        $sItemAddons = '';
        if(bx_get('item_addons') !== false) {
            $sItemAddons = bx_process_input(bx_get('item_addons'));
            if(is_array($sItemAddons))
                $sItemAddons = $this->_oConfig->a2s($sItemAddons);
        }

        $sRedirect = bx_process_input(bx_get('redirect'));
        $sCustom = bx_process_input(bx_get('custom'));

        $aCustom = array();
        if(!empty($sCustom)) {
            $aCustom = unserialize(base64_decode($sCustom));
            if(empty($aCustom) || !is_array($aCustom))
                $aCustom = array();
        }

        echoJson($this->getObjectSubscriptions()->serviceSubscribeWithAddons($iSellerId, $sSellerProvider, $iModuleId, $iItemId, $iItemCount, $sItemAddons, $sRedirect, $aCustom));
    }

    public function actionSubscriptionGetDetails($iId)
    {
        echoJson($this->_oTemplate->displaySubscriptionGetDetails($iId));
    }

    public function actionSubscriptionChangeDetails($iId)
    {
        echoJson($this->_oTemplate->displaySubscriptionChangeDetails($iId));
    }

    public function actionSubscriptionGetBilling($iId)
    {
        echoJson($this->_oTemplate->displaySubscriptionGetBilling($iId));
    }

    public function actionSubscriptionChangeBilling($iId)
    {
        echoJson($this->_oTemplate->displaySubscriptionChangeBilling($iId));
    }

    public function actionSubscriptionCancelation($iId)
    {
        $aResult = array('code' => 1, 'message' => _t('_bx_payment_err_cannot_perform'));

        $aPending = $this->_oDb->getOrderPending(array('type' => 'id', 'id' => $iId));
        if(empty($aPending) || !is_array($aPending))
            return echoJson($aResult);

        $aSubscription = $this->_oDb->getSubscription(array('type' => 'pending_id', 'pending_id' => $iId));
        if(empty($aSubscription) || !is_array($aSubscription))
            return echoJson($aResult);

        $oRecipient = BxDolProfile::getInstance((int)$aPending['seller_id']);
        if(!$oRecipient)
            return echoJson($aResult);

        $mixedResult = $this->isAllowedManage($aPending);
        if($mixedResult !== true)
            return echoJson(array('code' => 2, 'message' => $mixedResult));

        $aTemplate = BxDolEmailTemplates::getInstance()->parseTemplate($this->_oConfig->getPrefix('general') . 'cancelation_request', array(
            'sibscription_id' => $aSubscription['subscription_id'],
            'sibscription_customer' => $aSubscription['customer_id'],
            'sibscription_date' => bx_time_js($aSubscription['date'], BX_FORMAT_DATE, true)
        ), 0, (int)$aPending['client_id']);

        $sEmail = '';
        $oProvider = $this->getObjectProvider($aPending['provider'], $aPending['seller_id']);
        if($oProvider !== false && $oProvider->isActive())
            $sEmail = $oProvider->getOption('cancellation_email');

        if(empty($sEmail))
            $sEmail = $oRecipient->getAccountObject()->getEmail();

        if(!sendMail($sEmail, $aTemplate['Subject'], $aTemplate['Body'], 0, array(), BX_EMAIL_SYSTEM))
            return echoJson($aResult);

        echoJson(array('code' => 0, 'message' => _t('_bx_payment_msg_cancelation_request_sent')));
    }

    public function actionSubscriptionCancel($iId, $mixedGridObject = false)
    {
        $aResult = array('code' => 1, 'message' => _t('_bx_payment_err_cannot_perform'));

        $aPending = $this->_oDb->getOrderPending(array('type' => 'id', 'id' => $iId));
        if(empty($aPending) || !is_array($aPending))
            return echoJson($aResult);

        $mixedResult = $this->isAllowedManage($aPending);
        if($mixedResult !== true)
            return echoJson(array('code' => 2, 'message' => $mixedResult));

        if(!$this->getObjectSubscriptions()->cancel($iId))
            return echoJson($aResult);

        if(empty($mixedGridObject) && bx_get('grid') !== false)
            $mixedGridObject = bx_process_input(bx_get('grid'));

        if(!empty($mixedGridObject) && $aPending['client_id'] == $this->getProfileId()) {
            $oGrid = BxDolGrid::getObjectInstance($mixedGridObject, $this->_oTemplate);
            $oGrid->addQueryParam('client_id', $aPending['client_id']);

            return echoJson(array('object' => $mixedGridObject, 'grid' => $oGrid->getCode(false), 'blink' => array($iId)));
        }
        else
            return echoJson(array('code' => 0, 'message' => _t('_bx_payment_msg_successfully_performed')));
    }

    /**
     * Payment Processing Methods
     */
    public function actionInitializeCheckout($sType)
    {
    	if(!$this->isLogged())
            return $this->_oTemplate->displayPageCodeError($this->_sLangsPrefix . 'err_required_login');

        if(bx_get('seller_id') !== false && bx_get('provider') !== false && bx_get('items') !== false) {
            $iSellerId = bx_process_input(bx_get('seller_id'), BX_DATA_INT);
            $sProvider = bx_process_input(bx_get('provider'));
            $aItems = bx_process_input(bx_get('items'));

            $mixedResult = $this->serviceInitializeCheckout(BX_PAYMENT_TYPE_SINGLE, $iSellerId, $sProvider, $aItems);
            if($mixedResult !== true)
                return $this->_oTemplate->displayPageCodeError($mixedResult);
        }

        header('Location: ' . $this->_oConfig->getUrl('URL_CART'));
        exit;
    }

    /**
     * @page service Service Calls
     * @section bx_payment Payment
     * @subsection bx_payment-purchase_processing Purchase Processing
     * @subsubsection bx_payment-initialize_checkout initialize_checkout
     * 
     * @code bx_srv('bx_payment', 'initialize_checkout', [...]); @endcode
     * 
     * Initialize the checkout process.
     * 
     * @param $sType string value with payment type (single or recurring). 
     * @param $iSellerId integer value with seller ID. 
     * @param $sProvider string value with payment provider name. 
     * @param $aItems (optional) an array with items to be purchased. 
     * @param $sRedirect (optional) string value with redirect URL if it's needed.
     * @param $aCustom (optional) array with custom data to attach to a payment.
     * @return the result depends on the payment provider which is used for processing or represented as string value with error message if something is wrong.
     * 
     * @see BxPaymentModule::serviceInitializeCheckout
     */
    /** 
     * @ref bx_payment-initialize_checkout "initialize_checkout"
     */
    public function serviceInitializeCheckout($sType, $iSellerId, $sProvider, $aItems = array(), $sRedirect = '', $aCustoms = array())
    {
        $bTypeSingle = $sType == BX_PAYMENT_TYPE_SINGLE;
        $bTypeRecurring = $sType == BX_PAYMENT_TYPE_RECURRING;

        if(!is_array($aItems))
            $aItems = array($aItems);

        $iSellerId = (int)$iSellerId;
        if($iSellerId == BX_PAYMENT_EMPTY_ID)
            return $this->_sLangsPrefix . 'err_unknown_vendor';

        $oProvider = $this->getObjectProvider($sProvider, $iSellerId);
        if($oProvider === false || !$oProvider->isActive())
            return $this->_sLangsPrefix . 'err_incorrect_provider';

        $aInfo = $this->getObjectCart()->getInfo($sType, $this->_iUserId, $iSellerId, $aItems);
        if(empty($aInfo) || $aInfo['vendor_id'] == BX_PAYMENT_EMPTY_ID || empty($aInfo['items']))
            return $this->_sLangsPrefix . 'err_empty_order';

        /*
         * Process FREE (price = 0) items for LOGGED IN members
         * WITHOUT processing via payment provider.
         * Note. This section isn't used for now!
         */
        $bProcessedFree = false;
        $sKeyPriceSingle = $this->_oConfig->getKey('KEY_ARRAY_PRICE_SINGLE');
        $sKeyPriceRecurring = $this->_oConfig->getKey('KEY_ARRAY_PRICE_RECURRING');
        foreach($aInfo['items'] as $iIndex => $aItem) {
            if((int)$aInfo['client_id'] == 0)
                continue;

            //--- For Single time payments.
            if($bTypeSingle && (float)$aItem[$sKeyPriceSingle] == 0) {
                $aCart = $this->_oDb->getCartContent($aInfo['client_id']);
                $aCartCustoms = !empty($aCart['customs']) ? unserialize($aCart['customs']) : array();

                $aCartItem = array($aInfo['vendor_id'], $aItem['module_id'], $aItem['id'], $aItem['quantity']);
                $aCartItemCustom = $this->_oConfig->pullCustom($aCartItem, $aCartCustoms);

                $aItemInfo = $this->callRegisterCartItem((int)$aItem['module_id'], array($aInfo['client_id'], $aInfo['vendor_id'], $aItem['id'], $aItem['quantity'], $this->_oConfig->getLicense(), $aCartItemCustom));
                if(!empty($aItemInfo) && is_array($aItemInfo)) {
                    if(!empty($aItemInfo['addons']) && is_array($aItemInfo['addons']))
                        foreach($aItemInfo['addons'] as $sAddon => $aAddon)
                            $this->callRegisterCartItem((int)$aAddon['module_id'], array($aInfo['client_id'], $aInfo['vendor_id'], $aAddon['id'], $aAddon['quantity'], $this->_oConfig->getLicense(), $aCartItemCustom));

                    $bProcessedFree = true;
                }

                $aInfo['items_count'] -= 1;
                unset($aInfo['items'][$iIndex]);

                $aCart['items'] = trim(preg_replace("'" . $this->_oConfig->descriptorA2S($aCartItem) . ":?'", "", $aCart['items']), ":");
                $this->_oDb->setCartItems($aInfo['client_id'], $aCart['items'], $aCartCustoms);
            }

            //--- For Recurring payments.
            if($bTypeRecurring && (float)$aItem[$sKeyPriceRecurring] == 0) {
                //TODO: Process FREE subscription here, if such situation will be possible.
            }
        }

        if(empty($aInfo['items']))
            return $this->_sLangsPrefix . ($bProcessedFree ? 'msg_successfully_processed_free' : 'err_empty_order');

        if($bTypeSingle && (empty($aCustoms) || !is_array($aCustoms))) {
            $aCart = $this->_oDb->getCartContent($aInfo['client_id']);
            $aCartCustoms = !empty($aCart['customs']) ? unserialize($aCart['customs']) : array();

            $aCustoms = array();
            foreach($aInfo['items'] as $aItem) {
                $sCartItem = $this->_oConfig->descriptorA2S(array($aItem['author_id'], $aItem['module_id'], $aItem['id']));
                $aCartItemCustom = $this->_oConfig->getCustom($sCartItem, $aCartCustoms);
                $this->_oConfig->putCustom($sCartItem, $aCartItemCustom, $aCustoms);
            }
        }

        bx_alert($this->getName(), 'before_pending', 0, bx_get_logged_profile_id(), array(
            'client_id' => $this->_iUserId,
            'type' => &$sType,
            'provider' => &$sProvider,
            'cart_info' => &$aInfo,
            'custom' => &$aCustoms,
        ));

        $iPendingId = $this->_oDb->insertOrderPending($this->_iUserId, $sType, $sProvider, $aInfo, $aCustoms);
        if(empty($iPendingId))
            return $this->_sLangsPrefix . 'err_access_db';

        /*
         * Perform Join WITHOUT processing via payment provider
         * if a client ISN'T logged in and has only ONE FREE item in the card.
         * Note. This section isn't used for now because only a member can purchase!
         */
        if((int)$aInfo['client_id'] == 0 && (int)$aInfo['items_count'] == 1) {
            reset($aInfo['items']);
            $aItem = current($aInfo['items']);

            if(!empty($aItem) && $this->_oConfig->getPrice($sType, $aItem)) {
                $this->_oDb->updateOrderPending($iPendingId, array(
                    'order' => $this->_oConfig->getLicense(),
                    'error_code' => '1',
                    'error_msg' => ''
                ));

                $this->getObjectJoin()->performJoin($iPendingId);
            }
        }

        return $oProvider->initializeCheckout($iPendingId, $aInfo, $sRedirect);
    }

    public function actionFinalizeCheckout($sProvider, $mixedVendorId = "")
    {
        $aData = &$_REQUEST;

        $oProvider = $this->getObjectProvider($sProvider, $mixedVendorId);
        if($oProvider === false || !$oProvider->isActive())
            return $this->_oTemplate->displayPageCodeError($this->_sLangsPrefix . 'err_incorrect_provider');

        $aResult = $oProvider->finalizeCheckout($aData);
        if((int)$aResult['code'] != BX_PAYMENT_RESULT_SUCCESS) 
            return $this->_oTemplate->displayPageCodeError($aResult['message']);

        $aPending = $this->_oDb->getOrderPending(array('type' => 'id', 'id' => (int)$aResult['pending_id']));
        $bTypeRecurring = $aPending['type'] == BX_PAYMENT_TYPE_RECURRING;
        if($bTypeRecurring) {
            $sStatus = BX_PAYMENT_SBS_STATUS_UNPAID;
            if(isset($aResult['paid']) && $aResult['paid'])
                $sStatus = BX_PAYMENT_SBS_STATUS_ACTIVE;
            else if(isset($aResult['trial']) && $aResult['trial'])
                $sStatus = BX_PAYMENT_SBS_STATUS_TRIAL;

            $aSubscription = array(
                'customer_id' => $aResult['customer_id'], 
                'subscription_id' => $aResult['subscription_id'],
                'status' => $sStatus
            );

            if(!$this->getObjectSubscriptions()->register($aPending, $aSubscription))
                return $this->_oTemplate->displayPageCodeError($this->_sLangsPrefix . 'err_already_registered');
        }

        $this->onPaymentRegisterBefore($aPending);

        //--- Check "Pay Before Join" situation
        if((int)$aPending['client_id'] == 0)
            $this->getObjectJoin()->performJoin((int)$aPending['id'], isset($aResult['client_name']) ? $aResult['client_name'] : '', isset($aResult['client_email']) ? $aResult['client_email'] : '');

        //--- Register payment for purchased items in associated modules 
        if(!empty($aResult['paid']) || ($bTypeRecurring && !empty($aResult['trial'])))
            $this->registerPayment($aPending);

        bx_alert($this->getName(), 'finalize_checkout', 0, bx_get_logged_profile_id(), array(
            'pending' => $aPending,
            'transactions' => $this->_oDb->getOrderProcessed(array('type' => 'pending_id', 'pending_id' => (int)$aPending['id'])),
            'provider' => $oProvider,
            'message' => &$aResult['message'],
            'result' => &$aResult,
        ));

        if($oProvider->needRedirect()) {
            header('Location: ' . $oProvider->getReturnUrl());
            exit;
        }

        if(!empty($aResult['redirect'])) {
            header('Location: ' . base64_decode(urldecode($aResult['redirect'])));
            exit;
        }

        $this->_oTemplate->displayPageCodeResponse($aResult['message']);
    }

    public function actionFinalizedCheckout($sProvider, $mixedVendorId = "")
    {
        $oProvider = $this->getObjectProvider($sProvider, $mixedVendorId);
        if($oProvider === false || !$oProvider->isActive())
            return $this->_oTemplate->displayPageCodeError($this->_sLangsPrefix . 'err_incorrect_provider');

        $aResult = $oProvider->finalizedCheckout();
        $this->_oTemplate->displayPageCodeResponse($aResult['message']);
    }

    public function actionNotify($sProvider, $mixedVendorId = "")
    {
    	$oProvider = $this->getObjectProvider($sProvider, $mixedVendorId);
        if($oProvider === false || !$oProvider->isActive())
            return $this->_oTemplate->displayPageCodeError($this->_sLangsPrefix . 'err_incorrect_provider');

        $oProvider->notify();
    }
    
    /**
     * The method is needed to pass direct action calls to necessary Payment Provider.
     */
    public function actionCall($sProvider, $sAction, $mixedVendorId = BX_PAYMENT_EMPTY_ID)
    {
        $oProvider = $this->getObjectProvider($sProvider, $mixedVendorId);
        if($oProvider === false)
            BxDolRequest::methodNotFound($sAction, $this->getName());

         $sMethod = 'action' . bx_gen_method_name($sAction);
         if(!method_exists($oProvider, $sMethod))
             BxDolRequest::methodNotFound($sAction, $this->getName());

        return call_user_func_array(array($oProvider, $sMethod), array_slice(func_get_args(), 2));
    }

    public function onProfileJoin($iProfileId)
    {
    	$this->getObjectJoin()->onProfileJoin($iProfileId);
    }

    public function onProfileDelete($iProfileId)
    {
		$this->_oDb->onProfileDelete($iProfileId);
    }

    public function isAllowedPurchase($aItem, $bPerform = false)
    {
        $iUserId = (int)$this->getProfileId();

        $aItemInfo = $this->callGetCartItem((int)$aItem['module_id'], array($aItem['item_id'], isset($aItem['custom']) ? $aItem['custom'] : array()));
        if(empty($aItemInfo))
            return false;

        if(isAdmin())
            return true;

        $aCheckResult = checkActionModule($iUserId, 'purchase', $this->getName(), $bPerform);
        if($aCheckResult[CHECK_ACTION_RESULT] == CHECK_ACTION_RESULT_ALLOWED)
            return true;

        return $aCheckResult[CHECK_ACTION_MESSAGE];
    }

    public function isAllowedSell($aItem, $bPerform = false)
    {
        $iUserId = (int)$this->getProfileId();
        if(!$iUserId)
            return false;

        $aItemInfo = $this->callGetCartItem((int)$aItem['module_id'], array($aItem['item_id']));
        if(empty($aItemInfo))
            return false;

        if(isAdmin())
            return true;

        $aCheckResult = checkActionModule($iUserId, 'sell', $this->getName(), $bPerform);
        if((int)$aItemInfo['author_id'] == $iUserId && $aCheckResult[CHECK_ACTION_RESULT] == CHECK_ACTION_RESULT_ALLOWED)
            return true;

        return $aCheckResult[CHECK_ACTION_MESSAGE];
    }

    public function isAllowedManage($aPending, $bPerform = false)
    {
        $iUserId = (int)$this->getProfileId();

        if($iUserId == $aPending['client_id'] || $iUserId == $aPending['seller_id'] || isAdmin())
            return true;

        $aCheckResult = checkActionModule($iUserId, 'manage any purchase', $this->getName(), $bPerform);
        if($aCheckResult[CHECK_ACTION_RESULT] == CHECK_ACTION_RESULT_ALLOWED)
			return true;

        return $aCheckResult[CHECK_ACTION_MESSAGE];
    }

    public function checkData($iClientId, $iSellerId, $iModuleId, $iItemId, $iItemCount, $aCustom = array())
    {
    	$CNF = &$this->_oConfig->CNF;

		if($iSellerId == BX_PAYMENT_EMPTY_ID || empty($iModuleId) || empty($iItemId) || empty($iItemCount))
            return array('code' => 1, 'message' => _t($CNF['T']['ERR_WRONG_DATA']));

		$iClientId = $this->getProfileId();
        if(empty($iClientId)) {
        	$sLoginUrl = BxDolPermalinks::getInstance()->permalink('page.php?i=login');
            return array('code' => 2, 'eval' => 'window.open("' . $sLoginUrl . '", "_self");');
        }

        $mixedResult = $this->isAllowedPurchase(array('module_id' => $iModuleId, 'item_id' => $iItemId, 'custom' => $aCustom));
        if($mixedResult !== true) {
            if(is_string($mixedResult) && !empty($mixedResult))
                return array('code' => 2, 'message' => $mixedResult);
            else 
                return array('code' => 1, 'message' => _t($CNF['T']['ERR_WRONG_DATA']));
        }

        if($iClientId == $iSellerId)
            return array('code' => 3, 'message' => _t($CNF['T']['ERR_SELF_PURCHASE']));

        $aSeller = $this->getVendorInfo($iSellerId);
        if(!$aSeller['active'])
            return array('code' => 4, 'message' => _t($CNF['T']['ERR_INACTIVE_VENDOR']));

		return true;
    }

    public function registerPayment($mixedPending)
    {
    	$aPending = is_array($mixedPending) ? $mixedPending : $this->_oDb->getOrderPending(array('type' => 'id', 'id' => (int)$mixedPending));
    	if(empty($aPending) || !is_array($aPending))
            return false;

        $sType = $aPending['type'];
        $bTypeSingle = $sType == BX_PAYMENT_TYPE_SINGLE;

        if($bTypeSingle && (int)$aPending['processed'] == 1)
            return true;

        $iClientId = (int)$aPending['client_id'];
        $sLicense = $this->_oConfig->getLicense();
        $aCustoms = !empty($aPending['customs']) ? unserialize($aPending['customs']) : array();

        $aCart = array();
        if($bTypeSingle) {
            $aCart = $this->_oDb->getCartContent($iClientId);
            $aCart['customs'] = !empty($aCart['customs']) ? unserialize($aCart['customs']) : array();
        }

        $bResult = false;
        $aItems = $this->_oConfig->descriptorsM2A($aPending['items']);
        foreach($aItems as $aItem) {
            $sItem = $this->_oConfig->descriptorA2S(array($aItem['vendor_id'], $aItem['module_id'], $aItem['item_id']));
            $aItemCustom = $this->_oConfig->getCustom($sItem, $aCustoms);

            $sMethod = $bTypeSingle ? 'callRegisterCartItem' : 'callRegisterSubscriptionItem';
            $aItemInfo = $this->$sMethod((int)$aItem['module_id'], array($aPending['client_id'], $aPending['seller_id'], $aItem['item_id'], $aItem['item_count'], $aPending['order'], $sLicense, $aItemCustom));
            if(empty($aItemInfo) || !is_array($aItemInfo))
                continue;

            $this->_oDb->insertOrderProcessed(array(
                'pending_id' => $aPending['id'],
                'client_id' => $aPending['client_id'],
                'seller_id' => $aPending['seller_id'],
                'author_id' => $aItem['vendor_id'],
                'module_id' => (int)$aItem['module_id'],
                'item_id' => (int)$aItem['item_id'],
                'item_count' => (int)$aItem['item_count'],
                'amount' => (int)$aItem['item_count'] * $this->_oConfig->getPrice($sType, $aItemInfo),
            	'license' => $sLicense,
            ));

            if($bTypeSingle) {
                $this->_oConfig->pullCustom($sItem, $aCart['customs']);

            	$aCart['items'] = trim(preg_replace("'" . $this->_oConfig->descriptorA2S($aItem) . ":?'", "", $aCart['items']), ":");
            }

            $bResult = true;
        }

        if($bTypeSingle)
            $this->_oDb->setCartItems($iClientId, $aCart['items'], $aCart['customs']);

        if($bResult) {
            $this->_oDb->updateOrderPending($aPending['id'], array('processed' => 1));

            $this->onPaymentRegister($aPending);
        }

        return $bResult;
    }

    public function refundPayment($mixedPending)
    {
        $aPending = is_array($mixedPending) ? $mixedPending : $this->_oDb->getOrderPending(array('type' => 'id', 'id' => (int)$mixedPending));
        if(empty($aPending) || !is_array($aPending))
            return false;

        $bTypeSingle = $aPending['type'] == BX_PAYMENT_TYPE_SINGLE;

        $iCanceled = 0;
        $aOrders = $this->_oDb->getOrderProcessed(array('type' => 'pending_id', 'pending_id' => (int)$aPending['id']));
        foreach($aOrders as $aOrder) {
            $sMethod = $bTypeSingle ? 'callUnregisterCartItem' : 'callUnregisterSubscriptionItem';
            $bResult = $this->$sMethod((int)$aOrder['module_id'], array($aOrder['client_id'], $aOrder['seller_id'], $aOrder['item_id'], $aOrder['item_count'], $aPending['order'], $aOrder['license']));
            if(!$bResult)
                continue;

            if($this->_oDb->deleteOrderProcessed($aOrder['id']))
                $iCanceled++;
        }

        if($iCanceled != count($aOrders))
                return false;

        $bResult = $this->_oDb->deleteOrderPending($aPending['id']);
        if($bResult)
                $this->onPaymentRefund($aPending);

        return $bResult;
    }

    /**
     * @deprecated since version 12.0.0
     * 
     * @use BxPaymentSubscriptions::register instead.
     */
    public function registerSubscription($aPending, $aParams = array())
    {
        return $this->getObjectSubscriptions()->register($aPending, $aParams);
    }

    /**
     * @deprecated since version 12.0.0
     * 
     * @use BxPaymentSubscriptions::cancelLocal instead.
     */
    public function cancelSubscription($mixedPending)
    {
        return $this->getObjectSubscriptions()->cancelLocal($mixedPending);
    }

    public function processTimeTracker()
    {
        if(!defined('BX_DOL_CRON_EXECUTE'))
            return;

        $aSubscriptions = $this->_oDb->getSubscription(array(
            'type' => 'time_tracker',
            'status_active' => BX_PAYMENT_SBS_STATUS_ACTIVE,
            'status_trial' => BX_PAYMENT_SBS_STATUS_TRIAL,
            'status_unpaid' => BX_PAYMENT_SBS_STATUS_UNPAID,
            'pay_attempts_max' => $this->_oConfig->getPayAttemptsMax(),
            'pay_attempts_interval' => $this->_oConfig->getPayAttemptsInterval()
        ));

        if(empty($aSubscriptions) || !is_array($aSubscriptions))
            return;

        foreach($aSubscriptions as $aSubscription) {
            $aPending = $this->_oDb->getOrderPending(array('type' => 'id', 'id' => (int)$aSubscription['pending_id']));
            if(empty($aPending) || !is_array($aPending) || $aPending['type'] != BX_PAYMENT_TYPE_RECURRING) {
                $this->log($aSubscription, 'Time Tracker', 'Cannot process subscription.');
                continue;
            }

            $oProvider = $this->getObjectProvider($aPending['provider'], $aPending['seller_id']);
            if($oProvider === false || !$oProvider->isActive() || !method_exists($oProvider, 'makePayment')) {
                $this->log($aSubscription, 'Time Tracker', 'Payment provider unavailable or incorrect.');
                continue;
            }

            if(!$oProvider->makePayment($aPending)) {
                $this->log($aSubscription, 'Time Tracker', 'Payment cannot be processed.');
                continue;
            }

            if(!$this->getObjectSubscriptions()->prolong($aPending)) {
                $this->log($aSubscription, 'Time Tracker', 'Cannot prolong subscription.');
                continue;
            }

            if(!$this->registerPayment($aPending)) {
                $this->log($aSubscription, 'Time Tracker', 'Cannot register payment.');
                continue;
            }
        }
    }

    public function onPaymentRegisterBefore($aPending, $aResult = array())
    {
        bx_alert('system', 'before_register_payment', 0, $aPending['client_id'], array('pending' => $aPending));
    }

    public function onPaymentRegister($aPending, $aResult = array())
    {
        $bTypeSingle = $aPending['type'] == BX_PAYMENT_TYPE_SINGLE;

        if($bTypeSingle) {
            $aItems = $this->_oConfig->descriptorsM2A($aPending['items']);
            foreach($aItems as $aItem)
                $this->isAllowedPurchase(array('module_id' => $aItem['module_id'], 'item_id' => $aItem['item_id']), true);
        }

        bx_alert('system', 'register_payment', 0, $aPending['client_id'], array('pending' => $aPending));
    }

    public function onPaymentRefund($aPending, $aResult = array())
    {
        bx_alert('system', 'refund_payment', 0, $aPending['client_id'], array('pending' => $aPending));
    }

    public function onSubscriptionCreate($aPending, $aSubscription, $aResult = array())
    {
        $aItems = $this->_oConfig->descriptorsM2A($aPending['items']);
        $this->isAllowedPurchase(array('module_id' => $aItems[0]['module_id'], 'item_id' => $aItems[0]['item_id']), true);

        bx_alert('system', 'create_subscription', 0, $aPending['client_id'], array(
            'pending' => $aPending,
            'subscription' => $aSubscription
        ));
    }

    public function onSubscriptionProlong($aPending, $aSubscription, $aResult = array())
    {
        bx_alert('system', 'prolong_subscription', 0, $aPending['client_id'], array(
            'pending' => $aPending,
            'subscription' => $aSubscription
        ));
    }

    public function onSubscriptionOverdue($aPending, $aSubscription, $aResult = array())
    {
        bx_alert('system', 'overdue_subscription', 0, $aPending['client_id'], array(
            'pending' => $aPending,
            'subscription' => $aSubscription
        ));
    }

    public function onSubscriptionCancel($aPending, $aSubscription, $aResult = array())
    {
        bx_alert('system', 'cancel_subscription', 0, $aPending['client_id'], array(
            'pending' => $aPending,
            'subscription' => $aSubscription
        ));
    }

    public function setSiteSubmenu($sSubmenu, $sSelModule, $sSelName)
    {
        $oSiteSubmenu = BxDolMenu::getObjectInstance('sys_site_submenu');
        if(!$oSiteSubmenu)
            return;

        $sModuleSubmenu = $this->_oConfig->getObject($sSubmenu);
        $oModuleSubmenu = BxDolMenu::getObjectInstance($sModuleSubmenu);
        if(!$oModuleSubmenu) 
            return;

        $oSiteSubmenu->setObjectSubmenu($sModuleSubmenu);
        $oModuleSubmenu->setSelected($sSelModule, $sSelName);
    }

    public function getProviderButtonJs($aCartItem, $aProvider, $sRedirect = '', $aCustom = array())
    {
        $aButtonJs = array();
        $iClientId = $this->getProfileId();

        $sItemAddons = '';
        if(count($aCartItem) == 5)
            $sItemAddons = array_pop($aCartItem);

        list($iSellerId, $iModuleId, $iItemId, $iItemCount) = $aCartItem;

        $oProvider = $this->getObjectProvider($aProvider['name'], $iSellerId);
        if($oProvider !== false && method_exists($oProvider, 'getButtonRecurring')) {
            $aParams = array(
                'sObjNameCart' => $this->_oConfig->getJsObject('cart'),
                'iSellerId' => $iSellerId,
                'iModuleId' => $iModuleId,
                'iItemId' => $iItemId,
                'iItemCount' => $iItemCount,
                'sItemAddons' => $sItemAddons,
                'sRedirect' => $sRedirect,
                'sCustom' => base64_encode(serialize($aCustom))
            );

            $aCartInfo = $this->getObjectCart()->getInfo(BX_PAYMENT_TYPE_RECURRING, $iClientId, $iSellerId, $this->_oConfig->descriptorA2S($aCartItem));
            if(!empty($aCartInfo['items_price']) && !empty($aCartInfo['items']) && is_array($aCartInfo['items'])) {
                $aItem = array_shift($aCartInfo['items']);

                $aParams = array_merge($aParams, array(
                    'iAmount' => (int)round(100 * (float)$aCartInfo['items_price']),
                    'sItemName' => $aItem['name'],
                    'sItemTitle' => $aItem['title']
                ));
            }

            $aButtonJs = $oProvider->getButtonRecurringJs($iClientId, $iSellerId, $aParams);
        }

        if(empty($aButtonJs) || !is_array($aButtonJs))
            $aButtonJs = $this->getObjectSubscriptions()->serviceGetSubscribeJs($iSellerId, $aProvider['name'], $iModuleId, $iItemId, $iItemCount, $sRedirect, $aCustom);

        return $aButtonJs;
    }
}

/** @} */