cf_cloud/erp
3
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

!251 修复销量时间

Browse Source 
Merge pull request !251 from 杨建炊/fix-release-1.0.0/yjc-migrate
This commit is contained in:
杨建炊 2024-11-13 10:09:49 +00:00 committed by Gitee
commit 118cc6c749
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
4 changed files with 10 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
app/Http/Controllers/Goods/GoodsCombinationController.php
View File

@ -34,11 +34,8 @@ class GoodsCombinationController extends Controller
$orderRestTime = DeveloperConfig::query() $orderRestTime = DeveloperConfig::query()
->where('key', DeveloperConfig::$ORDER_RESET_TIME) ->where('key', DeveloperConfig::$ORDER_RESET_TIME)
->value('value'); ->value('value');
$time = date('Y-m-d 07:00:00');
if (is_null($orderRestTime)) { if (is_null($orderRestTime)) {
$orderRestTime = $time; $orderRestTime = date('Y-m-d 07:00:00');
} else {
$orderRestTime = Carbon::parse($orderRestTime)->lt(Carbon::parse($time)) ? $time : $orderRestTime;
} }
$businessOrderItems = BusinessOrderItem::query() $businessOrderItems = BusinessOrderItem::query()

12
app/Http/Controllers/Goods/GoodsSkusController.php
View File

@ -59,11 +59,8 @@ class GoodsSkusController extends Controller
$orderRestTime = DeveloperConfig::query() $orderRestTime = DeveloperConfig::query()
->where('key', DeveloperConfig::$ORDER_RESET_TIME) ->where('key', DeveloperConfig::$ORDER_RESET_TIME)
->value('value'); ->value('value');
$time = date('Y-m-d 07:00:00');
if (is_null($orderRestTime)) { if (is_null($orderRestTime)) {
$orderRestTime = $time; $orderRestTime = date('Y-m-d 07:00:00');
} else {
$orderRestTime = Carbon::parse($orderRestTime)->lt(Carbon::parse($time)) ? $time : $orderRestTime;
} }
$businessOrderItems = BusinessOrderItem::query() $businessOrderItems = BusinessOrderItem::query()
->select(DB::raw($fields)) ->select(DB::raw($fields))
@ -304,9 +301,6 @@ class GoodsSkusController extends Controller
$log = new LogModel(); $log = new LogModel();
$log->batchInsert($logs); $log->batchInsert($logs);
DB::commit(); DB::commit();
if (!empty($updateIds)) {
event(new BatchStockUpdateEvent($updateIds));
}
} catch (\Exception $exception) { } catch (\Exception $exception) {
DB::rollBack(); DB::rollBack();
$this->res = [ $this->res = [
@ -315,7 +309,9 @@ class GoodsSkusController extends Controller
'errorMessage' => $exception->getMessage(), 'errorMessage' => $exception->getMessage(),
]; ];
} }
if (!empty($updateIds)) {
event(new BatchStockUpdateEvent($updateIds));
}
return response($this->res, $this->res['httpCode']); return response($this->res, $this->res['httpCode']);
} }

7
app/Imports/SaleStockImport.php
View File

@ -71,13 +71,14 @@ class SaleStockImport implements ToArray, SkipsEmptyRows
$log = new LogModel(); $log = new LogModel();
$log->batchInsert($logs); $log->batchInsert($logs);
DB::commit(); DB::commit();
if (!empty($updateIds)) {
event(new BatchStockUpdateEvent($updateIds));
}
} catch (\Exception $exception) { } catch (\Exception $exception) {
DB::rollBack(); DB::rollBack();
throw new Exception($exception->getMessage()); throw new Exception($exception->getMessage());
} }
if (!empty($updateIds)) {
event(new BatchStockUpdateEvent($updateIds));
}
} }
} }
} }

2
app/Listeners/BatchStockUpdateListener.php
View File

@ -49,7 +49,7 @@ class BatchStockUpdateListener implements ShouldQueue
->where('external_sku_id', $goodsSku->external_sku_id) ->where('external_sku_id', $goodsSku->external_sku_id)
->get(); ->get();
BusinessFactory::init()->make($shop['plat_id'])->setShopWithId($shop['id'])->batchIncrQuantity($businessGoodsSkus->toArray(), $num, false); BusinessFactory::init()->make($shop['plat_id'])->setShopWithId($shop['id'])->batchIncrQuantity($businessGoodsSkus->toArray(), $num, false);
usleep(140); usleep(100);
} }
} }
} catch (\Exception $exception) { } catch (\Exception $exception) {