Base.php 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665
  1. <?php
  2. namespace Passport\Lib;
  3. use Dever;
  4. use Upload\Src\Lib\Img;
  5. use Dever\Routing\Uri;
  6. use Dever\Session\Oper as Save;
  7. use Dever\String\Encrypt;
  8. class Base
  9. {
  10. const NAME = 'passportv1';
  11. const CODE = 'code';
  12. const MCODE = 'mcode';
  13. protected $save;
  14. public function __construct()
  15. {
  16. $this->save = new Save(false, 'cookie');
  17. }
  18. # 注册用户
  19. public function reg($type, $data)
  20. {
  21. $user = $this->getUserExtInfo($data);
  22. $user['source_type'] = $type;
  23. $user['system_id'] = isset($data['system']) ? $data['system'] : 1;
  24. if (isset($data['username'])) {
  25. $user['temp'] = 2;
  26. $user['username'] = $data['username'];
  27. } else {
  28. $user['temp'] = 1;
  29. $user['username'] = '临时用户';
  30. }
  31. if (isset($data['mobile'])) {
  32. $user['bind'] = 1;
  33. $user['mobile'] = $data['mobile'];
  34. } else {
  35. $user['bind'] = 2;
  36. $user['mobile'] = '';
  37. }
  38. $uid = Dever::db('passport/user')->insert($user);
  39. $this->createUsername($uid, $user['username'], true);
  40. return $uid;
  41. }
  42. # 更新用户
  43. public function updateUser($uid, $data)
  44. {
  45. $user = $this->getUserExtInfo($data);
  46. $user['username'] = $this->createUsername($uid, $data['username']);
  47. if (isset($user) && $user) {
  48. $update['where_id'] = $uid;
  49. Dever::db('passport/user')->update($update);
  50. }
  51. return $uid;
  52. }
  53. private function getUserExtInfo($data)
  54. {
  55. $user = array();
  56. if (isset($data['sex'])) {
  57. $user['sex'] = $data['sex'];
  58. }
  59. if (isset($data['avatar'])) {
  60. //$update['avatar'] = $this->saveAvatar($pic);
  61. $user['avatar'] = $data['avatar'];
  62. }
  63. if (isset($data['city'])) {
  64. $user['city'] = $data['city'];
  65. }
  66. if (isset($data['province'])) {
  67. $user['province'] = $data['province'];
  68. }
  69. if (isset($data['country'])) {
  70. $user['country'] = $data['country'];
  71. }
  72. if (isset($user['country']) && isset($user['province']) && isset($user['city'])) {
  73. $user['set_area'] = $user['country'] .','. $user['province'] .','. $user['city'];
  74. }
  75. return $user;
  76. }
  77. public function wechat($data, $user = array(), $account, $system, $source_type, $source = false)
  78. {
  79. $uid = false;
  80. if (!$data['openid']) {
  81. Dever::alert('错误的openid');
  82. }
  83. if (!isset($user['username'])) {
  84. Dever::alert('用户名错误');
  85. }
  86. if (isset($user['sex'])) {
  87. if ($user['sex'] != 1 && $user['sex'] != 2) {
  88. $user['sex'] = 3;
  89. }
  90. }
  91. if (isset($user['country']) && $user['country'] && isset($user['province']) && $user['province'] && isset($user['city']) && $user['city']) {
  92. $user['area'] = $user['country'] .','. $user['province'] .','. $user['city'];
  93. }
  94. $info = Dever::db('passport/wechat')->one(array('openid' => $data['openid']));
  95. if (!$info) {
  96. if (isset($data['unionid']) && $data['unionid']) {
  97. $info = Dever::db('passport/wechat')->one(array('unionid' => $data['unionid']));
  98. if (!$info) {
  99. $uid = false;
  100. } else {
  101. $uid = $info['uid'];
  102. }
  103. $wechat['unionid'] = $data['unionid'];
  104. }
  105. if (!$uid) {
  106. $user['source_type'] = 'service';
  107. if ($system) {
  108. $user['system_id'] = $system;
  109. }
  110. if ($source_type) {
  111. $user['source_type'] = $source_type;
  112. }
  113. $uid = Dever::db('passport/user')->insert($user);
  114. } else {
  115. $user['where_id'] = $uid;
  116. Dever::db('passport/user')->update($user);
  117. }
  118. $wechat['access_token'] = $data['access_token'];
  119. $wechat['openid'] = $data['openid'];
  120. $wechat['expires_in'] = $data['expires_in'];
  121. $wechat['refresh_token'] = $data['refresh_token'];
  122. $wechat['account_id'] = $account;
  123. if ($system) {
  124. $wechat['system_id'] = $system;
  125. }
  126. $wechat['uid'] = $uid;
  127. $wechat['type'] = 2;
  128. if ($source_type == 'applet') {
  129. $wechat['type'] = 1;
  130. } elseif ($source_type == 'ios') {
  131. $wechat['type'] = 3;
  132. } elseif ($source_type == 'android') {
  133. $wechat['type'] = 4;
  134. }
  135. $id = Dever::db('passport/wechat')->insert($wechat);
  136. if (Dever::project('source') && isset($source) && $source && $source > 0) {
  137. Dever::load('source/lib/core')->saveUser($id, $uid, $source, 'oauth', $account);
  138. }
  139. } else {
  140. $uid = $info['uid'];
  141. if (isset($data['unionid']) && $data['unionid']) {
  142. $wechat['unionid'] = $data['unionid'];
  143. # 判断用户是否存在,是否需要合并
  144. //$wechat['uid'] = $this->combine($uid, $data['unionid']);
  145. }
  146. $wechat['access_token'] = $data['access_token'];
  147. $wechat['openid'] = $data['openid'];
  148. $wechat['expires_in'] = $data['expires_in'];
  149. $wechat['refresh_token'] = $data['refresh_token'];
  150. $wechat['where_id'] = $info['id'];
  151. $wechat['account_id'] = $account;
  152. if ($system) {
  153. $wechat['system_id'] = $system;
  154. }
  155. $id = $info['id'];
  156. //Dever::db('passport/wechat')->update($wechat);
  157. $user['where_id'] = $uid;
  158. //Dever::load('passport/user-update', $user);
  159. }
  160. $this->createUsername($uid, $user['username']);
  161. $user = Dever::load('passport/user-one', $uid);
  162. $this->save($user);
  163. $user['uid'] = $user['id'];
  164. $user['signature'] = Dever::login($user['id']);
  165. return $user;
  166. }
  167. /**
  168. * 更新用户信息 绑定用户手机号
  169. *
  170. * @return mixed
  171. */
  172. public function bind_mobile()
  173. {
  174. $uid = $this->check();
  175. //$code = Dever::input('mcode');
  176. $mobile = Dever::load('passport/reg')->checkMobileExists();
  177. //$mobile = Dever::input('mobile');
  178. if ($mobile && $uid) {
  179. $info = Dever::load('passport/user-one', array('mobile' => $mobile));
  180. if ($info && $info['bind'] == 1) {
  181. Dever::alert('该手机号已绑定');
  182. }
  183. $uid = $this->combine($uid, $mobile, 'mobile');
  184. $info = Dever::load('passport/user-one', $uid);
  185. $result['mobile'] = $mobile;
  186. if ($info) {
  187. $update['set_mobile'] = $mobile;
  188. $update['set_bind'] = 1;
  189. $update['where_id'] = $uid;
  190. Dever::load('passport/user-update', $update);
  191. $state = Dever::config('base', 'project')->regSendSms;
  192. if ($state) {
  193. Dever::setInput('skin', $state);
  194. $this->send($mobile, $uid);
  195. }
  196. } else {
  197. Dever::alert('无效的用户id,请重新登录');
  198. }
  199. }
  200. if (!$info['mobile']) {
  201. Dever::score($uid, 'bind_mobile', '绑定手机号');
  202. }
  203. $result['uid'] = $uid;
  204. $result['signature'] = Dever::login($uid);
  205. return $result;
  206. }
  207. public function createUsername($uid, $username, $update = false)
  208. {
  209. if (!$username || $username == '临时用户') {
  210. $username = $uid + 100000;
  211. $username = 'JM' . $username;
  212. if ($update) {
  213. Dever::db('passport/user')->update(array('where_id' => $uid, 'username' => $username));
  214. }
  215. }
  216. return $username;
  217. }
  218. # 合并用户
  219. public function combine($uid, $unionid, $col = 'unionid')
  220. {
  221. $cur = $uid;
  222. if ($col == 'mobile' || $col == 'id') {
  223. $user_wechat = Dever::load('passport/user-all', array($col => $unionid));
  224. } else {
  225. $user_wechat = Dever::load('passport/wechat-getByUnionid', array($col => $unionid));
  226. }
  227. if ($user_wechat) {
  228. # 合并去
  229. $drop = array();
  230. $total = count($user_wechat);
  231. if ($total <= 1) {
  232. return $cur;
  233. }
  234. $new = false;
  235. foreach ($user_wechat as $k => $v) {
  236. if (!isset($v['uid'])) {
  237. $v['uid'] = $v['id'];
  238. $user = $v;
  239. } else {
  240. $user = Dever::db('passport/user')->one($v['uid']);
  241. $user['uid'] = $user['id'];
  242. }
  243. if (!$new) {
  244. if ($user['bind'] == 1 && !strstr($user['username'], '****')) {
  245. $new = $user;
  246. } elseif ($user['temp'] == 2 && $user['source_type'] == 'applet') {
  247. $new = $user;
  248. } elseif ($user['avatar']) {
  249. $new = $user;
  250. } elseif ($user['mobile']) {
  251. $new = $user;
  252. } else {
  253. $drop[$user['uid']] = $user;
  254. }
  255. } else {
  256. $drop[$user['uid']] = $user;
  257. }
  258. }
  259. $cur = $new;
  260. if (Dever::input('test') == 1) {
  261. print_r($user_wechat);
  262. print_r($cur);
  263. print_r($drop);die;
  264. }
  265. # 异步处理
  266. $this->updateCombine($cur, $drop);
  267. $cur = $new['uid'];
  268. }
  269. return $cur;
  270. }
  271. private function updateCombine($new, $drop)
  272. {
  273. # 队列
  274. //Dever::queue();
  275. if (isset($drop[$new['uid']])) {
  276. unset($drop[$new['uid']]);
  277. }
  278. $drops = array();
  279. if ($drop) {
  280. foreach ($drop as $k => $v) {
  281. $drops[] = $k;
  282. $update = array();
  283. if (!$new['username'] && $v['username']) {
  284. $update['username'] = $v['username'];
  285. } elseif (strstr($new['username'], '****') && $v['username']) {
  286. $update['username'] = $v['username'];
  287. }
  288. if (!$new['avatar'] && $v['avatar']) {
  289. $update['avatar'] = $v['avatar'];
  290. }
  291. if (!$new['mobile'] && $v['mobile']) {
  292. $update['mobile'] = $v['mobile'];
  293. }
  294. if (!$new['area'] && $v['area']) {
  295. $update['area'] = $v['area'];
  296. }
  297. if (isset($update) && $update) {
  298. $update['where_id'] = $new['uid'];
  299. Dever::load('passport/user-update', $update);
  300. }
  301. }
  302. if ($drops) {
  303. asort($drops);
  304. $drop_uid = implode(',', $drops);
  305. //Dever::load('passport/lib/base.handleCombine?new_uid=' . $new['uid'] . '&old_uid=' . $drop_uid);
  306. Dever::daemon('lib/base.handleCombine?new_uid=' . $new['uid'] . '&old_uid=' . $drop_uid, 'passport');
  307. }
  308. }
  309. }
  310. public function handleCombine()
  311. {
  312. $combine = array();
  313. $combine['status'] = 1;
  314. $combine['new_uid'] = Dever::input('new_uid');
  315. $combine['old_uid'] = Dever::input('old_uid');
  316. $info = Dever::db('passport/combine')->one($combine);
  317. if (!$info) {
  318. Dever::db('passport/combine')->insert($combine);
  319. }
  320. Dever::load('passport/user-updates', array('set_state' => 2, 'where_id' => $combine['old_uid']));
  321. Dever::load('passport/wechat-updates', array('set_uid' => $combine['new_uid'], 'where_uid' => $combine['old_uid']));
  322. }
  323. /**
  324. * 检测用户有效性
  325. *
  326. * @return mixed
  327. */
  328. public function check($state = true)
  329. {
  330. $signature = Dever::input('signature');
  331. $user = Dever::checkLogin($signature, $state);
  332. if ($state && !isset($user['uid'])) {
  333. Dever::alert('user error');
  334. }
  335. if (isset($user['uid']) && $user['uid']) {
  336. return $user['uid'];
  337. }
  338. return -1;
  339. }
  340. public function getToken($request = array())
  341. {
  342. return http_build_query(Dever::token($request));
  343. }
  344. public function getUrl($method, $request = array())
  345. {
  346. return Dever::proxy($method, $this->getToken($request));
  347. }
  348. protected function info()
  349. {
  350. $data = $this->save->get(self::NAME);
  351. return $data;
  352. }
  353. protected function code($code = false)
  354. {
  355. if ($code) {
  356. $save = $this->save->get(self::CODE);
  357. return $code == $save;
  358. }
  359. $code = new Code();
  360. $code->create();
  361. $this->save->add(self::CODE, $code->code, 600);
  362. }
  363. protected function mcode($mobile, $code = false)
  364. {
  365. if ($code) {
  366. $save = $this->save->get(self::MCODE);
  367. return $mobile . '_' . $code == $save;
  368. }
  369. $day = date('Ymd', time());
  370. # 检测当前手机号最新一次发送时间,不允许一分钟之内发送
  371. $param['option_day'] = $day;
  372. $param['option_mobile'] = $mobile;
  373. # 检测当前手机号今天已经发送多少验证码了
  374. $info = Dever::load('passport/code-total', $param);
  375. if ($info >= 1) {
  376. $check = Dever::load('passport/code-one', $param);
  377. if ($check) {
  378. if (time() - $check['cdate'] < Dever::config('base', 'project')->mobileCode['time']) {
  379. Dever::alert('请不要在一分钟之内申请多次验证码,请您稍后再试');
  380. }
  381. }
  382. }
  383. $total = Dever::config('base', 'project')->mobileCode['total'];
  384. if ($info >= $total) {
  385. Dever::alert('很抱歉,您已经申请获取验证码超过' . $total . '次,今天您已经无法获取验证码了,请您明天再来');
  386. }
  387. $code = new Code();
  388. $code->createM();
  389. # 记录当前的验证码
  390. $insert['add_mobile'] = $mobile;
  391. $insert['add_day'] = $day;
  392. $insert['add_code'] = $code->mcode;
  393. $id = Dever::load('passport/code-insert', $insert);
  394. # 启动发送
  395. $this->send($mobile, $insert['add_code'], $id);
  396. $this->save->add(self::MCODE, $mobile . '_' . $code->mcode, Dever::config('base', 'project')->mobileCode['timeout']);
  397. return $code->mcode;
  398. }
  399. public function send($mobile, $code, $id = false)
  400. {
  401. if (Dever::project('sms')) {
  402. $send['skin'] = 'code';
  403. $send['mobile'] = $mobile;
  404. $send['param'] = array
  405. (
  406. 'code' => $code
  407. );
  408. $send['param'] = Dever::json_encode($send['param']);
  409. return Dever::load('sms/api.send', $send);
  410. }
  411. $url = Dever::config('base', 'project')->mobileCode['url'];
  412. if (!$url) {
  413. return;
  414. }
  415. $content = Dever::config('base', 'project')->mobileCode['body'];
  416. $content = $this->replace($content, $mobile, $code);
  417. parse_str($content, $param);
  418. $type = Dever::config('base', 'project')->mobileCode['method'];
  419. $json = Dever::config('base', 'project')->mobileCode['json'];
  420. $header = Dever::config('base', 'project')->mobileCode['header'];
  421. return Dever::curl($url, $param, $type, $json, $header);
  422. }
  423. private function replace($content, $mobile = '', $code = '')
  424. {
  425. $skin = Dever::config('base', 'project')->mobileCode['skin'];
  426. $skin_key = Dever::input('skin', 'code');
  427. if (isset($skin[$skin_key])) {
  428. $skin = $skin[$skin_key];
  429. } else {
  430. $skin = array_shift($skin);
  431. }
  432. $config = array('{code}', '{mobile}', '{sign}', '{skin}', '{param}');
  433. $replace = array($code, $mobile, Dever::config('base', 'project')->mobileCode['sign'], $skin);
  434. return str_replace($config, $replace, $content);
  435. }
  436. protected function refer($state = false)
  437. {
  438. $refer = Dever::input('refer');
  439. $project = 'main';
  440. if ($refer) {
  441. $refer = Encrypt::decode($refer);
  442. /*
  443. $url = parse_url(Encrypt::decode($refer));
  444. $url['path'] = preg_replace('/^\//', '', $url['path']);
  445. if (!isset($url['query'])) {
  446. $url['query'] = '';
  447. }
  448. if (Uri::$type == '?') {
  449. $refer = Dever::url(str_replace($url['path'] . Uri::$type, '', $url['query']), $project);
  450. } else {
  451. $refer = Dever::url($url['path'] . '?' . $url['query'], $project);
  452. }
  453. */
  454. } else {
  455. $refer = Dever::url('home', $project);
  456. }
  457. $param = Dever::input('param');
  458. if ($param) {
  459. $refer .= '&' . $param;
  460. }
  461. if ($state) {
  462. return $refer;
  463. }
  464. Dever::out($refer);
  465. }
  466. protected function save($user)
  467. {
  468. if (is_numeric($user)) {
  469. $user = Dever::load('passport/user-one', $user);
  470. }
  471. if ($user && is_array($user)) {
  472. if (Dever::mobile()) {
  473. $time = 30;
  474. } else {
  475. $time = 7;
  476. }
  477. $this->save->add(self::NAME, $user, 3600 * 24 * $time);
  478. $user['signature'] = Dever::login($user['id']);
  479. if (Dever::config('base', 'project')->regAction) {
  480. Dever::load(Dever::config('base', 'project')->regAction, $user);
  481. }
  482. return $user;
  483. }
  484. }
  485. public function createRefer()
  486. {
  487. return 'refer=' . Encrypt::encode(Dever::url(false, 'main'));
  488. }
  489. protected function saveSex($sex)
  490. {
  491. if ($sex || $sex == 0) {
  492. $config_sex = Dever::config('base', 'project')->sex;
  493. if (isset($config_sex[$sex])) {
  494. $sex = $config_sex[$sex];
  495. } else {
  496. if ($sex == '男') {
  497. $sex = 1;
  498. } elseif ($sex == '女') {
  499. $sex = 2;
  500. } elseif ($sex == '未知') {
  501. $sex = 3;
  502. }
  503. }
  504. }
  505. return $sex;
  506. }
  507. protected function saveAvatar($value)
  508. {
  509. if (!$value) {
  510. return '';
  511. }
  512. $value = Dever::pic($value);
  513. $base = Dever::data();
  514. $date = explode('-', date("Y-m-d"));
  515. if (is_array($value)) {
  516. $user = $value[1];
  517. $value = $value[0];
  518. if (is_array($value)) {
  519. $name = md5($value['tmp_name'] . rand(0, 100) . microtime());
  520. $path = 'avatar/' . $date[0] . '/' . $date[1] . '/' . $date[2] . '/';
  521. $ext = '.jpg';
  522. $temp = Dever::path($base, $path . $name . $ext);
  523. move_uploaded_file($value['tmp_name'], $temp);
  524. $value = $temp;
  525. }
  526. }
  527. //$result = Dever::$global['host']['img'] . 'chead.jpg';
  528. if ($value) {
  529. # 裁图
  530. $handle = new Img();
  531. $size = '200_200_2';
  532. $user = isset($user) && $user ? $user : $this->init();
  533. if ($user && isset($user['id']) && $user['id']) {
  534. $name = md5($user['id']);
  535. } else {
  536. $name = md5($value . rand(0, 100) . microtime());
  537. }
  538. $path = 'avatar/' . $date[0] . '/' . $date[1] . '/' . $date[2] . '/';
  539. $ext = '.jpg';
  540. $file = Dever::path($base, $path . $name . $ext);
  541. $temp = $file . '.temp.jpg';
  542. //$value = Dever::curl($value);
  543. //file_put_contents($temp, file_get_contents($value));
  544. $file = $handle->thumb($value, $size, true, $file);
  545. if ($file) {
  546. $result = str_replace('/upload/', '/', Dever::config('host')->uploadRes . $path . $name . $ext);
  547. } else {
  548. $result = $value;
  549. }
  550. }
  551. return $result;
  552. }
  553. }