reportProcessor = $reportProcessor;
$this->historyModel = $historyModel;
$this->reportHelper = $reportHelper;
$this->escaper = $escaper
?? ObjectManager::getInstance()->get(Escaper::class);
$this->backendUrl = $backendUrl
?? ObjectManager::getInstance()->get(UrlInterface::class);
}
/**
* Add Error Messages for Import
*
* @param ProcessingErrorAggregatorInterface $errorAggregator
* @return string
*/
public function renderMessages(
ProcessingErrorAggregatorInterface $errorAggregator
): string {
$message = '';
$counter = 0;
$escapedMessages = [];
foreach ($this->getErrorMessages($errorAggregator) as $error) {
$escapedMessages[] = (++$counter) . '. ' . $this->escaper->escapeHtml($error);
if ($counter >= ImportResult::LIMIT_ERRORS_MESSAGE) {
break;
}
}
if ($errorAggregator->hasFatalExceptions()) {
foreach ($this->getSystemExceptions($errorAggregator) as $error) {
$escapedMessages[] = $this->escaper->escapeHtml($error->getErrorMessage())
. ' '
. __('Show more') . '' . __('Additional data') . ': '
. $this->escaper->escapeHtml($error->getErrorDescription()) . '
';
}
}
$message .= implode('
', $escapedMessages);
return '' . __('Following Error(s) has been occurred during importing process:') . '
'
. '';
}
/**
* Get all Error Messages from Import Results
*
* @param ProcessingErrorAggregatorInterface $errorAggregator
* @return array
*/
public function getErrorMessages(ProcessingErrorAggregatorInterface $errorAggregator): array
{
$messages = [];
$rowMessages = $errorAggregator->getRowsGroupedByErrorCode([], [AbstractEntity::ERROR_CODE_SYSTEM_EXCEPTION]);
foreach ($rowMessages as $errorCode => $rows) {
$messages[] = $errorCode . ' ' . __('in row(s):') . ' ' . implode(', ', $rows);
}
return $messages;
}
/**
* Get System Generated Exception
*
* @param ProcessingErrorAggregatorInterface $errorAggregator
* @return ProcessingError[]
*/
public function getSystemExceptions(ProcessingErrorAggregatorInterface $errorAggregator): array
{
return $errorAggregator->getErrorsByCode([AbstractEntity::ERROR_CODE_SYSTEM_EXCEPTION]);
}
/**
* Generate Error Report File
*
* @param ProcessingErrorAggregatorInterface $errorAggregator
* @return string
*/
public function createErrorReport(ProcessingErrorAggregatorInterface $errorAggregator): string
{
$this->historyModel->loadLastInsertItem();
$sourceFile = $this->reportHelper->getReportAbsolutePath($this->historyModel->getImportedFile());
$writeOnlyErrorItems = true;
if ($this->historyModel->getData('execution_time') == ModelHistory::IMPORT_VALIDATION) {
$writeOnlyErrorItems = false;
}
$fileName = $this->reportProcessor->createReport($sourceFile, $errorAggregator, $writeOnlyErrorItems);
$this->historyModel->addErrorReportFile($fileName);
return $fileName;
}
/**
* Get Import History Url
*
* @param string $fileName
* @return string
*/
public function createDownloadUrlImportHistoryFile($fileName): string
{
return $this->backendUrl->getUrl(ImportResult::IMPORT_HISTORY_FILE_DOWNLOAD_ROUTE, ['filename' => $fileName]);
}
}