分享一个微信公众号开发封装类
温馨提示：
本文最后更新于 2017年08月09日，已超过 2,445 天没有更新。若文章内的图片失效（无法正常加载），请留言反馈或直接联系我。
<?php
/**
\* 微信公众平台PHP-SDK, 官方API部分
\* @author dodge <dodgepudding@gmail.com>
\*@link https://github.com/dodgepudding/wechat-php-sdk
\* @version 1.2
\* usage: \* $options = array( \* 'token'=>'tokenaccesskey', //填写你设定的key
\* 'appid'=>'wxdk1234567890', //填写高级调用功能的app id
\* 'appsecret'=>'xxxxxxxxxxxxxxxxxxx', //填写高级调用功能的密钥
\* 'partnerid'=>'88888888', //财付通商户身份标识
\* 'partnerkey'=>'', //财付通商户权限密钥Key
\* 'paysignkey'=>'' //商户签名密钥Key
\* ); \* $weObj = new Wechat($options); \* $weObj->valid(); \* $type = $weObj->getRev()->getRevType(); \* switch($type) { \* case Wechat::MSGTYPE_TEXT: \* $weObj->text("hello, I'm wechat")->reply(); \* exit; \* break; \* case Wechat::MSGTYPE_EVENT: \* .... \* break; \* case Wechat::MSGTYPE_IMAGE: \* ... \* break; \* default: \* $weObj->text("help info")->reply(); \* } \* \* //获取菜单操作:
\* $menu = $weObj->getMenu(); \* //设置菜单
\* $newmenu = array(
\* "button"=> \* array( \* array('type'=>'click','name'=>'最新消息','key'=>'MENU_KEY_NEWS'),
\* array('type'=>'view','name'=>'我要搜索','url'=>'http://www.baidu.com'),
\* )
\* ); \* $result = $weObj->createMenu($newmenu); */
class Wechat
{
const MSGTYPE_TEXT = 'text';
const MSGTYPE_IMAGE = 'image';
const MSGTYPE_LOCATION = 'location';
const MSGTYPE_LINK = 'link';
const MSGTYPE_EVENT = 'event';
const MSGTYPE_MUSIC = 'music';
const MSGTYPE_NEWS = 'news';
const MSGTYPE_VOICE = 'voice';
const MSGTYPE_VIDEO = 'video';
const API_URL_PREFIX = 'https://api.weixin.qq.com/cgi-bin';
const AUTH_URL = '/token?grant_type=client_credential&';
const MENU_CREATE_URL = '/menu/create?';
const MENU_GET_URL = '/menu/get?';
const MENU_DELETE_URL = '/menu/delete?';
const MEDIA_GET_URL = '/media/get?';
const QRCODE_CREATE_URL='/qrcode/create?';
const QR_SCENE = 0;
const QR_LIMIT_SCENE = 1;
const QRCODE_IMG_URL='https://mp.weixin.qq.com/cgi-bin/showqrcode?ticket=';
const SHORT_URL='/shorturl?';
const USER_GET_URL='/user/get?';
const USER_INFO_URL='/user/info?';
const USER_UPDATEREMARK_URL='/user/info/updateremark?';
const GROUP_GET_URL='/groups/get?';
const USER_GROUP_URL='/groups/getid?';
const GROUP_CREATE_URL='/groups/create?';
const GROUP_UPDATE_URL='/groups/update?';
const GROUP_MEMBER_UPDATE_URL='/groups/members/update?';
const CUSTOM_SEND_URL='/message/custom/send?';
const MEDIA_UPLOADNEWS_URL = '/media/uploadnews?';
const MASS_SEND_URL = '/message/mass/send?';
const TEMPLATE_SEND_URL = '/message/template/send?';
const MASS_SEND_GROUP_URL = '/message/mass/sendall?';
const MASS_DELETE_URL = '/message/mass/delete?';
const UPLOAD_MEDIA_URL = 'http://file.api.weixin.qq.com/cgi-bin';
const MEDIA_UPLOAD = '/media/upload?';
const OAUTH_PREFIX = 'https://open.weixin.qq.com/connect/oauth2';
const OAUTH_AUTHORIZE_URL = '/authorize?';
const OAUTH_TOKEN_PREFIX = 'https://api.weixin.qq.com/sns/oauth2';
const OAUTH_TOKEN_URL = '/access_token?';
const OAUTH_REFRESH_URL = '/refresh_token?';
const OAUTH_USERINFO_URL = 'https://api.weixin.qq.com/sns/userinfo?';
const OAUTH_AUTH_URL = 'https://api.weixin.qq.com/sns/auth?';
const PAY_DELIVERNOTIFY = 'https://api.weixin.qq.com/pay/delivernotify?';
const PAY_ORDERQUERY = 'https://api.weixin.qq.com/pay/orderquery?';
const CUSTOM_SERVICE_GET_RECORD = '/customservice/getrecord?';
const CUSTOM_SERVICE_GET_KFLIST = '/customservice/getkflist?';
const CUSTOM_SERVICE_GET_ONLINEKFLIST = '/customservice/getkflist?';
private $token;
private $appid;
private $appsecret;
private $access_token;
private $user_token;
private $partnerid;
private $partnerkey;
private $paysignkey;
private $_msg;
private $_funcflag = false;
private $_receive;
private $_text_filter = true;
public $debug = false;
public $errCode = 40001;
public $errMsg = "no access";
private $_logcallback;
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']:'';
$this->partnerid = isset($options['partnerid'])?$options['partnerid']:'';
$this->partnerkey = isset($options['partnerkey'])?$options['partnerkey']:'';
$this->paysignkey = isset($options['paysignkey'])?$options['paysignkey']:'';
$this->debug = isset($options['debug'])?$options['debug']:false;
$this->_logcallback = isset($options['logcallback'])?$options['logcallback']:false;
} /**
\* For weixin server validation */
private function checkSignature()
{ $signature = isset($_GET["signature"])?$_GET["signature"]:'';
$timestamp = isset($_GET["timestamp"])?$_GET["timestamp"]:'';
$nonce = isset($_GET["nonce"])?$_GET["nonce"]:'';
$token = $this->token;
$tmpArr = array($token, $timestamp, $nonce);
sort($tmpArr, SORT_STRING);
$tmpStr = implode( $tmpArr );
$tmpStr = sha1( $tmpStr );
if( $tmpStr == $signature ){
return true;
}else{
return false;
} } /**
\* For weixin server validation\* @param bool $return 是否返回
*/
public function valid($return=false)
{ $echoStr = isset($_GET["echostr"]) ? $_GET["echostr"]: '';
if ($return) {
if ($echoStr) {
if ($this->checkSignature())
return $echoStr;
else
return false;
} else
return $this->checkSignature();
} else {
if ($echoStr) {
if ($this->checkSignature())
die($echoStr);
else
die('no access');
}else {
if ($this->checkSignature())
return true;
else
die('no access');
} } return false;
} /**
\* 设置发送消息
\* @param array $msg 消息数组
\* @param bool $append 是否在原消息数组追加
*/
public function Message($msg = '',$append = false){
if (is_null($msg)) {
$this->_msg =array();
}elseif (is_array($msg)) {
if ($append)
$this->_msg = array_merge($this->_msg,$msg);
else
$this->_msg = $msg;
return $this->_msg;
} else {
return $this->_msg;
} } public function setFuncFlag($flag) {
$this->_funcflag = $flag;
return $this;
} private function log($log){
if ($this->debug && function_exists($this->_logcallback)) {
if (is_array($log)) $log = print_r($log,true);
return call_user_func($this->_logcallback,$log);
} } /**
\* 获取微信服务器发来的信息
*/
public function getRev()
{ if ($this->_receive) return $this;
$postStr = file_get_contents("php://input");
$this->log($postStr);
if (!empty($postStr)) {
$this->_receive = (array)simplexml_load_string($postStr, 'SimpleXMLElement', LIBXML_NOCDATA);
} return $this;
} /**
\* 获取微信服务器发来的信息
*/
public function getRevData()
{ return $this->_receive;
} /**
\* 获取消息发送者
*/
public function getRevFrom() {
if (isset($this->_receive['FromUserName']))
return $this->_receive['FromUserName'];
else
return false;
} /**
\* 获取消息接受者
*/
public function getRevTo() {
if (isset($this->_receive['ToUserName']))
return $this->_receive['ToUserName'];
else
return false;
} /**
\* 获取接收消息的类型
*/
public function getRevType() {
if (isset($this->_receive['MsgType']))
return $this->_receive['MsgType'];
else
return false;
} /**
\* 获取消息ID
*/ public function getRevID() {
if (isset($this->_receive['MsgId']))
return $this->_receive['MsgId'];
else
return false;
} /**
\* 获取消息发送时间
*/
public function getRevCtime() {
if (isset($this->_receive['CreateTime']))
return $this->_receive['CreateTime'];
else
return false;
} /**
\* 获取接收消息内容正文
*/
public function getRevContent(){
if (isset($this->_receive['Content']))
return $this->_receive['Content'];
else if (isset($this->_receive['Recognition'])) //获取语音识别文字内容，需申请开通
return $this->_receive['Recognition'];
else
return false;
} /**
\* 获取接收消息图片
*/
public function getRevPic(){
if (isset($this->_receive['PicUrl']))
return $this->_receive['PicUrl'];
else
return false;
} /**
\* 获取接收消息链接
*/
public function getRevLink(){
if (isset($this->_receive['Url'])){
return array(
'url'=>$this->_receive['Url'],
'title'=>$this->_receive['Title'],
'description'=>$this->_receive['Description']
); } else
return false;
} /**
\* 获取接收地理位置
*/
public function getRevGeo(){
if (isset($this->_receive['Location_X'])){
return array(
'x'=>$this->_receive['Location_X'],
'y'=>$this->_receive['Location_Y'],
'scale'=>$this->_receive['Scale'],
'label'=>$this->_receive['Label']
); } else
return false;
} /**
\* 获取上报地理位置事件
*/
public function getRevEventGeo(){
if (isset($this->_receive['Latitude'])){
return array(
'x'=>$this->_receive['Latitude'],
'y'=>$this->_receive['Longitude'],
'precision'=>$this->_receive['Precision'],
); } else
return false;
} /**
\* 获取接收事件推送
*/
public function getRevEvent(){
if (isset($this->_receive['Event'])){
$array['event'] = $this->_receive['Event'];
} if (isset($this->_receive['EventKey'])){
$array['key'] = $this->_receive['EventKey'];
} if (isset($array) && count($array) \> 0) {
return $array;
} else {
return false;
} }
/**
\* 获取接收语音推送
*/
public function getRevVoice(){
if (isset($this->_receive['MediaId'])){
return array(
'mediaid'=>$this->_receive['MediaId'],
'format'=>$this->_receive['Format'],
); } else
return false;
} /**
\* 获取接收视频推送
*/
public function getRevVideo(){
if (isset($this->_receive['MediaId'])){
return array(
'mediaid'=>$this->_receive['MediaId'],
'thumbmediaid'=>$this->_receive['ThumbMediaId']
); } else
return false;
} /**
\* 获取接收TICKET
*/ public function getRevTicket(){
if (isset($this->_receive['Ticket'])){
return $this->_receive['Ticket'];
} else
return false;
} /**
\* 获取二维码的场景值
*/
public function getRevSceneId (){
if (isset($this->_receive['EventKey'])){
return str_replace('qrscene_','',$this->_receive['EventKey']);
} else{
return false;
} } /**
\* 获取模板消息ID
\* 经过验证，这个和普通的消息MsgId不一样
*/
public function getRevTplMsgID(){
if (isset($this->_receive['MsgID'])){
return $this->_receive['MsgID'];
} else
return false;
} /**
\* 获取模板消息发送状态
*/
public function getRevStatus(){
if (isset($this->_receive['Status'])){
return $this->_receive['Status'];
} else
return false;
} public static function xmlSafeStr($str)
{return '<![CDATA['.preg_replace("/[\x00-\x08\x0b-\x0c\x0e-\x1f]/",'',$str).']]>';
}
/**
\* 数据XML编码
\* @param mixed $data 数据
\* @return string
*/ public static function data_to_xml($data) {
$xml = '';
foreach ($data as $key =\> $val) {
is_numeric($key) && $key = "item id=\"$key\"";
$xml .= "<$key>";
$xml .= ( is_array($val) || is_object($val)) ? self::data_to_xml($val) : self::xmlSafeStr($val);
list($key, ) = explode(' ', $key);
$xml .= "</$key>";
} return $xml;
} /**
\* XML编码
\* @param mixed $data 数据
\* @param string $root 根节点名
\* @param string $item 数字索引的子节点名
\* @param string $attr 根节点属性
\* @param string $id 数字索引子节点key转换的属性名
\* @param string $encoding 数据编码
\* @return string
*/ public function xml_encode($data, $root='xml', $item='item', $attr='', $id='id', $encoding='utf-8') {
if(is_array($attr)){
$_attr = array();
foreach ($attr as $key =\> $value) {
$_attr[] = "{$key}=\"{$value}\"";
} $attr = implode(' ', $_attr);
} $attr = trim($attr);
$attr = empty($attr) ? '' : " {$attr}";
$xml = "<{$root}{$attr}>";
$xml .= self::data_to_xml($data, $item, $id);
$xml .= "</{$root}>";
return $xml;
} /**
\* 过滤文字回复\r\n换行符
\* @param string $text
\* @return string|mixed
*/ private function _auto_text_filter($text) {
if (!$this->_text_filter) return $text;
return str_replace("\r\n", "\n", $text);
} /**
\* 设置回复消息
\* Examle: $obj->text('hello')->reply();
\* @param string $text
*/ public function text($text)
{ $FuncFlag = $this->_funcflag ? 1 : 0;
$msg = array(
'ToUserName' =\> $this->getRevFrom(),
'FromUserName'=>$this->getRevTo(),
'MsgType'=>self::MSGTYPE_TEXT,
'Content'=>$this->_auto_text_filter($text),
'CreateTime'=>time(),
'FuncFlag'=>$FuncFlag
);
$this->Message($msg);
return $this;
} /**
\* 设置回复音乐
\* @param string $title
\* @param string $desc
\* @param string $musicurl
\* @param string $hgmusicurl
*/ public function music($title,$desc,$musicurl,$hgmusicurl='') {
$FuncFlag = $this->_funcflag ? 1 : 0;
$msg = array(
'ToUserName' =\> $this->getRevFrom(),
'FromUserName'=>$this->getRevTo(),
'CreateTime'=>time(),
'MsgType'=>self::MSGTYPE_MUSIC,
'Music'=>array(
'Title'=>$title,
'Description'=>$desc,
'MusicUrl'=>$musicurl,
'HQMusicUrl'=>$hgmusicurl
),
'FuncFlag'=>$FuncFlag
);
$this->Message($msg);
return $this;
} /**
\* 设置回复图文
\* @param array $newsData
\* 数组结构:
\* array( \* "0"=>array( \* 'Title'=>'msg title', \* 'Description'=>'summary text', \* 'PicUrl'=>'http://www.domain.com/1.jpg',
\* 'Url'=>'http://www.domain.com/1.html'
\* ),
\* "1"=>.... \* ) */ public function news($newsData)
{ $FuncFlag = $this->_funcflag ? 1 : 0;
$count = count($newsData);
$msg = array(
'ToUserName' =\> $this->getRevFrom(),
'FromUserName'=>$this->getRevTo(),
'MsgType'=>self::MSGTYPE_NEWS,
'CreateTime'=>time(),
'ArticleCount'=>$count,
'Articles'=>$newsData,
'FuncFlag'=>$FuncFlag
);
$this->Message($msg);
return $this;
} /**
\*\* 回复微信服务器, 此函数支持链式操作
\* Example: $this->text('msg tips')->reply();
\* @param string $msg 要发送的信息, 默认取$this->_msg
\* @param bool $return 是否返回信息而不抛出到浏览器 默认:否
*/
public function reply($msg=array(),$return = false)
{ if (empty($msg))
$msg = $this->_msg;
$xmldata= $this->xml_encode($msg);
$this->log($xmldata);
if ($return)
return $xmldata;
else
echo $xmldata;
} /**
\* GET 请求
\* @param string $url
*/ private function http_get($url){
$oCurl = curl_init();
if(stripos($url,"https://")!==FALSE){
curl_setopt($oCurl, CURLOPT_SSL_VERIFYPEER, FALSE);
curl_setopt($oCurl, CURLOPT_SSL_VERIFYHOST, FALSE);
} curl_setopt($oCurl, CURLOPT_URL, $url);
curl_setopt($oCurl, CURLOPT_RETURNTRANSFER, 1 );
$sContent = curl_exec($oCurl);
$aStatus = curl_getinfo($oCurl);
curl_close($oCurl);
if(intval($aStatus["http_code"])==200){
return $sContent;
}else{
return false;
} } /**
\* POST 请求
\* @param string $url
\* @param array $param
\* @return string content
*/ private function http_post($url,$param){
$oCurl = curl_init();
if(stripos($url,"https://")!==FALSE){
curl_setopt($oCurl, CURLOPT_SSL_VERIFYPEER, FALSE);
curl_setopt($oCurl, CURLOPT_SSL_VERIFYHOST, false);
} if (is_string($param)) {
$strPOST = $param;
} else {
$aPOST = array();
foreach($param as $key=>$val){
$aPOST[] = $key."=".urlencode($val);
} $strPOST = join("&", $aPOST);
} curl_setopt($oCurl, CURLOPT_URL, $url);
curl_setopt($oCurl, CURLOPT_RETURNTRANSFER, 1 );
curl_setopt($oCurl, CURLOPT_POST,true);
curl_setopt($oCurl, CURLOPT_POSTFIELDS,$strPOST);
$sContent = curl_exec($oCurl);
$aStatus = curl_getinfo($oCurl);
curl_close($oCurl);
if(intval($aStatus["http_code"])==200){
return $sContent;
}else{
return false;
} } /**
\* 通用auth验证方法，暂时仅用于菜单更新操作
\* @param string $appid
\* @param string $appsecret
*/ public function checkAuth($appid='',$appsecret=''){
if (!$appid || !$appsecret) {
$appid = $this->appid;
$appsecret = $this->appsecret;
} //TODO: get the cache access_token
$result = $this->http_get(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'];
return false;
} $this->access_token = $json['access_token'];
$expire = $json['expires_in'] ? intval($json['expires_in'])-100 : 3600;
//TODO: cache access_token
return $this->access_token;
} return false;
}
/**
\* 删除验证数据
\* @param string $appid
*/ public function resetAuth($appid=''){
if (!$appid) $appid = $this->appid;
$this->access_token = '';
//TODO: remove cache
return true;
}
/**
\* 微信api不支持中文转义的json结构
\* @param array $arr
*/ static function json_encode($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 [] = self::json_encode ( $value ); /\* :RECURSION: */
else
$parts [] = '"' . $key . '":' . self::json_encode ( $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
}
/**
\* 创建菜单
\* @param array $data 菜单数组数据
\* example:
{ "button":[ { "type":"click",
"name":"今日歌曲",
"key":"MENU_KEY_MUSIC" }, { "type":"view", "name":"歌手简介",
"url":"http://www.qq.com/" }, { "name":"菜单",
"sub_button":[ { "type":"click", "name":"hello word", "key":"MENU_KEY_MENU" }, { "type":"click", "name":"赞一下我们",
"key":"MENU_KEY_GOOD" }] }] } */ public function createMenu($data){
if (!$this->access_token && !$this->checkAuth()) return false;
$result = $this->http_post(self::API_URL_PREFIX.self::MENU_CREATE_URL.'access_token='.$this->access_token,self::json_encode($data));
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return true;
} return false;
} /**
\* 获取菜单
\* @return array('menu'=>array(....s))
*/ public function getMenu(){
if (!$this->access_token && !$this->checkAuth()) return false;
$result = $this->http_get(self::API_URL_PREFIX.self::MENU_GET_URL.'access_token='.$this->access_token);
if ($result)
{ $json = json_decode($result,true);
if (!$json || isset($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
} /**
\* 删除菜单
\* @return boolean
*/ public function deleteMenu(){
if (!$this->access_token && !$this->checkAuth()) return false;
$result = $this->http_get(self::API_URL_PREFIX.self::MENU_DELETE_URL.'access_token='.$this->access_token);
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return true;
} return false;
}
/**
\* 上传多媒体文件
\* 注意：数组的键值任意，但文件名前必须加@，使用单引号以避免本地路径斜杠被转义
\* @param array $data {"media":'@Path\filename.jpg'}
\* @param type 类型：图片:image 语音:voice 视频:video 缩略图:thumb
\* @return boolean|array
*/ public function uploadMedia($data, $type){
if (!$this->access_token && !$this->checkAuth()) return false;
$result = $this->http_post(self::UPLOAD_MEDIA_URL.self::MEDIA_UPLOAD.'access_token='.$this->access_token.'&type='.$type,$data);
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
} /**
\* 根据媒体文件ID获取媒体文件
\* @param string $media_id 媒体文件id
\* @return raw data
*/ public function getMedia($media_id){
if (!$this->access_token && !$this->checkAuth()) return false;
$result = $this->http_get(self::UPLOAD_MEDIA_URL.self::MEDIA_GET_URL.'access_token='.$this->access_token.'&media_id='.$media_id);
if ($result)
{ $json = json_decode($result,true);
if (isset($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
}
/**
\* 上传图文消息素材
\* @param array $data 消息结构{"articles":[{...}]}
\* @return boolean|array
*/ public function uploadArticles($data){
if (!$this->access_token && !$this->checkAuth()) return false;
$result = $this->http_post(self::API_URL_PREFIX.self::MEDIA_UPLOADNEWS_URL.'access_token='.$this->access_token,self::json_encode($data));
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
} /**
\* 高级群发消息, 根据OpenID列表群发图文消息
\* @param array $data 消息结构{ "touser":[ "OPENID1", "OPENID2" ], "mpnews":{ "media_id":"123dsdajkasd231jhksad" }, "msgtype":"mpnews" }
\* @return boolean|array
*/ public function sendMassMessage($data){
if (!$this->access_token && !$this->checkAuth()) return false;
$result = $this->http_post(self::API_URL_PREFIX.self::MASS_SEND_URL.'access_token='.$this->access_token,self::json_encode($data));
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
} /**
\* 高级群发消息, 根据群组id群发图文消息
\* @param array $data 消息结构{ "filter":[ "group_id": "2" ], "mpnews":{ "media_id":"123dsdajkasd231jhksad" }, "msgtype":"mpnews" }
\* @return boolean|array
*/ public function sendGroupMassMessage($data){
if (!$this->access_token && !$this->checkAuth()) return false;
$result = $this->http_post(self::API_URL_PREFIX.self::MASS_SEND_GROUP_URL.'access_token='.$this->access_token,self::json_encode($data));
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
} /**
\* 高级群发消息, 删除群发图文消息
\* @param int $msg_id 消息id
\* @return boolean|array
*/ public function deleteMassMessage($msg_id){
if (!$this->access_token && !$this->checkAuth()) return false;
$result = $this->http_post(self::API_URL_PREFIX.self::MASS_DELETE_URL.'access_token='.$this->access_token,self::json_encode(array('msg_id'=>$msg_id)));
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return true;
} return false;
} /**
\* 创建二维码ticket
\* @param int $scene_id 自定义追踪id
\* @param int $type 0:临时二维码；1:永久二维码(此时expire参数无效)
\* @param int $expire 临时二维码有效期，最大为1800秒
\* @return array('ticket'=>'qrcode字串','expire_seconds'=>1800,'url'=>'二维码图片解析后的地址')
*/ public function getQRCode($scene_id,$type=0,$expire=1800){
if (!$this->access_token && !$this->checkAuth()) return false;
$data = array(
'action_name'=>$type?"QR_LIMIT_SCENE":"QR_SCENE",
'expire_seconds'=>$expire,
'action_info'=>array('scene'=>array('scene_id'=>$scene_id))
); if ($type == 1) {
unset($data['expire_seconds']);
} $result = $this->http_post(self::API_URL_PREFIX.self::QRCODE_CREATE_URL.'access_token='.$this->access_token,self::json_encode($data));
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
} /**
\* 获取二维码图片
\* @param string $ticket 传入由getQRCode方法生成的ticket参数
\* @return string url 返回http地址
*/
public function getQRUrl($ticket) {
return self::QRCODE_IMG_URL.$ticket;
} /**
\* 长链接转短链接接口
\* @param string $long_url 传入要转换的长url
\* @return boolean|string url 成功则返回转换后的短url
*/ public function getShortUrl($long_url){
if (!$this->access_token && !$this->checkAuth()) return false;
$data = array(
'action'=>'long2short',
'long_url'=>$long_url
);
$result = $this->http_post(self::API_URL_PREFIX.self::SHORT_URL.'access_token='.$this->access_token,self::json_encode($data));
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json['short_url'];
} return false;
}
/**
\* 批量获取关注用户列表
\* @param unknown $next_openid
*/ public function getUserList($next_openid=''){
if (!$this->access_token && !$this->checkAuth()) return false;
$result = $this->http_get(self::API_URL_PREFIX.self::USER_GET_URL.'access_token='.$this->access_token.'&next_openid='.$next_openid);
if ($result)
{ $json = json_decode($result,true);
if (isset($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
} /**
\* 获取关注者详细信息
\* @param string $openid
\* @return array
*/ public function getUserInfo($openid){
if (!$this->access_token && !$this->checkAuth()) return false;
$result = $this->http_get(self::API_URL_PREFIX.self::USER_INFO_URL.'access_token='.$this->access_token.'&openid='.$openid);
if ($result)
{ $json = json_decode($result,true);
if (isset($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
}
/**
\* 设置用户备注名
\* @param string $openid
\* @param string $remark 备注名
\* @return boolean|array
*/ public function updateUserRemark($openid,$remark){
if (!$this->access_token && !$this->checkAuth()) return false;
$data = array(
'openid'=>$openid,
'remark'=>$remark
);
$result = $this->http_post(self::API_URL_PREFIX.self::USER_UPDATEREMARK_URL.'access_token='.$this->access_token,$data);
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
} /**
\* 获取用户分组列表
\* @return boolean|array
*/ public function getGroup(){
if (!$this->access_token && !$this->checkAuth()) return false;
$result = $this->http_get(self::API_URL_PREFIX.self::GROUP_GET_URL.'access_token='.$this->access_token);
if ($result)
{ $json = json_decode($result,true);
if (isset($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
} /**
\* 获取用户所在分组
\* @param string $openid
\* @return boolean|int 成功则返回用户分组id
*/ public function getUserGroup($openid){
if (!$this->access_token && !$this->checkAuth()) return false;
$data = array(
'openid'=>$openid
);
$result = $this->http_post(self::API_URL_PREFIX.self::USER_GROUP_URL.'access_token='.$this->access_token,self::json_encode($data));
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} else
if (isset($json['groupid'])) return $json['groupid'];
} return false;
} /**
\* 新增自定分组
\* @param string $name 分组名称
\* @return boolean|array
*/ public function createGroup($name){
if (!$this->access_token && !$this->checkAuth()) return false;
$data = array(
'group'=>array('name'=>$name)
); $result = $this->http_post(self::API_URL_PREFIX.self::GROUP_CREATE_URL.'access_token='.$this->access_token,self::json_encode($data));
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
} /**
\* 更改分组名称
\* @param int $groupid 分组id
\* @param string $name 分组名称
\* @return boolean|array
*/ public function updateGroup($groupid,$name){
if (!$this->access_token && !$this->checkAuth()) return false;
$data = array(
'group'=>array('id'=>$groupid,'name'=>$name)
); $result = $this->http_post(self::API_URL_PREFIX.self::GROUP_UPDATE_URL.'access_token='.$this->access_token,self::json_encode($data));
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
} /**
\* 移动用户分组
\* @param int $groupid 分组id
\* @param string $openid 用户openid
\* @return boolean|array
*/ public function updateGroupMembers($groupid,$openid){
if (!$this->access_token && !$this->checkAuth()) return false;
$data = array(
'openid'=>$openid,
'to_groupid'=>$groupid
);
$result = $this->http_post(self::API_URL_PREFIX.self::GROUP_MEMBER_UPDATE_URL.'access_token='.$this->access_token,self::json_encode($data));
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
} /**
\* 发送客服消息
\* @param array $data 消息结构{"touser":"OPENID","msgtype":"news","news":{...}}
\* @return boolean|array
*/ public function sendCustomMessage($data){
if (!$this->access_token && !$this->checkAuth()) return false;
$result = $this->http_post(self::API_URL_PREFIX.self::CUSTOM_SEND_URL.'access_token='.$this->access_token,self::json_encode($data));
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
} /**
\* oauth 授权跳转接口
\* @param string $callback 回调URI
\* @return string
*/ public function getOauthRedirect($callback,$state='',$scope='snsapi_userinfo'){
return self::OAUTH_PREFIX.self::OAUTH_AUTHORIZE_URL.'appid='.$this->appid.'&redirect_uri='.urlencode($callback).'&response_type=code&scope='.$scope.'&state='.$state.'#wechat_redirect';
} /**
\* 通过code获取Access Token
\* @return array {access_token,expires_in,refresh_token,openid,scope}
*/ public function getOauthAccessToken(){
$code = isset($_GET['code'])?$_GET['code']:'';
if (!$code) return false;
$result = $this->http_get(self::OAUTH_TOKEN_PREFIX.self::OAUTH_TOKEN_URL.'appid='.$this->appid.'&secret='.$this->appsecret.'&code='.$code.'&grant_type=authorization_code');
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} $this->user_token = $json['access_token'];
return $json;
} return false;
} /**
\* 刷新access token并续期
\* @param string $refresh_token
\* @return boolean|mixed
*/ public function getOauthRefreshToken($refresh_token){
$result = $this->http_get(self::OAUTH_TOKEN_PREFIX.self::OAUTH_REFRESH_URL.'appid='.$this->appid.'&grant_type=refresh_token&refresh_token='.$refresh_token);
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} $this->user_token = $json['access_token'];
return $json;
} return false;
} /**
\* 获取授权后的用户资料
\* @param string $access_token
\* @param string $openid
\* @return array {openid,nickname,sex,province,city,country,headimgurl,privilege}
*/ public function getOauthUserinfo($access_token,$openid){
$result = $this->http_get(self::OAUTH_USERINFO_URL.'access_token='.$access_token.'&openid='.$openid);
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
}
/**
\* 检验授权凭证是否有效
\* @param string $access_token
\* @param string $openid
\* @return boolean 是否有效
*/
public function getOauthAuth($access_token,$openid){
$result = $this->http_get(self::OAUTH_AUTH_URL.'access_token='.$access_token.'&openid='.$openid);
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} else
if ($json['errcode']==0) return true;
} return false;
} /**
\* 获取签名
\* @param array $arrdata 签名数组
\* @param string $method 签名方法
\* @return boolean|string 签名值
*/
public function getSignature($arrdata,$method="sha1") {
if (!function_exists($method)) return false;
ksort($arrdata);
$paramstring = "";
foreach($arrdata as $key =\> $value)
{ if(strlen($paramstring) == 0)
$paramstring .= $key . "=" . $value;
else
$paramstring .= "&" . $key . "=" . $value;
} $paySign = $method($paramstring);
return $paySign;
} /**
\* 生成随机字串
\* @param number $length 长度，默认为16，最长为32字节
\* @return string
*/ public function generateNonceStr($length=16){
// 密码字符集，可任意添加你需要的字符
$chars = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";
$str = "";
for($i = 0; $i < $length; $i++)
{ $str .= $chars[mt_rand(0, strlen($chars) \- 1)];
} return $str;
} /**
\* 生成订单package字符串
\* @param string $out_trade_no 必填，商户系统内部的订单号,32个字符内,确保在商户系统唯一
\* @param string $body 必填，商品描述,128 字节以下
\* @param int $total_fee 必填，订单总金额,单位为分
\* @param string $notify_url 必填，支付完成通知回调接口，255 字节以内
\* @param string $spbill_create_ip 必填，用户终端IP，IPV4字串，15字节内
\* @param int $fee_type 必填，现金支付币种，默认1:人民币
\* @param string $bank_type 必填，银行通道类型,默认WX
\* @param string $input_charset 必填，传入参数字符编码，默认UTF-8，取值有UTF-8和GBK
\* @param string $time_start 交易起始时间,订单生成时间,格式yyyyMMddHHmmss
\* @param string $time_expire 交易结束时间,也是订单失效时间
\* @param int $transport_fee 物流费用,单位为分
\* @param int $product_fee 商品费用,单位为分,必须保证 transport_fee + product_fee=total_fee
\* @param string $goods_tag 商品标记,优惠券时可能用到
\* @param string $attach 附加数据，notify接口原样返回
\* @return string
*/ public function createPackage($out_trade_no,$body,$total_fee,$notify_url,$spbill_create_ip,$fee_type=1,$bank_type="WX",$input_charset="UTF-8",$time_start="",$time_expire="",$transport_fee="",$product_fee="",$goods_tag="",$attach=""){
$arrdata = array("bank_type" =\> $bank_type, "body" =\> $body, "partner" =\> $this->partnerid, "out_trade_no" =\> $out_trade_no, "total_fee" =\> $total_fee, "fee_type" =\> $fee_type, "notify_url" =\> $notify_url, "spbill_create_ip" =\> $spbill_create_ip, "input_charset" =\> $input_charset);
if ($time_start) $arrdata['time_start'] = $time_start;
if ($time_expire) $arrdata['time_expire'] = $time_expire;
if ($transport_fee) $arrdata['transport_fee'] = $transport_fee;
if ($product_fee) $arrdata['product_fee'] = $product_fee;
if ($goods_tag) $arrdata['goods_tag'] = $goods_tag;
if ($attach) $arrdata['attach'] = $attach;
ksort($arrdata);
$paramstring = "";
foreach($arrdata as $key =\> $value)
{ if(strlen($paramstring) == 0)
$paramstring .= $key . "=" . $value;
else
$paramstring .= "&" . $key . "=" . $value;
} $stringSignTemp = $paramstring . "&key=" . $this->partnerkey;
$signValue = strtoupper(md5($stringSignTemp));
$package = http_build_query($arrdata) . "&sign=" . $signValue;
return $package;
} /**
\* 支付签名(paySign)生成方法
\* @param string $package 订单详情字串
\* @param string $timeStamp 当前时间戳（需与JS输出的一致）
\* @param string $nonceStr 随机串（需与JS输出的一致）
\* @return string 返回签名字串
*/
public function getPaySign($package, $timeStamp, $nonceStr){
$arrdata = array("appid" =\> $this->appid, "timestamp" =\> $timeStamp, "noncestr" =\> $nonceStr, "package" =\> $package, "appkey" =\> $this->paysignkey);
$paySign = $this->getSignature($arrdata);
return $paySign;
} /**
\* 回调通知签名验证
\* @param array $orderxml 返回的orderXml的数组表示，留空则自动从post数据获取
\* @return boolean
*/ public function checkOrderSignature($orderxml=''){
if (!$orderxml) {
$postStr = file_get_contents("php://input");
if (!empty($postStr)) {
$orderxml = (array)simplexml_load_string($postStr, 'SimpleXMLElement', LIBXML_NOCDATA);
} else return false;
} $arrdata = array('appid'=>$orderxml['AppId'],'appkey'=>$this->paysignkey,'timestamp'=>$orderxml['TimeStamp'],'noncestr'=>$orderxml['NonceStr'],'openid'=>$orderxml['OpenId'],'issubscribe'=>$orderxml['IsSubscribe']);
$paySign = $this->getSignature($arrdata);
if ($paySign!=$orderxml['AppSignature']) return false;
return true;
} /**
\* 发货通知
\* @param string $openid 用户open_id
\* @param string $transid 交易单号
\* @param string $out_trade_no 第三方订单号
\* @param int $status 0:发货失败；1:已发货
\* @param string $msg 失败原因
\* @return boolean|array
*/ public function sendPayDeliverNotify($openid,$transid,$out_trade_no,$status=1,$msg='ok'){
if (!$this->access_token && !$this->checkAuth()) return false;
$postdata = array(
"appid"=>$this->appid,
"appkey"=>$this->paysignkey,
"openid"=>$openid,
"transid"=>strval($transid),
"out_trade_no"=>strval($out_trade_no),
"deliver_timestamp"=>strval(time()),
"deliver_status"=>strval($status),
"deliver_msg"=>$msg,
); $postdata['app_signature'] = $this->getSignature($postdata);
$postdata['sign_method'] = 'sha1';
unset($postdata['appkey']);
$result = $this->http_post(self::PAY_DELIVERNOTIFY.'access_token='.$this->access_token,self::json_encode($postdata));
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
} /**
\* 查询订单信息
\* @param string $out_trade_no 订单号
\* @return boolean|array
*/ public function getPayOrder($out_trade_no) {
if (!$this->access_token && !$this->checkAuth()) return false;
$sign = strtoupper(md5("out_trade_no=$out_trade_no&partner={$this->partnerid}&key={$this->partnerkey}"));
$postdata = array(
"appid"=>$this->appid,
"appkey"=>$this->paysignkey,
"package"=>"out_trade_no=$out_trade_no&partner={$this->partnerid}&sign=$sign",
"timestamp"=>strval(time()),
); $postdata['app_signature'] = $this->getSignature($postdata);
$postdata['sign_method'] = 'sha1';
unset($postdata['appkey']);
$result = $this->http_post(self::PAY_ORDERQUERY.'access_token='.$this->access_token,self::json_encode($postdata));
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'].json_encode($postdata);
return false;
} return $json["order_info"];
} return false;
} /**
\* 获取收货地址JS的签名
\* @tutorial 参考weixin.js脚本的WeixinJS.editAddress方法调用
\* @param string $appId
\* @param string $url
\* @param int $timeStamp
\* @param string $nonceStr
\* @param string $user_token
\* @return Ambigous <boolean, string>
*/ public function getAddrSign($url, $timeStamp, $nonceStr, $user_token=''){
if (!$user_token) $user_token = $this->user_token;
if (!$user_token) {
$this->errMsg = 'no user access token found!';
return false;
} $url = htmlspecialchars_decode($url);
$arrdata = array(
'appid'=>$this->appid,
'url'=>$url,
'timestamp'=>strval($timeStamp),
'noncestr'=>$nonceStr,
'accesstoken'=>$user_token
);
return $this->getSignature($arrdata);
} /**
\* 发送模板消息
\* @param array $data 消息结构
\* ｛
"touser":"OPENID",
"template_id":"ngqIpbwh8bUfcSsECmogfXcV14J0tQlEpBO27izEYtY", "url":"http://weixin.qq.com/download", "topcolor":"#FF0000", "data":{ "参数名1": {
"value":"参数",
"color":"#173177" //参数颜色
},
"Date":{ "value":"06月07日 19时24分",
"color":"#173177" }, "CardNumber":{ "value":"0426", "color":"#173177" }, "Type":{ "value":"消费",
"color":"#173177" } } } \* @return boolean|array
*/ public function sendTemplateMessage($data){
if (!$this->access_token && !$this->checkAuth()) return false;
$result = $this->http_post(self::API_URL_PREFIX.self::TEMPLATE_SEND_URL.'access_token='.$this->access_token,self::json_encode($data));
if($result){
$json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
} /**
\* 获取多客服会话记录
\* @param array $data 数据结构{"starttime":123456789,"endtime":987654321,"openid":"OPENID","pagesize":10,"pageindex":1,}
\* @return boolean|array
*/ public function getCustomServiceMessage($data){
if (!$this->access_token && !$this->checkAuth()) return false;
$result = $this->http_post(self::API_URL_PREFIX.self::CUSTOM_SERVICE_GET_RECORD.'access_token='.$this->access_token,self::json_encode($data));
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
}
/**
\* 转发多客服消息
\* Examle: $obj->transfer_customer_service($customer_account)->reply();
\* @param string $customer_account 转发到指定客服帐号：test1@test
*/
public function transfer_customer_service($customer_account = '')
{ $msg = array(
'ToUserName' =\> $this->getRevFrom(),
'FromUserName'=>$this->getRevTo(),
'CreateTime'=>time(),
'MsgType'=>'transfer_customer_service',
); if (!$customer_account) {
$msg['TransInfo'] = array('KfAccount'=>$customer_account);
} $this->Message($msg);
return $this;
} /**
\* 获取多客服客服基本信息
\*
\* @return boolean|array
*/ public function getCustomServiceKFlist(){
if (!$this->access_token && !$this->checkAuth()) return false;
$result = $this->http_get(self::API_URL_PREFIX.self::CUSTOM_SERVICE_GET_KFLIST.'access_token='.$this->access_token);
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
} /**
\* 获取多客服在线客服接待信息
\*
\* @return boolean|array {
"kf_online_list": [ { "kf_account": "test1@test", //客服账号@微信别名
"status": 1, //客服在线状态 1：pc在线，2：手机在线,若pc和手机同时在线则为 1+2=3 "kf_id": "1001", //客服工号
"auto_accept": 0, //客服设置的最大自动接入数
"accepted_case": 1 //客服当前正在接待的会话数
}
] } */ public function getCustomServiceOnlineKFlist(){
if (!$this->access_token && !$this->checkAuth()) return false;
$result = $this->http_get(self::API_URL_PREFIX.self::CUSTOM_SERVICE_GET_ONLINEKFLIST.'access_token='.$this->access_token);
if ($result)
{ $json = json_decode($result,true);
if (!$json || !empty($json['errcode'])) {
$this->errCode = $json['errcode'];
$this->errMsg = $json['errmsg'];
return false;
} return $json;
} return false;
}}
正文到此结束
热门推荐
相关文章
近期评论
-
来自： 留言板
-
来自： 留言板
-
来自： 留言板
-
来自： 程序设计原则之SOLID原则
-
来自： 程序设计原则之SOLID原则
