ACPT-1471: Import grouped product

Author: adifucan

app/code/Magento/GroupedImportExport/Model/Import/Product/Type/Grouped.php

@@ -95,16 +95,16 @@ public function saveData()
                 if ($this->_type != $rowData[Product::COL_TYPE]) {
                     continue;
                 }
-                $associatedSkusQty = isset($rowData['associated_skus']) ? $rowData['associated_skus'] : null;
+                $associatedSkusQty = $rowData['associated_skus'] ?? null;
                 if (!$this->_entityModel->isRowAllowedToImport($rowData, $rowNum) || empty($associatedSkusQty)) {
                     continue;
                 }
-                $associatedSkusAndQtyPairs = explode(Import::DEFAULT_GLOBAL_MULTI_VALUE_SEPARATOR, $associatedSkusQty);
+
+                $associatedSkusAndQtyPairs = $this->normalizeSkusAndQty($associatedSkusQty);
+
                 $position = 0;
-                foreach ($associatedSkusAndQtyPairs as $associatedSkuAndQty) {
+                foreach ($associatedSkusAndQtyPairs as $associatedSku => $qty) {
                     ++$position;
-                    $associatedSkuAndQty = explode(self::SKU_QTY_DELIMITER, $associatedSkuAndQty);
-                    $associatedSku = isset($associatedSkuAndQty[0]) ? strtolower(trim($associatedSkuAndQty[0])) : null;
                     if (isset($newSku[$associatedSku]) &&
                         in_array($newSku[$associatedSku]['type_id'], $this->allowedProductTypes)
                     ) {
@@ -116,6 +116,7 @@ public function saveData()
                     } else {
                         continue;
                     }
+
                     $scope = $this->_entityModel->getRowScope($rowData);
                     if (Product::SCOPE_DEFAULT == $scope) {
                         $productData = $newSku[strtolower($rowData[Product::COL_SKU])];
@@ -124,11 +125,10 @@ public function saveData()
                         $rowData[$colAttrSet] = $productData['attr_set_code'];
                         $rowData[Product::COL_TYPE] = $productData['type_id'];
                     }
-                    $productId = $productData[$this->getProductEntityLinkField()];
 
+                    $productId = $productData[$this->getProductEntityLinkField()];
                     $linksData['product_ids'][$productId] = true;
                     $linksData['relation'][] = ['parent_id' => $productId, 'child_id' => $linkedProductId];
-                    $qty = empty($associatedSkuAndQty[1]) ? 0 : trim($associatedSkuAndQty[1]);
                     $linksData['attr_product_ids'][$productId] = true;
                     $linksData['position']["{$productId} {$linkedProductId}"] = [
                         'product_link_attribute_id' => $attributes['position']['id'],
@@ -148,6 +148,33 @@ public function saveData()
         return $this;
     }
 
+    /**
+     * Normalize SKU-Quantity pairs.
+     *
+     * @param array|string $associatedSkusQty
+     * @return array
+     */
+    private function normalizeSkusAndQty(array|string $associatedSkusQty): array
+    {
+        $normalizedSkusAndQty = [];
+
+        if (is_string($associatedSkusQty)) {
+            $associatedSkusQtyTemp = explode(Import::DEFAULT_GLOBAL_MULTI_VALUE_SEPARATOR, $associatedSkusQty);
+            foreach ($associatedSkusQtyTemp as $skuQty) {
+                $skuQtyPair = explode(self::SKU_QTY_DELIMITER, $skuQty);
+                $associatedSku = strtolower(trim($skuQtyPair[0]));
+                $associatedQty = empty($skuQtyPair[1]) ? 0 : trim($skuQtyPair[1]);
+                $normalizedSkusAndQty[$associatedSku] = $associatedQty;
+            }
+        } elseif (is_array($associatedSkusQty)) {
+            foreach ($associatedSkusQty as $associatedSku => $associatedQty) {
+                $normalizedSkusAndQty[strtolower(trim($associatedSku))] = $associatedQty;
+            }
+        }
+
+        return $normalizedSkusAndQty;
+    }
+
     /**
      * Get product entity identifier field
      *