erp/app/Listeners/UpdateBusinessGoodsStock.php

64 lines
1.7 KiB
PHP
Raw Normal View History

2022-08-08 10:43:59 +08:00
<?php
namespace App\Listeners;
use App\Models\Log;
2022-08-08 10:43:59 +08:00
use App\Models\Shop;
use App\Services\Business\BusinessFactory;
2022-08-08 10:43:59 +08:00
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Queue\InteractsWithQueue;
use App\Events\BusinessOrdersUpdate;
use App\Jobs\BusinessGoodsSkuIncrQuantity;
2022-08-08 10:43:59 +08:00
2022-08-10 16:39:25 +08:00
class UpdateBusinessGoodsStock implements ShouldQueue
2022-08-08 10:43:59 +08:00
{
use InteractsWithQueue;
2022-08-08 10:43:59 +08:00
/**
* Create the event listener.
*
* @return void
*/
public function __construct()
2022-08-08 10:43:59 +08:00
{
//
2022-08-08 10:43:59 +08:00
}
/**
* Handle the event.
*
* @param BusinessOrdersUpdate $event
2022-08-08 10:43:59 +08:00
* @return void
*/
public function handle(BusinessOrdersUpdate $event)
2022-08-08 10:43:59 +08:00
{
if (empty($event->goodsSku)) {
$log = new Log();
$log->module = 'goods';
$log->action = 'PATCH';
$log->target_type = 'goods_sku';
$log->target_id = $event->goodsSku->id;
$log->target_field = 'stock';
$log->user_id = $event->businessOrderItem->shop_id;
$log->message = ($event->businessOrderItem->external_sku_id ?: '商品') . '未找到';
$log->save();
2022-08-16 21:02:31 +08:00
return;
}
$shops = Shop::query()->where('id', '<>', $event->businessOrderItem->shop_id)->where('status', 1)->get(['id', 'plat_id']);
if (empty($shops)) {
return;
}
foreach ($shops as $shop) {
2022-08-16 21:02:31 +08:00
$num = $event->num;
$isIncremental = true;
if ('妙选' === $shop->plat_id) {
$num = $event->goodsSku->stock;
$isIncremental = false;
}
BusinessGoodsSkuIncrQuantity::dispatch($shop, $event->businessOrderItem, $num, $isIncremental);
2022-08-10 16:39:25 +08:00
}
2022-08-08 10:43:59 +08:00
}
}