fastadmin_tailored/application/common/Service/Third/Wechat/MiniProgram.php

<?php

namespace app\common\Service\Third\Wechat;

use app\common\facade\Wechat;
use fast\Random;
use app\common\library\Auth;
use app\common\model\ThirdOauth;
use app\common\exception\BusinessException;

class MiniProgram
{
    public $wechat;
    protected $request;
    protected $payload;

    public function __construct($payload = [])
    {
        $this->payload = $payload;
        $this->wechat = Wechat::miniProgram();
    }

    // 小程序登录
    public function login()
    {
        // https://developers.weixin.qq.com/community/develop/doc/00022c683e8a80b29bed2142b56c01
        if (empty($this->payload['sessionId'])) {
            throw new BusinessException('未获取到登陆态, 请重试');
        }

        $sessionData = cache($this->payload['sessionId']);

        if (empty($sessionData)) {
            throw new BusinessException('登陆态已过期, 请重试');
        }

        $wechatUser = [
            'openid' => $sessionData['openid'],
            'unionid' => $sessionData['unionid'] ?? '',
            'mobile' => '',
            'avatar' => '',
            'nickname' => '',
        ];
        return $wechatUser;
    }

    public function bind()
    {
        if (empty($this->payload['sessionId'])) {
            throw new BusinessException('未获取到登陆态, 请重试');
        }

        $sessionData = cache($this->payload['sessionId']);

        if (empty($sessionData)) {
            throw new BusinessException('登陆态已过期, 请重试');
        }

        $wechatUser = [
            'openid' => $sessionData['openid'],
            'unionid' => $sessionData['unionid'] ?? '',
            'avatar' => '',
            'nickname' => '',
        ];
        return $wechatUser;
    }

    // 解密微信小程序手机号
    public function getUserPhoneNumber()
    {
        if (empty($this->payload['sessionId'])) {
            throw new BusinessException('未获取到登陆态, 请重试');
        }

        $sessionData = cache($this->payload['sessionId']);

        if (empty($sessionData)) {
            throw new BusinessException('登陆态已过期, 请重试');
        }

        $phoneInfo = $this->wechat->encryptor->decryptData($sessionData['session_key'], $this->payload['iv'], $this->payload['encryptedData']);

        if (empty($phoneInfo['purePhoneNumber'])) {
            throw new BusinessException('获取失败,请重试');
        }

        if ($phoneInfo['countryCode'] !== '86') {
            throw new BusinessException('仅支持大陆地区手机号');
        }
        return $phoneInfo['purePhoneNumber'];
    }

    /**
     * 获取session_id, 缓存 session_key, openid (unionid), 自动登录
     *
     * @return string
     */
    public function getSessionId()
    {
        if (empty($this->payload['code'])) {
            throw new BusinessException('缺少code参数');
        }
        
        $decryptData = $this->wechat->auth->session($this->payload['code']);

        if(!empty($decryptData['errmsg'])) {
            throw new BusinessException($decryptData['errmsg']);
        }

        if (empty($decryptData['session_key'])) {
            throw new BusinessException('未获取到登陆态, 请重试');
        }
        
        $auto_login = $this->payload['auto_login'] ?? false;

        // 自动登录流程
        if($auto_login) {
            $oauthInfo = ThirdOauth::getByOpenid($decryptData['openid']);
            if($oauthInfo && $oauthInfo->user_id) {
                $auth = Auth::instance();
                $ret = $auth->direct($oauthInfo->user_id);
                if ($ret) {
                    //set_token_in_header($auth->getToken());
                }
            }
        }
     
        $session_id = Random::uuid();
        cache($session_id, $decryptData, 60 * 60 * 24 * 7);   // session_key缓存保留一周
        return ['session_id' => $session_id, 'auto_login' => $auto_login];
    }
}