diff --git a/app/Listeners/BatchStockUpdateListener.php b/app/Listeners/BatchStockUpdateListener.php index bd3c363..5250aa4 100644 --- a/app/Listeners/BatchStockUpdateListener.php +++ b/app/Listeners/BatchStockUpdateListener.php @@ -40,7 +40,11 @@ class BatchStockUpdateListener implements ShouldQueue try { foreach ($shops as $shop) { foreach ($event->goodsSkus as $goodsSku) { - $num = $goodsSku->sale_stock; + if ($shop['plat_id'] == "快团团") { + $num = $goodsSku->sale_stock; + } else { + $num = $goodsSku->stock; + } $businessGoodsSkus = BusinessGoodsSku::query() ->select(['goods_id', 'sku_id', 'external_sku_id']) ->where('shop_id', $shop->id) @@ -52,7 +56,7 @@ class BatchStockUpdateListener implements ShouldQueue } } } catch (\Exception $exception) { - Log::error("同步三方库存出现异常",[$exception->getMessage()]); + Log::error("同步三方库存出现异常", [$exception->getMessage()]); } } } diff --git a/app/Listeners/StockUpdateListener.php b/app/Listeners/StockUpdateListener.php index 612c50e..3bc4380 100644 --- a/app/Listeners/StockUpdateListener.php +++ b/app/Listeners/StockUpdateListener.php @@ -36,7 +36,11 @@ class StockUpdateListener implements ShouldQueue return; } foreach ($shops as $shop) { - $num = $event->goodsSku->sale_stock; + if ($shop['plat_id'] == "快团团") { + $num = $event->goodsSku->sale_stock; + } else { + $num = $event->goodsSku->stock; + } $businessGoodsSkus = BusinessGoodsSku::query() ->select(['goods_id', 'sku_id', 'external_sku_id']) ->where('shop_id', $shop->id) diff --git a/app/Listeners/UpdateBusinessGoodsStock.php b/app/Listeners/UpdateBusinessGoodsStock.php index 490a767..52c801f 100644 --- a/app/Listeners/UpdateBusinessGoodsStock.php +++ b/app/Listeners/UpdateBusinessGoodsStock.php @@ -60,7 +60,11 @@ class UpdateBusinessGoodsStock implements ShouldQueue } foreach ($shops as $shop) { - $num = $event->goodsSku->sale_stock;//同步三方和秒选虚拟库存 + if ($shop['plat_id'] == "快团团") { + $num = $event->goodsSku->sale_stock; + } else { + $num = $event->goodsSku->stock; + } $businessGoodsSkus = BusinessGoodsSku::query() ->where('shop_id', $shop->id) ->where('is_sync', 1)