Laravel如何使用Observer实现日志管理模块
时间:2022-03-03 11:48
写在前面: 1、创建observer文件,我这里是要记录仓库库存模块的操作日志,所以执行下面的语句,会在app/Observers下面创建WarehouseInventoryObserver文件。 由于模型都是放在app/Models下面,所以要指定路径。 在App\Providers\AppServiceProvider下面开启observer 2、监听该模块下的增删改操作,这里使用Repository当然也可以直接使用model。created、updated、deleted分别监听WarehouseInventory模型的新增、更新和删除的操作。 3、数据库 以上就是Laravel如何使用Observer实现日志管理模块的详细内容,更多请关注www.gxlsystem.com其它相关文章!
这里实现日志管理写了两篇,第一篇是简单的模型增删改监听并记录日志。第二篇主要介绍的是通过导入文件进行批量数据处理无法很好的被监听处理到,这一部分的数据处理逻辑如何被记录下来。详细请看Laravel日志管理记录导入文件后的数据变化。php artisan make:observer WarehouseInventoryObserver --model=WarehouseInventory
php artisan make:observer WarehouseInventoryObserver --model=Models/WarehouseInventory
public function boot()
{
WarehouseInventory::observe(WarehouseInventoryObserver::class);
}
<?phpnamespace App\Observers;use App\Models\Warehouse;use App\Models\WarehouseInventory;use App\Repositories\ActionLogRepository;use Illuminate\Support\Arr;use Illuminate\Support\Facades\Auth;class WarehouseInventoryObserver{
protected $user_id;
protected $warehouse;
protected $actionLogRepository;
public function __construct(
Warehouse $warehouse,
ActionLogRepository $actionLogRepository
)
{
$this->user_id = Auth::user() ? Auth::user()->id : null;
$this->warehouse = $warehouse->pluck('name', 'id');
$this->actionLogRepository = $actionLogRepository;
}
//创建
public function created(WarehouseInventory $warehouseInventory)
{
if (!empty($this->user_id)) {
$attributes = $warehouseInventory->getAttributes();
$attributes = Arr::only($attributes, ['warehouse_id', 'seller_sku', 'quantity', 'box']);
$warehouse = $this->warehouse->get($attributes['warehouse_id']);
//拼接数据
$data = [
'module' => 'warehouse_inventory',
'user_id' => $this->user_id,
'type' => 'create',
'content' => [
'warehouse' => $warehouse,
'seller_sku' => $attributes['seller_sku'],
'original_quantity' => 0,
'current_quantity' => $attributes['quantity'],
'box' => $attributes['box']
]
];
$this->actionLogRepository->makeModel()->create($data);
}
}
//更新
public function updated(WarehouseInventory $warehouseInventory)
{
if (!empty($this->user_id)) {
$original = $warehouseInventory->getOriginal();
$dirty = $warehouseInventory->getDirty();
$dirty = Arr::except($dirty, ['remark', 'updated_at']);
if (count($dirty)) {
if (Arr::has($dirty, 'warehouse_id')) {
$warehouse = $this->warehouse->get($dirty['warehouse_id']);
} else {
$warehouse = $this->warehouse->get($original['warehouse_id']);
}
//拼接数据
$data = [
'module' => 'warehouse_inventory',
'user_id' => $this->user_id,
'type' => 'update',
'content' => [
'warehouse' => $warehouse,
'seller_sku' => $original['seller_sku'],
'original_quantity' => $original['quantity'],
'current_quantity' => $dirty['quantity'],
'box' => (Arr::has($dirty, 'box')) ? $dirty['box'] : $original['box']
]
];
$this->actionLogRepository->makeModel()->create($data);
}
}
}
//删除
public function deleted(WarehouseInventory $warehouseInventory)
{
if (!empty($this->user_id)) {
$original = $warehouseInventory->getOriginal();
$warehouse = $this->warehouse->get($original['warehouse_id']);
//拼接数据
$data = [
'module' => 'warehouse_inventory',
'user_id' => $this->user_id,
'type' => 'delete',
'content' => [
'warehouse' => $warehouse,
'seller_sku' => $original['seller_sku'],
'original_quantity' => $original['quantity'],
'current_quantity' => 0,
'box' => $original['box']
]
];
$this->actionLogRepository->makeModel()->create($data);
}
}}