discuz微信登录插件singcere_wechat.rar

<?php /** * [Discuz!] (C)2001-2099 Comsenz Inc. * This is NOT a freeware, use is subject to license terms * * $Id: wechat.lib.class.php 34815 2014-08-07 02:04:50Z nemohou $ */ if (!defined('IN_DISCUZ')) { exit('Access Denied'); } class WeChatServer { private $_token; /** * $hooks 格式说明 * array( * '钩子' => array('plugin' => '插件标识', 'include' => '引用的文件', 'class' => '类', 'method' => '方法'), * ） * ****** 钩子列表 ****** * receiveAllStart * receiveMsg::text * receiveMsg::location * receiveMsg::image * receiveMsg::video * receiveMsg::link * receiveMsg::voice * receiveEvent::subscribe * receiveEvent::unsubscribe * receiveEvent::scan * receiveEvent::location * receiveEvent::click * receiveAllEnd * accessCheckSuccess * 404 * * example: * array( * 'receiveMsg::text' => array('plugin' => 'wechat', 'include' => 'source/plugin/wechat/response.class.php', 'class' => 'WeChatResponse', 'method' => 'text'), * ) */ private $_hooks; private $_resclass; public function __construct($token, $hooks = array()) { $this->_token = $token; $this->_hooks = $hooks; $this->accessDataPush(); } // receiveMsg::text private function _activeHook($type) { if( !isset( $this->_hooks[$type] )) { return null; } $hook = & $this->_hooks[$type]; $argvs = func_get_args(); array_shift( $argvs ); if(!isset($this->_resclass)) { $this->_resclass = new WXResponse(); } return $this->_resclass->$hook($argvs); } private function _checkSignature() { $signature = $_GET["signature"]; $timestamp = $_GET["timestamp"]; $nonce = $_GET["nonce"]; $token = $this->_token; $tmpArr = array($token, $timestamp, $nonce); sort($tmpArr, SORT_STRING); $tmpStr = implode($tmpArr); $tmpStr = sha1($tmpStr); return $tmpStr == $signature; } private function _handlePostObj($postObj) { $MsgType = strtolower((string) $postObj->MsgType); $result = array( 'from' => self::$_from_id = (string) htmlspecialchars($postObj->FromUserName), 'to' => self::$_my_id = (string) htmlspecialchars($postObj->ToUserName), 'time' => (int) $postObj->CreateTime, 'type' => (string) $MsgType ); if (property_exists($postObj, 'MsgId')) { $result['id'] = $postObj->MsgId; } switch ($result['type']) { case 'text': $result['content'] = (string) $postObj->Content; // Content 消息内容 break; case 'location': $result['X'] = (float) $postObj->Location_X; // Location_X 地理位置纬度 $result['Y'] = (float) $postObj->Location_Y; // Location_Y 地理位置经度 $result['S'] = (float) $postObj->Scale; // Scale 地图缩放大小 $result['I'] = (string) $postObj->Label; // Label 地理位置信息 break; case 'image': $result['url'] = (string) $postObj->PicUrl; // PicUrl 图片链接，开发者可以用HTTP GET获取 $result['mid'] = (string) $postObj->MediaId; // MediaId 图片消息媒体id，可以调用多媒体文件下载接口拉取数据。 break; case 'video': $result['mid'] = (string) $postObj->MediaId; // MediaId 图片消息媒体id，可以调用多媒体文件下载接口拉取数据。 $result['thumbmid'] = (string) $postObj->ThumbMediaId; // ThumbMediaId 视频消息缩略图的媒体id，可以调用多媒体文件下载接口拉取数据。 break; case 'link': $result['title'] = (string) $postObj->Title; // 消息标题 $result['desc'] = (string) $postObj->Description; // 消息描述 $result['url'] = (string) $postObj->Url; // 消息链接 break; case 'voice': $result['mid'] = (string) $postObj->MediaId; // 语音消息媒体id，可以调用多媒体文件下载接口拉取该媒体 $result['format'] = (string) $postObj->Format; // 语音格式：amr if (property_exists($postObj, Recognition)) { $result['txt'] = (string) $postObj->Recognition; // 语音识别结果，UTF8编码 } break; case 'event': $result['event'] = strtolower((string) $postObj->Event); // 事件类型，subscribe(订阅)、unsubscribe(取消订阅)、CLICK(自定义菜单点击事??? switch ($result['event']) { // case 'unsubscribe': // 取消订阅 case 'subscribe': // 订阅 case 'scan': // 扫描二维码 if (property_exists($postObj, EventKey)) { // 扫描带参数二维码事件 $result['key'] = str_replace( 'qrscene_', '', (string) $postObj->EventKey ); // 事件KEY值，qrscene_为前缀，后面为二维码的参数值 $result['ticket'] = (string) $postObj->Ticket; } break; case 'location': // 上报地理位置事件 $result['la'] = (string) $postObj->Latitude; // 地理位置纬度 $result['lo'] = (string) $postObj->Longitude; // 地理位置经度 $result['p'] = (string) $postObj->Precision; // 地理位置精度 break; case 'click': // 自定义菜单事件 $result['key'] = (string) $postObj->EventKey; // 事件KEY值，与自定义菜单接口中KEY值对??? break; case "masssendjobfinish": // 高级群发接口 $result['id'] = (string) $postObj->MsgID; // 群发的消息ID $result['status'] = (bool) 'send success' === $postObj->Status; // 群发结果 $result['msg'] = (string) self::$ERRCODE_MAP[$postObj->Status]; // TotalCount >= FilterCount // FilterCount = SentCount + ErrorCount $result['total'] = (string) $postObj->TotalCount; // group_id下粉丝数；或者openid_list中的粉丝数 $result['fact'] = (string) $postObj->FilterCount; // 实际发送的粉丝数（部分设置黑白名单） $result['hit'] = (string) $postObj->SentCount; // 发送成功的粉丝数 $result['miss'] = (string) $postObj->ErrorCount; // 发送失败的粉丝数 break; case 'templatesendjobfinish': // 推送模板消息发送状态 $result['msg_id'] = (string) $postObj->MsgID; $result['status'] = (string) $postObj->Status; } } return $result; } private function accessDataPush() { if (!$this->_checkSignature()) { if (!headers_sent()) { header('HTTP/1.1 404 Not Found'); header('Status: 404 Not Found'); } $this->_activeHook('404'); return; } $postdata = file_get_contents("php://input"); if ($postdata) { if (!$this->_checkSignature()) { return; } $postObj = simplexml_load_string($postdata, 'SimpleXMLElement', LIBXML_NOCDATA); $postObj = $this->_handlePostObj($postObj); $this->_activeHook('receiveAllStart', $postObj); // Call Special Request Handle Function if (isset($postObj['event'])) { $hookName = 'receiveEvent::' . $postObj['event']; } else { $hookName = 'receiveMsg::' . $postObj['type']; } $this->_activeHook($hookName, $postObj); $this->_activeHook('receiveAllEnd', $postObj); } elseif (isset($_GET['echostr'])) { $this->_activeHook('accessCheckSuccess'); // avoid of xss if (!headers_sent()) { header('Content-Type: text/plain'); } echo preg_replace('/[^a-z0-9]/i', '', $_GET['echostr']); } } private static $_from_id; private static $_my_id; private static function _format2xml($nodes) { $xml = '<xml>' . '<ToUserName><![CDATA[%s]]></ToUserName>' . '<FromUserName><![CDATA[%s]]></FromUserName>' . '<CreateTime>%s</CreateTime>' . '%s' . '</xml>'; $return = sprintf( $xml, self::$_from_id, self::$_my_id, time(), $nodes ); return diconv($return, CHARSET, 'UTF-8'); } public static function getXml4Txt($txt) { $xml = '<MsgType><![CDATA[text]]></MsgType>' . '<Content><![CDATA[%s]]></Content>'; return self::_format2xml( sprintf( $xml, $txt ) ); } public static function getXml4ImgByMid($mid) { $xml = '<MsgType><![CDATA[image]]></MsgType>' . '<Image>' . '<MediaId><![CDATA[%s]]></MediaId>' . '</Image>'; return self::_format2xml( sprintf( $xml, $mid ) ); } public static function getXml4VoiceByM