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); } } }