bq_admin/application/api/controller/Index.php

<?php


namespace app\api\controller;

use app\common\library\Common;
use app\common\model\Config;
use app\common\model\ElectPool;
use app\common\model\SearchHistory;
use app\common\model\User;
use app\common\controller\Api;
use app\common\model\UserWantKnow;
use app\common\model\UserWantKnowRecord;
use think\Db;
use think\facade\Validate;


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

    /**
     * 创建、编辑互选池
     */
    public function create_edit_elect_pool(){
        $this->check_login();
        $data = input();
        $pool_id = intval(input('pool_id'));  //互选池id(有则修改)
//        if (!$data['name'] || !$data['education'] || !$data['province'] || !$data['city'] || !$data['area'] || !$data['birth_start'] || !$data['birth_end'] || !$data['group_number'] || !$data['type'] ||
//            !in_array($data['type'],array('1','2')) || !$data['introduction'] || !$data['imgs']){
//            $this->error('参数错误');
//        }
//        if ($data['type']==2){
//            if (!$data['password']){
//                $this->error('密码为空');
//            }
//            $data['password'] = md5($data['password']);
//        }else{
//            $data['password'] = '';
//        }

        unset($data['pool_id']);
        $data['is_audit'] = 1;
        $data['education'] = implode(',',$data['education']);
        $wx_check_name = $this->wx_check($data['name'],2);
        if ($wx_check_name['errcode']=='87014'){
            $this->error('含有违规文字');
        }
        $wx_check = $this->wx_check($data['introduction'],2);
        if ($wx_check['errcode']=='87014'){
            $this->error('含有违规文字');
        }
        $result = ElectPool::createElectPool($data,$pool_id);
        if ($result['code']){
            $this->success($result['msg'],$result['data']);
        }else{
            $this->error($result['msg']);
        }
    }



    /**
     * 获取置顶推荐用户列表
     */
    public function top_user(){
        $city = input('city');   //市
        $result = User::topUser($city);
        $this->success($result['msg'],$result['data']);
    }


    /**
     * 首页推荐嘉宾列表
     */
    public function recommended_user(){
        $city = input('city');   //市
        $result = User::recommendedUser($city);
        $this->success($result['msg'],$result['data']);
    }



    /**
     * 获取单身广场数据
     */
    public function single_user(){
        $this->check_login();
        $city = input('city');   //市
        $keywords = input('keywords');  //关键词
        $Nowpage = input('page',1);
        $limits = input("limit",10);
        $result = User::singleUser($city,$keywords,$Nowpage,$limits);
        $this->success($result['msg'],$result['data']);
    }


    /**
     * 获取互选池列表
     */
    public function pool_list(){
        $Nowpage = input('page') ? input('page') : 1;
        $limits = input("limit") ? input("limit") : 10;
        $city = input('city');   //市
        $keywords = input('keywords');  //关键词
        $result = ElectPool::poolList($city,$keywords,$Nowpage,$limits);
        //插入搜索记录
        if ($keywords)
            SearchHistory::setKeyword($keywords);
        $this->success($result['msg'],$result['data']);
    }

    /**
     * 互选池列表
     */
    public function my_create_join_pool(){
        $this->check_login();
        $Nowpage = input('page') ? input('page') : 1;
        $limits = input("limit") ? input("limit") : 10;
        $city = input('city');   //市
        $result = ElectPool::myCreateJoinPool($city,$Nowpage,$limits);
        $this->success($result['msg'],$result['data']);
    }


    /**
     * 获取互选池资料
     */
    public function pool_detail(){
        $pool_id = intval(input('pool_id'));  //互选池id
        if (!$pool_id) $this->error('互选池ID为空！');
        $result = ElectPool::poolDetail($pool_id);
        if ($result['code']){
            $this->success($result['msg'],$result['data']);
        }else{
            $this->error($result['msg']);
        }
    }

    /**
     * 进入互选池
     */
    public function into_pool(){
        $this->check_login();
        $pool_id = intval(input('pool_id'));  //互选池id
        $password = intval(input('password'));  //密码
        if (!$pool_id) $this->error('互选池ID为空！');
        $result = ElectPool::intoPool($pool_id,$password);
        if ($result['code']){
            $this->success($result['msg'],$result['data']);
        }else{
            $this->error($result['msg']);
        }
    }

    /**
     * 获取互选池异性用户列表
     */
    public function pool_user_list(){
        $this->check_login();
        $pool_id = intval(input('pool_id'));  //互选池id
        if (!$pool_id) $this->error('互选池ID为空！');
        $Nowpage = input('page') ? input('page') : 1;
        $limits = input("limit") ? input("limit") : 10;
        $result = ElectPool::poolUserList($pool_id,$Nowpage,$limits);
        if ($result['code']){
            $this->success($result['msg'],$result['data']);
        }else{
            $this->error($result['msg']);
        }
    }


    /**
     * 退出互选池
     */
    public function exit_pool(){
        $this->check_login();
        $pool_id = intval(input('pool_id'));  //互选池id
        if (!$pool_id) $this->error('互选池ID为空！');
        $result = ElectPool::exitPool($pool_id);
        if ($result['code']){
            $this->success($result['msg'],$result['data']);
        }else{
            $this->error($result['msg']);
        }
    }


    /**
     * 查看用户资料
     */
    public function sel_user(){
        //$this->check_login();
        $user_id = intval(input('user_id')); //用户ID
        if (!$user_id) $this->error('用户ID为空！');
        $result = ElectPool::SelUser($user_id);
        if ($result['code']){
            $this->success($result['msg'],$result['data']);
        }else{
            $this->error($result['msg']);
        }
    }


    /**
     * @title 查看申请
     * @desc 查看申请
     * @url /api/Index/sel_apply
     * @method POST
     * @tag 基础
     * @header
     * @param  name:user_id type:int require:1 desc:查看的用户ID
     * @return name:type type:int desc:1:申请者2：收到者 leave_message:留言 state:
     * @return name:info@id type:string desc:申请的主键ID
     * @return name:info@leave_message type:string desc:留言
     * @return name:info@state type:int desc:状态1:申请中2:同意3:不通过4:不合适5：终止申请
     * @return name:info@list@id type:int desc:记录ID
     * @return name:info@list@content type:string desc:内容
     * @return name:info@list@create_at type:date desc:时间
     */
    public function sel_apply(){
        $this->check_login();
        $user_id = intval(input('user_id')); //用户ID
        if (!$user_id) $this->error('用户ID为空！');
        $result = ElectPool::SelApply($user_id);
        if ($result['code']){
            $this->success($result['msg'],$result['data']);
        }else{
            $this->error($result['msg']);
        }
    }

    /**
     * @title 终止申请
     * @desc 终止申请
     * @url /api/Index/termination_apply
     * @method POST
     * @tag 基础
     * @header
     * @param  name:id type:int require:1 desc:申请的主键ID
     */
    public function termination_apply(){
        $this->check_login();
        $id = intval(input('id')); //申请ID
        if (!$id) $this->error('id为空！');
        $result = ElectPool::TerminationApply($id);
        if ($result['code']){
            $this->success($result['msg'],$result['data']);
        }else{
            $this->error($result['msg']);
        }
    }


    /**
     * @title 同意申请
     * @desc 同意申请
     * @url /api/Index/agree_apply
     * @method POST
     * @tag 基础
     * @header
     * @param  name:id type:int require:1 desc:申请的主键ID
     */
    public function agree_apply(){
        $this->check_login();
        $id = intval(input('id')); //申请ID
        if (!$id) $this->error('id为空！');
        $result = ElectPool::AgreeApply($id);
        if ($result['code']){
            $this->success($result['msg'],$result['data']);
        }else{
            $this->error($result['msg']);
        }
    }

    /**
     * @title 拒绝申请
     * @desc 拒绝申请
     * @url /api/Index/refuse_apply
     * @method POST
     * @tag 基础
     * @header
     * @param  name:id type:int require:1 desc:申请的主键ID
     * @param  name:refused_why type:string require:1 desc:拒绝理由
     */
    public function refuse_apply(){
        $this->check_login();
        $id = intval(input('id')); //申请ID
        if (!$id) $this->error('id为空！');
        $refused_why = input('refused_why'); //拒绝理由
        if (!$refused_why) $this->error('拒绝理由为空！');
        $result = ElectPool::RefuseApply($id,$refused_why);
        if ($result['code']){
            $this->success($result['msg'],$result['data']);
        }else{
            $this->error($result['msg']);
        }
    }


    /**
     * @title 屏蔽用户
     * @desc 屏蔽用户
     * @url /api/Index/shielding_know_user
     * @method POST
     * @tag 基础
     * @header
     * @param  name:to_user_id type:int require:1 desc:被屏蔽的用户ID
     * @param  name:switch type:int require:1 desc:1:屏蔽2:取消屏蔽
     */
    public function shielding_know_user(){
        $this->check_login();
        $to_user_id = input('to_user_id');  //被屏蔽的用户ID
        if (!$to_user_id) $this->error('参数错误');
        $switch = intval(input('switch',1));  //1:屏蔽2:取消屏蔽
        $result = ElectPool::shieldingKnowUser($to_user_id,$switch);
        if ($result['code']){
            $this->success($result['msg']);
        }else{
            $this->error($result['msg']);
        }
    }


    /**
     * @title 想认识
     * @desc 想认识
     * @url /api/Index/want_know
     * @method POST
     * @tag 基础
     * @header
     * @param  name:user_id type:int require:1 desc:想认识的用户id
     * @param  name:pool_id type:string require:0 desc:互选池ID
     * @param  name:leave_message type:string require:0 desc:留言
     */
    public function want_know(){
        $this->check_login();
        $user_id = intval(input('user_id'));  //用户id
        if (!$user_id) $this->error('用户ID为空！');
        $pool_id = intval(input('pool_id'));  //互选池id
        $leave_message = input('leave_message');  //留言
//        if (!$pool_id) $this->error('互选池ID为空！');
        $result = ElectPool::wantKnow($user_id,$pool_id,$leave_message);
        if ($result['code']){
            $this->success($result['msg']);
        }else{
            $this->error($result['msg']);
        }
    }

    /**
     * @title 不合适
     * @desc 不合适
     * @url /api/Index/dont_fit
     * @method POST
     * @tag 基础
     * @header
     * @param  name:user_id type:int require:1 desc:不合适的用户id
     */
    public function dont_fit(){
        $this->check_login();
        $user_id = intval(input('user_id'));  //用户id
        if (!$user_id) $this->error('用户ID为空！');
        $result = ElectPool::DontFit($user_id);
        if ($result['code']){
            $this->success($result['msg']);
        }else{
            $this->error($result['msg']);
        }
    }


    /**
     * @title 星标聊天开关
     * @desc 星标聊天开关
     * @url /api/Index/set_star
     * @method POST
     * @tag 基础
     * @header
     * @param  name:user_id type:int require:1 desc:用户id
     * @param  name:switch type:int require:1 desc:1:开2:关
     */
    public function set_star(){
        $this->check_login();
        $user_id = intval(input('user_id'));  //用户id
        if (!$user_id) $this->error('用户ID为空！');
        $switch = intval(input('switch',1));  //1:开 2：关
        $result = ElectPool::SetStar($user_id,$switch);
        if ($result['code']){
            $this->success($result['msg']);
        }else{
            $this->error($result['msg']);
        }
    }





    /**
     * 积分获取联系方式
     */
    public function integral_contact(){
        $this->check_login();
        $user_id = intval(input('user_id'));  //用户id
        if (!$user_id) $this->error('用户ID为空！');
        $pool_id = intval(input('pool_id'));  //互选池id
//        if (!$pool_id) $this->error('互选池ID为空！');
        $result = ElectPool::integralContact($user_id,$pool_id);
        if ($result['code']){
            $this->success($result['msg']);
        }else{
            $this->error($result['msg']);
        }
    }

    /**
     * 群主解散互选池
     */
    public function dissolution_pool(){
        $this->check_login();
        $pool_id = intval(input('pool_id'));   //互选池ID
        if (!$pool_id) $this->error('互选池ID为空！');
        $result = ElectPool::dissolutionPool($pool_id);
        if ($result['code']){
            $this->success($result['msg']);
        }else{
            $this->error($result['msg']);
        }
    }

    /**
     * 群主移出互选池用户
     */
    public function remove_user(){
        $this->check_login();
        $pool_id = intval(input('pool_id'));   //互选池ID
        if (!$pool_id) $this->error('互选池ID为空！');
        $user_id = intval(input('user_id'));   //用户ID
        if (!$user_id) $this->error('用户ID为空！');
        $result = ElectPool::removeUser($pool_id,$user_id);
        if ($result['code']){
            $this->success($result['msg']);
        }else{
            $this->error($result['msg']);
        }
    }


    /**
     * 分享获得积分
     */
    public function share(){
        $this->check_login();
        $type = intval(input('type'));   //1:分享小程序  2：分享互选池  3：分享个人资料   4：分享其他人资料
        $link_id = input('link_id');    //关联的ID
        $result = ElectPool::share($type,$link_id);
        if ($result['code']){
            $this->success($result['msg'],$result['data']);
        }else{
            $this->error($result['msg']);
        }
    }

    /**
     * @title 举报用户
     * @desc 举报用户
     * @url /api/Index/report_user
     * @method POST
     * @tag 基础
     * @header
     * @param  name:pool_id type:int require:0 desc:互选池ID
     * @param  name:user_id type:int require:1 desc:被举报的用户ID
     * @param  name:item_type type:string require:1 desc:类型
     * @param  name:content type:string require:1 desc:内容
     * @param  name:imgs type:array require:1 desc:图片凭证数组
     */
    public function report_user(){
        $this->check_login();
        $pool_id = intval(input('pool_id'));   //互选池ID
//        if (!$pool_id) $this->error('互选池ID为空！');
        $user_id = intval(input('user_id'));   //用户ID
        if (!$user_id) $this->error('用户ID为空！');
        $item_type = input('item_type');  //类型
        if (!$item_type) $this->error('类型为空！');
        $content = input('content');  //内容
        if (!$content) $this->error('内容为空！');
        $imgs = input('imgs');  //凭证图片
        $result = ElectPool::reportUser($pool_id,$user_id,$item_type,$content,$imgs);
        if ($result['code']){
            $this->success($result['msg']);
        }else{
            $this->error($result['msg']);
        }
    }


    /**
     * 特权过期脚本
     */
    public function privilege_overdue(){
        User::privilegeOverdue();
    }


    /**
     * 每周五24后收藏卡清空
     */
    public function collection_empty(){
        User::collectionEmpty();
    }


    /**
     * 判断好友申请七天是否过期
     */
    public function apply_overdue(){
        User::applyOverdue();
    }


    /**
     * 判断禁用时间是否到期
     */
    public function disable_overdue(){
        User::disableOverdue();
    }

    /**
     * 晚上八点推荐单身广场
     */
    public function recommended(){
        User::recommended();
    }


    /**
     * 公众号推送消息
     */
    public function sendTemplateMsg(){
        $appid = Config::get_values('wechat_appid');
        $appsecret = Config::get_values('wechat_appsecret');
        $url = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=' . $appid . '&secret=' . $appsecret;
        $res = json_decode(file_get_contents($url),true);
        $access_token = $res['access_token'];
        //请求url
      //  $url = 'https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token='.$access_token;
        $url='https://api.weixin.qq.com/cgi-bin/message/wxopen/template/uniform_send?access_token='.$access_token;
//        $arr = array(
//            'touser'=>"oo7E85LrD0ovt7hbz4sZGrf-_flA",
//            'template_id'=>"j5yotQv2l58Bk3rfVPt9J4HEAd5L8NjKYv2Is6S3rE4",
//            'url'=>"http://www.baidu.com",
//            'data'=>array(
//                'first'=>array('value'=>'申请成功通知','color'=>"#173177"),
//                'keyword1'=>array('value'=>'互选猫','color'=>"#173177"),
//                'keyword2'=>array('value'=>date('Y-m-d H:i:s'),'color'=>"#173177"),
//                'remark'=>array('value'=>'备注','color'=>"#173177"),
//            )
//
//        );

        $arr=[
            'touser'=>"oo7E85LrD0ovt7hbz4sZGrf-_flA",
            'mp_template_msg'=>[
                "appid"=>"wxad3ed96c8ce52359",
                "template_id"=>"j5yotQv2l58Bk3rfVPt9J4HEAd5L8NjKYv2Is6S3rE4",
                "url"=>"http://www.baidu.com",
                'miniprogram'=>[
                    "appid"=>Config::get_values('wechat_appid')
                ],
                'data'=>[
                    'first'=>[
                        "value"=>'申请成功通知',
                        "color"=>"#173177"
                    ],
                    'keyword1'=>[
                        "value"=>'互选猫',
                        "color"=>"#173177"
                    ],
                    'keyword2'=>[
                        "value"=>date('Y-m-d H:i:s'),
                        "color"=>"#173177"
                    ],
                    'remark'=>[
                        "value"=>'备注',
                        "color"=>"#173177"
                    ]
                ]
            ],
        ];

        //将数组->json
        //汉字不转义
        $postJson = json_encode($arr,JSON_UNESCAPED_UNICODE) ;
        $res = self::curlPost($url,$postJson);
        print_r($res);
    }



    /**
     * 订阅消息发送
     */
    public function sendMessage(){
        $appid = Config::get_values('wechat_appid');
        $appsecret = Config::get_values('wechat_appsecret');
        $touser = 'oo7E85AVzyBul7w_8vh6vkfExrIY';
        $template_id = 'q_wRBSYSOCG037hNgcRXT6WPy-jM8HtqXla2i6NIrsc';
        $page = '/pages/my/index';
        $url = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=' . $appid . '&secret=' . $appsecret;

        $res = json_decode(file_get_contents($url),true);

        $access_token = $res['access_token'] ;

        //请求url
        $url = 'https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=' . $access_token ;
        //发送内容
        $data = [] ;

        //接收者（用户）的 openid
        $data['touser'] = $touser;

        $data['scene'] = rand(1,9);

        //所需下发的订阅模板id
        $data['template_id'] = $template_id ;

        //点击模板卡片后的跳转页面，仅限本小程序内的页面。支持带参数,（示例index?foo=bar）。该字段不填则模板无跳转。
        $data['page'] = $page ;


        //模板内容，格式形如 { "key1": { "value": any }, "key2": { "value": any } }
        $data['data'] = [
            "name1"=>[
                'value'=>'张三'
            ],
            "date2"=>[
                'value' => date("Y-m-d H:i:s")
            ],
            "thing3"=>[
                'value' => '通知'
            ],
        ];

        //跳转小程序类型：developer为开发版；trial为体验版；formal为正式版；默认为正式版
        $data['miniprogram_state'] = 'formal' ;

        print_r(self::curlPost($url,json_encode($data))) ;
    }


    //发送post请求
    static function curlPost($url,$data)
    {
        $ch = curl_init();
        $params[CURLOPT_URL] = $url;    //请求url地址
        $params[CURLOPT_HEADER] = FALSE; //是否返回响应头信息
        $params[CURLOPT_SSL_VERIFYPEER] = false;
        $params[CURLOPT_SSL_VERIFYHOST] = false;
        $params[CURLOPT_RETURNTRANSFER] = true; //是否将结果返回
        $params[CURLOPT_POST] = true;
        $params[CURLOPT_POSTFIELDS] = $data;
        curl_setopt_array($ch, $params); //传入curl参数
        $content = curl_exec($ch); //执行
        curl_close($ch); //关闭连接
        return $content;
    }


    /**
     * 环信注册
     */
    function huanxin_zhuce(){
        $param = array (
            "username" => 'ceshi',
            "password" => '88888888',
            "nickname" => '测试'
        );
       // $url = "https://a1.easemob.com/".huanxin_get_org_name()."/".huanxin_get_app_name()."/users";
        $url = "https://a1.easemob.com/1101210401193729/demo/users";
        $res = self::huanxin_curl_request($url, json_encode($param));
        $tokenResult =  json_decode($res, true);
        print_r($tokenResult);die;
        $tokenResult["password"]=$param["password"];
        return $tokenResult;
        $huanxin_uuid = $tokenResult["entities"][0]["uuid"];
        $huanxin_username = $tokenResult["entities"][0]["username"];
        $huanxin_password=$param["password"];
        if(!($huanxin_uuid&&$huanxin_username)){
            $this->ajaxReturn(array("sta"=>2,"msg"=>"注册失败,环信接口异常"));
        }
    }

    static function huanxin_curl_request($url, $body, $header = array(), $method = "POST") {
        array_push ( $header, 'Accept:application/json' );
        array_push ( $header, 'Content-Type:application/json' );
        $ch = curl_init ();
        curl_setopt ( $ch, CURLOPT_CONNECTTIMEOUT, 60 );
        curl_setopt ( $ch, CURLOPT_URL, $url );
        curl_setopt ( $ch, CURLOPT_RETURNTRANSFER, 1 );
        // curl_setopt($ch, $method, 1);

        switch (strtoupper($method)) {
            case "GET" :
                curl_setopt ( $ch, CURLOPT_HTTPGET, true );
                break;
            case "POST" :
                curl_setopt ( $ch, CURLOPT_POST, true );
                break;
            case "PUT" :
                curl_setopt ( $ch, CURLOPT_CUSTOMREQUEST, "PUT" );
                break;
            case "DELETE" :
                curl_setopt ( $ch, CURLOPT_CUSTOMREQUEST, "DELETE" );
                break;
        }

        curl_setopt ( $ch, CURLOPT_USERAGENT, 'SSTS Browser/1.0' );
        curl_setopt ( $ch, CURLOPT_ENCODING, 'gzip' );
        curl_setopt ( $ch, CURLOPT_SSL_VERIFYPEER, FALSE );
        curl_setopt ( $ch, CURLOPT_SSL_VERIFYHOST, 2 );
        if (isset ( $body {3} ) > 0) {
            curl_setopt ( $ch, CURLOPT_POSTFIELDS, $body );
        }
        if (count ( $header ) > 0) {
            curl_setopt ( $ch, CURLOPT_HTTPHEADER, $header );
        }
        $ret = curl_exec ( $ch );
        $err = curl_error ( $ch );
        curl_close ( $ch );
        if ($err) {
            return $err;
        }
        return $ret;
    }




    public function zhuce(){
//        $list = Db::name('UserWantKnow')
//            ->where('state',2)
//            ->group('to_user_id')
//            ->select();
//        foreach ($list as &$v){
//            //注册环信
//            $nickname = Db::name('User')->where('id',$v['to_user_id'])->value('nickname');
//            Common::huanxin_zhuce('huxuanmao-'.$v['to_user_id'],$nickname);
//        }
//        print_r($list);die;
        $list2 = Db::name('UserWantKnow')->where('state',2)->select();
        foreach ($list2 as &$v){
            Common::add_friend('huxuanmao-'.$v['user_id'],'huxuanmao-'.$v['to_user_id']);
        }
        //注册环信
        //Common::huanxin_zhuce('huxuanmao-2410','苹果籽');
    }




    public function test(){
        $user_id = input('user_id');
        $to_user_id = input('to_user_id');
        $data['user_id'] = $user_id;
        $data['to_user_id'] = $to_user_id;
        $data['pool_id'] = 0;
        $data['leave_message'] = '认识你';
        $data['integral'] = '0';
        $knowid = UserWantKnow::create($data);
        //记录
        UserWantKnowRecord::create(
            [
                'know_id'=>$knowid['id'],
                'user_id'=>$user_id,
                'content'=>'发出申请',
                'sort'=>1
            ]
        );

        UserWantKnowRecord::create(
            [
                'know_id'=>$knowid['id'],
                'user_id'=>$user_id,
                'content'=>'等待对方查看',
                'sort'=>2
            ]
        );

        UserWantKnowRecord::create(
            [
                'know_id'=>$knowid['id'],
                'user_id'=>$to_user_id,
                'content'=>'收到申请',
                'sort'=>1
            ]
        );

        echo 'success';
    }
}