设为首页收藏本站
切换到宽版

 找回密码
 注册

QQ登录

只需一步，快速开始

BCM»广场 › IT生态 › 软件开发 › PHP语言 › eaglephp使用微信api接口开发微信框架
返回列表 发新帖
查看: 397|回复: 3

eaglephp使用微信api接口开发微信框架

[复制链接]
发表于 2014-3-10 12:13:05 | 显示全部楼层 |阅读模式
EaglePHP框架开发微信5.0的API接口，包含微信5.0 API基础接口、自定义菜单、高级接口,包括如下接收用户消息、向用户回复消息、会话界面自定义菜单、语音识别、客服接口等功能

适用平台：window/Linux
依赖项目：EaglePHP框架
包含微信5.0 API基础接口、自定义菜单、高级接口，具体如下：
1、接收用户消息。
2、向用户回复消息。
3、接受事件推送。
4、会话界面自定义菜单。
5、语音识别。
6、客服接口。
7、OAuth2.0网页授权。
8、生成带参数二维码。
9、获取用户地理位置。
10、获取用户基本信息。
11、获取关注者列表。
12、用户分组。


  2. <P> </P>
  3. <DIV class=blockcode>
  4. <BLOCKQUOTE><?php
  5. /**
  6. * 微信公众平台API
  7. */
  8. class WeixinChat
  9. {

  11. private $token;

  13. private $appid;

  15. private $appsecret;

  17. private $access_token;

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

  22. private $_reply = '';

  24. // 接口错误码
  25. private $errCode = '';

  27. // 接口错误信息
  28. private $errMsg = '';

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

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

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

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

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

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

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

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

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

  57. // 获取 access_token
  58. const AUTH_URL = '/token?grant_type=client_credential&';

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

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

  66. // 查询分组
  67. const GROUPS_GET_URL = '/groups/get?';

  69. // 创建分组
  70. const GROUPS_CREATE_URL = '/groups/create?';

  72. // 修改分组名
  73. const GROUPS_UPDATE_URL = '/groups/update?';

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

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

  81. // 创建二维码ticket
  82. const QRCODE_CREATE_URL = '/qrcode/create?';



  86. /**
  87. * 初始化配置数据
  88. * @param array $options
  89. */
  90. public function __construct($options)
  91. {
  92. $this->token = isset($options['token']) ? $options['token'] : '';
  93. $this->appid = isset($options['appid']) ? $options['appid'] : '';
  94. $this->appsecret = isset($options['appsecret']) ? $options['appsecret'] : '';
  95. }


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


  114. /**
  115. * 获取微信服务器发来的消息
  116. */
  117. public function getRevData()
  118. {
  119. return $this->_receive;
  120. }


  123. /**
  124. * 获取接收者
  125. */
  126. public function getRevTo()
  127. {
  128. return isset($this->_receive['ToUserName']) ? $this->_receive['ToUserName'] : false;
  129. }


  132. /**
  133. * 获取消息发送者（一个OpenID）
  134. */
  135. public function getRevFrom()
  136. {
  137. return isset($this->_receive['FromUserName']) ? $this->_receive['FromUserName'] : false;
  138. }


  141. /**
  142. * 获取接收消息创建时间 （整型）
  143. */
  144. public function getRevCTime()
  145. {
  146. return isset($this->_receive['CreateTime']) ? $this->_receive['CreateTime'] : false;
  147. }


  150. /**
  151. * 获取接收消息类型（text、image、voice、video、location、link、event）
  152. */
  153. public function getRevType()
  154. {
  155. return isset($this->_receive['MsgType']) ? $this->_receive['MsgType'] : false;
  156. }


  159. /**
  160. * 获取接收消息编号
  161. */
  162. public function getRevId()
  163. {
  164. return isset($this->_receive['MsgId']) ? $this->_receive['MsgId'] : false;
  165. }


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


  180. /**
  181. * 获取接收图片消息
  182. */
  183. public function getRevImage()
  184. {
  185. if(isset($this->_receive['PicUrl'])){
  186. return array(
  187. 'picUrl' => $this->_receive['PicUrl'], //图片链接
  188. 'mediaId' => $this->_receive['MediaId'] //图片消息媒体id，可以调用多媒体文件下载接口拉取数据。
  189. );
  190. }
  191. return false;
  192. }


  195. /**
  196. * 获取接收语音消息
  197. */
  198. public function getRevVoice()
  199. {
  200. if(isset($this->_receive['MediaId'])){
  201. return array(
  202. 'mediaId' => $this->_receive['MediaId'], //语音消息媒体id，可以调用多媒体文件下载接口拉取数据。
  203. 'format' => $this->_receive['Format'] //语音格式，如amr，speex等
  204. );
  205. }
  206. return false;
  207. }


  210. /**
  211. * 获取接收视频消息
  212. */
  213. public function getRevVideo()
  214. {
  215. if(isset($this->_receive['MediaId'])){
  216. return array(
  217. 'mediaId' => $this->_receive['MediaId'], //视频消息媒体id，可以调用多媒体文件下载接口拉取数据。
  218. 'thumbMediaId' => $this->_receive['ThumbMediaId'] //视频消息缩略图的媒体id，可以调用多媒体文件下载接口拉取数据。
  219. );
  220. }
  221. return false;
  222. }


  225. /**
  226. * 获取用户地理位置
  227. */
  228. public function getRevLocation()
  229. {
  230. if(isset($this->_receive['Location_X'])){
  231. return array(
  232. 'locationX' => $this->_receive['Location_X'], //地理位置维度
  233. 'locationY' => $this->_receive['Location_Y'], //地理位置经度
  234. 'scale' => $this->_receive['Scale'], //地图缩放大小
  235. 'label' => $this->_receive['Label'] //地理位置信息
  236. );
  237. }
  238. //开通了上报地理位置接口的公众号，用户在关注后进入公众号会话时，会弹框让用户确认是否允许公众号使用其地理位置。
  239. //弹框只在关注后出现一次，用户以后可以在公众号详情页面进行操作。
  240. elseif(isset($this->_receive['Latitude']))
  241. {
  242. return array(
  243. 'latitude' => $this->_receive['Latitude'], //地理位置纬度
  244. 'longitude' => $this->_receive['Longitude'], //地理位置经度
  245. 'precision' => $this->_receive['Precision'] // 地理位置精度
  246. );
  247. }
  248. return false;
  249. }


  252. /**
  253. * 获取接收链接消息
  254. */
  255. public function getRevLink()
  256. {
  257. if(isset($this->_receive['Title'])){
  258. return array(
  259. 'title' => $this->_receive['Title'], //消息标题
  260. 'description' => $this->_receive['Description'], //消息描述
  261. 'url' => $this->_receive['Url'] //消息链接
  262. );
  263. }
  264. return false;
  265. }


  268. /**
  269. * 获取接收事件类型
  270. * 事件类型如：subscribe(订阅)、unsubscribe(取消订阅)、click
  271. */
  272. public function getRevEvent()
  273. {
  274. if(isset($this->_receive['Event']))
  275. {
  276. return array(
  277. 'event' => strtolower($this->_receive['Event']),
  278. 'key'=> isset($this->_receive['EventKey']) ? $this->_receive['EventKey'] : ''
  279. );
  280. }
  281. return false;
  282. }
复制代码


回复

使用道具 举报

 楼主| 发表于 2014-3-10 12:15:37 | 显示全部楼层

  2. <P><?php

  4. /**
  5. * 设置回复文本消息
  6. * @param string $content
  7. * @param string $openid
  8. */
  9. public function text($content='')
  10. {
  11. $textTpl = "<xml>
  12. <ToUserName><![CDATA[%s]]></ToUserName>
  13. <FromUserName><![CDATA[%s]]></FromUserName>
  14. <CreateTime>%s</CreateTime>
  15. <MsgType><![CDATA[%s]]></MsgType>
  16. <Content><![CDATA[%s]]></Content>
  17. </xml>";

  19. $this->_reply = sprintf($textTpl,
  20. $this->getRevFrom(),
  21. $this->getRevTo(),
  22. Date::getTimeStamp(),
  23. 'text',
  24. $content
  25. );
  26. return $this;
  27. }


  30. /**
  31. * 设置回复音乐信息
  32. * @param string $title
  33. * @param string $desc
  34. * @param string $musicurl
  35. * @param string $hgmusicurl
  36. */
  37. public function music($title, $desc, $musicurl, $hgmusicurl='')
  38. {
  39. $textTpl = '<xml>
  40. <ToUserName><![CDATA[%s]]></ToUserName>
  41. <FromUserName><![CDATA[%s]]></FromUserName>
  42. <CreateTime>%s</CreateTime>
  43. <MsgType><![CDATA[%s]]></MsgType>
  44. <Music>
  45. <Title><![CDATA[%s]]></Title>
  46. <Description><![CDATA[%s]]></Description>
  47. <MusicUrl><![CDATA[%s]]></MusicUrl>
  48. <HQMusicUrl><![CDATA[%s]]></HQMusicUrl>
  49. </Music>
  50. </xml>';
  51. //<ThumbMediaId><![CDATA[%s]]></ThumbMediaId>

  53. $this->_reply = sprintf($textTpl,
  54. $this->getRevFrom(),
  55. $this->getRevTo(),
  56. Date::getTimeStamp(),
  57. 'music',
  58. $title,
  59. $desc,
  60. $musicurl,
  61. $hgmusicurl
  62. );
  63. return $this;
  64. }


  67. /**
  68. * 回复图文消息
  69. * @param array
  70. */
  71. public function news($data)
  72. {
  73. $count = count($data);
  74. $subText = '';
  75. if($count > 0)
  76. {
  77. foreach($data as $v)
  78. {
  79. $tmpText = '<item>
  80. <Title><![CDATA[%s]]></Title>
  81. <Description><![CDATA[%s]]></Description>
  82. <PicUrl><![CDATA[%s]]></PicUrl>
  83. <Url><![CDATA[%s]]></Url>
  84. </item>';

  86. $subText .= sprintf(
  87. $tmpText, $v['title'],
  88. isset($v['description']) ? $v['description'] : '',
  89. isset($v['picUrl']) ? $v['picUrl'] : '',
  90. isset($v['url']) ? $v['url'] : ''
  91. );
  92. }
  93. }

  95. $textTpl = '<xml>
  96. <ToUserName><![CDATA[%s]]></ToUserName>
  97. <FromUserName><![CDATA[%s]]></FromUserName>
  98. <CreateTime><![CDATA[%s]]></CreateTime>
  99. <MsgType><![CDATA[news]]></MsgType>
  100. <ArticleCount><![CDATA[%d]]></ArticleCount>
  101. <Articles>%s</Articles>
  102. </xml>';

  104. $this->_reply = sprintf(
  105. $textTpl,
  106. $this->getRevFrom(),
  107. $this->getRevTo(),
  108. Date::getTimeStamp(),
  109. $count,
  110. $subText
  111. );
  112. return $this;
  113. }


  116. /**
  117. * 回复消息
  118. * @param array $msg
  119. * @param bool $return
  120. */
  121. public function reply()
  122. {
  123. header('Content-Type:text/xml');
  124. echo $this->_reply;
  125. exit;
  126. }


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

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

  145. return false;
  146. }


  149. /**
  150. * 自定义菜单查询
  151. */
  152. public function getMenu()
  153. {
  154. if(!$this->access_token && !$this->checkAuth()) return false;

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

  164. return false;
  165. }


  168. /**
  169. * 自定义菜单删除
  170. */
  171. public function deleteMenu()
  172. {
  173. if(!$this->access_token && !$this->checkAuth()) return false;

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

  183. return false;
  184. }


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

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

  203. return false;
  204. }


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

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

  223. return false;
  224. }
  225. </P>
  226. <P>?>
  227. </P>
复制代码

回复 支持 反对

使用道具 举报

 楼主| 发表于 2014-3-10 12:18:31 | 显示全部楼层
  1. /**
  2. * 查询分组
  3. */
  4. public function getGroup()
  5. {
  6. if(!$this->access_token && !$this->checkAuth()) return false;

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

  16. return false;
  17. }


  20. /**
  21. * 创建分组
  22. * @param string $name 分组名字（30个字符以内）
  23. */
  24. public function createGroup($name)
  25. {
  26. if(!$this->access_token && !$this->checkAuth()) return false;
  27. $data = array('group' => array('name' => $name));
  28. $result = curlRequest(self::API_URL_PREFIX.self::GROUPS_CREATE_URL.'access_token='.$this->access_token, $this->jsonEncode($data), 'post');
  29. if($result)
  30. {
  31. $jsonArr = json_decode($result, true);
  32. if(!$jsonArr || (isset($jsonArr['errcode']) && $jsonArr['errcode'] > 0)) $this->error($jsonArr);
  33. else return true;
  34. }

  36. return false;
  37. }


  40. /**
  41. * 修改分组名
  42. * @param int $id 分组id，由微信分配
  43. * @param string $name 分组名字（30个字符以内）
  44. */
  45. public function updateGroup($id, $name)
  46. {
  47. if(!$this->access_token && !$this->checkAuth()) return false;

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

  58. return false;
  59. }


  62. /**
  63. * 移动用户分组
  64. *
  65. * @param string $openid 用户唯一标识符
  66. * @param int $to_groupid 分组id
  67. */
  68. public function updateGroupMembers($openid, $to_groupid)
  69. {
  70. if(!$this->access_token && !$this->checkAuth()) return false;

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

  81. return false;
  82. }


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

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

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

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

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

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

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

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

  140. return false;
  141. }



  145. /**
  146. * 获取access_token
  147. */
  148. public function checkAuth()
  149. {

  151. // 从缓存中获取access_token
  152. $cache_flag = 'weixin_access_token';
  153. $access_token = cache($cache_flag);
  154. if($access_token)
  155. {
  156. $this->access_token = $access_token;
  157. return true;
  158. }

  160. // 请求微信服务器获取access_token
  161. $result = curlRequest(self::API_URL_PREFIX.self::AUTH_URL.'appid='.$this->appid.'&secret='.$this->appsecret);
  162. if($result)
  163. {
  164. $jsonArr = json_decode($result, true);
  165. if(!$jsonArr || (isset($jsonArr['errcode']) && $jsonArr['errcode'] > 0))
  166. {
  167. $this->error($jsonArr);
  168. }
  169. else
  170. {
  171. $this->access_token = $jsonArr['access_token'];
  172. $expire = isset($jsonArr['expires_in']) ? intval($jsonArr['expires_in'])-100 : 3600;
  173. // 将access_token保存到缓存中
  174. cache($cache_flag, $this->access_token, $expire, Cache::FILE);
  175. return true;
  176. }
  177. }
  178. return false;
  179. }
复制代码
回复 支持 反对

使用道具 举报

 楼主| 发表于 2014-3-10 12:19:00 | 显示全部楼层
  1. /**
  2. * 微信oauth登陆->第一步：用户同意授权，获取code
  3. * 应用授权作用域，snsapi_base （不弹出授权页面，直接跳转，只能获取用户openid），
  4. * snsapi_userinfo （弹出授权页面，可通过openid拿到昵称、性别、所在地。并且，即使在未关注的情况下，只要用户授权，也能获取其信息）
  5. * 直接在微信打开链接，可以不填此参数。做页面302重定向时候，必须带此参数
  6. *
  7. * @param string $redirect_uri 授权后重定向的回调链接地址
  8. * @param string $scope 应用授权作用域 0为snsapi_base，1为snsapi_userinfo
  9. * @param string $state 重定向后会带上state参数，开发者可以填写任意参数值
  10. */
  11. public function redirectGetOauthCode($redirect_uri, $scope=0, $state='')
  12. {
  13. $scope = ($scope == 0) ? 'snsapi_base' : 'snsapi_userinfo';
  14. $url = self::CONNECT_OAUTH_AUTHORIZE_URL.'appid='.$this->appid.'&redirect_uri='.urlencode($redirect_uri).'&response_type=code&scope='.$scope.'&state='.$state.'#wechat_redirect';
  15. redirect($url);
  16. }


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

  34. return false;
  35. }


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

  55. return false;
  56. }


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

  76. return false;
  77. }


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

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

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

  105. return false;
  106. }


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


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


  135. /**
  136. * 将数组中的中文转换成json数据
  137. * @param array $arr
  138. */
  139. public function jsonEncode($arr) {
  140. $parts = array ();
  141. $is_list = false;
  142. //Find out if the given array is a numerical array
  143. $keys = array_keys ( $arr );
  144. $max_length = count ( $arr ) - 1;
  145. if (($keys [0] === 0) && ($keys [$max_length] === $max_length )) { //See if the first key is 0 and last key is length - 1
  146. $is_list = true;
  147. for($i = 0; $i < count ( $keys ); $i ++) { //See if each key correspondes to its position
  148. if ($i != $keys [$i]) { //A key fails at position check.
  149. $is_list = false; //It is an associative array.
  150. break;
  151. }
  152. }
  153. }
  154. foreach ( $arr as $key => $value ) {
  155. if (is_array ( $value )) { //Custom handling for arrays
  156. if ($is_list)
  157. $parts [] = $this->jsonEncode ( $value ); /* :RECURSION: */
  158. else
  159. $parts [] = '"' . $key . '":' . $this->jsonEncode ( $value ); /* :RECURSION: */
  160. } else {
  161. $str = '';
  162. if (! $is_list)
  163. $str = '"' . $key . '":';
  164. //Custom handling for multiple data types
  165. if (is_numeric ( $value ) && $value<2000000000)
  166. $str .= $value; //Numbers
  167. elseif ($value === false)
  168. $str .= 'false'; //The booleans
  169. elseif ($value === true)
  170. $str .= 'true';
  171. else
  172. $str .= '"' . addslashes ( $value ) . '"'; //All other things
  173. // :TODO: Is there any more datatype we should be in the lookout for? (Object?)
  174. $parts [] = $str;
  175. }
  176. }
  177. $json = implode ( ',', $parts );
  178. if ($is_list)
  179. return '[' . $json . ']'; //Return numerical JSON
  180. return '{' . $json . '}'; //Return associative JSON
  181. }


  184. /**
  185. * 检验签名
  186. */
  187. public function checkSignature()
  188. {
  189. $signature = HttpRequest::getGet('signature');
  190. $timestamp = HttpRequest::getGet('timestamp');
  191. $nonce = HttpRequest::getGet('nonce');

  193. $token = $this->token;
  194. $tmpArr = array($token, $timestamp, $nonce);
  195. sort($tmpArr);
  196. $tmpStr = implode($tmpArr);
  197. $tmpStr = sha1($tmpStr);

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


  203. /**
  204. * 验证token是否有效
  205. */
  206. public function valid()
  207. {
  208. if($this->checkSignature()) exit(HttpRequest::getGet('echostr'));
  209. }

  211. }
复制代码

回复 支持 反对

使用道具 举报

返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则

手机版|小黑屋|BC Morning Website ( Best Deal Inc. 001 )  

GMT-8, 2025-8-26 13:51 , Processed in 0.017581 second(s), 17 queries .

Supported by Best Deal Online X3.5

© 2001-2025 Discuz! Team.

快速回复 返回顶部 返回列表