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/amasty/product-attachment/Model/File/FileScope/SaveProcessors/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

<?php
/**
 * @author Amasty Team
 * @copyright Copyright (c) Amasty (https://www.amasty.com)
 * @package Product Attachments Base for Magento 2
 */

namespace Amasty\ProductAttachment\Model\File\FileScope\SaveProcessors;

use Amasty\ProductAttachment\Api\Data\FileInterface;
use Amasty\ProductAttachment\Api\Data\FileScopeInterface;
use Amasty\ProductAttachment\Controller\Adminhtml\RegistryConstants;
use Amasty\ProductAttachment\Model\File\FileScope\ResourceModel\FileStore;
use Amasty\ProductAttachment\Model\File\FileScope\ResourceModel\FileStoreCategory;
use Amasty\ProductAttachment\Model\File\FileScope\ResourceModel\FileStoreProduct;
use Magento\Framework\App\RequestInterface;

class File implements FileScopeSaveProcessorInterface
{
    /**
     * @var RequestInterface
     */
    private $request;

    /**
     * @var FileStore
     */
    private $fileStoreResource;

    /**
     * @var FileStoreCategory
     */
    private $fileStoreCategory;

    /**
     * @var FileStoreProduct
     */
    private $fileStoreProduct;

    /**
     * @var array
     */
    private $savedData;

    /**
     * @var \Amasty\ProductAttachment\Api\Data\FileInterface
     */
    private $file;

    /**
     * @var int
     */
    private $store;

    public function __construct(
        RequestInterface $request,
        FileStore $fileStoreResource,
        FileStoreCategory $fileStoreCategory,
        FileStoreProduct $fileStoreProduct
    ) {
        $this->request = $request;
        $this->fileStoreResource = $fileStoreResource;
        $this->fileStoreCategory = $fileStoreCategory;
        $this->fileStoreProduct = $fileStoreProduct;
    }

    /**
     * @inheritdoc
     */
    public function execute($params)
    {
        /** @var \Amasty\ProductAttachment\Api\Data\FileInterface $file */
        $this->file = $params[RegistryConstants::FILE];
        $this->store = isset($params[RegistryConstants::STORE]) ? (int)$params[RegistryConstants::STORE]
            : (int)$this->request->getParam('store');
        $storeId = $this->store;

        $this->savedData = [
            FileScopeInterface::FILE_ID => $this->file->getFileId(),
            FileScopeInterface::FILENAME => $this->file->getData(FileScopeInterface::FILENAME),
            FileScopeInterface::LABEL => $this->file->getData(FileScopeInterface::LABEL),
            FileScopeInterface::IS_VISIBLE => $this->file->getData(FileScopeInterface::IS_VISIBLE),
            FileScopeInterface::CUSTOMER_GROUPS => $this->file->getData(
                FileScopeInterface::CUSTOMER_GROUPS . '_output'
            ),
            FileScopeInterface::INCLUDE_IN_ORDER => $this->file->getData(FileScopeInterface::INCLUDE_IN_ORDER),
        ];
        $fileStoreId = $this->saveFileStoreRelation();
        if (!$this->file->getData('use_default_categories')) {
            $this->saveFileCategoriesRelation($fileStoreId);
        } elseif ($storeId) {
            $this->fileStoreCategory->deleteAllByStore($this->file->getFileId(), $storeId);
        }

        if (!$this->file->getData('use_default_products')) {
            $this->saveFileProductsRelation($fileStoreId);
        } elseif ($storeId) {
            $this->fileStoreProduct->deleteAllByStore($this->file->getFileId(), $storeId);
        }
    }

    /**
     * @return int|null
     */
    public function saveFileStoreRelation()
    {
        $fileId = $this->file->getFileId();
        $storeId = $this->store;
        $fileStoreId = null;

        $defaultFileStoreData = $this->fileStoreResource->getByStoreId($fileId, 0);
        $savedData = $this->savedData;

        $savedData[FileScopeInterface::STORE_ID] = 0;

        if ($storeId === 0 || !$defaultFileStoreData) {
            $fileStoreId = $this->fileStoreResource->saveFileStoreData(
                $defaultFileStoreData ? array_merge($defaultFileStoreData, $savedData) : $savedData
            );
        }

        if ($storeId) {
            $fileStoreData = $this->fileStoreResource->getByStoreId($fileId, $storeId);
            if ($fileStoreData) {
                $savedData = array_merge($fileStoreData, $savedData);
            }
            $savedData[FileScopeInterface::STORE_ID] = $storeId;
            $fileStoreId = $this->fileStoreResource->saveFileStoreData($savedData);
        }

        return $fileStoreId;
    }

    /**
     * @param int|null $fileStoreId
     */
    public function saveFileCategoriesRelation($fileStoreId)
    {
        $fileId = $this->file->getFileId();
        $storeId = $this->store;

        $categories = $this->file->getData(FileInterface::CATEGORIES);
        if (empty($categories)) {
            $this->fileStoreCategory->deleteAllByStore($fileId, $storeId);
            if ($storeId && !$this->file->getData('use_default_categories')) {
                $this->fileStoreCategory->insertFileStoreCategoryData(
                    [
                        FileScopeInterface::FILE_ID => $this->file->getFileId(),
                        FileScopeInterface::FILE_STORE_ID => $fileStoreId,
                        FileScopeInterface::CATEGORY_ID => 0,
                        FileScopeInterface::STORE_ID => $storeId
                    ]
                );
            }
        } else {
            $currentCategories = $this->fileStoreCategory->getStoreCategoryIdsByStoreId($fileId, $storeId);
            foreach ($categories as $categoryId) {
                if (array_key_exists($categoryId, $currentCategories)) {
                    $data = [
                        FileScopeInterface::FILE_ID => $this->file->getFileId(),
                        FileScopeInterface::FILE_STORE_CATEGORY_ID =>
                            $currentCategories[$categoryId][FileScopeInterface::FILE_STORE_CATEGORY_ID],
                        FileScopeInterface::FILE_STORE_ID => $fileStoreId,
                        FileScopeInterface::STORE_ID => $storeId
                    ];
                    if ($position = $this->file->getData(FileScopeInterface::POSITION)) {
                        $data[FileScopeInterface::POSITION] = $position;
                    }
                    $this->fileStoreCategory->updateFileStoreCategoryData($data);
                    unset($currentCategories[$categoryId]);
                } else {
                    $data = [
                        FileScopeInterface::FILE_ID => $this->file->getFileId(),
                        FileScopeInterface::FILE_STORE_ID => $fileStoreId,
                        FileScopeInterface::CATEGORY_ID => (int)$categoryId,
                        FileScopeInterface::STORE_ID => $storeId
                    ];
                    if ($position = $this->file->getData(FileScopeInterface::POSITION)) {
                        $data[FileScopeInterface::POSITION] = $position;
                    }
                    $this->fileStoreCategory->insertFileStoreCategoryData($data);
                }
            }
            if (!empty($currentCategories)) {
                $categoriesToDelete = [];
                foreach ($currentCategories as $categoryStore) {
                    $categoriesToDelete[] = $categoryStore[FileScopeInterface::FILE_STORE_CATEGORY_ID];
                }
                $this->fileStoreCategory->deleteByStoreCategoryIds($categoriesToDelete);
            }
        }
    }

    /**
     * @param int|null $fileStoreId
     */
    public function saveFileProductsRelation($fileStoreId)
    {
        $fileId = $this->file->getFileId();
        $storeId = $this->store;

        $products = $this->file->getData(FileInterface::PRODUCTS);
        if (empty($products)) {
            $this->fileStoreProduct->deleteAllByStore($fileId, $storeId);
            if ($storeId && !$this->file->getData('use_default_products')) {
                $this->fileStoreProduct->insertFileStoreProductData(
                    [
                        FileScopeInterface::FILE_ID => $this->file->getFileId(),
                        FileScopeInterface::FILE_STORE_ID => $fileStoreId,
                        FileScopeInterface::PRODUCT_ID => 0,
                        FileScopeInterface::STORE_ID => $storeId
                    ]
                );
            }
        } else {
            $currentProducts = $this->fileStoreProduct->getStoreProductIdsByStoreId($fileId, $storeId);
            foreach ($products as $productId) {
                if (array_key_exists($productId, $currentProducts)) {
                    $data = [
                        FileScopeInterface::FILE_ID => $this->file->getFileId(),
                        FileScopeInterface::FILE_STORE_PRODUCT_ID =>
                            $currentProducts[$productId][FileScopeInterface::FILE_STORE_PRODUCT_ID],
                        FileScopeInterface::FILE_STORE_ID => $fileStoreId,
                        FileScopeInterface::STORE_ID => $storeId
                    ];
                    if ($position = $this->file->getData(FileScopeInterface::POSITION)) {
                        $data[FileScopeInterface::POSITION] = $position;
                    }
                    $this->fileStoreProduct->updateFileStoreProductData($data);
                    unset($currentProducts[$productId]);
                } else {
                    $data = [
                        FileScopeInterface::FILE_ID => $this->file->getFileId(),
                        FileScopeInterface::FILE_STORE_ID => $fileStoreId,
                        FileScopeInterface::PRODUCT_ID => (int)$productId,
                        FileScopeInterface::STORE_ID => $storeId
                    ];
                    if ($position = $this->file->getData(FileScopeInterface::POSITION)) {
                        $data[FileScopeInterface::POSITION] = $position;
                    }
                    $this->fileStoreProduct->insertFileStoreProductData($data);
                }
            }
            if (!empty($currentProducts)) {
                $productsToDelete = [];
                foreach ($currentProducts as $productStore) {
                    $productsToDelete[] = $productStore[FileScopeInterface::FILE_STORE_PRODUCT_ID];
                }
                $this->fileStoreProduct->deleteByStoreProductIds($productsToDelete);
            }
        }
    }
}