简洁的PHP QQ Oauth 2.0 SDK类，基于EaglePHP框架封装整理

此类可以用来做什么？

QQ用户oauth验证登陆

获取用户信息

添加分享

获取相册列表

创建相册

上传相片

发表日志

发表说说

发表微博

检查是否是认证空间的粉丝

发图片消息到微博

获取微博用户信息

获取用户的听众列表

获取用户的收听列表

收听腾讯微博上的用户

获取财付通用户的收货地址

2. /**
3. *
4. * QQ开放平台API
5. * @author [e-mail]
6. * @since 2013-06-20
7. * @link http://www.eaglephp.com
8. *
9. */
11. class QQ
12. {
14. private $appid = null;
16. private $appkey = null;
18. private $callbcak = null;
20. private $APIMap = array();
22. private $keysArr = array();
24. const VERSION = '2.0';
26. const AUTH_CODE_URL = 'https://graph.qq.com/oauth2.0/authorize';
28. const ACCESS_TOKEN_URL = 'https://graph.qq.com/oauth2.0/token';
30. const OPENID_URL = 'https://graph.qq.com/oauth2.0/me';
32. const SCOPE = 'get_user_info,add_share,list_album,add_album,upload_pic,add_topic,add_one_blog,add_weibo,check_page_fans,add_t,add_pic_t,del_t,get_repost_list,get_info,get_other_info,get_fanslist,get_idolist,add_idol,del_idol,get_tenpay_addr';
36. public function __construct($appid, $appkey, $callbcak)
37. {
38. $this->appid = $appid;
39. $this->appkey = $appkey;
40. $this->callbcak = $callbcak;
41. }
44. /**
45. * 登录
46. */
47. public function login()
48. {
49. $state = md5(uniqid(rand(), true)); // 生成唯一随机串防CSRF攻击
50. Session::set('state', $state);
51. $keysArr = array(
52. 'response_type' => 'code',
53. 'client_id' => $this->appid,
54. 'redirect_uri' => $this->callbcak,
55. 'scope' => self::SCOPE,
56. 'state' => $state
57. );
58. header('Location:'.self::AUTH_CODE_URL.'?'.http_build_query($keysArr));
59. }
62. /**
63. *
64. * 回调函数返回access_token和open_id
65. *
66. */
67. public function callback()
68. {
69. $state = Session::get('state');
71. // 验证state防止CSRF攻击
72. if(HttpRequest::getGet('state') != $state) throw_exception('The state does not match. You may be a victim of CSRF.');
73. Session::set('state', null);
75. $keysArr = array(
76. 'grant_type' => 'authorization_code',
77. 'client_id' => $this->appid,
78. 'redirect_uri' => $this->callbcak,
79. 'client_secret' => $this->appkey,
80. 'code' => HttpRequest::getGet('code')
81. );
83. $response = curlRequest(self::ACCESS_TOKEN_URL.'?'.http_build_query($keysArr));
84. if(strpos($response, 'callback') !== false)
85. {
86. $lpos = strpos($response, '(');
87. $rpos = strrpos($response, ')');
88. $response = substr($response, $lpos + 1, $rpos - $lpos -1);
89. $msg = json_decode($response);
90. if(isset($msg->error)) throw_exception($msg->error.' '.$msg->error_description);
91. }
93. $params = array();
94. parse_str($response, $params);
95. Session::set('access_token', $params['access_token']);
97. // 根据token请求获取openid
98. $response = curlRequest(self::OPENID_URL.'?access_token='.$params['access_token']);
100. if(strpos($response, 'callback') !== false){
102. $lpos = strpos($response, '(');
103. $rpos = strrpos($response, ')');
104. $response = substr($response, $lpos + 1, $rpos - $lpos -1);
105. }
107. $user = json_decode($response);
108. if(isset($user->error)) throw_exception($msg->error.' '.$msg->error_description);
109. Session::set('open_id', $user->openid);
110. return array('access_token' => $params['access_token'], 'open_id' => $user->openid);
111. }
114. /**
115. *
116. * 初始化数据
117. *
118. */
119. protected function _initAPI()
120. {
121. $this->keysArr = array(
122. 'oauth_consumer_key' => (int)$this->appid,
123. 'access_token' => Session::get('access_token'),
124. 'openid' => Session::get('open_id')
125. );
127. /**
128. *
129. * 初始化APIMap
130. * 加#表示非必须，无则不传入url(url中不会出现该参数)， 'key' => 'val' 表示key如果没有定义则使用默认值val
131. * 规则 array( baseUrl, argListArr, method)
132. *
133. * @var array
134. */
136. $this->APIMap = array(
137. /* qzone */
138. 'add_blog' => array(
139. 'https://graph.qq.com/blog/add_one_blog',
140. array('title', 'format' => 'json', 'content' => null),
141. 'POST'
142. ),
143. 'add_topic' => array(
144. 'https://graph.qq.com/shuoshuo/add_topic',
145. array('richtype','richval','con','#lbs_nm','#lbs_x','#lbs_y','format' => 'json', '#third_source'),
146. 'POST'
147. ),
148. 'get_user_info' => array(
149. 'https://graph.qq.com/user/get_user_info',
150. array('format' => 'json'),
151. 'GET'
152. ),
153. 'add_one_blog' => array(
154. 'https://graph.qq.com/blog/add_one_blog',
155. array('title', 'content', 'format' => 'json'),
156. 'GET'
157. ),
158. 'add_album' => array(
159. 'https://graph.qq.com/photo/add_album',
160. array('albumname', '#albumdesc', '#priv', 'format' => 'json'),
161. 'POST'
162. ),
163. 'upload_pic' => array(
164. 'https://graph.qq.com/photo/upload_pic',
165. array('picture', '#photodesc', '#title', '#albumid', '#mobile', '#x', '#y', '#needfeed', '#successnum', '#picnum', 'format' => 'json'),
166. 'POST'
167. ),
168. 'list_album' => array(
169. 'https://graph.qq.com/photo/list_album',
170. array('format' => 'json')
171. ),
172. 'add_share' => array(
173. 'https://graph.qq.com/share/add_share',
174. array('title', 'url', '#comment','#summary','#images','format' => 'json','#type','#playurl','#nswb','site','fromurl'),
175. 'POST'
176. ),
177. 'check_page_fans' => array(
178. 'https://graph.qq.com/user/check_page_fans',
179. array('page_id' => '314416946','format' => 'json')
180. ),
181. /* wblog */
183. 'add_t' => array(
184. 'https://graph.qq.com/t/add_t',
185. array('format' => 'json', 'content','#clientip','#longitude','#compatibleflag'),
186. 'POST'
187. ),
188. 'add_pic_t' => array(
189. 'https://graph.qq.com/t/add_pic_t',
190. array('content', 'pic', 'format' => 'json', '#clientip', '#longitude', '#latitude', '#syncflag', '#compatiblefalg'),
191. 'POST'
192. ),
193. 'del_t' => array(
194. 'https://graph.qq.com/t/del_t',
195. array('id', 'format' => 'json'),
196. 'POST'
197. ),
198. 'get_repost_list' => array(
199. 'https://graph.qq.com/t/get_repost_list',
200. array('flag', 'rootid', 'pageflag', 'pagetime', 'reqnum', 'twitterid', 'format' => 'json')
201. ),
202. 'get_info' => array(
203. 'https://graph.qq.com/user/get_info',
204. array('format' => 'json')
205. ),
206. 'get_other_info' => array(
207. 'https://graph.qq.com/user/get_other_info',
208. array('format' => 'json', '#name', 'fopenid')
209. ),
210. 'get_fanslist' => array(
211. 'https://graph.qq.com/relation/get_fanslist',
212. array('format' => 'json', 'reqnum', 'startindex', '#mode', '#install', '#sex')
213. ),
214. 'get_idollist' => array(
215. 'https://graph.qq.com/relation/get_idollist',
216. array('format' => 'json', 'reqnum', 'startindex', '#mode', '#install')
217. ),
218. 'add_idol' => array(
219. 'https://graph.qq.com/relation/add_idol',
220. array('format' => 'json', '#name-1', '#fopenids-1'),
221. 'POST'
222. ),
223. 'del_idol' => array(
224. 'https://graph.qq.com/relation/del_idol',
225. array('format' => 'json', '#name-1', '#fopenid-1'),
226. 'POST'
227. ),
228. /* pay */
230. 'get_tenpay_addr' => array(
231. 'https://graph.qq.com/cft_info/get_tenpay_addr',
232. array('ver' => 1,'limit' => 5,'offset' => 0,'format' => 'json')
233. )
234. );
235. }
238. protected function _applyAPI($baseUrl, $argsList, $method)
239. {
240. $params = HttpRequest::getPost();
241. $optionArgList = '';
242. $keysArr = $this->keysArr;
243. $pre = '#';
244. foreach ($argsList as $k=>$v)
245. {
246. if(!is_string($k))
247. {
248. $k = $v;
249. if(strpos($v, $pre) === 0)
250. {
251. $v = $pre;
252. $k = substr($k, 1);
253. if(preg_match('/-(\d$)/', $k, $matchs))
254. {
255. $k = str_replace($matchs[0], '', $k);
256. $optionArgList[$matchs[1]][] = $k;
257. }
258. }
259. else $v = null;
260. }
261. if(!isset($params[$k]) || $params[$k] === '')
262. {
263. if($v == $pre) continue;
264. elseif($v) $params[$k] = $v;
265. else
266. {
267. if(isset($_FILES[$k]) && $_FILES[$k]['name']!='')
268. {
269. $uploadDir = getUploadAddr().'QQ'.__DS__;
270. mk_dir($uploadDir);
271. $uploadObj = new Upload();
272. $fileInfo = $uploadObj->uploadOne($_FILES[$k], $uploadDir);
273. $img = $uploadDir.$fileInfo[0]['savename'];
274. $params[$k] = "@{$img}";
275. }
276. else throw_exception("param {$k} not pass value.");
277. }
278. }
279. $keysArr[$k] = $params[$k];
280. }
282. // 检查选填参数必填一的情形
283. $i = 0;
284. if(isset($optionArgList[1]))
285. {
286. foreach ($optionArgList[1] as $k=>$v) if(array_key_exists($v, $keysArr)) $i++;
287. if(!$i) throw_exception('QQ_api_param_error,['.implode(',', $optionArgList[1]).'] must hava one value.');
288. }
290. $baseUrl .= ($method == 'GET') ? '?'.http_build_query($keysArr) : '';
291. $response = curlRequest($baseUrl, $keysArr, $method);
292. return json_decode($response, true);
293. }
296. public function __call($name, $args)
297. {
298. $this->_initAPI();
299. if(!array_key_exists($name, $this->APIMap)) throw_exception("QQ_api_{$name} not exists.");
301. //从APIMap获取api相应参数
302. $baseUrl = $this->APIMap[$name][0];
303. $argsList = $this->APIMap[$name][1];
304. $method = isset($this->APIMap[$name][2]) ? $this->APIMap[$name][2] : 'GET';
306. $responseArr = $this->_applyAPI($baseUrl, $argsList, $method);
308. //检查返回ret判断api是否成功调用
309. if($responseArr['ret'] == 0) return $responseArr;
310. else throw_exception('QQ_API_'.$name.' [ret:'.$responseArr['ret'].'] [errcode:'.$responseArr['errcode'].'] '.$responseArr['msg']);
311. }
314. }

复制代码