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

!137 修改

Browse Source 
Merge pull request !137 from 赵世界/develop
This commit is contained in:
赵世界 2023-01-27 15:04:53 +00:00 committed by Gitee
commit 3652339136
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
1 changed files with 35 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
app/Imports/InventoryImport.php
View File

@ -32,46 +32,64 @@ class InventoryImport implements ToCollection, SkipsEmptyRows
}
unset($row);
$hasGoods = Goods::query()->whereIn('goods_code', $goodsCodes)->get(['id', 'goods_code'])->toArray();
$hasGoodsIds = array_column($hasGoods, 'id');
$hasGoods = ArrayUtils::index($hasGoods, 'goods_code');
$updateIds = [];
$day = DateTimeUtils::getToday();
$dateTime = date('Y-m-d H:i:s');
$hasGoodsSkus = GoodsSku::query()
->whereIn('goods_id', $hasGoodsIds)
->get(['id', 'status', 'stock', 'cost', 'sku_code', 'goods_id'])
->toArray();
foreach ($collection as $row) {
if (!isset($hasGoods[$row[0]])) {
continue;
}
$goodsSku = GoodsSku::query()
->select(['id', 'status', 'stock', 'cost'])
->where('goods_id', $hasGoods[$row[0]]['id'])
->where('sku_code', $row[4])
->first();
$goodsId = $hasGoods[$row[0]]['id'];
$goodsSku = [];
foreach ($hasGoodsSkus as $item) {
if ($item['sku_code'] === $row[4] && $item['goods_id'] === $goodsId) {
$goodsSku = $item;
break;
}
}
if (empty($goodsSku)) {
Log::warning(json_encode($row, 256) . '=====库存导入未找到');
continue;
}
$goodsSku->stock = $row[6] + $row[7];
if ('下架' === $goodsSku->status) {
$goodsSku->status = 1;
if ('下架' === $goodsSku['status']) {
GoodsSku::query()->where('id', $goodsSku['id'])->update([
'stock' => $row[6] + $row[7],
'cost' => $row[8],
'status' => 1,
]);
} else {
GoodsSku::query()->where('id', $goodsSku['id'])->update([
'stock' => $row[6] + $row[7],
'cost' => $row[8],
]);
}
$goodsSku->cost = $row[8];
$goodsSku->save();
$updateIds[] = $goodsSku->id;
DailyStockRecord::query()->where('sku_id', $goodsSku->id)->where('day', $day)->update([
$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
]);
}
sleep(2);
$onSkuIds = GoodsSku::query()
->where('status', '>', 0)
->pluck('id')
->toArray();
$downSkuIds = array_diff($onSkuIds, $updateIds);
foreach ($downSkuIds as $downSkuId) {
$goodsSku = GoodsSku::query()->select(['id', 'yesterday_num', 'stock'])->find($downSkuId);
$goodsSku->yesterday_num -= $goodsSku->stock;
$goodsSku->stock = 0;
$goodsSku->save();
$goodsSkus = GoodsSku::query()->whereIn('id', $downSkuIds)
->get(['id', 'yesterday_num', 'stock'])
->toArray();
foreach ($goodsSkus as $goodsSku) {
GoodsSku::query()->where('id', $goodsSku['id'])->update([
'yesterday_num' => $goodsSku['yesterday_num'] - $goodsSku['stock'],
'stock' => 0,
]);
}
sleep(2);
event(new StockUpdateEvent($onSkuIds, 1));