123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293 |
- <?php
- /**
- * Copyright © Magento, Inc. All rights reserved.
- * See COPYING.txt for license details.
- */
- namespace Magento\Customer\Model\ResourceModel\Customer;
- use Magento\Framework\App\ResourceConnection;
- use Magento\Framework\Indexer\IndexerRegistry;
- use Magento\Framework\Indexer\ScopeResolver\FlatScopeResolver;
- use Magento\Customer\Model\Customer;
- /**
- * @deprecated 100.1.0
- */
- class Grid
- {
- /**
- * @var resource
- */
- protected $resource;
- /**
- * @var \Magento\Framework\Indexer\IndexerRegistry
- */
- protected $indexerRegistry;
- /**
- * @var \Magento\Framework\Indexer\ScopeResolver\FlatScopeResolver
- */
- protected $flatScopeResolver;
- /**
- * @param ResourceConnection $resource
- * @param IndexerRegistry $indexerRegistry
- * @param FlatScopeResolver $flatScopeResolver
- */
- public function __construct(
- ResourceConnection $resource,
- IndexerRegistry $indexerRegistry,
- FlatScopeResolver $flatScopeResolver
- ) {
- $this->resource = $resource;
- $this->indexerRegistry = $indexerRegistry;
- $this->flatScopeResolver = $flatScopeResolver;
- }
- /**
- * Synchronize customer grid
- *
- * @return void
- *
- * @deprecated 100.1.0
- */
- public function syncCustomerGrid()
- {
- $indexer = $this->indexerRegistry->get(Customer::CUSTOMER_GRID_INDEXER_ID);
- $customerIds = $this->getCustomerIdsForReindex();
- if ($customerIds) {
- $indexer->reindexList($customerIds);
- }
- }
- /**
- * Retrieve customer IDs for reindex
- *
- * @return array
- *
- * @deprecated 100.1.0
- */
- protected function getCustomerIdsForReindex()
- {
- $connection = $this->resource->getConnection();
- $gridTableName = $this->flatScopeResolver->resolve(Customer::CUSTOMER_GRID_INDEXER_ID, []);
- $select = $connection->select()
- ->from($this->resource->getTableName($gridTableName), 'last_visit_at')
- ->order('last_visit_at DESC')
- ->limit(1);
- $lastVisitAt = $connection->query($select)->fetchColumn();
- $select = $connection->select()
- ->from($this->resource->getTableName('customer_log'), 'customer_id')
- ->where('last_login_at > ?', $lastVisitAt);
- $customerIds = [];
- foreach ($connection->query($select)->fetchAll() as $row) {
- $customerIds[] = $row['customer_id'];
- }
- return $customerIds;
- }
- }
|