diff --git a/app/Imports/InventoryImport.php b/app/Imports/InventoryImport.php index a1c99e2..4f0ce9b 100644 --- a/app/Imports/InventoryImport.php +++ b/app/Imports/InventoryImport.php @@ -36,6 +36,7 @@ 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; @@ -54,13 +55,14 @@ class InventoryImport implements ToCollection, SkipsEmptyRows } $goodsSku->cost = $row[8]; $goodsSku->save(); - event(new StockUpdateEvent($goodsSku)); +// 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) @@ -72,7 +74,9 @@ class InventoryImport implements ToCollection, SkipsEmptyRows $goodsSku->yesterday_num -= $goodsSku->stock; $goodsSku->stock = 0; $goodsSku->save(); - event(new StockUpdateEvent($goodsSku)); + $syncIds[] = $goodsSku->id; +// event(new StockUpdateEvent($goodsSku)); } + event(new StockUpdateEvent($syncIds)); } }