xintian/application/api/controller/Member.php

<?php

namespace app\api\controller;


use app\api\model\MemberHouseModel;
use app\api\model\YzmModel;
use app\common\controller\Api;
use aliyun\api_demo\SmsDemo;
use app\api\model\CodeModel;
use app\api\model\MemberModel;
use app\api\model\AppDataModel;
use app\api\controller\Common;
/**
 * 会员相关接口
 * @ApiWeigh   (100)
 */
class Member extends Api
{
    protected $noNeedLogin = ['yzm','sendCode','register','create_qrcode','login','edit_password','out'];//,'my_keys','my_detail'
    protected $noNeedRight = ['*'];

    /**
     * 生成随机数字验证码图片
     * @ApiRoute    (/api/member/yzm)
     * @ApiReturn   ({
        "code": 1,
        "msg": "success",
        "time": "1603691703",
        "data": {
        "url": "/upload/verification_code_img/member_id_160369170339328.png", //验证码地址
        "rand": "160369170339328"   //标识码，点击发送验证码也要传过来
        }
    })
     */

    function yzm($width = 80,$height = 40)
    {
        $str = '0123456789abcdefghizklmnopqrstuvwxyz'; // 也可取出类似的0il
        $code = substr(str_shuffle($str),0,'4');
        $rand=rand(10000,99999);
        $member_id=time().$rand;
        //判断文件夹是否存在，不存在则创建
        $dir =  ROOT_PATH . 'public' . DS .'uploads/verification_code_img';
        if(!is_dir($dir)){
            mkdir($dir, 0777, true);
        }

        //验证码图片保存路径，文件名称
        $file_name =  ROOT_PATH . 'public' . DS .'uploads/verification_code_img/'.$member_id.'.png';
        //域名返回
        $domain_name = config('site.cdnurl').'/uploads/verification_code_img/'.$member_id.'.png';

        $img = imagecreatetruecolor($width, $height);
        $black = imagecolorallocate($img, 0x00, 0x00, 0x00);
        $green = imagecolorallocate($img, 0x00, 0xFF, 0x00);
        $white = imagecolorallocate($img, 0xFF, 0xFF, 0xFF);
        imagefill($img,0,0,$white);

        imagestring($img, 5, 22, 12, $code, $black);
        //加入噪点干扰
        for($i=0;$i<100;$i++) {
            imagesetpixel($img, rand(0, $width) , rand(0, $width) , $black);  //imagesetpixel — 画一个单一像素，语法: bool imagesetpixel ( resource $image , int $x , int $y , int $color )
            imagesetpixel($img, rand(0, $width) , rand(0, $width) , $green);
        }

        //输出验证码
//        header("content-type: image/png");
        imagepng($img,$file_name);  //保存图片
        imagedestroy($img);  //图像处理完成后，使用 imagedestroy() 指令销毁图像资源以释放内存，虽然该函数不是必须的，但使用它是一个好习惯。

        $log = ['code' => $code,
            'rand' => $member_id,
            'scene' => '图形验证码',
            'time' => datetime(time())
        ];
        $addLog = YzmModel::create($log);

        $this->result('success', ['url'=>$domain_name,'rand'=>$member_id], 1);
    }

    /**
     * 发送短信验证码
     *
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/member/sendCode)
     * @ApiParams   (name="mobile", type="varchar", required=true, description="用户手机号")
     * @ApiParams   (name="rand", type="string", required=true, description="标识码")
     * @ApiParams   (name="code", type="string", required=true, description="输入的图形验证码")
     * @ApiParams   (name="scene", type="string", required=true, description=" 1 注册发送验证码，2 找回密码验证码")
     * @ApiReturn   ({
        'code':'1',    //0是失败，弹出msg提示
        'msg':'验证码已发送'
        })
     */

    public function sendCode()
    {
        $mobile = $this->request->post('mobile');
        $rand= $this->request->post('rand');
        $code= $this->request->post('code');
        $scene= $this->request->post('scene');

        if (empty($code)){
            $this->result('请输入图形验证码');
        }
        if (!$mobile || !$rand || !$code) {
            $this->result('参数错误');
        }
        if (empty($scene)){
            $scene=1;
        }

       // $ip=get_ip();


        $check_code = CodeModel::where('mobile', $mobile)->where('scene',$scene)
            ->order('id desc')
            ->find();

        $sendTime = strtotime($check_code['time']);
        if (time() - $sendTime < 300) {
            $this->result('5分钟之后才可以发送');
        }

        $get_yzm=YzmModel::where('rand',$rand)->where('status','0')->order('id','desc')->find();
        if (empty($get_yzm)){
            $this->result('图形验证码错误!');
        }
        $sendTime = strtotime($get_yzm['time']);
        if (time() - $sendTime > 300) {//分钟过期
            $this->result('图形验证码已过期');
        }
        if ($code !=$get_yzm['code']){
            $this->result('图形验证码错误');
        }else{
            YzmModel::where('id',$get_yzm['id'])->update(['status'=>'1']);
        }

        $code = rand(1000, 9999);
        $Sms = new SmsDemo();
        $send = $Sms->sendSms($mobile, $code);
        if ($send->Message == 'OK') {
            $log = ['code' => $code,
                'mobile' => $mobile,
                'scene' =>$scene,
                'time' => datetime(time())
            ];
            $addLog = CodeModel::create($log);
            if ($addLog) {
                $this->result('验证码已发送', [], 1);
            } else {
                $this->result('验证码发送失败');
            }
        } else {
            $this->result('验证码发送失败');
        }
//        $log = ['code' => '1234',
//                'mobile' => $mobile,
//                 'scene' =>$scene,
//                'time' => datetime(time())
//            ];
//            $addLog = CodeModel::create($log);
//            if ($addLog) {
//                $this->result('验证码已发送', [], 1);
//            } else {
//                $this->result('验证码发送失败');
//            }

    }

       /**
     * 用户注册
     *
     * @ApiTitle    (用户注册)
     * @ApiSummary  (用户注册)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/member/register)
     * @ApiParams   (name="mobile", type="varchar", required=true, description="用户手机号")
     * @ApiParams   (name="check_code", type="int", required=true, description="短信验证码")
     * @ApiParams   (name="password", type="int", required=true, description="密码")
     */
    public function register()
    {
        $mobile = $this->request->post('mobile');
        $checkCode = $this->request->post('check_code');
        $password = $this->request->post('password');
        if (!$mobile || !$checkCode || !$password) {
            $this->result('参数错误');
        }


        //   验证验证码
        $check_code = CodeModel::where('mobile', $mobile)->where('scene','1')
            ->order('id desc')
            ->limit(0, 1)
            ->select();
        if (empty($check_code)) {
            $this->result('验证码错误');
        }
        if ($check_code[0]['code'] != $checkCode) {
            $this->result('验证码错误');
        }
        $sendTime = strtotime($check_code[0]['time']);
        if (time() - $sendTime > 300) {//5分钟过期时间
            $this->result('验证码已过期');
        }


        $get_is_user=MemberModel::where('mobile', $mobile)->field('id')->find();
        if (!empty($get_is_user)){
            $this->result('手机号已经注册，请直接登录或者找回密码');
        }else{
            $where = ['id' => 1];
            $defaultField = ['default_nickname', 'default_avatar'];
            $default = AppDataModel::where($where)->field($defaultField)->find();//-----------

            $info = [
                'avatar' => $default['default_avatar'],
                'nickname' => substr_replace($mobile,'****',3,4),//$default['default_nickname'],
                'name' => substr_replace($mobile,'****',3,4),
                'mobile' => $mobile,
                'rands' =>createSalt(),
                'password'=>md5(trim($password)),
                'create_time' => datetime(time()),
            ];

            $createId = MemberModel::insertGetId($info);
            if ($createId) {
                $this->result('恭喜你成功注册新天物业', ['user_id' => intval($createId)], 1);

                //  MemberModel::where('mobile', $mobile)->setInc('login_num', 1);
                // 生成token
//                $salt = createSalt();
//                $token = md5($createId.$salt);
//                // 更新token和随机码salt
//                $updateToken = MemberModel::where('mobile', $mobile)
//                    ->update(['salt' => $salt, 'token' => $token]);
//                if ($updateToken) {
//                    if (!empty($top_id)){
//                        MemberModel::where('id', $top_id)->setInc('down_people');
//                    }
//
//                 //   $this->result('恭喜你成功注册新天物业', ['user_id' => intval($createId), 'token' => $token,'rands'=>$info['rands']], 1);
//                } else {
//                    $this->result('登录失败', null, 0);
//                }
            } else {
                $this->result('注册失败', null, 0);
            }

        }
    }

    /**
     * 用户登录
     *
     * @ApiTitle    (用户登录)
     * @ApiSummary  (用户登录)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/member/login)
     * @ApiParams   (name="mobile", type="varchar", required=true, description="用户手机号")
     * @ApiParams   (name="password", type="int", required=true, description="密码")
     */
    public function login()
    {
        $mobile = $this->request->post('mobile');
        $password = $this->request->post('password');
        if (!$mobile || !$password) {
            $this->result('参数错误');
        }

        $user = MemberModel::where('mobile', $mobile)->where('password',md5(trim($password)))->field('id,rands')->find();
        if (!$user){
            $this->result('账号或密码错误，请重新登录');
        }else{
            $get_hu=MemberHouseModel::where('mid',$user['id'])->where('is_delete','0')->field('id')->find();
            if (empty($get_hu)){
                $user['hu_id']=0;
            }else{
                $user['hu_id']=$get_hu['id'];
            }
            MemberModel::where('id', $user['id'])->setInc('login_num', 1);
            // 生成token
            $salt = createSalt();
            $token = md5($user['id'].$salt);
            // 更新token和随机码salt
            $updateToken = MemberModel::where('mobile', $mobile)
                ->update(['salt' => $salt, 'token' => $token]);
            if ($updateToken) {
                $this->result('登录成功',['user_id' => $user['id'], 'token' => $token,'rands'=>$user['rands'],'hu_id'=>$user['hu_id']], 1);
            } else {
                $this->result('登录失败', null, 0);
            }
        }
    }

    /**
     * 找回密码
     *
     * @ApiTitle    (找回密码)
     * @ApiSummary  (找回密码)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/member/edit_password)
     * @ApiParams   (name="mobile", type="varchar", required=true, description="用户手机号")
     * @ApiParams   (name="check_code", type="int", required=true, description="短信验证码")
     * @ApiParams   (name="password", type="int", required=true, description="密码")
     */
    public function edit_password()
    {
        $mobile = $this->request->post('mobile');
        $checkCode = $this->request->post('check_code');
        $password = $this->request->post('password');
        if (!$mobile || !$checkCode || !$password) {
            $this->result('参数错误');
        }

        //   验证验证码
        $check_code = CodeModel::where('mobile', $mobile)->where('scene','2')
            ->order('id desc')
            ->limit(0, 1)
            ->select();
        if (empty($check_code)) {
            $this->result('验证码错误');
        }
        if ($check_code[0]['code'] != $checkCode) {
            $this->result('验证码错误');
        }
        $sendTime = strtotime($check_code[0]['time']);
        if (time() - $sendTime > 300) {//5分钟过期时间
            $this->result('验证码已过期');
        }

        $user = MemberModel::where('mobile', $mobile)->field('id,rands')->find();
        if (empty($user)){
            $this->result('您的手机号还未注册用户，请注册');
        }
        MemberModel::where('id', $user['id'])->setInc('login_num', 1);
        // 生成token
        $salt = createSalt();
        $token = md5($user['id'].$salt);
        // 更新token和随机码salt
        $updateToken = MemberModel::where('mobile', $mobile)
            ->update(['salt' => $salt, 'token' => $token,'password'=>md5(trim($password))]);
        if ($updateToken) {
            $this->result('密码修改成功',['user_id' => $user['id'], 'token' => $token,'rands'=>$user['rands']], 1);
        } else {
            $this->result('登录失败', null, 0);
        }


    }

    /**
     * 我的信息
     *
     * @ApiTitle    (我的信息)
     * @ApiSummary  (我的信息)
     * @ApiMethod   (POST)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiRoute    (/api/member/my_detail)
     * @ApiParams   (name="user_id", type="int", required=true, description="用户id")
     * @ApiParams   (name="token", type="int", required=true, description="请求的Token")
     * @ApiParams   (name="house_id", type="int", required=true, description="房产id")
     * @ApiReturn   ({
        "code": 1,
        "msg": "success",
        "time": "1604474877",
        "data": {
            "id": 1,//用户id
            "top_id": 0,
            "top_top_id": 0,
            "rands": "igqwpg",
            "avatar": "http://baoxiang.com//assets/img/qrcode.png",//用户头像
            "nickname": "默认昵称 ",//昵称
            "name": "",
            "price": null,
            "profile": "",
            "mobile": "13512144196",
            "wx_code": "",
            "sex": 0,
            "openid": "",
             "now_money": "0.00",//当前余额
            "down_people": 0,//下级人数
            "create_time": "2020-11-02 09:43:10",
            "login_num": 9,
            "status": 1,
            "salt": "pjxwqm",
            "token": "70780f043d7ffaf239c73095d5a2f808"
        }
    })
     */
    public function my_detail(){
        $userId = $this->request->post('user_id');
        $house_id = $this->request->post('house_id');
        if (empty($userId)){
            $this->result('登录信息丢失');
        }
        //
        $my=MemberModel::where(['id'=>$userId])->find();
        if (!empty($house_id)){
            $where['id']=$house_id;
        }
        $where['mid']=$userId;
        $where['is_delete']='0';
        $list=MemberHouseModel::where($where)
            ->with(['property','village','dong','danyuan','hu'])
            ->find();
        $my['house']='';
        if (!empty($list)){
            $my['house']=$list['village']['name'].$list['dong']['name'].$list['danyuan']['name'].$list['hu']['name'];
        }

        $this->result('success', $my, 1);

    }
    /**
     * 修改信息-昵称+头像
     *
     * @ApiTitle    (修改信息-昵称+头像)
     * @ApiSummary  (修改信息-昵称+头像)
     * @ApiMethod   (POST)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiRoute    (/api/member/my_edit)
     * @ApiParams   (name="user_id", type="int", required=true, description="用户id")
     * @ApiParams   (name="token", type="int", required=true, description="请求的Token")
     * @ApiParams   (name="nickname", type="string", required=true, description="昵称")
     * @ApiParams   (name="avatar", type="string", required=true, description="头像地址")
     * @ApiParams   (name="sex", type="string", required=true, description="未知，男，女")
     * @ApiReturn   ()
     */
    public function my_edit(){
        $userId = $this->request->post('user_id');
        $nickname= $this->request->post('nickname');
        $avatar = $this->request->post('avatar');
        $sex = $this->request->post('sex');
        if (empty($userId)){
            $this->result('登录信息丢失');
        }
        $update=[];
        if (!empty($nickname)){
            $update['name']=$update['nickname']=preg_replace('/[\xf0-\xf7].{3}/', '', trim($nickname));
        }
        if (!empty($avatar)){
            $update['avatar']=$avatar;
        }
        if (!empty($sex)){
            $update['sex']=$sex;
        }else{
            $update['sex']='未知';
        }
        if (!empty($update)){
            MemberModel::where(['id'=>$userId])->update($update);
            $this->result('信息修改成功', [], 1);
        }else{
            $this->result('没修改任何信息');
        }


    }

    /**
     * 微信登录
     *
     * @ApiTitle    (微信登录)
     * @ApiSummary  (微信登录)
     * @ApiMethod   (POST)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiRoute    (/api/member/wx_login)
     * @ApiParams   (name="user_id", type="int", required=true, description="用户id")
     * @ApiParams   (name="token", type="int", required=true, description="请求的Token")
     * @ApiParams   (name="code", type="int", required=true, description="微信code")
     * @ApiReturn   ()
     */
    public function wx_login()
    {
        $userId = $this->request->post('user_id');

        if (empty($userId)){
            $this->result('登录信息丢失');
        }
        $code = $this->request->post('code');
        if (!isset($code)) {
            return $this->result('未接收到code', []);
        }

        $appid = 'wxdbf57a855b519ecf';
        $appsecret = '87dc4671be6b63697a0048767924e94d';


        $access_token_url = 'https://api.weixin.qq.com/sns/oauth2/access_token?appid=' . $appid . '&secret=' . $appsecret . '&code=' . $code . '&grant_type=authorization_code';

        $tokens =$this->http_curl($access_token_url);

        if (isset($tokens['openid'])) {
            $member=MemberModel::where('id',$userId)->update(['openid'=>$tokens['openid']]);
            return $this->result('success', '', 200);
        } else {
            return $this->result($tokens);
        }

    }

    /**
     * 我的房屋列表
     *
     * @ApiTitle    (我的房屋列表)
     * @ApiSummary  (我的房屋列表)
     * @ApiMethod   (POST)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiRoute    (/api/member/my_house_list)
     * @ApiParams   (name="user_id", type="int", required=true, description="用户id")
     * @ApiParams   (name="token", type="int", required=true, description="请求的Token")
     * @ApiParams   (name="type", type="int", required=false, description="all  只有我的房屋列表才传值")
     * @ApiReturn   ()
     */
    public function my_house_list(){
        $userId = $this->request->post('user_id');
        if (empty($userId)){
            $this->result('登录信息丢失');
        }
        $type = $this->request->post('type');

        if (empty($type)){
            $where['status']='1';
        }

        $where['is_delete']='0';
        $list=MemberHouseModel::where(['mid'=>$userId])
            ->where($where)
            ->with(['property','village','dong','danyuan','hu'])
            ->field('id,mid,property_id,village_id,dong_id,danyuan_id,hu_id,status')
            ->select();
        foreach ($list as $k=>$v){
            $list[$k]['house']=$v['property']['name']." ".$v['village']['name']." ".$v['danyuan']['name']." ".$v['hu']['name'];
        }
        $this->result('房屋列表', $list, 1);
    }
    /**
     * 绑定住房信息
     *
     * @ApiTitle    (绑定住房信息)
     * @ApiSummary  (绑定住房信息)
     * @ApiMethod   (POST)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiRoute    (/api/member/my_house_add)
     * @ApiParams   (name="user_id", type="int", required=true, description="用户id")
     * @ApiParams   (name="token", type="int", required=true, description="请求的Token")
     * @ApiParams   (name="property_id", type="int", required=true, description="物业id")
     * @ApiParams   (name="village_id", type="int", required=true, description="小区id")
     * @ApiParams   (name="dong_id", type="int", required=true, description="楼宇id")
     * @ApiParams   (name="danyuan_id", type="int", required=true, description="单元id")
     * @ApiParams   (name="hu_id", type="int", required=true, description="户id")
     * @ApiParams   (name="name", type="int", required=true, description="姓名")
     * @ApiParams   (name="phone", type="int", required=true, description="电话")
     * @ApiReturn   ()
     */
    public function my_house_add(){
        $userId = $this->request->post('user_id');
        if (empty($userId)){
            $this->result('登录信息丢失');
        }
        $property_id = $this->request->post('property_id');
        $village_id = $this->request->post('village_id');
        $dong_id = $this->request->post('dong_id');
        $danyuan_id = $this->request->post('danyuan_id');
        $hu_id= $this->request->post('hu_id');
        $name= $this->request->post('name');
        $phone= $this->request->post('phone');
        $update=[
            'property_id'=>$property_id,
            'village_id'=>$village_id,
            'dong_id'=>$dong_id,
            'danyuan_id'=>$danyuan_id,
            'hu_id'=>$hu_id,
            'name'=>$name,
            'phone'=>$phone,
            'status'=>'0',
            'mid'=>$userId,
            'createtime'=>time(),
            'updatetime'=>time()
        ];

        MemberHouseModel::insert($update);
        $this->result('住房绑定成功', '', 1);
    }

    /**
     * 解绑住房信息
     *
     * @ApiTitle    (解绑住房信息)
     * @ApiSummary  (解绑住房信息)
     * @ApiMethod   (POST)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiRoute    (/api/member/my_house_del)
     * @ApiParams   (name="user_id", type="int", required=true, description="用户id")
     * @ApiParams   (name="token", type="int", required=true, description="请求的Token")
     * @ApiParams   (name="house_id", type="int", required=true, description="住房绑定列表id")
     * @ApiReturn   ()
     */
    public function my_house_del(){
        $userId = $this->request->post('user_id');
        if (empty($userId)){
            $this->result('登录信息丢失');
        }
        $house_id = $this->request->post('house_id');


        MemberHouseModel::where(['mid'=>$userId,'id'=>$house_id])->update(['is_delete'=>'1']);
        $this->result('住房解绑成功', '', 1);
    }

    /**
     * 退出登录
     *
     * @ApiTitle    (退出登录)
     * @ApiSummary  (退出登录)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/member/out)
     * @ApiParams   (name="user_id", type="int", required=true, description="用户id")
     * @ApiParams   (name="token", type="int", required=true, description="请求的Token")
     */
    public function out()
    {
        $userId = $this->request->post('user_id');
        if (empty($userId)){
            $this->result('成功退出','', 1);
        }


        $updateToken = MemberModel::where('id', $userId)
            ->update(['salt' => '0', 'token' => '0']);
        $this->result('成功退出','', 1);
    }

    function http_curl($url, $type = 'get', $res = 'json', $arr = '')
    {
        //1.初始化curl
        $ch = curl_init();
        //2.设置curl的参数
        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);
        //    curl_setopt($ch, CURLOPT_HTTPHEADER, array(' Accept-Ranges:bytes Cache-control:max-age=604800 Connection:keep-alive Content-Length:28026 Content-Type:image/jpg Date:Wed, 16 Oct 2013 06:37:10 GMT Expires:Wed, 23 Oct 2013 14:37:10 +0800 Server:nginx/1.4.1'));
        //3.采集
        $output = curl_exec($ch);
        //4.关闭
        curl_close($ch);
        if ($res == 'json') {
            return json_decode($output, true);
        }
        return $output;
    }

}