310 lines
9 KiB
PHP
310 lines
9 KiB
PHP
<?php
|
||
class dingapi
|
||
{
|
||
public $apiUrl = 'https://oapi.dingtalk.com/';
|
||
private $appKey;
|
||
private $appSecret;
|
||
private $token;
|
||
private $expires;
|
||
private $errors = array();
|
||
|
||
/**
|
||
* Construct
|
||
*
|
||
* @param string $appKey
|
||
* @param string $appSecret
|
||
* @param string $agentId
|
||
* @param string $apiUrl
|
||
* @access public
|
||
* @return void
|
||
*/
|
||
public function __construct($appKey, $appSecret, $agentId, $apiUrl = '')
|
||
{
|
||
$this->appKey = $appKey;
|
||
$this->appSecret = $appSecret;
|
||
$this->agentId = $agentId;
|
||
if($apiUrl) $this->apiUrl = rtrim($apiUrl, '/') . '/';
|
||
|
||
if(!$this->getToken()) return array('result' => 'fail', 'message' => $this->errors);
|
||
}
|
||
|
||
/**
|
||
* Get token.
|
||
*
|
||
* @access public
|
||
* @return string
|
||
*/
|
||
public function getToken()
|
||
{
|
||
if($this->token and (time() - $this->expires) >= 0) return $this->token;
|
||
|
||
$response = $this->queryAPI($this->apiUrl . "gettoken?appkey={$this->appKey}&appsecret={$this->appSecret}");
|
||
if($this->isError()) return false;
|
||
|
||
$this->token = $response->access_token;
|
||
$this->expires = time() + $response->expires_in;
|
||
return $this->token;
|
||
}
|
||
|
||
/**
|
||
* Get users.
|
||
*
|
||
* @param string $selectedDepts
|
||
* @access public
|
||
* @return array
|
||
*/
|
||
public function getUsers($selectedDepts = '')
|
||
{
|
||
$depts = trim($selectedDepts);
|
||
if(empty($depts)) return array('result' => 'fail', 'message' => 'nodept');
|
||
|
||
set_time_limit(0);
|
||
$users = array();
|
||
foreach(explode(',', $depts) as $deptID)
|
||
{
|
||
if(empty($deptID)) continue;
|
||
|
||
$response = $this->queryAPI($this->apiUrl . "user/simplelist?access_token={$this->token}&department_id={$deptID}");
|
||
if($this->isError())
|
||
{
|
||
$this->getErrors();
|
||
continue;
|
||
}
|
||
|
||
foreach($response->userlist as $user) $users[$user->name] = $user->userid;
|
||
}
|
||
|
||
$response = $this->queryAPI($this->apiUrl . "auth/scopes?access_token={$this->token}");
|
||
if(!empty($response->auth_org_scopes->authed_user))
|
||
{
|
||
foreach($response->auth_org_scopes->authed_user as $userid)
|
||
{
|
||
$user = $this->queryAPI($this->apiUrl . "user/get?access_token={$this->token}&userid={$userid}");
|
||
if($this->isError())
|
||
{
|
||
$this->getErrors();
|
||
continue;
|
||
}
|
||
|
||
$users[$user->name] = $user->userid;
|
||
}
|
||
}
|
||
|
||
return array('result' => 'success', 'data' => $users);
|
||
}
|
||
|
||
/**
|
||
* Get dept tree.
|
||
*
|
||
* @access public
|
||
* @return array
|
||
*/
|
||
public function getDeptTree()
|
||
{
|
||
$response = $this->queryAPI($this->apiUrl . "auth/scopes?access_token={$this->token}");
|
||
if(isset($response->auth_org_scopes->authed_dept) and $response->auth_org_scopes->authed_dept[0] != 1)
|
||
{
|
||
$selectedDepts = array();
|
||
foreach($response->auth_org_scopes->authed_dept as $deptID)
|
||
{
|
||
$selectedDepts[$deptID] = $deptID;
|
||
|
||
$response = $this->queryAPI($this->apiUrl . "department/list?access_token={$this->token}&id=$deptID");
|
||
foreach($response->department as $dept) $selectedDepts[$dept->id] = $dept->id;
|
||
}
|
||
return array('result' => 'selected', 'data' => $selectedDepts);
|
||
}
|
||
else
|
||
{
|
||
$response = $this->queryAPI($this->apiUrl . "department/list?access_token={$this->token}");
|
||
if($this->isError()) return array('result' => 'fail', 'message' => $this->errors);
|
||
|
||
$parentDepts = array();
|
||
foreach($response->department as $dept)
|
||
{
|
||
$parentID = isset($dept->parentid) ? $dept->parentid : 0;
|
||
$parentDepts[$parentID][$dept->id] = $dept->name;
|
||
}
|
||
}
|
||
|
||
$tree = array();
|
||
foreach($parentDepts as $parentID => $depts)
|
||
{
|
||
foreach($depts as $deptID => $deptName)
|
||
{
|
||
$node = array();
|
||
$node['id'] = $deptID;
|
||
$node['pId'] = $parentID;
|
||
$node['name'] = $deptName;
|
||
$node['open'] = true;
|
||
|
||
$tree[] = $node;
|
||
}
|
||
}
|
||
|
||
return array('result' => 'success', 'data' => $tree);
|
||
}
|
||
|
||
/**
|
||
* Send message
|
||
*
|
||
* @param string $userList
|
||
* @param string $message
|
||
* @access public
|
||
* @return array
|
||
*/
|
||
public function send($userList, $message)
|
||
{
|
||
$postData = array();
|
||
$postData['agent_id'] = $this->agentId;
|
||
$postData['userid_list'] = $userList;
|
||
$postData['msg'] = $message;
|
||
|
||
$url = $this->apiUrl . 'topapi/message/corpconversation/asyncsend_v2?access_token=' . $this->token;
|
||
$response = common::http($url, $postData);
|
||
$errors = commonModel::$requestErrors;
|
||
|
||
$response = json_decode($response);
|
||
if(isset($response->errcode) and $response->errcode == 0) return array('result' => 'success');
|
||
|
||
if(empty($response)) $this->errors = $errors;
|
||
if(isset($response->errcode)) $this->errors[$response->errcode] = "Errcode:{$response->errcode}, Errmsg:{$response->errmsg}";
|
||
return array('result' => 'fail', 'message' => $this->errors);
|
||
}
|
||
|
||
/**
|
||
* Query API.
|
||
*
|
||
* @param string $url
|
||
* @access public
|
||
* @return string
|
||
*/
|
||
public function queryAPI($url)
|
||
{
|
||
$response = common::http($url);
|
||
$errors = commonModel::$requestErrors;
|
||
|
||
$response = json_decode($response);
|
||
if(isset($response->errcode) and $response->errcode == 0) return $response;
|
||
|
||
if(empty($response)) $this->errors = $errors;
|
||
if(isset($response->result) and $response->result == 'fail') $this->errors['curl'] = $response->message;
|
||
if(isset($response->errcode)) $this->errors[$response->errcode] = "Errcode:{$response->errcode}, Errmsg:{$response->errmsg}";
|
||
return false;
|
||
}
|
||
|
||
/**
|
||
* 根据open_id列表，获取用户。
|
||
* Batch get users by open_id list.
|
||
*
|
||
* @param array $userIdList
|
||
* @access public
|
||
* @return array
|
||
*/
|
||
public function batchGetUsers($userIdList)
|
||
{
|
||
$useridPairs = array();
|
||
$userGroup = array_chunk($userIdList, 49);
|
||
foreach($userGroup as $userIdList)
|
||
{
|
||
$urls = array();
|
||
foreach($userIdList as $userID) $urls[] = $this->apiUrl . "topapi/v2/user/get?access_token={$this->token}&userid={$userID}";
|
||
$datas = $this->multiRequest($urls);
|
||
foreach($datas as $response)
|
||
{
|
||
$response = json_decode($response);
|
||
if(empty($response->result)) continue;
|
||
|
||
$user = $response->result;
|
||
$useridPairs[$user->userid] = $user->name;
|
||
}
|
||
}
|
||
|
||
return $useridPairs;
|
||
}
|
||
|
||
/**
|
||
* Handle the concurrency of requests.
|
||
*
|
||
* @param array $urls
|
||
* @access public
|
||
* @return array
|
||
*/
|
||
public function multiRequest($urls)
|
||
{
|
||
$curl = curl_multi_init();
|
||
$urlHandlers = array();
|
||
$urlData = array();
|
||
|
||
/* Set request header information. */
|
||
/* Initialize multiple request handles to one. */
|
||
foreach($urls as $url)
|
||
{
|
||
$ch = curl_init();
|
||
curl_setopt($ch, CURLOPT_URL, $url);
|
||
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
|
||
if(!isset($_SERVER['HTTPS']) or $_SERVER['HTTPS'] != 'on')
|
||
{
|
||
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
|
||
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
|
||
}
|
||
|
||
$urlHandlers[] = $ch;
|
||
curl_multi_add_handle($curl, $ch);
|
||
}
|
||
|
||
$active = null;
|
||
do
|
||
{
|
||
$mrc = curl_multi_exec($curl, $active);
|
||
}
|
||
while($mrc == CURLM_CALL_MULTI_PERFORM);
|
||
|
||
while($active and $mrc == CURLM_OK)
|
||
{
|
||
usleep(50000);
|
||
if(curl_multi_select($curl) != -1)
|
||
{
|
||
do
|
||
{
|
||
$mrc = curl_multi_exec($curl, $active);
|
||
}
|
||
while($mrc == CURLM_CALL_MULTI_PERFORM);
|
||
}
|
||
}
|
||
|
||
foreach($urlHandlers as $index => $ch)
|
||
{
|
||
$urlData[$index] = curl_multi_getcontent($ch);
|
||
curl_multi_remove_handle($curl, $ch);
|
||
}
|
||
curl_multi_close($curl);
|
||
return $urlData;
|
||
}
|
||
|
||
/**
|
||
* Check for errors.
|
||
*
|
||
* @access public
|
||
* @return bool
|
||
*/
|
||
public function isError()
|
||
{
|
||
return !empty($this->errors);
|
||
}
|
||
|
||
/**
|
||
* Get errors.
|
||
*
|
||
* @access public
|
||
* @return array
|
||
*/
|
||
public function getErrors()
|
||
{
|
||
$errors = $this->errors;
|
||
$this->errors = array();
|
||
|
||
return $errors;
|
||
}
|
||
}
|