模型:WeChat (回复参考weiphp)
<?php
namespace Org;
/**
* 微信开发工具类
* Class WeChat
* Author chenqionghe
* @package Org
*/
class WeChat
{
const LOG_NAME = "PHP_LOG_%s.log.php"; //日志名
const LOG_DIR = "./Log/%s/"; //日志目录
static private $fromUser = \'\'; //当前消息的发送者
static private $toUser = \'\'; //当前消息的接收者
static private $member = \'\'; //公众号会员记录
/**
* 设置要操作的微信公众号
* @param $mid 公众号id
*/
static public function setMember($mid)
{
self::$member = M(\'Member\')->find($mid);
}
/**
* 处理来自微信服务器的消息
* @param $callback
* @access public
* @return void
*/
static public function process($callback)
{
//如果回调函数没有设置，则退出
if (!is_callable($callback))
{
return;
}
$postData = $GLOBALS[\'HTTP_RAW_POST_DATA\'];
if (empty($postData)) return; //如果没有POST数据，则退出
$object = simplexml_load_string($postData, \'SimpleXMLElement\', LIBXML_NOCDATA);//解析POST数据(XML格式)
$messgeType = trim($object->MsgType); //取得消息类型
self::$fromUser = $object->FromUserName; //记录消息发送方(不是发送者的微信号，而是一个加密后的OpenID)
self::$toUser = $object->ToUserName; //记录消息接收方(就是公共平台的OpenID)
self::addLog($postData,1,$messgeType); //记录日志
//根据不同的消息类型，分别处理
switch($messgeType)
{
case "text": //文本消息
//调用回调函数
call_user_func($callback, "Text", array(\'Content\'=>$object->Content));
break;
case "image": //图片消息
call_user_func($callback, "Image",array(\'PicUrl\'=>$object->PicUrl, \'MediaId\'=>$object->MediaId));
break;
case "voice": //音频消息
call_user_func($callback, "Voice",array(\'MediaId\'=>$object->MediaId, \'Format\'=>$object->Format,\'Recognition\'=>$object->Recognition) );
break;
case "video": //视频消息
call_user_func($callback, "Video", array(\'MediaId\'=>$object->MediaId, \'ThumbMediaId\'=>$object->ThumbMediaId));
break;
case "shortvideo": //小视频消息
call_user_func($callback, "Shortvideo", array(\'MediaId\'=>$object->MediaId, \'ThumbMediaId\'=>$object->ThumbMediaId));
break;
case "location": //定位信息
call_user_func($callback, "Location", array(\'Label\'=>$object->Label, \'Location_X\'=>$object->Location_X, \'Location_Y\'=>$object->Location_Y,\'Scale\'=>$object->Scale));
break;
case "link": //链接信息
call_user_func($callback, "Link", array(\'Url\'=>$object->Url, \'Title\'=>$object->Title, \'Description\'=>$object->Description));
break;
case "event": //事件
switch ($object->Event)
{
case "subscribe": //订阅事件
call_user_func($callback, "Subscribe",array( \'EventKey\'=>$object->EventKey, \'Ticket\'=>$object->Ticket));
break;
case "unsubscribe": //取消订阅事件
call_user_func($callback, "UnSubscribe", array(\'FromUserName\'=>$object->FromUserName));
break;
case "CLICK": //点击菜单拉取消息时的事件
call_user_func($callback, "Click", array(\'EventKey\'=>$object->EventKey));
break;
case "VIEW": //点击菜单跳转链接时的事件
call_user_func($callback, "View",array(\'EventKey\'=> $object->EventKey));
break;
case "scancode_push": //扫码推事件的事件推送
call_user_func($callback, "ScanPush",array( \'EventKey\'=>$object->EventKey,\'ScanCodeInfo\'=>$object->ScanCodeInfo,\'ScanType\'=>$object->ScanType,\'ScanResult\'=>$object->ScanResult));
break;
case "scancode_waitmsg": //扫码推事件且弹出“消息接收中”提示框的事件推送
call_user_func($callback, "ScanWaitmsg",array( \'EventKey\'=>$object->EventKey,\'ScanCodeInfo\'=>$object->ScanCodeInfo,\'ScanType\'=>$object->ScanType,\'ScanResult\'=>$object->ScanResult));
break;
case "pic_sysphoto": //弹出系统拍照发图的事件推送
call_user_func($callback, "PicSysPhoto",array( \'EventKey\'=>$object->EventKey, \'SendPicsInfo\'=>$object->SendPicsInfo,\'Count\'=>$object->Count,\'PicList\'=>$object->PicList,\'PicMd5Sum\'=>$object->PicMd5Sum));
break;
case "pic_photo_or_album": //弹出拍照或者相册发图的事件推送
call_user_func($callback, "PicPhotoOrAlbum",array( \'EventKey\'=>$object->EventKey, \'SendPicsInfo\'=>$object->SendPicsInfo,\'Count\'=>$object->Count,\'PicList\'=>$object->PicList,\'PicMd5Sum\'=>$object->PicMd5Sum));
break;
case "pic_weixin": //弹出微信相册发图器的事件推送
call_user_func($callback, "PicWeixin",array( \'EventKey\'=>$object->EventKey, \'SendPicsInfo\'=>$object->SendPicsInfo,\'Count\'=>$object->Count,\'PicList\'=>$object->PicList,\'PicMd5Sum\'=>$object->PicMd5Sum));
break;
case "location_select": //弹出地理位置选择器的事件推送
call_user_func($callback, "LocationSelect",array( \'EventKey\'=>$object->EventKey, \'SendLocationInfo\'=>$object->SendLocationInfo,\'Location_X\'=>$object->Location_X,\'Location_Y\'=>$object->Location_Y,\'Scale\'=>$object->Scale,\'Label\'=>$object->Label,\'Poiname\'=>$object->Poiname));
break;
case \'LOCATION\': //上报地址位置事件
call_user_func($callback, "UpLocation",array( \'Latitude\'=>$object->Latitude, \'Longitude\'=>$object->Longitude, \'Precision\'=>$object->Precision));
break;
default :
//Unknow Event
break;
}
break;
default:
//未知消息类型
break;
}
}
/**
* 获取access_token
* $mid 公众号id
* @access public
* @return mixed
*/
static public function getAcctoken ($mid=\'\')
{
if(empty($mid)) {
$mid = defined(\'MID\') ? MID : session(\'mid\'); //如果定义了常量MID说明是微信请求的 ,否则是本地
}
$token = S(\'access_token\'.$mid);
if ($token === false)
{
if(empty(self::$member)) {
self::$member = M(\'Member\')->find($mid);
}
$url = \'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=\'.self::$member[\'appid\'].\'&secret=\'.self::$member[\'secret\'];
$result = self::http_get($url);
$result = json_decode($result, true);
$token = $result[\'access_token\'];
S(\'access_token\'.$mid, $token, $result[\'expires_in\'] - 1000);
}
return $token;
}
/**
* 验证签名是否正确
* @access public
* @param $token
*/
static public function checkSignature($token)
{
$tmpArr = array($token,$_GET ["timestamp"],$_GET ["nonce"]);
sort($tmpArr, SORT_STRING );
$tmpStr = sha1(implode( $tmpArr));
if ($tmpStr == $_GET ["signature"])
{
ob_clean();
echo $_GET ["echostr"];
}
self::addLog($_GET,4,\'微信接入\');//记录日志
exit;
}
/*************************************************** 发送消息响应微信 begin ***************************************************/
/**
* 回复文本消息
* @param $content 文本内容
* @access public
* @return void
*/
static public function replyText($content)
{
$msg [\'Content\'] = $content;
self::_replyData ( $msg, \'text\' );
}
/**
* 回复图片消息
* @param $media_id MediaId
*/
static public function replyImage($media_id)
{
$msg [\'Image\'] [\'MediaId\'] = $media_id;
self::_replyData ( $msg, \'image\' );
}
/**
* 回复语音消息
* @param $media_id MediaId
* @access public
* @return void
*/
static public function replyVoice($media_id)
{
$msg [\'Voice\'] [\'MediaId\'] = $media_id;
$msg [\'Voice\'] [\'MediaId\'] = $media_id;
self::_replyData ( $msg, \'voice\' );
}
/**
* 回复视频消息
* @param $media_id MediaId
* @param string $title 标题
* @param string $description 简介
* @access public
* @return void
*/
static public function replyVideo($media_id, $title = \'\', $description = \'\')
{
$msg [\'Video\'] [\'MediaId\'] = $media_id;
$msg [\'Video\'] [\'Title\'] = $title;
$msg [\'Video\'] [\'Description\'] = $description;
self::_replyData ( $msg, \'video\' );
}
/**
* 回复音乐消息
* @param $media_id MediaId
* @param string $title 标题
* @param string $description 简介
* @param $music_url 音乐地址
* @param $HQ_music_url 高品质音乐地址
* @access public
* @return void
*/
static function replyMusic($media_id, $title = \'\', $description = \'\', $music_url, $HQ_music_url)
{
$msg [\'Music\'] [\'ThumbMediaId\'] = $media_id;
$msg [\'Music\'] [\'Title\'] = $title;
$msg [\'Music\'] [\'Description\'] = $description;
$msg [\'Music\'] [\'MusicURL\'] = $music_url;
$msg [\'Music\'] [\'HQMusicUrl\'] = $HQ_music_url;
self::_replyData ( $msg, \'music\' );
}
/**
* 回复图文消息 格式如下：
array(
array($Title, $Description, $PicUrl , $Url),
array($Title, $Description, $PicUrl , $Url),
);
* @param array $articles
* @access public
* @return void
*/
static public function replyNews($articles)
{
foreach($articles as $k=>$v)
{
$arr[] = array(\'Title\'=>$v[0],\'Description\'=>$v[1],\'PicUrl\'=>$v[2],\'Url\'=>$v[3]);
}
$msg [\'ArticleCount\'] = count ( $articles );
$msg [\'Articles\'] = $arr;
self::_replyData ( $msg, \'news\' );
}
/**
* 将消息转发给客服
* @param string $kf_account 指定客服的账号,不传则由微信分配
* @access public
* @return void
*/
static public function replyKefu($kf_account=\'\')
{
if(!empty($kf_account))
{
$msg [\'TransInfo\'][] = $kf_account;
}
self::_replyData($msg,\'transfer_customer_service\',\'KfAccount\');
}
/**
* 发送回复消息到微信平台
* @param array $msg 消息数组
* @param $msgType 消息类型
* @param string $item 包含子元素的元素名
* @access private
* @return void
*/
static private function _replyData($msg, $msgType, $item = \'item\')
{
$msg [\'ToUserName\'] = strval(self::$fromUser);
$msg [\'FromUserName\'] = strval(self::$toUser);
$msg [\'CreateTime\'] = NOW_TIME;
$msg [\'MsgType\'] = $msgType;
if($_REQUEST [\'doNotInit\'])
{
dump($msg);
exit;
}
$xml = new \SimpleXMLElement ( \'<xml></xml>\' );
self::_data2xml ( $xml, $msg ,$item);
$str = $xml->asXML ();
self::addLog($str,2,\'发送消息\');//记录日志
echo $str;
}
/**
* 组装xml数据
* @param $xml xml对象
* @param $data 要格式化的数组
* @param string $item 包含子元素的元素名
* @access public
* @return void
*/
static public function _data2xml($xml, $data, $item = \'item\')
{
foreach ( $data as $key => $value )
{
is_numeric ( $key ) && ($key = $item);
if (is_array ( $value ) || is_object ( $value ))
{
$child = $xml->addChild ( $key );
self::_data2xml ( $child, $value, $item );
} else
{
if (is_numeric ( $value ))
{
$child = $xml->addChild ( $key, $value );
} else {
$child = $xml->addChild ( $key );
$node = dom_import_simplexml ( $child );
$node->appendChild ( $node->ownerDocument->createCDATASection ( $value ) );
}
}
}
}
/*************************************************** 发送消息响应微信 end ***************************************************/
/*************************************************** 上传下载文件 begin ***************************************************/
/**
* 上传临时素材
* @param $file 要发送的文件
* @param string $type 文件类型
* @access public
* @return mixed
*/
static public function uploadFile($file, $type = \'image\')
{
// 媒体文件类型，分别有图片（image）、语音（voice）、视频（video）和缩略图（thumb）
$post_data = array(\'meida\'=>"@".$file,\'type\'=>$type);
$url = "http://file.api.weixin.qq.com/cgi-bin/media/upload?access_token=".self::getAcctoken() ."&type=".$type;
return self::http_post($url,$post_data);
}
/* 上传永久素材*/
static public function uploadYJFile($file, $type = \'image\')
{
// 媒体文件类型，分别有图片（image）、语音（voice）、视频（video）和缩略图（thumb）
$post_data = array(\'meida\'=>"@".$file,\'type\'=>$type);
$url = "https://api.weixin.qq.com/cgi-bin/material/add_material?access_token=".self::getAcctoken();
return self::http_post($url,$post_data);
}
/**
* 下载多媒体文件
* @param $media_id MediaId
* @access public
* @return void
*/
static public function downloadFile($media_id)
{
$url = \'\';
$filename = date(\'Y-m-d_H_i_s\',time()).\'.jpg\';//设置保存的文件名
$ch = curl_init ();
curl_setopt ( $ch, CURLOPT_URL, $url );
curl_setopt ( $ch, CURLOPT_RETURNTRANSFER, 1 );
curl_setopt ( $ch, CURLOPT_TIMEOUT, 60 );
$temp = curl_exec($ch);
if(@file_get_contents($filename,$temp) && !curl_errno($ch)) {
echo $filename;
}
else {
echo false;
} // TODO
}
/*************************************************** 上传下载文件 end ***************************************************/
/*************************************************** 执行http请求方法 begin ***************************************************/
/**
* 发送GET 请求
* @param string $url 地址
* @access public
* @return mixed
*/
static public 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 );
return intval ( $aStatus ["http_code"] ) == 200 ? $sContent : false;
}
/**
* 发送POST 请求
* @param string $url 地址
* @param array $param 参数
* @access public
* @return string content
*/
static public 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 );
}
curl_setopt ( $oCurl, CURLOPT_URL, $url );
curl_setopt ( $oCurl, CURLOPT_RETURNTRANSFER, 1 );
curl_setopt ( $oCurl, CURLOPT_POST, true );
curl_setopt ( $oCurl, CURLOPT_POSTFIELDS, $param );
$sContent = curl_exec ( $oCurl );
$aStatus = curl_getinfo ( $oCurl );
curl_close ( $oCurl );
return intval ( $aStatus ["http_code"] ) == 200 ? $sContent : false;
}
/*************************************************** 执行http请求方法 end ***************************************************/
/*************************************************** 记录日志 begin ***************************************************/
/**
* @param $data 要记录的内容
* @param int $type 日志类型(1:Receive,2:Send,3:Sql,4:Signature)
* @param string $comment 备注信息
* @return null
*/
static public function addLog($data,$type=1,$comment=\'\')
{
//日志存放文件夹名
$dirName = array(\'1\' => \'Receive\',\'2\' => \'Send\',\'3\' => \'Sql\',\'4\'=>\'Signature\');
//构造日志文件名
$logDir = sprintf(self::LOG_DIR, $dirName[$type]); //格式化文件夹
$logName = sprintf(self::LOG_NAME,date(\'ymd\')); //格式化文件名
if(!is_dir($logDir)) mkdir($logDir,0777,true); //如果文件夹不存在,创建
$logFile = $logDir.$logName; //日志最终文件名
//构造日志文件内容
$separator = str_repeat(\'*\',42);
$content[] = "/$separator <- Begin:".date(\'Y-m-d H:i:s\')." --> $separator/";
$content[] = trim(var_export($data,true),\'\\'\');
if(!empty($comment)) $content[] = \'备注: \'.$comment;
$content[] = "/$separator <------------ End ------------> $separator/";
$logContent = PHP_EOL.implode(PHP_EOL,$content);
//写入日志文件
$fp = fopen($logFile,"a+");
flock($fp, LOCK_EX) ;
fwrite($fp,$logContent);
flock($fp, LOCK_UN);
fclose($fp);
}
/*************************************************** 记录日志 end ***************************************************/
/*************************************************** oAuth网页授权获取用户信息 begin ***************************************************/
/**
* 网页授权获取用户信息
* @param $type 类型为openid或者userinfo
* @return mixed
*/
public static function oAuthGet($type)
{
if (!isset($_GET[\'code\']))
{
//获取code码，以获取openid
$scopeArr = array(\'openid\'=>\'snsapi_base\',\'userinfo\'=>\'snsapi_userinfo\');
$scope = $scopeArr[$type];
$redirect_url = urlencode(\'http://\'.$_SERVER[\'HTTP_HOST\'].$_SERVER[\'PHP_SELF\'].$_SERVER[\'QUERY_STRING\']);
$url = "https://open.weixin.qq.com/connect/oauth2/authorize?appid=".self::$member[\'appid\']."&redirect_uri=$redirect_url&response_type=code&scope=$scope&state=oAuthInfo#wechat_redirect";
header ( \'Location: \' . $url );
}
else
{
/******************* 1.回调页面得到code *******************/
$code = $_GET[\'code\'];
/******************* 2.用code去获取access_token和openid *******************/
$url = "https://api.weixin.qq.com/sns/oauth2/access_token?appid=".self::$member[\'appid\']."&secret=".self::$member[\'secret\']."&code=$code&grant_type=authorization_code";
$result = self::http_get($url);
$result = json_decode($result,true);
$openid = $result[\'openid\'];
if($result[\'scope\'] == \'snsapi_base\') //如果类型是snsapi_base,只返回openid
return $openid;
else
{
$access_token = $result[\'access_token\']; //access_token
/******************* 3.用获取到的openid和access_token获取获取用户详细信息 *******************/
$url = "https://api.weixin.qq.com/sns/userinfo?access_token=$access_token&openid=$openid&lang=zh_CN";
$result = self::http_get($url);
return json_decode($result,true);
}
}
}
/*************************************************** oAuth网页授权获取用户信息 end ***************************************************/
/*************************************************** 获取jssdk配置 begin ***************************************************/
/**
* 获取 JSSDK 配置
* @param bool $debug 是否开启调试模式
* @access public
* @return array
*/
public static function getJssdkConf($debug = false) {
$data = array(
\'noncestr\' => self::createNonceStr(),
\'jsapi_ticket\' => self::getJsApiTicket(),
\'timestamp\' => time(),
\'url\' => SERVER.__SELF__,
);
$str = \'jsapi_ticket=\'.$data[\'jsapi_ticket\'].\'&noncestr=\'.$data[\'noncestr\'].\'×tamp=\'.$data[\'timestamp\'].\'&url=\'.$data[\'url\'];
return array(
\'debug\' => $debug,
\'appId\' => self::$member[\'appid\'],
\'timestamp\' => $data[\'timestamp\'],
\'nonceStr\' => $data[\'noncestr\'],
\'signature\' => sha1($str),
);
}
private static function getJsApiTicket() {
$mid = self::$member[\'id\'];
$ticket = S(\'jsapi_ticket\'.$mid);
if ($ticket == false) {
$url = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?type=jsapi&access_token=".self::getAcctoken($mid);
$result =WeChat::http_get($url);
$result = json_decode($result, true);
$ticket = $result[\'ticket\'];
S(\'jsapi_ticket\'.$mid, $ticket, $result[\'expires_in\'] - 1000);
}
return $ticket;
}
private static function createNonceStr($length = 16) {
$chars = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";
$str = "";
for ($i = 0; $i < $length; $i++) {
$str .= substr($chars, mt_rand(0, strlen($chars) - 1), 1);
}
return $str;
}
/*************************************************** 获取jssdk配置 end ***************************************************/
}
回复微信控制器:WeChatController
<?php
namespace Manage\Controller;
use Think\Controller;
use \Org\WeChat;
class WeChatController extends Controller
{
/* 接收微信的消息 */
public function index()
{
$id = intval(I(\'get.id\'));
$info = M(\'Member\')->where("status=\'1\'")->find($id);
if (!is_array($info)) exit(\'请求无效!\');
if (!empty ($_GET [\'echostr\']) && !empty ($_GET ["signature"]) && !empty ($_GET ["nonce"])) {
WeChat::checkSignature($info[\'token\']); //微信接入验证
}
define(\'MID\', $id); //定义公众号常量MID
WeChat::process(array($this, \'reply\')); //处理消息
}
/* 回复微信消息 */
public function reply($messageType, $data)
{
$controller = \'Process\' . \'\\Controller\\\' . $messageType . \'Controller\';
$class = new \ReflectionClass($controller);
$method = $class->getMethod(\'run\');
$instance = $class->newInstance();
$method->invokeArgs($instance, array($data));
}
}
WeChat控制器,负责将请求分发给Process模块下对应控制器处理, 如Click类型由ClickController处理, Text类型由TextController处理,下面给出一个TextController控制器
<?php
namespace Process\Controller;
use \Org\WeChat;
class TextController extends ProcessController
{
/* 用户点击菜单 */
public function run($data)
{
WeChat::replyText("您输入的内容是:" .$data[\'Content\']);
}
}
}
oAuth网页授权获取用户信息示例TestController
<?php
namespace Test\Controller;
use Think\Controller;
use \Org\WeChat;
class TestController extends Controller
{
/* 获取用户openid */
public function get_openid()
{
WeChat::setMember(2);
$openid = WeChat::oAuthGet(\'openid\');
}
/* 获取用户信息 */
public function get_userInfo()
{
WeChat::setMember(2);
$userinfo = WeChat::oAuthGet(\'userinfo\');
var_dump($userinfo);
}
}