hb/server/app/Services/TencentImAccountService.php

<?php

namespace App\Services;

use App\Exceptions\TencentImAccountException;
use App\Models\User;
use App\Traits\TencentIm;
use Illuminate\Support\Arr;

class TencentImAccountService
{
    use TencentIm;

    public const IM_IDENTIFIER_PREFIX = 'IM_USER_';
    public const TENCENT_REST_APIS    = [
        'accountImport'      => 'v4/im_open_login_svc/account_import',  // 导入单个帐号
        'multiAccountImport' => 'v4/im_open_login_svc/multiaccount_import', // 导入多个帐号
        'accountDelete'      => 'v4/im_open_login_svc/account_delete',  // 删除帐号
        'accountCheck'       => 'v4/im_open_login_svc/account_check',    // 查询帐号是否已导入IM
        'kick'               => 'v4/im_open_login_svc/kick',  // 失效帐号登录态
        'queryState'         => 'v4/openim/querystate', // 查询帐号在线状态
    ];

    /**
     * 导入单个账号.
     *
     * @return string
     *
     * @throws TencentImAccountException
     * @throws \App\Exceptions\TencentImException
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function accountImport(User $user)
    {
        $this->restApiName = self::TENCENT_REST_APIS['accountImport'];
        $baseApiHost       = $this->getTencentImRestApiBaseHost();
        $params            = [
            'Identifier' => self::IM_IDENTIFIER_PREFIX . $user->id,
            //            'Nick' => $user->nickname ?? null,
            //            'FaceUrl' => valid_url($user->avatar)
        ];
        if ($user->nickname) {
            $params = Arr::add($params, 'Nick', $user->nickName);
        }
        if ($user->avatar) {
            $params = Arr::add($params, 'FaceUrl', $user->avatar);
        }
        $apiResult = $this->requestApi($baseApiHost, $params);
        self::verifyApiResult($apiResult);

        return self::IM_IDENTIFIER_PREFIX . $user->id;
    }

    /**
     * 导入多个账号.
     *
     * @return array|string[]
     *
     * @throws TencentImAccountException
     * @throws \App\Exceptions\TencentImException
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function multiAccountImport(array $accounts)
    {
        $this->restApiName = self::TENCENT_REST_APIS['multiAccountImport'];
        $baseApiHost       = $this->getTencentImRestApiBaseHost();
        $accounts          = array_unique(array_filter($accounts));

        $this->verifyRestApiMaxItem($accounts);

        $accounts = array_map(function ($value) {
            return self::IM_IDENTIFIER_PREFIX . $value;
        }, $accounts);
        $params = [
            'Accounts' => $accounts,
        ];
        $apiResult = $this->requestApi($baseApiHost, $params);
        self::verifyApiResult($apiResult);

        return $accounts;
    }

    /**
     * 删除账号.
     *
     * @return bool
     *
     * @throws TencentImAccountException
     * @throws \App\Exceptions\TencentImException
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function accountDelete(array $accounts)
    {
        $this->restApiName = self::TENCENT_REST_APIS['accountDelete'];
        $baseApiHost       = $this->getTencentImRestApiBaseHost();
        $accounts          = array_unique(array_filter($accounts));

        $this->verifyRestApiMaxItem($accounts);

        $accounts = array_map(function ($value) {
            $UserID = $value;

            return compact('UserID');
        }, $accounts);
        $params = [
            'DeleteItem' => $accounts,
        ];
        $apiResult = $this->requestApi($baseApiHost, $params);
        self::verifyApiResult($apiResult);

        return true;
    }

    /**
     * 查询帐号是否已导入IM.
     *
     * @throws TencentImAccountException
     * @throws \App\Exceptions\TencentImException
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function accountCheck(array $accounts)
    {
        $this->restApiName = self::TENCENT_REST_APIS['accountCheck'];
        $baseApiHost       = $this->getTencentImRestApiBaseHost();
        $accounts          = array_unique(array_filter($accounts));

        $this->verifyRestApiMaxItem($accounts);

        $accounts = array_map(function ($value) {
            $UserID = $value;

            return compact('UserID');
        }, $accounts);
        $params = [
            'CheckItem' => $accounts,
        ];
        $apiResult = $this->requestApi($baseApiHost, $params);
        self::verifyApiResult($apiResult);

        return $apiResult['ResultItem'];
    }

    /**
     * 强制下线
     *
     * @return bool
     *
     * @throws TencentImAccountException
     * @throws \App\Exceptions\TencentImException
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function kick(string $identifier)
    {
        $this->restApiName = self::TENCENT_REST_APIS['kick'];
        $baseApiHost       = $this->getTencentImRestApiBaseHost();
        $params            = ['Identifier' => $identifier];
        $apiResult         = $this->requestApi($baseApiHost, $params);
        self::verifyApiResult($apiResult);

        return true;
    }

    /**
     * 获取用户当前的登录状态
     *
     * @throws TencentImAccountException
     * @throws \App\Exceptions\TencentImException
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function queryState(array $accounts, bool $isDetail = false)
    {
        $this->restApiName = self::TENCENT_REST_APIS['queryState'];
        $baseApiHost       = $this->getTencentImRestApiBaseHost();
        $accounts          = array_unique(array_filter($accounts));

        $this->verifyRestApiMaxItem($accounts);

        $params = [
            'To_Account' => $accounts,
        ];
        $apiResult = $this->requestApi($baseApiHost, $params);
        self::verifyApiResult($apiResult);

        return $apiResult['QueryResult'];
    }

    /**
     * 验证接口返回.
     *
     * @return bool
     *
     * @throws TencentImAccountException
     */
    public static function verifyApiResult($apiResult)
    {
        if (!is_array($apiResult)) {
            throw new TencentImAccountException('IM 请求失败');
        }
        if (count(array_diff(['ActionStatus', 'ErrorCode', 'ErrorInfo'], array_keys($apiResult))) > 0) {
            throw new TencentImAccountException('IM 接口返回异常');
        }
        if (('OK' != $apiResult['ActionStatus']) || (0 != $apiResult['ErrorCode'])) {
            throw new TencentImAccountException('操作失败:   ' . $apiResult['ErrorInfo']);
        }

        return true;
    }
}