<?php
/**
* 微信公众平台API
*/
class WeixinChat
{
private $token;
private $appid;
private $appsecret;
private $access_token;
// 接收的数据
private $_receive = array();
private $_reply = \'\';
// 接口错误码
private $errCode = \'\';
// 接口错误信息
private $errMsg = \'\';
// 微信oauth登陆获取code
const CONNECT_OAUTH_AUTHORIZE_URL = \'https://open.weixin.qq.com/connect/oauth2/authorize?\';
// 微信oauth登陆通过code换取网页授权access_token
const SNS_OAUTH_ACCESS_TOKEN_URL = \'https://api.weixin.qq.com/sns/oauth2/access_token?\';
// 微信oauth登陆刷新access_token（如果需要）
const SNS_OAUTH_REFRESH_TOKEN_URL = \'https://api.weixin.qq.com/sns/oauth2/refresh_token?\';
// 通过ticket换取二维码
const SHOW_QRCODE_URL = \'https://mp.weixin.qq.com/cgi-bin/showqrcode?\';
// 微信oauth登陆拉取用户信息(需scope为 snsapi_userinfo)
const SNS_USERINFO_URL = \'https://api.weixin.qq.com/sns/userinfo?\';
// 请求api前缀
const API_URL_PREFIX = \'https://api.weixin.qq.com/cgi-bin\';
// 自定义菜单创建
const MENU_CREATE_URL = \'/menu/create?\';
// 自定义菜单查询
const MENU_GET_URL = \'/menu/get?\';
// 自定义菜单删除
const MENU_DELETE_URL = \'/menu/delete?\';
// 获取 access_token
const AUTH_URL = \'/token?grant_type=client_credential&\';
// 获取用户基本信息
const USER_INFO_URL = \'/user/info?\';
// 获取关注者列表
const USER_GET_URL = \'/user/get?\';
// 查询分组
const GROUPS_GET_URL = \'/groups/get?\';
// 创建分组
const GROUPS_CREATE_URL = \'/groups/create?\';
// 修改分组名
const GROUPS_UPDATE_URL = \'/groups/update?\';
// 移动用户分组
const GROUPS_MEMBERS_UPDATE_URL = \'/groups/members/update?\';
// 发送客服消息
const MESSAGE_CUSTOM_SEND_URL = \'/message/custom/send?\';
// 创建二维码ticket
const QRCODE_CREATE_URL = \'/qrcode/create?\';
/**
* 初始化配置数据
* @param array $options
*/
public function __construct($options)
{
$this->token = isset($options[\'token\']) ? $options[\'token\'] : \'\';
$this->appid = isset($options[\'appid\']) ? $options[\'appid\'] : \'\';
$this->appsecret = isset($options[\'appsecret\']) ? $options[\'appsecret\'] : \'\';
}
/**
* 获取发来的消息
* 当普通微信用户向公众账号发消息时，微信服务器将POST消息的XML数据包到开发者填写的URL上。
*/
public function getRev()
{
$postStr = file_get_contents(\'php://input\');
if($postStr)
{
$this->_receive = (array)simplexml_load_string($postStr, \'SimpleXMLElement\', LIBXML_NOCDATA);
//Log::info(var_export($this->_receive, true));
}
return $this;
}
/**
* 获取微信服务器发来的消息
*/
public function getRevData()
{
return $this->_receive;
}
/**
* 获取接收者
*/
public function getRevTo()
{
return isset($this->_receive[\'ToUserName\']) ? $this->_receive[\'ToUserName\'] : false;
}
/**
* 获取消息发送者（一个OpenID）
*/
public function getRevFrom()
{
return isset($this->_receive[\'FromUserName\']) ? $this->_receive[\'FromUserName\'] : false;
}
/**
* 获取接收消息创建时间 （整型）
*/
public function getRevCTime()
{
return isset($this->_receive[\'CreateTime\']) ? $this->_receive[\'CreateTime\'] : false;
}
/**
* 获取接收消息类型（text、image、voice、video、location、link、event）
*/
public function getRevType()
{
return isset($this->_receive[\'MsgType\']) ? $this->_receive[\'MsgType\'] : false;
}
/**
* 获取接收消息编号
*/
public function getRevId()
{
return isset($this->_receive[\'MsgId\']) ? $this->_receive[\'MsgId\'] : false;
}
/**
* 获取接收消息文本
* 通过语音识别接口，用户发送的语音，将会同时给出语音识别出的文本内容。（需申请服务号的高级接口权限）
*/
public function getRevText()
{
if(isset($this->_receive[\'Content\'])) return trim($this->_receive[\'Content\']);
elseif(isset($this->_receive[\'Recognition\'])) return trim($this->_receive[\'Recognition\']);
else return false;
}
/**
* 获取接收图片消息
*/
public function getRevImage()
{
if(isset($this->_receive[\'PicUrl\'])){
return array(
\'picUrl\' => $this->_receive[\'PicUrl\'], //图片链接
\'mediaId\' => $this->_receive[\'MediaId\'] //图片消息媒体id，可以调用多媒体文件下载接口拉取数据。
);
}
return false;
}
/**
* 获取接收语音消息
*/
public function getRevVoice()
{
if(isset($this->_receive[\'MediaId\'])){
return array(
\'mediaId\' => $this->_receive[\'MediaId\'], //语音消息媒体id，可以调用多媒体文件下载接口拉取数据。
\'format\' => $this->_receive[\'Format\'] //语音格式，如amr，speex等
);
}
return false;
}
/**
* 获取接收视频消息
*/
public function getRevVideo()
{
if(isset($this->_receive[\'MediaId\'])){
return array(
\'mediaId\' => $this->_receive[\'MediaId\'], //视频消息媒体id，可以调用多媒体文件下载接口拉取数据。
\'thumbMediaId\' => $this->_receive[\'ThumbMediaId\'] //视频消息缩略图的媒体id，可以调用多媒体文件下载接口拉取数据。
);
}
return false;
}
/**
* 获取用户地理位置
*/
public function getRevLocation()
{
if(isset($this->_receive[\'Location_X\'])){
return array(
\'locationX\' => $this->_receive[\'Location_X\'], //地理位置维度
\'locationY\' => $this->_receive[\'Location_Y\'], //地理位置经度
\'scale\' => $this->_receive[\'Scale\'], //地图缩放大小
\'label\' => $this->_receive[\'Label\'] //地理位置信息
);
}
//开通了上报地理位置接口的公众号，用户在关注后进入公众号会话时，会弹框让用户确认是否允许公众号使用其地理位置。
//弹框只在关注后出现一次，用户以后可以在公众号详情页面进行操作。
elseif(isset($this->_receive[\'Latitude\']))
{
return array(
\'latitude\' => $this->_receive[\'Latitude\'], //地理位置纬度
\'longitude\' => $this->_receive[\'Longitude\'], //地理位置经度
\'precision\' => $this->_receive[\'Precision\'] // 地理位置精度
);
}
return false;
}
/**
* 获取接收链接消息
*/
public function getRevLink()
{
if(isset($this->_receive[\'Title\'])){
return array(
\'title\' => $this->_receive[\'Title\'], //消息标题
\'description\' => $this->_receive[\'Description\'], //消息描述
\'url\' => $this->_receive[\'Url\'] //消息链接
);
}
return false;
}
/**
* 获取接收事件类型
* 事件类型如：subscribe(订阅)、unsubscribe(取消订阅)、click
*/
public function getRevEvent()
{
if(isset($this->_receive[\'Event\']))
{
return array(
\'event\' => strtolower($this->_receive[\'Event\']),
\'key\'=> isset($this->_receive[\'EventKey\']) ? $this->_receive[\'EventKey\'] : \'\'
);
}
return false;
}
/**
* 设置回复文本消息
* @param string $content
* @param string $openid
*/
public function text($content=\'\')
{
$textTpl = "<xml>
<ToUserName><![CDATA[%s]]></ToUserName>
<FromUserName><![CDATA[%s]]></FromUserName>
<CreateTime>%s</CreateTime>
<MsgType><![CDATA[%s]]></MsgType>
<Content><![CDATA[%s]]></Content>
</xml>";
$this->_reply = sprintf($textTpl,
$this->getRevFrom(),
$this->getRevTo(),
Date::getTimeStamp(),
\'text\',
$content
);
return $this;
}
/**
* 设置回复音乐信息
* @param string $title
* @param string $desc
* @param string $musicurl
* @param string $hgmusicurl
*/
public function music($title, $desc, $musicurl, $hgmusicurl=\'\')
{
$textTpl = \'<xml>
<ToUserName><![CDATA[%s]]></ToUserName>
<FromUserName><![CDATA[%s]]></FromUserName>
<CreateTime>%s</CreateTime>
<MsgType><![CDATA[%s]]></MsgType>
<Music>
<Title><![CDATA[%s]]></Title>
<Description><![CDATA[%s]]></Description>
<MusicUrl><![CDATA[%s]]></MusicUrl>
<HQMusicUrl><![CDATA[%s]]></HQMusicUrl>
</Music>
</xml>\';
//<ThumbMediaId><![CDATA[%s]]></ThumbMediaId>
$this->_reply = sprintf($textTpl,
$this->getRevFrom(),
$this->getRevTo(),
Date::getTimeStamp(),
\'music\',
$title,
$desc,
$musicurl,
$hgmusicurl
);
return $this;
}
/**
* 回复图文消息
* @param array
*/
public function news($data)
{
$count = count($data);
$subText = \'\';
if($count > 0)
{
foreach($data as $v)
{
$tmpText = \'<item>
<Title><![CDATA[%s]]></Title>
<Description><![CDATA[%s]]></Description>
<PicUrl><![CDATA[%s]]></PicUrl>
<Url><![CDATA[%s]]></Url>
</item>\';
$subText .= sprintf(
$tmpText, $v[\'title\'],
isset($v[\'description\']) ? $v[\'description\'] : \'\',
isset($v[\'picUrl\']) ? $v[\'picUrl\'] : \'\',
isset($v[\'url\']) ? $v[\'url\'] : \'\'
);
}
}
$textTpl = \'<xml>
<ToUserName><![CDATA[%s]]></ToUserName>
<FromUserName><![CDATA[%s]]></FromUserName>
<CreateTime><![CDATA[%s]]></CreateTime>
<MsgType><![CDATA[news]]></MsgType>
<ArticleCount><![CDATA[%d]]></ArticleCount>
<Articles>%s</Articles>
</xml>\';
$this->_reply = sprintf(
$textTpl,
$this->getRevFrom(),
$this->getRevTo(),
Date::getTimeStamp(),
$count,
$subText
);
return $this;
}
/**
* 回复消息
* @param array $msg
* @param bool $return
*/
public function reply()
{
header(\'Content-Type:text/xml\');
echo $this->_reply;
exit;
}
/**
* 自定义菜单创建
* @param array 菜单数据
*/
public function createMenu($data)
{
if(!$this->access_token && !$this->checkAuth()) return false;
$result
=
curlRequest(self::API_URL_PREFIX.self::MENU_CREATE_URL.\'access_token=\'.$this->access_token,
$this->jsonEncode($data), \'post\');
if($result)
{
$jsonArr = json_decode($result, true);
if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
else return true;
}
return false;
}
/**
* 自定义菜单查询
*/
public function getMenu()
{
if(!$this->access_token && !$this->checkAuth()) return false;
$result = curlRequest(self::API_URL_PREFIX.self::MENU_GET_URL.\'access_token=\'.$this->access_token);
if($result)
{
$jsonArr = json_decode($result, true);
if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
else return $jsonArr;
}
return false;
}
/**
* 自定义菜单删除
*/
public function deleteMenu()
{
if(!$this->access_token && !$this->checkAuth()) return false;
$result = curlRequest(self::API_URL_PREFIX.self::MENU_DELETE_URL.\'access_token=\'.$this->access_token);
if($result)
{
$jsonArr = json_decode($result, true);
if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
else return true;
}
return false;
}
/**
* 获取用户基本信息
* @param string $openid 普通用户的标识，对当前公众号唯一
*/
public function getUserInfo($openid)
{
if(!$this->access_token && !$this->checkAuth()) return false;
$result = curlRequest(self::API_URL_PREFIX.self::USER_INFO_URL.\'access_token=\'.$this->access_token.\'&openid=\'.$openid);
if($result)
{
$jsonArr = json_decode($result, true);
if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
else return $jsonArr;
}
return false;
}
/**
* 获取关注者列表
* @param string $next_openid 第一个拉取的OPENID，不填默认从头开始拉取
*/
public function getUserList($next_openid=\'\')
{
if(!$this->access_token && !$this->checkAuth()) return false;
$result
=
curlRequest(self::API_URL_PREFIX.self::USER_GET_URL.\'access_token=\'.$this->access_token.\'&next_openid=\'.$next_openid);
if($result)
{
$jsonArr = json_decode($result, true);
if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
else return $jsonArr;
}
return false;
}
/**
* 查询分组
*/
public function getGroup()
{
if(!$this->access_token && !$this->checkAuth()) return false;
$result = curlRequest(self::API_URL_PREFIX.self::GROUPS_GET_URL.\'access_token=\'.$this->access_token);
if($result)
{
$jsonArr = json_decode($result, true);
if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
else return $jsonArr;
}
return false;
}
/**
* 创建分组
* @param string $name 分组名字（30个字符以内）
*/
public function createGroup($name)
{
if(!$this->access_token && !$this->checkAuth()) return false;
$data = array(\'group\' => array(\'name\' => $name));
$result
=
curlRequest(self::API_URL_PREFIX.self::GROUPS_CREATE_URL.\'access_token=\'.$this->access_token,
$this->jsonEncode($data), \'post\');
if($result)
{
$jsonArr = json_decode($result, true);
if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
else return true;
}
return false;
}
/**
* 修改分组名
* @param int $id 分组id，由微信分配
* @param string $name 分组名字（30个字符以内）
*/
public function updateGroup($id, $name)
{
if(!$this->access_token && !$this->checkAuth()) return false;
$data = array(\'group\' => array(\'id\' => $id, \'name\' => $name));
$result
=
curlRequest(self::API_URL_PREFIX.self::GROUPS_UPDATE_URL.\'access_token=\'.$this->access_token,
$this->jsonEncode($data), \'post\');
if($result)
{
$jsonArr = json_decode($result, true);
if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
else return true;
}
return false;
}
/**
* 移动用户分组
*
* @param string $openid 用户唯一标识符
* @param int $to_groupid 分组id
*/
public function updateGroupMembers($openid, $to_groupid)
{
if(!$this->access_token && !$this->checkAuth()) return false;
$data = array(\'openid\' => $openid, \'to_groupid\' => $to_groupid);
$result
=
curlRequest(self::API_URL_PREFIX.self::GROUPS_MEMBERS_UPDATE_URL.\'access_token=\'.$this->access_token,
$this->jsonEncode($data), \'post\');
if($result)
{
$jsonArr = json_decode($result, true);
if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
else return true;
}
return false;
}
/**
* 发送客服消息
* 当用户主动发消息给公众号的时候（包括发送信息、点击自定义菜单clike事件、订阅事件、扫描二维码事件、支付成功事件、用户维权），
* 微信将会把消息数据推送给开发者，开发者在一段时间内（目前为24小时）可以调用客服消息接口，通过POST一个JSON数据包来发送消息给普通用户，在24小时内不限制发送次数。
* 此接口主要用于客服等有人工消息处理环节的功能，方便开发者为用户提供更加优质的服务。
*
* @param string $touser 普通用户openid
*/
public function sendCustomMessage($touser, $data, $msgType = \'text\')
{
$arr = array();
$arr[\'touser\'] = $touser;
$arr[\'msgtype\'] = $msgType;
switch ($msgType)
{
case \'text\': // 发送文本消息
$arr[\'text\'][\'content\'] = $data;
break;
case \'image\': // 发送图片消息
$arr[\'image\'][\'media_id\'] = $data;
break;
case \'voice\': // 发送语音消息
$arr[\'voice\'][\'media_id\'] = $data;
break;
case \'video\': // 发送视频消息
$arr[\'video\'][\'media_id\'] = $data[\'media_id\']; // 发送的视频的媒体ID
$arr[\'video\'][\'thumb_media_id\'] = $data[\'thumb_media_id\']; // 视频缩略图的媒体ID
break;
case \'music\': // 发送音乐消息
$arr[\'music\'][\'title\'] = $data[\'title\'];// 音乐标题
$arr[\'music\'][\'description\'] = $data[\'description\'];// 音乐描述
$arr[\'music\'][\'musicurl\'] = $data[\'musicurl\'];// 音乐链接
$arr[\'music\'][\'hqmusicurl\'] = $data[\'hqmusicurl\'];// 高品质音乐链接，wifi环境优先使用该链接播放音乐
$arr[\'music\'][\'thumb_media_id\'] = $data[\'title\'];// 缩略图的媒体ID
break;
case \'news\': // 发送图文消息
$arr[\'news\'][\'articles\'] = $data; // title、description、url、picurl
break;
}
if(!$this->access_token && !$this->checkAuth()) return false;
$result
=
curlRequest(self::API_URL_PREFIX.self::MESSAGE_CUSTOM_SEND_URL.\'access_token=\'.$this->access_token,
$this->jsonEncode($arr), \'post\');
if($result)
{
$jsonArr = json_decode($result, true);
if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
else return true;
}
return false;
}
/**
* 获取access_token
*/
public function checkAuth()
{
// 从缓存中获取access_token
$cache_flag = \'weixin_access_token\';
$access_token = cache($cache_flag);
if($access_token)
{
$this->access_token = $access_token;
return true;
}
// 请求微信服务器获取access_token
$result = curlRequest(self::API_URL_PREFIX.self::AUTH_URL.\'appid=\'.$this->appid.\'&secret=\'.$this->appsecret);
if($result)
{
$jsonArr = json_decode($result, true);
if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0))
{
$this->error($jsonArr);
}
else
{
$this->access_token = $jsonArr[\'access_token\'];
$expire = isset($jsonArr[\'expires_in\']) ? intval($jsonArr[\'expires_in\'])-100 : 3600;
// 将access_token保存到缓存中
cache($cache_flag, $this->access_token, $expire, Cache::FILE);
return true;
}
}
return false;
}
/**
* 微信oauth登陆->第一步：用户同意授权，获取code
* 应用授权作用域，snsapi_base （不弹出授权页面，直接跳转，只能获取用户openid），
* snsapi_userinfo （弹出授权页面，可通过openid拿到昵称、性别、所在地。并且，即使在未关注的情况下，只要用户授权，也能获取其信息）
* 直接在微信打开链接，可以不填此参数。做页面302重定向时候，必须带此参数
*
* @param string $redirect_uri 授权后重定向的回调链接地址
* @param string $scope 应用授权作用域 0为snsapi_base，1为snsapi_userinfo
* @param string $state 重定向后会带上state参数，开发者可以填写任意参数值
*/
public function redirectGetOauthCode($redirect_uri, $scope=0, $state=\'\')
{
$scope = ($scope == 0) ? \'snsapi_base\' : \'snsapi_userinfo\';
$url
=
self::CONNECT_OAUTH_AUTHORIZE_URL.\'appid=\'.$this->appid.\'&redirect_uri=\'.urlencode($redirect_uri).\'&response_type=code&scope=\'.$scope.\'&state=\'.$state.\'#wechat_redirect\';
redirect($url);
}
/**
* 微信oauth登陆->第二步：通过code换取网页授权access_token
*
* @param string $code
*/
public function getSnsAccessToken($code)
{
$result
=
curlRequest(self::SNS_OAUTH_ACCESS_TOKEN_URL.\'appid=\'.$this->appid.\'&secret=\'.$this->appsecret.\'&code=\'.$code.\'&grant_type=authorization_code\');
if($result)
{
$jsonArr = json_decode($result, true);
if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
else return $jsonArr;
}
return false;
}
/**
* 微信oauth登陆->第三步：刷新access_token（如果需要）
* 由于access_token拥有较短的有效期，当access_token超时后，可以使用refresh_token进行刷新，
* refresh_token拥有较长的有效期（7天、30天、60天、90天），当refresh_token失效的后，需要用户重新授权。
*
* @param string $refresh_token 填写通过access_token获取到的refresh_token参数
*/
public function refershToken($refresh_token)
{
$result
=
curlRequest(self::SNS_OAUTH_REFRESH_TOKEN_URL.\'appid=\'.$this->appid.\'&grant_type=refresh_token&refresh_token=\'.$refresh_token);
if($result)
{
$jsonArr = json_decode($result, true);
if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
else return $jsonArr;
}
return false;
}
/**
* 微信oauth登陆->第四步：拉取用户信息(需scope为 snsapi_userinfo)
* 如果网页授权作用域为snsapi_userinfo，则此时开发者可以通过access_token和openid拉取用户信息了。
*
* @param string $access_token 网页授权接口调用凭证,注意：此access_token与基础支持的access_token不同
* @param string $openid 用户的唯一标识
*/
public function getSnsUserInfo($access_token, $openid)
{
$result = curlRequest(self::SNS_USERINFO_URL.\'access_token=\'.$access_token.\'&openid=\'.$openid);
if($result)
{
$jsonArr = json_decode($result, true);
if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
else return $jsonArr;
}
return false;
}
/**
* 创建二维码ticket
* 每次创建二维码ticket需要提供一个开发者自行设定的参数（scene_id），分别介绍临时二维码和永久二维码的创建二维码ticket过程。
*
* @param int $scene_id 场景值ID，临时二维码时为32位整型，永久二维码时最大值为1000
* @param int $type 二维码类型，0为临时,1为永久
* @param int $expire 该二维码有效时间，以秒为单位。 最大不超过1800。
*/
public function createQrcode($scene_id, $type=0, $expire=1800)
{
if(!$this->access_token && !$this->checkAuth()) return false;
$data = array();
$data[\'action_info\'] = array(\'scene\' => array(\'scene_id\' => $scene_id));
$data[\'action_name\'] = ($type == 0 ? \'QR_SCENE\' : \'QR_LIMIT_SCENE\');
if($type == 0) $data[\'expire_seconds\'] = $expire;
$result
=
curlRequest(self::API_URL_PREFIX.self::QRCODE_CREATE_URL.\'access_token=\'.$this->access_token,
$this->jsonEncode($data), \'post\');
if($result)
{
$jsonArr = json_decode($result, true);
if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
else return $jsonArr;
}
return false;
}
/**
* 通过ticket换取二维码
* 获取二维码ticket后，开发者可用ticket换取二维码图片。请注意，本接口无须登录态即可调用。
* 提醒：TICKET记得进行UrlEncode
* ticket正确情况下，http 返回码是200，是一张图片，可以直接展示或者下载。
* 错误情况下（如ticket非法）返回HTTP错误码404。
*
* @param string $ticket
*/
public function getQrcodeUrl($ticket)
{
return self::SHOW_QRCODE_URL.\'ticket=\'.urlencode($ticket);
}
/**
* 记录接口产生的错误日志
*/
public function error($data)
{
$this->errCode = $data[\'errcode\'];
$this->errMsg = $data[\'errmsg\'];
Log::info(\'WEIXIN API errcode:[\'.$this->errCode.\'] errmsg:[\'.$this->errMsg.\']\');
}
/**
* 将数组中的中文转换成json数据
* @param array $arr
*/
public function jsonEncode($arr) {
$parts = array ();
$is_list = false;
//Find out if the given array is a numerical array
$keys = array_keys ( $arr );
$max_length = count ( $arr ) - 1;
if (($keys [0] === 0) && ($keys [$max_length] === $max_length
)) { //See if the first key is 0 and last key is length - 1
$is_list = true;
for($i = 0; $i < count ( $keys ); $i ++) { //See if each key correspondes to its position
if ($i != $keys [$i]) { //A key fails at position check.
$is_list = false; //It is an associative array.
break;
}
}
}
foreach ( $arr as $key => $value ) {
if (is_array ( $value )) { //Custom handling for arrays
if ($is_list)
$parts [] = $this->jsonEncode ( $value ); /* :RECURSION: */
else
$parts [] = \'"\' . $key . \'":\' . $this->jsonEncode ( $value ); /* :RECURSION: */
} else {
$str = \'\';
if (! $is_list)
$str = \'"\' . $key . \'":\';
//Custom handling for multiple data types
if (is_numeric ( $value ) && $value<2000000000)
$str .= $value; //Numbers
elseif ($value === false)
$str .= \'false\'; //The booleans
elseif ($value === true)
$str .= \'true\';
else
$str .= \'"\' . addslashes ( $value ) . \'"\'; //All other things
// :TODO: Is there any more datatype we should be in the lookout for? (Object?)
$parts [] = $str;
}
}
$json = implode ( \',\', $parts );
if ($is_list)
return \'[\' . $json . \']\'; //Return numerical JSON
return \'{\' . $json . \'}\'; //Return associative JSON
}
/**
* 检验签名
*/
public function checkSignature()
{
$signature = HttpRequest::getGet(\'signature\');
$timestamp = HttpRequest::getGet(\'timestamp\');
$nonce = HttpRequest::getGet(\'nonce\');
$token = $this->token;
$tmpArr = array($token, $timestamp, $nonce);
sort($tmpArr);
$tmpStr = implode($tmpArr);
$tmpStr = sha1($tmpStr);
return ($tmpStr == $signature ? true : false);
}
/**
* 验证token是否有效
*/
public function valid()
{
if($this->checkSignature()) exit(HttpRequest::getGet(\'echostr\'));
}
function curlRequest($url){
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL,$url);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
$result = curl_exec($ch);
curl_close($ch);
return $result;
}
}