6
6
namespace Magento \CustomerImportExport \Model \Import ;
7
7
8
8
use Magento \ImportExport \Model \Import \ErrorProcessing \ProcessingErrorAggregatorInterface ;
9
+ use Magento \Customer \Model \Indexer \Processor ;
9
10
10
11
/**
11
12
* Import entity customer combined model
@@ -148,6 +149,11 @@ class CustomerComposite extends \Magento\ImportExport\Model\Import\AbstractEntit
148
149
*/
149
150
protected $ masterAttributeCode = 'email ' ;
150
151
152
+ /**
153
+ * @var Processor
154
+ */
155
+ private $ indexerProcessor ;
156
+
151
157
/**
152
158
* @param \Magento\Framework\Stdlib\StringUtils $string
153
159
* @param \Magento\Framework\App\Config\ScopeConfigInterface $scopeConfig
@@ -158,6 +164,7 @@ class CustomerComposite extends \Magento\ImportExport\Model\Import\AbstractEntit
158
164
* @param \Magento\CustomerImportExport\Model\ResourceModel\Import\CustomerComposite\DataFactory $dataFactory
159
165
* @param \Magento\CustomerImportExport\Model\Import\CustomerFactory $customerFactory
160
166
* @param \Magento\CustomerImportExport\Model\Import\AddressFactory $addressFactory
167
+ * @param Processor $indexerProcessor
161
168
* @param array $data
162
169
* @throws \Magento\Framework\Exception\LocalizedException
163
170
*
@@ -173,6 +180,7 @@ public function __construct(
173
180
\Magento \CustomerImportExport \Model \ResourceModel \Import \CustomerComposite \DataFactory $ dataFactory ,
174
181
\Magento \CustomerImportExport \Model \Import \CustomerFactory $ customerFactory ,
175
182
\Magento \CustomerImportExport \Model \Import \AddressFactory $ addressFactory ,
183
+ Processor $ indexerProcessor ,
176
184
array $ data = []
177
185
) {
178
186
parent ::__construct ($ string , $ scopeConfig , $ importFactory , $ resourceHelper , $ resource , $ errorAggregator , $ data );
@@ -230,6 +238,7 @@ public function __construct(
230
238
} else {
231
239
$ this ->_nextCustomerId = $ resourceHelper ->getNextAutoincrement ($ this ->_customerEntity ->getEntityTable ());
232
240
}
241
+ $ this ->indexerProcessor = $ indexerProcessor ;
233
242
}
234
243
235
244
/**
@@ -273,11 +282,12 @@ protected function _importData()
273
282
$ this ->countItemsCreated += $ this ->_customerEntity ->getCreatedItemsCount ();
274
283
$ this ->countItemsUpdated += $ this ->_customerEntity ->getUpdatedItemsCount ();
275
284
$ this ->countItemsDeleted += $ this ->_customerEntity ->getDeletedItemsCount ();
276
-
277
285
if ($ this ->getBehavior () != \Magento \ImportExport \Model \Import::BEHAVIOR_DELETE ) {
278
- return $ result && $ this ->_addressEntity ->setCustomerAttributes ($ this ->_customerAttributes )->importData ();
286
+ $ result = $ result && $ this ->_addressEntity ->setCustomerAttributes ($ this ->_customerAttributes )->importData ();
287
+ }
288
+ if ($ result ) {
289
+ $ this ->indexerProcessor ->markIndexerAsInvalid ();
279
290
}
280
-
281
291
return $ result ;
282
292
}
283
293
0 commit comments