userExpireWarning(); } $jobEndTime = microtime(true); $jobUsedTime = round(($jobEndTime - $jobStartTime), 4); Log::info('---【'.$this->description.'】完成---,耗时'.$jobUsedTime.'秒'); } private function userExpireWarning() { // 只取没被禁用的用户,其他不用管 User::whereEnable(1) ->where('expired_at', '<', date('Y-m-d', strtotime(sysConfig('expire_days').' days'))) ->chunk(config('tasks.chunk'), function ($users) { foreach ($users as $user) { if (filter_var($user->email, FILTER_VALIDATE_EMAIL) === false) { // 用户名不是邮箱的跳过 continue; } $user->notify(new AccountExpire($user->expired_at)); } }); } }