fastadmin_tailored/application/api/controller/Login.php

<?php

namespace app\api\controller;

use addons\third\model\Third;
use app\common\library\Auth;
use app\common\library\Sms;
use app\common\library\Ems;
use fast\Random;
use think\Validate;
use fast\Http;
use addons\third\library\Service;
use app\common\Enum\StatusEnum;
use app\common\facade\Wechat;
use think\Config;
use think\Env;
use think\Session;
use app\common\library\easywechatPlus\WechatService;
class Login extends Base
{

    protected $noNeedLogin = ['*'];

    public function _initialize()
    {
        parent::_initialize();
        if (!$this->request->isPost()) {
            $this->error('请求错误');
        }

        Auth::instance()->setAllowFields(array_merge(['username'], $this->allowFields));
    }

    /**
     * 会员登录
     *
     * @param string $account 账号
     * @param string $password 密码
     */
    public function login()
    {
        $params = $this->request->param();
        $account = $params['account'] ?? '';
        $password = $params['password'] ?? '';
        //增加验证器
        $validate = new \app\api\validate\User();
        if (!$validate->check($params, [], 'login')) {
            $this->error($validate->getError());
        }
        $ret = $this->auth->login($account, $password);
        if ($ret) {
            $user = $this->auth->getUserinfo();
            $user['avatar'] = cdnurl($user['avatar'], true);
            $this->success(__('Logged in successful'), [
                'token' => $this->auth->getToken(),
                'user'  => $user
            ]);
        } else {
            $this->error($this->auth->getError());
        }
    }

    /**
     * 重置密码
     *
     * @param string $mobile 手机号
     * @param string $newpassword 新密码
     * @param string $captcha 验证码
     */
    public function resetpwd()
    {
        $params = $this->request->param();
        $type = $params['type'] ?? '';
        $mobile = $params['mobile'] ?? '';
        $email = $params['email'] ?? '';
        $newpassword = $params['newpassword'] ?? '';
        $captcha = $params['captcha'] ?? '';
        //验证器
        $validate = new \app\api\validate\UserCancel();
        if (!$validate->check($params, [], 'resetpwd')) {
            $this->error($validate->getError());
        }
        if ($type == 'mobile') {
            $user = \app\common\model\User::getByMobile($mobile);
            if (!$user) {
                $this->error(__('User not found'));
            }
            if (!Env::get('app.app_debug') && $captcha != Env::get('app.DEFAULT_SMSCODE')) {
                $ret = Sms::check($mobile, $captcha, 'resetpwd');
                if (!$ret) {
                    $this->error(__('Captcha is incorrect'));
                }
            }
            Sms::flush($mobile, 'resetpwd');
        } else {
            $user = \app\common\model\User::getByEmail($email);
            if (!$user) {
                $this->error(__('User not found'));
            }
            $ret = Ems::check($email, $captcha, 'resetpwd');
            if (!$ret) {
                $this->error(__('Captcha is incorrect'));
            }
            Ems::flush($email, 'resetpwd');
        }
        //模拟一次登录
        $this->auth->direct($user->id);
        $ret = $this->auth->changepwd($newpassword, '', true);
        if ($ret) {
            $this->success(__('Reset password successful'));
        } else {
            $this->error($this->auth->getError());
        }
    }

  

    /**
     * 手机验证码登录
     *
     * @param string $mobile 手机号
     * @param string $captcha 验证码
     */
    public function mobilelogin()
    {
        $params = $this->request->param();
        $mobile = $params['mobile'] ?? '';
        $captcha = $params['captcha'] ?? '';
        $invite_id = $params['invite_id'] ?? '';
        // 验证器
        $validate = new \app\api\validate\User();
        if (!$validate->check($params, [], 'mobilelogin')) {
            $this->error($validate->getError());
        }
        // 这里需要处理 测试环境 env('app_debug') 为 true 时，不进行验证码验证 校验 验证码固定为env的配置 DEFAULT_SMSCODE: 123456
        if (!Env::get('app.app_debug') && $captcha != Env::get('app.DEFAULT_SMSCODE')) {
            if (!Sms::check($mobile, $captcha, 'mobilelogin')) {
                $this->error(__('Captcha is incorrect'));
            }
        }
        $user = \app\common\model\User::getByMobile($mobile);
        if ($user) {
            if ($user->status != StatusEnum::ENABLED) {
                $this->error(__('Account is locked'));
            }
            //如果已经有账号则直接登录
            $ret = $this->auth->direct($user->id);
        } else {
            $ret = $this->auth->register($mobile, Random::alnum(), '', $mobile, []);
        }
        if ($ret) {
            Sms::flush($mobile, 'mobilelogin');
            $user = $this->auth->getUserinfo();
            $user['avatar'] = cdnurl($user['avatar'], true);
            $data = ['token' => $this->auth->getToken(), 'user' => $user];
            $this->success(__('Logged in successful'), $data);
        } else {
            $this->error($this->auth->getError());
        }
    }

    /**
     * 注册会员
     *
     * @param string $username 用户名
     * @param string $password 密码
     * @param string $email 邮箱
     * @param string $mobile 手机号
     * @param string $code 验证码
     */
    public function register()
    {
        $params = $this->request->param();
        $username = $params['username'] ?? '';
        $password = $params['password'] ?? '';
        $mobile = $params['mobile'] ?? '';
        $code = $params['captcha'] ?? '';
        // 验证器
        $validate = new \app\api\validate\User();
        if (!$validate->check($params, [], 'register')) {
            $this->error($validate->getError());
        }
        $invite_id = $this->request->post('invite_id');
        if ($invite_id) {
            \think\Cookie::set('inviter', $invite_id);
        }
        $ret = Sms::check($mobile, $code, 'register');
        if (!$ret) {
            $this->error(__('Captcha is incorrect'));
        }

        $ret = $this->auth->register($username, $password, '', $mobile, []);
        if ($ret) {
            $user = $this->auth->getUserinfo();
            $user['avatar'] = cdnurl($user['avatar'], true);
            $this->success(__('Sign up successful'), [
                'token' => $this->auth->getToken(),
                'user'  => $user
            ]);
        } else {
            $this->error($this->auth->getError());
        }
    }

    /**
     * 第三方登录[绑定] 小程序
     */
    public function wxLogin()
    {
        $code = $this->request->post("code");
        $rawData = $this->request->post("rawData/a", '', 'trim');
        if (!$code) {
            $this->error("参数不正确");
        }
        $rawData = $rawData ?: ['nickName' => '微信用户'];
        $third = get_addon_info('third');
        if (!$third || !$third['state']) {
            $this->error("请在后台插件管理安装第三方登录插件并启用");
        }

        if (!config('shop.wx_appid') || !config('shop.wx_app_secret')) {
            $this->error("请在后台配置微信小程序参数");
        }

        $json = (new WechatService(Wechat::miniProgram()))->getWechatSession($code);
        if (isset($json['openid'])) {
            $userinfo = [
                'platform'      => 'wechat',
                'apptype'       => 'miniapp',
                'openid'        => $json['openid'],
                'userinfo'      => [
                    'nickname' => $rawData['nickName'] ?? '',
                    'avatar'   => $rawData['avatarUrl'] ?? ''
                ],
                'openname'      => $rawData['nickName'] ?? '',
                'access_token'  => $json['session_key'],
                'refresh_token' => '',
                'expires_in'    => $json['expires_in'] ?? 0,
                'unionid'       => $json['unionid'] ?? ''
            ];

            $third = [
                'nickname' => $rawData['nickName'] ?? '',
                'avatar'   => $rawData['avatarUrl'] ?? ''
            ];
            $user = null;

            if ($this->auth->isLogin() || Service::isBindThird($userinfo['platform'], $userinfo['openid'])) {
                Service::connect($userinfo['platform'], $userinfo);
            } else {
                // 是否自动创建账号
                if (config('shop.wechatautocreate')) {
                    Service::connect($userinfo['platform'], $userinfo);
                } else {
                    Session::set('third-userinfo', $userinfo);
                    $this->success('授权成功!', ['third' => $third, 'openid' => $json['openid'], 'bind' => true]);
                }
            }

            $user = $this->auth->getUserinfo();
            $this->success('授权成功!', ['user' => $user, 'third' => $third, 'openid' => $json['openid']]);
        }
        $this->error("授权失败," . ($json['errmsg'] ?? "未知错误"));
    }

    /**
     * 微信手机号授权登录
     */
    public function wechatMobileLogin()
    {
        $code = $this->request->post("code");
        $logincode = $this->request->post("logincode");
        $bind = $this->request->post("bind");
        $data = (new WechatService(Wechat::miniProgram()))->getWechatMobile($code);
        if ($data) {
            $mobile = $data['phoneNumber'];
            //获取openid和unionid
            if (!empty($logincode)) {
                $json = (new WechatService(Wechat::miniProgram()))->getWechatSession($logincode);
            }
            $openid = $json['openid'] ?? '';
            $unionid = $json['unionid'] ?? '';

            $user = \app\common\model\User::getByMobile($mobile);
            if ($user) {
                if ($user->status != StatusEnum::ENABLED) {
                    $this->error(__('Account is locked'));
                }
                //如果已经有账号则直接登录
                $ret = $this->auth->direct($user->id);
            } else {
                $ret = $this->auth->register($mobile, Random::alnum(), '', $mobile, ['nickname' => substr_replace($mobile, '****', 3, 4)]);
            }

            //判断是否绑定模式，openid是否有关联，没有关联的情况下手动进行关联
            if ($bind && $openid) {
                if (Service::isBindThird('wechat', $openid)) {
                    $this->error("手机号已经绑定其它账号");
                }

                // 在第三方登录表中创建关联
                $values = ['user_id' => $this->auth->id, 'platform' => 'wechat', 'openid' => $openid, 'unionid' => $unionid, 'openname' => '微信用户', 'apptype' => 'miniapp'];
                Third::create($values, true);
            }

            if ($ret) {
                $data = ['user' => $this->auth->getUserinfo(), 'token' => $this->auth->getToken(), 'openid' => $openid];
                $this->success('授权成功！', $data);
            } else {
                $this->error($this->auth->getError());
            }
        } else {
            $this->error("授权失败，请重试");
        }
    }

    /**
     * APP登录  todo  需要修改
     */
    public function appLogin()
    {
        $code = $this->request->post("code");
        $scope = $this->request->post("scope");
        if (!$code) {
            $this->error("参数不正确");
        }
        $third = get_addon_info('third');
        if (!$third || !$third['state']) {
            $this->error("请在后台插件管理安装第三方登录插件并启用");
        }
        Session::set('state', $code);
        $config = [
            'app_id'     => Config::get('shop.app_id'),
            'app_secret' => Config::get('shop.app_secret'),
            'scope'      => $scope
        ];
        if (!$config['app_id'] || !$config['app_secret']) {
            $this->error("请在后台配置移动端APP参数");
        }
        $wechat = new \addons\third\library\Wechat($config);
        $userinfo = $wechat->getUserInfo(['code' => $code, 'state' => $code]);
        if (!$userinfo) {
            $this->error(__('操作失败'));
        }
        //判断是否需要绑定
        $userinfo['apptype'] = 'native';
        $userinfo['platform'] = 'wechat';

        $third = [
            'avatar'   => $userinfo['userinfo']['avatar'],
            'nickname' => $userinfo['userinfo']['nickname']
        ];
        $user = null;
        if ($this->auth->isLogin() || Service::isBindThird($userinfo['platform'], $userinfo['openid'], $userinfo['apptype'], $userinfo['unionid'])) {
            Service::connect($userinfo['platform'], $userinfo);
            $user = $this->auth->getUserinfo();
        } else {
            Session::set('third-userinfo', $userinfo);
        }
        $this->success('授权成功!', ['user' => $user, 'third' => $third]);
    }

    /**
     * 获取Openid(仅用于微信小程序)
     */
    public function getWechatOpenid()
    {
        $code = $this->request->post("login_code");
        $json = (new WechatService(Wechat::miniProgram()))->getWechatSession($code);
        $this->success('获取成功!', ['openid' => $json['openid'] ?? '']);
    }

}