登录
当前位置： 首页 > 工具软件 > CI_WeChat-PHP-SDK > 使用案例 >

com wechat.class.php,wechat-php-sdk/wechat.class.php at master · l953422179/wechat-php-sdk · GitHub...

沈巴英
2023-12-01

/**

*微信公众平台PHP-SDK, 官方API部分

* @author dodge

* @link https://github.com/dodgepudding/wechat-php-sdk

* @version 1.1

* usage:

* $options = array(

*'token'=>'tokenaccesskey' //填写你设定的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?';

private $token;

private $appid;

private $appsecret;

private $access_token;

private $_msg;

private $_funcflag = false;

private $_receive;

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->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);

$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()

{

$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 ($this->_receive)

return $this->_receive['FromUserName'];

else

return false;

}

/**

* 获取消息接受者

*/

public function getRevTo() {

if ($this->_receive)

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 getRevEvent(){

if (isset($this->_receive['Event'])){

return array(

'event'=>$this->_receive['Event'],

'key'=>$this->_receive['EventKey'],

);

} 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;

}

public static function xmlSafeStr($str)

{

return '';

}

/**

* 数据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 .= "";

$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 = "";

$xml .= self::data_to_xml($data, $item, $id);

$xml .= "{$root}>";

return $xml;

}

/**

* 设置回复消息

* 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'=>$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=array())

{

$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=''){

$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 || $json['errcode']>0) {

$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 || $json['errcode']>0) {

$this->errCode = $json['errcode'];

$this->errMsg = $json['errmsg'];

return false;

}

return true;

}

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::API_URL_PREFIX.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 $result;

}

return false;

}

}

 类似资料：

相关阅读

PHP getTimestampLevenshtein：MySQL + PHPPHP中“=>PHP $ http_response_headerPHP session_start（）

相关文章

PHP XMLPHP StringPHP SimpleXMLPHP PDOPHP MySQLi

相关问答

如何为PHP Amazon Pay SDK完成TechEckoutSession？使用PHP SDK for Amazon S3时出错Firestore PHP SDK使用Auth规则设置使用AWS SDK PHP（SMTP/IAM）的SES凭据在camunda上使用PHP SDK服务任务

相关文档

Xunsearch PHP-SDK v1.4.8 权威指南PHP 进阶教程PHP 设计模式PHP 编程之道PHP 安全基础
快捷导航： 新手教程 算法原理 架构设计 Java进阶 数据库进阶 大厂专栏 面试经验 编程笔记 编程问答 所有专题 文档资料 工具软件 电子书籍 小牛导航
在线工具： 房贷计算器 个税计算器 Linux命令查询 Json格式化 正则表达式 颜色转换 AES加解密 SHA1加密 MD5加密 毒鸡汤 字数统计 随机密码生成 进制转换 Base64编解码 励志句子
Copyright © 2019-2024 小牛知识库@xnip.cn. All Rights Reserved.