yjc/erp
1
0
Fork 0
mirror of https://gitee.com/hzchunfen/erp.git synced 2025-11-30 22:20:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: #10000 盘点导入修改

Browse Source
This commit is contained in:
赵世界 2022-09-17 01:53:58 +08:00
parent 5da97fe3cf
commit a853e1ecf4
1 changed files with 24 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
app/Imports/InventoryImport.php
View File

@ -8,11 +8,11 @@ use App\Models\GoodsSku;
use App\Utils\DateTimeUtils; use App\Utils\DateTimeUtils;
use Exception; use Exception;
use Illuminate\Support\Collection; use Illuminate\Support\Collection;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log; use Illuminate\Support\Facades\Log;
use Maatwebsite\Excel\Concerns\SkipsEmptyRows; use Maatwebsite\Excel\Concerns\SkipsEmptyRows;
use Maatwebsite\Excel\Concerns\ToCollection; use Maatwebsite\Excel\Concerns\ToCollection;
use App\Utils\ArrayUtils; use App\Utils\ArrayUtils;
use App\Events\StockUpdateEvent;
class InventoryImport implements ToCollection, SkipsEmptyRows class InventoryImport implements ToCollection, SkipsEmptyRows
{ {
@ -36,34 +36,30 @@ class InventoryImport implements ToCollection, SkipsEmptyRows
$updateIds = []; $updateIds = [];
$day = DateTimeUtils::getToday(); $day = DateTimeUtils::getToday();
$dateTime = date('Y-m-d H:i:s'); $dateTime = date('Y-m-d H:i:s');
DB::beginTransaction(); foreach ($collection as $row) {
try { if (!isset($hasGoods[$row[0]])) {
foreach ($collection as $row) { continue;
if (!isset($hasGoods[$row[0]])) {
continue;
}
$goodsSku = GoodsSku::query()
->where('goods_id', $hasGoods[$row[0]]['id'])
->where('sku_code', $row[4])
->first();
if (empty($goodsSku)) {
Log::warning(json_encode($row, 256) . '=====库存导入未找到');
continue;
}
$goodsSku->stock = $row[6] + $row[7];
$goodsSku->save();
$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
]);
} }
DB::commit(); $goodsSku = GoodsSku::query()
} catch (Exception $exception) { ->where('goods_id', $hasGoods[$row[0]]['id'])
DB::rollBack(); ->where('sku_code', $row[4])
// 返回错误 ->first();
throw $exception; if (empty($goodsSku)) {
Log::warning(json_encode($row, 256) . '=====库存导入未找到');
continue;
}
$goodsSku->stock = $row[6] + $row[7];
if ('下架' === $goodsSku->status) {
$goodsSku->status = 1;
}
$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
]);
} }
$onSkuIds = GoodsSku::query() $onSkuIds = GoodsSku::query()
->where('status', '<>', 0) ->where('status', '<>', 0)