176 lines
4.3 KiB
PHP
176 lines
4.3 KiB
PHP
<?php
|
|
|
|
namespace PdAuth;
|
|
|
|
use JsonRpc\Client;
|
|
use PdAuth\Middleware\Authenticate;
|
|
|
|
class Auth
|
|
{
|
|
|
|
protected $config;
|
|
protected $host;
|
|
protected $id;
|
|
protected $secret;
|
|
|
|
/**
|
|
* @var Client
|
|
*/
|
|
protected $rpc;
|
|
|
|
public function __construct($config)
|
|
{
|
|
$this->config = $config;
|
|
$this->configure();
|
|
}
|
|
|
|
/**
|
|
* @throws \Exception
|
|
*/
|
|
protected function configure()
|
|
{
|
|
switch (env('APP_ENV')) {
|
|
case 'local':
|
|
case 'develop':
|
|
$this->host = 'http://auth.dev.haowumc.com';
|
|
break;
|
|
case 'production':
|
|
$this->host = 'https://auth.int.haowumc.com';
|
|
break;
|
|
default:
|
|
throw new \Exception('"APP_ENV" is not defined or not allow');
|
|
}
|
|
|
|
//为了公司内部调用的统一，更换协议为 JSON RPC
|
|
if (function_exists('app')) {
|
|
$this->rpc = app('rpc.auth');
|
|
} else {
|
|
$this->rpc = new Client([
|
|
'client' => [
|
|
'auth' => [
|
|
'local' => true,
|
|
'base_uri' => env('RPC_AUTH_URI'),
|
|
],
|
|
],
|
|
]);
|
|
}
|
|
}
|
|
|
|
protected function matchConfigById($id)
|
|
{
|
|
foreach ($this->config['apps'] as $name => $app) {
|
|
if ($app['id'] == $id) {
|
|
return $name;
|
|
}
|
|
}
|
|
return null;
|
|
}
|
|
|
|
public function choose($name = null, $id = null)
|
|
{
|
|
if ($id) {
|
|
$name = $this->matchConfigByid($id);
|
|
$this->choose($name);
|
|
}
|
|
|
|
if (!$name) {
|
|
$name = env('APP_NAME');
|
|
}
|
|
switch ($name) {
|
|
case 'erp':
|
|
case 'erp-api':
|
|
$this->id = $this->config['apps']['erp']['id'];
|
|
$this->secret = $this->config['apps']['erp']['secret'];
|
|
break;
|
|
case 'ds':
|
|
case 'ds-api':
|
|
$this->id = $this->config['apps']['erp']['id'];
|
|
$this->secret = $this->config['apps']['erp']['secret'];
|
|
break;
|
|
case 'crm':
|
|
case 'crm-api':
|
|
$this->id = $this->config['apps']['erp']['id'];
|
|
$this->secret = $this->config['apps']['erp']['secret'];
|
|
break;
|
|
case 'op':
|
|
case 'op-api':
|
|
$this->id = $this->config['apps']['erp']['id'];
|
|
$this->secret = $this->config['apps']['erp']['secret'];
|
|
break;
|
|
}
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* 生成web授权的链接
|
|
* @param $redirect
|
|
* @return string
|
|
*/
|
|
public function connect($redirect)
|
|
{
|
|
$id = $this->id;
|
|
$redirect = urlencode($redirect);
|
|
return "{$this->host}/connect?appid={$id}&redirect=$redirect";
|
|
}
|
|
|
|
/**
|
|
* @param $code
|
|
* @return array
|
|
* @throws \JsonRpc\Exception\RpcServerException
|
|
*/
|
|
public function getAccessToken($code)
|
|
{
|
|
$token = $this->rpc->call('oauth.access_token', [$this->id, $this->secret, $code]);
|
|
return $token;
|
|
}
|
|
|
|
/**
|
|
* 根据用户token获取用户信息
|
|
* @param $token
|
|
* @return array|null
|
|
* @throws \JsonRpc\Exception\RpcServerException
|
|
*/
|
|
public function getUserInfo($token)
|
|
{
|
|
$info = $this->rpc->call('oauth.user_info', [$this->id, $this->secret, $token]);
|
|
return $info;
|
|
}
|
|
|
|
/**
|
|
* 获取用户组
|
|
* @param null $token
|
|
* @return null
|
|
*/
|
|
public function getGroupUsers($token = null)
|
|
{
|
|
if ($token == null) {
|
|
$token = $_COOKIE[Authenticate::CookieName];
|
|
}
|
|
$token = urlencode($token);
|
|
$resp = $this->get("$this->host/api/group/users?access_token=$token");
|
|
if ($resp['code'] == 0) {
|
|
return $resp['data'];
|
|
}
|
|
return null;
|
|
}
|
|
|
|
|
|
/**
|
|
* @绑定好物平台用户
|
|
*
|
|
* @param int $user_id
|
|
* @param int $hwuser_id
|
|
* @return null
|
|
*/
|
|
public function bindHwUser(int $user_id, int $hwuser_id)
|
|
{
|
|
if ($user_id <= 0 || $hwuser_id <= 0) {
|
|
return null;
|
|
}
|
|
$resp = $this->post("$this->host/api/bind/hwuser", [
|
|
'id' => $user_id,
|
|
'hwmc_id' => $hwuser_id,
|
|
]);
|
|
return $resp;
|
|
}
|
|
} |