mirror of
https://gitee.com/zoujingli/ThinkAdmin.git
synced 2025-04-06 03:58:04 +08:00
233 lines
7.8 KiB
PHP
233 lines
7.8 KiB
PHP
<?php
|
||
|
||
// +----------------------------------------------------------------------
|
||
// | wechat-php-sdk
|
||
// +----------------------------------------------------------------------
|
||
// | 版权所有 2014~2017 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||
// +----------------------------------------------------------------------
|
||
// | 官方文档: https://www.kancloud.cn/zoujingli/wechat-php-sdk
|
||
// +----------------------------------------------------------------------
|
||
// | 开源协议 ( https://mit-license.org )
|
||
// +----------------------------------------------------------------------
|
||
// | github开源项目：https://github.com/zoujingli/wechat-php-sdk
|
||
// +----------------------------------------------------------------------
|
||
|
||
namespace Wechat\Lib;
|
||
|
||
use Prpcrypt;
|
||
use Wechat\Loader;
|
||
|
||
/**
|
||
* 微信SDK基础类
|
||
*
|
||
* @category WechatSDK
|
||
* @subpackage library
|
||
* @author Anyon <zoujingli@qq.com>
|
||
* @date 2016/05/28 11:55
|
||
*/
|
||
class Common
|
||
{
|
||
|
||
/** API接口URL需要使用此前缀 */
|
||
const API_BASE_URL_PREFIX = 'https://api.weixin.qq.com';
|
||
const API_URL_PREFIX = 'https://api.weixin.qq.com/cgi-bin';
|
||
const GET_TICKET_URL = '/ticket/getticket?';
|
||
const AUTH_URL = '/token?grant_type=client_credential&';
|
||
public $token;
|
||
public $encodingAesKey;
|
||
public $encrypt_type;
|
||
public $appid;
|
||
public $appsecret;
|
||
public $access_token;
|
||
public $postxml;
|
||
public $_msg;
|
||
public $errCode = 0;
|
||
public $errMsg = "";
|
||
public $config = array();
|
||
private $_retry = false;
|
||
|
||
/**
|
||
* 构造方法
|
||
* @param array $options
|
||
*/
|
||
public function __construct($options = array())
|
||
{
|
||
$config = Loader::config($options);
|
||
$this->token = isset($config['token']) ? $config['token'] : '';
|
||
$this->appid = isset($config['appid']) ? $config['appid'] : '';
|
||
$this->appsecret = isset($config['appsecret']) ? $config['appsecret'] : '';
|
||
$this->encodingAesKey = isset($config['encodingaeskey']) ? $config['encodingaeskey'] : '';
|
||
$this->config = $config;
|
||
}
|
||
|
||
/**
|
||
* 当前当前错误代码
|
||
* @return int
|
||
*/
|
||
public function getErrorCode()
|
||
{
|
||
return $this->errCode;
|
||
}
|
||
|
||
/**
|
||
* 获取当前错误内容
|
||
* @return string
|
||
*/
|
||
public function getError()
|
||
{
|
||
return $this->errMsg;
|
||
}
|
||
|
||
/**
|
||
* 获取当前操作公众号APPID
|
||
* @return string
|
||
*/
|
||
public function getAppid()
|
||
{
|
||
return $this->appid;
|
||
}
|
||
|
||
/**
|
||
* 获取SDK配置参数
|
||
* @return array
|
||
*/
|
||
public function getConfig()
|
||
{
|
||
return $this->config;
|
||
}
|
||
|
||
|
||
/**
|
||
* 接口验证
|
||
* @return bool
|
||
*/
|
||
public function valid()
|
||
{
|
||
$encryptStr = "";
|
||
if ($_SERVER['REQUEST_METHOD'] == "POST") {
|
||
$postStr = file_get_contents("php://input");
|
||
$array = (array)simplexml_load_string($postStr, 'SimpleXMLElement', LIBXML_NOCDATA);
|
||
$this->encrypt_type = isset($_GET["encrypt_type"]) ? $_GET["encrypt_type"] : '';
|
||
if ($this->encrypt_type == 'aes') {
|
||
$encryptStr = $array['Encrypt'];
|
||
!class_exists('Prpcrypt', false) && require __DIR__ . '/Prpcrypt.php';
|
||
$pc = new Prpcrypt($this->encodingAesKey);
|
||
$array = $pc->decrypt($encryptStr, $this->appid);
|
||
if (!isset($array[0]) || intval($array[0]) > 0) {
|
||
$this->errCode = $array[0];
|
||
$this->errMsg = $array[1];
|
||
Tools::log("Interface Authentication Failed. {$this->errMsg}[{$this->errCode}]", "ERR - {$this->appid}");
|
||
return false;
|
||
}
|
||
$this->postxml = $array[1];
|
||
empty($this->appid) && $this->appid = $array[2];
|
||
} else {
|
||
$this->postxml = $postStr;
|
||
}
|
||
} elseif (isset($_GET["echostr"])) {
|
||
if ($this->checkSignature()) {
|
||
@ob_clean();
|
||
exit($_GET["echostr"]);
|
||
}
|
||
return false;
|
||
}
|
||
if (!$this->checkSignature($encryptStr)) {
|
||
$this->errMsg = 'Interface authentication failed, please use the correct method to call.';
|
||
return false;
|
||
}
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 验证来自微信服务器
|
||
* @param string $str
|
||
* @return bool
|
||
*/
|
||
private function checkSignature($str = '')
|
||
{
|
||
$signature = isset($_GET["msg_signature"]) ? $_GET["msg_signature"] : (isset($_GET["signature"]) ? $_GET["signature"] : '');
|
||
$timestamp = isset($_GET["timestamp"]) ? $_GET["timestamp"] : '';
|
||
$nonce = isset($_GET["nonce"]) ? $_GET["nonce"] : '';
|
||
$tmpArr = array($this->token, $timestamp, $nonce, $str);
|
||
sort($tmpArr, SORT_STRING);
|
||
if (sha1(implode($tmpArr)) == $signature) {
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
|
||
/**
|
||
* 获取公众号访问 access_token
|
||
* @param string $appid 如在类初始化时已提供，则可为空
|
||
* @param string $appsecret 如在类初始化时已提供，则可为空
|
||
* @param string $token 手动指定access_token，非必要情况不建议用
|
||
* @return bool|string
|
||
*/
|
||
public function getAccessToken($appid = '', $appsecret = '', $token = '')
|
||
{
|
||
if (!$appid || !$appsecret) {
|
||
list($appid, $appsecret) = array($this->appid, $this->appsecret);
|
||
}
|
||
if ($token) {
|
||
return $this->access_token = $token;
|
||
}
|
||
$cache = 'wechat_access_token_' . $appid;
|
||
if (($access_token = Tools::getCache($cache)) && !empty($access_token)) {
|
||
return $this->access_token = $access_token;
|
||
}
|
||
# 检测事件注册
|
||
if (isset(Loader::$callback[__FUNCTION__])) {
|
||
return $this->access_token = call_user_func_array(Loader::$callback[__FUNCTION__], array(&$this, &$cache));
|
||
}
|
||
$result = Tools::httpGet(self::API_URL_PREFIX . self::AUTH_URL . 'appid=' . $appid . '&secret=' . $appsecret);
|
||
if ($result) {
|
||
$json = json_decode($result, true);
|
||
if (!$json || isset($json['errcode'])) {
|
||
$this->errCode = $json['errcode'];
|
||
$this->errMsg = $json['errmsg'];
|
||
Tools::log("Get New AccessToken Error. {$this->errMsg}[{$this->errCode}]", "ERR - {$this->appid}");
|
||
return false;
|
||
}
|
||
$this->access_token = $json['access_token'];
|
||
Tools::log("Get New AccessToken Success.", "MSG - {$this->appid}");
|
||
Tools::setCache($cache, $this->access_token, 5000);
|
||
return $this->access_token;
|
||
}
|
||
return false;
|
||
}
|
||
|
||
/**
|
||
* 接口失败重试
|
||
* @param string $method SDK方法名称
|
||
* @param array $arguments SDK方法参数
|
||
* @return bool|mixed
|
||
*/
|
||
protected function checkRetry($method, $arguments = array())
|
||
{
|
||
Tools::log("Run {$method} Faild. {$this->errMsg}[{$this->errCode}]", "ERR - {$this->appid}");
|
||
if (!$this->_retry && in_array($this->errCode, array('40014', '40001', '41001', '42001'))) {
|
||
($this->_retry = true) && $this->resetAuth();
|
||
$this->errCode = 40001;
|
||
$this->errMsg = 'no access';
|
||
Tools::log("Retry Run {$method} ...", "MSG - {$this->appid}");
|
||
return call_user_func_array(array($this, $method), $arguments);
|
||
}
|
||
return false;
|
||
}
|
||
|
||
/**
|
||
* 删除验证数据
|
||
* @param string $appid 如在类初始化时已提供，则可为空
|
||
* @return bool
|
||
*/
|
||
public function resetAuth($appid = '')
|
||
{
|
||
$authname = 'wechat_access_token_' . (empty($appid) ? $this->appid : $appid);
|
||
Tools::log("Reset Auth And Remove Old AccessToken.", "MSG - {$this->appid}");
|
||
$this->access_token = '';
|
||
Tools::removeCache($authname);
|
||
return true;
|
||
}
|
||
|
||
}
|