neiyou_user_web/app/Console/Commands/DailyJob.php

<?php

namespace App\Console\Commands;

use App\Components\Helpers;
use App\Components\PushNotification;
use App\Models\Invite;
use App\Models\Order;
use App\Models\Ticket;
use App\Models\User;
use App\Models\UserBanedLog;
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'))
                           ->get();
        $isBanStatus = sysConfig('is_ban_status');
        foreach ($userList as $user) {
            if ($isBanStatus) {
                $user->update(
                    [
                        'u'               => 0,
                        'd'               => 0,
                        'transfer_enable' => 0,
                        'enable'          => 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,
                        '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 . '] 流量重置失败'
                );
            }
        }
    }

}