expireUser(); // 关闭超过72小时未处理的工单 $this->closeTickets(); // 重置用户流量 if (sysConfig('reset_traffic')) { $this->resetUserTraffic(); } $jobEndTime = microtime(true); $jobUsedTime = round(($jobEndTime - $jobStartTime), 4); Log::info('---【'.$this->description.'】完成---,耗时'.$jobUsedTime.'秒'); } private function expireUser(): void { // 过期用户处理 $userList = User::activeUser()->where('expired_at', '<', date('Y-m-d'))->get(); $isBanStatus = sysConfig('is_ban_status'); foreach ($userList as $user) { if ($isBanStatus) { $user->update([ 'u' => 0, 'd' => 0, 'transfer_enable' => 0, 'enable' => 0, 'level' => 0, 'reset_time' => null, 'ban_time' => null, 'status' => -1, ]); $this->addUserBanLog($user->id, 0, '【禁止登录,清空账户】-账号已过期'); // 废除其名下邀请码 Invite::whereInviterId($user->id)->whereStatus(0)->update(['status' => 2]); // 写入用户流量变动记录 Helpers::addUserTrafficModifyLog($user->id, 0, $user->transfer_enable, 0, '[定时任务]账号已过期(禁止登录,清空账户)'); } else { $user->update([ 'u' => 0, 'd' => 0, 'transfer_enable' => 0, 'enable' => 0, 'level' => 0, 'reset_time' => null, 'ban_time' => null, ]); $this->addUserBanLog($user->id, 0, '【封禁代理,清空账户】-账号已过期'); // 写入用户流量变动记录 Helpers::addUserTrafficModifyLog($user->id, 0, $user->transfer_enable, 0, '[定时任务]账号已过期(封禁代理,清空账户)'); } } } /** * 添加用户封禁日志. * * @param int $userId 用户ID * @param int $time 封禁时长,单位分钟 * @param string $description 封禁理由 * @return bool */ private function addUserBanLog(int $userId, int $time, string $description): bool { $log = new UserBanedLog(); $log->user_id = $userId; $log->time = $time; $log->description = $description; return $log->save(); } // 关闭超过72小时未处理的工单 private function closeTickets(): void { $ticketList = Ticket::where('updated_at', '<=', date('Y-m-d', strtotime('-3 days')))->whereStatus(1)->get(); foreach ($ticketList as $ticket) { $ret = Ticket::whereId($ticket->id)->update(['status' => 2]); if ($ret) { PushNotification::send('工单关闭提醒', '工单:ID'.$ticket->id.'超过72小时未处理,系统已自动关闭'); } } } // 重置用户流量 private function resetUserTraffic(): void { $userList = User::where('status', '<>', -1) ->where('expired_at', '>', date('Y-m-d')) ->where('reset_time', '<=', date('Y-m-d')) ->get(); foreach ($userList as $user) { // 跳过 没有重置日期的账号 if (! $user->reset_time) { continue; } // 取出用户正在使用的套餐 $order = Order::userActivePlan($user->id)->first(); // 无订单用户跳过 if (! $order) { continue; } // 过期生效中的加油包 Order::userActivePackage($user->id)->update(['is_expire' => 1]); $oldData = $user->transfer_enable; // 重置流量与重置日期 TODO 可用流量变动日志加入至UserObserver $ret = $user->update((new OrderService($order))->resetTimeAndData($user->expired_at)); if ($ret) { // 可用流量变动日志 Helpers::addUserTrafficModifyLog($order->user_id, $order->id, $oldData, $user->transfer_enable, '【流量重置】重置可用流量'); Log::info('用户[ID:'.$user->id.' 昵称: '.$user->username.' 邮箱: '.$user->email.'] 流量重置为 '.flowAutoShow($user->transfer_enable).'. 重置日期为 '.($user->reset_time ?: '【无】')); } else { Log::error('用户[ID:'.$user->id.' 昵称: '.$user->username.' 邮箱: '.$user->email.'] 流量重置失败'); } } } }