如何高效集成amoCRMOAuth2.0？使用amocrm/oauth2-amocrm轻松搞定PHP应用与CRM的连接

<code class="bash">composer require amocrm/oauth2-amocrm</code>

<pre class="brush:php;toolbar:false;"><?php

require 'vendor/autoload.php';

use AmoCRM\OAuth2\Client\Provider\AmoCRM;
use League\OAuth2\Client\Provider\Exception\IdentityProviderException;

// 替换为你在 amoCRM 开发者后台获取的信息
$provider = new AmoCRM([
    'clientId'     => 'YOUR_CLIENT_ID',
    'clientSecret' => 'YOUR_CLIENT_SECRET',
    'redirectUri'  => 'http://your-redirect-uri.com/callback.php', // 确保与 amoCRM 后台设置一致
]);

if (!isset($_GET['code'])) {
    // 如果没有授权码，重定向到 amoCRM 授权页面
    $authorizationUrl = $provider->getAuthorizationUrl();
    $_SESSION['oauth2state'] = $provider->getState(); // 存储状态以防止 CSRF
    header('Location: ' . $authorizationUrl);
    exit;
} elseif (empty($_GET['state']) || ($_GET['state'] !== $_SESSION['oauth2state'])) {
    // 验证状态参数以防止 CSRF 攻击
    unset($_SESSION['oauth2state']);
    exit('Invalid state');
} else {
    try {
        // amoCRM 的特殊处理：需要设置 baseDomain
        if (isset($_GET['referer'])) {
            $provider->setBaseDomain($_GET['referer']);
        }

        // 使用授权码获取访问令牌
        $accessToken = $provider->getAccessToken('authorization_code', [
            'code' => $_GET['code']
        ]);

        // 到这里，你已经成功获取了访问令牌和刷新令牌！
        // 建议将这些令牌以及 baseDomain 存储到数据库或安全存储中。
        // $accessToken->getToken() 是访问令牌
        // $accessToken->getRefreshToken() 是刷新令牌
        // $accessToken->getExpires() 是令牌过期时间戳
        // $provider->getBaseDomain() 是当前账号的域名

        echo 'Access Token: ' . $accessToken->getToken() . '<br>';
        echo 'Refresh Token: ' . $accessToken->getRefreshToken() . '<br>';
        echo 'Expires: ' . date('Y-m-d H:i:s', $accessToken->getExpires()) . '<br>';
        echo 'Base Domain: ' . $provider->getBaseDomain() . '<br>';

        // 获取资源所有者（用户）信息
        /** @var \AmoCRM\OAuth2\Client\Provider\AmoCRMResourceOwner $ownerDetails */
        $ownerDetails = $provider->getResourceOwner($accessToken);
        printf('Hello, %s!', $ownerDetails->getName());

        // todo: 将 $accessToken 和 $provider->getBaseDomain() 存储起来以备后续使用
        // 例如：$_SESSION['amo_token'] = $accessToken->jsonSerialize();
        // $_SESSION['amo_base_domain'] = $provider->getBaseDomain();

    } catch (IdentityProviderException $e) {
        // 捕获认证失败异常
        exit('Error: ' . $e->getMessage());
    }
}

<pre class="brush:php;toolbar:false;"><?php

require 'vendor/autoload.php';

use AmoCRM\OAuth2\Client\Provider\AmoCRM;
use League\OAuth2\Client\Grant\RefreshToken;
use League\OAuth2\Client\Provider\Exception\IdentityProviderException;

// 替换为你在 amoCRM 开发者后台获取的信息
$provider = new AmoCRM([
    'clientId'     => 'YOUR_CLIENT_ID',
    'clientSecret' => 'YOUR_CLIENT_SECRET',
    'redirectUri'  => 'http://your-redirect-uri.com/callback.php',
]);

// todo: 从你的存储中加载之前保存的令牌数据和 baseDomain
// 假设你从数据库中获取了这些信息
$storedTokenData = [
    'accessToken' => 'YOUR_OLD_ACCESS_TOKEN',
    'refreshToken' => 'YOUR_OLD_REFRESH_TOKEN',
    'expires' => 1678886400, // 旧令牌的过期时间戳
    'baseDomain' => 'your-amocrm-subdomain.amocrm.ru',
];

$provider->setBaseDomain($storedTokenData['baseDomain']);

// 检查令牌是否过期
if (time() >= $storedTokenData['expires']) {
    echo "Access Token has expired. Attempting to refresh...<br>";
    try {
        $newAccessToken = $provider->getAccessToken(new RefreshToken(), [
            'refresh_token' => $storedTokenData['refreshToken'],
        ]);

        // 成功获取新令牌！
        // todo: 务必更新你的存储中的令牌信息
        // 例如：更新数据库中的 accessToken, refreshToken, expires, baseDomain
        echo 'New Access Token: ' . $newAccessToken->getToken() . '<br>';
        echo 'New Refresh Token: ' . $newAccessToken->getRefreshToken() . '<br>';
        echo 'New Expires: ' . date('Y-m-d H:i:s', $newAccessToken->getExpires()) . '<br>';

        // 现在你可以使用 $newAccessToken 进行 API 调用了
        // ...

    } catch (IdentityProviderException $e) {
        // 刷新令牌失败，可能需要用户重新授权
        exit('Error refreshing token: ' . $e->getMessage());
    }
} else {
    echo "Access Token is still valid.<br>";
    // 可以直接使用 $storedTokenData['accessToken'] 进行 API 调用
}