wip

app/Imports/Ecommerce/Product/ProductImport.php

@@ -0,0 +1,119 @@
+<?php
+
+namespace App\Imports\Ecommerce\Product;
+
+use App\Models\Ecommerce\Product\Inventory\Inventory;
+use App\Models\Ecommerce\Product\Product\Product;
+use App\Repositories\Ecommerce\Product\ProductRepository;
+use Illuminate\Support\Facades\DB;
+use Maatwebsite\Excel\Concerns\OnEachRow;
+use Maatwebsite\Excel\Concerns\WithHeadingRow;
+use Maatwebsite\Excel\Row;
+
+class ProductImport implements OnEachRow, WithHeadingRow
+{
+    public function __construct(
+        protected int $channel_id
+    ) {}
+
+    public function onRow(Row $row)
+    {
+        $rowIndex = $row->getIndex();
+        $row = $row->toArray();
+
+        $product = Product::query()
+            ->whereJsonContains('options->channel_id', $this->channel_id)
+            ->whereJsonContains('options->ynamdyr_product_code', $row['product_code'])
+            ->first();
+
+        $product ? $this->updateProduct($product, $row) : $this->createProduct($row);
+
+        // brand_id
+        // categories
+        // collections
+        // images
+        // inventories
+        // options => json_encode(ProductRepository::shippingAttributes())
+    }
+
+    public function createProduct($row)
+    {
+        $product = new Product(array_merge(
+            $this->baseColumns($row),
+            [
+                'stock' => $row['stock'],
+                'options' => json_encode(
+                    array_merge(
+                        ProductRepository::shippingAttributes(),
+                        [
+                            'channel_id' => $this->channel_id,
+                            'ynamdyr_product_code' => $row['product_code'],
+                            'ynamdyr_brand_id' => $row['brand_id'],
+                            'ynamdyr_category_id' => $row['category_id'],
+                        ]
+                    )
+                ),
+            ]
+        ));
+
+        $product->save();
+
+        $inventory = Inventory::where('channel_id', $this->channel_id)->first('id')?->id;
+
+        if ($inventory) {
+            $product->inventories()->attach($inventory, ['stock' => $row['stock']]);
+        }
+
+        $product->channels()->attach($this->channel_id);
+    }
+
+    public function updateProduct($product, $row)
+    {
+        $inventory = Inventory::where('channel_id', $this->channel_id)->first(['inventories.id']);
+
+        if ($inventory) {
+            $stockRecord = DB::table('inventory_product')
+                ->where('product_id', $product->id)
+                ->where('inventory_id', $inventory->id)
+                ->get();
+
+            if ($stockRecord->isNotEmpty()) {
+                DB::table('inventory_product')
+                    ->where('product_id', $product->id)
+                    ->where('inventory_id', $inventory->id)
+                    ->update([
+                        'stock' => $row['stock'],
+                    ]);
+            } else {
+                DB::table('inventory_product')
+                    ->where('product_id', $product->id)
+                    ->where('inventory_id', $inventory->id)
+                    ->insert([
+                        'product_id' => $product->id,
+                        'inventory_id' => $inventory->id,
+                        'stock' => $row['stock'],
+                    ]);
+            }
+        }
+
+        $product->update(array_merge(
+            $this->baseColumns($row),
+            [
+                'stock' => $product->inventories()->sum('inventory_product.stock'),
+            ]
+        ));
+    }
+
+    public function baseColumns($row)
+    {
+        return [
+            'name' => $row['name_tm'],
+            'barcode' => $row['barcode'],
+            'description' => $row['description_tm'],
+            'old_price_amount' => $row['old_price'],
+            'cost_amount' => $row['sale_price'],
+            'price_amount' => $row['sale_price'],
+            'is_visible' => false,
+        ];
+    }
+}