PHP code example of hyperf-apex / wecom

    
        
<?php
require_once('vendor/autoload.php');

/* Start to develop here. Best regards https://php-download.com/ */

    

hyperf-apex / wecom example snippets

return [
    'default' => env('WECOM_ALIAS', 'default'),
    'accounts' => [
        // 键名就是调用方使用的 alias
        'default' => [
            'corp_id' => env('WECOM_CORP_ID', ''),
            'agent_id' => env('WECOM_AGENT_ID', ''),
            'secret' => env('WECOM_SECRET', ''),
            'token' => env('WECOM_TOKEN', ''),        // 回调验签用，只做主动调用可留空
            'aes_key' => env('WECOM_AES_KEY', ''),    // 同上
            'redirect_uri' => env('WECOM_REDIRECT_URI', ''),
        ],
        'sales' => [
            'corp_id' => env('WECOM_SALES_CORP_ID', ''),
            // ...
        ],
    ],
    'timeout' => 5,
    'token_expire_ahead' => 300,
    'cache_prefix' => 'wecom:',
    'state_ttl' => 300,
    'log_channel' => 'outbound',
];

use Hyperf\Apex\WeCom\Manager\WeComManager;

final class UserSyncService
{
    public function __construct(private readonly WeComManager $wecom)
    {
    }

    public function departmentUsers(int $departmentId, ?string $alias = null): array
    {
        // 成功返回响应体；失败抛 BusinessException（503），errcode 在 $e->getData()['errcode'] 里
        return $this->wecom->api($alias)->get('cgi-bin/user/list', [
            'department_id' => $departmentId,
        ]);
    }

    public function sendText(string $userId, string $content, ?string $alias = null): array
    {
        return $this->wecom->api($alias)->post('cgi-bin/message/send', [
            'touser' => $userId,
            'msgtype' => 'text',
            'agentid' => (int) $this->wecom->account($alias)->agentId,
            'text' => ['content' => $content],
        ]);
    }
}

use Hyperf\Apex\WeCom\DTO\WeComAuthorizeRequestDTO;
use Hyperf\Apex\WeCom\DTO\WeComLoginRequestDTO;
use Hyperf\Apex\WeCom\Login\WeComLoginService;

final class AuthService
{
    public function __construct(private readonly WeComLoginService $login)
    {
    }

    /** 第一步：把三个入口与 state 交给前端 */
    public function authorizeUrl(): \Hyperf\Apex\WeCom\DTO\WeComAuthorizeUrlDTO
    {
        return $this->login->buildAuthorizeUrl(new WeComAuthorizeRequestDTO());   // 可传 alias / redirectUri
    }

    /** 第二步：回调带回的 code + state 换成员 userid */
    public function resolveUserId(string $code, string $state): string
    {
        return $this->login->resolveMember(new WeComLoginRequestDTO(code: $code, state: $state))->userId;
    }
}

use Hyperf\Apex\WeCom\Config\AccountResolverInterface;

// config/autoload/dependencies.php 或自己的 ConfigProvider
return [
    'dependencies' => [
        AccountResolverInterface::class => \App\Module\WeCom\DbAccountResolver::class,
    ],
];

bash
php bin/hyperf.php vendor:publish hyperf-apex/wecom --id=config