tken/application/api/controller/Index.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use think\Db;
use think\Cache;
/**
 * 首页接口
 */
class Index extends Api
{
    protected $noNeedLogin = ['index'];
    protected $noNeedRight = ['*'];



    public function index(){
        echo 'apisuccess';
        exit;
    }

    //附近
    //是vip，且开启了隐身的，不能在内
    public function fujin(){
        $cityname = input('cityname','');
        if(empty($cityname)){
            $cityname = $this->auth->cityname;
        }

        $where = [
            'user.id' => ['neq',$this->auth->id],
            'user.status' => 1,
            'user.cityname' => $cityname,
            'power.yinshen' => 0,
        ];

        //性别
        $gender = input('gender','all');
        if($gender != 'all'){
            $where['user.gender'] = $gender;
        }
        //属性
        $attribute = input('attribute','all');
        if($attribute != 'all' && $attribute != 'BOTH'){
            $where['user.attribute'] = $attribute;
        }
        //排除黑名单的
        $where_black = [];
        $black_ids = Db::name('user_black')->where(['uid'=>$this->auth->id])->column('black_uid');
        if(!empty($black_ids)){
            $where_black['user.id'] = ['NOTIN',$black_ids];
        }
        //年龄
        $agemin = input('agemin',18);
        if($agemin > 18){
            $where['user.birthday'] = ['lt',time()-$agemin*31536000];
        }
        $agemax = input('agemax',100);
        if($agemax < 100){
            $where['user.birthday'] = ['gt',time()-$agemax*31536000];
        }
        if($agemin > 18 && $agemax < 100){
            $where['user.birthday'] = ['between',[time()-$agemax*31536000,time()-$agemin*31536000]];
        }
        //距离
        $having_dis = '';
        $distancemin = input('distancemin',0);
        if($distancemin > 0){
            $having_dis = 'distance > '.$distancemin*1000;
        }
        $distancemax = input('distancemax',100);
        $distancemax = $distancemax > 100 ? 100 : $distancemax;//最大100
        if($distancemax > 0){
            $having_dis = 'distance < '.$distancemax*1000;
        }
        if($distancemin > 0 && $distancemax > 0){
            $having_dis = 'distance > '.$distancemin*1000 .' and distance < '.$distancemax*1000;
        }

        //当异地漫游的时候，距离条件作废
        if($cityname != $this->auth->cityname){
            $having_dis = '';
        }

        $field = [
            'user.id',
            'user.username',
            'user.nickname',
            'user.avatar',
            'user.photo_images',
            'user.gender',
            'user.birthday',
            'user.cityname',
            'user.longitude',
            'user.latitude',
            'user.attribute',
            'user.is_active',

            'wallet.vip_endtime',
            '(st_distance(point (' . $this->auth->longitude . ', ' . $this->auth->latitude . '),point(user.longitude,user.latitude))*111195) as distance',
            'active.requesttime',
        ];
        $list = Db::name('user')->alias('user')->field($field)
            ->join('user_wallet wallet','user.id = wallet.user_id','LEFT')
            ->join('user_power power' ,'user.id = power.user_id','LEFT')
            ->join('user_active active' ,'user.id = active.user_id','LEFT')
            ->where($where)
            ->where($where_black)
            ->having($having_dis)
            ->order('user.is_active desc,distance asc,user.id desc')
            ->autopage()
            ->select();
        $list = list_domain_image($list,['avatar','photo_images']);
        foreach($list as $key => &$val){
            $val['age'] = birthtime_to_age($val['birthday']);
            $val['photo_images'] = explode(',',$val['photo_images'])[0];
            $val['is_vip'] = $val['vip_endtime'] > time() ? 1 : 0;

            $val['distance'] = bcdiv(intval($val['distance']),1000,1).'km';
            if($this->auth->longitude == 0 || $val['longitude'] == 0){
                $val['distance'] = '未知';
            }

            $val['active_info'] = $this->user_activeinfo($val['id'],$val['requesttime']);

            //vip如果开了隐私保护，需要隐藏距离
            $yinsi = $this->user_power($val['id'],'yinsi');
            if($yinsi == 1){
                $val['distance'] = '';
            }

        }

        $this->success(1,$list);
    }

    //推荐
    //真人认证的，是推荐用户的，可能也要限制vip的
    public function tuijian(){
        /*$cityname = input('cityname','');
        if(empty($cityname)){
            $cityname = $this->auth->cityname;
        }*/

        //强制条件
        $where = [
            'user.id' => ['neq',$this->auth->id],
            'user.status' => 1,
            'power.yinshen' => 0,
        ];

        //搜索条件 性别
        $gender = input('gender','all');
        if($gender != 'all'){
            $where['user.gender'] = $gender;
        }
        //搜索条件 属性
        $attribute = input('attribute','all');
        if($attribute != 'all' && $attribute != 'BOTH'){
            $where['user.attribute'] = $attribute;
        }

        //搜索条件 年龄
        $agemin = input('agemin',18);
        if($agemin > 18){
            $where['user.birthday'] = ['lt',time()-$agemin*31536000];
        }
        $agemax = input('agemax',100);
        if($agemax < 100){
            $where['user.birthday'] = ['gt',time()-$agemax*31536000];
        }
        if($agemin > 18 && $agemax < 100){
            $where['user.birthday'] = ['between',[time()-$agemax*31536000,time()-$agemin*31536000]];
        }

        //排除黑名单的
        $where_black = [];
        $black_ids = Db::name('user_black')->where(['uid'=>$this->auth->id])->column('black_uid');
        if(!empty($black_ids)){
            $where_black['user.id'] = ['NOTIN',$black_ids];
        }

        //其他条件  与 推荐条件是 或的关系
        $where_other = [
            'user.avatar' => ['neq',''],
            'user.idcard_status' => 1,
        ];

        if(config('site.index_tuijian_vip_limit') == 1){
            $where_other['wallet.vip_endtime'] = ['gt',time()];
        }

        //选择了推荐，就强制推荐
        $where_tuijian = [
            'user.is_tuijian'    => 1,
        ];


        //距离
        $having_dis = '';
        $distancemin = input('distancemin',0);
        if($distancemin > 0){
            $having_dis = 'distance > '.$distancemin*1000;
        }
        $distancemax = input('distancemax',0);
        if($distancemax > 0){
            $having_dis = 'distance < '.$distancemax*1000;
        }
        if($distancemin > 0 && $distancemax > 0){
            $having_dis = 'distance > '.$distancemin*1000 .' and distance < '.$distancemax*1000;
        }

        $field = [
            'user.id',
            'user.username',
            'user.nickname',
            'user.avatar',
            'user.photo_images',
            'user.gender',
            'user.birthday',
            'user.cityname',
            'user.longitude',
            'user.latitude',
            'user.attribute',
            'user.is_active',

            'wallet.vip_endtime',
            '(st_distance(point (' . $this->auth->longitude . ', ' . $this->auth->latitude . '),point(user.longitude,user.latitude))*111195) as distance',
            'active.requesttime',
        ];
        $list = Db::name('user')->alias('user')->field($field)
            ->join('user_wallet wallet','user.id = wallet.user_id','LEFT')
            ->join('user_power power' ,'user.id = power.user_id','LEFT')
            ->join('user_active active' ,'user.id = active.user_id','LEFT')
            ->where($where)
            ->where($where_black)
            ->where(
                function($query)use($where_other,$where_tuijian){
                    $query->where(
                        function($query)use($where_other){
                        $query->where($where_other);
                        }
                    );
                    $query->whereOr($where_tuijian);
            })
            //->having($having_dis)推荐完全不受距离限制
            ->order('user.is_active desc,distance asc')
            ->autopage()
            ->select();

        $list = list_domain_image($list,['avatar','photo_images']);
        foreach($list as $key => &$val){
            $val['age'] = birthtime_to_age($val['birthday']);
            $val['photo_images'] = explode(',',$val['photo_images'])[0];
            $val['is_vip'] = $val['vip_endtime'] > time() ? 1 : 0;

            $val['distance'] = bcdiv(intval($val['distance']),1000,1).'km';
            if($this->auth->longitude == 0 || $val['longitude'] == 0){
                $val['distance'] = '未知';
            }

            $val['active_info'] = $this->user_activeinfo($val['id'],$val['requesttime']);
            
            //vip如果开了隐私保护，需要隐藏距离
            $yinsi = $this->user_power($val['id'],'yinsi');
            if($yinsi == 1){
                $val['distance'] = '';
            }
        }

        $this->success(1,$list);
    }

    //匹配配置
    public function pipei_config(){
        $result = [
            'index_pipei_switch' => config('site.index_pipei_switch'), //匹配开关
        ];

        //首页匹配每天每人匹配次数
        $user_id = $this->auth->id;
        $is_vip = $this->is_vip($this->auth->id);
        $times_limit = $is_vip == 1 ? config('site.pipei_oneday_vipuser_times') : config('site.index_pipei_oneday_user_times');

        $times_limit_redis = 'pipei_times_limit_'.$user_id;
        $user_times = Cache::get($times_limit_redis) ?: 0;

        if($times_limit > -1){
            $remain_times = $times_limit - $user_times;
            if($remain_times < 0){
                $remain_times = 0;
            }
        }else{
            $remain_times = -1;
        }

        $result['remain_times'] = $remain_times;

        $this->success(1,$result);
    }

    //匹配
    //做防止重复处理，参照荔枝
    public function pipei(){

        //首页匹配功能开关
        $index_pipei_switch = config('site.index_pipei_switch');
        if($index_pipei_switch != 1){
            $this->error('匹配功能维护中,请稍后再试');
        }

        //缓存，防重复
        $user_id = $this->auth->id;
        $user_id_redis = 'pipei_repeat_'.$user_id;
        $redis_ids = json_decode(Cache::get($user_id_redis),true);

        //首页匹配每天每人匹配次数
        $is_vip = $this->is_vip($this->auth->id);
        $times_limit = $is_vip == 1 ? config('site.pipei_oneday_vipuser_times') : config('site.index_pipei_oneday_user_times');

        $times_limit_redis = 'pipei_times_limit_'.$user_id;
        $user_times = Cache::get($times_limit_redis) ?: 0;

        if($times_limit > -1 && $user_times >= $times_limit){
            $this->error('今日已超匹配上限'.$times_limit.'次');
        }

        //where
        $where = [
            'user.id' => ['neq',$this->auth->id],
            'user.status' => 1,
            'user.is_active' => 1,
        ];

        //性别
        $gender = input('gender','all');
        if($gender != 'all'){
            $where['user.gender'] = $gender;
        }

        //排除黑名单的
        $where_black = [];
        $black_ids = Db::name('user_black')->where(['uid'=>$this->auth->id])->column('black_uid');
        if(!empty($black_ids)){
            $where_black['user.id'] = ['NOTIN',$black_ids];
        }

        //匹配一个
        $result = $this->pipei_action($redis_ids,$where,$where_black);

        //匹配不到，移除防重复
        if(!$result) {
            Cache::rm($user_id_redis);
            $redis_ids = [];
            $result = $this->pipei_action($redis_ids,$where,$where_black);
        }
        // 追加一个防重复
        if($result){
            if($redis_ids) {
                $redis_ids[] = $result;
            } else {
                $redis_ids = [$result];
            }
            Cache::set($user_id_redis,json_encode($redis_ids));

            //设置次数
            $second = strtotime(date('Y-m-d'))+86400 - time();
            Cache::set($times_limit_redis,$user_times+1,$second);
        }else{
            Cache::rm($user_id_redis);
        }

        $this->success(1,$result);
    }

    private function pipei_action($redis_ids,$where,$where_black){
        $where_op = [];
        if(!empty($redis_ids)){
            $where_op['user.id'] = ['NOTIN',$redis_ids];
        }

        $result = Db::name('user')->alias('user')
            //->join('user_active active' ,'user.id = active.user_id','LEFT')
            ->where($where)
            ->where($where_op)
            ->where($where_black)
            ->orderRaw('rand()')
            ->value('user.id');

        return $result;
    }
///////////////////////////////////
    public function test(){
        //缓存，防重复
        $user_id = $this->auth->id;
        $user_id_redis = 'pipei_repeat_'.$user_id;
        $redis_ids = json_decode(Cache::get($user_id_redis),true);
        dump($redis_ids);


        $times_limit_redis = 'pipei_times_limit_'.$user_id;
        $user_times = Cache::get($times_limit_redis) ?: 0;
        dump($user_times);
    }
    public function testrm(){
        $user_id = $this->auth->id;
        $user_id_redis = 'pipei_repeat_'.$user_id;
        Cache::rm($user_id_redis);

        $times_limit_redis = 'pipei_times_limit_'.$user_id;
        Cache::rm($times_limit_redis);
    }



}