zy.uas.admin/app/api/controller/Account.php

<?php

namespace app\api\controller;

use ba\Date;
use ba\Captcha;
use ba\Random;
use think\console\output\Formatter;
use think\facade\Db;
use app\common\model\User;
use app\common\facade\Token;
use app\common\model\UserScoreLog;
use app\common\model\UserMoneyLog;
use app\common\controller\Frontend;
use think\db\exception\PDOException;
use think\exception\ValidateException;
use app\api\validate\Account as AccountValidate;
use think\facade\Validate;
use app\common\model\FlightPlan as PlanModel;

class Account extends Frontend
{
    protected $noNeedLogin = ['retrievePassword'];
    
    protected $model = null;
    
    public function initialize()
    {
        parent::initialize();
    }
    
    public function overview()
    {
        $sevenDays = Date::unixtime('day', -6);
        $score     = $money = $days = [];
        for ($i = 0; $i < 7; $i++) {
            $days[$i]    = date("Y-m-d", $sevenDays + ($i * 86400));
            $tempToday0  = strtotime($days[$i]);
            $temptoday24 = strtotime('+1 day', $tempToday0) - 1;
            $score[$i]   = UserScoreLog::where('user_id', $this->auth->id)
                ->where('createtime', 'BETWEEN', $tempToday0 . ',' . $temptoday24)
                ->sum('score');
            
            $userMoneyTemp = UserMoneyLog::where('user_id', $this->auth->id)
                ->where('createtime', 'BETWEEN', $tempToday0 . ',' . $temptoday24)
                ->sum('money');
            $money[$i]     = bcdiv($userMoneyTemp, 100, 2);
        }
        
        $this->success('', [
            'days'  => $days,
            'score' => $score,
            'money' => $money,
        ]);
    }
    
    public function profile()
    {
        if ($this->request->isPost()) {
            $data = $this->request->only(['id', 'avatar', 'username', 'nickname', 'gender', 'birthday', 'motto']);
            if (!isset($data['birthday'])) $data['birthday'] = null;
            
            Db::startTrans();
            try {
                $validate = new AccountValidate();
                $validate->scene('edit')->check($data);
                $this->auth->getUser()->where('id', $this->auth->id)->update($data);
                Db::commit();
            } catch (ValidateException|PDOException $e) {
                Db::rollback();
                $this->error($e->getMessage());
            }
            
            $this->success(__('Data updated successfully~'));
        }
        
        $this->success('', [
            'accountVerificationType' => get_account_verification_type()
        ]);
    }
    
    public function realname()
    {
        if ($this->request->isPost()) {
            $data = $this->request->only(['real_name', 'identity', 'identity_img']);
            Db::startTrans();
            try {
                $validate = new AccountValidate();
                $validate->scene('realname')->check($data); // 验证规则,
                $this->auth->getUser()->where('id', $this->auth->id)->update($data);
                Db::commit();
            } catch (ValidateException|PDOException $e) {
                Db::rollback();
                $this->error($e->getMessage());
            }
            
            $this->success(__('Submitted successfully~'));
        }
    }
    
    public function certification()
    {
        if ($this->request->isPost()) {
            $data = $this->request->only(['license_type', 'pilot_license', 'city', 'address']);
            Db::startTrans();
            try {
                $validate = new AccountValidate();
                $validate->scene('certification')->check($data); // 验证规则,
                $this->auth->getUser()->where('id', $this->auth->id)->update($data);
                Db::commit();
            } catch (ValidateException|PDOException $e) {
                Db::rollback();
                $this->error($e->getMessage());
            }
            
            $this->success(__('Submitted successfully~'));
        }
    }
    
    public function applyFor()
    {
        if ($this->request->isPost()) {
            $data = $this->request->only(['username', 'real_name', 'license_type', 'mobile', 'pilot_license', 'city', 'flight_type', 'departure_point', 'planned_range', 'planned_height', 'aircraft_sn', 'aircraft_img', 'aircraft_brand', 'staff', 'staff_license', 'start_planning', 'end_planning']);
            
            Db::startTrans();
            
            try {
                $validate = new AccountValidate();
                $validate->scene('applyFor')->check($data); // 验证规则,
                
                // 更新用户表信息
                $this->auth->getUser()->where('id', $this->auth->id)->update($data);
                
                // 开始插入数据到新表
                
                $planModel = new PlanModel();
                $applyOrder = createOrderSn();
                $dataArr    = [
                    'user_id'          => $this->auth->id,
                    'username'         => $this->auth->username,
                    'group_id'         => $this->auth->group_id,
                    'applyfor_no'      => $applyOrder,
                    'business_id'      => $this->auth->business_id,
                    'real_name'        => $data['real_name'],
                    'real_name_status' => $this->auth->real_name_status,
                    'license_type'     => $data['license_type'],
                    'pilot_license'    => $data['pilot_license'],
                    'type'             => $data['flight_type'],
                    'city'             => $data['city'],
                    'departure_point'  => $data['departure_point'],
                    'range'            => $data['planned_range'],
                    'height'           => $data['planned_height'],
                    'aerocraft_sn'     => $data['aircraft_sn'],
                    'aerocraft_img'    => $data['aircraft_img'],
                    'start_time'       => $data['start_planning'],
                    'end_time'         => $data['end_planning'],
                    'staff'            => $data['staff'],
                    'staff_license'    => $data['staff_license'],
                    'createtime'       => time(),
                ];
                
                $existingPlan = $planModel->where('user_id', $this->auth->id)
                    ->whereDay('createtime')
                    ->find();
                
                // Todo: unset 'applyfor_no' when update
                if ($existingPlan) {
                    $planModel
                        ->where('id', $existingPlan->id)
                        ->data(['updatetime' => time()])
                        ->update($dataArr);
                } else {
                    $planModel->save($dataArr);
                }
                
                Db::commit();
            } catch (ValidateException|PDOException $e) {
                Db::rollback();
                $this->error($e->getMessage());
            }
            
            $this->success(__('Submitted successfully~'));
            
        }
    }
    
    /**
     * 通过手机号或邮箱验证账户
     * 此处检查的验证码是通过 api/Ems或api/Sms发送的
     * 验证成功后，向前端返回一个 email-pass Token或着 mobile-pass Token
     * 在 changBind 方法中，通过 pass Token来确定用户已经通过了账户验证（用户未绑定邮箱/手机时通过账户密码验证）
     */
    public function verification()
    {
        $captcha = new Captcha();
        $params  = $this->request->only(['type', 'captcha']);
        if ($captcha->check($params['captcha'], ($params['type'] == 'email' ? $this->auth->email : $this->auth->mobile) . "user_{$params['type']}_verify")) {
            $uuid = Random::uuid();
            Token::set($uuid, $params['type'] . '-pass', $this->auth->id, 600);
            $this->success('', [
                'type'                     => $params['type'],
                'accountVerificationToken' => $uuid,
            ]);
        }
        $this->error(__('Please enter the correct verification code'));
    }
    
    /**
     * 修改绑定信息（手机号、邮箱）
     * 通过 pass Token来确定用户已经通过了账户验证，也就是以上的 verification 方法，同时用户未绑定邮箱/手机时通过账户密码验证
     */
    public function changeBind()
    {
        $captcha = new Captcha();
        $params  = $this->request->only(['type', 'captcha', 'email', 'mobile', 'accountVerificationToken', 'password']);
        $user    = $this->auth->getUser();
        
        if ($user[$params['type']]) {
            if (!Token::check($params['accountVerificationToken'], $params['type'] . '-pass', $user->id, false)) {
                $this->error(__('You need to verify your account before modifying the binding information'));
            }
        } else {
            // 验证账户密码
            if (!isset($params['password']) || $user->password != encrypt_password($params['password'], $user->salt)) {
                $this->error(__('Password error'));
            }
        }
        
        // 检查验证码
        if ($captcha->check($params['captcha'], $params[$params['type']] . "user_change_{$params['type']}")) {
            if ($params['type'] == 'email') {
                $validate = Validate::rule(['email' => 'require|email|unique:user'])->message([
                    'email.require' => 'email format error',
                    'email.email'   => 'email format error',
                    'email.unique'  => 'email is occupied',
                ]);
                if (!$validate->check(['email' => $params['email']])) {
                    $this->error(__($validate->getError()));
                }
                $user->email = $params['email'];
            } else if ($params['type'] == 'mobile') {
                $validate = Validate::rule(['mobile' => 'require|mobile|unique:user'])->message([
                    'mobile.require' => 'mobile format error',
                    'mobile.mobile'  => 'mobile format error',
                    'mobile.unique'  => 'mobile is occupied',
                ]);
                if (!$validate->check(['mobile' => $params['mobile']])) {
                    $this->error(__($validate->getError()));
                }
                $user->mobile = $params['mobile'];
            }
            Token::delete($params['accountVerificationToken']);
            $user->save();
            $this->success();
        }
        $this->error(__('Please enter the correct verification code'));
    }
    
    public function changePassword()
    {
        if ($this->request->isPost()) {
            $params = $this->request->only(['oldPassword', 'newPassword']);
            
            if (!$this->auth->checkPassword($params['oldPassword'])) {
                $this->error(__('Old password error'));
            }
            
            Db::startTrans();
            try {
                $validate = new AccountValidate();
                $validate->scene('changePassword')->check(['password' => $params['newPassword']]);
                $this->auth->getUser()->resetPassword($this->auth->id, $params['newPassword']);
                Db::commit();
            } catch (ValidateException|PDOException $e) {
                Db::rollback();
                $this->error($e->getMessage());
            }
            
            $this->auth->logout();
            $this->success(__('Password has been changed, please login again~'));
        }
    }
    
    public function integral()
    {
        $limit         = $this->request->request('limit');
        $integralModel = new UserScoreLog();
        $res           = $integralModel->where('user_id', $this->auth->id)
            ->order('createtime desc')
            ->paginate($limit);
        
        $this->success('', [
            'list'  => $res->items(),
            'total' => $res->total(),
        ]);
    }
    
    public function balance()
    {
        $limit      = $this->request->request('limit');
        $moneyModel = new UserMoneyLog();
        $res        = $moneyModel->where('user_id', $this->auth->id)
            ->order('createtime desc')
            ->paginate($limit);
        
        $this->success('', [
            'list'  => $res->items(),
            'total' => $res->total(),
        ]);
    }
    
    public function retrievePassword()
    {
        $params = $this->request->only(['type', 'account', 'captcha', 'password']);
        try {
            $validate = new AccountValidate();
            $validate->scene('retrievePassword')->check($params);
        } catch (ValidateException $e) {
            $this->error($e->getMessage());
        }
        
        if ($params['type'] == 'email') {
            $user = User::where('email', $params['account'])->find();
        } else {
            $user = User::where('mobile', $params['account'])->find();
        }
        if (!$user) {
            $this->error(__('Account does not exist~'));
        }
        
        $captchaObj = new Captcha();
        if (!$captchaObj->check($params['captcha'], $params['account'] . 'user_retrieve_pwd')) {
            $this->error(__('Please enter the correct verification code'));
        }
        
        if ($user->resetPassword($user->id, $params['password'])) {
            $this->success(__('Password has been changed~'));
        } else {
            $this->error(__('Failed to modify password, please try again later~'));
        }
    }
    
    // 获取group_id,传给前端，
    public function getGroupId()
    {
        $this->success('', [
            'group_id' => $this->auth->group_id,
        ]);
    }
}