neiyou_user_web/app/Observers/UserObserver.php

<?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\Node;
use App\Models\User;
use App\Models\UserSubscribe;
use Arr;
use DB;
use Exception;
use Log;

class UserObserver
{

    public function created(User $user): void
    {
        $subscribe          = new UserSubscribe();
        $subscribe->user_id = $user->id;
        $subscribe->code    = Helpers::makeSubscribeCode();
        $subscribe->save();

        $allowNodes = Node::userAllowNodes($user->group_id, $user->level)
                          ->whereType(4)
                          ->get();
        if ($allowNodes) {
            addUser::dispatchNow($user->id, $allowNodes);
        }
    }

    public function updated(User $user): void
    {
        $changes    = $user->getChanges();
        $allowNodes = Node::userAllowNodes($user->group_id, $user->level)
                          ->whereType(4)
                          ->get();
        if ($allowNodes
            && Arr::exists($changes, 'level')
            || Arr::exists($changes, 'group_id')
            || Arr::exists($changes, 'port')
            || Arr::exists($changes, 'passwd')
            || Arr::exists($changes, 'speed_limit')
            || Arr::exists($changes, 'enable')) {
            editUser::dispatchNow($user, $allowNodes);
        }
    }

    public function deleting(User $user): void
    {
        try {
            DB::beginTransaction();
            // 邀请关系脱钩
            $user->invites()->delete();
            $user->invitees()->update(['inviter_id' => 0]);
            $user->commissionSettlements()->delete();
            $user->commissionLogs()->delete();

            $user->subscribe()->delete();
            $user->subscribeLogs()->delete();

            // 清理日志
            $user->orders()->delete();
            $user->payments()->delete();
            $user->onlineIpLogs()->delete();
            $user->ruleLogs()->delete();
            $user->tickets()->delete();
            $user->ticketReplies()->delete();
            $user->banedLogs()->delete();
            $user->creditLogs()->delete();
            $user->dailyDataFlows()->delete();
            $user->dataFlowLogs()->delete();
            $user->dataModifyLogs()->delete();
            $user->hourlyDataFlows()->delete();
            $user->loginLogs()->delete();
            $user->verify()->delete();

            DB::commit();
        } catch (Exception $e) {
            Log::error('删除用户相关信息错误：' . $e->getMessage());
            DB::rollBack();
        }
    }

    public function deleted(User $user): void
    {
        $allowNodes = Node::userAllowNodes($user->group_id, $user->level)
                          ->whereType(4)
                          ->get();
        if ($allowNodes) {
            delUser::dispatchNow($user->id, $allowNodes);
        }
    }

}