הטמעת סנכרון מלאי עם ספק דרופשיפינג

הטמעת סנכרון מלאי עם ספק דרופשיפינג

האם אי פעם קרה שלקוח ביצע הזמנה ורק לאחר מכן הספק הודיע שהפריט אזל מהמלאי? זה מוביל להחזרות, לקוחות לא מרוצים ופגיעה במוניטין. זה כואב במיוחד כשהאתר שלך מציג מלאי זמין, אבל המלאי האמיתי כבר אפס. הפער בין חנות המסחר שלך למציאות יכול להיות שעות — ובפריטים פופולריים, דקות. על פי סטטיסטיקות, עד 30% מהזמנות הדרופשיפינג מבוטלות עקב חוסר מלאי; סנכרון אוטומטי מפחית את זה ל-5%. אנו מתמחים באוטומציה של דרופשיפינג וסנכרון מלאי מול ספקים. במאמר זה נראה לך כיצד להגדיר סנכרון אמין כדי להימנע מבעיות אלה.

כיצד לבחור אסטרטגיית סנכרון?

להלן האסטרטגיות העיקריות שבהן אנו משתמשים, בהתאם ליכולות הספק ולדרישות הדיוק. לכל אחת יש פשרות בין מהירות לעומס.

עבור רוב הפרויקטים, אנו משתמשים בשילוב: סנכרון דלתא כל 30–60 דקות בתוספת בדיקה בזמן אמת כשהפריט מתווסף לסל. זה מאזן בין עומס לדיוק. סנכרון דלתא מקצץ את כמות הנתונים המועברים לכ-10% מייבוא מלא, מה שמפחית משמעותית את זמן העיבוד.

מדוע בדיקה בזמן אמת חיונית?

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

class AddToCartAction { public function execute(Product $product, int $quantity, Cart $cart): void { // Для дропшиппинг-товаров проверяем остаток у поставщика if ($product->dropshipProduct && $this->shouldDoRealtimeCheck($product)) { $connector = SupplierConnectorFactory::make($product->dropshipProduct->supplier); $result = $connector->checkStock($product->dropshipProduct->supplier_sku); // Обновляем кэш $product->dropshipProduct->update([ 'supplier_stock' => $result->stock, 'synced_at' => now(), ]); if ($result->stock < $quantity) { throw new InsufficientStockException( available: $result->stock, requested: $quantity, ); } } $cart->addItem($product, $quantity); } private function shouldDoRealtimeCheck(Product $product): bool { // Проверяем в реальном времени, если последняя синхронизация была более 15 минут назад $lastSync = $product->dropshipProduct->synced_at; return !$lastSync || $lastSync->diffInMinutes(now()) > 15; } } 

מודל נתונים ורישום שינויים

כדי לעקוב אחר שינויי מלאי, אנו יוצרים טבלת לוג. זה מפשט ניפוי באגים וביקורת.

Schema::create('dropship_stock_log', function (Blueprint $table) { $table->id(); $table->foreignId('dropship_product_id')->constrained(); $table->integer('prev_stock'); $table->integer('new_stock'); $table->string('source')->default('sync'); // sync | webhook | realtime_check $table->timestamp('recorded_at'); $table->index(['dropship_product_id', 'recorded_at']); }); 

סנכרון מלא מתוזמן

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

class FullStockSyncJob implements ShouldQueue { public $timeout = 1800; // 30 минут для крупных каталогов public function handle(): void { $suppliers = Supplier::where('is_active', true)->get(); foreach ($suppliers as $supplier) { SyncSupplierStockJob::dispatch($supplier)->onQueue('stock-sync'); } } } class SyncSupplierStockJob implements ShouldQueue { public $tries = 3; public $backoff = [60, 300, 900]; public function handle(SupplierConnectorFactory $factory): void { $connector = $factory->make($this->supplier); $page = 1; $updated = 0; do { $products = $connector->getStockLevels($page, 500); foreach ($products as $item) { $dropshipProduct = DropshipProduct::where([ 'supplier_id' => $this->supplier->id, 'supplier_sku' => $item->sku, ])->first(); if (!$dropshipProduct) continue; if ($dropshipProduct->supplier_stock !== $item->stock) { $prevStock = $dropshipProduct->supplier_stock; $dropshipProduct->update([ 'supplier_stock' => $item->stock, 'synced_at' => now(), ]); // Обновляем остаток в каталоге магазина if ($dropshipProduct->product) { $this->updateProductAvailability($dropshipProduct->product, $item->stock); } // Логируем изменение DropshipStockLog::create([ 'dropship_product_id' => $dropshipProduct->id, 'prev_stock' => $prevStock, 'new_stock' => $item->stock, 'source' => 'sync', 'recorded_at' => now(), ]); $updated++; } } $page++; } while (count($products) === 500); Log::info('Stock sync completed', [ 'supplier' => $this->supplier->slug, 'updated' => $updated, ]); } private function updateProductAvailability(Product $product, int $newStock): void { $wasAvailable = $product->stock > 0; $isAvailable = $newStock > 0; $product->update(['stock' => $newStock]); // Уведомляем подписчиков «Сообщить о поступлении», если товар появился if (!$wasAvailable && $isAvailable) { event(new ProductBackInStockEvent($product)); } } } 

סנכרון דלתא ו-Webhook

אם ה-API של הספק תומך בפרמטר class AddToCartAction { public function execute(Product $product, int $quantity, Cart $cart): void { // Для дропшиппинг-товаров проверяем остаток у поставщика if ($product->dropshipProduct && $this->shouldDoRealtimeCheck($product)) { $connector = SupplierConnectorFactory::make($product->dropshipProduct->supplier); $result = $connector->checkStock($product->dropshipProduct->supplier_sku); // Обновляем кэш $product->dropshipProduct->update([ 'supplier_stock' => $result->stock, 'synced_at' => now(), ]); if ($result->stock < $quantity) { throw new InsufficientStockException( available: $result->stock, requested: $quantity, ); } } $cart->addItem($product, $quantity); } private function shouldDoRealtimeCheck(Product $product): bool { // Проверяем в реальном времени, если последняя синхронизация была более 15 минут назад $lastSync = $product->dropshipProduct->synced_at; return !$lastSync || $lastSync->diffInMinutes(now()) > 15; } } , אנו משתמשים בסנכרון דלתא במקום ייבוא מלא — אנו טוענים רק רשומות שהשתנו. זה מפחית עומס ומאיץ עדכונים. עבור ספקים שתומכים בהודעות push, אנו מגדירים Webhook — עדכוני מלאי תוך שניות.

// routes/api.php Route::post('/webhooks/supplier/{supplier:slug}/stock', SupplierStockWebhookController::class) ->middleware('verify.supplier.signature'); class SupplierStockWebhookController { public function __invoke(Request $request, Supplier $supplier): JsonResponse { foreach ($request->input('items', []) as $item) { UpdateDropshipStockJob::dispatch($supplier, $item['sku'], $item['stock']); } return response()->json(['ok' => true]); } } 

אילו סיכונים נוצרים ללא סנכרון?

ללא אוטומציה, אתה נאלץ ליישב מלאי ידנית, מה שלוקח שעות מדי יום. לקוחות רואים נתונים לא מדויקים, מה שמוביל לביטולי הזמנות ולירידה בדירוג החיפוש עקב שיעורי החזרה גבוהים. לפי הנתונים שלנו, אוטומציה מקצצת את ביטולי ההזמנות מ-30% ל-5%, וחוסכת עד 15% ממחזור החנות. עבור חנות עם מחזור חודשי של $100,000, זה חיסכון של $15,000 — הפתרון מחזיר את עצמו תוך 2–3 חודשים.

כיצד להימנע משאילתות N+1 בסנכרון מלא?

בקוד Schema::create('dropship_stock_log', function (Blueprint $table) { $table->id(); $table->foreignId('dropship_product_id')->constrained(); $table->integer('prev_stock'); $table->integer('new_stock'); $table->string('source')->default('sync'); // sync | webhook | realtime_check $table->timestamp('recorded_at'); $table->index(['dropship_product_id', 'recorded_at']); }); , כל class FullStockSyncJob implements ShouldQueue { public $timeout = 1800; // 30 минут для крупных каталогов public function handle(): void { $suppliers = Supplier::where('is_active', true)->get(); foreach ($suppliers as $supplier) { SyncSupplierStockJob::dispatch($supplier)->onQueue('stock-sync'); } } } class SyncSupplierStockJob implements ShouldQueue { public $tries = 3; public $backoff = [60, 300, 900]; public function handle(SupplierConnectorFactory $factory): void { $connector = $factory->make($this->supplier); $page = 1; $updated = 0; do { $products = $connector->getStockLevels($page, 500); foreach ($products as $item) { $dropshipProduct = DropshipProduct::where([ 'supplier_id' => $this->supplier->id, 'supplier_sku' => $item->sku, ])->first(); if (!$dropshipProduct) continue; if ($dropshipProduct->supplier_stock !== $item->stock) { $prevStock = $dropshipProduct->supplier_stock; $dropshipProduct->update([ 'supplier_stock' => $item->stock, 'synced_at' => now(), ]); // Обновляем остаток в каталоге магазина if ($dropshipProduct->product) { $this->updateProductAvailability($dropshipProduct->product, $item->stock); } // Логируем изменение DropshipStockLog::create([ 'dropship_product_id' => $dropshipProduct->id, 'prev_stock' => $prevStock, 'new_stock' => $item->stock, 'source' => 'sync', 'recorded_at' => now(), ]); $updated++; } } $page++; } while (count($products) === 500); Log::info('Stock sync completed', [ 'supplier' => $this->supplier->slug, 'updated' => $updated, ]); } private function updateProductAvailability(Product $product, int $newStock): void { $wasAvailable = $product->stock > 0; $isAvailable = $newStock > 0; $product->update(['stock' => $newStock]); // Уведомляем подписчиков «Сообщить о поступлении», если товар появился if (!$wasAvailable && $isAvailable) { event(new ProductBackInStockEvent($product)); } } } בתוך הלולאה הוא N+1 פוטנציאלי. עבור קטלוג של 10,000 SKU, זה 10,000 שאילתות. אנו מייעלים על ידי טעינת כל הרשומות הקיימות עבור הספק בשאילתה אחת לתוך updated_since, ולאחר מכן התאמה לפי מפתח. לחלופין, השתמש ב-// routes/api.php Route::post('/webhooks/supplier/{supplier:slug}/stock', SupplierStockWebhookController::class) ->middleware('verify.supplier.signature'); class SupplierStockWebhookController { public function __invoke(Request $request, Supplier $supplier): JsonResponse { foreach ($request->input('items', []) as $item) { UpdateDropshipStockJob::dispatch($supplier, $item['sku'], $item['stock']); } return response()->json(['ok' => true]); } } עם עדכון המוני, אך גרסאות דורשות זהירות.

ניטור והתראות

אנו מגדירים התראות ב-Telegram/Slack על כשלי סנכרון. כל שלב מתועד: מספר רשומות שעודכנו, זמן ביצוע, שגיאות API. זה מאפשר תגובה מהירה לבעיות. לדוגמה, אם הספק מחזיר HTTP 503, ה-job מנסה שוב אוטומטית לאחר 5 דקות עם backoff אקספוננציאלי.

'stock-sync' => [ 'driver' => 'database', 'connection' => 'mysql', 'table' => 'jobs', 'queue' => 'stock-sync', 'retry_after' => 1800, ],