gonghuixiangqin/application/api/controller/Index.php

<?php


namespace app\api\controller;

use AlibabaCloud\DBFS\V20200418\DbfsRecord;
use app\common\model\Article;
use app\common\model\ArticleCate;
use app\common\model\GoodsCate;
use app\common\model\Goods;
use app\common\model\GoodsNumber;
use app\common\model\Order;
use app\common\model\Banner;
use app\common\model\User;
use app\common\controller\Api;
use app\common\model\UserForm;
use app\store\controller\Video;
use think\Exception;
use think\facade\Validate;
use think\Db;

/**
 * @title 首页
 * @controller Index
 */
class Index extends Api
{


    /**
     * @title 首页banner
     * @desc 首页banner
     * @url /api/Index/banner_list
     * @method POST
     * @tag 基础
     */
    public function banner_list(){
        $result = Banner::BannerList();
        $this->success($result['msg'],$result['data']);
    }
    public function text(){
        print_r(getConfig('tuijian'));die;
//        $sta_week = date("Y-m-d H:i:s", mktime(0,0,0,date("m"),date("d")-date("w")+1,date("Y")));    //2020-03-09 00:00:00
//        $end_week = date("Y-m-d H:i:s", mktime(0,0,0,date("m"),date("d")-date("w")+7,date("Y")));    //2020-03-09 00:00:00
//        $weeek_regiz = Db::name('store_member')->whereBetween('create_at',[$sta_week,$end_week])->fetchSql()->count();
//        print_r($weeek_regiz);
//        $userId = 9;
//        $list = Db::name('store_member_interested')
//            ->alias('i')
//            ->join('store_member m', 'm.id=i.i_id')
////            ->join('store_area a', 'm.province_id=a.id')
//            ->where('mid', 9)
//            ->field('i_id,nickname,age,headimg')
//            ->select();
//        print_r($list);die;
        $pr = av_status(8);
//        $use =  Db::name('store_member')->where('id',9)->find();
//        $url = 'https://xiangqinim.zhousi.hdlkeji.com/addons/fastim/api.user/createUser?username='.$use['nickname'].'&avatar='.$use['nickname'].'&id='.$userId;
//        curlRequest($url);
    }
    /**
     * 首页公告
     */
    public function notice(){
        $mid = $this->check_login();
        $sex = Db::name('store_member')->where('id',$mid)->value('sex');
        if($sex==1) {
            $p_sex = 2;
        }
        else{
            $p_sex = 1;
        }
        $notice = Db::name('store_notice')->order('id','DESC')->find();
        unset($notice['is_deleted']);
        $ids = Db::name('store_recommend')->where('m_id',$mid)->find();
        if(empty($ids['tuijian'])){
            $member = [];
        }
        else {
            $time_a = time() - $ids['createtime'];
            $time_b = 86400 * getConfigValue('tuijian');
            if ($time_a >= $time_b) {
                $this->save_recommend($mid, $p_sex);
                $ids = Db::name('store_recommend')->where('m_id', $mid)->find();

            }
            $u_ids = explode(',', $ids['tuijian']);
            $member = Db::name('store_member')->whereIn('id', $u_ids)->field('id,sex,nickname,headimg,im_id')->select();


        }
//        $member = Db::name('store_member')->where('sex','=',$p_sex)->where('vip_level','=',1)->whereIn('status','1,3,4')->orderRaw('rand()')->limit(3)->field('id,sex,nickname,headimg,im_id')->select();
        $video = Db::name('store_video')->where('is_deleted',0)->orderRaw('rand()')->limit(3)->field('id,title,video_url,show_image,video_time')->select();
        $article = Db::name('store_article')->where('is_deleted',0)->order('id','DESC')->field('id,title,content,show_image,subtitle')->limit(3)->select();
        $this->success('首页数据',['notice' => $notice,'member'=>$member,'video'=>$video,'article'=>$article]);
    }

    /**
     * 视频列表
     */
    public function videolist(){
        $listRows = input('listRows','10');
        $page = input('page','1');
        $key = input('title');
        $where = [];
        if(isset($key)&&$key){
            $where[] = ['title','like','%'.$key.'%'];
        }
        $video = Db::name('store_video')
            ->where($where)
            ->where('is_deleted',3)
           ->field('id,title,video_url,create_at,show_image,video_time')
            ->order('id','DESC')
            ->paginate($listRows,'',['page'=>$page]);
        $this->success('首页数据',$video);

    }
    public function article_class(){
        $class = Db::name('store_article_class')->where('is_deleted','=',0)->field('id,title')->select();
        $this->success('文章分类',$class);
    }
    /**
     * 文章列表
     */
    public function articlelist(){
        $listRows = input('listRows','10');
        $page = input('page','1');
        $key = input('title');

        $where = [];
        if(isset($key)&&$key){
            $where[] = ['title','like','%'.$key.'%'];
        }

        $video = Db::name('store_article')
            ->where($where)
            ->where('is_deleted',0)
            ->field('id,title,show_image,create_at,subtitle,type')
            ->order('id','DESC')
            ->paginate($listRows,'',['page'=>$page]);
        $this->success('首页数据',$video);

    }
    /**
     * 文章详情
     */
    public function articlederail(){
        $id = input('id');
        $article = Db::name('store_article')
            ->where('id',$id)
            ->find();
        unset($article['is_deleted']);

        $this->success('首页数据',$article);

    }
    /**
     * 注册用户
     */
    public function registered_user(){
        $this->check_login();
        $page = input('page',1);
        $page_num = input('page_num',6);
        $age_max = input('age_max');
        $age_min = input('age_min');
        $nature = input('nature');
        $education = input('education');
        $sex = input('sex');

        $where = [];
        if(isset($age_max)&&isset($age_min)) {
            if (!empty($age_max) && !empty($age_min)) {
                $where[] = ['age', 'between', [$age_min, $age_max]];
            }
        }
        if(isset($nature)) {
            if (!empty($nature)) {
                $where[] = ['nature', 'in', $nature];
            }
        }
        if(isset($education)) {
            if (!empty($education)) {
                $where[] = ['education', 'in', $education];
            }
        }
        if(isset($sex)) {
            if (!empty($sex)) {
                $where[] = ['sex', '=', $sex];
            }
        }
        $member = Db::name('store_member')
            ->where('vip_level',0)
            ->where($where)
            ->order('id','DESC')
            ->field('id,nickname,sex,height,province_id,age,headimg,vip_level,im_id')
            ->paginate($page_num,'',['page'=>$page]);
        $member= $member->items();
        foreach ($member as $k=>$v){
            $member[$k]['province_id'] = Db::name('store_area')->where('id',$member[$k]['province_id'])->value('shortname');
        }

        $this->success('注册用户',$member);

    }
    /**
     * 认证用户
     */
    public function certified_user(){
        $this->check_login();
        $page = input('page',1);
        $page_num = input('page_num',6);
        $age_max = input('age_max');
        $age_min = input('age_min');
        $nature = input('nature');
        $education = input('education');
        $sex = input('sex');
        $level = input('level','');

        $where = [];
        if(isset($age_max)&&isset($age_min)) {
            if (!empty($age_max) && !empty($age_min)) {
                $where[] = ['age', 'between', [$age_min, $age_max]];
            }
        }
        if(isset($nature)) {
            if (!empty($nature)) {
                $where[] = ['nature', 'in', $nature];
            }
        }
        if(isset($education)) {
            if (!empty($education)) {
                $where[] = ['education', 'in', $education];
            }
        }
        if(isset($sex)) {
            if (!empty($sex)) {
                $where[] = ['sex', '=', $sex];
            }
        }
        if(isset($level)) {
            if ($level!='') {
                $where[] = ['vip_level', '=', $level];
            }
        }

        $member = Db::name('store_member')
            ->whereIn('vip_level','0,1')
            ->where($where)
            ->order('id','DESC')
            ->field('id,nickname,sex,height,area_id,age,headimg,vip_level,im_id')
            ->paginate($page_num,'',['page'=>$page]);
        $member= $member->items();
        foreach ($member as $k=>$v){
            $member[$k]['province_id'] = Db::name('store_area')->where('id',$member[$k]['area_id'])->value('shortname');
        }

        $this->success('认证用户',$member);

    }
    /**
     * 工作性质
     */
    public function WorkNature(){
        $nature = Db::name('store_work_nature')->where('is_deleted',0)->field('id,name')->select();
        $this->success('工作性质',$nature);
    }
    /*
     * 智能匹配
     */
    public function Intelligent(){
        $user_id =  $this->check_login();;
        $data = input();
        $sex = Db::name('store_member')->where('id',$user_id)->value('sex');
        if($sex==1) {
            $p_sex = 2;
        }
        else{
            $p_sex = 1;
        }
        $add_data=[
            'age'=>$data['age_min'].'-'.$data['age_max'],
            'education'=>$data['education'],
            'height'=>$data['height_min'].'-'.$data['height_max'],
            'income' => $data['income_min'].'-'.$data['income_max'],
            'nature'=>$data['nature'],
            'area_id'=>$data['area_id'],
        ];
        Db::name('store_marriage')->insert($add_data);
        $where = [];
        if($data['age_min']&&$data['age_max']&&$data['nature']&&$data['education']&&$data['height_min']&&$data['height_max']&&$data['income_min']&&$data['income_max']&&$data['area_id']){
            $where[] = ['age','between',[$data['age_min'],$data['age_max']]];
            $where[] = ['nature','=',$data['nature']];
            $where[] = ['education','=',$data['education']];
            $where[] = ['height','between',[$data['height_min'],$data['height_max']]];
            $where[] = ['income','between',[$data['income_min'],$data['income_max']]];
            $where[] = ['area_id','=',$data['area_id']];
            $member = Db::name('store_member')
                ->where('sex',$p_sex)
                ->where('is_deleted',1)
                ->where($where)
                ->field('id,nickname,sex,height,province_id,age,headimg')
                ->select();
            foreach ($member as $k=>$v){
                $member[$k]['province_id'] = Db::name('store_area')->where('id',$member[$k]['province_id'])->value('shortname');
            }
            $this->success('匹配结果',$member);
        }
        else{
            $this->error('筛选信息不能为空');
        }

    }
    /**
     * 三区九县
     */
    public function linyi(){
        $area = Db::name('store_area')->where('pid','=',1479)->field('id,name')->select();
        $this->success('三区九县',$area);
    }
    /**
     * 举报类型
     */
    public function report_problem(){
        $list = Db::name('store_report_problem')->where('is_deleted',0)->field('id,title')->select();
        $this->success('举报类型',$list);
    }
    /**
     * 我要举报uuid举报
     */
    public function report(){
        $mid  = $this->check_login();
//        $this->check_login()

        $data = input();
        $r_id = Db::name('store_member')->where('vip_number',$data['uuid'])->value('id');
        if(empty($r_id)){
            $this->error('填写正确要举报人的会员ID');
        }
        if(empty($data['type'])){
            $this->error('填写举报类型不能为空');
        }
        $p_name = Db::name('store_report_problem')->where('id',$data['type'])->value('title');
        if(empty($data['content'])){
            $this->error('填写举报内容不能为空');
        }
        if(empty($data['r_images'])){
            $this->error('填写举报图片不能为空');
        }
        $insert = [
            'm_id'=>$r_id,
            'r_id'=>$mid,
            'p_id'=>$data['type'],
            'p_name'=>$p_name,
            'r_content'=>$data['content'],
            'r_images'=>$data['r_images'],
            'reject'=>'',
            'status'=>1,
            'is_deleted'=>0,
            'create_at'=>date('Y-m-d H:i:s')
        ];

        Db::startTrans();
        try {
            $is_have = Db::name('store_report')->where(array('m_id'=>$r_id,'r_id'=>$mid))->find();
            if($is_have){
                Db::name('store_report')->where('id',$is_have['id'])->update($insert);
            }
            else {
                Db::name('store_report')->insert($insert);
            }
            Db::commit();
        }catch (Exception $e) {
            Db::rollback();
            $this->error('举报未成功，重新举报');
        }
        $this->success('举报成功，等待结果');


    }
    /**
     * 我要举报指定用户举报
     */
    public function user_report(){
        $mid  = $this->check_login();
//        $this->check_login()

        $data = input();
        if(empty($data['type'])){
            $this->error('填写举报类型不能为空');
        }
        $p_name = Db::name('store_report_problem')->where('id',$data['type'])->value('title');
        if(empty($data['content'])){
            $this->error('填写举报内容不能为空');
        }
        if(empty($data['r_images'])){
            $this->error('填写举报图片不能为空');
        }
        $insert = [
            'm_id'=>$data['r_id'],
            'r_id'=>$mid,
            'p_id'=>$data['type'],
            'p_name'=>$p_name,
            'r_content'=>$data['content'],
            'r_images'=>$data['r_images'],
            'reject'=>'',
            'status'=>1,
            'is_deleted'=>0,
            'create_at'=>date('Y-m-d H:i:s')
        ];

        Db::startTrans();
        try {
            $is_have = Db::name('store_report')->where(array('m_id'=>$data['r_id'],'r_id'=>$mid))->find();
            if($is_have){
                Db::name('store_report')->where('id',$is_have['id'])->update($insert);
            }
            else {
                Db::name('store_report')->insert($insert);
            }
            Db::commit();
        }catch (Exception $e) {
            Db::rollback();
            $this->error('举报未成功，重新举报');
        }
        $this->success('举报成功，等待结果');


    }
    public function banner(){
        $list = Db::name('store_banner')->where('is_deleted',0)->field('show_image')->select();
        $this->success('轮播图',$list);
    }



    public function xcxtuisong($uid){
        $openid = Db::name('third')->where('user_id',2)->field('openid')->find();
        //请求access_token
        $getToken = file_get_contents("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=wx4c96fac89070fe7a&secret=36edc36c9ec2fb309fd90c9a9e719560");
        //json解析返回数据
        $getToken = json_decode($getToken);
        //拿到access_token
        $token = $getToken ->{'access_token'};

        // 获取请求路径
        //sprintf=php方法

        //推送消息url
        $msgUrl = 'https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token='.$token;


        //订阅消息的模板消息
        $msgObj =	[
            //模板属性
            "thing1"=> [
                //模板属性值
                "value"=> "339208499"
            ],
            "thing3"=> [
                "value"=> "17503008888"
            ],
            "date2"=> [
                "value"=> "120"
            ],

        ];

        //请求的data数据
        $msgData = [
            'access_token'=> $token,
            'touser'=> $openid['openid'],
            'template_id'=> '6gBL8zRZ3YKjA7iNXpeS7SBguNKNQM8hmXrHK3VWr9M',
            'data'=> $msgObj
        ];
        //curl_post自定封装post请求
        curl_post($msgUrl,$msgData);
    }

    /**
     * @return void
     * 情感咨询
     */
    public function emotion(){
        $mid  = $this->check_login();
        $problem = input('problem','');
        if($problem==''){
            $this->error('咨询问题不能为空');
        }
        $add_data = [
            'm_id'=>$mid,
            'problem'=>$problem,
            'create_time'=>date('Y-m-d H:i:s')
        ];
        Db::startTrans();
        try {
            $res = Db::name('store_emotional_counseling')->insertGetId($add_data);
            $add_data_new = [
                'e_id'=>$res,
                'type'=>1,
                'answer'=>$problem,
                'create_time'=>date('Y-m-d H:i:s')
            ];
            Db::name('store_answer_log')->insert($add_data_new);
            Db::commit();
        }catch (Exception $e){
            $this->error('提交失败联系管理人员');
        }
        $this->success('情感咨询已提交，等待专员回复');
    }

    /**
     * @return void
     * 持续回复
     */
    public function answer(){
        $this->check_login();
        $eid = input('e_id');
        $answer = input('answer');
        $add_data_new = [
            'e_id'=>$eid,
            'type'=>1,
            'answer'=>$answer,
            'create_time'=>date('Y-m-d H:i:s')
        ];
        Db::startTrans();
        try {
            Db::name('store_answer_log')->insert($add_data_new);
            Db::name('store_emotional_counseling')->where('id',$eid)->update(['status'=>1]);
            Db::commit();
        }catch (Exception $e){
            $this->error('发送失败，联系管理人员');
        }
        $this->success('发送成功，等待专员回复');

    }

    /**
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * 问答记录
     */
    public function answer_log(){
        $this->check_login();
        $eid = input('e_id');
        $list = Db::name('store_answer_log')->where('e_id',$eid)->order('id','asc')->field('type,answer,create_time')->select();
        $this->success('问答记录',$list);
    }

    /**
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * 情感咨询记录
     */
    public function emotion_list(){
       $mid =  $this->check_login();
       $list = Db::name('store_emotional_counseling')->where('m_id',$mid)->where('is_deleted','=',0)->field('id,problem,create_time')->select();
       $this->success('情感咨询记录',$list);

    }
    public function delete_emotion(){
        $this->check_login();
        $eid = input('e_id');
        Db::name('store_emotional_counseling')->where('id',$eid)->update(['is_deleted'=>1]);
        $this->success('情感咨询记录已删除');
    }

    /**
     * @return void
     * @throws Exception
     * @throws \think\exception\PDOException
     * 基础信息
     */
    public function member_basic(){
        $uid = $this->check_login();
        $ceshi = input('type');
        $nickname = input('nickname');
        $height =input('height');
        $weight = input('weight');
        $area_id = input('area_id');
        $working = input('working');
        $username = input('username');
        $sex = input('sex');
        $ID_car = input('ID_car');
        $age = input('age');
        $education = input('education');
        $phone = input('phone');
        $code  = input('code');
        $headimg = input('headimg');
        if(!$code||!$phone||!$username||!$ID_car||!$age||!$education){
            $this->error('参数不能为空');
        }
        $time = time()-60;
        $sms = Db::name('store_sms')->where(['mobile' => $phone, 'event' => 'yzm'])
            ->where('createtime','>',$time)
            ->order('id', 'DESC')
            ->find();

        if (!$sms || $sms['code'] != $code) $this->error('短信验证码不正确！');

        $data = [
            'working'=>$working,
            'username'=>$username,
            'sex'=>$sex,
            'ID_car'=>$ID_car,
            'age'=>$age,
            'education'=>$education,
            'phone'=>$phone,
            'state'=>0,
            'create_at'=>date('Y-m-d H:i:s')
        ];

        if(isset($ceshi)){
            $data = [
                'nickname'=>$nickname,
                'username'=>$username,
                'sex'=>$sex,
                'ID_car'=>$ID_car,
                'age'=>$age,
                'education'=>$education,
                'height'=>$height,
                'weight'=>$weight,
                'area_id'=>$area_id,
                'phone'=>$phone,
                'headimg'=>$headimg,
                'state'=>0,
                'create_at'=>date('Y-m-d H:i:s')
            ];
        }
        $is_have  = Db::name('store_member_basic')->where('mid',$uid)->find();
        if($is_have){
            Db::name('store_member_basic')->where('id',$is_have['id'])->update($data);
        }
        else{
            $data['mid']=$uid;
            Db::name('store_member_basic')->insert($data);
        }
        $this->success('基础信息提已提交等待审核');
    }
    /**
     * 合作商家列表
     */
    public function business(){
        $page = input('page',1);
        $page_num = input('page_num',5);
        $list = Db::name('store_business')
            ->order('id','DESC')
            ->paginate($page_num,'',['page'=>$page]);
        $this->success('合作商家列表',$list);

    }
    /*
     * 定时任务
     */
    public function disable_time(){
        $time = time();
        $list = Db::name('store_member')->where('vip_level',2)->where('disable_time','<',$time)->select();
        foreach ($list as &$v){
            Db::name('store_member')->where('id',$v['id'])->update(['vip_level'=>1,'disable_time'=>0]);
        }
    }
    /*
     * 会员推荐
     */
    public function recommend(){
        $user_id =  43;
        $ids = Db::name('store_recommend')->where('m_id',$user_id)->find();
        if(empty($ids['tuijian'])){
            $this->error('没有数据');
        }
        $time_a = time()-$ids['createtime'];
        $time_b = 86400*getConfigValue('tuijian');
        if($time_a>=$time_b){
            $sex = Db::name('store_member')->where('id',$user_id)->value('sex');
            if($sex==1) {
                $p_sex = 2;
            }
            else{
                $p_sex = 1;
            }
            $this->save_recommend($user_id,$p_sex);
            $ids = Db::name('store_recommend')->where('m_id',$user_id)->find();

        }
        $u_ids = explode(',',$ids['tuijian']);
        $list=[];
        foreach ($u_ids as $k=>$v){
            $list[$k]= Db::name('store_member')->where('id',$u_ids[$k])->field('id,sex,nickname,headimg,im_id')->select();

        }
        $this->success('推荐会员',$list);
    }
    public function save_recommend($user_id,$p_sex)
    {
        $data = Db::name('store_member_appeals')->where('mid', $user_id)->find();
        if ($data) {
            $education = json_decode(education($data['education']));
            $education = implode(',',$education);
            $height_a = $data['height']-2;
            $height_b = $data['height']+2;
            $where[] = ['age', 'between', [$data['age_min'], $data['age_max']]];
            $where[] = ['education', 'in', $education];
            $where[] = ['weight', '<', $data['weight']];
            $where[] = ['height', 'between', [$height_a,  $height_b]];
            $where[] = ['income', '>=', $data['income']];
            $where[] = ['area_id', '=', $data['area_id']];
            $member = Db::name('store_member')
                ->where('sex', $p_sex)
                ->where('is_deleted', 1)
                ->where($where)
                ->orderRaw('rand()')
                ->limit(3)
                ->field('id')
                ->select();
            $array = [];
            foreach ($member as $k => $v) {
                $array[$k] = $member[$k]['id'];
            }

            $tuijian = implode(',', $array);


            $is_have = Db::name('store_recommend')->where('m_id', $user_id)->find();
            if ($is_have) {
                Db::name('store_recommend')->where('m_id', $user_id)->update(['tuijian' => $tuijian, 'createtime' => time()]);
            } else {
                Db::name('store_recommend')->insert(['m_id' => $user_id, 'tuijian' => $tuijian, 'createtime' => time()]);
            }
        }
    }
    public function notice1(){
        $user_id = 43;
        $p_sex = 1;

        $data = Db::name('store_member_appeals')->where('mid', $user_id)->find();
        if ($data) {
            $education = json_decode(education($data['education']));
            $education = implode(',',$education);
            $height_a = $data['height']-2;
            $height_b = $data['height']+2;
            $where[] = ['age', 'between', [$data['age_min'], $data['age_max']]];
            $where[] = ['education', 'in', $education];
            $where[] = ['weight', '<', $data['weight']];
            $where[] = ['height', 'between', [$height_a,  $height_b]];
            $where[] = ['income', '>=', $data['income']];
            $where[] = ['area_id', '=', $data['area_id']];
            $member = Db::name('store_member')
                ->where('sex', $p_sex)
                ->where('is_deleted', 1)
                ->where($where)
                ->orderRaw('rand()')
                ->limit(3)
                ->field('id')
                ->select();
            $array = [];
            foreach ($member as $k => $v) {
                $array[$k] = $member[$k]['id'];
            }

            $tuijian = implode(',', $array);


            $is_have = Db::name('store_recommend')->where('m_id', $user_id)->find();
            if ($is_have) {
                Db::name('store_recommend')->where('m_id', $user_id)->update(['tuijian' => $tuijian, 'createtime' => time()]);
            } else {
                Db::name('store_recommend')->insert(['m_id' => $user_id, 'tuijian' => $tuijian, 'createtime' => time()]);
            }
        }
    }
}