123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990 |
- <?php
- /**
- * Copyright © Magento, Inc. All rights reserved.
- * See COPYING.txt for license details.
- */
- namespace Magento\Sales\Cron;
- use Magento\Store\Model\StoresConfig;
- /**
- * Class CleanExpiredQuotes
- */
- class CleanExpiredQuotes
- {
- const LIFETIME = 86400;
- /**
- * @var StoresConfig
- */
- protected $storesConfig;
- /**
- * @var \Magento\Quote\Model\ResourceModel\Quote\CollectionFactory
- */
- protected $quoteCollectionFactory;
- /**
- * @var array
- */
- protected $expireQuotesFilterFields = [];
- /**
- * @param StoresConfig $storesConfig
- * @param \Magento\Quote\Model\ResourceModel\Quote\CollectionFactory $collectionFactory
- */
- public function __construct(
- StoresConfig $storesConfig,
- \Magento\Quote\Model\ResourceModel\Quote\CollectionFactory $collectionFactory
- ) {
- $this->storesConfig = $storesConfig;
- $this->quoteCollectionFactory = $collectionFactory;
- }
- /**
- * Clean expired quotes (cron process)
- *
- * @return void
- */
- public function execute()
- {
- $lifetimes = $this->storesConfig->getStoresConfigByPath('checkout/cart/delete_quote_after');
- foreach ($lifetimes as $storeId => $lifetime) {
- $lifetime *= self::LIFETIME;
- /** @var $quotes \Magento\Quote\Model\ResourceModel\Quote\Collection */
- $quotes = $this->quoteCollectionFactory->create();
- $quotes->addFieldToFilter('store_id', $storeId);
- $quotes->addFieldToFilter('updated_at', ['to' => date("Y-m-d", time() - $lifetime)]);
- $quotes->addFieldToFilter('is_active', 0);
- foreach ($this->getExpireQuotesAdditionalFilterFields() as $field => $condition) {
- $quotes->addFieldToFilter($field, $condition);
- }
- $quotes->walk('delete');
- }
- }
- /**
- * Retrieve expire quotes additional fields to filter
- *
- * @return array
- */
- protected function getExpireQuotesAdditionalFilterFields()
- {
- return $this->expireQuotesFilterFields;
- }
- /**
- * Set expire quotes additional fields to filter
- *
- * @param array $fields
- * @return void
- */
- public function setExpireQuotesAdditionalFilterFields(array $fields)
- {
- $this->expireQuotesFilterFields = $fields;
- }
- }
|