szcollect_admin/application/api/controller/Login.php

<?php

// +----------------------------------------------------------------------
// | ThinkAdmin
// +----------------------------------------------------------------------
// | 版权所有 2014~2019 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://demo.thinkadmin.top
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | gitee 代码仓库：https://gitee.com/zoujingli/ThinkAdmin
// | github 代码仓库：https://github.com/zoujingli/ThinkAdmin
// +----------------------------------------------------------------------

namespace app\api\controller;

use AlibabaCloud\Client\AlibabaCloud;
use AlibabaCloud\Client\Exception\ClientException;
use AlibabaCloud\Client\Exception\ServerException;
use app\api\controller\Base;
use think\Db;
use Firebase\JWT\JWT;
use EasyWeChat\Factory;
/**
 * @title 用户登录
 * @controller Login
 * @group worker
 */
class Login extends Base
{
    /**
     * @title 微信登录（小程序）
     * @desc 微信登录（小程序）
     * @author qc
     * @url /api/Login/weChatLogin
     * @method POST
     * @tag 登录 授权
     * @param name:code type:int require:1 default:-- desc:code值
     * @param name:pid type:int require:0 default:0 desc:推荐人id
     * @param name:goods_id type:int require:0 default:0 desc:商品id
     * @return name:token type:string default:-- desc:用户登录成功后的token值
     */
    public function weChatLogin(){
        $code = input('code');
        $pid = input('pid');
        $goods_id = input('goods_id');
        if(empty($code)) $this->error('参数错误1');
        $res = http_get('https://api.weixin.qq.com/sns/oauth2/access_token?appid='.config('app.official_account')['appid'].'&secret='.config('app.official_account')['secret'].'&code='.$code.'&grant_type=authorization_code');
        $res = json_decode($res,true);
        $member = Db::name('store_member')->field('id,phone')->where('openid', $res['openid'])->find();
        if (empty($member)) {
            $user_info = http_get('https://api.weixin.qq.com/sns/userinfo?access_token='.$res['access_token'].'&openid='.$res['openid']);
            $user_info = json_decode($user_info,true);
            $member_data = array(
                'openid' => $user_info['openid'],
                'headimg' => $user_info['headimgurl'],
                'name' => $user_info['nickname'],
                'pid' => $pid,
                'create_at' => date("Y-m-d H:i:s")
            );
            Db::table('store_member')->insert($member_data);
            $uid = Db::getLastInsID();
            // 给推荐人奖励
            if ($pid && $goods_id) {
                $invite_info = [
                    'user_id'   => $uid,
                    'pid'       => $pid,
                    'goods_id'  => $goods_id,
                ];
                Db::table('invite_info')->insert($invite_info);
            }
        } else {
            $uid = $member['id'];
        }
        if (empty($uid)) $this->error('数据有误');
        $token = self::create_jwt($uid);
        $this->success('登录成功', ['token' => $token]);
    }

    /**
     * @param name:phone type:int require:1 default:-- desc:手机号
     * @param name:password type:string require:1 default:-- desc:密码
     * @return name:token type:string default:-- desc:用户登录成功后的token值
     */
    public function passwordLogin()
    {
        $phone = input('phone');
        $password = input('password');
        if (empty($password) || empty($phone)) {
            $this->error('参数错误');
        }
        $member_id = Db::name('store_member')->where('phone', $phone)->where('password', md5($password))->value('id');
        if (empty($member_id)) {
            $this->error('手机号或密码错误');
        }
        $token = self::create_jwt($member_id);
        $this->success('登录成功', $token);
    }

    //token加密
    public function create_jwt($uid)
    {
        $key = md5(config('app.jwt')); //jwt的签发密钥，验证token的时候需要用到
        $time = time(); //签发时间
        $expire = $time + config('app.jwt_time'); //过期时间
        $token = array(
            "uid" => $uid,
            "iss" => "https://zain.com",//签发组织
            "aud" => "https://zain.com", //签发作者
            "iat" => $time,
            "nbf" => $time,
            "exp" => $expire
        );
        $jwt = JWT::encode($token, $key);
        return $jwt;
    }


    /**
     * @title 手机号授权登录
     * @desc 手机号授权登录
     * @author qc
     * @url /api/Login/programLogin
     * @method POST
     * @tag 登录 授权
     * @param name:code type:int require:1 default:-- desc:code值
     * @param name:encrypted type:string require:1 default:-- desc:encrypted
     * @param name:iv type:string require:1 default:-- desc:iv
     * @param name:pid type:string require:0 default:0 desc:推荐人id
     * @param name:goods_id type:int require:0 default:0 desc:商品id
     * @return name:token type:string default:-- desc:用户登录成功后的token值
     */
    public function programLogin()
    {
        $code           = input('post.code');
        $encryptedData  = input('post.encrypted');
        $iv             = input('post.iv');
        $pid             = input('post.pid',0);
        $goods_id             = input('post.goods_id',0);
        if (empty($code)) $this->error('参数错误');
        $app = Factory::miniProgram(config('app.mini_program'));
        $data = $app->auth->session($code);
        //var_dump($data);
        if (empty($data['openid'])) $this->error('微信登录失败,未获取到openid');
        $member_id = Db::name('store_member')->field('id')->where('openid', $data['openid'])->value('id');
        if ($member_id) $this->success('登录成功',['token'=>self::create_jwt($member_id)]);
        require_once env('root_path') . 'vendor/zoujingli/wechat-developer/WeMini/crypt/wxBizDataCrypt.php';
        $sessionKey = $data['session_key'];
        $pc = new \WXBizDataCrypt(config('app.mini_program')['app_id'], $sessionKey);
        $errCode = $pc->decryptData($encryptedData, $iv, $info);
        if ($errCode != 0) $this->error('微信登录失败2');
        $info = json_decode($info, true);
        $phone = $info['purePhoneNumber'];
        if (empty($phone)) $this->error('微信登录失败3');
        $member = Db::name('store_member')->field('id,phone,openid')->where('phone', $phone)->find();
        if(!empty($member)) $this->error('该手机号已绑定账号');
        $member_data = [
            'phone' => $phone,
            'headimg' =>'',
            'openid' => $data['openid'],
            'pid' => $pid,
            'create_at' => date("Y-m-d H:i:s")
        ];
        Db::table('store_member')->insert($member_data);
        $uid = Db::getLastInsID();
        Db::table('store_member')->where('id',$uid)->update(['name'=>'HG'.$uid]);
        // 给推荐人奖励
        if ($pid && $goods_id) {
            $invite_info = [
                'user_id' => $uid,
                'pid' => $pid,
                'goods_id' => $goods_id
            ];
            Db::table('invite_info')->insert($invite_info);
        }
        $this->success('登录成功',['token'=>self::create_jwt($uid)]);
    }





}