| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859 |
- <?php
- namespace App\Observers;
- use App\Components\Helpers;
- use App\Jobs\VNet\addUser;
- use App\Jobs\VNet\delUser;
- use App\Jobs\VNet\editUser;
- use App\Models\User;
- use Arr;
- class UserObserver
- {
- public function created(User $user): void
- {
- $user->subscribe()->create(['code' => Helpers::makeSubscribeCode()]);
- $allowNodes = $user->nodes()->whereType(4)->get()->pluck('id');
- if (count($allowNodes)) {
- addUser::dispatch($user->id, $allowNodes);
- }
- }
- public function updated(User $user): void
- {
- $changes = $user->getChanges();
- $allowNodes = $user->nodes()->whereType(4)->get();
- $oldAllowNodes = $user->nodes($user->getOriginal('level'), $user->getOriginal('user_group_id'))->whereType(4)->get();
- if ($allowNodes->isNotEmpty() || $oldAllowNodes->isNotEmpty()) {
- if (Arr::hasAny($changes, ['level', 'user_group_id', 'enable'])) {
- if (Arr::has($changes, 'enable')) {
- if ($user->enable) { // TODO: 由于vnet未正确使用enable字段,临时解决方案
- addUser::dispatch($user->id, $allowNodes);
- } else {
- delUser::dispatch($user->id, $allowNodes);
- }
- } else {
- // 权限修改,消除重叠的部分
- if ($oldAllowNodes->isNotEmpty() && $oldAllowNodes->diff($allowNodes)->isNotEmpty()) {
- delUser::dispatch($user->id, $oldAllowNodes->diff($allowNodes));
- }
- if ($allowNodes->diff($oldAllowNodes)->isNotEmpty()) {
- addUser::dispatch($user->id, $allowNodes->diff($oldAllowNodes));
- }
- }
- } elseif (Arr::hasAny($changes, ['port', 'passwd', 'speed_limit'])) {
- editUser::dispatch($user, $allowNodes);
- }
- }
- }
- public function deleted(User $user): void
- {
- $allowNodes = $user->nodes()->whereType(4)->get();
- if ($allowNodes->isNotEmpty()) {
- delUser::dispatch($user->id, $allowNodes);
- }
- }
- }
|