123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130 |
- <?php
- namespace App\Console\Commands;
- use App\Components\Helpers;
- use App\Models\Order;
- use App\Models\Ticket;
- use App\Models\User;
- use App\Notifications\TicketClosed;
- use App\Services\OrderService;
- use Illuminate\Console\Command;
- use Log;
- class DailyJob extends Command
- {
- protected $signature = 'dailyJob';
- protected $description = '每日任务';
- public function handle(): void
- {
- $jobStartTime = microtime(true);
- // 过期用户处理
- $this->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 H:i:s'))->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,
- ]);
- Helpers::addUserBanLog($user->id, 0, '【禁止登录,清空账户】-账号已过期');
- // 废除其名下邀请码
- $user->invites()->whereStatus(0)->update(['status' => 2]);
- // 写入用户流量变动记录
- Helpers::addUserTrafficModifyLog($user->id, null, $user->transfer_enable, 0, '[定时任务]账号已过期(禁止登录,清空账户)');
- } else {
- $user->update([
- 'u' => 0,
- 'd' => 0,
- 'transfer_enable' => 0,
- 'enable' => 0,
- 'level' => 0,
- 'reset_time' => null,
- 'ban_time' => null,
- ]);
- Helpers::addUserBanLog($user->id, 0, '【封禁代理,清空账户】-账号已过期');
- // 写入用户流量变动记录
- Helpers::addUserTrafficModifyLog($user->id, null, $user->transfer_enable, 0, '[定时任务]账号已过期(封禁代理,清空账户)');
- }
- }
- }
- // 关闭超过72小时未处理的工单
- private function closeTickets(): void
- {
- foreach (Ticket::where('updated_at', '<=', date('Y-m-d', strtotime('-3 days')))->whereStatus(1)->get() as $ticket) {
- if ($ticket->close()) {
- $ticket->user->notify(new TicketClosed($ticket->id, $ticket->title, route('replyTicket', ['id' => $ticket->id]), __('You have not responded this ticket in :num hours, System has auto closed your ticket.', ['num' => '72'])));
- }
- }
- }
- // 重置用户流量
- private function resetUserTraffic(): void
- {
- $userList = User::where('status', '<>', -1)
- ->where('expired_at', '>', date('Y-m-d H:i:s'))
- ->where('reset_time', '<=', date('Y-m-d H:i:s'))
- ->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;
- // 重置流量与重置日期
- $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::warning('用户[ID:'.$user->id.' 昵称: '.$user->username.' 邮箱: '.$user->email.'] 流量重置失败');
- }
- }
- }
- }
|