![]() 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/magento/module-media-gallery/Model/ResourceModel/ |
<?php /** * Copyright © Magento, Inc. All rights reserved. * See COPYING.txt for license details. */ declare(strict_types=1); namespace Magento\MediaGallery\Model\ResourceModel; use Magento\Framework\App\ResourceConnection; use Magento\Framework\Exception\CouldNotSaveException; use Magento\Framework\Reflection\DataObjectProcessor; use Magento\MediaGalleryApi\Api\Data\AssetInterface; use Magento\MediaGalleryApi\Api\SaveAssetsInterface; use Psr\Log\LoggerInterface; /** * Save media asset to the database */ class SaveAssets implements SaveAssetsInterface { private const TABLE_MEDIA_GALLERY_ASSET = 'media_gallery_asset'; /** * @var ResourceConnection */ private $resourceConnection; /** * @var LoggerInterface */ private $logger; /** * Save constructor. * * @param ResourceConnection $resourceConnection * @param LoggerInterface $logger */ public function __construct( ResourceConnection $resourceConnection, LoggerInterface $logger ) { $this->resourceConnection = $resourceConnection; $this->logger = $logger; } /** * @inheritdoc */ public function execute(array $assets): void { $connection = $this->resourceConnection->getConnection(); $tableName = $this->resourceConnection->getTableName(self::TABLE_MEDIA_GALLERY_ASSET); $failedAssets = []; foreach ($assets as $asset) { try { $record = [ 'id' => $asset->getId(), 'path' => $asset->getPath(), 'title' => $asset->getTitle(), 'description' => $asset->getDescription(), 'source' => $asset->getSource(), 'hash' => $asset->getHash(), 'content_type' => $asset->getContentType(), 'width' => $asset->getWidth(), 'height' => $asset->getHeight(), 'size' => $asset->getSize(), ]; if ($asset->getCreatedAt()) { $record['created_at'] = $asset->getCreatedAt(); } if ($asset->getUpdatedAt()) { $record['updated_at'] = $asset->getUpdatedAt(); } $connection->insertOnDuplicate($tableName, $record); } catch (\Exception $exception) { $this->logger->critical($exception); $failedAssets[] = $asset; } } if (!empty($failedAssets)) { throw new CouldNotSaveException( __( 'Could not save the media assets: %assets', [ 'assets' => implode(' ,', $failedAssets) ] ) ); } } }