|
|
@@ -0,0 +1,739 @@
|
|
|
+<?php
|
|
|
+
|
|
|
+namespace App\Console\Commands;
|
|
|
+
|
|
|
+use App\Services\Asteria\Magento1OrderReader;
|
|
|
+use Illuminate\Console\Command;
|
|
|
+use Illuminate\Support\Collection;
|
|
|
+use Illuminate\Support\Facades\Cache;
|
|
|
+use Illuminate\Support\Facades\DB;
|
|
|
+use Illuminate\Support\Facades\Log;
|
|
|
+use Illuminate\Support\Facades\Schema;
|
|
|
+use Webkul\Core\Models\Channel;
|
|
|
+use Webkul\Customer\Models\Customer;
|
|
|
+use Webkul\Product\Models\Product;
|
|
|
+use Webkul\Sales\Models\Order;
|
|
|
+use Webkul\Sales\Models\OrderAddress;
|
|
|
+use Webkul\Sales\Models\OrderItem;
|
|
|
+use Webkul\Sales\Models\OrderPayment;
|
|
|
+
|
|
|
+/**
|
|
|
+ * Migrates storefront orders from Asteria (Magento 1.x).
|
|
|
+ *
|
|
|
+ * Does not create invoices/shipments/refunds, does not decrement inventory,
|
|
|
+ * and does not fire checkout.order.save.after listeners.
|
|
|
+ *
|
|
|
+ * Usage
|
|
|
+ * ─────
|
|
|
+ * php artisan orders:migrate-asteria
|
|
|
+ * php artisan orders:migrate-asteria --batch-size=200
|
|
|
+ * php artisan orders:migrate-asteria --reset-progress
|
|
|
+ * php artisan orders:migrate-asteria --dry-run
|
|
|
+ */
|
|
|
+class MigrateAsteriaOrders extends Command
|
|
|
+{
|
|
|
+ protected $signature = 'orders:migrate-asteria
|
|
|
+ {--batch-size=100 : Number of Magento orders per batch}
|
|
|
+ {--reset-progress : Ignore saved progress and start from entity_id=0}
|
|
|
+ {--dry-run : Count records without writing}
|
|
|
+ {--connection=asteria : Laravel DB connection for the Asteria database}';
|
|
|
+
|
|
|
+ protected $description = 'Migrate Asteria (Magento 1.x) orders into Bagisto';
|
|
|
+
|
|
|
+ private const PROGRESS_KEY = 'migrate_asteria_orders_last_id';
|
|
|
+
|
|
|
+ private const BAGISTO_PRODUCT_TYPES = [
|
|
|
+ 'simple',
|
|
|
+ 'configurable',
|
|
|
+ 'virtual',
|
|
|
+ 'downloadable',
|
|
|
+ 'bundle',
|
|
|
+ 'grouped',
|
|
|
+ ];
|
|
|
+
|
|
|
+ public function handle(): int
|
|
|
+ {
|
|
|
+ $connection = (string) $this->option('connection');
|
|
|
+ $batchSize = max(1, (int) $this->option('batch-size'));
|
|
|
+ $resetProgress = (bool) $this->option('reset-progress');
|
|
|
+ $dryRun = (bool) $this->option('dry-run');
|
|
|
+
|
|
|
+ try {
|
|
|
+ DB::connection($connection)->getPdo();
|
|
|
+ } catch (\Throwable $e) {
|
|
|
+ $this->error("Cannot connect to Asteria DB (connection='{$connection}'): ".$e->getMessage());
|
|
|
+
|
|
|
+ return self::FAILURE;
|
|
|
+ }
|
|
|
+
|
|
|
+ foreach ([
|
|
|
+ 'sales_flat_order',
|
|
|
+ 'sales_flat_order_item',
|
|
|
+ 'sales_flat_order_address',
|
|
|
+ 'sales_flat_order_payment',
|
|
|
+ ] as $table) {
|
|
|
+ if (! Schema::connection($connection)->hasTable($table)) {
|
|
|
+ $this->error("Asteria table '{$table}' is missing on connection '{$connection}'.");
|
|
|
+
|
|
|
+ return self::FAILURE;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if (! Schema::hasColumn('orders', 'migrated_from_asteria_id')) {
|
|
|
+ $this->error('orders.migrated_from_asteria_id is missing. Run php artisan migrate.');
|
|
|
+
|
|
|
+ return self::FAILURE;
|
|
|
+ }
|
|
|
+
|
|
|
+ $channel = core()->getDefaultChannel() ?? core()->getCurrentChannel();
|
|
|
+
|
|
|
+ if (! $channel) {
|
|
|
+ $this->error('Bagisto default channel was not found.');
|
|
|
+
|
|
|
+ return self::FAILURE;
|
|
|
+ }
|
|
|
+
|
|
|
+ $reader = new Magento1OrderReader($connection);
|
|
|
+ $lastId = $resetProgress ? 0 : (int) Cache::get(self::PROGRESS_KEY, 0);
|
|
|
+
|
|
|
+ if ($resetProgress) {
|
|
|
+ Cache::forget(self::PROGRESS_KEY);
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($lastId > 0) {
|
|
|
+ $this->line("Resuming from Asteria entity_id > {$lastId} (use --reset-progress to restart).");
|
|
|
+ }
|
|
|
+
|
|
|
+ $created = 0;
|
|
|
+ $skipped = 0;
|
|
|
+ $itemsImported = 0;
|
|
|
+ $addressesImported = 0;
|
|
|
+ $batchNumber = 0;
|
|
|
+
|
|
|
+ $this->info($dryRun ? '[DRY RUN] Scanning Magento orders…' : 'Migrating Magento orders…');
|
|
|
+
|
|
|
+ do {
|
|
|
+ $orders = $reader->fetchOrders($lastId, $batchSize);
|
|
|
+
|
|
|
+ if ($orders->isEmpty()) {
|
|
|
+ break;
|
|
|
+ }
|
|
|
+
|
|
|
+ $batchNumber++;
|
|
|
+ $lastId = (int) $orders->max('entity_id');
|
|
|
+ $orderIds = $orders->pluck('entity_id')->map(fn ($id) => (int) $id)->all();
|
|
|
+
|
|
|
+ $items = $reader->fetchItems($orderIds)->groupBy(fn (array $row) => (int) $row['order_id']);
|
|
|
+ $addresses = $reader->fetchAddresses($orderIds)->groupBy(fn (array $row) => (int) $row['parent_id']);
|
|
|
+ $payments = $reader->fetchPayments($orderIds)->groupBy(fn (array $row) => (int) $row['parent_id']);
|
|
|
+
|
|
|
+ if ($dryRun) {
|
|
|
+ $created += $orders->count();
|
|
|
+ $itemsImported += $items->flatten(1)->count();
|
|
|
+ $addressesImported += $addresses->flatten(1)->count();
|
|
|
+ $this->line(sprintf(
|
|
|
+ ' Batch #%d: %d orders, %d items, %d addresses (last entity_id=%d) [skipped – dry-run]',
|
|
|
+ $batchNumber,
|
|
|
+ $orders->count(),
|
|
|
+ $items->flatten(1)->count(),
|
|
|
+ $addresses->flatten(1)->count(),
|
|
|
+ $lastId
|
|
|
+ ));
|
|
|
+
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+
|
|
|
+ [$customersByAsteriaId, $customersByEmail] = $this->loadCustomers($orders);
|
|
|
+ $productsBySku = $this->loadProducts($items);
|
|
|
+
|
|
|
+ $batchCreated = 0;
|
|
|
+ $batchSkipped = 0;
|
|
|
+ $batchItems = 0;
|
|
|
+ $batchAddresses = 0;
|
|
|
+
|
|
|
+ DB::transaction(function () use (
|
|
|
+ $orders,
|
|
|
+ $items,
|
|
|
+ $addresses,
|
|
|
+ $payments,
|
|
|
+ $channel,
|
|
|
+ $customersByAsteriaId,
|
|
|
+ $customersByEmail,
|
|
|
+ $productsBySku,
|
|
|
+ &$batchCreated,
|
|
|
+ &$batchSkipped,
|
|
|
+ &$batchItems,
|
|
|
+ &$batchAddresses
|
|
|
+ ) {
|
|
|
+ foreach ($orders as $row) {
|
|
|
+ $result = $this->migrateOrder(
|
|
|
+ $row,
|
|
|
+ $items->get((int) $row['entity_id'], collect()),
|
|
|
+ $addresses->get((int) $row['entity_id'], collect()),
|
|
|
+ $payments->get((int) $row['entity_id'], collect())->first(),
|
|
|
+ $channel,
|
|
|
+ $customersByAsteriaId,
|
|
|
+ $customersByEmail,
|
|
|
+ $productsBySku
|
|
|
+ );
|
|
|
+
|
|
|
+ $batchCreated += $result['created'];
|
|
|
+ $batchSkipped += $result['skipped'];
|
|
|
+ $batchItems += $result['items'];
|
|
|
+ $batchAddresses += $result['addresses'];
|
|
|
+ }
|
|
|
+ });
|
|
|
+
|
|
|
+ Cache::put(self::PROGRESS_KEY, $lastId, now()->addDays(30));
|
|
|
+
|
|
|
+ $created += $batchCreated;
|
|
|
+ $skipped += $batchSkipped;
|
|
|
+ $itemsImported += $batchItems;
|
|
|
+ $addressesImported += $batchAddresses;
|
|
|
+
|
|
|
+ $this->line(sprintf(
|
|
|
+ ' Batch #%d: created=%d skipped=%d items=%d addresses=%d (last entity_id=%d)',
|
|
|
+ $batchNumber,
|
|
|
+ $batchCreated,
|
|
|
+ $batchSkipped,
|
|
|
+ $batchItems,
|
|
|
+ $batchAddresses,
|
|
|
+ $lastId
|
|
|
+ ));
|
|
|
+
|
|
|
+ Log::info('MigrateAsteriaOrders: batch '.$batchNumber.', last_id='.$lastId);
|
|
|
+ } while ($orders->count() === $batchSize);
|
|
|
+
|
|
|
+ $this->newLine();
|
|
|
+ $this->info("Done. Batches: {$batchNumber}, created: {$created}, skipped: {$skipped}, items: {$itemsImported}, addresses: {$addressesImported}.");
|
|
|
+
|
|
|
+ return self::SUCCESS;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @param array<string, mixed> $row
|
|
|
+ * @param Collection<int, array<string, mixed>> $itemRows
|
|
|
+ * @param Collection<int, array<string, mixed>> $addressRows
|
|
|
+ * @param array<string, mixed>|null $paymentRow
|
|
|
+ * @param array<int, Customer> $customersByAsteriaId
|
|
|
+ * @param array<string, Customer> $customersByEmail
|
|
|
+ * @param array<string, Product> $productsBySku
|
|
|
+ * @return array{created: int, skipped: int, items: int, addresses: int}
|
|
|
+ */
|
|
|
+ private function migrateOrder(
|
|
|
+ array $row,
|
|
|
+ $itemRows,
|
|
|
+ $addressRows,
|
|
|
+ ?array $paymentRow,
|
|
|
+ Channel $channel,
|
|
|
+ array $customersByAsteriaId,
|
|
|
+ array $customersByEmail,
|
|
|
+ array $productsBySku
|
|
|
+ ): array {
|
|
|
+ $asteriaId = (int) $row['entity_id'];
|
|
|
+ $incrementId = trim((string) ($row['increment_id'] ?? ''));
|
|
|
+
|
|
|
+ if ($asteriaId < 1 || $incrementId === '') {
|
|
|
+ return ['created' => 0, 'skipped' => 1, 'items' => 0, 'addresses' => 0];
|
|
|
+ }
|
|
|
+
|
|
|
+ $alreadyMigrated = Order::query()
|
|
|
+ ->where('migrated_from_asteria_id', $asteriaId)
|
|
|
+ ->exists();
|
|
|
+
|
|
|
+ if ($alreadyMigrated) {
|
|
|
+ return ['created' => 0, 'skipped' => 1, 'items' => 0, 'addresses' => 0];
|
|
|
+ }
|
|
|
+
|
|
|
+ $incrementTaken = Order::query()
|
|
|
+ ->where('increment_id', $incrementId)
|
|
|
+ ->exists();
|
|
|
+
|
|
|
+ if ($incrementTaken) {
|
|
|
+ return ['created' => 0, 'skipped' => 1, 'items' => 0, 'addresses' => 0];
|
|
|
+ }
|
|
|
+
|
|
|
+ $customer = $this->resolveCustomer($row, $customersByAsteriaId, $customersByEmail);
|
|
|
+ $email = strtolower(trim((string) ($row['customer_email'] ?? '')));
|
|
|
+
|
|
|
+ if ($email === '' && $customer) {
|
|
|
+ $email = strtolower((string) $customer->email);
|
|
|
+ }
|
|
|
+
|
|
|
+ $subTotal = $this->money($row['subtotal'] ?? 0);
|
|
|
+ $baseSubTotal = $this->money($row['base_subtotal'] ?? $subTotal);
|
|
|
+ $taxAmount = $this->money($row['tax_amount'] ?? 0);
|
|
|
+ $baseTaxAmount = $this->money($row['base_tax_amount'] ?? $taxAmount);
|
|
|
+ $shippingAmount = $this->money($row['shipping_amount'] ?? 0);
|
|
|
+ $baseShippingAmount = $this->money($row['base_shipping_amount'] ?? $shippingAmount);
|
|
|
+ $shippingTaxAmount = $this->money($row['shipping_tax_amount'] ?? 0);
|
|
|
+ $baseShippingTaxAmount = $this->money($row['base_shipping_tax_amount'] ?? $shippingTaxAmount);
|
|
|
+ $discountAmount = $this->money($row['discount_amount'] ?? 0);
|
|
|
+ $baseDiscountAmount = $this->money($row['base_discount_amount'] ?? $discountAmount);
|
|
|
+ $grandTotal = $this->money($row['grand_total'] ?? 0);
|
|
|
+ $baseGrandTotal = $this->money($row['base_grand_total'] ?? $grandTotal);
|
|
|
+
|
|
|
+ $subTotalInclTax = array_key_exists('subtotal_incl_tax', $row)
|
|
|
+ ? $this->money($row['subtotal_incl_tax'])
|
|
|
+ : $subTotal + $taxAmount;
|
|
|
+ $baseSubTotalInclTax = array_key_exists('base_subtotal_incl_tax', $row)
|
|
|
+ ? $this->money($row['base_subtotal_incl_tax'])
|
|
|
+ : $baseSubTotal + $baseTaxAmount;
|
|
|
+ $shippingInclTax = array_key_exists('shipping_incl_tax', $row)
|
|
|
+ ? $this->money($row['shipping_incl_tax'])
|
|
|
+ : $shippingAmount + $shippingTaxAmount;
|
|
|
+ $baseShippingInclTax = array_key_exists('base_shipping_incl_tax', $row)
|
|
|
+ ? $this->money($row['base_shipping_incl_tax'])
|
|
|
+ : $baseShippingAmount + $baseShippingTaxAmount;
|
|
|
+
|
|
|
+ $order = new Order;
|
|
|
+ $order->forceFill([
|
|
|
+ 'migrated_from_asteria_id' => $asteriaId,
|
|
|
+ 'increment_id' => $incrementId,
|
|
|
+ 'status' => $this->mapStatus($row),
|
|
|
+ 'channel_name' => $channel->name,
|
|
|
+ 'is_guest' => $customer ? 0 : 1,
|
|
|
+ 'customer_email' => $email !== '' ? $email : null,
|
|
|
+ 'customer_first_name' => $this->requiredName($row['customer_firstname'] ?? null, $customer?->first_name ?? $email),
|
|
|
+ 'customer_last_name' => trim((string) ($row['customer_lastname'] ?? '')) ?: ($customer?->last_name ?? '-'),
|
|
|
+ 'customer_id' => $customer?->id,
|
|
|
+ 'customer_type' => $customer ? Customer::class : null,
|
|
|
+ 'channel_id' => $channel->id,
|
|
|
+ 'channel_type' => get_class($channel),
|
|
|
+ 'cart_id' => null,
|
|
|
+ 'shipping_method' => $this->nullableString($row['shipping_method'] ?? null),
|
|
|
+ 'shipping_title' => $this->nullableString($row['shipping_description'] ?? null),
|
|
|
+ 'shipping_description' => $this->nullableString($row['shipping_description'] ?? null),
|
|
|
+ 'coupon_code' => $this->nullableString($row['coupon_code'] ?? null),
|
|
|
+ 'is_gift' => 0,
|
|
|
+ 'total_item_count' => $this->qty($row['total_item_count'] ?? $itemRows->count()),
|
|
|
+ 'total_qty_ordered' => $this->qty($row['total_qty_ordered'] ?? $itemRows->sum(fn (array $item) => (float) ($item['qty_ordered'] ?? 0))),
|
|
|
+ 'base_currency_code' => $this->nullableString($row['base_currency_code'] ?? null) ?? 'USD',
|
|
|
+ 'channel_currency_code' => $this->nullableString($row['store_currency_code'] ?? null)
|
|
|
+ ?? $this->nullableString($row['order_currency_code'] ?? null)
|
|
|
+ ?? 'USD',
|
|
|
+ 'order_currency_code' => $this->nullableString($row['order_currency_code'] ?? null) ?? 'USD',
|
|
|
+ 'grand_total' => $grandTotal,
|
|
|
+ 'base_grand_total' => $baseGrandTotal,
|
|
|
+ 'grand_total_invoiced' => $this->money($row['total_invoiced'] ?? 0),
|
|
|
+ 'base_grand_total_invoiced' => $this->money($row['base_total_invoiced'] ?? 0),
|
|
|
+ 'grand_total_refunded' => $this->money($row['total_refunded'] ?? 0),
|
|
|
+ 'base_grand_total_refunded' => $this->money($row['base_total_refunded'] ?? 0),
|
|
|
+ 'sub_total' => $subTotal,
|
|
|
+ 'base_sub_total' => $baseSubTotal,
|
|
|
+ 'sub_total_incl_tax' => $subTotalInclTax,
|
|
|
+ 'base_sub_total_incl_tax' => $baseSubTotalInclTax,
|
|
|
+ 'sub_total_invoiced' => $this->money($row['subtotal_invoiced'] ?? 0),
|
|
|
+ 'base_sub_total_invoiced' => $this->money($row['base_subtotal_invoiced'] ?? 0),
|
|
|
+ 'sub_total_refunded' => $this->money($row['subtotal_refunded'] ?? 0),
|
|
|
+ 'base_sub_total_refunded' => $this->money($row['base_subtotal_refunded'] ?? 0),
|
|
|
+ 'discount_amount' => $discountAmount,
|
|
|
+ 'base_discount_amount' => $baseDiscountAmount,
|
|
|
+ 'discount_invoiced' => $this->money($row['discount_invoiced'] ?? 0),
|
|
|
+ 'base_discount_invoiced' => $this->money($row['base_discount_invoiced'] ?? 0),
|
|
|
+ 'discount_refunded' => $this->money($row['discount_refunded'] ?? 0),
|
|
|
+ 'base_discount_refunded' => $this->money($row['base_discount_refunded'] ?? 0),
|
|
|
+ 'tax_amount' => $taxAmount,
|
|
|
+ 'base_tax_amount' => $baseTaxAmount,
|
|
|
+ 'tax_amount_invoiced' => $this->money($row['tax_invoiced'] ?? 0),
|
|
|
+ 'base_tax_amount_invoiced' => $this->money($row['base_tax_invoiced'] ?? 0),
|
|
|
+ 'tax_amount_refunded' => $this->money($row['tax_refunded'] ?? 0),
|
|
|
+ 'base_tax_amount_refunded' => $this->money($row['base_tax_refunded'] ?? 0),
|
|
|
+ 'shipping_amount' => $shippingAmount,
|
|
|
+ 'base_shipping_amount' => $baseShippingAmount,
|
|
|
+ 'shipping_amount_incl_tax' => $shippingInclTax,
|
|
|
+ 'base_shipping_amount_incl_tax' => $baseShippingInclTax,
|
|
|
+ 'shipping_invoiced' => $this->money($row['shipping_invoiced'] ?? 0),
|
|
|
+ 'base_shipping_invoiced' => $this->money($row['base_shipping_invoiced'] ?? 0),
|
|
|
+ 'shipping_refunded' => $this->money($row['shipping_refunded'] ?? 0),
|
|
|
+ 'base_shipping_refunded' => $this->money($row['base_shipping_refunded'] ?? 0),
|
|
|
+ 'shipping_tax_amount' => $shippingTaxAmount,
|
|
|
+ 'base_shipping_tax_amount' => $baseShippingTaxAmount,
|
|
|
+ ]);
|
|
|
+
|
|
|
+ if (! empty($row['created_at'])) {
|
|
|
+ $order->created_at = $row['created_at'];
|
|
|
+ }
|
|
|
+
|
|
|
+ $order->save();
|
|
|
+
|
|
|
+ $this->importPayment($order, $paymentRow);
|
|
|
+ $importedAddresses = $this->importAddresses($order, $addressRows, $customer, $email);
|
|
|
+ $importedItems = $this->importItems($order, $itemRows, $productsBySku);
|
|
|
+
|
|
|
+ return [
|
|
|
+ 'created' => 1,
|
|
|
+ 'skipped' => 0,
|
|
|
+ 'items' => $importedItems,
|
|
|
+ 'addresses' => $importedAddresses,
|
|
|
+ ];
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @param array<string, mixed>|null $paymentRow
|
|
|
+ */
|
|
|
+ private function importPayment(Order $order, ?array $paymentRow): void
|
|
|
+ {
|
|
|
+ $magentoMethod = trim((string) ($paymentRow['method'] ?? ''));
|
|
|
+
|
|
|
+ $additional = [
|
|
|
+ 'magento_method' => $magentoMethod !== '' ? $magentoMethod : null,
|
|
|
+ ];
|
|
|
+
|
|
|
+ if ($paymentRow) {
|
|
|
+ $additional['asteria_payment_id'] = (int) ($paymentRow['entity_id'] ?? 0);
|
|
|
+
|
|
|
+ foreach (['last_trans_id', 'cc_type', 'cc_last4'] as $key) {
|
|
|
+ $value = $this->nullableString($paymentRow[$key] ?? null);
|
|
|
+
|
|
|
+ if ($value !== null) {
|
|
|
+ $additional[$key] = $value;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ $payment = new OrderPayment;
|
|
|
+ $payment->forceFill([
|
|
|
+ 'order_id' => $order->id,
|
|
|
+ 'method' => $this->mapPaymentMethod($magentoMethod),
|
|
|
+ 'method_title' => $magentoMethod !== '' ? $magentoMethod : null,
|
|
|
+ 'additional' => $additional,
|
|
|
+ ]);
|
|
|
+ $payment->save();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @param Collection<int, array<string, mixed>> $addressRows
|
|
|
+ */
|
|
|
+ private function importAddresses(Order $order, $addressRows, ?Customer $customer, string $email): int
|
|
|
+ {
|
|
|
+ $imported = 0;
|
|
|
+
|
|
|
+ foreach ($addressRows as $row) {
|
|
|
+ $type = strtolower(trim((string) ($row['address_type'] ?? '')));
|
|
|
+ $addressType = $type === 'shipping'
|
|
|
+ ? OrderAddress::ADDRESS_TYPE_SHIPPING
|
|
|
+ : OrderAddress::ADDRESS_TYPE_BILLING;
|
|
|
+
|
|
|
+ $address = new OrderAddress;
|
|
|
+ $address->forceFill([
|
|
|
+ 'order_id' => $order->id,
|
|
|
+ 'customer_id' => $customer?->id,
|
|
|
+ 'address_type' => $addressType,
|
|
|
+ 'first_name' => $this->requiredName($row['firstname'] ?? null, $order->customer_first_name),
|
|
|
+ 'last_name' => trim((string) ($row['lastname'] ?? '')) ?: $order->customer_last_name,
|
|
|
+ 'company_name' => $this->nullableString($row['company'] ?? null),
|
|
|
+ 'address' => $this->mapStreet($row['street'] ?? null) ?: '-',
|
|
|
+ 'city' => trim((string) ($row['city'] ?? '')) ?: '-',
|
|
|
+ 'state' => $this->nullableString($row['region'] ?? null),
|
|
|
+ 'country' => $this->nullableString($row['country_id'] ?? null),
|
|
|
+ 'postcode' => $this->nullableString($row['postcode'] ?? null),
|
|
|
+ 'email' => $this->nullableString($row['email'] ?? null) ?? ($email !== '' ? $email : null),
|
|
|
+ 'phone' => $this->nullableString($row['telephone'] ?? null),
|
|
|
+ 'additional' => json_encode(['asteria_address_id' => (int) ($row['entity_id'] ?? 0)]),
|
|
|
+ ]);
|
|
|
+ $address->save();
|
|
|
+
|
|
|
+ $imported++;
|
|
|
+ }
|
|
|
+
|
|
|
+ return $imported;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @param Collection<int, array<string, mixed>> $itemRows
|
|
|
+ * @param array<string, Product> $productsBySku
|
|
|
+ */
|
|
|
+ private function importItems(Order $order, $itemRows, array $productsBySku): int
|
|
|
+ {
|
|
|
+ if ($itemRows->isEmpty()) {
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+
|
|
|
+ $parents = $itemRows->filter(fn (array $row) => empty($row['parent_item_id']));
|
|
|
+ $children = $itemRows->filter(fn (array $row) => ! empty($row['parent_item_id']));
|
|
|
+ $idMap = [];
|
|
|
+ $imported = 0;
|
|
|
+
|
|
|
+ foreach ($parents as $row) {
|
|
|
+ $item = $this->createOrderItem($order, $row, null, $productsBySku);
|
|
|
+ $idMap[(int) $row['item_id']] = $item->id;
|
|
|
+ $imported++;
|
|
|
+ }
|
|
|
+
|
|
|
+ foreach ($children as $row) {
|
|
|
+ $parentId = $idMap[(int) $row['parent_item_id']] ?? null;
|
|
|
+ $this->createOrderItem($order, $row, $parentId, $productsBySku);
|
|
|
+ $imported++;
|
|
|
+ }
|
|
|
+
|
|
|
+ return $imported;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @param array<string, mixed> $row
|
|
|
+ * @param array<string, Product> $productsBySku
|
|
|
+ */
|
|
|
+ private function createOrderItem(Order $order, array $row, ?int $parentId, array $productsBySku): OrderItem
|
|
|
+ {
|
|
|
+ $sku = trim((string) ($row['sku'] ?? ''));
|
|
|
+ $product = $sku !== '' ? ($productsBySku[$sku] ?? null) : null;
|
|
|
+ $type = $this->mapProductType($row['product_type'] ?? null, $product);
|
|
|
+
|
|
|
+ $price = $this->money($row['price'] ?? 0);
|
|
|
+ $basePrice = $this->money($row['base_price'] ?? $price);
|
|
|
+ $total = $this->money($row['row_total'] ?? 0);
|
|
|
+ $baseTotal = $this->money($row['base_row_total'] ?? $total);
|
|
|
+ $taxAmount = $this->money($row['tax_amount'] ?? 0);
|
|
|
+ $baseTaxAmount = $this->money($row['base_tax_amount'] ?? $taxAmount);
|
|
|
+
|
|
|
+ $item = new OrderItem;
|
|
|
+ $item->forceFill([
|
|
|
+ 'order_id' => $order->id,
|
|
|
+ 'parent_id' => $parentId,
|
|
|
+ 'sku' => $sku !== '' ? $sku : null,
|
|
|
+ 'type' => $type,
|
|
|
+ 'name' => $this->nullableString($row['name'] ?? null) ?? '-',
|
|
|
+ 'weight' => $this->money($row['weight'] ?? 0),
|
|
|
+ 'total_weight' => $this->money($row['row_weight'] ?? $row['weight'] ?? 0),
|
|
|
+ 'qty_ordered' => $this->qty($row['qty_ordered'] ?? 0),
|
|
|
+ 'qty_shipped' => $this->qty($row['qty_shipped'] ?? 0),
|
|
|
+ 'qty_invoiced' => $this->qty($row['qty_invoiced'] ?? 0),
|
|
|
+ 'qty_canceled' => $this->qty($row['qty_canceled'] ?? 0),
|
|
|
+ 'qty_refunded' => $this->qty($row['qty_refunded'] ?? 0),
|
|
|
+ 'price' => $price,
|
|
|
+ 'base_price' => $basePrice,
|
|
|
+ 'price_incl_tax' => array_key_exists('price_incl_tax', $row) ? $this->money($row['price_incl_tax']) : $price,
|
|
|
+ 'base_price_incl_tax' => array_key_exists('base_price_incl_tax', $row) ? $this->money($row['base_price_incl_tax']) : $basePrice,
|
|
|
+ 'total' => $total,
|
|
|
+ 'base_total' => $baseTotal,
|
|
|
+ 'total_incl_tax' => array_key_exists('row_total_incl_tax', $row) ? $this->money($row['row_total_incl_tax']) : $total + $taxAmount,
|
|
|
+ 'base_total_incl_tax' => array_key_exists('base_row_total_incl_tax', $row) ? $this->money($row['base_row_total_incl_tax']) : $baseTotal + $baseTaxAmount,
|
|
|
+ 'tax_percent' => $this->money($row['tax_percent'] ?? 0),
|
|
|
+ 'tax_amount' => $taxAmount,
|
|
|
+ 'base_tax_amount' => $baseTaxAmount,
|
|
|
+ 'discount_percent' => $this->money($row['discount_percent'] ?? 0),
|
|
|
+ 'discount_amount' => $this->money($row['discount_amount'] ?? 0),
|
|
|
+ 'base_discount_amount' => $this->money($row['base_discount_amount'] ?? 0),
|
|
|
+ 'product_id' => $product?->id,
|
|
|
+ 'product_type' => $product ? get_class($product) : null,
|
|
|
+ 'additional' => [
|
|
|
+ 'asteria_item_id' => (int) ($row['item_id'] ?? 0),
|
|
|
+ ],
|
|
|
+ ]);
|
|
|
+ $item->save();
|
|
|
+
|
|
|
+ return $item;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @param Collection<int, array<string, mixed>> $orders
|
|
|
+ * @return array{0: array<int, Customer>, 1: array<string, Customer>}
|
|
|
+ */
|
|
|
+ private function loadCustomers($orders): array
|
|
|
+ {
|
|
|
+ $asteriaIds = $orders
|
|
|
+ ->pluck('customer_id')
|
|
|
+ ->filter(fn ($id) => (int) $id > 0)
|
|
|
+ ->map(fn ($id) => (int) $id)
|
|
|
+ ->unique()
|
|
|
+ ->values()
|
|
|
+ ->all();
|
|
|
+
|
|
|
+ $emails = $orders
|
|
|
+ ->pluck('customer_email')
|
|
|
+ ->map(fn ($email) => strtolower(trim((string) $email)))
|
|
|
+ ->filter()
|
|
|
+ ->unique()
|
|
|
+ ->values()
|
|
|
+ ->all();
|
|
|
+
|
|
|
+ $byAsteriaId = [];
|
|
|
+ $byEmail = [];
|
|
|
+
|
|
|
+ if ($asteriaIds !== []) {
|
|
|
+ foreach (Customer::query()->whereIn('migrated_from_asteria_id', $asteriaIds)->get() as $customer) {
|
|
|
+ $byAsteriaId[(int) $customer->migrated_from_asteria_id] = $customer;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($emails !== []) {
|
|
|
+ $query = Customer::query();
|
|
|
+ $query->where(function ($inner) use ($emails) {
|
|
|
+ foreach ($emails as $email) {
|
|
|
+ $inner->orWhereRaw('LOWER(email) = ?', [$email]);
|
|
|
+ }
|
|
|
+ });
|
|
|
+
|
|
|
+ foreach ($query->get() as $customer) {
|
|
|
+ $byEmail[strtolower((string) $customer->email)] = $customer;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return [$byAsteriaId, $byEmail];
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @param Collection<int, Collection<int, array<string, mixed>>> $items
|
|
|
+ * @return array<string, Product>
|
|
|
+ */
|
|
|
+ private function loadProducts($items): array
|
|
|
+ {
|
|
|
+ $skus = $items
|
|
|
+ ->flatten(1)
|
|
|
+ ->pluck('sku')
|
|
|
+ ->map(fn ($sku) => trim((string) $sku))
|
|
|
+ ->filter()
|
|
|
+ ->unique()
|
|
|
+ ->values()
|
|
|
+ ->all();
|
|
|
+
|
|
|
+ if ($skus === []) {
|
|
|
+ return [];
|
|
|
+ }
|
|
|
+
|
|
|
+ return Product::query()
|
|
|
+ ->whereIn('sku', $skus)
|
|
|
+ ->get(['id', 'sku', 'type'])
|
|
|
+ ->keyBy('sku')
|
|
|
+ ->all();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @param array<string, mixed> $row
|
|
|
+ * @param array<int, Customer> $customersByAsteriaId
|
|
|
+ * @param array<string, Customer> $customersByEmail
|
|
|
+ */
|
|
|
+ private function resolveCustomer(array $row, array $customersByAsteriaId, array $customersByEmail): ?Customer
|
|
|
+ {
|
|
|
+ $asteriaCustomerId = (int) ($row['customer_id'] ?? 0);
|
|
|
+
|
|
|
+ if ($asteriaCustomerId > 0 && isset($customersByAsteriaId[$asteriaCustomerId])) {
|
|
|
+ return $customersByAsteriaId[$asteriaCustomerId];
|
|
|
+ }
|
|
|
+
|
|
|
+ $email = strtolower(trim((string) ($row['customer_email'] ?? '')));
|
|
|
+
|
|
|
+ if ($email !== '' && isset($customersByEmail[$email])) {
|
|
|
+ return $customersByEmail[$email];
|
|
|
+ }
|
|
|
+
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @param array<string, mixed> $row
|
|
|
+ */
|
|
|
+ private function mapStatus(array $row): string
|
|
|
+ {
|
|
|
+ $status = strtolower(trim((string) ($row['status'] ?? '')));
|
|
|
+ $state = strtolower(trim((string) ($row['state'] ?? '')));
|
|
|
+ $value = $status !== '' ? $status : $state;
|
|
|
+
|
|
|
+ return match ($value) {
|
|
|
+ 'complete' => Order::STATUS_COMPLETED,
|
|
|
+ 'canceled', 'cancelled' => Order::STATUS_CANCELED,
|
|
|
+ 'pending_payment', 'payment_review', 'pending_paypal' => Order::STATUS_PENDING_PAYMENT,
|
|
|
+ 'holded' => Order::STATUS_PENDING,
|
|
|
+ 'fraud' => Order::STATUS_FRAUD,
|
|
|
+ 'closed' => Order::STATUS_CLOSED,
|
|
|
+ 'processing' => Order::STATUS_PROCESSING,
|
|
|
+ default => Order::STATUS_PENDING,
|
|
|
+ };
|
|
|
+ }
|
|
|
+
|
|
|
+ private function mapPaymentMethod(string $method): string
|
|
|
+ {
|
|
|
+ $method = strtolower(trim($method));
|
|
|
+
|
|
|
+ if ($method === '') {
|
|
|
+ return 'unknown';
|
|
|
+ }
|
|
|
+
|
|
|
+ if (in_array($method, ['paypal_express', 'paypal_standard'], true) || str_starts_with($method, 'paypaluk_')) {
|
|
|
+ return 'paypal_standard';
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($method === 'checkmo') {
|
|
|
+ return 'moneytransfer';
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($method === 'cashondelivery') {
|
|
|
+ return 'cashondelivery';
|
|
|
+ }
|
|
|
+
|
|
|
+ if (str_starts_with($method, 'klarna')) {
|
|
|
+ return 'klarna';
|
|
|
+ }
|
|
|
+
|
|
|
+ if (str_starts_with($method, 'afterpay') || str_starts_with($method, 'clearpay')) {
|
|
|
+ return 'afterpay';
|
|
|
+ }
|
|
|
+
|
|
|
+ return $method;
|
|
|
+ }
|
|
|
+
|
|
|
+ private function mapProductType(mixed $magentoType, ?Product $product): string
|
|
|
+ {
|
|
|
+ if ($product && in_array($product->type, self::BAGISTO_PRODUCT_TYPES, true)) {
|
|
|
+ return $product->type;
|
|
|
+ }
|
|
|
+
|
|
|
+ $type = strtolower(trim((string) $magentoType));
|
|
|
+
|
|
|
+ if (in_array($type, self::BAGISTO_PRODUCT_TYPES, true)) {
|
|
|
+ return $type;
|
|
|
+ }
|
|
|
+
|
|
|
+ return 'simple';
|
|
|
+ }
|
|
|
+
|
|
|
+ private function mapStreet(mixed $value): string
|
|
|
+ {
|
|
|
+ $value = trim((string) $value);
|
|
|
+
|
|
|
+ if ($value === '') {
|
|
|
+ return '';
|
|
|
+ }
|
|
|
+
|
|
|
+ $lines = preg_split("/\r\n|\n|\r/", $value) ?: [];
|
|
|
+
|
|
|
+ return implode(', ', array_filter(array_map('trim', $lines)));
|
|
|
+ }
|
|
|
+
|
|
|
+ private function requiredName(mixed $value, string $fallback): string
|
|
|
+ {
|
|
|
+ $value = trim((string) $value);
|
|
|
+
|
|
|
+ if ($value !== '') {
|
|
|
+ return $value;
|
|
|
+ }
|
|
|
+
|
|
|
+ $fallback = trim($fallback);
|
|
|
+
|
|
|
+ if ($fallback !== '') {
|
|
|
+ $local = strstr($fallback, '@', true);
|
|
|
+
|
|
|
+ return $local !== false && $local !== '' ? $local : $fallback;
|
|
|
+ }
|
|
|
+
|
|
|
+ return 'Customer';
|
|
|
+ }
|
|
|
+
|
|
|
+ private function nullableString(mixed $value): ?string
|
|
|
+ {
|
|
|
+ $value = trim((string) $value);
|
|
|
+
|
|
|
+ return $value === '' ? null : $value;
|
|
|
+ }
|
|
|
+
|
|
|
+ private function money(mixed $value): float
|
|
|
+ {
|
|
|
+ return is_numeric($value) ? (float) $value : 0.0;
|
|
|
+ }
|
|
|
+
|
|
|
+ private function qty(mixed $value): int
|
|
|
+ {
|
|
|
+ return (int) round((float) $value);
|
|
|
+ }
|
|
|
+}
|
chengwl