NN2025081602/app/Services/Api/MemberService.php

<?php
// +----------------------------------------------------------------------
// | LARAVEL8.0 框架 [ LARAVEL ][ RXThinkCMF ]
// +----------------------------------------------------------------------
// | 版权所有 2017~2021 LARAVEL研发中心
// +----------------------------------------------------------------------
// | 官方网站: http://www.laravel.cn
// +----------------------------------------------------------------------
// | Author: laravel开发员 <laravel.qq.com>
// +----------------------------------------------------------------------

namespace App\Services\Api;

use App\Helpers\Jwt;
use App\Models\ActionLogModel;
use App\Models\MemberModel;
use App\Models\OrderModel;
use App\Models\VideoCoursesModel;
use App\Models\VideoOrderModel;
use App\Models\VipModel;
use App\Services\BaseService;
use App\Services\ConfigService;
use App\Services\MpService;
use App\Services\PaymentService;
use App\Services\RedisService;
use App\Services\SmsService;
use phpQrcode\QRcode;
use Illuminate\Support\Facades\DB;

/**
 * 会员管理-服务类
 * @author laravel开发员
 * @since 2020/11/11
 * Class MemberService
 * @package App\Services\Api
 */
class MemberService extends BaseService
{
    // 静态对象
    protected static $instance = null;


    /**
     * 构造函数
     * @author laravel开发员
     * @since 2020/11/11
     * MemberService constructor.
     */
    public function __construct()
    {
        $this->model = new MemberModel();
    }

    /**
     * 静态入口
     * @return MemberService|static|null
     */
    public static function make()
    {
        if (!self::$instance) {
            self::$instance = new static();
        }
        return self::$instance;
    }

    /**
     * 账号登录
     * @param $params
     * @return array|false
     */
    public function login($params)
    {
        // 账号登录
        $mobile = isset($params['mobile']) ? $params['mobile'] : '';
        $password = isset($params['password']) ? $params['password'] : '';
        if (empty($params) || empty($mobile) || empty($password)) {
            $this->error = 1041;
            return false;
        }

        // 验证是否注册，没有则注册
        $data = $this->model->where(['mobile' => $mobile, 'mark' => 1])->select(['id', 'mobile', 'user_type', 'password', 'nickname', 'code', 'status'])->first();
        $data = $data ? $data->toArray() : [];
        $userId = isset($data['id']) ? $data['id'] : 0;
        $status = isset($data['status']) ? $data['status'] : 0;
        $userPassword = isset($data['password']) ? $data['password'] : '';
        if (empty($data) || $userId <= 0) {
            $this->error = 2014;
            return false;
        }

        if ($status != 1) {
            $this->error = 2015;
            return false;
        }

        // 验证登录密码
        if (empty($userPassword) || $userPassword != get_password($password)) {
            $this->error = 2017;
            return false;
        }

        // 更新
        if (!RedisService::get("caches:members:login_{$userId}")) {
            $system = isset($params['system']) ? $params['system'] : [];
            $system = $system && !is_array($system) ? json_decode($system, true) : $system;
            $appSources = isset($system['app_sources']) && $system['app_sources'] ? $system['app_sources'] : 'ios';
            $uuid = isset($system['uuid']) ? $system['uuid'] : '';
            $version = isset($system['app_version']) ? $system['app_version'] : '';
            $updateData = [
                'update_time' => time(),
                'login_ip' => get_client_ip(),
                'login_time' => time(),
                'device_code' => $uuid,
                'login_count' => DB::raw("login_count+1"),
                'app_version' => $version,
                'device' => $appSources == 'ios' ? 1 : 2,
            ];
            $this->model->where(['id' => $userId])->update($updateData);
            RedisService::set("caches:members:login_{$userId}", $updateData, rand(300, 600));
        }


        // 获取登录授权token
        $jwt = new Jwt('jwt_jd_app');
        $token = $jwt->getToken($userId);

        // 结果返回
        $result = [
            'access_token' => $token,
            'info' => ['uid' => $userId, 'nickname' => $data['nickname']],
        ];

        // 用户缓存信息
        $this->error = 2019;
        $data['token'] = $token;
        unset($data['password']);
        unset($data['mobile']);
        RedisService::set("auths:info:{$userId}", $data, 24 * 3600);
        return $result;
    }

    /**
     * 授权登录
     * @param $code
     * @param array $params
     * @return array|false
     */
    public function mpAuth($code, $params = [])
    {
        // 账号登录
        if (empty($code)) {
            $this->error = 1041;
            return false;
        }

        // 获取授权用户信息
        $phone = '';
        $pcode = isset($params['pcode']) ? $params['pcode'] : '';
        if ($pcode) {
            $phoneData = MpService::make()->getPhoneNumber($pcode);
            $phoneData = isset($phoneData['phone_info']) ? $phoneData['phone_info'] : [];
            $phone = isset($phoneData['phoneNumber']) ? $phoneData['phoneNumber'] : '';
        }

        if (empty($phone)) {
            $this->error = 2014;
            return false;
        }

        $userInfo = MpService::make()->getUserInfo($code);
        $openid = isset($userInfo['openid']) ? $userInfo['openid'] : '';
        if (empty($userInfo)) {
            $this->error = MpService::make()->getError();
            return false;
        }

        if (empty($openid)) {
            $this->error = 1042;
            return false;
        }

        // 验证是否注册，没有则注册
        $where = ['mobile' => $phone, 'mark' => 1];
        $data = $this->model->where($where)
            ->select(['id', 'openid', 'mobile', 'user_type', 'nickname', 'entry_type', 'need_paper', 'code', 'status'])
            ->first();
        $data = $data ? $data->toArray() : [];
        $userId = isset($data['id']) ? $data['id'] : 0;
        $status = isset($data['status']) ? $data['status'] : 0;
        $entryType = isset($data['entry_type']) ? $data['entry_type'] : 0;
        $needPaper = isset($data['need_paper']) ? $data['need_paper'] : 0;
        if ($data && $userId && $status != 1) {
            $this->error = 2011;
            return false;
        }


        $system = isset($params['system']) ? $params['system'] : [];
        $system = $system && !is_array($system) ? json_decode($system, true) : $system;
        $appSources = isset($system['app_sources']) && $system['app_sources'] ? $system['app_sources'] : 'ios';
        $uuid = isset($system['uuid']) ? $system['uuid'] : '';
        $version = isset($system['app_version']) ? $system['app_version'] : '';
        if (empty($data)) {

            $userId = $this->model->max('id') + 1;
            $data = [
                'nickname' => $phone ? '微信用户' . substr($phone, -6, 6) : '微信用户' . $userId,
                'openid' => $openid,
                'mobile' => $phone,
                'password' => $phone ? get_password(substr($phone, -6, 6)) : get_password('123456'),
                'login_ip' => get_client_ip(),
                'create_time' => time(),
                'login_time' => time(),
                'login_count' => DB::raw("login_count+1"),
                'app_version' => $version,
                'app_uuid' => $uuid,
                'device' => $appSources == 'ios' ? 1 : 2,
            ];
            if ($this->model->insertGetId($data)) {
                $this->error = 2012;
                return false;
            }
        } // 更新登录信息
        else if (!RedisService::get("caches:members:login_{$userId}")) {
            $updateData = [
                'login_ip' => get_client_ip(),
                'create_time' => time(),
                'login_time' => time(),
                'app_uuid' => $uuid,
                'login_count' => DB::raw("login_count+1"),
                'app_version' => $version,
                'device' => $appSources == 'ios' ? 1 : 2,
            ];
            if ($openid) {
                $updateData['openid'] = $openid;
            }
            $this->model->where(['id' => $userId])->update($updateData);
            RedisService::set("caches:members:login_{$userId}", $updateData, rand(180, 300));
        }

        // 获取登录授权token
        $jwt = new Jwt('jwt_jd_app');
        $token = $jwt->getToken($userId);

        // 结果返回
        $setEntry = $entryType && $needPaper ? 1 : 0;
        $result = [
            'access_token' => $token,
            'info' => ['uid' => $userId, 'openid' => $openid, 'set_entry' => $setEntry, 'nickname' => $data['nickname']],
        ];

        // 用户缓存信息
        $this->error = 2013;
        $data['token'] = $token;
        unset($data['mobile']);
        RedisService::set("auths:info:{$userId}", $data, 24 * 3600);
        return $result;
    }

    /**
     * 重置密码
     * @param $params
     * @return array|false
     */
    public function forget($params)
    {
        // 账号登录
        $mobile = isset($params['mobile']) ? trim($params['mobile']) : '';
        $password = isset($params['password']) ? trim($params['password']) : '';
        if (empty($params) || empty($mobile) || empty($password)) {
            $this->error = 1041;
            return false;
        }

        // 验证码验证
        $smsCode = isset($params['sms_code']) ? trim($params['sms_code']) : '';
        if (!SmsService::make()->check($mobile, $smsCode, 'reset_password')) {
            $this->error = SmsService::make()->getError();
            return false;
        }

        // 验证是否注册
        if (!$userId = $this->model->where(['mobile' => $mobile, 'mark' => 1])->value('id')) {
            $this->error = 1038;
            return false;
        }

        if (!$this->model->where(['id' => $userId])->update(['password' => get_password($password), 'update_time' => time()])) {
            $this->error = 2030;
            return false;
        }

        // 操作日志
        ActionLogModel::setRecord($userId, ['type' => 2, 'title' => '重置密码', 'content' => '重置登录密码', 'module' => 'member']);
        ActionLogModel::record();

        $this->error = 2031;
        return true;
    }

    /**
     * 获取资料详情
     * @param $where
     * @param array $field
     */
    public function getInfo($where, array $field = [], $refresh = true)
    {
        $cacheKey = "caches:members:info_" . (!is_array($where) ? $where . '_' : '') . md5(json_encode($where) . json_encode($field));
        $info = RedisService::get($cacheKey);
        if ($info && !$refresh) {
            return $info;
        }

        $defaultField = ['id', 'user_type', 'realname', 'mobile', 'nickname', 'is_zg_vip', 'zg_vip_expired', 'is_zsb_vip', 'is_zsb_vip', 'zsb_vip_expired', 'is_video_vip', 'video_vip_expired', 'balance', 'code', 'openid', 'status', 'avatar'];
        $field = $field ? $field : $defaultField;
        if (is_array($where)) {
            $info = $this->model->where(['mark' => 1])->where($where)->select($field)->first();
        } else {
            $info = $this->model->where(['mark' => 1])->where(['id' => (int)$where])->select($field)->first();
        }

        $info = $info ? $info->toArray() : [];
        if ($info) {
            if (isset($info['avatar'])) {
                $info['avatar'] = $info['avatar'] ? get_image_url($info['avatar']) : '';
            }

            if (isset($info['mobile'])) {
                $info['mobile_text'] = $info['mobile'] ? format_mobile($info['mobile']) : '';
            }

            if (isset($info['create_time'])) {
                $info['create_at'] = datetime(strtotime($info['create_time']));
            }

            $isVip = 0;
            $vipExpired = '';
            $isZgVip = isset($info['is_zg_vip']) ? $info['is_zg_vip'] : 0;
            $zgVipExpired = isset($info['zg_vip_expired']) && !empty($info['zg_vip_expired']) ? $info['zg_vip_expired'] : '';
            if ($isZgVip==1 && $zgVipExpired && $zgVipExpired > date('Y-m-d H:i:s')) {
                $isVip = 1;
                $isZgVip = 1;
                $vipExpired = $zgVipExpired;
            } else {
                $isZgVip = 0;
            }

            $isZsbVip = isset($info['is_zsb_vip']) ? $info['is_zsb_vip'] : 0;
            $zsbVipExpired = isset($info['zsb_vip_expired']) && !empty($info['zsb_vip_expired']) ? $info['zsb_vip_expired'] : '';
            if ($isZsbVip==1 && $zsbVipExpired && $zsbVipExpired > date('Y-m-d H:i:s')) {
                $isVip = 1;
                $vipExpired = $zsbVipExpired > $vipExpired ? $zsbVipExpired : $vipExpired;
            } else {
                $isZsbVip = 0;
            }

            $isVideoVip = isset($info['is_video_vip']) ? $info['is_video_vip'] : 0;
            $videoVipExpired = isset($info['video_vip_expired']) && !empty($info['video_vip_expired']) ? $info['video_vip_expired'] : '';
            if ($isVideoVip==1 && $videoVipExpired && $videoVipExpired > date('Y-m-d H:i:s')) {
                $isVideoVip = 1;
            } else {
                $isVideoVip = 0;
            }

            $info['is_vip'] = $isVip;
            $info['is_zg_vip'] = $isZgVip;
            $info['is_zsb_vip'] = $isZsbVip;
            $info['vip_expired'] = $vipExpired;
            $info['zg_vip_expired'] = $zgVipExpired;
            $info['zg_vip_day'] = max(0, intval((strtotime($zgVipExpired) - time())/86400));
            $info['zsb_vip_expired'] = $zsbVipExpired;
            $info['zsb_vip_day'] = max(0, intval((strtotime($zsbVipExpired) - time())/86400));
            $info['is_video_vip'] = $isVideoVip;
            $info['video_vip_expired'] = $videoVipExpired;
            $info['video_vip_day'] = max(0, intval((strtotime($videoVipExpired) - time())/86400));
            RedisService::set($cacheKey, $info, rand(5, 10));
        }

        return $info;
    }

    /**
     * 生成普通参数二维码
     * @param $str 参数
     * @param bool $refresh 是否重新生成
     * @return bool
     */
    public function makeQrcode($str, $refresh = false, $size = 4, $margin = 2, $level = 2)
    {
        $basePath = base_path() . '/public';
        $qrFile = '/images/qrcode/';
        if (!is_dir($basePath . '/uploads' . $qrFile)) {
            @mkdir($basePath . '/uploads' . $qrFile, 0755, true);
        }

        $key = date('Ymd') . strtoupper(md5($str . '_' . $size . $margin . $level));
        $qrFile = $qrFile . "C_{$key}.png";
        $cacheKey = "caches:qrcodes:member_" . $key;
        if (RedisService::get($cacheKey) && is_file($basePath . '/uploads' . $qrFile) && !$refresh) {
            return $qrFile;
        }

        QRcode::png($str, $basePath . '/uploads' . $qrFile, $level, $size, $margin);
        if (!file_exists($basePath . '/uploads' . $qrFile)) {
            return false;
        }
        RedisService::set($cacheKey, ['str' => $str, 'qrcode' => $qrFile, 'date' => date('Y-m-d H:i:s')], 7 * 24 * 3600);
        return $qrFile;
    }

    /**
     * 修改头像
     * @param $userId
     * @param $avatar
     * @return mixed
     */
    public function saveAvatar($userId, $avatar)
    {
        $oldAvatar = $this->model->where(['id' => $userId])->value('avatar');
        if ($this->model->where(['id' => $userId])->update(['avatar' => $avatar, 'update_time' => time()])) {
            if ($oldAvatar && file_exists(ATTACHMENT_PATH . $oldAvatar)) {
                @unlink(ATTACHMENT_PATH . $oldAvatar);
            }
            return true;
        }

        return false;
    }

    /**
     * 修改账号信息
     * @param $userId
     * @param $params
     * @return bool
     */
    public function modify($userId, $params)
    {
        $cacheLockKey = "caches:members:modify_{$userId}";
        if (RedisService::get($cacheLockKey)) {
            $this->error = 1034;
            return false;
        }

        // 用户验证
        RedisService::set($cacheLockKey, ['user_id' => $userId, 'params' => $params], rand(2, 3));
        $info = $this->model->where(['id' => $userId, 'mark' => 1])
            ->select(['id', 'password', 'status'])
            ->first();
        $userPassword = isset($info['password']) ? $info['password'] : '';
        if (!$info || $info['status'] != 1) {
            $this->error = 1029;
            RedisService::clear($cacheLockKey);
            return false;
        }

        // 密码校验
        $data = ['update_time' => time()];
        // 修改数据
        $nickname = isset($params['nickname']) ? $params['nickname'] : '';
        if (isset($params['nickname']) && $nickname) {
            $data['nickname'] = $nickname;
        }

        $mobile = isset($params['mobile']) ? $params['mobile'] : '';
        if (isset($params['mobile']) && $mobile) {
            $data['mobile'] = $mobile;
        }

        $password = isset($params['password']) ? $params['password'] : '';
        $newPassword = isset($params['new_password']) ? $params['new_password'] : '';
        if (isset($params['password']) && $password) {
            if ($userPassword != get_password($password)) {
                $this->error = 1038;
                RedisService::clear($cacheLockKey);
                return false;
            }

            if (empty($newPassword)) {
                $this->error = 1039;
                RedisService::clear($cacheLockKey);
                return false;
            }
            $data['password'] = get_password($newPassword);
        }

        // 头像
        $avatar = isset($params['avatar']) ? $params['avatar'] : '';
        if (isset($params['avatar']) && $avatar) {
            $data['avatar'] = get_image_path($avatar);
        }

        if (!$this->model->where(['id' => $userId])->update($data)) {
            $this->error = 1014;
            RedisService::clear($cacheLockKey);
            return false;
        }

        $oldAvatar = isset($info['avatar']) ? $info['avatar'] : '';
        if ($avatar && $oldAvatar && ($avatar != $oldAvatar) && file_exists(ATTACHMENT_PATH . $oldAvatar)) {
            @unlink(ATTACHMENT_PATH . $oldAvatar);
        }

        $this->error = 1013;
        RedisService::clear($cacheLockKey);
        return true;
    }

    /**
     * 设置入口类型
     * @param $userId
     * @param $params
     * @return bool
     */
    public function setEntry($userId, $params)
    {
        $cacheLockKey = "caches:members:entry_{$userId}";
        if (RedisService::get($cacheLockKey)) {
            $this->error = 1034;
            return false;
        }

        // 用户验证
        RedisService::set($cacheLockKey, ['user_id' => $userId, 'params' => $params], rand(2, 3));
        $info = $this->model->where(['id' => $userId, 'mark' => 1])
            ->select(['id', 'password', 'status'])
            ->first();
        if (!$info || $info['status'] != 1) {
            $this->error = 1043;
            RedisService::clear($cacheLockKey);
            return false;
        }

        // 密码校验
        $data = [
            'entry_type' => isset($params['entry_type']) ? intval($params['entry_type']) : 0,
            'need_paper' => isset($params['need_paper']) ? intval($params['need_paper']) : 0,
            'update_time' => time()
        ];

        if (!$this->model->where(['id' => $userId])->update($data)) {
            $this->error = 1020;
            RedisService::clear($cacheLockKey);
            return false;
        }

        $this->error = 1019;
        RedisService::clear($cacheLockKey);
        return true;
    }

    /**
     * 获取VIP类别
     * @param int $type
     * @return array|mixed
     */
    public function getVipList($type = 1)
    {
        $cacheKey = "caches:members:vipList:{$type}";
        $datas = RedisService::get($cacheKey);
        if ($datas) {
            return $datas;
        }

        $datas = VipModel::where(['type' => $type, 'status' => 1, 'mark' => 1])
            ->select(['id', 'name', 'type', 'price','original_price', 'day', 'remark', 'status'])
            ->orderBy('id', 'asc')
            ->get();
        $datas = $datas ? $datas->toArray() : [];
        if ($datas) {
            RedisService::set($cacheKey, $datas, rand(3600, 7200));
        }

        return $datas;
    }

    /**
     * 购买VIP
     * @param $userId
     * @param $vipId
     * @return array|false
     */
    public function vipBuy($userId, $params)
    {
        $vipId = isset($params['id'])? $params['id'] : 0; // VIP
        $cId = isset($params['cid'])? $params['cid'] : 0; // 课程ID
        $cacheKey = "caches:members:vipBuy:{$userId}_{$vipId}";
        if (RedisService::get($cacheKey . '_lock')) {
            $this->error = '请不要频繁提交～';
            return false;
        }

        RedisService::set($cacheKey, ['date' => date('Y-m-d H:i:s')], rand(2, 3));
        $vipInfo = VipModel::where(['id' => $vipId, 'status' => 1, 'mark' => 1])
            ->select(['id','name', 'type', 'price', 'day', 'status'])
            ->first();
        $price = isset($vipInfo['price']) ? floatval($vipInfo['price']) : 0;
        $day = isset($vipInfo['day']) ? intval($vipInfo['day']) : 0;
        $vipType = isset($vipInfo['type']) && $vipInfo['type']? intval($vipInfo['type']) : 1;
        $vipName = isset($vipInfo['name'])? $vipInfo['name'] : '';
        if (empty($vipInfo)) {
            $this->error = '该VIP已下架';
            RedisService::clear($cacheKey . '_lock');
            return false;
        }

        if ($price <= 0 || $day <= 0) {
            $this->error = '该VIP参数错误';
            RedisService::clear($cacheKey . '_lock');
            return false;
        }

        $info = $this->model->where(['id' => $userId, 'mark' => 1])
            ->select(['id','openid','mobile','is_zg_vip', 'zg_vip_expired','is_zsb_vip','zsb_vip_expired','is_video_vip','video_vip_expired', 'status'])
            ->first();
        $isZgVip = isset($info['is_zg_vip'])? $info['is_zg_vip'] : 0;
        $isZsbVip = isset($info['is_zsb_vip'])? $info['is_zsb_vip'] : 0;
        $isVideoVip = isset($info['is_video_vip'])? $info['is_video_vip'] : 0;
        $zgVipExpired = isset($info['zg_vip_expired'])? $info['zg_vip_expired'] : '';
        $zsbVipExpired = isset($info['zsb_vip_expired'])? $info['zsb_vip_expired'] : '';
        $videoVipExpired = isset($info['video_vip_expired'])? $info['video_vip_expired'] : '';
        $openid = isset($info['openid'])? $info['openid'] : '';
        if (!$info || $info['status'] != 1) {
            $this->error = 1045;
            RedisService::clear($cacheKey . '_lock');
            return false;
        }

        if(empty($openid)){
            $this->error = '用户参数错误，请重新授权登录后尝试～';
            RedisService::clear($cacheKey . '_lock');
            return false;
        }

        // 验证是否
        $goodsId = 0;
        $scene = 'vip';
        $expiredTime = time();
        if($vipId == 5){
            // 单节视频验证是否已付费过
            if(VideoOrderModel::where(['goods_id'=> $vipId,'status'=>2,'mark'=>1])->where('expired_at','>', date('Y-m-d H:i:s'))->value('id')){
                $this->error = '抱歉，您已购买过该节视频课，请刷新后尝试观看～';
                return false;
            }

            // 视频数据
            $goodsId = $cId;
            $scene = 'course';
            $courseInfo = VideoCoursesModel::where(['id'=>$goodsId,'status'=>1,'mark'=>1])->select(['id','fee','course_name','status'])->first();
            $fee = isset($courseInfo['fee'])?$courseInfo['fee'] : 0;
            if(empty($courseInfo)){
                $this->error = '抱歉，您购买的课程已下架，请刷新后重试～';
                return false;
            }

            if($fee<=0){
                $this->error = '抱歉，您购买的课程为免费课程，请刷新后直接观看～';
                return false;
            }
        }else {
            // VIP 验证
            $goodsId = $vipId;
            $vipLimitOpen = ConfigService::make()->getConfigByCode('vip_limit_more', 0);
            if($vipLimitOpen){
                // 已开通职高VIP无法再开通
                if($vipType == 1 && ($isZgVip==1 && $zgVipExpired >= date('Y-m-d H:i:s'))){
                    $this->error = '抱歉，您的职高VIP未到期，到期后再尝试～';
                    return false;
                }

                // 已开通专升本VIP无法再开通
                if($vipType == 2 && ($isZsbVip==1 && $zsbVipExpired >= date('Y-m-d H:i:s'))){
                    $this->error = '抱歉，您的专升本VIP未到期，到期后再尝试～';
                    return false;
                }

                // 已开通全部视频VIP无法再开通
                if($vipType == 3 && ($isVideoVip && $videoVipExpired >= date('Y-m-d H:i:s'))){
                    $this->error = '抱歉，您的已开通全部视频VIP，请到期后再尝试～';
                    return false;
                }
            }else{
                if($vipType == 1 && $isZgVip==1 && $zgVipExpired >= date('Y-m-d H:i:s')){
                    $expiredTime = strtotime($zgVipExpired);
                }

                if($vipType == 2 && $isZsbVip==1 && $zsbVipExpired >= date('Y-m-d H:i:s')){
                    $expiredTime = strtotime($zsbVipExpired);
                }

                if($vipType == 3 && $isVideoVip==1 && $videoVipExpired >= date('Y-m-d H:i:s')){
                    $expiredTime = strtotime($videoVipExpired);
                }
            }
        }

        // 创建订单
        $orderNo = get_order_num('VP');
        $remark = $vipType==3? "购买{$vipName}" : "购买{$vipName}VIP";
        $order = [
            'order_no'=> $orderNo,
            'user_id'=> $userId,
            'goods_id'=> $goodsId,
            'total'=> $price,
            'expired_at'=> date('Y-m-d H:i:s', $expiredTime + $day * 86400),
            'create_time'=> time(),
            'remark'=> $remark,
            'status'=>1,
            'mark'=>1
        ];

        DB::beginTransaction();
        $model = $vipId==5? new VideoOrderModel : new OrderModel;
        if(!$orderId = $model::insertGetId($order)){
            $this->error = '创建VIP订单失败';
            return false;
        }

        /* TODO 支付处理 */
        $payOrder = [
            'type'=> 1,
            'order_no'=> $orderNo,
            'pay_money'=> $price,
            'body'=> $remark,
            'openid'=> $openid
        ];

        // 调起支付
        $payment = PaymentService::make()->minPay($info, $payOrder,$scene);
        if(empty($payment)){
            DB::rollBack();
            RedisService::clear($cacheKey.'_lock');
            $this->error = PaymentService::make()->getError();
            return false;
        }

        // 用户操作记录
        DB::commit();
        $this->error = '创建VIP订单成功，请前往支付～';
        RedisService::clear($cacheKey.'_lock');
        RedisService::keyDel("caches:videos:list_by_group*");
        RedisService::clear("caches:videos:info_{$userId}_{$cId}");
        return [
            'order_id'=> $orderId,
            'payment'=> $payment,
            'total'=> $payOrder['pay_money'],
            'pay_type'=> 10,
        ];

    }
}