<?php // error_reporting(0); /** * 微信公共平台整合库 * @author Ligboy (ligboy@gmail.com) * @license 本库的很多思路来自于网上的其他热心人士的贡献，大家任意使用，我本人放弃所有权利，如果您心情好，给我留个署名也行。 * */ interface WechatSessionToolInter { /** * @name 获取token * */ function getToken(); /** * @name 设置保存token * @param string $token */ function setToken($token); /** * @name 获取Cookies * */ function getCookies(); /** * @name 设置保存Cookies * @param string $Cookies */ function setCookies($Cookies); } /** * @author Ligboy * @name 微信关联接口 * */ interface WechatAscToolInter { /** * @name 判断指定Openid是否关联 * @param string $Openid 指定Openid * @return boolean 返回逻辑判断结果,已关联则返回用户信息数组 */ function getAscStatusByOpenid($Openid); /** * @name 判断指定fakeid是否关联 * @param string $fakeid 指定fakeid * @return boolean 返回逻辑判断结果,已关联则返回用户信息数组 */ function getAscStatusByFakeid($fakeid); /** * @name 设置fakeid与Openid的关联 * @param string $openid Openid * @param string $fakeid fakeid * @param string $detailInfo $detailInfo */ function setAssociation($openid, $fakeid, $detailInfo); } interface WechatFollowToolInter { /** * @name 用户关注执行动作 * @param string $openid Openid */ function followAddAction($openid); /** * @name 取消关注执行动作 * @param string $openid Openid */ function followCancelAction($openid); } class Wechat { / 配置参数 / /** * * @var array * @example array('token'=>'微信接口密钥','account'=>'微信公共平台账号','password'=>'微信公共平台密码','webtoken'=>"微信公共平台网页url的token"); */ private $wechatOptions=array('token'=>'rqerwer','account'=>'ligboy@gmail.com','password'=>'wwwwww'); // private $cookiefilepath = ""; //以文件形式保存cookie的保存目录，肯定是可写的 public $webtoken = ''; private $webtokenStoragefile = ""; //微信公共平台的token存储文件，就是公共平后台网页的token public $debug = false; //调试开关 public $protocol = "https"; //使用协议类型 http or https / 静态常量 / 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'; / 私有参数 / private $_msg; private $_funcflag = false; public $_receive; private $_logcallback; private $_token; private $_getRevRunOnce = 0; private $_cookies; private $_wechatcallbackFuns = null; private $_curlHttpObject = null; /** * @var boolean 自动附带发送openid开关 */ private $_autosendopenid = false; /** * @var boolean 被动响应关联动作开关 */ private $_passiveAssociationSwitch = false; /** * */ /** * @var boolean 被动响应关联动作开关 */ private $_passiveAscGetDetailSwitch = false; /** * 初始化工作 * @param array $option array('token'=>'微信接口密钥','account'=>'微信公共平台账号','password'=>'微信公共平台密码'); */ function __construct($option=array()) { if (!empty($option)) { $this->wechatOptions = array_merge($this->wechatOptions, $option); } } /** * @name 主动动作初始化 * @return Wechat */ function positiveInit() { if (!is_object($this->_wechatcallbackFuns)) { if ($this->wechatOptions['wechattool']) { $this->setWechatToolFun($this->wechatOptions['wechattool']); } $this->setWechatToolFun($this->wechatOptions['wechattool']); } $this->_cookies = $this->getCookies(); $this->webtoken = (string)$this->getToken(); return $this; } private function curlInit($type=null, $option=null) { if (!isset($this->_curlHttpObject)) { $this->_curlHttpObject = new CurlHttp(); } if ("single"==$type) { $this->_curlHttpObject->singleInit($option); } elseif ("roll"==$type){ $this->_curlHttpObject->rollInit($option); } return $this->_curlHttpObject; } /** * 验证请求签名操作 * @return boolean */ private function checkSignature() { $signature = $_GET["signature"]; $timestamp = $_GET["timestamp"]; $nonce = $_GET["nonce"]; $token = $this->wechatOptions['token']; $tmpArr = array($token, $timestamp, $nonce); sort($tmpArr); $tmpStr = implode( $tmpArr ); $tmpStr = sha1( $tmpStr ); if( $tmpStr == $signature ) { return true; } else { return false; } } /** * 验证当前请求是否有效 * @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); } } /** * @name 获取微信服务器发来的信息 * @return mixed */ 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); } if ($this->_getRevRunOnce==0) { $event = $this->getRevEvent(); if (Wechat::MSGTYPE_EVENT==$this->getRevType()) { if ($event['event']=="subscribe" && method_exists($this->_wechatcallbackFuns, "followAddAction")) { $this->_wechatcallbackFuns->followAddAction($this->getRevFrom()); } elseif ($event['event']=="unsubscribe" && method_exists($this->_wechatcallbackFuns, "followCancelAction")){ $this->_wechatcallbackFuns->followCancelAction($this->getRevFrom()); } } $this->doAssociationAction(); $this->_getRevRunOnce = 1; } return $this; } /** * 获取消息发送者 * @return string or boolean */ public function getRevFrom() { if ($this->_receive) { return $this->_receive['FromUserName']; } else { return false; } } /** * 获取消息接受者 * @return string or boolean */ 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 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; } /** * 获取接收地理位置 * @return array('x'=>'','y'=>'','scale'=>'','label'=>'') */ 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; } /** * 获取接收事件推送 * @return array 成功返回事件数组，失败返回false */ public function getRevEvent(){ if (isset($this->_receive['Event'])){ return array( 'event'=>$this->_receive['Event'], 'key'=>$this->_receive['EventKey'], ); } else return false; } /** * 获取接收语言推送 * @return */ public function getRevVoice(){ if (isset($this->_receive['MediaId'])){ return array( 'mediaid'=>$this->_receive['MediaId'], 'format'=>$this->_receive['Format'], ); } else return false; } private static function xmlSafeStr($str) { return '<![CDATA['.preg_replace("/[\\x00-\\x08\\x0b-\\x0c\\x0e-\\x1f]/",'',$str).']]>'; } /** * 数据XML编码 * @param mixed $data 数据 * @return string */ private 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 */ private 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; } /** * 设置回复消息 * Examle: $obj->text('hello')->reply(); * @param string $text */ public function text($text='') { if ($this->_autosendopenid) { if (is_object($this->_wechatcallbackFuns) && method_exists($this->_wechatcallbackFuns, "getAscStatusByOpenid")) { if (!$this->_wechatcallbackFuns->getAscStatusByOpenid($this->getRevFrom())) { $text .= "<a href=\"".$this->getRevFrom()."\"> </a>"; } } else{ $text .= "<a href=\"".$this->getRevFrom()."\"> </a>"; } } $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 * @example 数组结构: * 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 是否返回信息而输出 默认：false */ 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; } //debug 调试记录回复信息 if ($this->debug){file_put_contents($this->debugpath."./reply.txt","\n---".date('Y-m-d H:i:s')."\n".$xmldata,FILE_APPEND);} } /** * 登录微信公共平台，获取并保存cookie、webtoken到指定文件 * @return mixed 成功则返回true，失败则返回失败 */ public function login(){ $url = $this->protocol."://mp.weixin.qq.com/cgi-bin/login?lang=zh_CN"; $postfields["username"] = $this->wechatOptions['account']; $postfields["pwd"] = md5($this->wechatOptions['password']); $postfields["f"] = "json"; $postfieldss = "username=".urlencode($this->wechatOptions['account'])."&pwd=".urlencode(md5($this->wechatOptions['password']))."&f=json"; $this->curlInit("single"); $response = $this->_curlHttpObject->post($url, $postfields, $this->protocol."://mp.weixin.qq.com/cgi-bin/login", $this->_cookies); $result = json_decode($response, true); if ($result['ErrCode']=="65201"||$result['ErrCode']=="65202"||$result['ErrCode']=="0") { preg_match('/&token=([\d]+)/i', $result['ErrMsg'],$match); $this->webtoken = $match[1]; $this->setToken($this->webtoken); $this->setCookies($this->_curlHttpObject->getCookies()); return true; } else { // return false; return $result['ErrCode']; } } /** * @name 执行关联动作 */ private function doAssociationAction() { //var_dump($this->_passiveAssociationSwitch && Wechat::MSGTYPE_EVENT!=$this->getRevType() && is_object($this->_wechatcallbackFuns) && method_exists($this->_wechatcallbackFuns, "getAscStatusByOpenid") && method_exists($this->_wechatcallbackFuns, "setAssociation") && !$this->_wechatcallbackFuns->getAscStatusByOpenid($this->getRevFrom())); if ($this->_passiveAssociationSwitch && Wechat::MSGTYPE_EVENT!=$this->getRevType() && is_object($this->_wechatcallbackFuns) && method_exists($this->_wechatcallbackFuns, "getAscStatusByOpenid") && method_exists($this->_wechatcallbackFuns, "setAssociation") && !$this->_wechatcallbackFuns->getAscStatusByOpenid($this->getRevFrom())) { //$messageList = $this->getMessage(); $messageList = $this->getMessageAjax(0, 40, 0, 99999999+intval(mt_rand(0, 99999))); if ($messageList) { $count = 0; $fakeid = ""; foreach ($messageList as $value) { if ($value["dateTime"]==$this->getRevCtime()) { $count += 1; $fakeid = $value["fakeId"]; } } if (1==$count && $fakeid!="") { $detailInfo = NULL; if ($this->_passiveAscGetDetailSwitch) { $detailInfo = $this->getContactInfo($fakeid); } $this->_wechatcallbackFuns->setAssociation((string)$this->getRevFrom(), $fakeid, $detailInfo); } } } } /** * 验证登录是否在线 * @return boolean */ public function checkValid() { $postfields = array(); $url = $this->protocol."://mp.weixin.qq.com/cgi-bin/getregions?id=1054&t=ajax-getregions&lang=zh_CN&token=".$this->webtoken; //判断cookie是否为空，为空的话自动执行登录 if ($this->_cookies||$this->_cookies = $this->getCookies()) { $this->curlInit("single"); $response = $this->_curlHttpObject->get($url, $this->protocol."://mp.weixin.qq.com/cgi-bin/", $this->_cookies); $result = json_decode($response,1); if(isset($result['num'])) { return true; } else { return false; } } else { return false; } } /** * keepLive心跳包保持，在线状态，推荐通过cron每15分钟调用一下 * @return boolean */ public function keepLive() { if (!$this->checkValid()) { return (true===$this->login()); } return 1; } /** * 主动单条发消息 * @param string $id 用户的fakeid * @param string $content 发送的内容 * @return integer 返回发送结果：成功返回:1,登录问题返回:-1,其他原因返回:0 */ public function send($fakeid,$content) { //判断cookie是否为空，为空的话自动执行登录 if (file_exists($this->cookiefilepath)||true===$this->login()) { $postfields = array(); $postfields['tofakeid'] = $fakeid; $postfields['type'] = 1; $postfields['error']= "false"; $postfields['token']= $this->webtoken; $postfields['content'] = $content; $postfields['ajax'] = 1; $url = $this->protocol."://mp.weixin.qq.com/cgi-bin/singlesend?t=ajax-response"; $this->curlInit("single"); $response = $this->_curlHttpObject->post($url, $postfields, $this->protocol."://mp.weixin.qq.com/", $this->_cookies); $tmp = json_decode($response,true); //判断发送结果的逻辑部分 if ('ok'==$tmp["msg"]) { return 1; } elseif ($tmp['ret']=="-2000") { return -1; } else { return 0; } } else //登录失败返回false { return 0; } } /** * 主动群发相同消息，目前暂支持文本方式 * @param array $fakeidGroup 接受微信fakeid集合数组 * @param string $content 群发消息内容 * @return mixed 返回一个记录发送结果的数组列表 * 这里需要注意请求耗时问题，目前采用curl并发性请求. */ public function batSend($fakeidGroup,$content) { $queueSendArray = array(); foreach ($fakeidGroup as $key =>$value) { $queueSendArray[] = array( 'fakeid' => $value, 'content' => $content ); } return $this->doQueueSend($queueSendArray); } /** * 主动发送队列消息，目前暂支持文本方式 * @param array 发送队列数组 array(array('fakeid'='','content')) * @param integer $queueCount 并发数量,默认10 * @return mixed 返回一个记录发送结果的数组列表 * 这里需要注意请求耗时问题，目前采用curl并发性请求. */ public function queueSend($queueSendArray,$queueCount=10) { return $this->doQueueSend($queueSendArray,$queueCount); } /** * 执行主动发送队列，默认并发队列数是10 * @param array $queueSendArray 发送队列数组 array(array('fakeid'='','content')) * @param integer $queueCount 并发数量,默认10 * @return array 返回一个记录发送结果的数组列表 **/ private function doQueueSend($queueSendArray, $queueCount=10) { $requestArray = array(); foreach ($queueSendArray as $key =>$value) { $postfields = array(); $postfields['tofakeid'] = $value['fakeid']; $postfields['type'] = 1; $postfields['error']= "false"; $postfields['token']= $this->webtoken; $postfields['content'] = $value['content']; $postfields['ajax'] = 1; $url = $this->protocol."://mp.weixin.qq.com/cgi-bin/singlesend?t=ajax-response"; $requestArray[] = array('url'=>$url,'method'=>'post','postfields'=>$postfields,'referer'=>$this->protocol."://mp.weixin.qq.com/",'cookies'=>$this->_cookies); } function callback($result, $key){ $tmp = json_decode($result,true); //判断发送结果的逻辑部分 if ('ok'==$tmp["msg"]) { return 1; } elseif ($tmp['ret']=="-2000") { return -1; } else { return 0; } }; $this->curlInit("roll"); $this->_curlHttpObject->setRollLimitCount($queueCount); $response = $this->_curlHttpObject->setCallback("callback")->rollRequest($requestArray); return $response; } /** * 获取用户的信息 * @param string $fakeid 用户的fakeid * @return mixed 如果成功获取返回数据数组，登录问题返回false，其他未知问题返回true， */ public function getContactInfo($fakeid) { $url = $this->protocol."://mp.weixin.qq.com/cgi-bin/getcontactinfo?t=ajax-getcontactinfo&lang=zh_CN&fakeid=".$fakeid; $this->curlInit("single"); $postfields = array("token"=>$this->webtoken, "ajax"=>1); $response = $this->_curlHttpObject->post($url, $postfields, $this->protocol."://mp.weixin.qq.com/", $this->_cookies); $result = json_decode($response,1); if($result['FakeId']){ return $result; } elseif ($result['ret']) { return false; } else { return false; } } /** * 获取消息所附文件 * @param string $msgid 消息的id * @return array 如果成功获取返回下载的文件的基本信息 */ public function getDownloadFile($msgid, $filepath = null) { if ($this->_cookies||true===$this->login()) { $url = $this->protocol."://mp.weixin.qq.com/cgi-bin/downloadfile?token=".$this->webtoken."&msgid=$msgid&source="; $ch = curl_init(); $tmpfile = $filepath?$filepath:tempnam(sys_get_temp_dir(), 'WechatFileTemp'); $fp = @fopen($tmpfile,"w"); if ($fp) { curl_setopt($ch, CURLOPT_URL, $url); $options = array( CURLOPT_RETURNTRANSFER => true, // return web page CURLOPT_HEADER => false, CURLOPT_FOLLOWLOCATION => true, // follow redirects CURLOPT_ENCODING => "", // handle all encodings CURLOPT_USERAGENT => "", // who am i CURLOPT_AUTOREFERER => true, // set referer on redirect CURLOPT_CONNECTTIMEOUT => 10, // timeout on connect CURLOPT_TIMEOUT => 10, // timeout on response CURLOPT_MAXREDIRS => 10, // stop after 10 redirects CURLOPT_POST => false, // i am sending post data CURLOPT_SSL_VERIFYHOST => 0, // don't verify ssl CURLOPT_SSL_VERIFYPEER => false, // // CURLOPT_FILE => $fp, //目标文件保存路径 // CURLOPT_RETURNTRANSFER => 1 ); curl_setopt_array($ch, $options); $reqCookiesString = ""; if(is_array($this->_cookies)){ foreach ($this->_cookies as $key => $val){ $reqCookiesString .= $key."=".$val."; "; } curl_setopt($ch, CURLOPT_COOKIE, $reqCookiesString); } $content = curl_exec($ch); $info = (curl_getinfo($ch)); curl_close($ch); fwrite($fp, $content); fclose($fp); $result = array(); echo filesize($tmpfile); if ($content && file_exists($tmpfile) && filesize($tmpfile)>0 && $info["content_type"]!="text/html") { echo "XXX"; $result["filename"] = $tmpfile; $result["filesize"] = filesize($tmpfile); $result['filetype'] = $info["content_type"]; return $result; } } } return false; } /** * @name 获取公共消息列表（html） * @param number $day * @param number $count 数量限制 * @param number $page 页数 * @return array|boolean */ public function getMessage($day=0, $count=100, $page=1) { if ($this->_cookies||true===$this->login()) { $url = $this->protocol."://mp.weixin.qq.com/cgi-bin/getmessage?t=wxm-message&token=".$this->webtoken."&lang=zh_CN&count=100"; $this->curlInit("single"); $result = $this->_curlHttpObject->get($url, $this->protocol."://mp.weixin.qq.com/cgi-bin/", $this->_cookies); if (preg_match('%<script type="json" id="json-msgList">([\s\S]*?)</script>%', $result, $match)) { $tmp = json_decode($match[1], true); return $tmp; } else { return false; } } } /** * @name 获取与指定用户的对话信息列表 * @param string $fakeid 要获取指定用户消息的fakeid（必选） * @param number $lastmsgid 最早消息的id * @param number $createtime 最早消息的时间戳 * @param string $lastmsgfromfakeid 消息最后来源 */ public function getSingleMessage($fakeid, $lastmsgid=1, $createtime=0, $lastmsgfromfakeid=null) { if (!empty($this->_cookies)) { $url = $this->protocol."://mp.weixin.qq.com/cgi-bin/singlemsgpage?t=ajax-single-getnewmsg"; $this->curlInit("single"); $postfield = array(); $postfield['createtime']=$createtime; $postfield['fromfakeid']=$fakeid; $postfield['opcode']=1; $postfield['lastmsgfromfakeid']=$lastmsgfromfakeid; $postfield['lastmsgid']=$lastmsgid; $postfield['token']=$this->webtoken; $postfield['ajax']=1; $result = $this->_curlHttpObject->post($url, $postfield, $this->protocol."://mp.weixin.qq.com/",$this->_cookies); if ($result) { return json_decode($result, true); } } return false; } /** * @name 获取公共消息时间线列表 * @param number $day 获取几日内的消息参数（0:当天;1:昨天;2:前天;3:最近5天.默认0） * @param number $count 获取消息数量限制.默认100 * @param number $offset 获取消息开始位置,差不多是偏移分页的样子.默认是0 * @param number $msgid 最后消息的id 默认为9999999999(意味着全部消息的意思) * @param boolean $timeline 这个参数决定了上面的$day是否有效，设置成false,直接按时间线排列的全部消息 * @return mixed|boolean */ public function getMessageAjax($day=0, $count=100, $offset=1, $msgid=999999999, $timeline=1) { if ($this->_cookies||true===$this->login()) { $url = $this->protocol."://mp.weixin.qq.com/cgi-bin/getmessage?t=ajax-message&lang=zh_CN&count=$count&timeline=".($timeline?"1":"")."&day=$day&star=&frommsgid=$msgid&cgi=getmessage&offset=".intval($offset); $this->curlInit("single"); $postfieldArray = array( "token" => $this->webtoken, "ajax" => 1 ); $header = array( "X-Requested-With" => "XMLHttpRequest" ); $result = $this->_curlHttpObject->post($url, $postfieldArray, $this->protocol."://mp.weixin.qq.com/cgi-bin/", $this->_cookies, $header); if ($result) { return json_decode($result, true); } else { return false; } } } /** * @name 得到确定的某条消息(因为微信两个时间戳有时不同, 所以这个接口效果不完美) * @param string $datetime */ public function getOneMessage($datetime=NULL, $type=NULL, $openid=NULL) { if (!$type) { $type = $this->getRevType(); } if (!$datetime) { $datetime = $this->getRevCtime(); } if (!$openid) { $openid = $this->getRevFrom(); } // file_put_contents("log.txt", "\n[b]".$this->getRevCtime()."[/b]*****\n",FILE_APPEND); $typeList = array(Wechat::MSGTYPE_TEXT=>1, Wechat::MSGTYPE_IMAGE=>2, Wechat::MSGTYPE_VOICE=>3, Wechat::MSGTYPE_VIDEO=>4, Wechat::MSGTYPE_LOCATION=>1); if ($openid && method_exists($this->_wechatcallbackFuns, "getAscStatusByOpenid") && is_array($userInfo = $this->_wechatcallbackFuns->getAscStatusByOpenid($openid))) { // file_put_contents("log.txt", "A\n".serialize($userInfo),FILE_APPEND); if ($userInfo['fakeid']) { // file_put_contents("log.txt", "B\n",FILE_APPEND); $singleMessage = $this->getSingleMessage($userInfo['fakeid'], 1, (string)(intval($datetime)-10)); $singleMessageCount = count($singleMessage); // file_put_contents("log.txt", (string)(intval($datetime)-0)."\n",FILE_APPEND); if ($singleMessageCount==1) { // file_put_contents("log.txt", "\$singleMessageCount:$singleMessageCount\n",FILE_APPEND); if( $userInfo['fakeid']==$singleMessage[0]['fakeId'] && (empty($type) || $singleMessage[0]['type']==$typeList[$type]) ) { // file_put_contents("log.txt", serialize($singleMessage[0])."\n",FILE_APPEND); return $singleMessage[0]; } } elseif ($singleMessageCount>1)//TODO 当前进度在这 { for($i=0;$i<$singleMessageCount;$i++) { if ( $userInfo['fakeid']==$singleMessage[0]['fakeId'] && $datetime == $singleMessage[$i]['dateTime']) { // file_put_contents("log.txt", serialize($singleMessage[$i])."\n",FILE_APPEND); return $singleMessage[$i]; } } // file_put_contents("log.txt", $singleMessageCount."\n",FILE_APPEND); for($i=0;$i<$singleMessageCount;$i++) { if( $userInfo['fakeid']==$singleMessage[$i]['fakeId'] && $singleMessage[$i]['type']==$typeList[$type]) { // file_put_contents("log.txt", serialize($singleMessage[$i])."\n",FILE_APPEND); return $singleMessage[$i]; } } } else { // file_put_contents("log.txt", "False\n",FILE_APPEND); return FALSE; } } } //获取40条最新的公共消息列表 $messageList = $this->getMessageAjax(0, 40, 0, 99999999+intval(mt_rand(0, 99999))); $messageListCount = count($messageList); if ($messageListCount>0) { $matchMessageList = array(); for($i=0;$i<$messageListCount;$i++) { if (($datetime?$datetime:$this->getRevCtime()) == $messageList[$i]['dateTime'] && ($type?($messageList[$i]['type']==$typeList[$type]):true)) { $matchMessageList[] = $messageList[$i]; } } if (count($matchMessageList)==1) { return $matchMessageList[0]; } } return FALSE; } /** * @name 得到指定分组的用户列表 * @param number $groupid * @return Ambigous <boolean, string, mixed> */ public function getfriendlist($groupid=0, $pagesize=100) { $url = $this->protocol."://mp.weixin.qq.com/cgi-bin/contactmanagepage?token=$this->webtoken&t=wxm-friend&pagesize=$pagesize&groupid=$groupid"; $referer = $this->protocol."://mp.weixin.qq.com/"; $this->curlInit("single"); $response = $this->_curlHttpObject->get($url, $referer, $this->_cookies); $tmp = ""; if (preg_match('%<script id="json-friendList" type="json/text">([\s\S]*?)</script>%', $response, $match)) { $tmp = json_decode($match[1], true); } return empty($tmp)?false:$tmp; } /** * 获取用户的fakeid * @param callback $callback 处理匹配结果的回调函数，剥离出来方便大家自己的实现自己的逻辑，大致就是循环的查找，并写入数据库之类的 * * 下面是示例： * function callback($result, $key, $request, $otherCallbackArg){ * $reruen_tmp = false; * dump($result); * foreach ($otherCallbackArg['data'] as $data_key => $data_value) * { * if(false !== strpos($result, substr(md5($data_value['openid']), 0, 16))) * { * $subscribeusersModel = D("Subscribeusers"); * $condition['openid'] = $data_value['openid']; * $data = $subscribeusersModel->where($condition)->save(array('fakeid'=>$request['postfields']['fromfakeid'])); * $otherCallbackArg['wechatObj']->putIntoGroup($request['postfields']['fromfakeid'], 101); * $reruen_tmp = $data_value['openid']; * break; * } * } * return $reruen_tmp; * }; * print_r($this->wechatObj->getfakeid("callback")); */ /* public function getfakeid($callback) { //接下来是数据库的访问，大家可以按照自己的环境修改，接下来会通过回调函数解决。 $subscribeusersModel = D("Subscribeusers"); $data = $subscribeusersModel->where(' `fakeid` IS NULL and `unsubscribed`=0')->select(); //$data 是当前fakeid为空的用户的列表数组 if (!is_array($data)) { die("none data"); } $unfriendList = $this->getfriendlist(0); if (!$unfriendList){ die("none friendlist"); } $requestArray = array(); foreach ($unfriendList as $key => $value) { // $requestArray[$key]['postfields']['createtime'] = time()-60000; $requestArray[$key]['postfields']['fromfakeid'] = $value['fakeId']; $requestArray[$key]['postfields']['opcode'] = 1; $requestArray[$key]['postfields']['token'] = $this->webtoken; $requestArray[$key]['postfields']['ajax'] = 1; $requestArray[$key]['referer'] = $this->protocol."://mp.weixin.qq.com/"; $requestArray[$key]['cookiefilepath'] = $this->cookiefilepath; $requestArray[$key]['method'] = "post"; $requestArray[$key]['url'] = $this->protocol."://mp.weixin.qq.com/cgi-bin/singlemsgpage?t=ajax-single-getnewmsg"; } $this->curlInit("roll"); $rollingCurlObj->setOtherCallbackArg(array('data'=>$data, 'wechatObj'=>$this)); $response = $rollingCurlObj->setCallback($callback)->request($requestArray); // dump($response); } */ /** * 将用户放入制定的分组 * @param array $fakeidsList * @param string $groupid * @return boolean 放入是否成功 */ public function putIntoGroup($fakeidsList, $groupid) { $fakeidsListString = ""; if(is_array($fakeidsList)) { foreach ($fakeidsList as $value) { $fakeidsListString .= $value."|"; } } else { $fakeidsListString = $fakeidsList; } $postfields['contacttype'] = $groupid; $postfields['tofakeidlist'] = $fakeidsListString; $postfields['token'] = $this->webtoken; $postfields['ajax'] = 1; $referer = $this->protocol."://mp.weixin.qq.com/"; $url = $this->protocol."://mp.weixin.qq.com/cgi-bin/modifycontacts?action=modifycontacts&t=ajax-putinto-group"; $this->curlInit("roll"); $response = $this->_wechatcallbackFuns->post($url, $postfields, $referer, $this->_cookies); $tmp = json_decode($response, true); $result = $tmp['ret']=="0"&&!empty($tmp)?true:false; return $result; } public function setWechatToolFun($class){ if (is_string($class)) { $toolObj = new $class; if (is_object($toolObj)) { $this->_wechatcallbackFuns = $toolObj; return $this; } else{ return false; } } elseif (is_object($class)){ $this->_wechatcallbackFuns = $class; return $this; } else{ return false; } } /** * @return the $wechatOptions */ public function getCookies() { return $this->_wechatcallbackFuns->getCookies(); } /** * @return the $wechatOptions */ public function getToken() { return $this->_wechatcallbackFuns->getToken(); } /** * @return the $wechatOptions */ public function getWechatOptions() { return $this->wechatOptions; } /** * 设置微信配置信息 * @param multitype:string $wechatOptions */ public function setWechatOptions($wechatOptions) { $this->wechatOptions = array_merge($this->wechatOptions, $wechatOptions); return $this; } /** * 设置cookie保存位置 * @param string $cookies cookie */ public function setCookies($cookies) { $this->_wechatcallbackFuns->setCookies($cookies); return $this; } /** * 设置token保存 * @param string $token token */ public function setToken($token) { $this->_wechatcallbackFuns->setToken($token); return $this; } /** * @param boolean $debug */ public function setDebug($debug) { $this->debug = $debug; return $this; } /** * 设置是否自动附带发送openid开关,default：False * @param boolean $autosendopenid * @return Wechat */ public function setAutoSendOpenidSwitch($autosendopenid=FALSE) { $this->_autosendopenid = $autosendopenid; return $this; } /** * @设置被动关联动作开关 * @param boolean $switch 开关 * @param boolean $detailSwitch 是否获取用户详细信息开关 * @return Wechat */ public function setPassiveAscSwitch($switch, $detailSwitch=false) { $this->_passiveAssociationSwitch = $switch; $this->_passiveAscGetDetailSwitch = $detailSwitch; return $this; } } /** * Rolling Curl Request Class * @author Ligboy (ligboy@gamil.com) * @copyright * @example * * */ class CurlHttp { / 单线程请求设置项 / / 并发请求设置项 / private $limitCount = 10; //并发请求数量 public $returninfoswitch = false; //是否返回请求信息，开启后单项请求返回结果为:array('info'=>请求信息, 'result'=>返回内容, 'error'=>错误信息) //私有属性 private $singlequeue = null; private $rollqueue = null; private $_requstItems = null; private $_callback = null; private $_result; private $_referer = null; private $_cookies = array(); private $_resheader; private $_reqheader = array(); private $_resurl; private $_redirect_url; private $referer; private $_singleoptions = array( CURLOPT_RETURNTRANSFER => true, // return web page CURLOPT_HEADER => true, // don't return headers // CURLOPT_FOLLOWLOCATION => true, // follow redirects CURLOPT_NOSIGNAL =>true, CURLOPT_ENCODING => "", // handle all encodings CURLOPT_USERAGENT => "", // who am i CURLOPT_AUTOREFERER => true, // set referer on redirect CURLOPT_CONNECTTIMEOUT => 120, // timeout on connect CURLOPT_TIMEOUT => 120, // timeout on response CURLOPT_MAXREDIRS => 10, // stop after 10 redirects CURLOPT_SSL_VERIFYHOST => 0, // don't verify ssl CURLOPT_SSL_VERIFYPEER => false, // ); private $_rolloptions = array( CURLOPT_RETURNTRANSFER => true, // return web page CURLOPT_HEADER => true, // don't return headers // CURLOPT_FOLLOWLOCATION => true, // follow redirects CURLOPT_NOSIGNAL =>true, CURLOPT_ENCODING => "", // handle all encodings CURLOPT_USERAGENT => "", // who am i CURLOPT_AUTOREFERER => true, // set referer on redirect CURLOPT_CONNECTTIMEOUT => 120, // timeout on connect CURLOPT_TIMEOUT => 120, // timeout on response CURLOPT_MAXREDIRS => 10, // stop after 10 redirects CURLOPT_SSL_VERIFYHOST => 0, // don't verify ssl CURLOPT_SSL_VERIFYPEER => false, // ); function singleInit($options = array()) { if (!$this->singlequeue) { $this->singlequeue = curl_init(); } if ($options) { $this->_singleoptions = array_merge($this->_singleoptions, $options); } } function rollInit($options = array()) { if(!$this->rollqueue){ $this->rollqueue = curl_multi_init(); } if ($options) { $this->_rolloptions = array_merge($this->_rolloptions, $options); } } /** * @name 返回Header数组 * @param resource $ch * @return string */ private function getResRawHeader($ch, $result) { $ch_info = curl_getinfo($ch); $header_size = $ch_info["header_size"]; $rawheader = substr($result, 0, $ch_info['header_size']); return $rawheader; } /** * @name 返回Header数组 * @param resource $ch * @return string */ private function getResHeader($ch, $result) { $header = array(); $rawheader = $this->getResRawHeader($ch, $result); if(preg_match_all('/([^:\s]+): (.*)/i', $rawheader, $header_match)){ for($i=0;$i<count($header_match[0]);$i++){ $header[$header_match[1][$i]] = $header_match[2][$i]; } } return $header; } /** * @name 返回网页主体内容 * @param resource $ch * @return string 网页主体内容 */ private function getResBody($ch, $result) { $ch_info = curl_getinfo($ch); $body = substr($result, -$ch_info['download_content_length']); return $body; } /** * @name 返回网页主体内容 * @param resource $ch * @return array 网页主体内容 */ private function getResCookies($ch, $result) { $rawheader = $this->getResRawHeader($ch, $result); $cookies = array(); if(preg_match_all('/Set-Cookie:(?:\s)([^=]?)=([^\;]*?);/i', $rawheader, $cookie_match)){ for($i=0;$i<count($cookie_match[0]);$i++){ $cookies[$cookie_match[1][$i]] = $cookie_match[2][$i]; } } return $cookies; } private function setReqCookies($ch, $reqcookies = array()) { $reqCookiesString = ""; if(!empty($reqcookies)){ if(is_array($reqcookies)){ foreach ($reqcookies as $key => $val){ $reqCookiesString .= $key."=".$val."; "; } curl_setopt($ch, CURLOPT_COOKIE, $reqCookiesString); } }elseif(!empty($this->_cookies)) { foreach ($this->_cookies as $key => $val){ $reqCookiesString .= $key."=".$val."; "; } curl_setopt($ch, CURLOPT_COOKIE, $reqCookiesString); } } private function setResCookies($ch) { if(!empty($reqcookies)&&is_array($reqcookies)){ $this->_cookies = array_merge($this->_cookies, $reqcookies); } } /** * @param unknown $url * @param mixed $postfields * @param string $referer * @param array $reqcookies * @return unknown */ function post($url, $postfields=null, $referer=null, $reqcookies=null, $reqheader=array()) { $this->singlequeue = curl_init($url); $options = array( CURLOPT_RETURNTRANSFER => true, // return web page CURLOPT_HEADER => true, // don't return headers // CURLOPT_FOLLOWLOCATION => true, // follow redirects CURLOPT_ENCODING => "", // handle all encodings CURLOPT_USERAGENT => "", // who am i CURLOPT_AUTOREFERER => true, // set referer on redirect CURLOPT_CONNECTTIMEOUT => 120, // timeout on connect CURLOPT_TIMEOUT => 120, // timeout on response CURLOPT_MAXREDIRS => 10, // stop after 10 redirects CURLOPT_POST => true, // i am sending post data CURLOPT_POSTFIELDS => $postfields, // this are my post vars CURLOPT_SSL_VERIFYHOST => 0, // don't verify ssl CURLOPT_SSL_VERIFYPEER => false, // ); curl_setopt_array($this->singlequeue, $options); if($referer){ curl_setopt($this->singlequeue, CURLOPT_REFERER, $referer); } elseif ($this->referer){ curl_setopt($this->singlequeue, CURLOPT_REFERER, $this->referer); } $this->setReqheader($this->singlequeue, $reqheader); $this->setReqCookies($this->singlequeue, $reqcookies); $result = curl_exec($this->singlequeue); $resCookies = $this->getResCookies($this->singlequeue, $result);; if (is_array($resCookies)&&!empty($resCookies)) { $this->_cookies = array_merge($this->_cookies ,$resCookies); } $resHeader = $this->getResHeader($this->singlequeue, $result); if (is_array($resHeader)&&!empty($resHeader)) { $this->_resheader = $resHeader; } $this->_result = $this->getResBody($this->singlequeue, $result); curl_close($this->singlequeue); $this->singlequeue = null; return $this->_result; } /** * @param unknown $url * @param unknown $postfields * @param unknown $referer * @return unknown */ function get($url, $referer=null, $reqcookies=null, $reqheader=array()) { $this->singlequeue = curl_init($url); $options = array( CURLOPT_RETURNTRANSFER => true, // return web page CURLOPT_HEADER => true, // don't return headers // CURLOPT_FOLLOWLOCATION => true, // follow redirects CURLOPT_ENCODING => "", // handle all encodings CURLOPT_USERAGENT => "", // who am i CURLOPT_AUTOREFERER => true, // set referer on redirect CURLOPT_CONNECTTIMEOUT => 120, // timeout on connect CURLOPT_TIMEOUT => 120, // timeout on response CURLOPT_MAXREDIRS => 10, // stop after 10 redirects CURLOPT_POST => false, // i am sending post data CURLOPT_SSL_VERIFYHOST => 0, // don't verify ssl CURLOPT_SSL_VERIFYPEER => false, // CURLOPT_REFERER =>$referer, ); curl_setopt_array($this->singlequeue, $options); if($referer){ curl_setopt($this->singlequeue, CURLOPT_REFERER, $referer); } elseif ($this->referer){ curl_setopt($this->singlequeue, CURLOPT_REFERER, $this->referer); } $this->setReqheader($this->singlequeue, $reqheader); $this->setReqCookies($this->singlequeue, $reqcookies); $result = curl_exec($this->singlequeue); $resCookies = $this->getResCookies($this->singlequeue, $result); if (is_array($resCookies)&&!empty($resCookies)) { $this->_cookies = array_merge($this->_cookies ,$resCookies); } $resHeader = $this->getResHeader($this->singlequeue, $result); if (is_array($resHeader)) { $this->_resheader = $resHeader; } $this->_result = $this->getResBody($this->singlequeue, $result); curl_close($this->singlequeue); $this->singlequeue = null; return $this->_result; } /** * 并发行的curl方法 * @param unknown $requestArray * @param string $callback * @return multitype:multitype: */ function rollRequest($requestArray, $callback="") { $this->_requstItems = $requestArray; $requestArrayKeys = array_keys($requestArray); /* $requestArray = array( array( 'url' => "", 'method' => "post", 'postfields' => array(), 'cookies' => "", 'referer' => "", ), array( 'url' => "", 'postfields' => array(), 'cookies' => "", 'referer' => "", ), ); */ $this->rollqueue = curl_multi_init(); $map = array(); for ($i=0;$i<$this->limitCount && !empty($requestArrayKeys);$i++) { $keyvalue = array_shift($requestArrayKeys); $this->addToRollQueue( $requestArray, $keyvalue, $map ); } $responses = array(); do { while (($code = curl_multi_exec($this->rollqueue, $active)) == CURLM_CALL_MULTI_PERFORM) ; if ($code != CURLM_OK) { break; } // 找到刚刚完成的任务句柄 while ($done = curl_multi_info_read($this->rollqueue)) { // 处理当前句柄的信息、错误、和返回内容 $info = curl_getinfo($done['handle']); $error = curl_error($done['handle']); if ($this->_callback) { //调用callback函数处理当前句柄的返回内容，callback函数参数有：（返回内容, 队列id） $result = call_user_func($this->_callback, curl_multi_getcontent($done['handle']), $map[(string) $done['handle']]); } else { //如果callback为空，直接返回内容 $result = curl_multi_getcontent($done['handle']); } if ($this->returninfoswitch) { $responses[$map[(string) $done['handle']]] = compact('info', 'error', 'result'); } else { $responses[$map[(string) $done['handle']]] = $result; } // 从队列里移除上面完成处理的句柄 curl_multi_remove_handle($this->rollqueue, $done['handle']); curl_close($done['handle']); if (!empty($requestArrayKeys)) { $addkey = array_shift($requestArrayKeys); $this->addToRollQueue ( $requestArray, $addkey, $map ); } } // Block for data in / output; error handling is done by curl_multi_exec if ($active > 0) { curl_multi_select($this->rollqueue, 0.5); } } while ($active); curl_multi_close($this->rollqueue); $this->rollqueue = null; return $responses; } /** * @param requestArray * @param map * @param keyvalue */ private function addToRollQueue($requestArray, $keyvalue, &$map) { $ch = curl_init(); curl_setopt_array($ch, $this->_rolloptions); //检查提交方式，并设置对应的设置，为空的话默认采用get方式 if ("post" === $requestArray[$keyvalue]['method']) { curl_setopt($ch, CURLOPT_POST, true); curl_setopt($ch, CURLOPT_POSTFIELDS, $requestArray[$keyvalue]['postfields']); } else { curl_setopt($ch, CURLOPT_HTTPGET, true); } if($requestArray[$keyvalue]['referer']){ curl_setopt($ch, CURLOPT_REFERER, $requestArray[$keyvalue]['referer']); } elseif ($this->referer){ curl_setopt($ch, CURLOPT_REFERER, $this->referer); } $this->setReqheader($ch, $requestArray[$keyvalue]['header']); //cookies设置 $this->setReqCookies($ch, $requestArray[$keyvalue]['cookies']); curl_setopt($ch, CURLOPT_URL, $requestArray[$keyvalue]['url']); curl_setopt($ch, CURLOPT_REFERER, $requestArray[$keyvalue]['referer']); curl_multi_add_handle($this->rollqueue, $ch); $map[(string) $ch] = $keyvalue; } /** * 返回当前并行数 * @return the $limitCount */ public function getRollLimitCount() { return $this->limitCount; } /** * 设置并发性请求数量 * @param number $limitCount */ public function setRollLimitCount($limitCount) { $this->limitCount = $limitCount; return $this; } /** * 设置回调函数 * @param field_type $_callback */ public function setCallback($_callback) { $this->_callback = $_callback; return $this; } public function getResult() { return $this->_result; } public function getRawHeader() { return $this->_resheader; } public function getCookies() { return $this->_cookies; } public function setCookies($_cookies) { $this->_cookies = $_cookies; return $this; } /** * @param unknown_type $reqheader */ public function setHeader($header) { $this->_reqheader = array_merge($this->_reqheader, $header); return $this; } /** * @param unknown_type $reqheader */ private function setReqheader($ch, $reqheader) { $reqheader = array_merge($this->_reqheader, $reqheader); if (is_array($reqheader)) { $rawReqHeader = array(); foreach ($reqheader as $key => $value){ $rawReqHeader[] = "$key: $value"; } curl_setopt($ch, CURLOPT_HTTPHEADER, $rawReqHeader); $this->_reqheader = array(); } return $this; } }