问Shopware 6导入性能

EN

    /*
     * Amount of entities to execute per round.
     * */
    public const BATCH = 200;

    public function execute()
    {
        // read products from import xml file
        $importProducts = $this->loadProducts();
        $csvBatch = array_chunk($importProducts, self::BATCH);
        $productNumbers = [];

        foreach ($csvBatch as $products) {
            $productNumbers[] = $this->processImportProducts($products, false);
        }

        $this->deleteProducts(array_merge(...$productNumbers));

        return 0;
    }

    private function processImportProducts($productsData)
    {
        $products = [];
        $productNumbers = [];

        foreach ($productsData as $product) {
            $products[$product['ProductNo']] = $this->importProducts($product);
            $productNumbers[] = $product['ProductNo'];
        }

        // upsert product
        try {
            $this->cleanProductProperties($products, $this->context);
            $this->productRepository->upsert(array_values($products), $this->context);
        } catch (WriteException $exception) {
            $this->logger->info(' ');
            $this->logger->info('<error>Products could not be imported. Message: '. $exception->getMessage() .'</error>');
        }
        unset($products);

        return $productNumbers;
    }


    private function cleanProductProperties($products, $context)
    {
        $productIds = array_values(array_map(static function($product){
            return $product['id'];
        }, $products));

        $productProperties = $this->productPropertyRepository->searchIds(
            (new Criteria())->addFilter(new EqualsAnyFilter('productId', $productIds)),
            $context
        );

        $productRelationsToDelete = [];
        foreach($productProperties->getIds() as $productProperty) {
            $productRelationsToDelete[] = [
                'productId' => $productProperty['product_id'],
                'optionId' => $productProperty['property_group_option_id']
            ];
        }

        $this->productPropertyRepository->delete($productRelationsToDelete, $context);

        unset($productIds, $productProperties, $productRelationsToDelete);
    }

    private function importProducts($product)
    {
        // search product by productNumber
        $productSearch = $this->productRepository->search(
            (new Criteria())->addFilter(new EqualsFilter('productNumber', $productNumber)),
            $this->context
        );

        $existingProduct = $productSearch->getEntities()->first();
        if ($existingProduct) {
            $productId = $existingProduct->getId();
        } else {
            $productId = Uuid::randomHex();
        }

        $productData = [
            'id' => $productId,
            'productNumber' => $productNumber,
            'price' => [
                [
                    'currencyId' => Defaults::CURRENCY,
                    'gross' => 0,
                    'net' => 0,
                    'linked' => true
                ]
            ],
            'stock' => 99999,
            'taxId' => $this->taxId,
            'name' => $productNames,
            'description' => $productDescriptions
        ];

        return $productData;
    }