From 16dca74eda08939771b8ead51a1ba4d7bfed8849 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=B5=B5=E4=B8=96=E7=95=8C?= <642747453@qq.com> Date: Thu, 3 Nov 2022 17:02:24 +0800 Subject: [PATCH 1/2] =?UTF-8?q?feat:=20#10000=20=E7=9B=98=E7=82=B9?= =?UTF-8?q?=E5=AF=BC=E5=85=A5=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/Imports/InventoryImport.php | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) diff --git a/app/Imports/InventoryImport.php b/app/Imports/InventoryImport.php index 4f0ce9b..58c2886 100644 --- a/app/Imports/InventoryImport.php +++ b/app/Imports/InventoryImport.php @@ -36,7 +36,6 @@ class InventoryImport implements ToCollection, SkipsEmptyRows $updateIds = []; $day = DateTimeUtils::getToday(); $dateTime = date('Y-m-d H:i:s'); - $syncIds = []; foreach ($collection as $row) { if (!isset($hasGoods[$row[0]])) { continue; @@ -55,17 +54,15 @@ class InventoryImport implements ToCollection, SkipsEmptyRows } $goodsSku->cost = $row[8]; $goodsSku->save(); -// event(new StockUpdateEvent($goodsSku)); $updateIds[] = $goodsSku->id; DailyStockRecord::query()->where('sku_id', $goodsSku->id)->where('day', $day)->update([ 'arrived_today_num' => $row[7], 'inventory' => $row[6], 'inventory_time' => $dateTime ]); - $syncIds[] = $goodsSku->id; } $onSkuIds = GoodsSku::query() - ->where('status', '<>', 0) + ->where('status', '>', 0) ->pluck('id') ->toArray(); $downSkuIds = array_diff($onSkuIds, $updateIds); @@ -74,9 +71,7 @@ class InventoryImport implements ToCollection, SkipsEmptyRows $goodsSku->yesterday_num -= $goodsSku->stock; $goodsSku->stock = 0; $goodsSku->save(); - $syncIds[] = $goodsSku->id; -// event(new StockUpdateEvent($goodsSku)); } - event(new StockUpdateEvent($syncIds)); + event(new StockUpdateEvent($onSkuIds)); } } From 1b9bd4bdf90aa58661809093fc8c02876f9eeff8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=B5=B5=E4=B8=96=E7=95=8C?= <642747453@qq.com> Date: Thu, 3 Nov 2022 17:09:48 +0800 Subject: [PATCH 2/2] =?UTF-8?q?feat:=20#10000=20=E7=9B=98=E7=82=B9?= =?UTF-8?q?=E5=AF=BC=E5=85=A5=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/Listeners/StockUpdateListener.php | 5 +---- app/Listeners/UpdateBusinessGoodsStock.php | 3 --- 2 files changed, 1 insertion(+), 7 deletions(-) diff --git a/app/Listeners/StockUpdateListener.php b/app/Listeners/StockUpdateListener.php index 6ae9761..e468ebb 100644 --- a/app/Listeners/StockUpdateListener.php +++ b/app/Listeners/StockUpdateListener.php @@ -34,7 +34,7 @@ class StockUpdateListener return; } foreach ($shops as $shop) { - if (isset($event->goodsSku) && '下架' !== $event->goodsSku->status) { + if (isset($event->goodsSku)) { $num = $event->goodsSku->stock; $businessGoodsSkus = BusinessGoodsSku::query()->where('shop_id', $shop->id)->where('is_sync', 1)->where('external_sku_id', $event->goodsSku->goods['goods_code'] . '_' . $event->goodsSku->sku_code)->get(); foreach ($businessGoodsSkus as $businessGoodsSku) { @@ -43,9 +43,6 @@ class StockUpdateListener } if (isset($event->goodsSkus)) { foreach ($event->goodsSkus as $goodsSku) { - if ('下架' === $goodsSku->status) { - continue; - } $num = $goodsSku->stock; $businessGoodsSkus = BusinessGoodsSku::query()->where('shop_id', $shop->id)->where('is_sync', 1)->where('external_sku_id', $goodsSku->goods['goods_code'] . '_' . $goodsSku->sku_code)->get(); foreach ($businessGoodsSkus as $businessGoodsSku) { diff --git a/app/Listeners/UpdateBusinessGoodsStock.php b/app/Listeners/UpdateBusinessGoodsStock.php index 992cc21..7efb6a5 100644 --- a/app/Listeners/UpdateBusinessGoodsStock.php +++ b/app/Listeners/UpdateBusinessGoodsStock.php @@ -46,9 +46,6 @@ class UpdateBusinessGoodsStock implements ShouldQueue return; } - if ('下架' === $event->goodsSku->status) { - return; - } $builder = Shop::query()->whereNotIn('status', [Shop::$STATUS_UNAUTHORIZED, Shop::$STATUS_STOP]); // 非订单影响库存变更,只更新本店铺下商品 if (!isset($event->businessGoods['business_order_id'])) {