yjf713
<?php
/**
 * 微信公众平台API
 */
class WeixinChat
{

 private $token;

 private $appid;

 private $appsecret;

 private $access_token;

 // 接收的数据
 private $_receive = array();

 private $_reply = \'\';

 // 接口错误码
 private $errCode = \'\';

 // 接口错误信息
 private $errMsg = \'\';

 // 微信oauth登陆获取code
 const CONNECT_OAUTH_AUTHORIZE_URL = \'https://open.weixin.qq.com/connect/oauth2/authorize?\';

 // 微信oauth登陆通过code换取网页授权access_token
 const SNS_OAUTH_ACCESS_TOKEN_URL = \'https://api.weixin.qq.com/sns/oauth2/access_token?\';

 // 微信oauth登陆刷新access_token(如果需要)
 const SNS_OAUTH_REFRESH_TOKEN_URL = \'https://api.weixin.qq.com/sns/oauth2/refresh_token?\';

 // 通过ticket换取二维码
 const SHOW_QRCODE_URL = \'https://mp.weixin.qq.com/cgi-bin/showqrcode?\';

 // 微信oauth登陆拉取用户信息(需scope为 snsapi_userinfo)
 const SNS_USERINFO_URL = \'https://api.weixin.qq.com/sns/userinfo?\';

 // 请求api前缀
 const API_URL_PREFIX = \'https://api.weixin.qq.com/cgi-bin\';

 // 自定义菜单创建
 const MENU_CREATE_URL = \'/menu/create?\';

 // 自定义菜单查询
 const MENU_GET_URL = \'/menu/get?\';

 // 自定义菜单删除
 const MENU_DELETE_URL = \'/menu/delete?\';

 // 获取 access_token
 const AUTH_URL = \'/token?grant_type=client_credential&\';

 // 获取用户基本信息
 const USER_INFO_URL = \'/user/info?\';

 // 获取关注者列表
 const USER_GET_URL = \'/user/get?\';

 // 查询分组
 const GROUPS_GET_URL = \'/groups/get?\'; 

 // 创建分组
 const GROUPS_CREATE_URL = \'/groups/create?\';

 // 修改分组名
 const GROUPS_UPDATE_URL = \'/groups/update?\';

 // 移动用户分组
 const GROUPS_MEMBERS_UPDATE_URL = \'/groups/members/update?\';

 // 发送客服消息
 const MESSAGE_CUSTOM_SEND_URL = \'/message/custom/send?\';

 // 创建二维码ticket
 const QRCODE_CREATE_URL = \'/qrcode/create?\';

 

 /**
  * 初始化配置数据
  * @param array $options
  */
 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\'] : \'\';
 }

 
 /**
  * 获取发来的消息
  * 当普通微信用户向公众账号发消息时,微信服务器将POST消息的XML数据包到开发者填写的URL上。
  */
 public function getRev()
 {
  $postStr = file_get_contents(\'php://input\');
  if($postStr)
  {
   $this->_receive = (array)simplexml_load_string($postStr, \'SimpleXMLElement\', LIBXML_NOCDATA);
   //Log::info(var_export($this->_receive, true));
  }
  return $this;
 }

 
 /**
  * 获取微信服务器发来的消息
  */
 public function getRevData()
 {
  return $this->_receive;
 }

 
 /**
  * 获取接收者
  */
 public function getRevTo()
 {
  return isset($this->_receive[\'ToUserName\']) ? $this->_receive[\'ToUserName\'] : false;
 }

 
 /**
  * 获取消息发送者(一个OpenID)
  */
 public function getRevFrom()
 {
  return isset($this->_receive[\'FromUserName\']) ? $this->_receive[\'FromUserName\'] : false;
 }

 
 /**
  * 获取接收消息创建时间 (整型)
  */
 public function getRevCTime()
 {
  return isset($this->_receive[\'CreateTime\']) ? $this->_receive[\'CreateTime\'] : false;
 }

 
 /**
  * 获取接收消息类型(text、image、voice、video、location、link、event)
  */
 public function getRevType()
 {
  return isset($this->_receive[\'MsgType\']) ? $this->_receive[\'MsgType\'] : false;
 }

 
 /**
  * 获取接收消息编号
  */
 public function getRevId()
 {
  return isset($this->_receive[\'MsgId\']) ? $this->_receive[\'MsgId\'] : false;
 }

 
 /**
  * 获取接收消息文本
  * 通过语音识别接口,用户发送的语音,将会同时给出语音识别出的文本内容。(需申请服务号的高级接口权限)
  */
 public function getRevText()
 {
  if(isset($this->_receive[\'Content\'])) return trim($this->_receive[\'Content\']);
  elseif(isset($this->_receive[\'Recognition\'])) return trim($this->_receive[\'Recognition\']);
  else return false;
 }

 
 /**
  * 获取接收图片消息
  */
 public function getRevImage()
 {
  if(isset($this->_receive[\'PicUrl\'])){
   return array(
        \'picUrl\' => $this->_receive[\'PicUrl\'],  //图片链接
     \'mediaId\' => $this->_receive[\'MediaId\'] //图片消息媒体id,可以调用多媒体文件下载接口拉取数据。
       );
  }
  return false;
 }

 
 /**
  * 获取接收语音消息
  */
 public function getRevVoice()
 {
  if(isset($this->_receive[\'MediaId\'])){
   return array(
        \'mediaId\' => $this->_receive[\'MediaId\'],  //语音消息媒体id,可以调用多媒体文件下载接口拉取数据。
     \'format\' => $this->_receive[\'Format\'] //语音格式,如amr,speex等
       );
  }
  return false;
 }

 
 /**
  * 获取接收视频消息
  */
 public function getRevVideo()
 {
  if(isset($this->_receive[\'MediaId\'])){
   return array(
        \'mediaId\' => $this->_receive[\'MediaId\'],       //视频消息媒体id,可以调用多媒体文件下载接口拉取数据。
     \'thumbMediaId\' => $this->_receive[\'ThumbMediaId\']  //视频消息缩略图的媒体id,可以调用多媒体文件下载接口拉取数据。
       );
  }
  return false;
 } 

 
 /**
  * 获取用户地理位置
  */
 public function getRevLocation()
 {
  if(isset($this->_receive[\'Location_X\'])){
   return array(
        \'locationX\' => $this->_receive[\'Location_X\'],  //地理位置维度
     \'locationY\' => $this->_receive[\'Location_Y\'],  //地理位置经度
     \'scale\' => $this->_receive[\'Scale\'], //地图缩放大小
     \'label\' => $this->_receive[\'Label\'] //地理位置信息
       );
  }
  //开通了上报地理位置接口的公众号,用户在关注后进入公众号会话时,会弹框让用户确认是否允许公众号使用其地理位置。
  //弹框只在关注后出现一次,用户以后可以在公众号详情页面进行操作。
  elseif(isset($this->_receive[\'Latitude\'])) 
  {
   return array(
        \'latitude\' => $this->_receive[\'Latitude\'],  //地理位置纬度
     \'longitude\' => $this->_receive[\'Longitude\'], //地理位置经度
      \'precision\' => $this->_receive[\'Precision\'] // 地理位置精度
       );
  }
  return false;
 }

 
 /**
  * 获取接收链接消息
  */
 public function getRevLink()
 {
  if(isset($this->_receive[\'Title\'])){
   return array(
        \'title\' => $this->_receive[\'Title\'],  //消息标题
     \'description\' => $this->_receive[\'Description\'],  //消息描述
     \'url\' => $this->_receive[\'Url\'] //消息链接
       );
  }
  return false;
 }

 
 /**
  * 获取接收事件类型
  * 事件类型如:subscribe(订阅)、unsubscribe(取消订阅)、click
  */
 public function getRevEvent()
 {
  if(isset($this->_receive[\'Event\']))
  {
   return array(
     \'event\' => strtolower($this->_receive[\'Event\']), 
     \'key\'=> isset($this->_receive[\'EventKey\']) ? $this->_receive[\'EventKey\'] : \'\'
       );
  }
  return false;
 }

 
 /**
  * 设置回复文本消息
  * @param string $content
  * @param string $openid
  */
 public function text($content=\'\')
 {
  $textTpl = "<xml>
      <ToUserName><![CDATA[%s]]></ToUserName>
      <FromUserName><![CDATA[%s]]></FromUserName>
      <CreateTime>%s</CreateTime>
      <MsgType><![CDATA[%s]]></MsgType>
      <Content><![CDATA[%s]]></Content>
     </xml>";

  $this->_reply = sprintf($textTpl, 
         $this->getRevFrom(),
         $this->getRevTo(), 
         Date::getTimeStamp(), 
         \'text\', 
         $content
        );
  return $this;
 }

 
 /**
  * 设置回复音乐信息
  * @param string $title
  * @param string $desc
  * @param string $musicurl
  * @param string $hgmusicurl
  */
 public function music($title, $desc, $musicurl, $hgmusicurl=\'\')
 {
  $textTpl = \'<xml>
      <ToUserName><![CDATA[%s]]></ToUserName>
      <FromUserName><![CDATA[%s]]></FromUserName>
      <CreateTime>%s</CreateTime>
      <MsgType><![CDATA[%s]]></MsgType>
      <Music>
       <Title><![CDATA[%s]]></Title>
       <Description><![CDATA[%s]]></Description>
       <MusicUrl><![CDATA[%s]]></MusicUrl>
       <HQMusicUrl><![CDATA[%s]]></HQMusicUrl>
      </Music>
     </xml>\';
  //<ThumbMediaId><![CDATA[%s]]></ThumbMediaId>

  $this->_reply = sprintf($textTpl, 
         $this->getRevFrom(),
         $this->getRevTo(), 
         Date::getTimeStamp(), 
         \'music\', 
         $title,
         $desc,
         $musicurl,
         $hgmusicurl
        );
  return $this;
 }

 
 /**
  * 回复图文消息
  * @param array
  */
 public function news($data)
 {
  $count = count($data);
  $subText = \'\';
  if($count > 0)
  {
   foreach($data as $v)
   {
    $tmpText = \'<item>
      <Title><![CDATA[%s]]></Title> 
      <Description><![CDATA[%s]]></Description>
      <PicUrl><![CDATA[%s]]></PicUrl>
      <Url><![CDATA[%s]]></Url>
      </item>\';

    $subText .= sprintf(
        $tmpText, $v[\'title\'], 
        isset($v[\'description\']) ? $v[\'description\'] : \'\', 
        isset($v[\'picUrl\']) ? $v[\'picUrl\'] : \'\', 
        isset($v[\'url\']) ? $v[\'url\'] : \'\'
       );
   }
  }

  $textTpl = \'<xml>
      <ToUserName><![CDATA[%s]]></ToUserName>
      <FromUserName><![CDATA[%s]]></FromUserName>
      <CreateTime><![CDATA[%s]]></CreateTime>
      <MsgType><![CDATA[news]]></MsgType>
      <ArticleCount><![CDATA[%d]]></ArticleCount>
      <Articles>%s</Articles>
     </xml>\';

  $this->_reply = sprintf(
       $textTpl, 
       $this->getRevFrom(), 
       $this->getRevTo(), 
       Date::getTimeStamp(), 
       $count, 
       $subText
      );
  return $this;
 }

 
 /**
  * 回复消息
  * @param array $msg
  * @param bool $return
  */
 public function reply()
 {
  header(\'Content-Type:text/xml\');
  echo $this->_reply;
  exit;
 }

 
 /**
  * 自定义菜单创建
  * @param array 菜单数据
  */
 public function createMenu($data)
 {
  if(!$this->access_token && !$this->checkAuth()) return false;

  $result = curlRequest(self::API_URL_PREFIX.self::MENU_CREATE_URL.\'access_token=\'.$this->access_token, $this->jsonEncode($data), \'post\');
  if($result)
  {
   $jsonArr = json_decode($result, true);
   if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
   else return true;
  }

  return false;
 }

 
 /**
  * 自定义菜单查询
  */
 public function getMenu()
 {
  if(!$this->access_token && !$this->checkAuth()) return false;

  $result = curlRequest(self::API_URL_PREFIX.self::MENU_GET_URL.\'access_token=\'.$this->access_token);
  if($result)
  {
   $jsonArr = json_decode($result, true);
   if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
   else return $jsonArr;
  }

  return false;
 }

 
 /**
  * 自定义菜单删除
  */
 public function deleteMenu()
 {
  if(!$this->access_token && !$this->checkAuth()) return false;

  $result = curlRequest(self::API_URL_PREFIX.self::MENU_DELETE_URL.\'access_token=\'.$this->access_token);
  if($result)
  {
   $jsonArr = json_decode($result, true);
   if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
   else return true;
  }

  return false;
 }

 
 /**
  * 获取用户基本信息
  * @param string $openid 普通用户的标识,对当前公众号唯一
  */
 public function getUserInfo($openid)
 {
  if(!$this->access_token && !$this->checkAuth()) return false;

  $result = curlRequest(self::API_URL_PREFIX.self::USER_INFO_URL.\'access_token=\'.$this->access_token.\'&openid=\'.$openid);
  if($result)
  {
   $jsonArr = json_decode($result, true);
   if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
   else return $jsonArr;
  }

  return false;
 }

 
 /**
  * 获取关注者列表
  * @param string $next_openid 第一个拉取的OPENID,不填默认从头开始拉取
  */
 public function getUserList($next_openid=\'\')
 {
  if(!$this->access_token && !$this->checkAuth()) return false;

  $result = curlRequest(self::API_URL_PREFIX.self::USER_GET_URL.\'access_token=\'.$this->access_token.\'&next_openid=\'.$next_openid);
  if($result)
  {
   $jsonArr = json_decode($result, true);
   if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
   else return $jsonArr;
  }

  return false;
 }

 
 /**
  * 查询分组
  */
 public function getGroup()
 {
  if(!$this->access_token && !$this->checkAuth()) return false;

  $result = curlRequest(self::API_URL_PREFIX.self::GROUPS_GET_URL.\'access_token=\'.$this->access_token);
  if($result)
  {
   $jsonArr = json_decode($result, true);
   if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
   else return $jsonArr;
  }

  return false;
 }

 
 /**
  * 创建分组
  * @param string $name 分组名字(30个字符以内)
  */
 public function createGroup($name)
 {
  if(!$this->access_token && !$this->checkAuth()) return false;
  $data = array(\'group\' => array(\'name\' => $name));
  $result = curlRequest(self::API_URL_PREFIX.self::GROUPS_CREATE_URL.\'access_token=\'.$this->access_token, $this->jsonEncode($data), \'post\');
  if($result)
  {
   $jsonArr = json_decode($result, true);
   if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
   else return true;
  }

  return false;
 }

 
 /**
  * 修改分组名
  * @param int $id 分组id,由微信分配
  * @param string $name 分组名字(30个字符以内)
  */
 public function updateGroup($id, $name)
 {
  if(!$this->access_token && !$this->checkAuth()) return false;

  $data = array(\'group\' => array(\'id\' => $id, \'name\' => $name));
  $result = curlRequest(self::API_URL_PREFIX.self::GROUPS_UPDATE_URL.\'access_token=\'.$this->access_token, $this->jsonEncode($data), \'post\');
  if($result)
  {
   $jsonArr = json_decode($result, true);
   if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
   else return true;
  }

  return false;
 }

 
 /**
  * 移动用户分组
  * 
  * @param string $openid 用户唯一标识符
  * @param int $to_groupid 分组id
  */
 public function updateGroupMembers($openid, $to_groupid)
 {
  if(!$this->access_token && !$this->checkAuth()) return false;

  $data = array(\'openid\' => $openid, \'to_groupid\' => $to_groupid);
  $result = curlRequest(self::API_URL_PREFIX.self::GROUPS_MEMBERS_UPDATE_URL.\'access_token=\'.$this->access_token, $this->jsonEncode($data), \'post\');
  if($result)
  {
   $jsonArr = json_decode($result, true);
   if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
   else return true;
  }

  return false;
 }

 
 /**
  * 发送客服消息
  * 当用户主动发消息给公众号的时候(包括发送信息、点击自定义菜单clike事件、订阅事件、扫描二维码事件、支付成功事件、用户维权),
  * 微信将会把消息数据推送给开发者,开发者在一段时间内(目前为24小时)可以调用客服消息接口,通过POST一个JSON数据包来发送消息给普通用户,在24小时内不限制发送次数。
  * 此接口主要用于客服等有人工消息处理环节的功能,方便开发者为用户提供更加优质的服务。
  * 
  * @param string $touser 普通用户openid
  */
 public function sendCustomMessage($touser, $data, $msgType = \'text\')
 {
  $arr = array();
  $arr[\'touser\'] = $touser;
  $arr[\'msgtype\'] = $msgType;
  switch ($msgType)
  {
   case \'text\': // 发送文本消息
    $arr[\'text\'][\'content\'] = $data; 
    break;

   case \'image\': // 发送图片消息
    $arr[\'image\'][\'media_id\'] = $data;
    break;

   case \'voice\': // 发送语音消息
    $arr[\'voice\'][\'media_id\'] = $data;
    break;

   case \'video\': // 发送视频消息
    $arr[\'video\'][\'media_id\'] = $data[\'media_id\']; // 发送的视频的媒体ID
    $arr[\'video\'][\'thumb_media_id\'] = $data[\'thumb_media_id\']; // 视频缩略图的媒体ID
    break;

   case \'music\': // 发送音乐消息
    $arr[\'music\'][\'title\'] = $data[\'title\'];// 音乐标题
    $arr[\'music\'][\'description\'] = $data[\'description\'];// 音乐描述
    $arr[\'music\'][\'musicurl\'] = $data[\'musicurl\'];// 音乐链接
    $arr[\'music\'][\'hqmusicurl\'] = $data[\'hqmusicurl\'];// 高品质音乐链接,wifi环境优先使用该链接播放音乐
    $arr[\'music\'][\'thumb_media_id\'] = $data[\'title\'];// 缩略图的媒体ID
    break;

   case \'news\': // 发送图文消息
    $arr[\'news\'][\'articles\'] = $data; // title、description、url、picurl
    break;
  } 

  if(!$this->access_token && !$this->checkAuth()) return false;

  $result = curlRequest(self::API_URL_PREFIX.self::MESSAGE_CUSTOM_SEND_URL.\'access_token=\'.$this->access_token, $this->jsonEncode($arr), \'post\');
  if($result)
  {
   $jsonArr = json_decode($result, true);
   if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
   else return true;
  }

  return false;
 }

 

 /**
  * 获取access_token
  */
 public function checkAuth()
 {

  // 从缓存中获取access_token
  $cache_flag = \'weixin_access_token\';
  $access_token = cache($cache_flag);
  if($access_token) 
  {
   $this->access_token = $access_token;
   return true;
  }

  // 请求微信服务器获取access_token 
  $result = curlRequest(self::API_URL_PREFIX.self::AUTH_URL.\'appid=\'.$this->appid.\'&secret=\'.$this->appsecret);
  if($result)
  {
   $jsonArr = json_decode($result, true);
   if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0))
   {
    $this->error($jsonArr);
   }
   else
   {
    $this->access_token = $jsonArr[\'access_token\'];
    $expire = isset($jsonArr[\'expires_in\']) ? intval($jsonArr[\'expires_in\'])-100 : 3600;
    // 将access_token保存到缓存中
    cache($cache_flag, $this->access_token, $expire, Cache::FILE); 
    return true;
   }
  }
  return false;
 }

 
 /**
  * 微信oauth登陆->第一步:用户同意授权,获取code
  * 应用授权作用域,snsapi_base (不弹出授权页面,直接跳转,只能获取用户openid),
  * snsapi_userinfo (弹出授权页面,可通过openid拿到昵称、性别、所在地。并且,即使在未关注的情况下,只要用户授权,也能获取其信息)
  * 直接在微信打开链接,可以不填此参数。做页面302重定向时候,必须带此参数
  * 
  * @param string $redirect_uri 授权后重定向的回调链接地址
  * @param string $scope 应用授权作用域 0为snsapi_base,1为snsapi_userinfo
  * @param string $state 重定向后会带上state参数,开发者可以填写任意参数值
  */
 public function redirectGetOauthCode($redirect_uri, $scope=0, $state=\'\')
 {
  $scope = ($scope == 0) ? \'snsapi_base\' : \'snsapi_userinfo\';
  $url = self::CONNECT_OAUTH_AUTHORIZE_URL.\'appid=\'.$this->appid.\'&redirect_uri=\'.urlencode($redirect_uri).\'&response_type=code&scope=\'.$scope.\'&state=\'.$state.\'#wechat_redirect\';
  redirect($url);
 }

 
 /**
  * 微信oauth登陆->第二步:通过code换取网页授权access_token
  * 
  * @param string $code
  */
 public function getSnsAccessToken($code)
 {
  $result = curlRequest(self::SNS_OAUTH_ACCESS_TOKEN_URL.\'appid=\'.$this->appid.\'&secret=\'.$this->appsecret.\'&code=\'.$code.\'&grant_type=authorization_code\');
  if($result)
  {
   $jsonArr = json_decode($result, true);
   if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
   else return $jsonArr;
  }

  return false;
 }

 
 /**
  * 微信oauth登陆->第三步:刷新access_token(如果需要)
  * 由于access_token拥有较短的有效期,当access_token超时后,可以使用refresh_token进行刷新,
  * refresh_token拥有较长的有效期(7天、30天、60天、90天),当refresh_token失效的后,需要用户重新授权。
  * 
  * @param string $refresh_token 填写通过access_token获取到的refresh_token参数
  */
 public function refershToken($refresh_token)
 {
  $result = curlRequest(self::SNS_OAUTH_REFRESH_TOKEN_URL.\'appid=\'.$this->appid.\'&grant_type=refresh_token&refresh_token=\'.$refresh_token);
  if($result)
  {
   $jsonArr = json_decode($result, true);
   if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
   else return $jsonArr;
  }

  return false;
 }

 
 /**
  * 微信oauth登陆->第四步:拉取用户信息(需scope为 snsapi_userinfo)
  * 如果网页授权作用域为snsapi_userinfo,则此时开发者可以通过access_token和openid拉取用户信息了。
  * 
  * @param string $access_token 网页授权接口调用凭证,注意:此access_token与基础支持的access_token不同
  * @param string $openid 用户的唯一标识
  */
 public function getSnsUserInfo($access_token, $openid)
 {
  $result = curlRequest(self::SNS_USERINFO_URL.\'access_token=\'.$access_token.\'&openid=\'.$openid);
  if($result)
  {
   $jsonArr = json_decode($result, true);
   if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
   else return $jsonArr;
  }

  return false;
 }

 
 /**
  * 创建二维码ticket
  * 每次创建二维码ticket需要提供一个开发者自行设定的参数(scene_id),分别介绍临时二维码和永久二维码的创建二维码ticket过程。
  * 
  * @param int $scene_id 场景值ID,临时二维码时为32位整型,永久二维码时最大值为1000
  * @param int $type 二维码类型,0为临时,1为永久
  * @param int $expire 该二维码有效时间,以秒为单位。 最大不超过1800。
  */
 public function createQrcode($scene_id, $type=0, $expire=1800)
 {
  if(!$this->access_token && !$this->checkAuth()) return false;

  $data = array();
  $data[\'action_info\'] = array(\'scene\' => array(\'scene_id\' => $scene_id));
  $data[\'action_name\'] = ($type == 0 ? \'QR_SCENE\' : \'QR_LIMIT_SCENE\');
  if($type == 0) $data[\'expire_seconds\'] = $expire;

  $result = curlRequest(self::API_URL_PREFIX.self::QRCODE_CREATE_URL.\'access_token=\'.$this->access_token, $this->jsonEncode($data), \'post\');
  if($result)
  {
   $jsonArr = json_decode($result, true);
   if(!$jsonArr || (isset($jsonArr[\'errcode\']) && $jsonArr[\'errcode\'] > 0)) $this->error($jsonArr);
   else return $jsonArr;
  }

  return false;
 }

 
 /**
  * 通过ticket换取二维码
  * 获取二维码ticket后,开发者可用ticket换取二维码图片。请注意,本接口无须登录态即可调用。
  * 提醒:TICKET记得进行UrlEncode
  * ticket正确情况下,http 返回码是200,是一张图片,可以直接展示或者下载。
  * 错误情况下(如ticket非法)返回HTTP错误码404。
  * 
  * @param string $ticket
  */
 public function getQrcodeUrl($ticket)
 {
  return self::SHOW_QRCODE_URL.\'ticket=\'.urlencode($ticket);
 }

 
 /**
  * 记录接口产生的错误日志
  */
 public function error($data)
 {
  $this->errCode = $data[\'errcode\'];
  $this->errMsg = $data[\'errmsg\'];
  Log::info(\'WEIXIN API errcode:[\'.$this->errCode.\'] errmsg:[\'.$this->errMsg.\']\');
 }

 
 /**
  * 将数组中的中文转换成json数据
  * @param array $arr
  */
 public function jsonEncode($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 [] = $this->jsonEncode ( $value ); /* :RECURSION: */
                                else
                                        $parts [] = \'"\' . $key . \'":\' . $this->jsonEncode ( $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
        }

        
 /**
  * 检验签名
  */
 public function checkSignature()
 {
        $signature = HttpRequest::getGet(\'signature\');
        $timestamp = HttpRequest::getGet(\'timestamp\');
        $nonce = HttpRequest::getGet(\'nonce\');

  $token = $this->token;
  $tmpArr = array($token, $timestamp, $nonce);
  sort($tmpArr);
  $tmpStr = implode($tmpArr);
  $tmpStr = sha1($tmpStr);

  return ($tmpStr == $signature ? true : false);
 }

 
 /**
  * 验证token是否有效
  */
 public function valid()
 {
  if($this->checkSignature()) exit(HttpRequest::getGet(\'echostr\'));
 }

function curlRequest($url){
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL,$url);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        $result = curl_exec($ch);
        curl_close($ch);
        return $result;
    }


}

 

分类:

技术点:

相关文章: