Merge pull request #12 from justbetter/feature/adjust-product-creation

Adjust product creation
justbetter · Jul 24, 2024 · 76878c9 · 76878c9
2 parents 3776cac + 5b32100
commit 76878c9
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 6 deletions.
diff --git a/src/Actions/CheckKnownProducts.php b/src/Actions/CheckKnownProducts.php
@@ -21,7 +21,7 @@ public function handle(array $skus = []): void
     {
         $productChunks = MagentoProduct::query()
             ->where('exists_in_magento', false)
-            ->when(count($skus), fn (Builder $query): Builder => $query->whereIn('sku', $skus)) /** @phpstan-ignore-line */
+            ->when(count($skus), fn (Builder $query): Builder => $query->whereIn('sku', $skus))
             ->get()
             ->chunk(static::CHUNK_SIZE);
 

diff --git a/src/Actions/ProcessMagentoSkus.php b/src/Actions/ProcessMagentoSkus.php
@@ -36,13 +36,17 @@ public function process(Enumerable $skus): void
 
         $knownProductsThatDontExistQuery->update(['exists_in_magento' => true, 'updated_at' => now()]);
 
-        $missingProducts = $skus->diff($knownProductsThatDontExist->pluck('sku'))
-            ->map(fn (string $sku) => ['sku' => $sku, 'exists_in_magento' => true, 'created_at' => now(), 'updated_at' => now()]);
+        $missingProducts = $skus->diff($knownProductsThatDontExist->pluck('sku'));
 
-        MagentoProduct::query()
-            ->insert($missingProducts->toArray());
+        $missingProducts
+            ->each(fn (string $sku) => MagentoProduct::query()->updateOrCreate(
+                ['sku' => $sku],
+                ['exists_in_magento' => true]
+            ));
 
-        $knownProductsThatDontExist->pluck('sku')->merge($missingProducts->pluck('sku'))
+        $knownProductsThatDontExist
+            ->pluck('sku')
+            ->merge($missingProducts)
             ->each(fn (string $sku) => event(new ProductCreatedInMagentoEvent($sku)));
     }