שילוח אוטומטי של הזמנות DropShipping לאחר תשלום

שליחה ידנית של הזמנות לספקי dropshipping באמצעות דוא"ל או Excel היא צוואר בקבוק בתהליך. שגיאות בכתובות, הזמנות כפולות, עיכובים של מספר שעות. לדוגמה, חנות מקוונת עם 100 הזמנות ביום איבדה עד 10% מלקוחותיה בגלל עיכובים. אנו הופכים תהליך זה לאוטומטי: לאחר אישור התשלום, ההזמנה נשלחת מיידית לספק באמצעות REST API, דוא"ל או Telegram. זמן העיבוד הממוצע יורד מ-30 דקות ל-2 שניות. החיסכון בעבודה ידנית מגיע ל-70%, כלומר כ-$1,500 בחודש לחנות עם 100 הזמנות. תקופת החזר השקעה — 2–3 חודשים. ההשקעה מתחילה ב-$300 לאינטגרציית דוא"ל ו-$500 ל-REST API. קבלו ייעוץ על אוטומציה של dropshipping.

כיצד להפוך את שליחת ההזמנות לאוטומטית ב-5 צעדים?

1. הגדירו מאזין לאירועי תשלום.
2. צרו משימה בתור עם לוגיקת ניסיונות חוזרים.
3. יישמו מחבר ספק (REST/דוא"ל/Telegram).
4. הגדירו בדיקת סטטוס או webhook.
5. נטרו את הביצוע וטפלו בתקלות.

מדוע אוטומציה קריטית ל-Dropshipping?

ללא אוטומציה, כל הזמנה עוברת דרך מנהל: העתקת נתונים, הדבקה בדוא"ל, שליחה. עם 50 הזמנות ביום — 50 פעולות ידניות. הסתברות השגיאה היא 5–10%. עבור dropshipping זה קריטי: הספק לא יקבל את ההזמנה, הלקוח לא יקבל את החבילה. אוטומציה מבטלת את הגורם האנושי ומקצרת את זמן המשלוח. REST API שולח הזמנות ב-2 שניות — פי 30 מהר יותר מאינטגרציית דוא"ל (כדקה אחת).

כיצד להפעיל העברה באירוע תשלום?

ההעברה חייבת להתבצע אך ורק לאחר אישור התשלום. יישום ב-Laravel: מאזין עבור PaymentConfirmedEvent מסנן פריטי dropshipping ושולח משימה לכל ספק. עבור ספקים מרובים, אנו מקבצים פריטים לפי supplier_id ומפעילים משימות נפרדות בתור.

// Listener на событие оплаты
class DispatchOrderToSupplierListener
{
    public function __construct(
        private readonly DropshippingKernel $kernel,
    ) {}

    public function handle(PaymentConfirmedEvent $event): void
    {
        $order = $event->order;

        // Только дропшиппинг-позиции
        $dropshipItems = $order->items->filter(
            fn($item) => $item->product->dropshipProduct !== null
        );

        if ($dropshipItems->isEmpty()) {
            return;
        }

        // Группируем по поставщику и диспатчим отдельные задачи
        $dropshipItems
            ->groupBy(fn($item) => $item->product->dropshipProduct->supplier_id)
            ->each(function ($items, $supplierId) use ($order) {
                DispatchOrderToSupplierJob::dispatch($order, $supplierId, $items)
                    ->onQueue('supplier-orders');
            });
    }
}

ה-// Listener на событие оплаты class DispatchOrderToSupplierListener { public function __construct( private readonly DropshippingKernel $kernel, ) {} public function handle(PaymentConfirmedEvent $event): void { $order = $event->order; // Только дропшиппинг-позиции $dropshipItems = $order->items->filter( fn($item) => $item->product->dropshipProduct !== null ); if ($dropshipItems->isEmpty()) { return; } // Группируем по поставщику и диспатчим отдельные задачи $dropshipItems ->groupBy(fn($item) => $item->product->dropshipProduct->supplier_id) ->each(function ($items, $supplierId) use ($order) { DispatchOrderToSupplierJob::dispatch($order, $supplierId, $items) ->onQueue('supplier-orders'); }); } } בונה DTO ושולח אותו דרך מחבר. במקרה של שגיאה — עד 5 ניסיונות חוזרים עם השהיה אקספוננציאלית (30, 60, 120, 300, 600 שניות). לאחר מיצוי הניסיונות, המנהל מקבל הודעה.

דוגמה למשימת תור:

class DispatchOrderToSupplierJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public $tries = 5;
    public $backoff = [30, 60, 120, 300, 600];
    public $timeout = 60;

    public function __construct(
        private readonly Order $order,
        private readonly int $supplierId,
        private readonly Collection $items,
    ) {}

    public function handle(SupplierConnectorFactory $factory): void
    {
        $supplier = Supplier::findOrFail($this->supplierId);
        $connector = $factory->make($supplier);

        $dto = new SupplierOrderDTO(
            orderId: $this->order->id,
            externalRef: $this->order->number,
            recipientName: $this->order->delivery_name,
            phone: $this->order->delivery_phone,
            deliveryAddress: $this->order->deliveryAddress->formatted(),
            deliveryMethod: $this->order->delivery_method,
            comment: $this->order->comment,
            items: $this->items->map(fn($item) => new SupplierOrderItemDTO(
                supplierSku: $item->product->dropshipProduct->supplier_sku,
                quantity: $item->quantity,
            )),
        );

        $result = $connector->placeOrder($dto);

        SupplierOrder::create([
            'order_id' => $this->order->id,
            'supplier_id' => $this->supplierId,
            'supplier_order_id' => $result->supplierOrderId,
            'status' => $result->status,
            'placed_at' => now(),
        ]);

        $this->items->each(fn($item) => $item->update([
            'supplier_status' => 'dispatched',
            'dispatched_at' => now(),
        ]));

        Log::info('Order dispatched to supplier', [
            'order_id' => $this->order->id,
            'supplier_id' => $this->supplierId,
            'supplier_order_id' => $result->supplierOrderId,
        ]);
    }

    public function failed(Throwable $e): void
    {
        $this->order->update(['requires_manual_dispatch' => true]);

        Notification::route('mail', config('dropshipping.manager_email'))
            ->notify(new SupplierDispatchFailedNotification(
                $this->order,
                $this->supplierId,
                $e->getMessage()
            ));
    }
}

באמצעות תורי Laravel ומאזיני אירועים, אנו הופכים את כל תהליך שליחת ההזמנות ב-dropshipping לאוטומטי דרך REST API, דוא"ל או בוט Telegram. לפי תיעוד Laravel, תורים מספקים עיבוד אסינכרוני עם ניסיונות חוזרים מושהים.

פורמטים נתמכים להעברת הזמנות

בהתאם ליכולות הספק, אנו משתמשים בפרוטוקולים שונים:

class PollSupplierOrderStatusJob implements ShouldQueue {
    public function handle(): void {
        SupplierOrder::where('status', 'dispatched')
            ->where('placed_at', '>', now()->subDays(14))
            ->with('supplier')
            ->chunk(50, function ($supplierOrders) {
                foreach ($supplierOrders as $so) {
                    $connector = SupplierConnectorFactory::make($so->supplier);
                    $result = $connector->getOrderStatus($so->supplier_order_id);
                    if ($result->status !== $so->status) {
                        $so->update(['status' => $result->status, 'tracking_number' => $result->tracking]);
                        event(new SupplierOrderStatusChangedEvent($so, $result));
                    }
                }
            });
    }
}