ddsc/application/api/controller/Login.php

<?php
namespace app\api\controller;
use app\common\validate\UserVali;
use app\common\model\User;
use app\common\model\UserWallet;
use library\service\CaptchaService;
use library\tools\Data;
use think\Db;
use EasyWeChat\Factory;
use app\common\model\InviteInfo;
use function AlibabaCloud\Client\value;

/**
 * @title 用户登录
 * @controller Login
 */
class Login extends Base
{

    /**
     * @title 用户统一登录
     * @desc 用户登录
     * @author qc
     * @url /api/Login/unifiedLogin
     * @method POST
     * @tag 登录 授权
     * @param name:login_type type:int require:1 default:1 desc:登录方式（1.微信小程序，2.微信授权app,3.pc微信扫码,4.手机号验证码，5.手机号密码登录，6.qq授权app,7.pc端QQ登录）
     * @param name:code type:int require:1 default:-- desc:code值（1）
     * @param name:phone type:string require:0 default:0 desc:手机号（4,5）
     * @param name:password type:string require:0 default:0 desc:登录密码（5）
     * @param name:phone_code type:string require:0 default:0 desc:手机验证码（4）
     * @param name:access_token type:string require:0 default:0 desc:access_token(2,6,7)
     * @param name:openid type:string require:0 default:0 desc:openid(2)
     * @return name:token type:string default:-- desc:用户登录成功后的token值(没返回token跳转绑定手机号！！！！！！！)
     * @return name:phone type:string default:-- desc:用户绑定的手机号
     */
    public function unifiedLogin()
    {
        $code = input('post.code');
        $headimg = input('post.headimg');
        $name = input('post.name');
        $access_token = input('post.access_token');
        $openid = input('post.openid');
        $login_type = input('post.login_type', 1);
        $ret_data = ['code' => 200, 'token' => ''];
        $msg = '登录成功';
        try {
            switch ($login_type){
                case 1://微信小程序登录
                    if (empty($code) || empty($headimg) || empty($name)) $this->exception('参数错误');
                    $app = Factory::miniProgram(config('app.mini_program'));
                    $data = $app->auth->session($code);
                    if(empty($data['openid']) || empty($data['unionid'])) $this->exception($data['errmsg']);
                    $member = User::field('id,openid,phone')->where('wechat_unionid', $data['unionid'])->find();
                    if(!$member) $this->exception('请绑定手机号');
                    if(!$member->openid) User::where('id',$member->id)->update(['openid'=>$data['openid']]);// 没有小程序openid则绑定openid
                    $token = $this->createJwt($member->id);
                    $ret_data['token'] =  $token;
                    break;
                case 2://微信授权app登录
                    if(empty($access_token) || empty($openid)) $this->exception('缺少access_token或openid');
                    $user_info = http_curl('https://api.weixin.qq.com/sns/userinfo?access_token='.$access_token.'&openid='.$openid);
                    if(!$user_info || empty( $user_info['unionid'])) $this->exception('获取用户微信信息有误');
                    $member = User::field('id,app_openid,phone')->where('wechat_unionid', $user_info['unionid'])->find();
                    if(!$member) $this->exception('请绑定手机号');
                    if(!$member->app_openid)User::where('id',$member->id)->update(['app_openid'=>$user_info['openid']]);// 没有openid则绑定openid
                    $token = $this->createJwt($member->id);
                    $ret_data['token'] = $token;
                    break;
                case 3://pc微信扫码
                    $res = http_curl('https://api.weixin.qq.com/sns/oauth2/access_token?appid='.config('pc_wx')['app_id'].'&secret='.config('pc_wx')['secret'].'&code='.$code.'&grant_type=authorization_code');
                    if(!$res || !isset($res['access_token'])) $this->exception('获取access_token有误');
                    $user_info = http_curl('https://api.weixin.qq.com/sns/userinfo?access_token='.$res['access_token'].'&openid='.$res['openid']);
                    if(!$user_info) $this->exception('获取用户微信信息有误');
                    $member = User::field('id,app_openid,phone')->where('wechat_unionid', $user_info['unionid'])->find();
                    if(!$member) $this->exception('请绑定手机号');
                    if(!$member->pc_openid)User::where('id',$member->id)->update(['pc_openid'=>$res['openid']]);// 没有openid则绑定openid
                    $token = $this->createJwt($member->id);
                    $ret_data['token'] = $token;
                    break;
                case 4:// 手机号验证码登录
                    $phone = input('post.phone');
                    $phone_code  = input('post.phone_code');
                    $member =User::where('phone', $phone)->find();
                    if(!$member) $this->exception('用户不存在，请先注册');
                    $check_code = $this->checkPhoneCode($phone,$phone_code);
                    if(!$check_code) $this->exception('验证码错误');
                    $this->updatePhoneCode($check_code);
                    $ret_data['token'] = $this->createJwt($member->id);
                    break;
                case 5://手机密码登录
                    $phone = input('post.phone');
                    $password = input('post.password');
                    if (empty($password) || empty($phone)) $this->exception('参数错误');
                    $member = User::where('phone', $phone)->find();
                    if(!$member) $this->exception('用户不存在');
                    if(!check_password($password,$member->encryption_password)) $this->exception('密码错误');
                    $ret_data['token'] = $this->createJwt($member->id);
                    break;
                case 6://qq 授权app
                    if(empty($access_token)) $this->error('参数错误');
                    $res = curl_get('https://graph.qq.com/oauth2.0/me?access_token='.$access_token.'&unionid=1'.'&fmt=json');
                    if(!$res || !isset($res['unionid'])) $this->exception('获取unionid有误');
                    $member = User::where('qq_unionid',$res['unionid'])->find();
                    if(!$member) $this->exception('用户不存在，请先注册');
                    $token = $this->createJwt($member->id);
                    $ret_data['token'] = $token;
                    break;
                case 7://pc QQ登录
                    if(empty($access_token)) $this->error('参数错误');
                    $res = curl_get('https://graph.qq.com/oauth2.0/me?access_token='.$access_token.'&unionid=1'.'&fmt=json');
                    if(!$res || !isset($res['unionid'])) $this->exception('获取unionid有误');
                    $member = User::where('qq_unionid',$res['unionid'])->find();
                    if(!$member) $this->exception('用户不存在，请先注册');
                    $token = $this->createJwt($member->id);
                    $ret_data['token'] = $token;
                    break;
            }
        }catch (\Exception $e){
            $ret_data['code'] = 201;
            $msg =$e->getMessage();
        }
        $ret_data['code'] == 200 ? $this->success($msg,$ret_data):$this->error($msg,$ret_data);
    }


    /**
     * @title 账号绑定手机号
     * @desc 账号绑定手机号
     * @author qc
     * @url /api/Login/accountBindPhone
     * @method POST
     * @param name:bind_type type:int require:1 default:1 desc:绑定类型（1.微信小程序，2.微信授权app,3.pc微信扫码,4.qq授权app,5pc授权QQ）
     * @param name:phone type:int require:1 default:-- desc:手机号(1,2,3,4)
     * @param name:phone_code type:string require:1 default:-- desc:手机验证码(1,2,3,4)
     * @param name:code type:int require:0 default:-- desc:code值(1)
     * @param name:access_token type:string require:0 default:0 desc:access_token(2,4)
     * @param name:openid type:string require:0 default:0 desc:openid(2)
     * @param name:pid type:string require:0 default:-- desc:推荐人(能获取到就传)
     * @param name:name type:string require:0 default:-- desc:名称(能获取到就传)
     * @param name:headimg type:string require:0 default:-- desc:头像(能获取到就传)
     * @return name:token type:string default:-- desc:成功返回token
     */
    public function accountBindPhone()
    {
        $bind_type = input('post.bind_type',1);
        $phone = input('post.phone');
        $phone_code = input('post.phone_code');
        $code = input('post.code');
        $pid = input('post.pid', 0);
        $headimgurl = input('post.headimg', '');
        $nickname = input('post.name', '');
        $access_token = input('post.access_token');
        $openid = input('post.openid');
        $check_code = $this->checkPhoneCode($phone,$phone_code);
        if(!$check_code) $this->error('验证码错误');
        $this->updatePhoneCode($check_code);
        $member =User::where('phone', $phone)->find();
        $is_new = $member ? 0:1;// 是否是新用户
        $bind_data = [];
        if($is_new) $bind_data['phone'] = $phone;
        switch ($bind_type){
            case 1://微信小程序注册
                $app = Factory::miniProgram(config('app.mini_program'));
                $data = $app->auth->session($code);
                if(empty($data['openid'])) $this->error($data['errmsg']);
                $check_member = User::where('openid',$data['openid'])->find();
                if($check_member) $this->error('账号已存在'.$bind_type);
                $bind_data['openid'] = $data['openid'];
                if($is_new) $bind_data['name']   =  $nickname ? :$phone;
                if($is_new) $bind_data['headimg'] = $headimgurl ? :'';
                if($is_new || (!$is_new && !$member->wechat_unionid)) $bind_data['wechat_unionid'] = !empty($data['unionid']) ? $data['unionid'] :'';
                break;
            case 2://微信授权app注册
                if($member && $member->app_openid) $this->error('该手机号已绑定微信'.$bind_type);
                if(empty($access_token) || empty($openid)) $this->error('参数错误');
                $user_info = http_curl('https://api.weixin.qq.com/sns/userinfo?access_token='.$access_token.'&openid='.$openid);
                if(!$user_info || empty($user_info['unionid'])) $this->error('获取用户微信信息有误');
                $check_member = User::where('app_openid',$user_info['openid'])->find();
                if($check_member) $this->error('账号已存在'.$bind_type);
                $bind_data['app_openid'] = $user_info['openid'];
                if($is_new) $bind_data['name']   = $user_info['nickname'];
                if($is_new) $bind_data['headimg'] = $user_info['headimgurl'];
                if($is_new || (!$is_new && !$member->wechat_unionid))  $bind_data['wechat_unionid'] = !empty($user_info['unionid']) ? $user_info['unionid'] :'';
                break;
            case 3://pc微信扫码
                if($member && $member->pc_openid) $this->error('该手机号已绑定微信'.$bind_type);
                if(empty($code)) $this->error('参数错误');
                $res = http_curl('https://api.weixin.qq.com/sns/oauth2/access_token?appid='.config('pc_wx')['app_id'].'&secret='.config('pc_wx')['secret'].'&code='.$code.'&grant_type=authorization_code');
                if(!$res || !isset($res['access_token'])) $this->error('获取access_token有误');
                $user_info = http_curl('https://api.weixin.qq.com/sns/userinfo?access_token='.$res['access_token'].'&openid='.$res['openid']);
                if(!$user_info) $this->error('获取用户微信信息有误');
                $check_member = User::where('pc_openid',$user_info['openid'])->find();
                if($check_member) $this->error('账号已存在'.$bind_type);
                $bind_data['pc_openid'] = $user_info['openid'];
                if($is_new) $bind_data['name']   = $user_info['nickname'];
                if($is_new) $bind_data['headimg'] = $user_info['headimgurl'];
                if($is_new || (!$is_new && !$member->wechat_unionid)) $bind_data['wechat_unionid'] = !empty($user_info['unionid']) ? $user_info['unionid'] :'';
                break;
            case 4:// qq授权app
                if($member && $member->qq_unionid) $this->error('该手机号已绑定QQ'.$bind_type);
                if(empty($access_token)) $this->error('参数错误');
                $res = curl_get('https://graph.qq.com/oauth2.0/me?access_token='.$access_token.'&unionid=1'.'&fmt=json');
                if(!$res || !isset($res['unionid'])) $this->error('获取unionid有误');
                $check_qq = User::where('qq_unionid', $res['unionid'])->value('id');
                if($check_qq) $this->error('用户已存在');
                $bind_data['qq_unionid'] = $res['unionid'];
                if($is_new) $bind_data['name']   = $nickname;
                if($is_new) $bind_data['headimg'] = $headimgurl;
                break;
            case 5:// pc qq
                if(empty($access_token)) $this->error('参数错误');
                $res = curl_get('https://graph.qq.com/oauth2.0/me?access_token='.$access_token.'&unionid=1'.'&fmt=json');
                if(!$res || !isset($res['unionid'])) $this->error('获取unionid有误');
                $check_qq = User::where('qq_unionid', $res['unionid'])->value('id');
                if($check_qq) $this->error('用户已存在');
                $bind_data['qq_unionid'] = $res['unionid'];
                if($is_new) $bind_data['name']   = $nickname;
                if($is_new) $bind_data['headimg'] = $headimgurl;
                break;
        }
        // 新用户创建钱包
        if($is_new){
            if(empty($bind_data['headimg'])) $bind_data['headimg'] = 'https://xieshouxiongmao.oss-cn-beijing.aliyuncs.com/add09dc3edac6bfd/c15ab257e41b46ba.png';
            if(empty($bind_data['name'])) $bind_data['name'] = $phone;
            $member = User::create($bind_data);
            User::update(['invite_code'=>create_invite_code($member->id)],['id'=>$member->id]);
            Data::save("UserWallet",['user_id'=>$member->id],'user_id',['user_id'=>$member->id]);//创建钱包
            if($pid) InviteInfo::create(['user_id'=>$member->id,'pid'=>$pid,'create_at'=>date('Y-m-d H:i:s')]);
        }else{
            User::where('id',$member->id)->update($bind_data);
        }
        $token = $this->createJwt($member->id);
        $this->success('绑定成功', ['token' => $token]);
    }

    /**
     * @title 手机验正码注册
     * @desc 手机验正码注册
     * @author qc
     * @url /api/Login/phoneCodeRegister
     * @method POST
     * @param name:phone type:int require:1 default:-- desc:手机号
     * @param name:code type:string require:1 default:-- desc:手机验证码
     * @param name:verify type:string require:1 default:-- desc:图形验证码
     * @param name:pid type:string require:0 default:-- desc:推荐人id
     * @param name:uniqid type:string require:1 default:-- desc:生成验证码图形时返回的uniqid
     * @param name:password type:string require:1 default:-- desc:密码
     * @param name:con_password type:string require:1 default:-- desc:确认密码
     * @return name:token type:string default:-- desc:用户登录成功后的token值
     */
    public function phoneCodeRegister()
    {
        $verify = input('post.verify');
        $uniqid = input('post.uniqid');
        $phone = input('post.phone');
        $code = input('post.code');
        $password = input('post.password');
        $con_password = input('post.con_password');
        $pid = input('pid', 0);
        if($password !== $con_password) $this->error('两次输入密码不一致');
        if (!CaptchaService::instance()->check($verify, $uniqid)) $this->error('图形验证码验证失败，请重新输入!');
        $check_code = $this->checkPhoneCode($phone,$code);
        if(!$check_code) $this->error('验证码错误');
        $this->updatePhoneCode($check_code);
        $member = User::field('id,phone')->where('phone', $phone)->find();
        if($member) $this->error('该手机号已注册');
        $member_data = ['phone' => $phone,'encryption_password'=>encrypt_password($password)];
        Db::name('store_member')->insert($member_data);
        $uid = Db::getLastInsID();
        User::update(['invite_code'=>create_invite_code($uid)],['id'=>$uid]);
        UserWallet::create(['user_id'=>$uid]);//创建钱包
        if($pid) InviteInfo::create(['user_id'=>$uid,'pid'=>$pid,'create_at'=>date('Y-m-d H:i:s')]);
        $token = $this->createJwt($uid);
        $this->success('登录成功', ['token' => $token]);
    }


    /**
     * @title 获取验证码
     * @desc 获取验证码
     * @author qc
     * @url /api/Login/getCaptcha
     * @method GET
     * @return name:image type:string default:-- desc:图片
     * @return name:uniqid type:string default:-- desc:uniqid
     */
    public function getCaptcha()
    {
        $image = CaptchaService::instance();
        $captcha = ['image' => $image->getData(), 'uniqid' => $image->getUniqid()];
        $this->success('生成验证码成功', $captcha);
    }

    /**
     * @title 重置密码
     * @desc 重置密码
     * @author qc
     * @url /api/Login/resetPassword
     * @method POST
     * @param name:phone type:int require:1 default:-- desc:手机号
     * @param name:code type:string require:1 default:-- desc:手机验证码
     * @param name:verify type:string require:1 default:-- desc:图形验证码
     * @param name:uniqid type:string require:1 default:-- desc:生成验证码图形时返回的uniqid
     * @param name:password type:string require:1 default:-- desc:密码
     * @param name:con_password type:string require:1 default:-- desc:确认密码
     */
    public function resetPassword()
    {
        $verify = input('post.verify');
        $uniqid = input('post.uniqid');
        $phone = input('post.phone');
        $code = input('post.code');
        $password = input('post.password');
        $con_password = input('post.con_password');
        $validate = new UserVali();
        if (!$validate->scene('reset_password')->check(['phone'=>$phone,'password'=>$password])) {
            $this->error($validate->getError());
        }
        if (!CaptchaService::instance()->check($verify, $uniqid)) $this->error('图形验证码验证失败，请重新输入!');
        $check_code = $this->checkPhoneCode($phone,$code);
        if(!$check_code) $this->error('验证码错误');
        $user_id = User::where('phone',$phone)->value('id');
        if(!$user_id) $this->error('账号不存在');
        if($password !== $con_password) $this->error('两次输入密码不一致');
        User::where(['phone'=>$phone])->update(['encryption_password'=>encrypt_password($password)]);
        $this->success('修改密码成功');
    }


    public function weChatLogin()
    {
        $code = input('post.code');
        $headimg = input('post.headimg');
        $name = input('post.name');
        $pid = input('post.pid', 0);
        if (empty($code) || empty($headimg) || empty($name)) $this->error('参数错误');
        $app = Factory::miniProgram(config('app.mini_program'));
        $data = $app->auth->session($code);
        if (empty($data['openid'])) {
            $this->error($data['errmsg']);
        }
        $member = Db::name('store_member')->field('id,phone')->where('openid', $data['openid'])->find();
        if (empty($member)) {
            $member_data = array(
                'openid' => $data['openid'],
                'headimg' => $headimg,
                'name' => $name,
                'pid' => $pid,
                'create_at' => date("Y-m-d H:i:s")
            );
            Db::name('store_member')->insert($member_data);
            $uid = Db::getLastInsID();
            User::update(['invite_code'=>create_invite_code($uid)],['id'=>$uid]);
            UserWallet::create(['user_id'=>$uid]);//创建钱包
            if($pid) InviteInfo::create(['user_id'=>$uid,'pid'=>$pid,'create_at'=>date('Y-m-d H:i:s')]);
        } else {
            $uid = $member['id'];
        }
        if (empty($uid)) $this->error('数据有误');
        $token = $this->createJwt($uid);
        $this->success('登录成功', ['token' => $token,'phone'=>empty($member)  ?'' :$member['phone']]);
    }

    public function weChatAppLogin()
    {
        $code = input('post.code');
        if(empty($code)) $this->error('参数错误');
        $res = http_curl('https://api.weixin.qq.com/sns/oauth2/access_token?appid='.config('app_wx')['app_id'].'&secret='.config('app_wx')['secret'].'&code='.$code.'&grant_type=authorization_code');
        if(!$res) $this->error('获取access_token有误');
        $user_info = http_curl('https://api.weixin.qq.com/sns/userinfo?access_token='.$res['access_token'].'&openid='.$res['openid']);
        if(!$user_info) $this->error('获取用户微信信息有误');
        $data['app_openid'] = $user_info['openid'];
        $data['name'] = $user_info['nickname'];
        $data['headimg'] = $user_info['headimgurl'];
        $data['token'] = '';
        $member = User::where('app_openid',$data['app_openid'])->find();
        if(!$member) $this->success('授权成功',$data);
        $token = $this->createJwt($member->id);
        $data['token'] = $token;
        $this->success('登录成功',$data);
    }

    public function weChatPcLogin()
    {
        $code = input('post.code');
        $res = http_get('https://api.weixin.qq.com/sns/oauth2/access_token?appid='.config('pc_wx')['app_id'].'&secret='.config('pc_wx')['secret'].'&code='.$code.'&grant_type=authorization_code');
        if(!$res) $this->error('获取access_token有误');
        $user_info = http_get('https://api.weixin.qq.com/sns/userinfo?access_token='.$res['access_token'].'&openid='.$res['openid']);
        $data['pc_openid'] = $user_info['openid'];
        $data['name'] = $user_info['nickname'];
        $data['headimg'] = $user_info['headimgurl'];
        $member = User::where('pc_openid',$data['pc_openid'])->find();
        if(!$member) $this->success('授权成功',$data);
        $token = $this->createJwt($member->id);
        $data['token'] = $token;
        $this->success('登录成功',$data);
    }

    public function phoneCodeLogin()
    {
        $phone = input('post.phone');
        $code = input('post.code');
        $member = Db::name('store_member')->field('id,phone')->where('phone', $phone)->find();
        if(empty($phone)) $this->error('用户不存在，请先注册');
        $check_code = $this->checkPhoneCode($phone,$code);
        if(!$check_code) $this->error('验证码错误');
        $this->updatePhoneCode($check_code);
        $uid = $member['id'];
        $token = $this->createJwt($uid);
        $this->success('登录成功', ['token' => $token,'phone'=>empty($member)  ?'' :$member['phone']]);
    }

    public function passwordLogin()
    {
        $phone = input('post.phone');
        $password = input('post.password');
        if (empty($password) || empty($phone)) $this->error('参数错误');
        $member = Db::name('store_member')->where('phone', $phone)->find();
        if(!$member) $this->error('用户不存在');
        if(!check_password($password,$member['encryption_password'])) $this->error('密码错误');
        $token = self::createJwt($member['id']);
        $this->success('登录成功', ['token' => $token]);
    }
    /**
     * @title 获取版本号
     * @desc 获取版本号
     * @author QGF
     * @url /api/Login/get_store_versions
     * @method GET
     * @tag 获取版本号
     * @param name:type type:int require:1 default:1 desc:类型（1：安卓，2：IOS。默认安卓）
     * @return name:title type:string default:-- desc:版本号
     * @return name:content type:string default:-- desc:修改内容
     * @return name:url type:string default:-- desc:下載地址（安卓有值）
     */
    public function get_store_versions(){
        $type = input('type',1);
        $store_versions = Db::name('store_versions')->field('title,content,url')->where('type',$type)->find();
        $this->success('获取成功',$store_versions);
    }

}