Observer
//注册观察器App\Providers\AppServiceProvider.php;class AppServiceProvider extends ServiceProvider{public function boot(){$this->addModelLog();}public function addModelLog(){User::observe(Observer::class);}}App\Observers\Observer.php<?phpnamespace App\Observers;use Illuminate\Database\Eloquent\Model;use App\Jobs\OrmObserver;class Observer{插入前public function creating(Model $model){}//插入后public function created(Model $model){}//修改前public function updating(Model $model){}//修改后public function updated(Model $model){}//删除前public function deleting(Model $model){}//删除后public funtion deleted(Model $model){}public funtion ObserverJob(){OrmObserver::dispatch(json_encode($data))->onConnection('redis')->onQueue('ObserverQueue');}}?>App\Job\OrmObserver;<?phpnamespace App\Jobs;use Illuminate\Bus\Queueable;use Illuminate\Contracts\Queue\ShouldQueue;use Illuminate\Foundation\Bus\Dispatchable;use Illuminate\Queue\InteractsWithQueue;use Illuminate\Queue\SerializesModels;use Illuminate\Support\Facades\Log;use Modules\Crm\Models\CrmOrmSqlLog;class OrmObserver implements ShouldQueue{use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;protected $data = [];public function __construct($data){$this->data = json_decode($data)}public function handle(){}?>
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号