Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory :  /home/corals/old/vendor/mageplaza/module-smtp/Controller/Adminhtml/Smtp/Sync/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

<?php
/**
 * Mageplaza
 *
 * NOTICE OF LICENSE
 *
 * This source file is subject to the Mageplaza.com license that is
 * available through the world-wide-web at this URL:
 * https://www.mageplaza.com/LICENSE.txt
 *
 * DISCLAIMER
 *
 * Do not edit or add to this file if you wish to upgrade this extension to newer
 * version in the future.
 *
 * @category    Mageplaza
 * @package     Mageplaza_Smtp
 * @copyright   Copyright (c) Mageplaza (https://www.mageplaza.com/)
 * @license     https://www.mageplaza.com/LICENSE.txt
 */

namespace Mageplaza\Smtp\Controller\Adminhtml\Smtp\Sync;

use Exception;
use Magento\Backend\App\Action;
use Magento\Backend\App\Action\Context;
use Magento\Customer\Model\ResourceModel\Customer\Collection;
use Magento\Customer\Model\ResourceModel\Customer\CollectionFactory as CustomerCollectionFactory;
use Magento\Framework\App\ResponseInterface;
use Magento\Framework\Controller\ResultInterface;
use Magento\Framework\Exception\LocalizedException;
use Magento\Newsletter\Model\ResourceModel\Subscriber\Collection as SubscriberCollection;
use Magento\Newsletter\Model\ResourceModel\Subscriber\CollectionFactory as SubscriberCollectionFactory;
use Magento\Newsletter\Model\Subscriber;
use Magento\Sales\Model\ResourceModel\Order\CollectionFactory as OrderCollectionFactory;
use Mageplaza\Smtp\Helper\Data;
use Mageplaza\Smtp\Helper\EmailMarketing;
use Magento\Sales\Model\ResourceModel\Order\Collection as OrderCollection;
use Magento\Framework\Phrase;
use Mageplaza\Smtp\Model\Config\Source\Newsletter;
use Mageplaza\Smtp\Model\Config\Source\SyncOptions;
use Mageplaza\Smtp\Model\Config\Source\SyncType;

/**
 * Class Estimate
 * @package Mageplaza\Smtp\Controller\Adminhtml\Smtp\Sync
 */
class Estimate extends Action
{
    /**
     * Authorization level of a basic admin session
     *
     * @see _isAllowed()
     */
    const ADMIN_RESOURCE = 'Mageplaza_Smtp::email_marketing';

    /**
     * @var EmailMarketing
     */
    protected $emailMarketing;

    /**
     * @var string
     */
    protected $websiteIdField = 'website_id';

    /**
     * @var string
     */
    protected $storeIdField = 'store_id';

    /**
     * @var CustomerCollectionFactory
     */
    protected $customerCollectionFactory;

    /**
     * @var OrderCollectionFactory
     */
    protected $orderCollectionFactory;

    /**
     * @var SubscriberCollectionFactory
     */
    protected $subscriberCollectionFactory;

    /**
     * @var Data
     */
    protected $helperData;

    /**
     * Estimate constructor.
     *
     * @param Context $context
     * @param EmailMarketing $emailMarketing
     * @param CustomerCollectionFactory $customerCollectionFactory
     * @param OrderCollectionFactory $orderCollectionFactory
     * @param SubscriberCollectionFactory $subscriberCollectionFactory
     * @param Data $helperData
     */
    public function __construct(
        Context $context,
        EmailMarketing $emailMarketing,
        CustomerCollectionFactory $customerCollectionFactory,
        OrderCollectionFactory $orderCollectionFactory,
        SubscriberCollectionFactory $subscriberCollectionFactory,
        Data $helperData
    ) {
        $this->emailMarketing              = $emailMarketing;
        $this->customerCollectionFactory   = $customerCollectionFactory;
        $this->orderCollectionFactory      = $orderCollectionFactory;
        $this->subscriberCollectionFactory = $subscriberCollectionFactory;
        $this->helperData                  = $helperData;

        parent::__construct($context);
    }

    /**
     * @return ResponseInterface|ResultInterface
     */
    public function execute()
    {
        try {

            if (!$this->emailMarketing->getAppID() || !$this->emailMarketing->getSecretKey()) {
                throw new LocalizedException(__('App ID or Secret Key is empty'));
            }

            $daysRange   = $this->getRequest()->getParam('daysRange');
            $from        = $this->getRequest()->getParam('from');
            $to          = $this->getRequest()->getParam('to');
            $type        = $this->getRequest()->getParam('type');
            $syncOptions = $this->getRequest()->getParam('syncOptions');
            $collection  = $this->prepareCollection($type);

            if ($syncOptions === SyncOptions::NOT_SYNC) {
                if ($this->helperData->versionCompare('2.4.0')) {
                    $collection->getSelect()->where('mp_smtp_email_marketing_synced = ?', 0);
                } else {
                    $collection->addFieldToFilter('mp_smtp_email_marketing_synced', 0);
                }
            }

            $storeId   = $this->getRequest()->getParam('storeId');
            $websiteId = $this->getRequest()->getParam('websiteId');

            if ($storeId) {
                $collection->addFieldToFilter($this->storeIdField, $storeId);
            }

            if ($websiteId) {
                $collection->addFieldToFilter($this->websiteIdField, $websiteId);
            }

            if (!$collection instanceof SubscriberCollection && $daysRange !== 'lifetime'
                && $query = $this->emailMarketing->queryExpr(
                    $daysRange,
                    $from,
                    $to,
                    $collection instanceof Collection ? 'e' : 'main_table'
                )
            ) {
                $collection->getSelect()->where($query);
            }

            $ids             = $collection->getAllIds();
            $result['ids']   = $ids;
            $result['total'] = count($ids);

            if ($result['total'] === 0) {
                $result['message'] = $this->getZeroMessage($type);
            }

            $result['status'] = true;
        } catch (Exception $e) {
            $result = [
                'status'  => false,
                'message' => $e->getMessage()
            ];
        }

        return $this->getResponse()->representJson(EmailMarketing::jsonEncode($result));
    }

    /**
     * @param int $type
     *
     * @return bool|Collection|SubscriberCollection|OrderCollection
     */
    public function prepareCollection($type)
    {
        switch ($type) {
            case SyncType::CUSTOMERS:
                return $this->customerCollectionFactory->create();
            case SyncType::ORDERS:
                $orderCollection      = $this->orderCollectionFactory->create();
                $storeTable           = $orderCollection->getTable('store');
                $this->websiteIdField = 'store_table.website_id';
                $this->storeIdField   = 'main_table.store_id';
                $orderCollection->getSelect()->join(
                    ['store_table' => $storeTable],
                    'main_table.store_id = store_table.store_id',
                    [
                        $this->websiteIdField
                    ]
                );

                return $orderCollection;
            case SyncType::SUBSCRIBERS:
                $collection = $this->subscriberCollectionFactory->create();

                if ($this->emailMarketing->getSubscriberConfig() === Newsletter::SUBSCRIBED) {
                    $collection->addFieldToFilter('subscriber_status', ['eq' => Subscriber::STATUS_SUBSCRIBED]);
                }

                return $collection;
            default:
                return false;
        }
    }

    /**
     * @param int $type
     *
     * @return Phrase|string
     */
    public function getZeroMessage($type)
    {
        switch ($type) {
            case SyncType::CUSTOMERS:
                return __('No customers to synchronize.');
            case SyncType::ORDERS:
                return __('No Orders to synchronize.');
            case SyncType::SUBSCRIBERS:
                return __('No subscriber to synchronize.');
            default:
                return '';
        }
    }
}