passport/src/Applet.php

<?php
namespace Passport\Src;

use Dever;
use Passport\Lib\Base;

# 小程序

class Applet extends Base
{
  	public function init()
    {
      	$uid = $this->check();
        $user = Dever::load('passport/user-one', $uid);

        return $user;
    }
    /**
     * 用户绑定 生成用户信息
     *
     * @return mixed
     */
    public function bind()
    {
        $token = Dever::project('token');
        $applet = array();

        $system = Dever::input('system', 1);

        $config = Dever::config('base', 'project')->applet;

        if ($token) {
            $applet = Dever::db('token/project')->one($system);
        }

        if (!$applet) {
            if (isset($config['project']) && $config['project']) {
                $applet = Dever::db($config['project'])->one($system);
            } else {
                $applet = $config;
            }
        }

        if (!$applet) {
            Dever::alert('错误的appid');
        }

        $appid = $applet['appid'];
        $secret = $applet['secret'];
        $url = $config['url'];
        $code = Dever::input('code');

        $url .= '?appid=' . $appid;
        $url .= '&secret=' . $secret;
        $url .= '&js_code=' . $code;
        $url .= '&grant_type=authorization_code';

        $data = Dever::curl($url);
        Dever::log($data, 'passport_applet');
        if (strstr($data, 'errcode')) {
            Dever::alert($data);
        }

        //YzJkOThpRFhwZ1lQTF9mZl9hLVZjZnFXemJVenlYcDQ3d3JWekk0b1I4NjBBQ0Naejg4a0VQa0U=
        //$data = '{"session_key":"aNAXk7nG\/DRYI\/G0KzJRsw==","openid":"oIZ895RZs2ZkywasoZIv6WavPZlQ"}';
        $data = Dever::json_decode($data);

        $user = $this->create($data);

        return $user;
    }

    /*
    public function test_sms()
    {
        $uid = Dever::input('uid');
        $mobile = Dever::input('mobile');
        $state = Dever::config('base', 'project')->regSendSms;
        if ($state) {
            Dever::setInput('skin', $state);
            $this->send($mobile, $uid);
        }
    }
    */

    /**
     * 生成用户，返回uid
     *
     * @return int
     */
    private function create($data)
    {
        $uid = false;
        $system = Dever::input('system', 1);
        $info = Dever::load('passport/wechat-one', array('option_openid' => $data['openid']));

        if (!$info) {
            if (isset($data['unionid']) && $data['unionid']) {
                $info = Dever::load('passport/wechat-one', array('unionid' => $data['unionid']));
                if (!$info) {
                    $uid = false;
                } else {
                    # 判断用户是否存在，是否需要合并
                    $uid = $this->combine($info['uid'], $data['unionid']);
                }
                $wechat['unionid'] = $data['unionid'];
            }
            if (!$uid) {
                $user['bind'] = 2;
                $user['temp'] = 1;
                $user['username'] = '临时用户';
                $user['source_type'] = 'applet';
                $user['system_id'] = $system;

                $uid = Dever::load('passport/user-insert', $user);

                Dever::load('passport/lib/base')->createUsername($uid, $user['username'], true);
            }
             
            $wechat['openid'] = $data['openid'];
            $wechat['session_key'] = $data['session_key'];
            $wechat['uid'] = $uid;
            $wechat['type'] = 1;
            $wechat['system_id'] = $system;
            $id = Dever::load('passport/wechat-insert', $wechat);
        } else {
            $uid = $info['uid'];
            if (isset($data['unionid']) && $data['unionid']) {
                $wechat['unionid'] = $data['unionid'];
                # 判断用户是否存在，是否需要合并
                $wechat['uid'] = $this->combine($uid, $data['unionid']);
            }
            
            $wechat['session_key'] = $data['session_key'];
            $wechat['where_id'] = $info['id'];
            $id = $info['id'];
            Dever::load('passport/wechat-update', $wechat);
        }

        $user = Dever::load('passport/user-one', $uid);

        $result['vid'] = $id;
        $result['uid'] = $uid;
        $result['signature'] = Dever::login($uid);
      
      	if ($user['mobile']) {
        	$result['mobile'] = $user['mobile'];
        }

        return $result;
    }

    /**
     * 更新用户信息 手机号
     *
     * @return mixed
     */
    public function mobile()
    {
        $uid = $this->check();
        $vid = Dever::input('vid');
        $result = array();
        $mobile = $phoneNumber = '';

        $iv = Dever::input('iv');
        $encryptedData = Dever::input('encryptedData');
        
        if ($iv && $encryptedData) {
            $vinfo = Dever::load('passport/wechat-one', $vid);
            $data = $this->decryptData($vinfo['session_key']);
            if ($data && isset($data->purePhoneNumber) && isset($data->phoneNumber)) {
                $mobile = $data->purePhoneNumber;
                $phoneNumber = $data->phoneNumber;
            }
        }

        if ($mobile && $phoneNumber && $uid) {
            $uid = $this->combine($uid, $mobile, 'mobile');

            $info = Dever::load('passport/user-one', $uid);
            $result['mobile'] = $mobile;
            if ($info) {

                if (!$info['mobile']) {
                    Dever::score($uid, 'bind_mobile', '绑定手机号');
                }
                $update['set_mobile'] = $mobile;
                $update['set_bind'] = 1;
                $update['where_id'] = $uid;
                Dever::load('passport/user-update', $update);

                $state = Dever::config('base', 'project')->regSendSms;
                if ($state) {
                    Dever::setInput('skin', $state);
                    $this->send($mobile, $uid);
                }
            } else {
                Dever::alert('无效的用户id,请重新登录');
            }
        }

        

        $result['vid'] = $vid;
        $result['uid'] = $uid;
        $result['signature'] = Dever::login($uid);

        return $result;
    }

    /**
     * 更新用户信息
     *
     * @return mixed
     */
    public function update()
    {
        $uid = $this->check();
        $name = Dever::emoji(Dever::input('nickname'));
        $pic = Dever::input('avatarurl');
        $sex = Dever::input('gender');
        $city = Dever::input('city');
        $mobile = Dever::input('mobile');
        $province = Dever::input('province');
        $country = Dever::input('country');
        $vid = Dever::input('vid');

        $update['temp'] = 3;
        if ($vid) {
            $vinfo = Dever::load('passport/wechat-one', $vid);

            $unionid = $this->unionid($vinfo['session_key']);
            if ($unionid) {
                $vinfo = Dever::load('passport/wechat-one', array('option_unionid' => $unionid));
                if (!$vinfo) {
                    $wechat['set_unionid'] = $unionid;
                    $wechat['where_id'] = $vid;
                    Dever::load('passport/wechat-update', $wechat);
                } elseif ($vinfo && $vinfo['id'] != $vid) {
                    $wechat['set_unionid'] = $unionid;
                    $uid = $this->combine($uid, $unionid);
                    $wechat['set_uid'] = $uid;
                    $wechat['where_id'] = $vid;
                    Dever::load('passport/wechat-update', $wechat);
                }
                
                $update['temp'] = 2;
            }
        }

        $info = Dever::load('passport/user-one', $uid);
        if ($info) {

            if ($info['temp'] == 1) {
                Dever::score($uid, 'bind_wechat', '用户微信授权');
            }
            $update['temp'] = 2;

            $update['set_username'] = Dever::load('passport/lib/base')->createUsername($uid, $name);
            
            if ($sex == 1) {
                $update['set_sex'] = 1;
            } elseif ($sex == 2) {
                $update['set_sex'] = 2;
            } else {
                $update['set_sex'] = 3;
            }
            /*
            if ($sex || $sex == 0) {
                $update['set_sex'] = $this->saveSex($sex);
            }
            */
            
            if ($pic) {
                //$update['set_avatar'] = $this->saveAvatar($pic);
              	$update['set_avatar'] = $pic;
            }
            
            if ($city) {
                $update['set_city'] = $city;
            }
            
            //$update['set_mobile'] = $mobile;
            if ($province) {
                $update['set_province'] = $province;
            }
            
            if ($country) {
                $update['set_country'] = $country;
            }
            
            if ($country && $province && $city) {
                $update['set_area'] = $country . ',' . $province . ',' . $city;
            }
            if (isset($update) && $update) {
                $update['where_id'] = $uid;
                Dever::load('passport/user-update', $update);
            }
            
        } else {
            Dever::alert('无效的用户id,请重新登录');
        }

        $result['vid'] = $vid;
        $result['uid'] = $uid;
        $result['signature'] = Dever::login($uid);

        return $result;
    }

    private function unionid($session_key)
    {
        $data = $this->decryptData($session_key);
        if ($data && isset($data->unionId)) {
            return $data->unionId;
        }
        
        return false;
    }

    private function decryptData($session_key)
    {
    	$iv = Dever::input('iv');
        $encryptedData = Dever::input('encryptedData');

        if (!$iv || !$encryptedData) {
        	return false;
        }
        if (strlen($session_key) != 24) {
            return false;
        }
        if (strlen($iv) != 24) {
            return false;
        }

        $aesKey = base64_decode($session_key);

        $aesIV = base64_decode($iv);

        $aesCipher = base64_decode($encryptedData);

        $result = openssl_decrypt($aesCipher, "AES-128-CBC", $aesKey, 1, $aesIV);

        $dataObj = json_decode($result);
        if ($dataObj  == NULL) {
            return false;
        }
        /*
      	$applet = Dever::config('base', 'project')->applet;
        $appid = $applet['appid'];
        if($dataObj->watermark->appid != $appid) {
            return false;
        }*/
        return $dataObj;
    }
}