ThinkPHP框架目录结构：
<?php
/**
* Created by PhpStorm.
* User: Tinywan
* Date: 2016/9/11
* Time: 9:55
*/
namespace Org\Util;
class WechatAuth
{
/* 消息类型常量 */
const MSG_TYPE_TEXT = 'text';
const MSG_TYPE_IMAGE = 'image';
const MSG_TYPE_VOICE = 'voice';
const MSG_TYPE_VIDEO = 'video';
const MSG_TYPE_SHORTVIDEO = 'shortvideo';
const MSG_TYPE_LOCATION = 'location';
const MSG_TYPE_LINK = 'link';
const MSG_TYPE_MUSIC = 'music';
const MSG_TYPE_NEWS = 'news';
const MSG_TYPE_EVENT = 'event';
/* 二维码类型常量 */
const QR_SCENE = 'QR_SCENE';
const QR_LIMIT_SCENE = 'QR_LIMIT_SCENE';
/**
* 微信开发者申请的appID
* @var string
*/
private $appId = '';
/**
* 微信开发者申请的appSecret
* @var string
*/
private $appSecret = '';
/**
* 获取到的access_token
* @var string
*/
private $accessToken = '';
/**
* 微信api根路径
* @var string
*/
private $apiURL = 'https://api.weixin.qq.com/cgi-bin';
/**
* 微信二维码根路径
* @var string
*/
private $qrcodeURL = 'https://mp.weixin.qq.com/cgi-bin';
//授权地址
private $requestCodeURL = 'https://open.weixin.qq.com/connect/oauth2/authorize';
private $oauthApiURL = 'https://api.weixin.qq.com/sns';
/**
* 构造方法，调用微信高级接口时实例化SDK
* @param string $appid 微信appid
* @param string $secret 微信appsecret
* @param string $token 获取到的access_token
*/
public function __construct($appid, $secret, $token = null)
{
if ($appid && $secret) {
$this->appId = $appid;
$this->appSecret = $secret;
if (!empty($token)) $this->accessToken = $token;
} else {
throw new \Exception('缺少参数 APP_ID 和 APP_SECRET!');
}
}
// 是为了拼接成一URL地址，什么地址，拼接一个
public function getRequestCodeURL($redirect_uri, $state = null, $scope = 'snsapi_userinfo')
{
$query = array(
'appid' => $this->appId,
'redirect_uri' => $redirect_uri,
'response_type' => 'code',
'scope' => $scope,
);
if (!is_null($state) && preg_match('/[a-zA-Z0-9]+/', $state)) $query['state'] = $state;
//生成 URL-encode 之后的请求字符串 :foo=bar&baz=boom&cow=milk&php=hypertext+pro
$query = http_build_query($query);
return "{$this->requestCodeURL}?{$query}#wechat_redirect";
}
/**
* 获取access_token，用于后续接口访问
* @return array access_token信息，包含 token 和有效期
*/
public function getAccessToken($type = 'client', $code = null)
{
$param = array(
'appid' => $this->appId,
'secret' => $this->appSecret
);
switch ($type) {
case 'client':
$param['grant_type'] = 'client_credential';
$url = "{$this->apiURL}/token";
break;
case 'code':
$param['code'] = $code;
$param['grant_type'] = 'authorization_code';
$url = "{$this->oauthApiURL}/oauth2/access_token";
break;
default:
throw new \Exception('不支持的grant_type类型！');
break;
}
$token = self::http($url, $param);
$token = json_decode($token, true);
if (is_array($token)) {
if (isset($token['errcode'])) {
throw new \Exception($token['errmsg']);
} else {
$this->accessToken = $token['access_token'];
return $token;
}
} else {
throw new \Exception('获取微信access_token失败！');
}
}
/**
* 获取授权用户信息
* @param string $openid 用户的OpenID
* @param string $lang 指定的语言
* @return array 用户信息数据，具体参见微信文档
*/
public function getUserInfo($openid, $lang = 'zh_CN')
{
$query = array(
'access_token' => $this->accessToken,
'openid' => $openid,
'lang' => $lang,
);
$info = self::http("{$this->oauthApiURL}/userinfo", $query);
return json_decode($info, true);
}
/**
* 上传零时媒体资源
* @param string $filename 媒体资源本地路径
* @param string $type 媒体资源类型，具体请参考微信开发手册
*/
public function mediaUpload($filename, $type)
{
$filename = realpath($filename);
if (!$filename) throw new \Exception('资源路径错误！');
$data = array(
'type' => $type,
'media' => "@{$filename}"
);
return $this->api('media/upload', $data, 'POST', '', false);
}
/**
* 上传永久媒体资源
* @param string $filename 媒体资源本地路径
* @param string $type 媒体资源类型，具体请参考微信开发手册
* @param string $description 资源描述，仅资源类型为 video 时有效
*/
public function materialAddMaterial($filename, $type, $description = '')
{
$filename = realpath($filename);
if (!$filename) throw new \Exception('资源路径错误！');
$data = array(
'type' => $type,
'media' => "@{$filename}",
);
if ($type == 'video') {
if (is_array($description)) {
//保护中文，微信api不支持中文转义的json结构
array_walk_recursive($description, function (&$value) {
$value = urlencode($value);
});
$description = urldecode(json_encode($description));
}
$data['description'] = $description;
}
return $this->api('material/add_material', $data, 'POST', '', false);
}
/**
* 获取媒体资源下载地址
* 注意：视频资源不允许下载
* @param string $media_id 媒体资源id
* @return string 媒体资源下载地址
*/
public function mediaGet($media_id)
{
$param = array(
'access_token' => $this->accessToken,
'media_id' => $media_id
);
$url = "{$this->apiURL}/media/get?";
return $url . http_build_query($param);
}
/**
* 给指定用户推送信息
* 注意：微信规则只允许给在48小时内给公众平台发送过消息的用户推送信息
* @param string $openid 用户的openid
* @param array $content 发送的数据，不同类型的数据结构可能不同
* @param string $type 推送消息类型
*/
public function messageCustomSend($openid, $content, $type = self::MSG_TYPE_TEXT)
{
//基础数据
$data = array(
'touser' => $openid,
'msgtype' => $type,
);
//根据类型附加额外数据
$data[$type] = call_user_func(array(self, $type), $content);
return $this->api('message/custom/send', $data);
}
/**
* 发送文本消息
* @param string $openid 用户的openid
* @param string $text 发送的文字
*/
public function sendText($openid, $text)
{
return $this->messageCustomSend($openid, $text, self::MSG_TYPE_TEXT);
}
/**
* 发送图片消息
* @param string $openid 用户的openid
* @param string $media 图片ID
*/
public function sendImage($openid, $media)
{
return $this->messageCustomSend($openid, $media, self::MSG_TYPE_IMAGE);
}
/**
* 发送语音消息
* @param string $openid 用户的openid
* @param string $media 音频ID
*/
public function sendVoice($openid, $media)
{
return $this->messageCustomSend($openid, $media, self::MSG_TYPE_VOICE);
}
/**
* 发送视频消息
* @param string $openid 用户的openid
* @param string $media_id 视频ID
* @param string $title 视频标题
* @param string $discription 视频描述
*/
public function sendVideo()
{
$video = func_get_args();
$openid = array_shift($video);
return $this->messageCustomSend($openid, $video, self::MSG_TYPE_VIDEO);
}
/**
* 发送音乐消息
* @param string $openid 用户的openid
* @param string $title 音乐标题
* @param string $discription 音乐描述
* @param string $musicurl 音乐链接
* @param string $hqmusicurl 高品质音乐链接
* @param string $thumb_media_id 缩略图ID
*/
public function sendMusic()
{
$music = func_get_args();
$openid = array_shift($music);
return $this->messageCustomSend($openid, $music, self::MSG_TYPE_MUSIC);
}
/**
* 发送图文消息
* @param string $openid 用户的openid
* @param array $news 图文内容 [标题，描述，URL，缩略图]
* @param array $news1 图文内容 [标题，描述，URL，缩略图]
* @param array $news2 图文内容 [标题，描述，URL，缩略图]
* ... ...
* @param array $news9 图文内容 [标题，描述，URL，缩略图]
*/
public function sendNews()
{
$news = func_get_args();
$openid = array_shift($news);
return $this->messageCustomSend($openid, $news, self::MSG_TYPE_NEWS);
}
/**
* 发送一条图文消息
* @param string $openid 用户的openid
* @param string $title 文章标题
* @param string $discription 文章简介
* @param string $url 文章连接
* @param string $picurl 文章缩略图
*/
public function sendNewsOnce()
{
$news = func_get_args();
$openid = array_shift($news);
$news = array($news);
return $this->messageCustomSend($openid, $news, self::MSG_TYPE_NEWS);
}
/**
* 创建用户组
* @param string $name 组名称
*/
public function groupsCreate($name)
{
$data = array('group' => array('name' => $name));
return $this->api('groups/create', $data);
}
/**
* 查询所有分组
* @return array 分组列表
*/
public function groupsGet()
{
return $this->api('groups/get', '', 'GET');
}
/**
* 查询用户所在的分组
* @param string $openid 用户的OpenID
* @return number 分组ID
*/
public function groupsGetid($openid)
{
$data = array('openid' => $openid);
return $this->api('groups/getid', $data);
}
/**
* 修改分组
* @param number $id 分组ID
* @param string $name 分组名称
* @return array 修改成功或失败信息
*/
public function groupsUpdate($id, $name)
{
$data = array('id' => $id, 'name' => $name);
return $this->api('groups/update', $data);
}
/**
* 移动用户分组
* @param string $openid 用户的OpenID
* @param number $to_groupid 要移动到的分组ID
* @return array 移动成功或失败信息
*/
public function groupsMemberUpdate($openid, $to_groupid)
{
$data = array('openid' => $openid, 'to_groupid' => $to_groupid);
return $this->api('groups/member/update', $data);
}
/**
* 用户设备注名
* @param string $openid 用户的OpenID
* @param string $remark 设备注名
* @return array 执行成功失败信息
*/
public function userInfoUpdateremark($openid, $remark)
{
$data = array('openid' => $openid, 'remark' => $remark);
return $this->api('user/info/updateremark', $data);
}
/**
* 获取指定用户的详细信息
* @param string $openid 用户的openid
* @param string $lang 需要获取数据的语言
*/
public function userInfo($openid, $lang = 'zh_CN')
{
$param = array('openid' => $openid, 'lang' => $lang);
return $this->api('user/info', '', 'GET', $param);
}
/**
* 获取关注者列表
* @param string $next_openid 下一个openid，在用户数大于10000时有效
* @return array 用户列表
*/
public function userGet($next_openid = '')
{
$param = array('next_openid' => $next_openid);
return $this->api('user/get', '', 'GET', $param);
}
/**
* 创建自定义菜单
* @param array $button 符合规则的菜单数组，规则参见微信手册
*/
public function menuCreate($button)
{
$data = array('button' => $button);
return $this->api('menu/create', $data);
}
/**
* 获取所有的自定义菜单
* @return array 自定义菜单数组
*/
public function menuGet()
{
return $this->api('menu/get', '', 'GET');
}
/**
* 删除自定义菜单
*/
public function menuDelete()
{
return $this->api('menu/delete', '', 'GET');
}
/**
* 创建二维码，可创建指定有效期的二维码和永久二维码
* @param integer $scene_id 二维码参数
* @param integer $expire_seconds 二维码有效期，0-永久有效
*/
public function qrcodeCreate($scene_id, $expire_seconds = 0)
{
$data = array();
if (is_numeric($expire_seconds) && $expire_seconds > 0) {
$data['expire_seconds'] = $expire_seconds;
$data['action_name'] = self::QR_SCENE;
} else {
$data['action_name'] = self::QR_LIMIT_SCENE;
}
$data['action_info']['scene']['scene_id'] = $scene_id;
return $this->api('qrcode/create', $data);
}
/**
* 根据ticket获取二维码URL
* @param string $ticket 通过 qrcodeCreate接口获取到的ticket
* @return string 二维码URL
*/
public function showqrcode($ticket)
{
return "{$this->qrcodeURL}/showqrcode?ticket={$ticket}";
}
/**
* 长链接转短链接
* @param string $long_url 长链接
* @return string 短链接
*/
public function shorturl($long_url)
{
$data = array(
'action' => 'long2short',
'long_url' => $long_url
);
return $this->api('shorturl', $data);
}
/**
* 调用微信api获取响应数据
* @param string $name API名称
* @param string $data POST请求数据
* @param string $method 请求方式
* @param string $param GET请求参数
* @return array api返回结果
*/
protected function api($name, $data = '', $method = 'POST', $param = '', $json = true)
{
$params = array('access_token' => $this->accessToken);
if (!empty($param) && is_array($param)) {
$params = array_merge($params, $param);
}
$url = "{$this->apiURL}/{$name}";
if ($json && !empty($data)) {
//保护中文，微信api不支持中文转义的json结构
array_walk_recursive($data, function (&$value) {
$value = urlencode($value);
});
$data = urldecode(json_encode($data));
}
$data = self::http($url, $params, $data, $method);
return json_decode($data, true);
}
/**
* 发送HTTP请求方法，目前只支持CURL发送请求
* @param string $url 请求URL
* @param array $param GET参数数组
* @param array $data POST的数据，GET请求时该参数无效
* @param string $method 请求方法GET/POST
* @return array 响应数据
*/
protected static function http($url, $param, $data = '', $method = 'GET')
{
$opts = array(
CURLOPT_TIMEOUT => 30,
CURLOPT_RETURNTRANSFER => 1,
CURLOPT_SSL_VERIFYPEER => false,
CURLOPT_SSL_VERIFYHOST => false,
);
/* 根据请求类型设置特定参数 */
$opts[CURLOPT_URL] = $url . '?' . http_build_query($param);
if (strtoupper($method) == 'POST') {
$opts[CURLOPT_POST] = 1;
$opts[CURLOPT_POSTFIELDS] = $data;
if (is_string($data)) { //发送JSON数据
$opts[CURLOPT_HTTPHEADER] = array(
'Content-Type: application/json; charset=utf-8',
'Content-Length: ' . strlen($data),
);
}
}
/* 初始化并执行curl请求 */
$ch = curl_init();
curl_setopt_array($ch, $opts);
$data = curl_exec($ch);
$error = curl_error($ch);
curl_close($ch);
//发生错误，抛出异常
if ($error) throw new \Exception('请求发生错误：' . $error);
return $data;
}
/**
* 构造文本信息
* @param string $content 要回复的文本
*/
private static function text($content)
{
$data['content'] = $content;
return $data;
}
/**
* 构造图片信息
* @param integer $media 图片ID
*/
private static function image($media)
{
$data['media_id'] = $media;
return $data;
}
/**
* 构造音频信息
* @param integer $media 语音ID
*/
private static function voice($media)
{
$data['media_id'] = $media;
return $data;
}
/**
* 构造视频信息
* @param array $video 要回复的视频 [视频ID，标题，说明]
*/
private static function video($video)
{
$data = array();
list(
$data['media_id'],
$data['title'],
$data['description'],
) = $video;
return $data;
}
/**
* 构造音乐信息
* @param array $music 要回复的音乐[标题，说明，链接，高品质链接，缩略图ID]
*/
private static function music($music)
{
$data = array();
list(
$data['title'],
$data['description'],
$data['musicurl'],
$data['hqmusicurl'],
$data['thumb_media_id'],
) = $music;
return $data;
}
/**
* 构造图文信息
* @param array $news 要回复的图文内容
* [
* 0 => 第一条图文信息[标题，说明，图片链接，全文连接]，
* 1 => 第二条图文信息[标题，说明，图片链接，全文连接]，
* 2 => 第三条图文信息[标题，说明，图片链接，全文连接]，
* ]
*/
private static function news($news)
{
$articles = array();
foreach ($news as $key => $value) {
list(
$articles[$key]['title'],
$articles[$key]['description'],
$articles[$key]['url'],
$articles[$key]['picurl']
) = $value;
if ($key >= 9) break; //最多只允许10条图文信息
}
$data['articles'] = $articles;
return $data;
}
}