<?php
// +----------------------------------------------------------------------
// | likeadmin快速开发前后端分离管理后台（PHP版）
// +----------------------------------------------------------------------
// | 欢迎阅读学习系统程序代码，建议反馈是我们前进的动力
// | 开源版本可自由商用，可去除界面版权logo
// | gitee下载：https://gitee.com/likeshop_gitee/likeadmin
// | github下载：https://github.com/likeshop-github/likeadmin
// | 访问官网：https://www.likeadmin.cn
// | likeadmin团队 版权所有 拥有最终解释权
// +----------------------------------------------------------------------
// | author: likeadminTeam
// +----------------------------------------------------------------------

namespace app\api\logic;

use app\common\cache\WebScanLoginCache;
use app\common\logic\BaseLogic;
use app\api\service\{UserTokenService, WechatUserService};
use app\common\enum\{LoginEnum, user\UserTerminalEnum, YesNoEnum};
use app\common\model\dict\DictData;
use app\common\service\{
    ConfigService,
    FileService,
    wechat\WeChatConfigService,
    wechat\WeChatMnpService,
    wechat\WeChatOaService,
    wechat\WeChatRequestService
};
use app\common\model\user\{User, UserAuth};
use think\facade\{Db, Config};
use Firebase\JWT\JWT;
use Firebase\JWT\Key;
use Firebase\JWT\SignatureInvalidException;
use Firebase\JWT\BeforeValidException;
use Firebase\JWT\ExpiredException;
use GuzzleHttp\Client;
use GuzzleHttp\Psr7\Request;
use GuzzleHttp\Exception\GuzzleException;
use Guzzle\Http\Exception\RequestException;
/**
 * 登录逻辑
 * Class LoginLogic
 * @package app\api\logic
 */
class LoginLogic extends BaseLogic
{

    /**
     * @notes 账号密码注册
     * @param array $params
     * @return bool
     * @author 段誉
     * @date 2022/9/7 15:37
     */
    public static function register(array $params)
    {
        try {
            // 手机号已被使用
            $mobileUser = User::where(['account' => $params['account']])->find();
            if (!empty($mobileUser)) {
                self::setError('手机号已被注册');
                return false;
            }
            $count = User::where('company_id', $params['company_id'])->count();
            $value = DictData::where('id', 28)->value('value');
            if ($count >= $value) {
                self::setError('你创建的账号已达上限');
                return false;
            }
            $userSn = User::createUserSn();
            $passwordSalt = Config::get('project.unique_identification');
            $password = create_password($params['password'], $passwordSalt);
            // if($params['qualification']){
            //     $params['qualification']=explode(',',$params['qualification']);
            // }
            if ($params['avatar'] != '') {
                $avatar = $params['avatar'];
            } else {
                $avatar = ConfigService::get('default_image', 'user_avatar');
            }
            $group_id=1;
            if ($params['is_captain']) {
                $group_id=2;
            }
            // 镇农科公司服务部长
            if ($params['is_service_manager'] == 1) {
                $user = User::where(['company_id' => $params['company_id'], 'group_id' => 14])->find();
                if (!empty($user)) {
                    self::setError('公司已创建服务部长账号');
                    return false;
                }
                $group_id=14;
            }
            User::create([
                'sn' => $userSn,
                'avatar' => $avatar,
                'is_captain' => $params['is_captain'],
                'nickname' => $params['nickname'],
                'account' => $params['account'],
                'mobile' => $params['account'],
                'id_card' => $params['id_card'],
                'password' => $password,
                'channel' => 0,
                'sex' => $params['sex'],
                'province' => $params['province'],
                'city' => $params['city'],
                'area' => $params['area'],
                'street' => $params['street'],
                'village' => $params['village'],
                'brigade' => $params['brigade'],
                'address' => $params['address'],
                'qualification' => json_encode($params['qualification']),
                'company_id' => $params['company_id'],
                'group_id' => $group_id,
            ]);

            return true;
        } catch (\Exception $e) {
            self::setError($e->getMessage());
            return false;
        }
    }


    /**
     * @notes 账号/手机号登录，手机号验证码
     * @param $params
     * @return array|false
     * @author 段誉
     * @date 2022/9/6 19:26
     */
    public static function login($params)
    {
        try {
            // 账号/手机号 密码登录
            $where = ['account|mobile' => $params['account']];
            if ($params['scene'] == LoginEnum::MOBILE_CAPTCHA) {
                //手机验证码登录
                $where = ['mobile' => $params['account']];
            }

            $user = User::where($where)->findOrEmpty();
            if ($user->isEmpty()) {
                throw new \Exception('用户不存在');
            }
            if (isset($params['register_id']) && $params['register_id'] != '') {
                $user->register_id = $params['register_id'];
            }
	        if (isset($params['ytj_register_id']) && $params['ytj_register_id'] != '') {
		        $user->ytj_register_id = $params['ytj_register_id'];
	        }
            //更新登录信息
            $user->login_time = time();
            $user->login_ip = request()->ip();
            $user->save();

            //设置token
            $userInfo = UserTokenService::setToken($user->id, $params['terminal']);

            //返回登录信息
            $avatar = $user->avatar ?: Config::get('project.default_image.user_avatar');
            $avatar = FileService::getFileUrl($avatar);
            if(isset($params['shop_token'])&&$params['shop_token']!=''){
                $jwt = JWT::decode($params['shop_token'], new Key('ae47e94a7dcd1fdfacb499b60e361a8d', 'HS256'));
                if ($jwt) {
                    $user_id = $jwt->jti[0];
                    Db::name('user_other')->insert(['user_id'=>$user->id,'other_user_id'=>$user_id,'type'=>'shop_user']);
                }
            }
            return [
                'nickname' => $userInfo['nickname'],
                'sn' => $userInfo['sn'],
                'mobile' => $userInfo['mobile'],
                'avatar' => $avatar,
                'token' => $userInfo['token'],
            ];
        } catch (\Exception $e) {
            self::setError($e->getMessage());
            return false;
        }
    }

    public static function shop($payload,$type=1){
        $jwt = JWT::decode($payload, new Key('ae47e94a7dcd1fdfacb499b60e361a8d', 'HS256'));
        if ($jwt) {
            $user_id = $jwt->jti[0];
            $find = Db::name('user_other')->where('other_user_id', $user_id)->where('type', 'shop_user')->find();
            if ($find) {
                $user = User::where('id', $find['user_id'])->findOrEmpty();
                if ($user->isEmpty()) {
                    self::setError('无登录信息');
                    return false;
                }
                $terminal=3;
                $Android=IndexLogic::isAndroid();
                if($Android){
                    $terminal=5;
                }
                $ios=IndexLogic::isIOS();
                if($ios){
                    $terminal=6;
                }
                $userInfo = UserTokenService::setToken($user->id, $terminal);
                //返回登录信息
                $avatar = $user->avatar ?: Config::get('project.default_image.user_avatar');
                $avatar = FileService::getFileUrl($avatar);
                return [
                    'nickname' => $userInfo['nickname'],
                    'sn' => $userInfo['sn'],
                    'mobile' => $userInfo['mobile'],
                    'avatar' => $avatar,
                    'token' => $userInfo['token'],
                ];
            }
        }
        self::setError('无登录信息');
        return false;
    }

    public static function parseToken($token){
        $app_key = 'ae47e94a7dcd1fdfacb499b60e361a8d';
        try {
            JWT::$leeway = 10; //当前时间减去10秒，时间留点余地
            $decoded = JWT::decode($token, new Key($app_key, 'HS256'));
            $decodedArray = json_decode(json_encode($decoded), true);
            $jwtData = $decodedArray['data'] ?? [];
            if (empty($jwtData['uid']) || empty($jwtData['phone'])) {
                self::setError('当前账号未授权，请手动登录');
                return false;
            }
            $where = ['account|mobile' => $jwtData['phone']];
            $user = User::where($where)->findOrEmpty();
            if ($user->isEmpty()) {
                try {
                    //适配解析商城token
                    $parseHostUrl = env('url.shop_prefix') . '/api/parse/token';
                    $client = new Client(['timeout' => 5]); 
                    $requestBody['token'] = $token;
                    $response = $client->request('POST', $parseHostUrl, [
                        'json'   => $requestBody,
                        'verify' => false
                    ]);
                    $responseData = $response->getBody()->getContents();
                    $responseArray = json_decode($responseData, true);
                    if (empty($responseArray['data']['user']['uid'])) {
                        self::setError('用户不存在，请联系管理员开通供销系统账户');
                        return false;
                    } else {
                        $user_id = $responseArray['data']['user']['uid'];
                        $find = Db::name('user_other')->where('other_user_id', $user_id)->where('type', 'shop_user')->find();
                        if ($find) {
                            $user = User::where('id', $find['user_id'])->findOrEmpty();
                            if ($user->isEmpty()) {
                                self::setError('用户不存在，请联系管理员开通供销系统账户');
                                return false;
                            }
                            $terminal=3;
                            $Android=IndexLogic::isAndroid();
                            if($Android){
                                $terminal=5;
                            }
                            $ios=IndexLogic::isIOS();
                            if($ios){
                                $terminal=6;
                            }
                            $userInfo = UserTokenService::setToken($user->id, $terminal);
                            //返回登录信息
                            $avatar = $user->avatar ?: Config::get('project.default_image.user_avatar');
                            $avatar = FileService::getFileUrl($avatar);
                            return [
                                'nickname' => $userInfo['nickname'],
                                'sn' => $userInfo['sn'],
                                'mobile' => $userInfo['mobile'],
                                'avatar' => $avatar,
                                'token' => $userInfo['token'],
                            ];
                        } else {
                            self::setError('用户不存在，请联系管理员开通供销系统账户');
                            return false;
                        }
                    }
                } catch (GuzzleException $e) {
                    //return $this->fail($e->getMessage());self::setError('用户不存在，请联系管理员开通供销系统账户');
                    return false;
                }
            }
            //更新登录信息
            $user->login_time = time();
            $user->login_ip = request()->ip();
            $user->save();
            $terminal=3;
            $Android=IndexLogic::isAndroid();
            if($Android){
                $terminal=5;
            }
            $ios=IndexLogic::isIOS();
            if($ios){
                $terminal=6;
            }
            //设置token
            $userInfo = UserTokenService::setToken($user->id, $terminal);
            //返回登录信息
            $avatar = $user->avatar ?: Config::get('project.default_image.user_avatar');
            $avatar = FileService::getFileUrl($avatar);
            $user_id = $jwtData['uid'];
            return [
                'nickname' => $userInfo['nickname'],
                'sn' => $userInfo['sn'],
                'mobile' => $userInfo['mobile'],
                'avatar' => $avatar,
                'token' => $userInfo['token'],
            ];
        } catch(\Firebase\JWT\SignatureInvalidException $e) {
            self::setError('签名错误');
            return false;
        } catch(\Firebase\JWT\BeforeValidException $e) {
            self::setError('token无效');
            return false;
        } catch(\Firebase\JWT\ExpiredException $e) {
            self::setError('token已过期');
            return false;
        } catch(\Exception $e) {
            self::setError('非法请求');
            return false;
        }
        return false;
    }

    /**
     * @notes 退出登录
     * @param $userInfo
     * @return bool
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     * @author 段誉
     * @date 2022/9/16 17:56
     */
    public static function logout($userInfo)
    {
        //token不存在，不注销
        if (!isset($userInfo['token'])) {
            return false;
        }

        //设置token过期
        return UserTokenService::expireToken($userInfo['token']);
    }


    /**
     * @notes 获取微信请求code的链接
     * @param string $url
     * @return string
     * @author 段誉
     * @date 2022/9/20 19:47
     */
    public static function codeUrl(string $url)
    {
        return (new WeChatOaService())->getCodeUrl($url);
    }


    /**
     * @notes 公众号登录
     * @param array $params
     * @return array|false
     * @throws \GuzzleHttp\Exception\GuzzleException
     * @author 段誉
     * @date 2022/9/20 19:47
     */
    public static function oaLogin(array $params)
    {
        Db::startTrans();
        try {
            //通过code获取微信 openid
            $response = (new WeChatOaService())->getOaResByCode($params['code']);
            $userServer = new WechatUserService($response, UserTerminalEnum::WECHAT_OA);
            $userInfo = $userServer->getResopnseByUserInfo()->authUserLogin()->getUserInfo();

            // 更新登录信息
            self::updateLoginInfo($userInfo['id']);

            Db::commit();
            return $userInfo;
        } catch (\Exception $e) {
            Db::rollback();
            self::$error = $e->getMessage();
            return false;
        }
    }


    /**
     * @notes 小程序-静默登录
     * @param array $params
     * @return array|false
     * @author 段誉
     * @date 2022/9/20 19:47
     */
    public static function silentLogin(array $params)
    {
        try {
            //通过code获取微信 openid
            $response = (new WeChatMnpService())->getMnpResByCode($params['code']);
            $userServer = new WechatUserService($response, UserTerminalEnum::WECHAT_MMP);
            $userInfo = $userServer->getResopnseByUserInfo('silent')->getUserInfo();

            if (!empty($userInfo)) {
                // 更新登录信息
                self::updateLoginInfo($userInfo['id']);
            }

            return $userInfo;
        } catch (\Exception  $e) {
            self::$error = $e->getMessage();
            return false;
        }
    }


    /**
     * @notes 小程序-授权登录
     * @param array $params
     * @return array|false
     * @author 段誉
     * @date 2022/9/20 19:47
     */
    public static function mnpLogin(array $params)
    {
        Db::startTrans();
        try {
            //通过code获取微信 openid
            $response = (new WeChatMnpService())->getMnpResByCode($params['code']);
            $userServer = new WechatUserService($response, UserTerminalEnum::WECHAT_MMP);
            $userInfo = $userServer->getResopnseByUserInfo()->authUserLogin()->getUserInfo();

            // 更新登录信息
            self::updateLoginInfo($userInfo['id']);

            Db::commit();
            return $userInfo;
        } catch (\Exception  $e) {
            Db::rollback();
            self::$error = $e->getMessage();
            return false;
        }
    }


    /**
     * @notes 更新登录信息
     * @param $userId
     * @throws \Exception
     * @author 段誉
     * @date 2022/9/20 19:46
     */
    public static function updateLoginInfo($userId)
    {
        $user = User::findOrEmpty($userId);
        if ($user->isEmpty()) {
            throw new \Exception('用户不存在');
        }

        $time = time();
        $user->login_time = $time;
        $user->login_ip = request()->ip();
        $user->update_time = $time;
        $user->save();
    }


    /**
     * @notes 小程序端绑定微信
     * @param array $params
     * @return bool
     * @author 段誉
     * @date 2022/9/20 19:46
     */
    public static function mnpAuthLogin(array $params)
    {
        try {
            //通过code获取微信openid
            $response = (new WeChatMnpService())->getMnpResByCode($params['code']);
            $response['user_id'] = $params['user_id'];
            $response['terminal'] = UserTerminalEnum::WECHAT_MMP;

            return self::createAuth($response);
        } catch (\Exception  $e) {
            self::$error = $e->getMessage();
            return false;
        }
    }


    /**
     * @notes 公众号端绑定微信
     * @param array $params
     * @return bool
     * @throws \GuzzleHttp\Exception\GuzzleException
     * @author 段誉
     * @date 2022/9/16 10:43
     */
    public static function oaAuthLogin(array $params)
    {
        try {
            //通过code获取微信openid
            $response = (new WeChatOaService())->getOaResByCode($params['code']);
            $response['user_id'] = $params['user_id'];
            $response['terminal'] = UserTerminalEnum::WECHAT_OA;

            return self::createAuth($response);
        } catch (\Exception  $e) {
            self::$error = $e->getMessage();
            return false;
        }
    }


    /**
     * @notes 生成授权记录
     * @param $response
     * @return bool
     * @throws \Exception
     * @author 段誉
     * @date 2022/9/16 10:43
     */
    public static function createAuth($response)
    {
        //先检查openid是否有记录
        $isAuth = UserAuth::where('openid', '=', $response['openid'])->findOrEmpty();
        if (!$isAuth->isEmpty()) {
            throw new \Exception('该微信已被绑定');
        }

        if (isset($response['unionid']) && !empty($response['unionid'])) {
            //在用unionid找记录，防止生成两个账号，同个unionid的问题
            $userAuth = UserAuth::where(['unionid' => $response['unionid']])
                ->findOrEmpty();
            if (!$userAuth->isEmpty() && $userAuth->user_id != $response['user_id']) {
                throw new \Exception('该微信已被绑定');
            }
        }

        //如果没有授权，直接生成一条微信授权记录
        UserAuth::create([
            'user_id' => $response['user_id'],
            'openid' => $response['openid'],
            'unionid' => $response['unionid'] ?? '',
            'terminal' => $response['terminal'],
        ]);
        return true;
    }


    /**
     * @notes 获取扫码登录地址
     * @return array|false
     * @author 段誉
     * @date 2022/10/20 18:23
     */
    public static function getScanCode($redirectUri)
    {
        try {
            $config = WeChatConfigService::getOpConfig();
            $appId = $config['app_id'];
            $redirectUri = UrlEncode($redirectUri);

            // 设置有效时间标记状态, 超时扫码不可登录
            $state = MD5(time() . rand(10000, 99999));
            (new WebScanLoginCache())->setScanLoginState($state);

            // 扫码地址
            $url = WeChatRequestService::getScanCodeUrl($appId, $redirectUri, $state);
            return ['url' => $url];
        } catch (\Exception $e) {
            self::$error = $e->getMessage();
            return false;
        }
    }


    /**
     * @notes 网站扫码登录
     * @param $params
     * @return array|false
     * @author 段誉
     * @date 2022/10/21 10:28
     */
    public static function scanLogin($params)
    {
        Db::startTrans();
        try {
            // 通过code 获取 access_token,openid,unionid等信息
            $userAuth = WeChatRequestService::getUserAuthByCode($params['code']);

            if (empty($userAuth['openid']) || empty($userAuth['access_token'])) {
                throw new \Exception('获取用户授权信息失败');
            }

            // 获取微信用户信息
            $response = WeChatRequestService::getUserInfoByAuth($userAuth['access_token'], $userAuth['openid']);

            // 生成用户或更新用户信息
            $userServer = new WechatUserService($response, UserTerminalEnum::PC);
            $userInfo = $userServer->getResopnseByUserInfo()->authUserLogin()->getUserInfo();

            // 更新登录信息
            self::updateLoginInfo($userInfo['id']);

            Db::commit();
            return $userInfo;
        } catch (\Exception $e) {
            Db::rollback();
            self::$error = $e->getMessage();
            return false;
        }
    }


    /**
     * @notes 更新用户信息
     * @param $params
     * @param $userId
     * @return User
     * @author 段誉
     * @date 2023/2/22 11:19
     */
    public static function updateUser($params, $userId)
    {
        return User::where(['id' => $userId])->update([
            'nickname' => $params['nickname'],
            'avatar' => FileService::setFileUrl($params['avatar']),
            'is_new_user' => YesNoEnum::NO
        ]);
    }
}