diff --git a/src/Processing/ImportProcessingService.php b/src/Processing/ImportProcessingService.php index 433c9a0e..967aabdf 100644 --- a/src/Processing/ImportProcessingService.php +++ b/src/Processing/ImportProcessingService.php @@ -149,6 +149,16 @@ public function processQueueItem(int $id) $this->queueService->markQueueEntryAsProcessed($id); } + private function flattenArray(array $arr): array + { + $flattenedArray = []; + array_walk_recursive($arr, function ($item, $key) use (&$flattenedArray) { + $flattenedArray[$key] = $item; + }); + + return $flattenedArray; + } + /** * @param string $configName * @param array $importDataRow @@ -158,7 +168,7 @@ public function processQueueItem(int $id) protected function processElement(string $configName, array $importDataRow, Resolver $resolver, array $mapping) { $element = null; - $importDataRowString = implode(', ', $importDataRow); + $importDataRowString = implode(', ', $this->flattenArray($importDataRow)); try { //resolve data object $createNew = true;